mocks

Documentation

Index

• type ChannelManager
  • func NewChannelManager(t interface{ ... }) *ChannelManager
  • func (_m *ChannelManager) AddDroppedCollection(ids []int64)
  • func (_m *ChannelManager) AddDroppedPartition(ids []int64)
  • func (_m *ChannelManager) AddPartition(ctx context.Context, dbInfo *model.DatabaseInfo, ...) error
  • func (_m *ChannelManager) EXPECT() *ChannelManager_Expecter
  • func (_m *ChannelManager) GetChannelChan() <-chan string
  • func (_m *ChannelManager) GetChannelLatestMsgID(ctx context.Context, channelName string) ([]byte, error)
  • func (_m *ChannelManager) GetEventChan() <-chan *api.ReplicateAPIEvent
  • func (_m *ChannelManager) GetMsgChan(pChannel string) <-chan *api.ReplicateMsg
  • func (_m *ChannelManager) SetCtx(ctx context.Context)
  • func (_m *ChannelManager) StartReadCollection(ctx context.Context, db *model.DatabaseInfo, info *pb.CollectionInfo, ...) error
  • func (_m *ChannelManager) StopReadCollection(ctx context.Context, info *pb.CollectionInfo) error
• type ChannelManager_AddDroppedCollection_Call
  • func (_c *ChannelManager_AddDroppedCollection_Call) Return() *ChannelManager_AddDroppedCollection_Call
  • func (_c *ChannelManager_AddDroppedCollection_Call) Run(run func(ids []int64)) *ChannelManager_AddDroppedCollection_Call
  • func (_c *ChannelManager_AddDroppedCollection_Call) RunAndReturn(run func([]int64)) *ChannelManager_AddDroppedCollection_Call
• type ChannelManager_AddDroppedPartition_Call
  • func (_c *ChannelManager_AddDroppedPartition_Call) Return() *ChannelManager_AddDroppedPartition_Call
  • func (_c *ChannelManager_AddDroppedPartition_Call) Run(run func(ids []int64)) *ChannelManager_AddDroppedPartition_Call
  • func (_c *ChannelManager_AddDroppedPartition_Call) RunAndReturn(run func([]int64)) *ChannelManager_AddDroppedPartition_Call
• type ChannelManager_AddPartition_Call
  • func (_c *ChannelManager_AddPartition_Call) Return(_a0 error) *ChannelManager_AddPartition_Call
  • func (_c *ChannelManager_AddPartition_Call) Run(run func(ctx context.Context, dbInfo *model.DatabaseInfo, ...)) *ChannelManager_AddPartition_Call
  • func (_c *ChannelManager_AddPartition_Call) RunAndReturn(...) *ChannelManager_AddPartition_Call
• type ChannelManager_Expecter
  • func (_e *ChannelManager_Expecter) AddDroppedCollection(ids interface{}) *ChannelManager_AddDroppedCollection_Call
  • func (_e *ChannelManager_Expecter) AddDroppedPartition(ids interface{}) *ChannelManager_AddDroppedPartition_Call
  • func (_e *ChannelManager_Expecter) AddPartition(ctx interface{}, dbInfo interface{}, collectionInfo interface{}, ...) *ChannelManager_AddPartition_Call
  • func (_e *ChannelManager_Expecter) GetChannelChan() *ChannelManager_GetChannelChan_Call
  • func (_e *ChannelManager_Expecter) GetChannelLatestMsgID(ctx interface{}, channelName interface{}) *ChannelManager_GetChannelLatestMsgID_Call
  • func (_e *ChannelManager_Expecter) GetEventChan() *ChannelManager_GetEventChan_Call
  • func (_e *ChannelManager_Expecter) GetMsgChan(pChannel interface{}) *ChannelManager_GetMsgChan_Call
  • func (_e *ChannelManager_Expecter) SetCtx(ctx interface{}) *ChannelManager_SetCtx_Call
  • func (_e *ChannelManager_Expecter) StartReadCollection(ctx interface{}, db interface{}, info interface{}, seekPositions interface{}) *ChannelManager_StartReadCollection_Call
  • func (_e *ChannelManager_Expecter) StopReadCollection(ctx interface{}, info interface{}) *ChannelManager_StopReadCollection_Call
• type ChannelManager_GetChannelChan_Call
  • func (_c *ChannelManager_GetChannelChan_Call) Return(_a0 <-chan string) *ChannelManager_GetChannelChan_Call
  • func (_c *ChannelManager_GetChannelChan_Call) Run(run func()) *ChannelManager_GetChannelChan_Call
  • func (_c *ChannelManager_GetChannelChan_Call) RunAndReturn(run func() <-chan string) *ChannelManager_GetChannelChan_Call
• type ChannelManager_GetChannelLatestMsgID_Call
  • func (_c *ChannelManager_GetChannelLatestMsgID_Call) Return(_a0 []byte, _a1 error) *ChannelManager_GetChannelLatestMsgID_Call
  • func (_c *ChannelManager_GetChannelLatestMsgID_Call) Run(run func(ctx context.Context, channelName string)) *ChannelManager_GetChannelLatestMsgID_Call
  • func (_c *ChannelManager_GetChannelLatestMsgID_Call) RunAndReturn(run func(context.Context, string) ([]byte, error)) *ChannelManager_GetChannelLatestMsgID_Call
• type ChannelManager_GetEventChan_Call
  • func (_c *ChannelManager_GetEventChan_Call) Return(_a0 <-chan *api.ReplicateAPIEvent) *ChannelManager_GetEventChan_Call
  • func (_c *ChannelManager_GetEventChan_Call) Run(run func()) *ChannelManager_GetEventChan_Call
  • func (_c *ChannelManager_GetEventChan_Call) RunAndReturn(run func() <-chan *api.ReplicateAPIEvent) *ChannelManager_GetEventChan_Call
• type ChannelManager_GetMsgChan_Call
  • func (_c *ChannelManager_GetMsgChan_Call) Return(_a0 <-chan *api.ReplicateMsg) *ChannelManager_GetMsgChan_Call
  • func (_c *ChannelManager_GetMsgChan_Call) Run(run func(pChannel string)) *ChannelManager_GetMsgChan_Call
  • func (_c *ChannelManager_GetMsgChan_Call) RunAndReturn(run func(string) <-chan *api.ReplicateMsg) *ChannelManager_GetMsgChan_Call
• type ChannelManager_SetCtx_Call
  • func (_c *ChannelManager_SetCtx_Call) Return() *ChannelManager_SetCtx_Call
  • func (_c *ChannelManager_SetCtx_Call) Run(run func(ctx context.Context)) *ChannelManager_SetCtx_Call
  • func (_c *ChannelManager_SetCtx_Call) RunAndReturn(run func(context.Context)) *ChannelManager_SetCtx_Call
• type ChannelManager_StartReadCollection_Call
  • func (_c *ChannelManager_StartReadCollection_Call) Return(_a0 error) *ChannelManager_StartReadCollection_Call
  • func (_c *ChannelManager_StartReadCollection_Call) Run(...) *ChannelManager_StartReadCollection_Call
  • func (_c *ChannelManager_StartReadCollection_Call) RunAndReturn(...) *ChannelManager_StartReadCollection_Call
• type ChannelManager_StopReadCollection_Call
  • func (_c *ChannelManager_StopReadCollection_Call) Return(_a0 error) *ChannelManager_StopReadCollection_Call
  • func (_c *ChannelManager_StopReadCollection_Call) Run(run func(ctx context.Context, info *pb.CollectionInfo)) *ChannelManager_StopReadCollection_Call
  • func (_c *ChannelManager_StopReadCollection_Call) RunAndReturn(run func(context.Context, *pb.CollectionInfo) error) *ChannelManager_StopReadCollection_Call
• type DataHandler
  • func NewDataHandler(t interface{ ... }) *DataHandler
  • func (_m *DataHandler) AlterDatabase(ctx context.Context, param *api.AlterDatabaseParam) error
  • func (_m *DataHandler) AlterIndex(ctx context.Context, param *api.AlterIndexParam) error
  • func (_m *DataHandler) CreateCollection(ctx context.Context, param *api.CreateCollectionParam) error
  • func (_m *DataHandler) CreateDatabase(ctx context.Context, param *api.CreateDatabaseParam) error
  • func (_m *DataHandler) CreateIndex(ctx context.Context, param *api.CreateIndexParam) error
  • func (_m *DataHandler) CreatePartition(ctx context.Context, param *api.CreatePartitionParam) error
  • func (_m *DataHandler) CreateRole(ctx context.Context, param *api.CreateRoleParam) error
  • func (_m *DataHandler) CreateUser(ctx context.Context, param *api.CreateUserParam) error
  • func (_m *DataHandler) Delete(ctx context.Context, param *api.DeleteParam) error
  • func (_m *DataHandler) DeleteUser(ctx context.Context, param *api.DeleteUserParam) error
  • func (_m *DataHandler) DescribeCollection(ctx context.Context, param *api.DescribeCollectionParam) error
  • func (_m *DataHandler) DescribeDatabase(ctx context.Context, param *api.DescribeDatabaseParam) error
  • func (_m *DataHandler) DescribePartition(ctx context.Context, param *api.DescribePartitionParam) error
  • func (_m *DataHandler) DropCollection(ctx context.Context, param *api.DropCollectionParam) error
  • func (_m *DataHandler) DropDatabase(ctx context.Context, param *api.DropDatabaseParam) error
  • func (_m *DataHandler) DropIndex(ctx context.Context, param *api.DropIndexParam) error
  • func (_m *DataHandler) DropPartition(ctx context.Context, param *api.DropPartitionParam) error
  • func (_m *DataHandler) DropRole(ctx context.Context, param *api.DropRoleParam) error
  • func (_m *DataHandler) EXPECT() *DataHandler_Expecter
  • func (_m *DataHandler) Flush(ctx context.Context, param *api.FlushParam) error
  • func (_m *DataHandler) Insert(ctx context.Context, param *api.InsertParam) error
  • func (_m *DataHandler) LoadCollection(ctx context.Context, param *api.LoadCollectionParam) error
  • func (_m *DataHandler) LoadPartitions(ctx context.Context, param *api.LoadPartitionsParam) error
  • func (_m *DataHandler) OperatePrivilege(ctx context.Context, param *api.OperatePrivilegeParam) error
  • func (_m *DataHandler) OperateUserRole(ctx context.Context, param *api.OperateUserRoleParam) error
  • func (_m *DataHandler) ReleaseCollection(ctx context.Context, param *api.ReleaseCollectionParam) error
  • func (_m *DataHandler) ReleasePartitions(ctx context.Context, param *api.ReleasePartitionsParam) error
  • func (_m *DataHandler) ReplicateMessage(ctx context.Context, param *api.ReplicateMessageParam) error
  • func (_m *DataHandler) UpdateUser(ctx context.Context, param *api.UpdateUserParam) error
• type DataHandler_AlterDatabase_Call
  • func (_c *DataHandler_AlterDatabase_Call) Return(_a0 error) *DataHandler_AlterDatabase_Call
  • func (_c *DataHandler_AlterDatabase_Call) Run(run func(ctx context.Context, param *api.AlterDatabaseParam)) *DataHandler_AlterDatabase_Call
  • func (_c *DataHandler_AlterDatabase_Call) RunAndReturn(run func(context.Context, *api.AlterDatabaseParam) error) *DataHandler_AlterDatabase_Call
• type DataHandler_AlterIndex_Call
  • func (_c *DataHandler_AlterIndex_Call) Return(_a0 error) *DataHandler_AlterIndex_Call
  • func (_c *DataHandler_AlterIndex_Call) Run(run func(ctx context.Context, param *api.AlterIndexParam)) *DataHandler_AlterIndex_Call
  • func (_c *DataHandler_AlterIndex_Call) RunAndReturn(run func(context.Context, *api.AlterIndexParam) error) *DataHandler_AlterIndex_Call
• type DataHandler_CreateCollection_Call
  • func (_c *DataHandler_CreateCollection_Call) Return(_a0 error) *DataHandler_CreateCollection_Call
  • func (_c *DataHandler_CreateCollection_Call) Run(run func(ctx context.Context, param *api.CreateCollectionParam)) *DataHandler_CreateCollection_Call
  • func (_c *DataHandler_CreateCollection_Call) RunAndReturn(run func(context.Context, *api.CreateCollectionParam) error) *DataHandler_CreateCollection_Call
• type DataHandler_CreateDatabase_Call
  • func (_c *DataHandler_CreateDatabase_Call) Return(_a0 error) *DataHandler_CreateDatabase_Call
  • func (_c *DataHandler_CreateDatabase_Call) Run(run func(ctx context.Context, param *api.CreateDatabaseParam)) *DataHandler_CreateDatabase_Call
  • func (_c *DataHandler_CreateDatabase_Call) RunAndReturn(run func(context.Context, *api.CreateDatabaseParam) error) *DataHandler_CreateDatabase_Call
• type DataHandler_CreateIndex_Call
  • func (_c *DataHandler_CreateIndex_Call) Return(_a0 error) *DataHandler_CreateIndex_Call
  • func (_c *DataHandler_CreateIndex_Call) Run(run func(ctx context.Context, param *api.CreateIndexParam)) *DataHandler_CreateIndex_Call
  • func (_c *DataHandler_CreateIndex_Call) RunAndReturn(run func(context.Context, *api.CreateIndexParam) error) *DataHandler_CreateIndex_Call
• type DataHandler_CreatePartition_Call
  • func (_c *DataHandler_CreatePartition_Call) Return(_a0 error) *DataHandler_CreatePartition_Call
  • func (_c *DataHandler_CreatePartition_Call) Run(run func(ctx context.Context, param *api.CreatePartitionParam)) *DataHandler_CreatePartition_Call
  • func (_c *DataHandler_CreatePartition_Call) RunAndReturn(run func(context.Context, *api.CreatePartitionParam) error) *DataHandler_CreatePartition_Call
• type DataHandler_CreateRole_Call
  • func (_c *DataHandler_CreateRole_Call) Return(_a0 error) *DataHandler_CreateRole_Call
  • func (_c *DataHandler_CreateRole_Call) Run(run func(ctx context.Context, param *api.CreateRoleParam)) *DataHandler_CreateRole_Call
  • func (_c *DataHandler_CreateRole_Call) RunAndReturn(run func(context.Context, *api.CreateRoleParam) error) *DataHandler_CreateRole_Call
• type DataHandler_CreateUser_Call
  • func (_c *DataHandler_CreateUser_Call) Return(_a0 error) *DataHandler_CreateUser_Call
  • func (_c *DataHandler_CreateUser_Call) Run(run func(ctx context.Context, param *api.CreateUserParam)) *DataHandler_CreateUser_Call
  • func (_c *DataHandler_CreateUser_Call) RunAndReturn(run func(context.Context, *api.CreateUserParam) error) *DataHandler_CreateUser_Call
• type DataHandler_DeleteUser_Call
  • func (_c *DataHandler_DeleteUser_Call) Return(_a0 error) *DataHandler_DeleteUser_Call
  • func (_c *DataHandler_DeleteUser_Call) Run(run func(ctx context.Context, param *api.DeleteUserParam)) *DataHandler_DeleteUser_Call
  • func (_c *DataHandler_DeleteUser_Call) RunAndReturn(run func(context.Context, *api.DeleteUserParam) error) *DataHandler_DeleteUser_Call
• type DataHandler_Delete_Call
  • func (_c *DataHandler_Delete_Call) Return(_a0 error) *DataHandler_Delete_Call
  • func (_c *DataHandler_Delete_Call) Run(run func(ctx context.Context, param *api.DeleteParam)) *DataHandler_Delete_Call
  • func (_c *DataHandler_Delete_Call) RunAndReturn(run func(context.Context, *api.DeleteParam) error) *DataHandler_Delete_Call
• type DataHandler_DescribeCollection_Call
  • func (_c *DataHandler_DescribeCollection_Call) Return(_a0 error) *DataHandler_DescribeCollection_Call
  • func (_c *DataHandler_DescribeCollection_Call) Run(run func(ctx context.Context, param *api.DescribeCollectionParam)) *DataHandler_DescribeCollection_Call
  • func (_c *DataHandler_DescribeCollection_Call) RunAndReturn(run func(context.Context, *api.DescribeCollectionParam) error) *DataHandler_DescribeCollection_Call
• type DataHandler_DescribeDatabase_Call
  • func (_c *DataHandler_DescribeDatabase_Call) Return(_a0 error) *DataHandler_DescribeDatabase_Call
  • func (_c *DataHandler_DescribeDatabase_Call) Run(run func(ctx context.Context, param *api.DescribeDatabaseParam)) *DataHandler_DescribeDatabase_Call
  • func (_c *DataHandler_DescribeDatabase_Call) RunAndReturn(run func(context.Context, *api.DescribeDatabaseParam) error) *DataHandler_DescribeDatabase_Call
• type DataHandler_DescribePartition_Call
  • func (_c *DataHandler_DescribePartition_Call) Return(_a0 error) *DataHandler_DescribePartition_Call
  • func (_c *DataHandler_DescribePartition_Call) Run(run func(ctx context.Context, param *api.DescribePartitionParam)) *DataHandler_DescribePartition_Call
  • func (_c *DataHandler_DescribePartition_Call) RunAndReturn(run func(context.Context, *api.DescribePartitionParam) error) *DataHandler_DescribePartition_Call
• type DataHandler_DropCollection_Call
  • func (_c *DataHandler_DropCollection_Call) Return(_a0 error) *DataHandler_DropCollection_Call
  • func (_c *DataHandler_DropCollection_Call) Run(run func(ctx context.Context, param *api.DropCollectionParam)) *DataHandler_DropCollection_Call
  • func (_c *DataHandler_DropCollection_Call) RunAndReturn(run func(context.Context, *api.DropCollectionParam) error) *DataHandler_DropCollection_Call
• type DataHandler_DropDatabase_Call
  • func (_c *DataHandler_DropDatabase_Call) Return(_a0 error) *DataHandler_DropDatabase_Call
  • func (_c *DataHandler_DropDatabase_Call) Run(run func(ctx context.Context, param *api.DropDatabaseParam)) *DataHandler_DropDatabase_Call
  • func (_c *DataHandler_DropDatabase_Call) RunAndReturn(run func(context.Context, *api.DropDatabaseParam) error) *DataHandler_DropDatabase_Call
• type DataHandler_DropIndex_Call
  • func (_c *DataHandler_DropIndex_Call) Return(_a0 error) *DataHandler_DropIndex_Call
  • func (_c *DataHandler_DropIndex_Call) Run(run func(ctx context.Context, param *api.DropIndexParam)) *DataHandler_DropIndex_Call
  • func (_c *DataHandler_DropIndex_Call) RunAndReturn(run func(context.Context, *api.DropIndexParam) error) *DataHandler_DropIndex_Call
• type DataHandler_DropPartition_Call
  • func (_c *DataHandler_DropPartition_Call) Return(_a0 error) *DataHandler_DropPartition_Call
  • func (_c *DataHandler_DropPartition_Call) Run(run func(ctx context.Context, param *api.DropPartitionParam)) *DataHandler_DropPartition_Call
  • func (_c *DataHandler_DropPartition_Call) RunAndReturn(run func(context.Context, *api.DropPartitionParam) error) *DataHandler_DropPartition_Call
• type DataHandler_DropRole_Call
  • func (_c *DataHandler_DropRole_Call) Return(_a0 error) *DataHandler_DropRole_Call
  • func (_c *DataHandler_DropRole_Call) Run(run func(ctx context.Context, param *api.DropRoleParam)) *DataHandler_DropRole_Call
  • func (_c *DataHandler_DropRole_Call) RunAndReturn(run func(context.Context, *api.DropRoleParam) error) *DataHandler_DropRole_Call
