diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-01 22:43:25 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-28 23:22:06 -0700 |
| commit | 21b6b07dd8d0379d835f9d9c1259155a12f1e61b (patch) | |
| tree | c3b13d69cac50afc227b1a06d34082cf3598f98a /weed/messaging/msgclient/config.go | |
| parent | 8c4edf7b4014b157ee269419febe57af9cd67618 (diff) | |
| download | seaweedfs-21b6b07dd8d0379d835f9d9c1259155a12f1e61b.tar.xz seaweedfs-21b6b07dd8d0379d835f9d9c1259155a12f1e61b.zip | |
renaming
Diffstat (limited to 'weed/messaging/msgclient/config.go')
| -rw-r--r-- | weed/messaging/msgclient/config.go | 63 |
1 files changed, 0 insertions, 63 deletions
diff --git a/weed/messaging/msgclient/config.go b/weed/messaging/msgclient/config.go deleted file mode 100644 index 2b9eba1a8..000000000 --- a/weed/messaging/msgclient/config.go +++ /dev/null @@ -1,63 +0,0 @@ -package msgclient - -import ( - "context" - "log" - - "github.com/chrislusf/seaweedfs/weed/messaging/broker" - "github.com/chrislusf/seaweedfs/weed/pb" - "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb" -) - -func (mc *MessagingClient) configureTopic(tp broker.TopicPartition) error { - - return mc.withAnyBroker(func(client messaging_pb.SeaweedMessagingClient) error { - _, err := client.ConfigureTopic(context.Background(), - &messaging_pb.ConfigureTopicRequest{ - Namespace: tp.Namespace, - Topic: tp.Topic, - Configuration: &messaging_pb.TopicConfiguration{ - PartitionCount: 0, - Collection: "", - Replication: "", - IsTransient: false, - Partitoning: 0, - }, - }) - return err - }) - -} - -func (mc *MessagingClient) DeleteTopic(namespace, topic string) error { - - return mc.withAnyBroker(func(client messaging_pb.SeaweedMessagingClient) error { - _, err := client.DeleteTopic(context.Background(), - &messaging_pb.DeleteTopicRequest{ - Namespace: namespace, - Topic: topic, - }) - return err - }) -} - -func (mc *MessagingClient) withAnyBroker(fn func(client messaging_pb.SeaweedMessagingClient) error) error { - - var lastErr error - for _, broker := range mc.bootstrapBrokers { - grpcConnection, err := pb.GrpcDial(context.Background(), broker, mc.grpcDialOption) - if err != nil { - log.Printf("dial broker %s: %v", broker, err) - continue - } - defer grpcConnection.Close() - - err = fn(messaging_pb.NewSeaweedMessagingClient(grpcConnection)) - if err == nil { - return nil - } - lastErr = err - } - - return lastErr -} |
