diff --git a/internal/datacoord/channel_manager_factory.go b/internal/datacoord/channel_manager_factory.go index ac93042a12..3dcabc849a 100644 --- a/internal/datacoord/channel_manager_factory.go +++ b/internal/datacoord/channel_manager_factory.go @@ -92,6 +92,7 @@ func (f *ConsistentHashChannelPolicyFactory) NewAssignPolicy() ChannelAssignPoli return ConsistentHashChannelAssignPolicy(f.hashring) } +// NewReassignPolicy creates a new reassign policy func (f *ConsistentHashChannelPolicyFactory) NewReassignPolicy() ChannelReassignPolicy { return EmptyReassignPolicy }