aboutsummaryrefslogtreecommitdiff
path: root/weed/messaging/msgclient/config.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-07-01 22:43:25 -0700
committerchrislu <chris.lu@gmail.com>2022-07-28 23:22:06 -0700
commit21b6b07dd8d0379d835f9d9c1259155a12f1e61b (patch)
treec3b13d69cac50afc227b1a06d34082cf3598f98a /weed/messaging/msgclient/config.go
parent8c4edf7b4014b157ee269419febe57af9cd67618 (diff)
downloadseaweedfs-21b6b07dd8d0379d835f9d9c1259155a12f1e61b.tar.xz
seaweedfs-21b6b07dd8d0379d835f9d9c1259155a12f1e61b.zip
renaming
Diffstat (limited to 'weed/messaging/msgclient/config.go')
-rw-r--r--weed/messaging/msgclient/config.go63
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
-}