diff --git a/internal/datacoord/channel_manager_factory.go b/internal/datacoord/channel_manager_factory.go index 72c5b2b6b3..5080e4279c 100644 --- a/internal/datacoord/channel_manager_factory.go +++ b/internal/datacoord/channel_manager_factory.go @@ -76,6 +76,7 @@ func NewConsistentHashChannelPolicyFactory(hashring *consistent.Consistent) *Con } } +// NewRegisterPolicy create a new register policy func (f *ConsistentHashChannelPolicyFactory) NewRegisterPolicy() RegisterPolicy { return ConsistentHashRegisterPolicy(f.hashring) }