From 928a4e8dff01bab01766ca761f3bc56862a20736 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 2 May 2024 08:35:06 -0700 Subject: [PATCH] rename --- .gitignore | 2 +- .../cmd/{weed_pub/publisher.go => weed_pub_kv/publisher_kv.go} | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) rename weed/mq/client/cmd/{weed_pub/publisher.go => weed_pub_kv/publisher_kv.go} (99%) diff --git a/.gitignore b/.gitignore index 2a858c427..c3cb0386a 100644 --- a/.gitignore +++ b/.gitignore @@ -87,7 +87,7 @@ other/java/hdfs/dependency-reduced-pom.xml # binary file weed/weed -weed/mq/client/cmd/weed_pub/weed_pub +weed/mq/client/cmd/weed_pub_kv/weed_pub docker/weed # test generated files diff --git a/weed/mq/client/cmd/weed_pub/publisher.go b/weed/mq/client/cmd/weed_pub_kv/publisher_kv.go similarity index 99% rename from weed/mq/client/cmd/weed_pub/publisher.go rename to weed/mq/client/cmd/weed_pub_kv/publisher_kv.go index 482e28384..59842c21f 100644 --- a/weed/mq/client/cmd/weed_pub/publisher.go +++ b/weed/mq/client/cmd/weed_pub_kv/publisher_kv.go @@ -45,6 +45,7 @@ func doPublish(publisher *pub_client.TopicPublisher, id int) { func main() { flag.Parse() + config := &pub_client.PublisherConfiguration{ Topic: topic.NewTopic(*namespace, *t), PartitionCount: int32(*partitionCount),