diff --git a/internal/datacoord/datanode_helper.go b/internal/datacoord/datanode_helper.go index 6994b0d7041e004957c16fd6b12398b638c88531..a1c881b9d12fb1860300427ca4e95b28e345dd94 100644 --- a/internal/datacoord/datanode_helper.go +++ b/internal/datacoord/datanode_helper.go @@ -25,6 +25,8 @@ type positionProvider interface { GetVChanPositions(vchans []vchannel, seekFromStartPosition bool) ([]*datapb.VchannelInfo, error) } +var _ positionProvider = (*dummyPosProvider)(nil) + type dummyPosProvider struct{} //GetVChanPositions implements positionProvider diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go index af96c95bfbf0befd6fef5ee304859f8bd1bd40f6..3385a0666afce64f798086ee37913509a198ce85 100644 --- a/internal/datacoord/server.go +++ b/internal/datacoord/server.go @@ -79,6 +79,9 @@ type RootCoordCreatorFunc func(ctx context.Context, metaRootPath string, etcdEnd // makes sure Server implements `DataCoord` var _ types.DataCoord = (*Server)(nil) +// makes sure Server implements `positionProvider` +var _ positionProvider = (*Server)(nil) + // Server implements `types.Datacoord` // handles Data Cooridinator related jobs type Server struct {