diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-05-17 17:42:42 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-05-17 17:42:42 -0700 |
| commit | d3925d086c9ca3f30b5f4c46a92767fe99522ccb (patch) | |
| tree | 1baee09cb990cc80d7d1dc21cd7482728967b2fb | |
| parent | e0e31e67a809d00c99edaa299531c7ce4d4750dc (diff) | |
| download | seaweedfs-d3925d086c9ca3f30b5f4c46a92767fe99522ccb.tar.xz seaweedfs-d3925d086c9ca3f30b5f4c46a92767fe99522ccb.zip | |
add delete channel
| -rw-r--r-- | weed/messaging/msgclient/chan_config.go | 5 | ||||
| -rw-r--r-- | weed/messaging/msgclient/chan_pub.go (renamed from weed/messaging/msgclient/pub_chan.go) | 0 | ||||
| -rw-r--r-- | weed/messaging/msgclient/chan_sub.go (renamed from weed/messaging/msgclient/sub_chan.go) | 0 |
3 files changed, 5 insertions, 0 deletions
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 index 9bc88f7c0..9bc88f7c0 100644 --- a/weed/messaging/msgclient/pub_chan.go +++ b/weed/messaging/msgclient/chan_pub.go diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/chan_sub.go index 213ff4666..213ff4666 100644 --- a/weed/messaging/msgclient/sub_chan.go +++ b/weed/messaging/msgclient/chan_sub.go |