• type DataHandler_Expecter
  • func (_e *DataHandler_Expecter) AlterDatabase(ctx interface{}, param interface{}) *DataHandler_AlterDatabase_Call
  • func (_e *DataHandler_Expecter) AlterIndex(ctx interface{}, param interface{}) *DataHandler_AlterIndex_Call
  • func (_e *DataHandler_Expecter) CreateCollection(ctx interface{}, param interface{}) *DataHandler_CreateCollection_Call
  • func (_e *DataHandler_Expecter) CreateDatabase(ctx interface{}, param interface{}) *DataHandler_CreateDatabase_Call
  • func (_e *DataHandler_Expecter) CreateIndex(ctx interface{}, param interface{}) *DataHandler_CreateIndex_Call
  • func (_e *DataHandler_Expecter) CreatePartition(ctx interface{}, param interface{}) *DataHandler_CreatePartition_Call
  • func (_e *DataHandler_Expecter) CreateRole(ctx interface{}, param interface{}) *DataHandler_CreateRole_Call
  • func (_e *DataHandler_Expecter) CreateUser(ctx interface{}, param interface{}) *DataHandler_CreateUser_Call
  • func (_e *DataHandler_Expecter) Delete(ctx interface{}, param interface{}) *DataHandler_Delete_Call
  • func (_e *DataHandler_Expecter) DeleteUser(ctx interface{}, param interface{}) *DataHandler_DeleteUser_Call
  • func (_e *DataHandler_Expecter) DescribeCollection(ctx interface{}, param interface{}) *DataHandler_DescribeCollection_Call
  • func (_e *DataHandler_Expecter) DescribeDatabase(ctx interface{}, param interface{}) *DataHandler_DescribeDatabase_Call
  • func (_e *DataHandler_Expecter) DescribePartition(ctx interface{}, param interface{}) *DataHandler_DescribePartition_Call
  • func (_e *DataHandler_Expecter) DropCollection(ctx interface{}, param interface{}) *DataHandler_DropCollection_Call
  • func (_e *DataHandler_Expecter) DropDatabase(ctx interface{}, param interface{}) *DataHandler_DropDatabase_Call
  • func (_e *DataHandler_Expecter) DropIndex(ctx interface{}, param interface{}) *DataHandler_DropIndex_Call
  • func (_e *DataHandler_Expecter) DropPartition(ctx interface{}, param interface{}) *DataHandler_DropPartition_Call
  • func (_e *DataHandler_Expecter) DropRole(ctx interface{}, param interface{}) *DataHandler_DropRole_Call
  • func (_e *DataHandler_Expecter) Flush(ctx interface{}, param interface{}) *DataHandler_Flush_Call
  • func (_e *DataHandler_Expecter) Insert(ctx interface{}, param interface{}) *DataHandler_Insert_Call
  • func (_e *DataHandler_Expecter) LoadCollection(ctx interface{}, param interface{}) *DataHandler_LoadCollection_Call
  • func (_e *DataHandler_Expecter) LoadPartitions(ctx interface{}, param interface{}) *DataHandler_LoadPartitions_Call
  • func (_e *DataHandler_Expecter) OperatePrivilege(ctx interface{}, param interface{}) *DataHandler_OperatePrivilege_Call
  • func (_e *DataHandler_Expecter) OperateUserRole(ctx interface{}, param interface{}) *DataHandler_OperateUserRole_Call
  • func (_e *DataHandler_Expecter) ReleaseCollection(ctx interface{}, param interface{}) *DataHandler_ReleaseCollection_Call
  • func (_e *DataHandler_Expecter) ReleasePartitions(ctx interface{}, param interface{}) *DataHandler_ReleasePartitions_Call
  • func (_e *DataHandler_Expecter) ReplicateMessage(ctx interface{}, param interface{}) *DataHandler_ReplicateMessage_Call
  • func (_e *DataHandler_Expecter) UpdateUser(ctx interface{}, param interface{}) *DataHandler_UpdateUser_Call
• type DataHandler_Flush_Call
  • func (_c *DataHandler_Flush_Call) Return(_a0 error) *DataHandler_Flush_Call
  • func (_c *DataHandler_Flush_Call) Run(run func(ctx context.Context, param *api.FlushParam)) *DataHandler_Flush_Call
  • func (_c *DataHandler_Flush_Call) RunAndReturn(run func(context.Context, *api.FlushParam) error) *DataHandler_Flush_Call
• type DataHandler_Insert_Call
  • func (_c *DataHandler_Insert_Call) Return(_a0 error) *DataHandler_Insert_Call
  • func (_c *DataHandler_Insert_Call) Run(run func(ctx context.Context, param *api.InsertParam)) *DataHandler_Insert_Call
  • func (_c *DataHandler_Insert_Call) RunAndReturn(run func(context.Context, *api.InsertParam) error) *DataHandler_Insert_Call
• type DataHandler_LoadCollection_Call
  • func (_c *DataHandler_LoadCollection_Call) Return(_a0 error) *DataHandler_LoadCollection_Call
  • func (_c *DataHandler_LoadCollection_Call) Run(run func(ctx context.Context, param *api.LoadCollectionParam)) *DataHandler_LoadCollection_Call
  • func (_c *DataHandler_LoadCollection_Call) RunAndReturn(run func(context.Context, *api.LoadCollectionParam) error) *DataHandler_LoadCollection_Call
• type DataHandler_LoadPartitions_Call
  • func (_c *DataHandler_LoadPartitions_Call) Return(_a0 error) *DataHandler_LoadPartitions_Call
  • func (_c *DataHandler_LoadPartitions_Call) Run(run func(ctx context.Context, param *api.LoadPartitionsParam)) *DataHandler_LoadPartitions_Call
  • func (_c *DataHandler_LoadPartitions_Call) RunAndReturn(run func(context.Context, *api.LoadPartitionsParam) error) *DataHandler_LoadPartitions_Call
• type DataHandler_OperatePrivilege_Call
  • func (_c *DataHandler_OperatePrivilege_Call) Return(_a0 error) *DataHandler_OperatePrivilege_Call
  • func (_c *DataHandler_OperatePrivilege_Call) Run(run func(ctx context.Context, param *api.OperatePrivilegeParam)) *DataHandler_OperatePrivilege_Call
  • func (_c *DataHandler_OperatePrivilege_Call) RunAndReturn(run func(context.Context, *api.OperatePrivilegeParam) error) *DataHandler_OperatePrivilege_Call
• type DataHandler_OperateUserRole_Call
  • func (_c *DataHandler_OperateUserRole_Call) Return(_a0 error) *DataHandler_OperateUserRole_Call
  • func (_c *DataHandler_OperateUserRole_Call) Run(run func(ctx context.Context, param *api.OperateUserRoleParam)) *DataHandler_OperateUserRole_Call
  • func (_c *DataHandler_OperateUserRole_Call) RunAndReturn(run func(context.Context, *api.OperateUserRoleParam) error) *DataHandler_OperateUserRole_Call
• type DataHandler_ReleaseCollection_Call
  • func (_c *DataHandler_ReleaseCollection_Call) Return(_a0 error) *DataHandler_ReleaseCollection_Call
  • func (_c *DataHandler_ReleaseCollection_Call) Run(run func(ctx context.Context, param *api.ReleaseCollectionParam)) *DataHandler_ReleaseCollection_Call
  • func (_c *DataHandler_ReleaseCollection_Call) RunAndReturn(run func(context.Context, *api.ReleaseCollectionParam) error) *DataHandler_ReleaseCollection_Call
• type DataHandler_ReleasePartitions_Call
  • func (_c *DataHandler_ReleasePartitions_Call) Return(_a0 error) *DataHandler_ReleasePartitions_Call
  • func (_c *DataHandler_ReleasePartitions_Call) Run(run func(ctx context.Context, param *api.ReleasePartitionsParam)) *DataHandler_ReleasePartitions_Call
  • func (_c *DataHandler_ReleasePartitions_Call) RunAndReturn(run func(context.Context, *api.ReleasePartitionsParam) error) *DataHandler_ReleasePartitions_Call
• type DataHandler_ReplicateMessage_Call
  • func (_c *DataHandler_ReplicateMessage_Call) Return(_a0 error) *DataHandler_ReplicateMessage_Call
  • func (_c *DataHandler_ReplicateMessage_Call) Run(run func(ctx context.Context, param *api.ReplicateMessageParam)) *DataHandler_ReplicateMessage_Call
  • func (_c *DataHandler_ReplicateMessage_Call) RunAndReturn(run func(context.Context, *api.ReplicateMessageParam) error) *DataHandler_ReplicateMessage_Call
• type DataHandler_UpdateUser_Call
  • func (_c *DataHandler_UpdateUser_Call) Return(_a0 error) *DataHandler_UpdateUser_Call
  • func (_c *DataHandler_UpdateUser_Call) Run(run func(ctx context.Context, param *api.UpdateUserParam)) *DataHandler_UpdateUser_Call
  • func (_c *DataHandler_UpdateUser_Call) RunAndReturn(run func(context.Context, *api.UpdateUserParam) error) *DataHandler_UpdateUser_Call
• type FactoryCreator
  • func NewFactoryCreator(t interface{ ... }) *FactoryCreator
  • func (_m *FactoryCreator) EXPECT() *FactoryCreator_Expecter
  • func (_m *FactoryCreator) NewKmsFactory(cfg *config.KafkaConfig) msgstream.Factory
  • func (_m *FactoryCreator) NewPmsFactory(cfg *config.PulsarConfig) msgstream.Factory
• type FactoryCreator_Expecter
  • func (_e *FactoryCreator_Expecter) NewKmsFactory(cfg interface{}) *FactoryCreator_NewKmsFactory_Call
  • func (_e *FactoryCreator_Expecter) NewPmsFactory(cfg interface{}) *FactoryCreator_NewPmsFactory_Call
• type FactoryCreator_NewKmsFactory_Call
  • func (_c *FactoryCreator_NewKmsFactory_Call) Return(_a0 msgstream.Factory) *FactoryCreator_NewKmsFactory_Call
  • func (_c *FactoryCreator_NewKmsFactory_Call) Run(run func(cfg *config.KafkaConfig)) *FactoryCreator_NewKmsFactory_Call
  • func (_c *FactoryCreator_NewKmsFactory_Call) RunAndReturn(run func(*config.KafkaConfig) msgstream.Factory) *FactoryCreator_NewKmsFactory_Call
• type FactoryCreator_NewPmsFactory_Call
  • func (_c *FactoryCreator_NewPmsFactory_Call) Return(_a0 msgstream.Factory) *FactoryCreator_NewPmsFactory_Call
  • func (_c *FactoryCreator_NewPmsFactory_Call) Run(run func(cfg *config.PulsarConfig)) *FactoryCreator_NewPmsFactory_Call
  • func (_c *FactoryCreator_NewPmsFactory_Call) RunAndReturn(run func(*config.PulsarConfig) msgstream.Factory) *FactoryCreator_NewPmsFactory_Call
