From 82c97ddd5206ecbd662c8a111c2a907acb596186 Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 25 Feb 2025 22:17:00 -0800 Subject: [PATCH] remove unused --- weed/mq/client/sub_client/subscriber.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/weed/mq/client/sub_client/subscriber.go b/weed/mq/client/sub_client/subscriber.go index fa4335232..911f3a318 100644 --- a/weed/mq/client/sub_client/subscriber.go +++ b/weed/mq/client/sub_client/subscriber.go @@ -6,7 +6,6 @@ import ( "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" "google.golang.org/grpc" "sync" - "time" ) type SubscriberConfiguration struct { @@ -22,7 +21,6 @@ type ContentConfiguration struct { Topic topic.Topic Filter string PartitionOffsets []*schema_pb.PartitionOffset - DefaultStartTime time.Time } type OnDataMessageFn func(m *mq_pb.SubscribeMessageResponse_Data)