diff --git a/internal/datacoord/channel_manager_factory.go b/internal/datacoord/channel_manager_factory.go index d2010478f1..b8a9b93b49 100644 --- a/internal/datacoord/channel_manager_factory.go +++ b/internal/datacoord/channel_manager_factory.go @@ -82,6 +82,7 @@ func (f *ConsistentHashChannelPolicyFactory) NewRegisterPolicy() RegisterPolicy return ConsistentHashRegisterPolicy(f.hashring) } +// NewDeregisterPolicy create a new dereigster policy func (f *ConsistentHashChannelPolicyFactory) NewDeregisterPolicy() DeregisterPolicy { return ConsistentHashDeregisterPolicy(f.hashring) }