• type KVApi
  • func NewKVApi(t mockConstructorTestingTNewKVApi) *KVApi
  • func (_m *KVApi) Close() error
  • func (_m *KVApi) Compact(ctx context.Context, rev int64, opts ...clientv3.CompactOption) (*clientv3.CompactResponse, error)
  • func (_m *KVApi) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)
  • func (_m *KVApi) Do(ctx context.Context, op clientv3.Op) (clientv3.OpResponse, error)
  • func (_m *KVApi) EXPECT() *KVApi_Expecter
  • func (_m *KVApi) Endpoints() []string
  • func (_m *KVApi) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
  • func (_m *KVApi) Put(ctx context.Context, key string, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
  • func (_m *KVApi) RequestProgress(ctx context.Context) error
  • func (_m *KVApi) Status(ctx context.Context, endpoint string) (*clientv3.StatusResponse, error)
  • func (_m *KVApi) Txn(ctx context.Context) clientv3.Txn
  • func (_m *KVApi) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan
• type KVApi_Close_Call
  • func (_c *KVApi_Close_Call) Return(_a0 error) *KVApi_Close_Call
  • func (_c *KVApi_Close_Call) Run(run func()) *KVApi_Close_Call
  • func (_c *KVApi_Close_Call) RunAndReturn(run func() error) *KVApi_Close_Call
• type KVApi_Compact_Call
  • func (_c *KVApi_Compact_Call) Return(_a0 *clientv3.CompactResponse, _a1 error) *KVApi_Compact_Call
  • func (_c *KVApi_Compact_Call) Run(run func(ctx context.Context, rev int64, opts ...clientv3.CompactOption)) *KVApi_Compact_Call
  • func (_c *KVApi_Compact_Call) RunAndReturn(...) *KVApi_Compact_Call
• type KVApi_Delete_Call
  • func (_c *KVApi_Delete_Call) Return(_a0 *clientv3.DeleteResponse, _a1 error) *KVApi_Delete_Call
  • func (_c *KVApi_Delete_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Delete_Call
  • func (_c *KVApi_Delete_Call) RunAndReturn(...) *KVApi_Delete_Call
• type KVApi_Do_Call
  • func (_c *KVApi_Do_Call) Return(_a0 clientv3.OpResponse, _a1 error) *KVApi_Do_Call
  • func (_c *KVApi_Do_Call) Run(run func(ctx context.Context, op clientv3.Op)) *KVApi_Do_Call
  • func (_c *KVApi_Do_Call) RunAndReturn(run func(context.Context, clientv3.Op) (clientv3.OpResponse, error)) *KVApi_Do_Call
• type KVApi_Endpoints_Call
  • func (_c *KVApi_Endpoints_Call) Return(_a0 []string) *KVApi_Endpoints_Call
  • func (_c *KVApi_Endpoints_Call) Run(run func()) *KVApi_Endpoints_Call
  • func (_c *KVApi_Endpoints_Call) RunAndReturn(run func() []string) *KVApi_Endpoints_Call
• type KVApi_Expecter
  • func (_e *KVApi_Expecter) Close() *KVApi_Close_Call
  • func (_e *KVApi_Expecter) Compact(ctx interface{}, rev interface{}, opts ...interface{}) *KVApi_Compact_Call
  • func (_e *KVApi_Expecter) Delete(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Delete_Call
  • func (_e *KVApi_Expecter) Do(ctx interface{}, op interface{}) *KVApi_Do_Call
  • func (_e *KVApi_Expecter) Endpoints() *KVApi_Endpoints_Call
  • func (_e *KVApi_Expecter) Get(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Get_Call
  • func (_e *KVApi_Expecter) Put(ctx interface{}, key interface{}, val interface{}, opts ...interface{}) *KVApi_Put_Call
  • func (_e *KVApi_Expecter) RequestProgress(ctx interface{}) *KVApi_RequestProgress_Call
  • func (_e *KVApi_Expecter) Status(ctx interface{}, endpoint interface{}) *KVApi_Status_Call
  • func (_e *KVApi_Expecter) Txn(ctx interface{}) *KVApi_Txn_Call
  • func (_e *KVApi_Expecter) Watch(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Watch_Call
• type KVApi_Get_Call
  • func (_c *KVApi_Get_Call) Return(_a0 *clientv3.GetResponse, _a1 error) *KVApi_Get_Call
  • func (_c *KVApi_Get_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Get_Call
  • func (_c *KVApi_Get_Call) RunAndReturn(...) *KVApi_Get_Call
• type KVApi_Put_Call
  • func (_c *KVApi_Put_Call) Return(_a0 *clientv3.PutResponse, _a1 error) *KVApi_Put_Call
  • func (_c *KVApi_Put_Call) Run(...) *KVApi_Put_Call
  • func (_c *KVApi_Put_Call) RunAndReturn(...) *KVApi_Put_Call
• type KVApi_RequestProgress_Call
  • func (_c *KVApi_RequestProgress_Call) Return(_a0 error) *KVApi_RequestProgress_Call
  • func (_c *KVApi_RequestProgress_Call) Run(run func(ctx context.Context)) *KVApi_RequestProgress_Call
  • func (_c *KVApi_RequestProgress_Call) RunAndReturn(run func(context.Context) error) *KVApi_RequestProgress_Call
• type KVApi_Status_Call
  • func (_c *KVApi_Status_Call) Return(_a0 *clientv3.StatusResponse, _a1 error) *KVApi_Status_Call
  • func (_c *KVApi_Status_Call) Run(run func(ctx context.Context, endpoint string)) *KVApi_Status_Call
  • func (_c *KVApi_Status_Call) RunAndReturn(run func(context.Context, string) (*clientv3.StatusResponse, error)) *KVApi_Status_Call
• type KVApi_Txn_Call
  • func (_c *KVApi_Txn_Call) Return(_a0 clientv3.Txn) *KVApi_Txn_Call
  • func (_c *KVApi_Txn_Call) Run(run func(ctx context.Context)) *KVApi_Txn_Call
  • func (_c *KVApi_Txn_Call) RunAndReturn(run func(context.Context) clientv3.Txn) *KVApi_Txn_Call
• type KVApi_Watch_Call
  • func (_c *KVApi_Watch_Call) Return(_a0 clientv3.WatchChan) *KVApi_Watch_Call
  • func (_c *KVApi_Watch_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Watch_Call
  • func (_c *KVApi_Watch_Call) RunAndReturn(run func(context.Context, string, ...clientv3.OpOption) clientv3.WatchChan) *KVApi_Watch_Call
• type MessageManager
  • func NewMessageManager(t interface{ ... }) *MessageManager
  • func (_m *MessageManager) Close(channelName string)
  • func (_m *MessageManager) EXPECT() *MessageManager_Expecter
  • func (_m *MessageManager) ReplicateMessage(message *api.ReplicateMessage)
• type MessageManager_Close_Call
  • func (_c *MessageManager_Close_Call) Return() *MessageManager_Close_Call
  • func (_c *MessageManager_Close_Call) Run(run func(channelName string)) *MessageManager_Close_Call
  • func (_c *MessageManager_Close_Call) RunAndReturn(run func(string)) *MessageManager_Close_Call
• type MessageManager_Expecter
  • func (_e *MessageManager_Expecter) Close(channelName interface{}) *MessageManager_Close_Call
  • func (_e *MessageManager_Expecter) ReplicateMessage(message interface{}) *MessageManager_ReplicateMessage_Call
• type MessageManager_ReplicateMessage_Call
  • func (_c *MessageManager_ReplicateMessage_Call) Return() *MessageManager_ReplicateMessage_Call
  • func (_c *MessageManager_ReplicateMessage_Call) Run(run func(message *api.ReplicateMessage)) *MessageManager_ReplicateMessage_Call
  • func (_c *MessageManager_ReplicateMessage_Call) RunAndReturn(run func(*api.ReplicateMessage)) *MessageManager_ReplicateMessage_Call
• type MetaOp
  • func NewMetaOp(t interface{ ... }) *MetaOp
  • func (_m *MetaOp) EXPECT() *MetaOp_Expecter
  • func (_m *MetaOp) GetAllCollection(ctx context.Context, filter api.CollectionFilter) ([]*pb.CollectionInfo, error)
  • func (_m *MetaOp) GetAllDroppedObj() map[string]map[string]uint64
  • func (_m *MetaOp) GetAllPartition(ctx context.Context, filter api.PartitionFilter) ([]*pb.PartitionInfo, error)
  • func (_m *MetaOp) GetCollectionNameByID(ctx context.Context, id int64) string
  • func (_m *MetaOp) GetDatabaseInfoForCollection(ctx context.Context, id int64) model.DatabaseInfo
  • func (_m *MetaOp) StartWatch()
  • func (_m *MetaOp) SubscribeCollectionEvent(taskID string, consumer api.CollectionEventConsumer)
  • func (_m *MetaOp) SubscribePartitionEvent(taskID string, consumer api.PartitionEventConsumer)
  • func (_m *MetaOp) UnsubscribeEvent(taskID string, eventType api.WatchEventType)
  • func (_m *MetaOp) WatchCollection(ctx context.Context, filter api.CollectionFilter)
  • func (_m *MetaOp) WatchPartition(ctx context.Context, filter api.PartitionFilter)
• type MetaOp_Expecter
  • func (_e *MetaOp_Expecter) GetAllCollection(ctx interface{}, filter interface{}) *MetaOp_GetAllCollection_Call
  • func (_e *MetaOp_Expecter) GetAllDroppedObj() *MetaOp_GetAllDroppedObj_Call
  • func (_e *MetaOp_Expecter) GetAllPartition(ctx interface{}, filter interface{}) *MetaOp_GetAllPartition_Call
  • func (_e *MetaOp_Expecter) GetCollectionNameByID(ctx interface{}, id interface{}) *MetaOp_GetCollectionNameByID_Call
  • func (_e *MetaOp_Expecter) GetDatabaseInfoForCollection(ctx interface{}, id interface{}) *MetaOp_GetDatabaseInfoForCollection_Call
  • func (_e *MetaOp_Expecter) StartWatch() *MetaOp_StartWatch_Call
  • func (_e *MetaOp_Expecter) SubscribeCollectionEvent(taskID interface{}, consumer interface{}) *MetaOp_SubscribeCollectionEvent_Call
  • func (_e *MetaOp_Expecter) SubscribePartitionEvent(taskID interface{}, consumer interface{}) *MetaOp_SubscribePartitionEvent_Call
  • func (_e *MetaOp_Expecter) UnsubscribeEvent(taskID interface{}, eventType interface{}) *MetaOp_UnsubscribeEvent_Call
  • func (_e *MetaOp_Expecter) WatchCollection(ctx interface{}, filter interface{}) *MetaOp_WatchCollection_Call
  • func (_e *MetaOp_Expecter) WatchPartition(ctx interface{}, filter interface{}) *MetaOp_WatchPartition_Call
• type MetaOp_GetAllCollection_Call
  • func (_c *MetaOp_GetAllCollection_Call) Return(_a0 []*pb.CollectionInfo, _a1 error) *MetaOp_GetAllCollection_Call
  • func (_c *MetaOp_GetAllCollection_Call) Run(run func(ctx context.Context, filter api.CollectionFilter)) *MetaOp_GetAllCollection_Call
  • func (_c *MetaOp_GetAllCollection_Call) RunAndReturn(run func(context.Context, api.CollectionFilter) ([]*pb.CollectionInfo, error)) *MetaOp_GetAllCollection_Call
• type MetaOp_GetAllDroppedObj_Call
  • func (_c *MetaOp_GetAllDroppedObj_Call) Return(_a0 map[string]map[string]uint64) *MetaOp_GetAllDroppedObj_Call
  • func (_c *MetaOp_GetAllDroppedObj_Call) Run(run func()) *MetaOp_GetAllDroppedObj_Call
  • func (_c *MetaOp_GetAllDroppedObj_Call) RunAndReturn(run func() map[string]map[string]uint64) *MetaOp_GetAllDroppedObj_Call
• type MetaOp_GetAllPartition_Call
  • func (_c *MetaOp_GetAllPartition_Call) Return(_a0 []*pb.PartitionInfo, _a1 error) *MetaOp_GetAllPartition_Call
  • func (_c *MetaOp_GetAllPartition_Call) Run(run func(ctx context.Context, filter api.PartitionFilter)) *MetaOp_GetAllPartition_Call
  • func (_c *MetaOp_GetAllPartition_Call) RunAndReturn(run func(context.Context, api.PartitionFilter) ([]*pb.PartitionInfo, error)) *MetaOp_GetAllPartition_Call
• type MetaOp_GetCollectionNameByID_Call
  • func (_c *MetaOp_GetCollectionNameByID_Call) Return(_a0 string) *MetaOp_GetCollectionNameByID_Call
  • func (_c *MetaOp_GetCollectionNameByID_Call) Run(run func(ctx context.Context, id int64)) *MetaOp_GetCollectionNameByID_Call
  • func (_c *MetaOp_GetCollectionNameByID_Call) RunAndReturn(run func(context.Context, int64) string) *MetaOp_GetCollectionNameByID_Call
• type MetaOp_GetDatabaseInfoForCollection_Call
  • func (_c *MetaOp_GetDatabaseInfoForCollection_Call) Return(_a0 model.DatabaseInfo) *MetaOp_GetDatabaseInfoForCollection_Call
  • func (_c *MetaOp_GetDatabaseInfoForCollection_Call) Run(run func(ctx context.Context, id int64)) *MetaOp_GetDatabaseInfoForCollection_Call
  • func (_c *MetaOp_GetDatabaseInfoForCollection_Call) RunAndReturn(run func(context.Context, int64) model.DatabaseInfo) *MetaOp_GetDatabaseInfoForCollection_Call
• type MetaOp_StartWatch_Call
  • func (_c *MetaOp_StartWatch_Call) Return() *MetaOp_StartWatch_Call
  • func (_c *MetaOp_StartWatch_Call) Run(run func()) *MetaOp_StartWatch_Call
  • func (_c *MetaOp_StartWatch_Call) RunAndReturn(run func()) *MetaOp_StartWatch_Call
• type MetaOp_SubscribeCollectionEvent_Call
  • func (_c *MetaOp_SubscribeCollectionEvent_Call) Return() *MetaOp_SubscribeCollectionEvent_Call
  • func (_c *MetaOp_SubscribeCollectionEvent_Call) Run(run func(taskID string, consumer api.CollectionEventConsumer)) *MetaOp_SubscribeCollectionEvent_Call
  • func (_c *MetaOp_SubscribeCollectionEvent_Call) RunAndReturn(run func(string, api.CollectionEventConsumer)) *MetaOp_SubscribeCollectionEvent_Call
• type MetaOp_SubscribePartitionEvent_Call
  • func (_c *MetaOp_SubscribePartitionEvent_Call) Return() *MetaOp_SubscribePartitionEvent_Call
  • func (_c *MetaOp_SubscribePartitionEvent_Call) Run(run func(taskID string, consumer api.PartitionEventConsumer)) *MetaOp_SubscribePartitionEvent_Call
  • func (_c *MetaOp_SubscribePartitionEvent_Call) RunAndReturn(run func(string, api.PartitionEventConsumer)) *MetaOp_SubscribePartitionEvent_Call
• type MetaOp_UnsubscribeEvent_Call
  • func (_c *MetaOp_UnsubscribeEvent_Call) Return() *MetaOp_UnsubscribeEvent_Call
  • func (_c *MetaOp_UnsubscribeEvent_Call) Run(run func(taskID string, eventType api.WatchEventType)) *MetaOp_UnsubscribeEvent_Call
  • func (_c *MetaOp_UnsubscribeEvent_Call) RunAndReturn(run func(string, api.WatchEventType)) *MetaOp_UnsubscribeEvent_Call
• type MetaOp_WatchCollection_Call
  • func (_c *MetaOp_WatchCollection_Call) Return() *MetaOp_WatchCollection_Call
  • func (_c *MetaOp_WatchCollection_Call) Run(run func(ctx context.Context, filter api.CollectionFilter)) *MetaOp_WatchCollection_Call
  • func (_c *MetaOp_WatchCollection_Call) RunAndReturn(run func(context.Context, api.CollectionFilter)) *MetaOp_WatchCollection_Call
• type MetaOp_WatchPartition_Call
  • func (_c *MetaOp_WatchPartition_Call) Return() *MetaOp_WatchPartition_Call
  • func (_c *MetaOp_WatchPartition_Call) Run(run func(ctx context.Context, filter api.PartitionFilter)) *MetaOp_WatchPartition_Call
  • func (_c *MetaOp_WatchPartition_Call) RunAndReturn(run func(context.Context, api.PartitionFilter)) *MetaOp_WatchPartition_Call
• type Reader
  • func NewReader(t interface{ ... }) *Reader
  • func (_m *Reader) EXPECT() *Reader_Expecter
  • func (_m *Reader) ErrorChan() <-chan error
  • func (_m *Reader) QuitRead(ctx context.Context)
  • func (_m *Reader) StartRead(ctx context.Context)
• type Reader_ErrorChan_Call
  • func (_c *Reader_ErrorChan_Call) Return(_a0 <-chan error) *Reader_ErrorChan_Call
  • func (_c *Reader_ErrorChan_Call) Run(run func()) *Reader_ErrorChan_Call
  • func (_c *Reader_ErrorChan_Call) RunAndReturn(run func() <-chan error) *Reader_ErrorChan_Call
• type Reader_Expecter
  • func (_e *Reader_Expecter) ErrorChan() *Reader_ErrorChan_Call
  • func (_e *Reader_Expecter) QuitRead(ctx interface{}) *Reader_QuitRead_Call
  • func (_e *Reader_Expecter) StartRead(ctx interface{}) *Reader_StartRead_Call
• type Reader_QuitRead_Call
  • func (_c *Reader_QuitRead_Call) Return() *Reader_QuitRead_Call
  • func (_c *Reader_QuitRead_Call) Run(run func(ctx context.Context)) *Reader_QuitRead_Call
  • func (_c *Reader_QuitRead_Call) RunAndReturn(run func(context.Context)) *Reader_QuitRead_Call
• type Reader_StartRead_Call
  • func (_c *Reader_StartRead_Call) Return() *Reader_StartRead_Call
  • func (_c *Reader_StartRead_Call) Run(run func(ctx context.Context)) *Reader_StartRead_Call
  • func (_c *Reader_StartRead_Call) RunAndReturn(run func(context.Context)) *Reader_StartRead_Call
• type ReplicateMeta
  • func NewReplicateMeta(t interface{ ... }) *ReplicateMeta
  • func (_m *ReplicateMeta) EXPECT() *ReplicateMeta_Expecter
  • func (_m *ReplicateMeta) GetTaskDropCollectionMsg(ctx context.Context, taskID string, msgID string) ([]api.TaskDropCollectionMsg, error)
  • func (_m *ReplicateMeta) GetTaskDropPartitionMsg(ctx context.Context, taskID string, msgID string) ([]api.TaskDropPartitionMsg, error)
  • func (_m *ReplicateMeta) RemoveTaskMsg(ctx context.Context, taskID string, msgID string) error
  • func (_m *ReplicateMeta) UpdateTaskDropCollectionMsg(ctx context.Context, msg api.TaskDropCollectionMsg) (bool, error)
  • func (_m *ReplicateMeta) UpdateTaskDropPartitionMsg(ctx context.Context, msg api.TaskDropPartitionMsg) (bool, error)
• type ReplicateMeta_Expecter
  • func (_e *ReplicateMeta_Expecter) GetTaskDropCollectionMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_GetTaskDropCollectionMsg_Call
  • func (_e *ReplicateMeta_Expecter) GetTaskDropPartitionMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_GetTaskDropPartitionMsg_Call
  • func (_e *ReplicateMeta_Expecter) RemoveTaskMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_RemoveTaskMsg_Call
  • func (_e *ReplicateMeta_Expecter) UpdateTaskDropCollectionMsg(ctx interface{}, msg interface{}) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call
  • func (_e *ReplicateMeta_Expecter) UpdateTaskDropPartitionMsg(ctx interface{}, msg interface{}) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call
• type ReplicateMeta_GetTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) Return(_a0 []api.TaskDropCollectionMsg, _a1 error) *ReplicateMeta_GetTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_GetTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) RunAndReturn(run func(context.Context, string, string) ([]api.TaskDropCollectionMsg, error)) *ReplicateMeta_GetTaskDropCollectionMsg_Call
• type ReplicateMeta_GetTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) Return(_a0 []api.TaskDropPartitionMsg, _a1 error) *ReplicateMeta_GetTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_GetTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) RunAndReturn(run func(context.Context, string, string) ([]api.TaskDropPartitionMsg, error)) *ReplicateMeta_GetTaskDropPartitionMsg_Call
• type ReplicateMeta_RemoveTaskMsg_Call
  • func (_c *ReplicateMeta_RemoveTaskMsg_Call) Return(_a0 error) *ReplicateMeta_RemoveTaskMsg_Call
  • func (_c *ReplicateMeta_RemoveTaskMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_RemoveTaskMsg_Call
  • func (_c *ReplicateMeta_RemoveTaskMsg_Call) RunAndReturn(run func(context.Context, string, string) error) *ReplicateMeta_RemoveTaskMsg_Call
• type ReplicateMeta_UpdateTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Return(_a0 bool, _a1 error) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Run(run func(ctx context.Context, msg api.TaskDropCollectionMsg)) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) RunAndReturn(run func(context.Context, api.TaskDropCollectionMsg) (bool, error)) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call
• type ReplicateMeta_UpdateTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Return(_a0 bool, _a1 error) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Run(run func(ctx context.Context, msg api.TaskDropPartitionMsg)) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call
  • func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) RunAndReturn(run func(context.Context, api.TaskDropPartitionMsg) (bool, error)) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call
• type ReplicateStore
  • func NewReplicateStore(t interface{ ... }) *ReplicateStore
  • func (_m *ReplicateStore) EXPECT() *ReplicateStore_Expecter
  • func (_m *ReplicateStore) Get(ctx context.Context, key string, withPrefix bool) ([]api.MetaMsg, error)
  • func (_m *ReplicateStore) Put(ctx context.Context, key string, value api.MetaMsg) error
  • func (_m *ReplicateStore) Remove(ctx context.Context, key string) error
• type ReplicateStore_Expecter
  • func (_e *ReplicateStore_Expecter) Get(ctx interface{}, key interface{}, withPrefix interface{}) *ReplicateStore_Get_Call
  • func (_e *ReplicateStore_Expecter) Put(ctx interface{}, key interface{}, value interface{}) *ReplicateStore_Put_Call
  • func (_e *ReplicateStore_Expecter) Remove(ctx interface{}, key interface{}) *ReplicateStore_Remove_Call
• type ReplicateStore_Get_Call
  • func (_c *ReplicateStore_Get_Call) Return(_a0 []api.MetaMsg, _a1 error) *ReplicateStore_Get_Call
  • func (_c *ReplicateStore_Get_Call) Run(run func(ctx context.Context, key string, withPrefix bool)) *ReplicateStore_Get_Call
  • func (_c *ReplicateStore_Get_Call) RunAndReturn(run func(context.Context, string, bool) ([]api.MetaMsg, error)) *ReplicateStore_Get_Call
• type ReplicateStore_Put_Call
  • func (_c *ReplicateStore_Put_Call) Return(_a0 error) *ReplicateStore_Put_Call
  • func (_c *ReplicateStore_Put_Call) Run(run func(ctx context.Context, key string, value api.MetaMsg)) *ReplicateStore_Put_Call
  • func (_c *ReplicateStore_Put_Call) RunAndReturn(run func(context.Context, string, api.MetaMsg) error) *ReplicateStore_Put_Call
• type ReplicateStore_Remove_Call
  • func (_c *ReplicateStore_Remove_Call) Return(_a0 error) *ReplicateStore_Remove_Call
  • func (_c *ReplicateStore_Remove_Call) Run(run func(ctx context.Context, key string)) *ReplicateStore_Remove_Call
  • func (_c *ReplicateStore_Remove_Call) RunAndReturn(run func(context.Context, string) error) *ReplicateStore_Remove_Call
• type TargetAPI
  • func NewTargetAPI(t interface{ ... }) *TargetAPI
  • func (_m *TargetAPI) EXPECT() *TargetAPI_Expecter
  • func (_m *TargetAPI) GetCollectionInfo(ctx context.Context, collectionName string, databaseName string) (*model.CollectionInfo, error)
  • func (_m *TargetAPI) GetDatabaseName(ctx context.Context, collectionName string, databaseName string) (string, error)
  • func (_m *TargetAPI) GetPartitionInfo(ctx context.Context, collectionName string, databaseName string) (*model.CollectionInfo, error)
• type TargetAPI_Expecter
  • func (_e *TargetAPI_Expecter) GetCollectionInfo(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetCollectionInfo_Call
  • func (_e *TargetAPI_Expecter) GetDatabaseName(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetDatabaseName_Call
  • func (_e *TargetAPI_Expecter) GetPartitionInfo(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetPartitionInfo_Call
• type TargetAPI_GetCollectionInfo_Call
  • func (_c *TargetAPI_GetCollectionInfo_Call) Return(_a0 *model.CollectionInfo, _a1 error) *TargetAPI_GetCollectionInfo_Call
  • func (_c *TargetAPI_GetCollectionInfo_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetCollectionInfo_Call
  • func (_c *TargetAPI_GetCollectionInfo_Call) RunAndReturn(run func(context.Context, string, string) (*model.CollectionInfo, error)) *TargetAPI_GetCollectionInfo_Call
• type TargetAPI_GetDatabaseName_Call
  • func (_c *TargetAPI_GetDatabaseName_Call) Return(_a0 string, _a1 error) *TargetAPI_GetDatabaseName_Call
  • func (_c *TargetAPI_GetDatabaseName_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetDatabaseName_Call
  • func (_c *TargetAPI_GetDatabaseName_Call) RunAndReturn(run func(context.Context, string, string) (string, error)) *TargetAPI_GetDatabaseName_Call
• type TargetAPI_GetPartitionInfo_Call
  • func (_c *TargetAPI_GetPartitionInfo_Call) Return(_a0 *model.CollectionInfo, _a1 error) *TargetAPI_GetPartitionInfo_Call
  • func (_c *TargetAPI_GetPartitionInfo_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetPartitionInfo_Call
  • func (_c *TargetAPI_GetPartitionInfo_Call) RunAndReturn(run func(context.Context, string, string) (*model.CollectionInfo, error)) *TargetAPI_GetPartitionInfo_Call
• type Writer
  • func NewWriter(t interface{ ... }) *Writer
  • func (_m *Writer) EXPECT() *Writer_Expecter
  • func (_m *Writer) HandleOpMessagePack(ctx context.Context, msgPack *msgstream.MsgPack) ([]byte, error)
  • func (_m *Writer) HandleReplicateAPIEvent(ctx context.Context, apiEvent *api.ReplicateAPIEvent) error
  • func (_m *Writer) HandleReplicateMessage(ctx context.Context, channelName string, msgPack *msgstream.MsgPack) ([]byte, []byte, error)
  • func (_m *Writer) RecoveryMetaMsg(ctx context.Context, taskID string) error
• type Writer_Expecter
  • func (_e *Writer_Expecter) HandleOpMessagePack(ctx interface{}, msgPack interface{}) *Writer_HandleOpMessagePack_Call
  • func (_e *Writer_Expecter) HandleReplicateAPIEvent(ctx interface{}, apiEvent interface{}) *Writer_HandleReplicateAPIEvent_Call
  • func (_e *Writer_Expecter) HandleReplicateMessage(ctx interface{}, channelName interface{}, msgPack interface{}) *Writer_HandleReplicateMessage_Call
  • func (_e *Writer_Expecter) RecoveryMetaMsg(ctx interface{}, taskID interface{}) *Writer_RecoveryMetaMsg_Call
• type Writer_HandleOpMessagePack_Call
  • func (_c *Writer_HandleOpMessagePack_Call) Return(_a0 []byte, _a1 error) *Writer_HandleOpMessagePack_Call
  • func (_c *Writer_HandleOpMessagePack_Call) Run(run func(ctx context.Context, msgPack *msgstream.MsgPack)) *Writer_HandleOpMessagePack_Call
  • func (_c *Writer_HandleOpMessagePack_Call) RunAndReturn(run func(context.Context, *msgstream.MsgPack) ([]byte, error)) *Writer_HandleOpMessagePack_Call
• type Writer_HandleReplicateAPIEvent_Call
  • func (_c *Writer_HandleReplicateAPIEvent_Call) Return(_a0 error) *Writer_HandleReplicateAPIEvent_Call
  • func (_c *Writer_HandleReplicateAPIEvent_Call) Run(run func(ctx context.Context, apiEvent *api.ReplicateAPIEvent)) *Writer_HandleReplicateAPIEvent_Call
  • func (_c *Writer_HandleReplicateAPIEvent_Call) RunAndReturn(run func(context.Context, *api.ReplicateAPIEvent) error) *Writer_HandleReplicateAPIEvent_Call
• type Writer_HandleReplicateMessage_Call
  • func (_c *Writer_HandleReplicateMessage_Call) Return(_a0 []byte, _a1 []byte, _a2 error) *Writer_HandleReplicateMessage_Call
  • func (_c *Writer_HandleReplicateMessage_Call) Run(run func(ctx context.Context, channelName string, msgPack *msgstream.MsgPack)) *Writer_HandleReplicateMessage_Call
  • func (_c *Writer_HandleReplicateMessage_Call) RunAndReturn(run func(context.Context, string, *msgstream.MsgPack) ([]byte, []byte, error)) *Writer_HandleReplicateMessage_Call
• type Writer_RecoveryMetaMsg_Call
  • func (_c *Writer_RecoveryMetaMsg_Call) Return(_a0 error) *Writer_RecoveryMetaMsg_Call
  • func (_c *Writer_RecoveryMetaMsg_Call) Run(run func(ctx context.Context, taskID string)) *Writer_RecoveryMetaMsg_Call
  • func (_c *Writer_RecoveryMetaMsg_Call) RunAndReturn(run func(context.Context, string) error) *Writer_RecoveryMetaMsg_Call

Types

type ChannelManager

type ChannelManager struct {
	mock.Mock
}

ChannelManager is an autogenerated mock type for the ChannelManager type

func NewChannelManager

func NewChannelManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ChannelManager

NewChannelManager creates a new instance of ChannelManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ChannelManager) AddDroppedCollection

func (_m *ChannelManager) AddDroppedCollection(ids []int64)

AddDroppedCollection provides a mock function with given fields: ids

func (*ChannelManager) AddDroppedPartition

func (_m *ChannelManager) AddDroppedPartition(ids []int64)

AddDroppedPartition provides a mock function with given fields: ids

func (*ChannelManager) AddPartition

func (_m *ChannelManager) AddPartition(ctx context.Context, dbInfo *model.DatabaseInfo, collectionInfo *pb.CollectionInfo, partitionInfo *pb.PartitionInfo) error

AddPartition provides a mock function with given fields: ctx, dbInfo, collectionInfo, partitionInfo

func (*ChannelManager) EXPECT

func (_m *ChannelManager) EXPECT() *ChannelManager_Expecter

func (*ChannelManager) GetChannelChan

func (_m *ChannelManager) GetChannelChan() <-chan string

GetChannelChan provides a mock function with given fields:

func (*ChannelManager) GetChannelLatestMsgID

func (_m *ChannelManager) GetChannelLatestMsgID(ctx context.Context, channelName string) ([]byte, error)

GetChannelLatestMsgID provides a mock function with given fields: ctx, channelName

func (*ChannelManager) GetEventChan

func (_m *ChannelManager) GetEventChan() <-chan *api.ReplicateAPIEvent

GetEventChan provides a mock function with given fields:

func (*ChannelManager) GetMsgChan

func (_m *ChannelManager) GetMsgChan(pChannel string) <-chan *api.ReplicateMsg

GetMsgChan provides a mock function with given fields: pChannel

func (*ChannelManager) SetCtx

func (_m *ChannelManager) SetCtx(ctx context.Context)

SetCtx provides a mock function with given fields: ctx

func (*ChannelManager) StartReadCollection

func (_m *ChannelManager) StartReadCollection(ctx context.Context, db *model.DatabaseInfo, info *pb.CollectionInfo, seekPositions []*msgpb.MsgPosition) error

StartReadCollection provides a mock function with given fields: ctx, db, info, seekPositions

func (*ChannelManager) StopReadCollection

func (_m *ChannelManager) StopReadCollection(ctx context.Context, info *pb.CollectionInfo) error

StopReadCollection provides a mock function with given fields: ctx, info

type ChannelManager_AddDroppedCollection_Call

type ChannelManager_AddDroppedCollection_Call struct {
	*mock.Call
}

ChannelManager_AddDroppedCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddDroppedCollection'

func (*ChannelManager_AddDroppedCollection_Call) Return

func (_c *ChannelManager_AddDroppedCollection_Call) Return() *ChannelManager_AddDroppedCollection_Call

func (*ChannelManager_AddDroppedCollection_Call) Run

func (_c *ChannelManager_AddDroppedCollection_Call) Run(run func(ids []int64)) *ChannelManager_AddDroppedCollection_Call

func (*ChannelManager_AddDroppedCollection_Call) RunAndReturn

func (_c *ChannelManager_AddDroppedCollection_Call) RunAndReturn(run func([]int64)) *ChannelManager_AddDroppedCollection_Call

type ChannelManager_AddDroppedPartition_Call

type ChannelManager_AddDroppedPartition_Call struct {
	*mock.Call
}

ChannelManager_AddDroppedPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddDroppedPartition'

func (*ChannelManager_AddDroppedPartition_Call) Return

func (_c *ChannelManager_AddDroppedPartition_Call) Return() *ChannelManager_AddDroppedPartition_Call

func (*ChannelManager_AddDroppedPartition_Call) Run

func (_c *ChannelManager_AddDroppedPartition_Call) Run(run func(ids []int64)) *ChannelManager_AddDroppedPartition_Call

func (*ChannelManager_AddDroppedPartition_Call) RunAndReturn

func (_c *ChannelManager_AddDroppedPartition_Call) RunAndReturn(run func([]int64)) *ChannelManager_AddDroppedPartition_Call

type ChannelManager_AddPartition_Call

type ChannelManager_AddPartition_Call struct {
	*mock.Call
}

ChannelManager_AddPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPartition'

func (*ChannelManager_AddPartition_Call) Return

func (_c *ChannelManager_AddPartition_Call) Return(_a0 error) *ChannelManager_AddPartition_Call

func (*ChannelManager_AddPartition_Call) Run

func (_c *ChannelManager_AddPartition_Call) Run(run func(ctx context.Context, dbInfo *model.DatabaseInfo, collectionInfo *pb.CollectionInfo, partitionInfo *pb.PartitionInfo)) *ChannelManager_AddPartition_Call

func (*ChannelManager_AddPartition_Call) RunAndReturn

func (_c *ChannelManager_AddPartition_Call) RunAndReturn(run func(context.Context, *model.DatabaseInfo, *pb.CollectionInfo, *pb.PartitionInfo) error) *ChannelManager_AddPartition_Call

type ChannelManager_Expecter

type ChannelManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*ChannelManager_Expecter) AddDroppedCollection

func (_e *ChannelManager_Expecter) AddDroppedCollection(ids interface{}) *ChannelManager_AddDroppedCollection_Call

AddDroppedCollection is a helper method to define mock.On call

• ids []int64

func (*ChannelManager_Expecter) AddDroppedPartition

func (_e *ChannelManager_Expecter) AddDroppedPartition(ids interface{}) *ChannelManager_AddDroppedPartition_Call

AddDroppedPartition is a helper method to define mock.On call

• ids []int64

func (*ChannelManager_Expecter) AddPartition

func (_e *ChannelManager_Expecter) AddPartition(ctx interface{}, dbInfo interface{}, collectionInfo interface{}, partitionInfo interface{}) *ChannelManager_AddPartition_Call

AddPartition is a helper method to define mock.On call

• ctx context.Context
• dbInfo *model.DatabaseInfo
• collectionInfo *pb.CollectionInfo
• partitionInfo *pb.PartitionInfo

func (*ChannelManager_Expecter) GetChannelChan

func (_e *ChannelManager_Expecter) GetChannelChan() *ChannelManager_GetChannelChan_Call

GetChannelChan is a helper method to define mock.On call

func (*ChannelManager_Expecter) GetChannelLatestMsgID

func (_e *ChannelManager_Expecter) GetChannelLatestMsgID(ctx interface{}, channelName interface{}) *ChannelManager_GetChannelLatestMsgID_Call

GetChannelLatestMsgID is a helper method to define mock.On call

• ctx context.Context
• channelName string

func (*ChannelManager_Expecter) GetEventChan

func (_e *ChannelManager_Expecter) GetEventChan() *ChannelManager_GetEventChan_Call

GetEventChan is a helper method to define mock.On call

func (*ChannelManager_Expecter) GetMsgChan

func (_e *ChannelManager_Expecter) GetMsgChan(pChannel interface{}) *ChannelManager_GetMsgChan_Call

GetMsgChan is a helper method to define mock.On call

• pChannel string

func (*ChannelManager_Expecter) SetCtx

func (_e *ChannelManager_Expecter) SetCtx(ctx interface{}) *ChannelManager_SetCtx_Call

SetCtx is a helper method to define mock.On call

• ctx context.Context

func (*ChannelManager_Expecter) StartReadCollection

func (_e *ChannelManager_Expecter) StartReadCollection(ctx interface{}, db interface{}, info interface{}, seekPositions interface{}) *ChannelManager_StartReadCollection_Call

StartReadCollection is a helper method to define mock.On call

• ctx context.Context
• db *model.DatabaseInfo
• info *pb.CollectionInfo
• seekPositions []*msgpb.MsgPosition

func (*ChannelManager_Expecter) StopReadCollection

func (_e *ChannelManager_Expecter) StopReadCollection(ctx interface{}, info interface{}) *ChannelManager_StopReadCollection_Call

StopReadCollection is a helper method to define mock.On call

• ctx context.Context
• info *pb.CollectionInfo

type ChannelManager_GetChannelChan_Call

type ChannelManager_GetChannelChan_Call struct {
	*mock.Call
}

ChannelManager_GetChannelChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChannelChan'

func (*ChannelManager_GetChannelChan_Call) Return

func (_c *ChannelManager_GetChannelChan_Call) Return(_a0 <-chan string) *ChannelManager_GetChannelChan_Call

func (*ChannelManager_GetChannelChan_Call) Run

func (_c *ChannelManager_GetChannelChan_Call) Run(run func()) *ChannelManager_GetChannelChan_Call

func (*ChannelManager_GetChannelChan_Call) RunAndReturn

func (_c *ChannelManager_GetChannelChan_Call) RunAndReturn(run func() <-chan string) *ChannelManager_GetChannelChan_Call

type ChannelManager_GetChannelLatestMsgID_Call

type ChannelManager_GetChannelLatestMsgID_Call struct {
	*mock.Call
}

ChannelManager_GetChannelLatestMsgID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetChannelLatestMsgID'

func (*ChannelManager_GetChannelLatestMsgID_Call) Return

func (_c *ChannelManager_GetChannelLatestMsgID_Call) Return(_a0 []byte, _a1 error) *ChannelManager_GetChannelLatestMsgID_Call

func (*ChannelManager_GetChannelLatestMsgID_Call) Run

func (_c *ChannelManager_GetChannelLatestMsgID_Call) Run(run func(ctx context.Context, channelName string)) *ChannelManager_GetChannelLatestMsgID_Call

func (*ChannelManager_GetChannelLatestMsgID_Call) RunAndReturn

func (_c *ChannelManager_GetChannelLatestMsgID_Call) RunAndReturn(run func(context.Context, string) ([]byte, error)) *ChannelManager_GetChannelLatestMsgID_Call

type ChannelManager_GetEventChan_Call

type ChannelManager_GetEventChan_Call struct {
	*mock.Call
}

ChannelManager_GetEventChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEventChan'

func (*ChannelManager_GetEventChan_Call) Return

func (_c *ChannelManager_GetEventChan_Call) Return(_a0 <-chan *api.ReplicateAPIEvent) *ChannelManager_GetEventChan_Call

func (*ChannelManager_GetEventChan_Call) Run

func (_c *ChannelManager_GetEventChan_Call) Run(run func()) *ChannelManager_GetEventChan_Call

func (*ChannelManager_GetEventChan_Call) RunAndReturn

func (_c *ChannelManager_GetEventChan_Call) RunAndReturn(run func() <-chan *api.ReplicateAPIEvent) *ChannelManager_GetEventChan_Call

type ChannelManager_GetMsgChan_Call

type ChannelManager_GetMsgChan_Call struct {
	*mock.Call
}

ChannelManager_GetMsgChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMsgChan'

func (*ChannelManager_GetMsgChan_Call) Return

func (_c *ChannelManager_GetMsgChan_Call) Return(_a0 <-chan *api.ReplicateMsg) *ChannelManager_GetMsgChan_Call

func (*ChannelManager_GetMsgChan_Call) Run

func (_c *ChannelManager_GetMsgChan_Call) Run(run func(pChannel string)) *ChannelManager_GetMsgChan_Call

func (*ChannelManager_GetMsgChan_Call) RunAndReturn

func (_c *ChannelManager_GetMsgChan_Call) RunAndReturn(run func(string) <-chan *api.ReplicateMsg) *ChannelManager_GetMsgChan_Call

type ChannelManager_SetCtx_Call

type ChannelManager_SetCtx_Call struct {
	*mock.Call
}

ChannelManager_SetCtx_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetCtx'

func (*ChannelManager_SetCtx_Call) Return

func (_c *ChannelManager_SetCtx_Call) Return() *ChannelManager_SetCtx_Call

func (*ChannelManager_SetCtx_Call) Run

func (_c *ChannelManager_SetCtx_Call) Run(run func(ctx context.Context)) *ChannelManager_SetCtx_Call

func (*ChannelManager_SetCtx_Call) RunAndReturn

func (_c *ChannelManager_SetCtx_Call) RunAndReturn(run func(context.Context)) *ChannelManager_SetCtx_Call

type ChannelManager_StartReadCollection_Call

type ChannelManager_StartReadCollection_Call struct {
	*mock.Call
}

ChannelManager_StartReadCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartReadCollection'

func (*ChannelManager_StartReadCollection_Call) Return

func (_c *ChannelManager_StartReadCollection_Call) Return(_a0 error) *ChannelManager_StartReadCollection_Call

func (*ChannelManager_StartReadCollection_Call) Run

func (_c *ChannelManager_StartReadCollection_Call) Run(run func(ctx context.Context, db *model.DatabaseInfo, info *pb.CollectionInfo, seekPositions []*msgpb.MsgPosition)) *ChannelManager_StartReadCollection_Call

func (*ChannelManager_StartReadCollection_Call) RunAndReturn

func (_c *ChannelManager_StartReadCollection_Call) RunAndReturn(run func(context.Context, *model.DatabaseInfo, *pb.CollectionInfo, []*msgpb.MsgPosition) error) *ChannelManager_StartReadCollection_Call

type ChannelManager_StopReadCollection_Call

type ChannelManager_StopReadCollection_Call struct {
	*mock.Call
}

ChannelManager_StopReadCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopReadCollection'

func (*ChannelManager_StopReadCollection_Call) Return

func (_c *ChannelManager_StopReadCollection_Call) Return(_a0 error) *ChannelManager_StopReadCollection_Call

func (*ChannelManager_StopReadCollection_Call) Run

func (_c *ChannelManager_StopReadCollection_Call) Run(run func(ctx context.Context, info *pb.CollectionInfo)) *ChannelManager_StopReadCollection_Call

func (*ChannelManager_StopReadCollection_Call) RunAndReturn

func (_c *ChannelManager_StopReadCollection_Call) RunAndReturn(run func(context.Context, *pb.CollectionInfo) error) *ChannelManager_StopReadCollection_Call

type DataHandler

type DataHandler struct {
	mock.Mock
}

DataHandler is an autogenerated mock type for the DataHandler type

func NewDataHandler

func NewDataHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *DataHandler

NewDataHandler creates a new instance of DataHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DataHandler) AlterDatabase

func (_m *DataHandler) AlterDatabase(ctx context.Context, param *api.AlterDatabaseParam) error

AlterDatabase provides a mock function with given fields: ctx, param

func (*DataHandler) AlterIndex

func (_m *DataHandler) AlterIndex(ctx context.Context, param *api.AlterIndexParam) error

AlterIndex provides a mock function with given fields: ctx, param

func (*DataHandler) CreateCollection

func (_m *DataHandler) CreateCollection(ctx context.Context, param *api.CreateCollectionParam) error

CreateCollection provides a mock function with given fields: ctx, param

func (*DataHandler) CreateDatabase

func (_m *DataHandler) CreateDatabase(ctx context.Context, param *api.CreateDatabaseParam) error

CreateDatabase provides a mock function with given fields: ctx, param

func (*DataHandler) CreateIndex

func (_m *DataHandler) CreateIndex(ctx context.Context, param *api.CreateIndexParam) error

CreateIndex provides a mock function with given fields: ctx, param

func (*DataHandler) CreatePartition

func (_m *DataHandler) CreatePartition(ctx context.Context, param *api.CreatePartitionParam) error

CreatePartition provides a mock function with given fields: ctx, param

func (*DataHandler) CreateRole

func (_m *DataHandler) CreateRole(ctx context.Context, param *api.CreateRoleParam) error

CreateRole provides a mock function with given fields: ctx, param

func (*DataHandler) CreateUser

func (_m *DataHandler) CreateUser(ctx context.Context, param *api.CreateUserParam) error

CreateUser provides a mock function with given fields: ctx, param

func (*DataHandler) Delete

func (_m *DataHandler) Delete(ctx context.Context, param *api.DeleteParam) error

Delete provides a mock function with given fields: ctx, param

func (*DataHandler) DeleteUser

func (_m *DataHandler) DeleteUser(ctx context.Context, param *api.DeleteUserParam) error

DeleteUser provides a mock function with given fields: ctx, param

func (*DataHandler) DescribeCollection

func (_m *DataHandler) DescribeCollection(ctx context.Context, param *api.DescribeCollectionParam) error

DescribeCollection provides a mock function with given fields: ctx, param

func (*DataHandler) DescribeDatabase

func (_m *DataHandler) DescribeDatabase(ctx context.Context, param *api.DescribeDatabaseParam) error

DescribeDatabase provides a mock function with given fields: ctx, param

func (*DataHandler) DescribePartition

func (_m *DataHandler) DescribePartition(ctx context.Context, param *api.DescribePartitionParam) error

DescribePartition provides a mock function with given fields: ctx, param

func (*DataHandler) DropCollection

func (_m *DataHandler) DropCollection(ctx context.Context, param *api.DropCollectionParam) error

DropCollection provides a mock function with given fields: ctx, param

func (*DataHandler) DropDatabase

func (_m *DataHandler) DropDatabase(ctx context.Context, param *api.DropDatabaseParam) error

DropDatabase provides a mock function with given fields: ctx, param

func (*DataHandler) DropIndex

func (_m *DataHandler) DropIndex(ctx context.Context, param *api.DropIndexParam) error

DropIndex provides a mock function with given fields: ctx, param

func (*DataHandler) DropPartition

func (_m *DataHandler) DropPartition(ctx context.Context, param *api.DropPartitionParam) error

DropPartition provides a mock function with given fields: ctx, param

func (*DataHandler) DropRole

func (_m *DataHandler) DropRole(ctx context.Context, param *api.DropRoleParam) error

DropRole provides a mock function with given fields: ctx, param

func (*DataHandler) EXPECT

func (_m *DataHandler) EXPECT() *DataHandler_Expecter

func (*DataHandler) Flush

func (_m *DataHandler) Flush(ctx context.Context, param *api.FlushParam) error

Flush provides a mock function with given fields: ctx, param

func (*DataHandler) Insert

func (_m *DataHandler) Insert(ctx context.Context, param *api.InsertParam) error

Insert provides a mock function with given fields: ctx, param

func (*DataHandler) LoadCollection

func (_m *DataHandler) LoadCollection(ctx context.Context, param *api.LoadCollectionParam) error

LoadCollection provides a mock function with given fields: ctx, param

func (*DataHandler) LoadPartitions

func (_m *DataHandler) LoadPartitions(ctx context.Context, param *api.LoadPartitionsParam) error

LoadPartitions provides a mock function with given fields: ctx, param

func (*DataHandler) OperatePrivilege

func (_m *DataHandler) OperatePrivilege(ctx context.Context, param *api.OperatePrivilegeParam) error

OperatePrivilege provides a mock function with given fields: ctx, param

func (*DataHandler) OperateUserRole

func (_m *DataHandler) OperateUserRole(ctx context.Context, param *api.OperateUserRoleParam) error

OperateUserRole provides a mock function with given fields: ctx, param

func (*DataHandler) ReleaseCollection

func (_m *DataHandler) ReleaseCollection(ctx context.Context, param *api.ReleaseCollectionParam) error

ReleaseCollection provides a mock function with given fields: ctx, param

func (*DataHandler) ReleasePartitions

func (_m *DataHandler) ReleasePartitions(ctx context.Context, param *api.ReleasePartitionsParam) error

ReleasePartitions provides a mock function with given fields: ctx, param

func (*DataHandler) ReplicateMessage

func (_m *DataHandler) ReplicateMessage(ctx context.Context, param *api.ReplicateMessageParam) error

ReplicateMessage provides a mock function with given fields: ctx, param

func (*DataHandler) UpdateUser

func (_m *DataHandler) UpdateUser(ctx context.Context, param *api.UpdateUserParam) error

UpdateUser provides a mock function with given fields: ctx, param

type DataHandler_AlterDatabase_Call

type DataHandler_AlterDatabase_Call struct {
	*mock.Call
}

DataHandler_AlterDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterDatabase'

func (*DataHandler_AlterDatabase_Call) Return

func (_c *DataHandler_AlterDatabase_Call) Return(_a0 error) *DataHandler_AlterDatabase_Call

func (*DataHandler_AlterDatabase_Call) Run

func (_c *DataHandler_AlterDatabase_Call) Run(run func(ctx context.Context, param *api.AlterDatabaseParam)) *DataHandler_AlterDatabase_Call

func (*DataHandler_AlterDatabase_Call) RunAndReturn

func (_c *DataHandler_AlterDatabase_Call) RunAndReturn(run func(context.Context, *api.AlterDatabaseParam) error) *DataHandler_AlterDatabase_Call

type DataHandler_AlterIndex_Call

type DataHandler_AlterIndex_Call struct {
	*mock.Call
}

DataHandler_AlterIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterIndex'

func (*DataHandler_AlterIndex_Call) Return

func (_c *DataHandler_AlterIndex_Call) Return(_a0 error) *DataHandler_AlterIndex_Call

func (*DataHandler_AlterIndex_Call) Run

func (_c *DataHandler_AlterIndex_Call) Run(run func(ctx context.Context, param *api.AlterIndexParam)) *DataHandler_AlterIndex_Call

func (*DataHandler_AlterIndex_Call) RunAndReturn

func (_c *DataHandler_AlterIndex_Call) RunAndReturn(run func(context.Context, *api.AlterIndexParam) error) *DataHandler_AlterIndex_Call

type DataHandler_CreateCollection_Call

type DataHandler_CreateCollection_Call struct {
	*mock.Call
}

DataHandler_CreateCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateCollection'

func (*DataHandler_CreateCollection_Call) Return

func (_c *DataHandler_CreateCollection_Call) Return(_a0 error) *DataHandler_CreateCollection_Call

func (*DataHandler_CreateCollection_Call) Run

func (_c *DataHandler_CreateCollection_Call) Run(run func(ctx context.Context, param *api.CreateCollectionParam)) *DataHandler_CreateCollection_Call

func (*DataHandler_CreateCollection_Call) RunAndReturn

func (_c *DataHandler_CreateCollection_Call) RunAndReturn(run func(context.Context, *api.CreateCollectionParam) error) *DataHandler_CreateCollection_Call

type DataHandler_CreateDatabase_Call

type DataHandler_CreateDatabase_Call struct {
	*mock.Call
}

DataHandler_CreateDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateDatabase'

func (*DataHandler_CreateDatabase_Call) Return

func (_c *DataHandler_CreateDatabase_Call) Return(_a0 error) *DataHandler_CreateDatabase_Call

func (*DataHandler_CreateDatabase_Call) Run

func (_c *DataHandler_CreateDatabase_Call) Run(run func(ctx context.Context, param *api.CreateDatabaseParam)) *DataHandler_CreateDatabase_Call

func (*DataHandler_CreateDatabase_Call) RunAndReturn

func (_c *DataHandler_CreateDatabase_Call) RunAndReturn(run func(context.Context, *api.CreateDatabaseParam) error) *DataHandler_CreateDatabase_Call

type DataHandler_CreateIndex_Call

type DataHandler_CreateIndex_Call struct {
	*mock.Call
}

DataHandler_CreateIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateIndex'

func (*DataHandler_CreateIndex_Call) Return

func (_c *DataHandler_CreateIndex_Call) Return(_a0 error) *DataHandler_CreateIndex_Call

func (*DataHandler_CreateIndex_Call) Run

func (_c *DataHandler_CreateIndex_Call) Run(run func(ctx context.Context, param *api.CreateIndexParam)) *DataHandler_CreateIndex_Call

func (*DataHandler_CreateIndex_Call) RunAndReturn

func (_c *DataHandler_CreateIndex_Call) RunAndReturn(run func(context.Context, *api.CreateIndexParam) error) *DataHandler_CreateIndex_Call

type DataHandler_CreatePartition_Call

type DataHandler_CreatePartition_Call struct {
	*mock.Call
}

DataHandler_CreatePartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreatePartition'

func (*DataHandler_CreatePartition_Call) Return

func (_c *DataHandler_CreatePartition_Call) Return(_a0 error) *DataHandler_CreatePartition_Call

func (*DataHandler_CreatePartition_Call) Run

func (_c *DataHandler_CreatePartition_Call) Run(run func(ctx context.Context, param *api.CreatePartitionParam)) *DataHandler_CreatePartition_Call

func (*DataHandler_CreatePartition_Call) RunAndReturn

func (_c *DataHandler_CreatePartition_Call) RunAndReturn(run func(context.Context, *api.CreatePartitionParam) error) *DataHandler_CreatePartition_Call

type DataHandler_CreateRole_Call

type DataHandler_CreateRole_Call struct {
	*mock.Call
}

DataHandler_CreateRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRole'

func (*DataHandler_CreateRole_Call) Return

func (_c *DataHandler_CreateRole_Call) Return(_a0 error) *DataHandler_CreateRole_Call

func (*DataHandler_CreateRole_Call) Run

func (_c *DataHandler_CreateRole_Call) Run(run func(ctx context.Context, param *api.CreateRoleParam)) *DataHandler_CreateRole_Call

func (*DataHandler_CreateRole_Call) RunAndReturn

func (_c *DataHandler_CreateRole_Call) RunAndReturn(run func(context.Context, *api.CreateRoleParam) error) *DataHandler_CreateRole_Call

type DataHandler_CreateUser_Call

type DataHandler_CreateUser_Call struct {
	*mock.Call
}

DataHandler_CreateUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateUser'

func (*DataHandler_CreateUser_Call) Return

func (_c *DataHandler_CreateUser_Call) Return(_a0 error) *DataHandler_CreateUser_Call

func (*DataHandler_CreateUser_Call) Run

func (_c *DataHandler_CreateUser_Call) Run(run func(ctx context.Context, param *api.CreateUserParam)) *DataHandler_CreateUser_Call

func (*DataHandler_CreateUser_Call) RunAndReturn

func (_c *DataHandler_CreateUser_Call) RunAndReturn(run func(context.Context, *api.CreateUserParam) error) *DataHandler_CreateUser_Call

type DataHandler_DeleteUser_Call

type DataHandler_DeleteUser_Call struct {
	*mock.Call
}

DataHandler_DeleteUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteUser'

func (*DataHandler_DeleteUser_Call) Return

func (_c *DataHandler_DeleteUser_Call) Return(_a0 error) *DataHandler_DeleteUser_Call

func (*DataHandler_DeleteUser_Call) Run

func (_c *DataHandler_DeleteUser_Call) Run(run func(ctx context.Context, param *api.DeleteUserParam)) *DataHandler_DeleteUser_Call

func (*DataHandler_DeleteUser_Call) RunAndReturn

func (_c *DataHandler_DeleteUser_Call) RunAndReturn(run func(context.Context, *api.DeleteUserParam) error) *DataHandler_DeleteUser_Call

type DataHandler_Delete_Call

type DataHandler_Delete_Call struct {
	*mock.Call
}

DataHandler_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*DataHandler_Delete_Call) Return

func (_c *DataHandler_Delete_Call) Return(_a0 error) *DataHandler_Delete_Call

func (*DataHandler_Delete_Call) Run

func (_c *DataHandler_Delete_Call) Run(run func(ctx context.Context, param *api.DeleteParam)) *DataHandler_Delete_Call

func (*DataHandler_Delete_Call) RunAndReturn

func (_c *DataHandler_Delete_Call) RunAndReturn(run func(context.Context, *api.DeleteParam) error) *DataHandler_Delete_Call

type DataHandler_DescribeCollection_Call

type DataHandler_DescribeCollection_Call struct {
	*mock.Call
}

DataHandler_DescribeCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeCollection'

func (*DataHandler_DescribeCollection_Call) Return

func (_c *DataHandler_DescribeCollection_Call) Return(_a0 error) *DataHandler_DescribeCollection_Call

func (*DataHandler_DescribeCollection_Call) Run

func (_c *DataHandler_DescribeCollection_Call) Run(run func(ctx context.Context, param *api.DescribeCollectionParam)) *DataHandler_DescribeCollection_Call

func (*DataHandler_DescribeCollection_Call) RunAndReturn

func (_c *DataHandler_DescribeCollection_Call) RunAndReturn(run func(context.Context, *api.DescribeCollectionParam) error) *DataHandler_DescribeCollection_Call

type DataHandler_DescribeDatabase_Call

type DataHandler_DescribeDatabase_Call struct {
	*mock.Call
}

DataHandler_DescribeDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeDatabase'

func (*DataHandler_DescribeDatabase_Call) Return

func (_c *DataHandler_DescribeDatabase_Call) Return(_a0 error) *DataHandler_DescribeDatabase_Call

func (*DataHandler_DescribeDatabase_Call) Run

func (_c *DataHandler_DescribeDatabase_Call) Run(run func(ctx context.Context, param *api.DescribeDatabaseParam)) *DataHandler_DescribeDatabase_Call

func (*DataHandler_DescribeDatabase_Call) RunAndReturn

func (_c *DataHandler_DescribeDatabase_Call) RunAndReturn(run func(context.Context, *api.DescribeDatabaseParam) error) *DataHandler_DescribeDatabase_Call

type DataHandler_DescribePartition_Call

type DataHandler_DescribePartition_Call struct {
	*mock.Call
}

DataHandler_DescribePartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribePartition'

func (*DataHandler_DescribePartition_Call) Return

func (_c *DataHandler_DescribePartition_Call) Return(_a0 error) *DataHandler_DescribePartition_Call

func (*DataHandler_DescribePartition_Call) Run

func (_c *DataHandler_DescribePartition_Call) Run(run func(ctx context.Context, param *api.DescribePartitionParam)) *DataHandler_DescribePartition_Call

func (*DataHandler_DescribePartition_Call) RunAndReturn

func (_c *DataHandler_DescribePartition_Call) RunAndReturn(run func(context.Context, *api.DescribePartitionParam) error) *DataHandler_DescribePartition_Call

type DataHandler_DropCollection_Call

type DataHandler_DropCollection_Call struct {
	*mock.Call
}

DataHandler_DropCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropCollection'

func (*DataHandler_DropCollection_Call) Return

func (_c *DataHandler_DropCollection_Call) Return(_a0 error) *DataHandler_DropCollection_Call

func (*DataHandler_DropCollection_Call) Run

func (_c *DataHandler_DropCollection_Call) Run(run func(ctx context.Context, param *api.DropCollectionParam)) *DataHandler_DropCollection_Call

func (*DataHandler_DropCollection_Call) RunAndReturn

func (_c *DataHandler_DropCollection_Call) RunAndReturn(run func(context.Context, *api.DropCollectionParam) error) *DataHandler_DropCollection_Call

type DataHandler_DropDatabase_Call

type DataHandler_DropDatabase_Call struct {
	*mock.Call
}

DataHandler_DropDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropDatabase'

func (*DataHandler_DropDatabase_Call) Return

func (_c *DataHandler_DropDatabase_Call) Return(_a0 error) *DataHandler_DropDatabase_Call

func (*DataHandler_DropDatabase_Call) Run

func (_c *DataHandler_DropDatabase_Call) Run(run func(ctx context.Context, param *api.DropDatabaseParam)) *DataHandler_DropDatabase_Call

func (*DataHandler_DropDatabase_Call) RunAndReturn

func (_c *DataHandler_DropDatabase_Call) RunAndReturn(run func(context.Context, *api.DropDatabaseParam) error) *DataHandler_DropDatabase_Call

type DataHandler_DropIndex_Call

type DataHandler_DropIndex_Call struct {
	*mock.Call
}

DataHandler_DropIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropIndex'

func (*DataHandler_DropIndex_Call) Return

func (_c *DataHandler_DropIndex_Call) Return(_a0 error) *DataHandler_DropIndex_Call

func (*DataHandler_DropIndex_Call) Run

func (_c *DataHandler_DropIndex_Call) Run(run func(ctx context.Context, param *api.DropIndexParam)) *DataHandler_DropIndex_Call

func (*DataHandler_DropIndex_Call) RunAndReturn

func (_c *DataHandler_DropIndex_Call) RunAndReturn(run func(context.Context, *api.DropIndexParam) error) *DataHandler_DropIndex_Call

type DataHandler_DropPartition_Call

type DataHandler_DropPartition_Call struct {
	*mock.Call
}

DataHandler_DropPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropPartition'

func (*DataHandler_DropPartition_Call) Return

func (_c *DataHandler_DropPartition_Call) Return(_a0 error) *DataHandler_DropPartition_Call

func (*DataHandler_DropPartition_Call) Run

func (_c *DataHandler_DropPartition_Call) Run(run func(ctx context.Context, param *api.DropPartitionParam)) *DataHandler_DropPartition_Call

func (*DataHandler_DropPartition_Call) RunAndReturn

func (_c *DataHandler_DropPartition_Call) RunAndReturn(run func(context.Context, *api.DropPartitionParam) error) *DataHandler_DropPartition_Call

type DataHandler_DropRole_Call

type DataHandler_DropRole_Call struct {
	*mock.Call
}

DataHandler_DropRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropRole'

func (*DataHandler_DropRole_Call) Return

func (_c *DataHandler_DropRole_Call) Return(_a0 error) *DataHandler_DropRole_Call

func (*DataHandler_DropRole_Call) Run

func (_c *DataHandler_DropRole_Call) Run(run func(ctx context.Context, param *api.DropRoleParam)) *DataHandler_DropRole_Call

func (*DataHandler_DropRole_Call) RunAndReturn

func (_c *DataHandler_DropRole_Call) RunAndReturn(run func(context.Context, *api.DropRoleParam) error) *DataHandler_DropRole_Call

type DataHandler_Expecter

type DataHandler_Expecter struct {
	// contains filtered or unexported fields
}

func (*DataHandler_Expecter) AlterDatabase

func (_e *DataHandler_Expecter) AlterDatabase(ctx interface{}, param interface{}) *DataHandler_AlterDatabase_Call

AlterDatabase is a helper method to define mock.On call

• ctx context.Context
• param *api.AlterDatabaseParam

func (*DataHandler_Expecter) AlterIndex

func (_e *DataHandler_Expecter) AlterIndex(ctx interface{}, param interface{}) *DataHandler_AlterIndex_Call

AlterIndex is a helper method to define mock.On call

• ctx context.Context
• param *api.AlterIndexParam

func (*DataHandler_Expecter) CreateCollection

func (_e *DataHandler_Expecter) CreateCollection(ctx interface{}, param interface{}) *DataHandler_CreateCollection_Call

CreateCollection is a helper method to define mock.On call

• ctx context.Context
• param *api.CreateCollectionParam

func (*DataHandler_Expecter) CreateDatabase

func (_e *DataHandler_Expecter) CreateDatabase(ctx interface{}, param interface{}) *DataHandler_CreateDatabase_Call

CreateDatabase is a helper method to define mock.On call

• ctx context.Context
• param *api.CreateDatabaseParam

func (*DataHandler_Expecter) CreateIndex

func (_e *DataHandler_Expecter) CreateIndex(ctx interface{}, param interface{}) *DataHandler_CreateIndex_Call

CreateIndex is a helper method to define mock.On call

• ctx context.Context
• param *api.CreateIndexParam

func (*DataHandler_Expecter) CreatePartition

func (_e *DataHandler_Expecter) CreatePartition(ctx interface{}, param interface{}) *DataHandler_CreatePartition_Call

CreatePartition is a helper method to define mock.On call

• ctx context.Context
• param *api.CreatePartitionParam

func (*DataHandler_Expecter) CreateRole

func (_e *DataHandler_Expecter) CreateRole(ctx interface{}, param interface{}) *DataHandler_CreateRole_Call

CreateRole is a helper method to define mock.On call

• ctx context.Context
• param *api.CreateRoleParam

func (*DataHandler_Expecter) CreateUser

func (_e *DataHandler_Expecter) CreateUser(ctx interface{}, param interface{}) *DataHandler_CreateUser_Call

CreateUser is a helper method to define mock.On call

• ctx context.Context
• param *api.CreateUserParam

func (*DataHandler_Expecter) Delete

func (_e *DataHandler_Expecter) Delete(ctx interface{}, param interface{}) *DataHandler_Delete_Call

Delete is a helper method to define mock.On call

• ctx context.Context
• param *api.DeleteParam

func (*DataHandler_Expecter) DeleteUser

func (_e *DataHandler_Expecter) DeleteUser(ctx interface{}, param interface{}) *DataHandler_DeleteUser_Call

DeleteUser is a helper method to define mock.On call

• ctx context.Context
• param *api.DeleteUserParam

func (*DataHandler_Expecter) DescribeCollection

func (_e *DataHandler_Expecter) DescribeCollection(ctx interface{}, param interface{}) *DataHandler_DescribeCollection_Call

DescribeCollection is a helper method to define mock.On call

• ctx context.Context
• param *api.DescribeCollectionParam

func (*DataHandler_Expecter) DescribeDatabase

func (_e *DataHandler_Expecter) DescribeDatabase(ctx interface{}, param interface{}) *DataHandler_DescribeDatabase_Call

DescribeDatabase is a helper method to define mock.On call

• ctx context.Context
• param *api.DescribeDatabaseParam

func (*DataHandler_Expecter) DescribePartition

func (_e *DataHandler_Expecter) DescribePartition(ctx interface{}, param interface{}) *DataHandler_DescribePartition_Call

DescribePartition is a helper method to define mock.On call

• ctx context.Context
• param *api.DescribePartitionParam

func (*DataHandler_Expecter) DropCollection

func (_e *DataHandler_Expecter) DropCollection(ctx interface{}, param interface{}) *DataHandler_DropCollection_Call

DropCollection is a helper method to define mock.On call

• ctx context.Context
• param *api.DropCollectionParam

func (*DataHandler_Expecter) DropDatabase

func (_e *DataHandler_Expecter) DropDatabase(ctx interface{}, param interface{}) *DataHandler_DropDatabase_Call

DropDatabase is a helper method to define mock.On call

• ctx context.Context
• param *api.DropDatabaseParam

func (*DataHandler_Expecter) DropIndex

func (_e *DataHandler_Expecter) DropIndex(ctx interface{}, param interface{}) *DataHandler_DropIndex_Call

DropIndex is a helper method to define mock.On call

• ctx context.Context
• param *api.DropIndexParam

func (*DataHandler_Expecter) DropPartition

func (_e *DataHandler_Expecter) DropPartition(ctx interface{}, param interface{}) *DataHandler_DropPartition_Call

DropPartition is a helper method to define mock.On call

• ctx context.Context
• param *api.DropPartitionParam

func (*DataHandler_Expecter) DropRole

func (_e *DataHandler_Expecter) DropRole(ctx interface{}, param interface{}) *DataHandler_DropRole_Call

DropRole is a helper method to define mock.On call

• ctx context.Context
• param *api.DropRoleParam

func (*DataHandler_Expecter) Flush

func (_e *DataHandler_Expecter) Flush(ctx interface{}, param interface{}) *DataHandler_Flush_Call

Flush is a helper method to define mock.On call

• ctx context.Context
• param *api.FlushParam

func (*DataHandler_Expecter) Insert

func (_e *DataHandler_Expecter) Insert(ctx interface{}, param interface{}) *DataHandler_Insert_Call

Insert is a helper method to define mock.On call

• ctx context.Context
• param *api.InsertParam

func (*DataHandler_Expecter) LoadCollection

func (_e *DataHandler_Expecter) LoadCollection(ctx interface{}, param interface{}) *DataHandler_LoadCollection_Call

LoadCollection is a helper method to define mock.On call

• ctx context.Context
• param *api.LoadCollectionParam

func (*DataHandler_Expecter) LoadPartitions

func (_e *DataHandler_Expecter) LoadPartitions(ctx interface{}, param interface{}) *DataHandler_LoadPartitions_Call

LoadPartitions is a helper method to define mock.On call

• ctx context.Context
• param *api.LoadPartitionsParam

func (*DataHandler_Expecter) OperatePrivilege

func (_e *DataHandler_Expecter) OperatePrivilege(ctx interface{}, param interface{}) *DataHandler_OperatePrivilege_Call

OperatePrivilege is a helper method to define mock.On call

• ctx context.Context
• param *api.OperatePrivilegeParam

func (*DataHandler_Expecter) OperateUserRole

func (_e *DataHandler_Expecter) OperateUserRole(ctx interface{}, param interface{}) *DataHandler_OperateUserRole_Call

OperateUserRole is a helper method to define mock.On call

• ctx context.Context
• param *api.OperateUserRoleParam

func (*DataHandler_Expecter) ReleaseCollection

func (_e *DataHandler_Expecter) ReleaseCollection(ctx interface{}, param interface{}) *DataHandler_ReleaseCollection_Call

ReleaseCollection is a helper method to define mock.On call

• ctx context.Context
• param *api.ReleaseCollectionParam

func (*DataHandler_Expecter) ReleasePartitions

func (_e *DataHandler_Expecter) ReleasePartitions(ctx interface{}, param interface{}) *DataHandler_ReleasePartitions_Call

ReleasePartitions is a helper method to define mock.On call

• ctx context.Context
• param *api.ReleasePartitionsParam

func (*DataHandler_Expecter) ReplicateMessage

func (_e *DataHandler_Expecter) ReplicateMessage(ctx interface{}, param interface{}) *DataHandler_ReplicateMessage_Call

ReplicateMessage is a helper method to define mock.On call

• ctx context.Context
• param *api.ReplicateMessageParam

func (*DataHandler_Expecter) UpdateUser

func (_e *DataHandler_Expecter) UpdateUser(ctx interface{}, param interface{}) *DataHandler_UpdateUser_Call

UpdateUser is a helper method to define mock.On call

• ctx context.Context
• param *api.UpdateUserParam

type DataHandler_Flush_Call

type DataHandler_Flush_Call struct {
	*mock.Call
}

DataHandler_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'

func (*DataHandler_Flush_Call) Return

func (_c *DataHandler_Flush_Call) Return(_a0 error) *DataHandler_Flush_Call

func (*DataHandler_Flush_Call) Run

func (_c *DataHandler_Flush_Call) Run(run func(ctx context.Context, param *api.FlushParam)) *DataHandler_Flush_Call

func (*DataHandler_Flush_Call) RunAndReturn

func (_c *DataHandler_Flush_Call) RunAndReturn(run func(context.Context, *api.FlushParam) error) *DataHandler_Flush_Call

type DataHandler_Insert_Call

type DataHandler_Insert_Call struct {
	*mock.Call
}

DataHandler_Insert_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Insert'

func (*DataHandler_Insert_Call) Return

func (_c *DataHandler_Insert_Call) Return(_a0 error) *DataHandler_Insert_Call

func (*DataHandler_Insert_Call) Run

func (_c *DataHandler_Insert_Call) Run(run func(ctx context.Context, param *api.InsertParam)) *DataHandler_Insert_Call

func (*DataHandler_Insert_Call) RunAndReturn

func (_c *DataHandler_Insert_Call) RunAndReturn(run func(context.Context, *api.InsertParam) error) *DataHandler_Insert_Call

type DataHandler_LoadCollection_Call

type DataHandler_LoadCollection_Call struct {
	*mock.Call
}

DataHandler_LoadCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoadCollection'

func (*DataHandler_LoadCollection_Call) Return

func (_c *DataHandler_LoadCollection_Call) Return(_a0 error) *DataHandler_LoadCollection_Call

func (*DataHandler_LoadCollection_Call) Run

func (_c *DataHandler_LoadCollection_Call) Run(run func(ctx context.Context, param *api.LoadCollectionParam)) *DataHandler_LoadCollection_Call

func (*DataHandler_LoadCollection_Call) RunAndReturn

func (_c *DataHandler_LoadCollection_Call) RunAndReturn(run func(context.Context, *api.LoadCollectionParam) error) *DataHandler_LoadCollection_Call

type DataHandler_LoadPartitions_Call

type DataHandler_LoadPartitions_Call struct {
	*mock.Call
}

DataHandler_LoadPartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoadPartitions'

func (*DataHandler_LoadPartitions_Call) Return

func (_c *DataHandler_LoadPartitions_Call) Return(_a0 error) *DataHandler_LoadPartitions_Call

func (*DataHandler_LoadPartitions_Call) Run

func (_c *DataHandler_LoadPartitions_Call) Run(run func(ctx context.Context, param *api.LoadPartitionsParam)) *DataHandler_LoadPartitions_Call

func (*DataHandler_LoadPartitions_Call) RunAndReturn

func (_c *DataHandler_LoadPartitions_Call) RunAndReturn(run func(context.Context, *api.LoadPartitionsParam) error) *DataHandler_LoadPartitions_Call

type DataHandler_OperatePrivilege_Call

type DataHandler_OperatePrivilege_Call struct {
	*mock.Call
}

DataHandler_OperatePrivilege_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperatePrivilege'

func (*DataHandler_OperatePrivilege_Call) Return

func (_c *DataHandler_OperatePrivilege_Call) Return(_a0 error) *DataHandler_OperatePrivilege_Call

func (*DataHandler_OperatePrivilege_Call) Run

func (_c *DataHandler_OperatePrivilege_Call) Run(run func(ctx context.Context, param *api.OperatePrivilegeParam)) *DataHandler_OperatePrivilege_Call

func (*DataHandler_OperatePrivilege_Call) RunAndReturn

func (_c *DataHandler_OperatePrivilege_Call) RunAndReturn(run func(context.Context, *api.OperatePrivilegeParam) error) *DataHandler_OperatePrivilege_Call

type DataHandler_OperateUserRole_Call

type DataHandler_OperateUserRole_Call struct {
	*mock.Call
}

DataHandler_OperateUserRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperateUserRole'

func (*DataHandler_OperateUserRole_Call) Return

func (_c *DataHandler_OperateUserRole_Call) Return(_a0 error) *DataHandler_OperateUserRole_Call

func (*DataHandler_OperateUserRole_Call) Run

func (_c *DataHandler_OperateUserRole_Call) Run(run func(ctx context.Context, param *api.OperateUserRoleParam)) *DataHandler_OperateUserRole_Call

func (*DataHandler_OperateUserRole_Call) RunAndReturn

func (_c *DataHandler_OperateUserRole_Call) RunAndReturn(run func(context.Context, *api.OperateUserRoleParam) error) *DataHandler_OperateUserRole_Call

type DataHandler_ReleaseCollection_Call

type DataHandler_ReleaseCollection_Call struct {
	*mock.Call
}

DataHandler_ReleaseCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleaseCollection'

func (*DataHandler_ReleaseCollection_Call) Return

func (_c *DataHandler_ReleaseCollection_Call) Return(_a0 error) *DataHandler_ReleaseCollection_Call

func (*DataHandler_ReleaseCollection_Call) Run

func (_c *DataHandler_ReleaseCollection_Call) Run(run func(ctx context.Context, param *api.ReleaseCollectionParam)) *DataHandler_ReleaseCollection_Call

func (*DataHandler_ReleaseCollection_Call) RunAndReturn

func (_c *DataHandler_ReleaseCollection_Call) RunAndReturn(run func(context.Context, *api.ReleaseCollectionParam) error) *DataHandler_ReleaseCollection_Call

type DataHandler_ReleasePartitions_Call

type DataHandler_ReleasePartitions_Call struct {
	*mock.Call
}

DataHandler_ReleasePartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReleasePartitions'

func (*DataHandler_ReleasePartitions_Call) Return

func (_c *DataHandler_ReleasePartitions_Call) Return(_a0 error) *DataHandler_ReleasePartitions_Call

func (*DataHandler_ReleasePartitions_Call) Run

func (_c *DataHandler_ReleasePartitions_Call) Run(run func(ctx context.Context, param *api.ReleasePartitionsParam)) *DataHandler_ReleasePartitions_Call

func (*DataHandler_ReleasePartitions_Call) RunAndReturn

func (_c *DataHandler_ReleasePartitions_Call) RunAndReturn(run func(context.Context, *api.ReleasePartitionsParam) error) *DataHandler_ReleasePartitions_Call

type DataHandler_ReplicateMessage_Call

type DataHandler_ReplicateMessage_Call struct {
	*mock.Call
}

DataHandler_ReplicateMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplicateMessage'

func (*DataHandler_ReplicateMessage_Call) Return

func (_c *DataHandler_ReplicateMessage_Call) Return(_a0 error) *DataHandler_ReplicateMessage_Call

func (*DataHandler_ReplicateMessage_Call) Run

func (_c *DataHandler_ReplicateMessage_Call) Run(run func(ctx context.Context, param *api.ReplicateMessageParam)) *DataHandler_ReplicateMessage_Call

func (*DataHandler_ReplicateMessage_Call) RunAndReturn

func (_c *DataHandler_ReplicateMessage_Call) RunAndReturn(run func(context.Context, *api.ReplicateMessageParam) error) *DataHandler_ReplicateMessage_Call

type DataHandler_UpdateUser_Call

type DataHandler_UpdateUser_Call struct {
	*mock.Call
}

DataHandler_UpdateUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateUser'

func (*DataHandler_UpdateUser_Call) Return

func (_c *DataHandler_UpdateUser_Call) Return(_a0 error) *DataHandler_UpdateUser_Call

func (*DataHandler_UpdateUser_Call) Run

func (_c *DataHandler_UpdateUser_Call) Run(run func(ctx context.Context, param *api.UpdateUserParam)) *DataHandler_UpdateUser_Call

func (*DataHandler_UpdateUser_Call) RunAndReturn

func (_c *DataHandler_UpdateUser_Call) RunAndReturn(run func(context.Context, *api.UpdateUserParam) error) *DataHandler_UpdateUser_Call

type FactoryCreator

type FactoryCreator struct {
	mock.Mock
}

FactoryCreator is an autogenerated mock type for the FactoryCreator type

func NewFactoryCreator

func NewFactoryCreator(t interface {
	mock.TestingT
	Cleanup(func())
}) *FactoryCreator

NewFactoryCreator creates a new instance of FactoryCreator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*FactoryCreator) EXPECT

func (_m *FactoryCreator) EXPECT() *FactoryCreator_Expecter

func (*FactoryCreator) NewKmsFactory

func (_m *FactoryCreator) NewKmsFactory(cfg *config.KafkaConfig) msgstream.Factory

NewKmsFactory provides a mock function with given fields: cfg

func (*FactoryCreator) NewPmsFactory

func (_m *FactoryCreator) NewPmsFactory(cfg *config.PulsarConfig) msgstream.Factory

NewPmsFactory provides a mock function with given fields: cfg

type FactoryCreator_Expecter

type FactoryCreator_Expecter struct {
	// contains filtered or unexported fields
}

func (*FactoryCreator_Expecter) NewKmsFactory

func (_e *FactoryCreator_Expecter) NewKmsFactory(cfg interface{}) *FactoryCreator_NewKmsFactory_Call

NewKmsFactory is a helper method to define mock.On call

• cfg *config.KafkaConfig

func (*FactoryCreator_Expecter) NewPmsFactory

func (_e *FactoryCreator_Expecter) NewPmsFactory(cfg interface{}) *FactoryCreator_NewPmsFactory_Call

NewPmsFactory is a helper method to define mock.On call

• cfg *config.PulsarConfig

type FactoryCreator_NewKmsFactory_Call

type FactoryCreator_NewKmsFactory_Call struct {
	*mock.Call
}

FactoryCreator_NewKmsFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewKmsFactory'

func (*FactoryCreator_NewKmsFactory_Call) Return

func (_c *FactoryCreator_NewKmsFactory_Call) Return(_a0 msgstream.Factory) *FactoryCreator_NewKmsFactory_Call

func (*FactoryCreator_NewKmsFactory_Call) Run

func (_c *FactoryCreator_NewKmsFactory_Call) Run(run func(cfg *config.KafkaConfig)) *FactoryCreator_NewKmsFactory_Call

func (*FactoryCreator_NewKmsFactory_Call) RunAndReturn

func (_c *FactoryCreator_NewKmsFactory_Call) RunAndReturn(run func(*config.KafkaConfig) msgstream.Factory) *FactoryCreator_NewKmsFactory_Call

type FactoryCreator_NewPmsFactory_Call

type FactoryCreator_NewPmsFactory_Call struct {
	*mock.Call
}

FactoryCreator_NewPmsFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewPmsFactory'

func (*FactoryCreator_NewPmsFactory_Call) Return

func (_c *FactoryCreator_NewPmsFactory_Call) Return(_a0 msgstream.Factory) *FactoryCreator_NewPmsFactory_Call

func (*FactoryCreator_NewPmsFactory_Call) Run

func (_c *FactoryCreator_NewPmsFactory_Call) Run(run func(cfg *config.PulsarConfig)) *FactoryCreator_NewPmsFactory_Call

func (*FactoryCreator_NewPmsFactory_Call) RunAndReturn

func (_c *FactoryCreator_NewPmsFactory_Call) RunAndReturn(run func(*config.PulsarConfig) msgstream.Factory) *FactoryCreator_NewPmsFactory_Call

type KVApi

type KVApi struct {
	mock.Mock
}

KVApi is an autogenerated mock type for the KVApi type

func NewKVApi

func NewKVApi(t mockConstructorTestingTNewKVApi) *KVApi

NewKVApi creates a new instance of KVApi. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*KVApi) Close

func (_m *KVApi) Close() error

Close provides a mock function with given fields:

func (*KVApi) Compact

func (_m *KVApi) Compact(ctx context.Context, rev int64, opts ...clientv3.CompactOption) (*clientv3.CompactResponse, error)

Compact provides a mock function with given fields: ctx, rev, opts

func (*KVApi) Delete

func (_m *KVApi) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

Delete provides a mock function with given fields: ctx, key, opts

func (*KVApi) Do

func (_m *KVApi) Do(ctx context.Context, op clientv3.Op) (clientv3.OpResponse, error)

Do provides a mock function with given fields: ctx, op

func (*KVApi) EXPECT

func (_m *KVApi) EXPECT() *KVApi_Expecter

func (*KVApi) Endpoints

func (_m *KVApi) Endpoints() []string

Endpoints provides a mock function with given fields:

func (*KVApi) Get

func (_m *KVApi) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

Get provides a mock function with given fields: ctx, key, opts

func (*KVApi) Put

func (_m *KVApi) Put(ctx context.Context, key string, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

Put provides a mock function with given fields: ctx, key, val, opts

func (*KVApi) RequestProgress

func (_m *KVApi) RequestProgress(ctx context.Context) error

RequestProgress provides a mock function with given fields: ctx

func (*KVApi) Status

func (_m *KVApi) Status(ctx context.Context, endpoint string) (*clientv3.StatusResponse, error)

Status provides a mock function with given fields: ctx, endpoint

func (*KVApi) Txn

func (_m *KVApi) Txn(ctx context.Context) clientv3.Txn

Txn provides a mock function with given fields: ctx

func (*KVApi) Watch

func (_m *KVApi) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan

Watch provides a mock function with given fields: ctx, key, opts

type KVApi_Close_Call

type KVApi_Close_Call struct {
	*mock.Call
}

KVApi_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*KVApi_Close_Call) Return

func (_c *KVApi_Close_Call) Return(_a0 error) *KVApi_Close_Call

func (*KVApi_Close_Call) Run

func (_c *KVApi_Close_Call) Run(run func()) *KVApi_Close_Call

func (*KVApi_Close_Call) RunAndReturn

func (_c *KVApi_Close_Call) RunAndReturn(run func() error) *KVApi_Close_Call

type KVApi_Compact_Call

type KVApi_Compact_Call struct {
	*mock.Call
}

KVApi_Compact_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Compact'

func (*KVApi_Compact_Call) Return

func (_c *KVApi_Compact_Call) Return(_a0 *clientv3.CompactResponse, _a1 error) *KVApi_Compact_Call

func (*KVApi_Compact_Call) Run

func (_c *KVApi_Compact_Call) Run(run func(ctx context.Context, rev int64, opts ...clientv3.CompactOption)) *KVApi_Compact_Call

func (*KVApi_Compact_Call) RunAndReturn

func (_c *KVApi_Compact_Call) RunAndReturn(run func(context.Context, int64, ...clientv3.CompactOption) (*clientv3.CompactResponse, error)) *KVApi_Compact_Call

type KVApi_Delete_Call

type KVApi_Delete_Call struct {
	*mock.Call
}

KVApi_Delete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Delete'

func (*KVApi_Delete_Call) Return

func (_c *KVApi_Delete_Call) Return(_a0 *clientv3.DeleteResponse, _a1 error) *KVApi_Delete_Call

func (*KVApi_Delete_Call) Run

func (_c *KVApi_Delete_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Delete_Call

func (*KVApi_Delete_Call) RunAndReturn

func (_c *KVApi_Delete_Call) RunAndReturn(run func(context.Context, string, ...clientv3.OpOption) (*clientv3.DeleteResponse, error)) *KVApi_Delete_Call

type KVApi_Do_Call

type KVApi_Do_Call struct {
	*mock.Call
}

KVApi_Do_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Do'

func (*KVApi_Do_Call) Return

func (_c *KVApi_Do_Call) Return(_a0 clientv3.OpResponse, _a1 error) *KVApi_Do_Call

func (*KVApi_Do_Call) Run

func (_c *KVApi_Do_Call) Run(run func(ctx context.Context, op clientv3.Op)) *KVApi_Do_Call

func (*KVApi_Do_Call) RunAndReturn

func (_c *KVApi_Do_Call) RunAndReturn(run func(context.Context, clientv3.Op) (clientv3.OpResponse, error)) *KVApi_Do_Call

type KVApi_Endpoints_Call

type KVApi_Endpoints_Call struct {
	*mock.Call
}

KVApi_Endpoints_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EtcdEndpoints'

func (*KVApi_Endpoints_Call) Return

func (_c *KVApi_Endpoints_Call) Return(_a0 []string) *KVApi_Endpoints_Call

func (*KVApi_Endpoints_Call) Run

func (_c *KVApi_Endpoints_Call) Run(run func()) *KVApi_Endpoints_Call

func (*KVApi_Endpoints_Call) RunAndReturn

func (_c *KVApi_Endpoints_Call) RunAndReturn(run func() []string) *KVApi_Endpoints_Call

type KVApi_Expecter

type KVApi_Expecter struct {
	// contains filtered or unexported fields
}

func (*KVApi_Expecter) Close

func (_e *KVApi_Expecter) Close() *KVApi_Close_Call

Close is a helper method to define mock.On call

func (*KVApi_Expecter) Compact

func (_e *KVApi_Expecter) Compact(ctx interface{}, rev interface{}, opts ...interface{}) *KVApi_Compact_Call

Compact is a helper method to define mock.On call

• ctx context.Context
• rev int64
• opts ...clientv3.CompactOption

func (*KVApi_Expecter) Delete

func (_e *KVApi_Expecter) Delete(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Delete_Call

Delete is a helper method to define mock.On call

• ctx context.Context
• key string
• opts ...clientv3.OpOption

func (*KVApi_Expecter) Do

func (_e *KVApi_Expecter) Do(ctx interface{}, op interface{}) *KVApi_Do_Call

Do is a helper method to define mock.On call

• ctx context.Context
• op clientv3.Op

func (*KVApi_Expecter) Endpoints

func (_e *KVApi_Expecter) Endpoints() *KVApi_Endpoints_Call

Endpoints is a helper method to define mock.On call

func (*KVApi_Expecter) Get

func (_e *KVApi_Expecter) Get(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Get_Call

Get is a helper method to define mock.On call

• ctx context.Context
• key string
• opts ...clientv3.OpOption

func (*KVApi_Expecter) Put

func (_e *KVApi_Expecter) Put(ctx interface{}, key interface{}, val interface{}, opts ...interface{}) *KVApi_Put_Call

Put is a helper method to define mock.On call

• ctx context.Context
• key string
• val string
• opts ...clientv3.OpOption

func (*KVApi_Expecter) RequestProgress

func (_e *KVApi_Expecter) RequestProgress(ctx interface{}) *KVApi_RequestProgress_Call

RequestProgress is a helper method to define mock.On call

• ctx context.Context

func (*KVApi_Expecter) Status

func (_e *KVApi_Expecter) Status(ctx interface{}, endpoint interface{}) *KVApi_Status_Call

Status is a helper method to define mock.On call

• ctx context.Context
• endpoint string

func (*KVApi_Expecter) Txn

func (_e *KVApi_Expecter) Txn(ctx interface{}) *KVApi_Txn_Call

Txn is a helper method to define mock.On call

• ctx context.Context

func (*KVApi_Expecter) Watch

func (_e *KVApi_Expecter) Watch(ctx interface{}, key interface{}, opts ...interface{}) *KVApi_Watch_Call

Watch is a helper method to define mock.On call

• ctx context.Context
• key string
• opts ...clientv3.OpOption

type KVApi_Get_Call

type KVApi_Get_Call struct {
	*mock.Call
}

KVApi_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*KVApi_Get_Call) Return

func (_c *KVApi_Get_Call) Return(_a0 *clientv3.GetResponse, _a1 error) *KVApi_Get_Call

func (*KVApi_Get_Call) Run

func (_c *KVApi_Get_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Get_Call

func (*KVApi_Get_Call) RunAndReturn

func (_c *KVApi_Get_Call) RunAndReturn(run func(context.Context, string, ...clientv3.OpOption) (*clientv3.GetResponse, error)) *KVApi_Get_Call

type KVApi_Put_Call

type KVApi_Put_Call struct {
	*mock.Call
}

KVApi_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'

func (*KVApi_Put_Call) Return

func (_c *KVApi_Put_Call) Return(_a0 *clientv3.PutResponse, _a1 error) *KVApi_Put_Call

func (*KVApi_Put_Call) Run

func (_c *KVApi_Put_Call) Run(run func(ctx context.Context, key string, val string, opts ...clientv3.OpOption)) *KVApi_Put_Call

func (*KVApi_Put_Call) RunAndReturn

func (_c *KVApi_Put_Call) RunAndReturn(run func(context.Context, string, string, ...clientv3.OpOption) (*clientv3.PutResponse, error)) *KVApi_Put_Call

type KVApi_RequestProgress_Call

type KVApi_RequestProgress_Call struct {
	*mock.Call
}

KVApi_RequestProgress_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RequestProgress'

func (*KVApi_RequestProgress_Call) Return

func (_c *KVApi_RequestProgress_Call) Return(_a0 error) *KVApi_RequestProgress_Call

func (*KVApi_RequestProgress_Call) Run

func (_c *KVApi_RequestProgress_Call) Run(run func(ctx context.Context)) *KVApi_RequestProgress_Call

func (*KVApi_RequestProgress_Call) RunAndReturn

func (_c *KVApi_RequestProgress_Call) RunAndReturn(run func(context.Context) error) *KVApi_RequestProgress_Call

type KVApi_Status_Call

type KVApi_Status_Call struct {
	*mock.Call
}

KVApi_Status_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Status'

func (*KVApi_Status_Call) Return

func (_c *KVApi_Status_Call) Return(_a0 *clientv3.StatusResponse, _a1 error) *KVApi_Status_Call

func (*KVApi_Status_Call) Run

func (_c *KVApi_Status_Call) Run(run func(ctx context.Context, endpoint string)) *KVApi_Status_Call

func (*KVApi_Status_Call) RunAndReturn

func (_c *KVApi_Status_Call) RunAndReturn(run func(context.Context, string) (*clientv3.StatusResponse, error)) *KVApi_Status_Call

type KVApi_Txn_Call

type KVApi_Txn_Call struct {
	*mock.Call
}

KVApi_Txn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Txn'

func (*KVApi_Txn_Call) Return

func (_c *KVApi_Txn_Call) Return(_a0 clientv3.Txn) *KVApi_Txn_Call

func (*KVApi_Txn_Call) Run

func (_c *KVApi_Txn_Call) Run(run func(ctx context.Context)) *KVApi_Txn_Call

func (*KVApi_Txn_Call) RunAndReturn

func (_c *KVApi_Txn_Call) RunAndReturn(run func(context.Context) clientv3.Txn) *KVApi_Txn_Call

type KVApi_Watch_Call

type KVApi_Watch_Call struct {
	*mock.Call
}

KVApi_Watch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Watch'

func (*KVApi_Watch_Call) Return

func (_c *KVApi_Watch_Call) Return(_a0 clientv3.WatchChan) *KVApi_Watch_Call

func (*KVApi_Watch_Call) Run

func (_c *KVApi_Watch_Call) Run(run func(ctx context.Context, key string, opts ...clientv3.OpOption)) *KVApi_Watch_Call

func (*KVApi_Watch_Call) RunAndReturn

func (_c *KVApi_Watch_Call) RunAndReturn(run func(context.Context, string, ...clientv3.OpOption) clientv3.WatchChan) *KVApi_Watch_Call

type MessageManager

type MessageManager struct {
	mock.Mock
}

MessageManager is an autogenerated mock type for the MessageManager type

func NewMessageManager

func NewMessageManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageManager

NewMessageManager creates a new instance of MessageManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageManager) Close

func (_m *MessageManager) Close(channelName string)

Close provides a mock function with given fields: channelName

func (*MessageManager) EXPECT

func (_m *MessageManager) EXPECT() *MessageManager_Expecter

func (*MessageManager) ReplicateMessage

func (_m *MessageManager) ReplicateMessage(message *api.ReplicateMessage)

ReplicateMessage provides a mock function with given fields: message

type MessageManager_Close_Call

type MessageManager_Close_Call struct {
	*mock.Call
}

MessageManager_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MessageManager_Close_Call) Return

func (_c *MessageManager_Close_Call) Return() *MessageManager_Close_Call

func (*MessageManager_Close_Call) Run

func (_c *MessageManager_Close_Call) Run(run func(channelName string)) *MessageManager_Close_Call

func (*MessageManager_Close_Call) RunAndReturn

func (_c *MessageManager_Close_Call) RunAndReturn(run func(string)) *MessageManager_Close_Call

type MessageManager_Expecter

type MessageManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*MessageManager_Expecter) Close

func (_e *MessageManager_Expecter) Close(channelName interface{}) *MessageManager_Close_Call

Close is a helper method to define mock.On call

• channelName string

func (*MessageManager_Expecter) ReplicateMessage

func (_e *MessageManager_Expecter) ReplicateMessage(message interface{}) *MessageManager_ReplicateMessage_Call

ReplicateMessage is a helper method to define mock.On call

• message *api.ReplicateMessage

type MessageManager_ReplicateMessage_Call

type MessageManager_ReplicateMessage_Call struct {
	*mock.Call
}

MessageManager_ReplicateMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReplicateMessage'

func (*MessageManager_ReplicateMessage_Call) Return

func (_c *MessageManager_ReplicateMessage_Call) Return() *MessageManager_ReplicateMessage_Call

func (*MessageManager_ReplicateMessage_Call) Run

func (_c *MessageManager_ReplicateMessage_Call) Run(run func(message *api.ReplicateMessage)) *MessageManager_ReplicateMessage_Call

func (*MessageManager_ReplicateMessage_Call) RunAndReturn

func (_c *MessageManager_ReplicateMessage_Call) RunAndReturn(run func(*api.ReplicateMessage)) *MessageManager_ReplicateMessage_Call

type MetaOp

type MetaOp struct {
	mock.Mock
}

MetaOp is an autogenerated mock type for the MetaOp type

func NewMetaOp

func NewMetaOp(t interface {
	mock.TestingT
	Cleanup(func())
}) *MetaOp

NewMetaOp creates a new instance of MetaOp. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MetaOp) EXPECT

func (_m *MetaOp) EXPECT() *MetaOp_Expecter

func (*MetaOp) GetAllCollection

func (_m *MetaOp) GetAllCollection(ctx context.Context, filter api.CollectionFilter) ([]*pb.CollectionInfo, error)

GetAllCollection provides a mock function with given fields: ctx, filter

func (*MetaOp) GetAllDroppedObj

func (_m *MetaOp) GetAllDroppedObj() map[string]map[string]uint64

GetAllDroppedObj provides a mock function with given fields:

func (*MetaOp) GetAllPartition

func (_m *MetaOp) GetAllPartition(ctx context.Context, filter api.PartitionFilter) ([]*pb.PartitionInfo, error)

GetAllPartition provides a mock function with given fields: ctx, filter

func (*MetaOp) GetCollectionNameByID

func (_m *MetaOp) GetCollectionNameByID(ctx context.Context, id int64) string

GetCollectionNameByID provides a mock function with given fields: ctx, id

func (*MetaOp) GetDatabaseInfoForCollection

func (_m *MetaOp) GetDatabaseInfoForCollection(ctx context.Context, id int64) model.DatabaseInfo

GetDatabaseInfoForCollection provides a mock function with given fields: ctx, id

func (*MetaOp) StartWatch

func (_m *MetaOp) StartWatch()

StartWatch provides a mock function with given fields:

func (*MetaOp) SubscribeCollectionEvent

func (_m *MetaOp) SubscribeCollectionEvent(taskID string, consumer api.CollectionEventConsumer)

SubscribeCollectionEvent provides a mock function with given fields: taskID, consumer

func (*MetaOp) SubscribePartitionEvent

func (_m *MetaOp) SubscribePartitionEvent(taskID string, consumer api.PartitionEventConsumer)

SubscribePartitionEvent provides a mock function with given fields: taskID, consumer

func (*MetaOp) UnsubscribeEvent

func (_m *MetaOp) UnsubscribeEvent(taskID string, eventType api.WatchEventType)

UnsubscribeEvent provides a mock function with given fields: taskID, eventType

func (*MetaOp) WatchCollection

func (_m *MetaOp) WatchCollection(ctx context.Context, filter api.CollectionFilter)

WatchCollection provides a mock function with given fields: ctx, filter

func (*MetaOp) WatchPartition

func (_m *MetaOp) WatchPartition(ctx context.Context, filter api.PartitionFilter)

WatchPartition provides a mock function with given fields: ctx, filter

type MetaOp_Expecter

type MetaOp_Expecter struct {
	// contains filtered or unexported fields
}

func (*MetaOp_Expecter) GetAllCollection

func (_e *MetaOp_Expecter) GetAllCollection(ctx interface{}, filter interface{}) *MetaOp_GetAllCollection_Call

GetAllCollection is a helper method to define mock.On call

• ctx context.Context
• filter api.CollectionFilter

func (*MetaOp_Expecter) GetAllDroppedObj

func (_e *MetaOp_Expecter) GetAllDroppedObj() *MetaOp_GetAllDroppedObj_Call

GetAllDroppedObj is a helper method to define mock.On call

func (*MetaOp_Expecter) GetAllPartition

func (_e *MetaOp_Expecter) GetAllPartition(ctx interface{}, filter interface{}) *MetaOp_GetAllPartition_Call

GetAllPartition is a helper method to define mock.On call

• ctx context.Context
• filter api.PartitionFilter

func (*MetaOp_Expecter) GetCollectionNameByID

func (_e *MetaOp_Expecter) GetCollectionNameByID(ctx interface{}, id interface{}) *MetaOp_GetCollectionNameByID_Call

GetCollectionNameByID is a helper method to define mock.On call

• ctx context.Context
• id int64

func (*MetaOp_Expecter) GetDatabaseInfoForCollection

func (_e *MetaOp_Expecter) GetDatabaseInfoForCollection(ctx interface{}, id interface{}) *MetaOp_GetDatabaseInfoForCollection_Call

GetDatabaseInfoForCollection is a helper method to define mock.On call

• ctx context.Context
• id int64

func (*MetaOp_Expecter) StartWatch

func (_e *MetaOp_Expecter) StartWatch() *MetaOp_StartWatch_Call

StartWatch is a helper method to define mock.On call

func (*MetaOp_Expecter) SubscribeCollectionEvent

func (_e *MetaOp_Expecter) SubscribeCollectionEvent(taskID interface{}, consumer interface{}) *MetaOp_SubscribeCollectionEvent_Call

SubscribeCollectionEvent is a helper method to define mock.On call

• taskID string
• consumer api.CollectionEventConsumer

func (*MetaOp_Expecter) SubscribePartitionEvent

func (_e *MetaOp_Expecter) SubscribePartitionEvent(taskID interface{}, consumer interface{}) *MetaOp_SubscribePartitionEvent_Call

SubscribePartitionEvent is a helper method to define mock.On call

• taskID string
• consumer api.PartitionEventConsumer

func (*MetaOp_Expecter) UnsubscribeEvent

func (_e *MetaOp_Expecter) UnsubscribeEvent(taskID interface{}, eventType interface{}) *MetaOp_UnsubscribeEvent_Call

UnsubscribeEvent is a helper method to define mock.On call

• taskID string
• eventType api.WatchEventType

func (*MetaOp_Expecter) WatchCollection

func (_e *MetaOp_Expecter) WatchCollection(ctx interface{}, filter interface{}) *MetaOp_WatchCollection_Call

WatchCollection is a helper method to define mock.On call

• ctx context.Context
• filter api.CollectionFilter

func (*MetaOp_Expecter) WatchPartition

func (_e *MetaOp_Expecter) WatchPartition(ctx interface{}, filter interface{}) *MetaOp_WatchPartition_Call

WatchPartition is a helper method to define mock.On call

• ctx context.Context
• filter api.PartitionFilter

type MetaOp_GetAllCollection_Call

type MetaOp_GetAllCollection_Call struct {
	*mock.Call
}

MetaOp_GetAllCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllCollection'

func (*MetaOp_GetAllCollection_Call) Return

func (_c *MetaOp_GetAllCollection_Call) Return(_a0 []*pb.CollectionInfo, _a1 error) *MetaOp_GetAllCollection_Call

func (*MetaOp_GetAllCollection_Call) Run

func (_c *MetaOp_GetAllCollection_Call) Run(run func(ctx context.Context, filter api.CollectionFilter)) *MetaOp_GetAllCollection_Call

func (*MetaOp_GetAllCollection_Call) RunAndReturn

func (_c *MetaOp_GetAllCollection_Call) RunAndReturn(run func(context.Context, api.CollectionFilter) ([]*pb.CollectionInfo, error)) *MetaOp_GetAllCollection_Call

type MetaOp_GetAllDroppedObj_Call

type MetaOp_GetAllDroppedObj_Call struct {
	*mock.Call
}

MetaOp_GetAllDroppedObj_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllDroppedObj'

func (*MetaOp_GetAllDroppedObj_Call) Return

func (_c *MetaOp_GetAllDroppedObj_Call) Return(_a0 map[string]map[string]uint64) *MetaOp_GetAllDroppedObj_Call

func (*MetaOp_GetAllDroppedObj_Call) Run

func (_c *MetaOp_GetAllDroppedObj_Call) Run(run func()) *MetaOp_GetAllDroppedObj_Call

func (*MetaOp_GetAllDroppedObj_Call) RunAndReturn

func (_c *MetaOp_GetAllDroppedObj_Call) RunAndReturn(run func() map[string]map[string]uint64) *MetaOp_GetAllDroppedObj_Call

type MetaOp_GetAllPartition_Call

type MetaOp_GetAllPartition_Call struct {
	*mock.Call
}

MetaOp_GetAllPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllPartition'

func (*MetaOp_GetAllPartition_Call) Return

func (_c *MetaOp_GetAllPartition_Call) Return(_a0 []*pb.PartitionInfo, _a1 error) *MetaOp_GetAllPartition_Call

func (*MetaOp_GetAllPartition_Call) Run

func (_c *MetaOp_GetAllPartition_Call) Run(run func(ctx context.Context, filter api.PartitionFilter)) *MetaOp_GetAllPartition_Call

func (*MetaOp_GetAllPartition_Call) RunAndReturn

func (_c *MetaOp_GetAllPartition_Call) RunAndReturn(run func(context.Context, api.PartitionFilter) ([]*pb.PartitionInfo, error)) *MetaOp_GetAllPartition_Call

type MetaOp_GetCollectionNameByID_Call

type MetaOp_GetCollectionNameByID_Call struct {
	*mock.Call
}

MetaOp_GetCollectionNameByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionNameByID'

func (*MetaOp_GetCollectionNameByID_Call) Return

func (_c *MetaOp_GetCollectionNameByID_Call) Return(_a0 string) *MetaOp_GetCollectionNameByID_Call

func (*MetaOp_GetCollectionNameByID_Call) Run

func (_c *MetaOp_GetCollectionNameByID_Call) Run(run func(ctx context.Context, id int64)) *MetaOp_GetCollectionNameByID_Call

func (*MetaOp_GetCollectionNameByID_Call) RunAndReturn

func (_c *MetaOp_GetCollectionNameByID_Call) RunAndReturn(run func(context.Context, int64) string) *MetaOp_GetCollectionNameByID_Call

type MetaOp_GetDatabaseInfoForCollection_Call

type MetaOp_GetDatabaseInfoForCollection_Call struct {
	*mock.Call
}

MetaOp_GetDatabaseInfoForCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseInfoForCollection'

func (*MetaOp_GetDatabaseInfoForCollection_Call) Return

func (_c *MetaOp_GetDatabaseInfoForCollection_Call) Return(_a0 model.DatabaseInfo) *MetaOp_GetDatabaseInfoForCollection_Call

func (*MetaOp_GetDatabaseInfoForCollection_Call) Run

func (_c *MetaOp_GetDatabaseInfoForCollection_Call) Run(run func(ctx context.Context, id int64)) *MetaOp_GetDatabaseInfoForCollection_Call

func (*MetaOp_GetDatabaseInfoForCollection_Call) RunAndReturn

func (_c *MetaOp_GetDatabaseInfoForCollection_Call) RunAndReturn(run func(context.Context, int64) model.DatabaseInfo) *MetaOp_GetDatabaseInfoForCollection_Call

type MetaOp_StartWatch_Call

type MetaOp_StartWatch_Call struct {
	*mock.Call
}

MetaOp_StartWatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartWatch'

func (*MetaOp_StartWatch_Call) Return

func (_c *MetaOp_StartWatch_Call) Return() *MetaOp_StartWatch_Call

func (*MetaOp_StartWatch_Call) Run

func (_c *MetaOp_StartWatch_Call) Run(run func()) *MetaOp_StartWatch_Call

func (*MetaOp_StartWatch_Call) RunAndReturn

func (_c *MetaOp_StartWatch_Call) RunAndReturn(run func()) *MetaOp_StartWatch_Call

type MetaOp_SubscribeCollectionEvent_Call

type MetaOp_SubscribeCollectionEvent_Call struct {
	*mock.Call
}

MetaOp_SubscribeCollectionEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribeCollectionEvent'

func (*MetaOp_SubscribeCollectionEvent_Call) Return

func (_c *MetaOp_SubscribeCollectionEvent_Call) Return() *MetaOp_SubscribeCollectionEvent_Call

func (*MetaOp_SubscribeCollectionEvent_Call) Run

func (_c *MetaOp_SubscribeCollectionEvent_Call) Run(run func(taskID string, consumer api.CollectionEventConsumer)) *MetaOp_SubscribeCollectionEvent_Call

func (*MetaOp_SubscribeCollectionEvent_Call) RunAndReturn

func (_c *MetaOp_SubscribeCollectionEvent_Call) RunAndReturn(run func(string, api.CollectionEventConsumer)) *MetaOp_SubscribeCollectionEvent_Call

type MetaOp_SubscribePartitionEvent_Call

type MetaOp_SubscribePartitionEvent_Call struct {
	*mock.Call
}

MetaOp_SubscribePartitionEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribePartitionEvent'

func (*MetaOp_SubscribePartitionEvent_Call) Return

func (_c *MetaOp_SubscribePartitionEvent_Call) Return() *MetaOp_SubscribePartitionEvent_Call

func (*MetaOp_SubscribePartitionEvent_Call) Run

func (_c *MetaOp_SubscribePartitionEvent_Call) Run(run func(taskID string, consumer api.PartitionEventConsumer)) *MetaOp_SubscribePartitionEvent_Call

func (*MetaOp_SubscribePartitionEvent_Call) RunAndReturn

func (_c *MetaOp_SubscribePartitionEvent_Call) RunAndReturn(run func(string, api.PartitionEventConsumer)) *MetaOp_SubscribePartitionEvent_Call

type MetaOp_UnsubscribeEvent_Call

type MetaOp_UnsubscribeEvent_Call struct {
	*mock.Call
}

MetaOp_UnsubscribeEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnsubscribeEvent'

func (*MetaOp_UnsubscribeEvent_Call) Return

func (_c *MetaOp_UnsubscribeEvent_Call) Return() *MetaOp_UnsubscribeEvent_Call

func (*MetaOp_UnsubscribeEvent_Call) Run

func (_c *MetaOp_UnsubscribeEvent_Call) Run(run func(taskID string, eventType api.WatchEventType)) *MetaOp_UnsubscribeEvent_Call

func (*MetaOp_UnsubscribeEvent_Call) RunAndReturn

func (_c *MetaOp_UnsubscribeEvent_Call) RunAndReturn(run func(string, api.WatchEventType)) *MetaOp_UnsubscribeEvent_Call

type MetaOp_WatchCollection_Call

type MetaOp_WatchCollection_Call struct {
	*mock.Call
}

MetaOp_WatchCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchCollection'

func (*MetaOp_WatchCollection_Call) Return

func (_c *MetaOp_WatchCollection_Call) Return() *MetaOp_WatchCollection_Call

func (*MetaOp_WatchCollection_Call) Run

func (_c *MetaOp_WatchCollection_Call) Run(run func(ctx context.Context, filter api.CollectionFilter)) *MetaOp_WatchCollection_Call

func (*MetaOp_WatchCollection_Call) RunAndReturn

func (_c *MetaOp_WatchCollection_Call) RunAndReturn(run func(context.Context, api.CollectionFilter)) *MetaOp_WatchCollection_Call

type MetaOp_WatchPartition_Call

type MetaOp_WatchPartition_Call struct {
	*mock.Call
}

MetaOp_WatchPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchPartition'

func (*MetaOp_WatchPartition_Call) Return

func (_c *MetaOp_WatchPartition_Call) Return() *MetaOp_WatchPartition_Call

func (*MetaOp_WatchPartition_Call) Run

func (_c *MetaOp_WatchPartition_Call) Run(run func(ctx context.Context, filter api.PartitionFilter)) *MetaOp_WatchPartition_Call

func (*MetaOp_WatchPartition_Call) RunAndReturn

func (_c *MetaOp_WatchPartition_Call) RunAndReturn(run func(context.Context, api.PartitionFilter)) *MetaOp_WatchPartition_Call

type Reader

type Reader struct {
	mock.Mock
}

Reader is an autogenerated mock type for the Reader type

func NewReader

func NewReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *Reader

NewReader creates a new instance of Reader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Reader) EXPECT

