From d3925d086c9ca3f30b5f4c46a92767fe99522ccb Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Sun, 17 May 2020 17:42:42 -0700 Subject: [PATCH] add delete channel --- weed/messaging/msgclient/chan_config.go | 5 +++++ weed/messaging/msgclient/{pub_chan.go => chan_pub.go} | 0 weed/messaging/msgclient/{sub_chan.go => chan_sub.go} | 0 3 files changed, 5 insertions(+) create mode 100644 weed/messaging/msgclient/chan_config.go rename weed/messaging/msgclient/{pub_chan.go => chan_pub.go} (100%) rename weed/messaging/msgclient/{sub_chan.go => chan_sub.go} (100%) diff --git a/weed/messaging/msgclient/chan_config.go b/weed/messaging/msgclient/chan_config.go new file mode 100644 index 000000000..a75678815 --- /dev/null +++ b/weed/messaging/msgclient/chan_config.go @@ -0,0 +1,5 @@ +package msgclient + +func (mc *MessagingClient) DeleteChannel(chanName string) error { + return mc.DeleteTopic("chan", chanName) +} diff --git a/weed/messaging/msgclient/pub_chan.go b/weed/messaging/msgclient/chan_pub.go similarity index 100% rename from weed/messaging/msgclient/pub_chan.go rename to weed/messaging/msgclient/chan_pub.go diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/chan_sub.go similarity index 100% rename from weed/messaging/msgclient/sub_chan.go rename to weed/messaging/msgclient/chan_sub.go