diff options
| author | jiawei <jiawei.liu@daocloud.io> | 2023-12-15 13:54:48 +0800 |
|---|---|---|
| committer | jiawei <jiawei.liu@daocloud.io> | 2023-12-15 13:54:48 +0800 |
| commit | 83a5889860b5a7aece10b3035632b74a599b832e (patch) | |
| tree | 1b9adc7cdd765a74e1c3a0d911ed0ae140d8bc97 /cloud | |
| parent | Merge pull request #5312 from wlq1212/fix/pause (diff) | |
| download | kubeedge-83a5889860b5a7aece10b3035632b74a599b832e.tar.gz | |
eventbus constant optimization
Signed-off-by: jiawei <jiawei.liu@daocloud.io>
Diffstat (limited to 'cloud')
| -rw-r--r-- | cloud/pkg/router/provider/eventbus/eventbus.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cloud/pkg/router/provider/eventbus/eventbus.go b/cloud/pkg/router/provider/eventbus/eventbus.go index ce68bfd38..f7005eedd 100644 --- a/cloud/pkg/router/provider/eventbus/eventbus.go +++ b/cloud/pkg/router/provider/eventbus/eventbus.go @@ -13,6 +13,7 @@ import ( "github.com/kubeedge/kubeedge/cloud/pkg/router/constants" "github.com/kubeedge/kubeedge/cloud/pkg/router/listener" "github.com/kubeedge/kubeedge/cloud/pkg/router/provider" + "github.com/kubeedge/kubeedge/edge/pkg/common/message" v1 "github.com/kubeedge/kubeedge/pkg/apis/rules/v1" ) @@ -62,7 +63,7 @@ func (factory *eventbusFactory) GetSource(ep *v1.RuleEndpoint, sourceResource ma func (eb *EventBus) RegisterListener(handle listener.Handle) error { listener.MessageHandlerInstance.AddListener(path.Join("bus/node", eb.nodeName, eb.namespace, eb.subTopic), handle) msg := model.NewMessage("") - msg.SetResourceOperation(path.Join("node", eb.nodeName, eb.namespace, eb.subTopic), "subscribe") + msg.SetResourceOperation(path.Join("node", eb.nodeName, eb.namespace, eb.subTopic), message.OperationSubscribe) msg.SetRoute(modules.RouterSourceEventBus, modules.UserGroup) beehiveContext.Send(modules.CloudHubModuleName, *msg) return nil @@ -70,7 +71,7 @@ func (eb *EventBus) RegisterListener(handle listener.Handle) error { func (eb *EventBus) UnregisterListener() { msg := model.NewMessage("") - msg.SetResourceOperation(path.Join("node", eb.nodeName, eb.namespace, eb.subTopic), "unsubscribe") + msg.SetResourceOperation(path.Join("node", eb.nodeName, eb.namespace, eb.subTopic), message.OperationUnsubscribe) msg.SetRoute(modules.RouterSourceEventBus, modules.UserGroup) beehiveContext.Send(modules.CloudHubModuleName, *msg) listener.MessageHandlerInstance.RemoveListener(path.Join("bus/node", eb.nodeName, eb.namespace, eb.subTopic)) |