func (_m *Reader) EXPECT() *Reader_Expecter

func (*Reader) ErrorChan

func (_m *Reader) ErrorChan() <-chan error

ErrorChan provides a mock function with given fields:

func (*Reader) QuitRead

func (_m *Reader) QuitRead(ctx context.Context)

QuitRead provides a mock function with given fields: ctx

func (*Reader) StartRead

func (_m *Reader) StartRead(ctx context.Context)

StartRead provides a mock function with given fields: ctx

type Reader_ErrorChan_Call

type Reader_ErrorChan_Call struct {
	*mock.Call
}

Reader_ErrorChan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ErrorChan'

func (*Reader_ErrorChan_Call) Return

func (_c *Reader_ErrorChan_Call) Return(_a0 <-chan error) *Reader_ErrorChan_Call

func (*Reader_ErrorChan_Call) Run

func (_c *Reader_ErrorChan_Call) Run(run func()) *Reader_ErrorChan_Call

func (*Reader_ErrorChan_Call) RunAndReturn

func (_c *Reader_ErrorChan_Call) RunAndReturn(run func() <-chan error) *Reader_ErrorChan_Call

type Reader_Expecter

type Reader_Expecter struct {
	// contains filtered or unexported fields
}

func (*Reader_Expecter) ErrorChan

func (_e *Reader_Expecter) ErrorChan() *Reader_ErrorChan_Call

ErrorChan is a helper method to define mock.On call

func (*Reader_Expecter) QuitRead

func (_e *Reader_Expecter) QuitRead(ctx interface{}) *Reader_QuitRead_Call

QuitRead is a helper method to define mock.On call

• ctx context.Context

func (*Reader_Expecter) StartRead

func (_e *Reader_Expecter) StartRead(ctx interface{}) *Reader_StartRead_Call

StartRead is a helper method to define mock.On call

• ctx context.Context

type Reader_QuitRead_Call

type Reader_QuitRead_Call struct {
	*mock.Call
}

Reader_QuitRead_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QuitRead'

func (*Reader_QuitRead_Call) Return

func (_c *Reader_QuitRead_Call) Return() *Reader_QuitRead_Call

func (*Reader_QuitRead_Call) Run

func (_c *Reader_QuitRead_Call) Run(run func(ctx context.Context)) *Reader_QuitRead_Call

func (*Reader_QuitRead_Call) RunAndReturn

func (_c *Reader_QuitRead_Call) RunAndReturn(run func(context.Context)) *Reader_QuitRead_Call

type Reader_StartRead_Call

type Reader_StartRead_Call struct {
	*mock.Call
}

Reader_StartRead_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartRead'

func (*Reader_StartRead_Call) Return

func (_c *Reader_StartRead_Call) Return() *Reader_StartRead_Call

func (*Reader_StartRead_Call) Run

func (_c *Reader_StartRead_Call) Run(run func(ctx context.Context)) *Reader_StartRead_Call

func (*Reader_StartRead_Call) RunAndReturn

func (_c *Reader_StartRead_Call) RunAndReturn(run func(context.Context)) *Reader_StartRead_Call

type ReplicateMeta

type ReplicateMeta struct {
	mock.Mock
}

ReplicateMeta is an autogenerated mock type for the ReplicateMeta type

func NewReplicateMeta

func NewReplicateMeta(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReplicateMeta

NewReplicateMeta creates a new instance of ReplicateMeta. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ReplicateMeta) EXPECT

func (_m *ReplicateMeta) EXPECT() *ReplicateMeta_Expecter

func (*ReplicateMeta) GetTaskDropCollectionMsg

func (_m *ReplicateMeta) GetTaskDropCollectionMsg(ctx context.Context, taskID string, msgID string) ([]api.TaskDropCollectionMsg, error)

GetTaskDropCollectionMsg provides a mock function with given fields: ctx, taskID, msgID

func (*ReplicateMeta) GetTaskDropPartitionMsg

func (_m *ReplicateMeta) GetTaskDropPartitionMsg(ctx context.Context, taskID string, msgID string) ([]api.TaskDropPartitionMsg, error)

GetTaskDropPartitionMsg provides a mock function with given fields: ctx, taskID, msgID

func (*ReplicateMeta) RemoveTaskMsg

func (_m *ReplicateMeta) RemoveTaskMsg(ctx context.Context, taskID string, msgID string) error

RemoveTaskMsg provides a mock function with given fields: ctx, taskID, msgID

func (*ReplicateMeta) UpdateTaskDropCollectionMsg

func (_m *ReplicateMeta) UpdateTaskDropCollectionMsg(ctx context.Context, msg api.TaskDropCollectionMsg) (bool, error)

UpdateTaskDropCollectionMsg provides a mock function with given fields: ctx, msg

func (*ReplicateMeta) UpdateTaskDropPartitionMsg

func (_m *ReplicateMeta) UpdateTaskDropPartitionMsg(ctx context.Context, msg api.TaskDropPartitionMsg) (bool, error)

UpdateTaskDropPartitionMsg provides a mock function with given fields: ctx, msg

type ReplicateMeta_Expecter

type ReplicateMeta_Expecter struct {
	// contains filtered or unexported fields
}

func (*ReplicateMeta_Expecter) GetTaskDropCollectionMsg

func (_e *ReplicateMeta_Expecter) GetTaskDropCollectionMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_GetTaskDropCollectionMsg_Call

GetTaskDropCollectionMsg is a helper method to define mock.On call

• ctx context.Context
• taskID string
• msgID string

func (*ReplicateMeta_Expecter) GetTaskDropPartitionMsg

func (_e *ReplicateMeta_Expecter) GetTaskDropPartitionMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_GetTaskDropPartitionMsg_Call

GetTaskDropPartitionMsg is a helper method to define mock.On call

• ctx context.Context
• taskID string
• msgID string

func (*ReplicateMeta_Expecter) RemoveTaskMsg

func (_e *ReplicateMeta_Expecter) RemoveTaskMsg(ctx interface{}, taskID interface{}, msgID interface{}) *ReplicateMeta_RemoveTaskMsg_Call

RemoveTaskMsg is a helper method to define mock.On call

• ctx context.Context
• taskID string
• msgID string

func (*ReplicateMeta_Expecter) UpdateTaskDropCollectionMsg

func (_e *ReplicateMeta_Expecter) UpdateTaskDropCollectionMsg(ctx interface{}, msg interface{}) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call

UpdateTaskDropCollectionMsg is a helper method to define mock.On call

• ctx context.Context
• msg api.TaskDropCollectionMsg

func (*ReplicateMeta_Expecter) UpdateTaskDropPartitionMsg

func (_e *ReplicateMeta_Expecter) UpdateTaskDropPartitionMsg(ctx interface{}, msg interface{}) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call

UpdateTaskDropPartitionMsg is a helper method to define mock.On call

• ctx context.Context
• msg api.TaskDropPartitionMsg

type ReplicateMeta_GetTaskDropCollectionMsg_Call

type ReplicateMeta_GetTaskDropCollectionMsg_Call struct {
	*mock.Call
}

ReplicateMeta_GetTaskDropCollectionMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskDropCollectionMsg'

func (*ReplicateMeta_GetTaskDropCollectionMsg_Call) Return

func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) Return(_a0 []api.TaskDropCollectionMsg, _a1 error) *ReplicateMeta_GetTaskDropCollectionMsg_Call

func (*ReplicateMeta_GetTaskDropCollectionMsg_Call) Run

func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_GetTaskDropCollectionMsg_Call

func (*ReplicateMeta_GetTaskDropCollectionMsg_Call) RunAndReturn

func (_c *ReplicateMeta_GetTaskDropCollectionMsg_Call) RunAndReturn(run func(context.Context, string, string) ([]api.TaskDropCollectionMsg, error)) *ReplicateMeta_GetTaskDropCollectionMsg_Call

type ReplicateMeta_GetTaskDropPartitionMsg_Call

type ReplicateMeta_GetTaskDropPartitionMsg_Call struct {
	*mock.Call
}

ReplicateMeta_GetTaskDropPartitionMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskDropPartitionMsg'

func (*ReplicateMeta_GetTaskDropPartitionMsg_Call) Return

func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) Return(_a0 []api.TaskDropPartitionMsg, _a1 error) *ReplicateMeta_GetTaskDropPartitionMsg_Call

func (*ReplicateMeta_GetTaskDropPartitionMsg_Call) Run

func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_GetTaskDropPartitionMsg_Call

func (*ReplicateMeta_GetTaskDropPartitionMsg_Call) RunAndReturn

func (_c *ReplicateMeta_GetTaskDropPartitionMsg_Call) RunAndReturn(run func(context.Context, string, string) ([]api.TaskDropPartitionMsg, error)) *ReplicateMeta_GetTaskDropPartitionMsg_Call

type ReplicateMeta_RemoveTaskMsg_Call

type ReplicateMeta_RemoveTaskMsg_Call struct {
	*mock.Call
}

ReplicateMeta_RemoveTaskMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveTaskMsg'

func (*ReplicateMeta_RemoveTaskMsg_Call) Return

func (_c *ReplicateMeta_RemoveTaskMsg_Call) Return(_a0 error) *ReplicateMeta_RemoveTaskMsg_Call

func (*ReplicateMeta_RemoveTaskMsg_Call) Run

func (_c *ReplicateMeta_RemoveTaskMsg_Call) Run(run func(ctx context.Context, taskID string, msgID string)) *ReplicateMeta_RemoveTaskMsg_Call

func (*ReplicateMeta_RemoveTaskMsg_Call) RunAndReturn

func (_c *ReplicateMeta_RemoveTaskMsg_Call) RunAndReturn(run func(context.Context, string, string) error) *ReplicateMeta_RemoveTaskMsg_Call

type ReplicateMeta_UpdateTaskDropCollectionMsg_Call

type ReplicateMeta_UpdateTaskDropCollectionMsg_Call struct {
	*mock.Call
}

ReplicateMeta_UpdateTaskDropCollectionMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTaskDropCollectionMsg'

func (*ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Return

func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Return(_a0 bool, _a1 error) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call

func (*ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Run

func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) Run(run func(ctx context.Context, msg api.TaskDropCollectionMsg)) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call

func (*ReplicateMeta_UpdateTaskDropCollectionMsg_Call) RunAndReturn

func (_c *ReplicateMeta_UpdateTaskDropCollectionMsg_Call) RunAndReturn(run func(context.Context, api.TaskDropCollectionMsg) (bool, error)) *ReplicateMeta_UpdateTaskDropCollectionMsg_Call

type ReplicateMeta_UpdateTaskDropPartitionMsg_Call

type ReplicateMeta_UpdateTaskDropPartitionMsg_Call struct {
	*mock.Call
}

ReplicateMeta_UpdateTaskDropPartitionMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTaskDropPartitionMsg'

func (*ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Return

func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Return(_a0 bool, _a1 error) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call

func (*ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Run

func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) Run(run func(ctx context.Context, msg api.TaskDropPartitionMsg)) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call

func (*ReplicateMeta_UpdateTaskDropPartitionMsg_Call) RunAndReturn

func (_c *ReplicateMeta_UpdateTaskDropPartitionMsg_Call) RunAndReturn(run func(context.Context, api.TaskDropPartitionMsg) (bool, error)) *ReplicateMeta_UpdateTaskDropPartitionMsg_Call

type ReplicateStore

type ReplicateStore struct {
	mock.Mock
}

ReplicateStore is an autogenerated mock type for the ReplicateStore type

func NewReplicateStore

func NewReplicateStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReplicateStore

NewReplicateStore creates a new instance of ReplicateStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ReplicateStore) EXPECT

func (_m *ReplicateStore) EXPECT() *ReplicateStore_Expecter

func (*ReplicateStore) Get

func (_m *ReplicateStore) Get(ctx context.Context, key string, withPrefix bool) ([]api.MetaMsg, error)

Get provides a mock function with given fields: ctx, key, withPrefix

func (*ReplicateStore) Put

func (_m *ReplicateStore) Put(ctx context.Context, key string, value api.MetaMsg) error

Put provides a mock function with given fields: ctx, key, value

func (*ReplicateStore) Remove

func (_m *ReplicateStore) Remove(ctx context.Context, key string) error

Remove provides a mock function with given fields: ctx, key

type ReplicateStore_Expecter

type ReplicateStore_Expecter struct {
	// contains filtered or unexported fields
}

func (*ReplicateStore_Expecter) Get

func (_e *ReplicateStore_Expecter) Get(ctx interface{}, key interface{}, withPrefix interface{}) *ReplicateStore_Get_Call

Get is a helper method to define mock.On call

• ctx context.Context
• key string
• withPrefix bool

func (*ReplicateStore_Expecter) Put

func (_e *ReplicateStore_Expecter) Put(ctx interface{}, key interface{}, value interface{}) *ReplicateStore_Put_Call

Put is a helper method to define mock.On call

• ctx context.Context
• key string
• value api.MetaMsg

func (*ReplicateStore_Expecter) Remove

func (_e *ReplicateStore_Expecter) Remove(ctx interface{}, key interface{}) *ReplicateStore_Remove_Call

Remove is a helper method to define mock.On call

• ctx context.Context
• key string

type ReplicateStore_Get_Call

type ReplicateStore_Get_Call struct {
	*mock.Call
}

ReplicateStore_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*ReplicateStore_Get_Call) Return

func (_c *ReplicateStore_Get_Call) Return(_a0 []api.MetaMsg, _a1 error) *ReplicateStore_Get_Call

func (*ReplicateStore_Get_Call) Run

func (_c *ReplicateStore_Get_Call) Run(run func(ctx context.Context, key string, withPrefix bool)) *ReplicateStore_Get_Call

func (*ReplicateStore_Get_Call) RunAndReturn

func (_c *ReplicateStore_Get_Call) RunAndReturn(run func(context.Context, string, bool) ([]api.MetaMsg, error)) *ReplicateStore_Get_Call

type ReplicateStore_Put_Call

type ReplicateStore_Put_Call struct {
	*mock.Call
}

ReplicateStore_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'

func (*ReplicateStore_Put_Call) Return

func (_c *ReplicateStore_Put_Call) Return(_a0 error) *ReplicateStore_Put_Call

func (*ReplicateStore_Put_Call) Run

func (_c *ReplicateStore_Put_Call) Run(run func(ctx context.Context, key string, value api.MetaMsg)) *ReplicateStore_Put_Call

func (*ReplicateStore_Put_Call) RunAndReturn

func (_c *ReplicateStore_Put_Call) RunAndReturn(run func(context.Context, string, api.MetaMsg) error) *ReplicateStore_Put_Call

type ReplicateStore_Remove_Call

type ReplicateStore_Remove_Call struct {
	*mock.Call
}

ReplicateStore_Remove_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Remove'

func (*ReplicateStore_Remove_Call) Return

func (_c *ReplicateStore_Remove_Call) Return(_a0 error) *ReplicateStore_Remove_Call

func (*ReplicateStore_Remove_Call) Run

func (_c *ReplicateStore_Remove_Call) Run(run func(ctx context.Context, key string)) *ReplicateStore_Remove_Call

func (*ReplicateStore_Remove_Call) RunAndReturn

func (_c *ReplicateStore_Remove_Call) RunAndReturn(run func(context.Context, string) error) *ReplicateStore_Remove_Call

type TargetAPI

type TargetAPI struct {
	mock.Mock
}

TargetAPI is an autogenerated mock type for the TargetAPI type

func NewTargetAPI

func NewTargetAPI(t interface {
	mock.TestingT
	Cleanup(func())
}) *TargetAPI

NewTargetAPI creates a new instance of TargetAPI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TargetAPI) EXPECT

func (_m *TargetAPI) EXPECT() *TargetAPI_Expecter

func (*TargetAPI) GetCollectionInfo

func (_m *TargetAPI) GetCollectionInfo(ctx context.Context, collectionName string, databaseName string) (*model.CollectionInfo, error)

GetCollectionInfo provides a mock function with given fields: ctx, collectionName, databaseName

func (*TargetAPI) GetDatabaseName

func (_m *TargetAPI) GetDatabaseName(ctx context.Context, collectionName string, databaseName string) (string, error)

GetDatabaseName provides a mock function with given fields: ctx, collectionName, databaseName

func (*TargetAPI) GetPartitionInfo

func (_m *TargetAPI) GetPartitionInfo(ctx context.Context, collectionName string, databaseName string) (*model.CollectionInfo, error)

GetPartitionInfo provides a mock function with given fields: ctx, collectionName, databaseName

type TargetAPI_Expecter

type TargetAPI_Expecter struct {
	// contains filtered or unexported fields
}

func (*TargetAPI_Expecter) GetCollectionInfo

func (_e *TargetAPI_Expecter) GetCollectionInfo(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetCollectionInfo_Call

GetCollectionInfo is a helper method to define mock.On call

• ctx context.Context
• collectionName string
• databaseName string

func (*TargetAPI_Expecter) GetDatabaseName

func (_e *TargetAPI_Expecter) GetDatabaseName(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetDatabaseName_Call

GetDatabaseName is a helper method to define mock.On call

• ctx context.Context
• collectionName string
• databaseName string

func (*TargetAPI_Expecter) GetPartitionInfo

func (_e *TargetAPI_Expecter) GetPartitionInfo(ctx interface{}, collectionName interface{}, databaseName interface{}) *TargetAPI_GetPartitionInfo_Call

GetPartitionInfo is a helper method to define mock.On call

• ctx context.Context
• collectionName string
• databaseName string

type TargetAPI_GetCollectionInfo_Call

type TargetAPI_GetCollectionInfo_Call struct {
	*mock.Call
}

TargetAPI_GetCollectionInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionInfo'

func (*TargetAPI_GetCollectionInfo_Call) Return

func (_c *TargetAPI_GetCollectionInfo_Call) Return(_a0 *model.CollectionInfo, _a1 error) *TargetAPI_GetCollectionInfo_Call

func (*TargetAPI_GetCollectionInfo_Call) Run

func (_c *TargetAPI_GetCollectionInfo_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetCollectionInfo_Call

func (*TargetAPI_GetCollectionInfo_Call) RunAndReturn

func (_c *TargetAPI_GetCollectionInfo_Call) RunAndReturn(run func(context.Context, string, string) (*model.CollectionInfo, error)) *TargetAPI_GetCollectionInfo_Call

type TargetAPI_GetDatabaseName_Call

type TargetAPI_GetDatabaseName_Call struct {
	*mock.Call
}

TargetAPI_GetDatabaseName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseName'

func (*TargetAPI_GetDatabaseName_Call) Return

func (_c *TargetAPI_GetDatabaseName_Call) Return(_a0 string, _a1 error) *TargetAPI_GetDatabaseName_Call

func (*TargetAPI_GetDatabaseName_Call) Run

func (_c *TargetAPI_GetDatabaseName_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetDatabaseName_Call

func (*TargetAPI_GetDatabaseName_Call) RunAndReturn

func (_c *TargetAPI_GetDatabaseName_Call) RunAndReturn(run func(context.Context, string, string) (string, error)) *TargetAPI_GetDatabaseName_Call

type TargetAPI_GetPartitionInfo_Call

type TargetAPI_GetPartitionInfo_Call struct {
	*mock.Call
}

TargetAPI_GetPartitionInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPartitionInfo'

func (*TargetAPI_GetPartitionInfo_Call) Return

func (_c *TargetAPI_GetPartitionInfo_Call) Return(_a0 *model.CollectionInfo, _a1 error) *TargetAPI_GetPartitionInfo_Call

func (*TargetAPI_GetPartitionInfo_Call) Run

func (_c *TargetAPI_GetPartitionInfo_Call) Run(run func(ctx context.Context, collectionName string, databaseName string)) *TargetAPI_GetPartitionInfo_Call

func (*TargetAPI_GetPartitionInfo_Call) RunAndReturn

func (_c *TargetAPI_GetPartitionInfo_Call) RunAndReturn(run func(context.Context, string, string) (*model.CollectionInfo, error)) *TargetAPI_GetPartitionInfo_Call

type Writer

type Writer struct {
	mock.Mock
}

Writer is an autogenerated mock type for the Writer type

func NewWriter

func NewWriter(t interface {
	mock.TestingT
	Cleanup(func())
}) *Writer

NewWriter creates a new instance of Writer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Writer) EXPECT

func (_m *Writer) EXPECT() *Writer_Expecter

func (*Writer) HandleOpMessagePack

func (_m *Writer) HandleOpMessagePack(ctx context.Context, msgPack *msgstream.MsgPack) ([]byte, error)

HandleOpMessagePack provides a mock function with given fields: ctx, msgPack

func (*Writer) HandleReplicateAPIEvent

func (_m *Writer) HandleReplicateAPIEvent(ctx context.Context, apiEvent *api.ReplicateAPIEvent) error

HandleReplicateAPIEvent provides a mock function with given fields: ctx, apiEvent

func (*Writer) HandleReplicateMessage

func (_m *Writer) HandleReplicateMessage(ctx context.Context, channelName string, msgPack *msgstream.MsgPack) ([]byte, []byte, error)

HandleReplicateMessage provides a mock function with given fields: ctx, channelName, msgPack

func (*Writer) RecoveryMetaMsg

func (_m *Writer) RecoveryMetaMsg(ctx context.Context, taskID string) error

RecoveryMetaMsg provides a mock function with given fields: ctx, taskID

type Writer_Expecter

type Writer_Expecter struct {
	// contains filtered or unexported fields
}

func (*Writer_Expecter) HandleOpMessagePack

func (_e *Writer_Expecter) HandleOpMessagePack(ctx interface{}, msgPack interface{}) *Writer_HandleOpMessagePack_Call

HandleOpMessagePack is a helper method to define mock.On call

• ctx context.Context
• msgPack *msgstream.MsgPack

func (*Writer_Expecter) HandleReplicateAPIEvent

func (_e *Writer_Expecter) HandleReplicateAPIEvent(ctx interface{}, apiEvent interface{}) *Writer_HandleReplicateAPIEvent_Call

HandleReplicateAPIEvent is a helper method to define mock.On call

• ctx context.Context
• apiEvent *api.ReplicateAPIEvent

func (*Writer_Expecter) HandleReplicateMessage

func (_e *Writer_Expecter) HandleReplicateMessage(ctx interface{}, channelName interface{}, msgPack interface{}) *Writer_HandleReplicateMessage_Call

HandleReplicateMessage is a helper method to define mock.On call

• ctx context.Context
• channelName string
• msgPack *msgstream.MsgPack

func (*Writer_Expecter) RecoveryMetaMsg

func (_e *Writer_Expecter) RecoveryMetaMsg(ctx interface{}, taskID interface{}) *Writer_RecoveryMetaMsg_Call

RecoveryMetaMsg is a helper method to define mock.On call

• ctx context.Context
• taskID string

type Writer_HandleOpMessagePack_Call

type Writer_HandleOpMessagePack_Call struct {
	*mock.Call
}

Writer_HandleOpMessagePack_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleOpMessagePack'

func (*Writer_HandleOpMessagePack_Call) Return

func (_c *Writer_HandleOpMessagePack_Call) Return(_a0 []byte, _a1 error) *Writer_HandleOpMessagePack_Call

func (*Writer_HandleOpMessagePack_Call) Run

func (_c *Writer_HandleOpMessagePack_Call) Run(run func(ctx context.Context, msgPack *msgstream.MsgPack)) *Writer_HandleOpMessagePack_Call

func (*Writer_HandleOpMessagePack_Call) RunAndReturn

func (_c *Writer_HandleOpMessagePack_Call) RunAndReturn(run func(context.Context, *msgstream.MsgPack) ([]byte, error)) *Writer_HandleOpMessagePack_Call

type Writer_HandleReplicateAPIEvent_Call

type Writer_HandleReplicateAPIEvent_Call struct {
	*mock.Call
}

Writer_HandleReplicateAPIEvent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleReplicateAPIEvent'

func (*Writer_HandleReplicateAPIEvent_Call) Return

func (_c *Writer_HandleReplicateAPIEvent_Call) Return(_a0 error) *Writer_HandleReplicateAPIEvent_Call

func (*Writer_HandleReplicateAPIEvent_Call) Run

func (_c *Writer_HandleReplicateAPIEvent_Call) Run(run func(ctx context.Context, apiEvent *api.ReplicateAPIEvent)) *Writer_HandleReplicateAPIEvent_Call

func (*Writer_HandleReplicateAPIEvent_Call) RunAndReturn

func (_c *Writer_HandleReplicateAPIEvent_Call) RunAndReturn(run func(context.Context, *api.ReplicateAPIEvent) error) *Writer_HandleReplicateAPIEvent_Call

type Writer_HandleReplicateMessage_Call

type Writer_HandleReplicateMessage_Call struct {
	*mock.Call
}

Writer_HandleReplicateMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleReplicateMessage'

func (*Writer_HandleReplicateMessage_Call) Return

func (_c *Writer_HandleReplicateMessage_Call) Return(_a0 []byte, _a1 []byte, _a2 error) *Writer_HandleReplicateMessage_Call

func (*Writer_HandleReplicateMessage_Call) Run

func (_c *Writer_HandleReplicateMessage_Call) Run(run func(ctx context.Context, channelName string, msgPack *msgstream.MsgPack)) *Writer_HandleReplicateMessage_Call

func (*Writer_HandleReplicateMessage_Call) RunAndReturn

func (_c *Writer_HandleReplicateMessage_Call) RunAndReturn(run func(context.Context, string, *msgstream.MsgPack) ([]byte, []byte, error)) *Writer_HandleReplicateMessage_Call

type Writer_RecoveryMetaMsg_Call

type Writer_RecoveryMetaMsg_Call struct {
	*mock.Call
}

Writer_RecoveryMetaMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecoveryMetaMsg'

func (*Writer_RecoveryMetaMsg_Call) Return

func (_c *Writer_RecoveryMetaMsg_Call) Return(_a0 error) *Writer_RecoveryMetaMsg_Call

func (*Writer_RecoveryMetaMsg_Call) Run

func (_c *Writer_RecoveryMetaMsg_Call) Run(run func(ctx context.Context, taskID string)) *Writer_RecoveryMetaMsg_Call

func (*Writer_RecoveryMetaMsg_Call) RunAndReturn

func (_c *Writer_RecoveryMetaMsg_Call) RunAndReturn(run func(context.Context, string) error) *Writer_RecoveryMetaMsg_Call