Documentation ¶
Index ¶
- type GarbageCollector
- func (_m *GarbageCollector) EXPECT() *GarbageCollector_Expecter
- func (_m *GarbageCollector) GcCollectionData(ctx context.Context, coll *model.Collection) (uint64, error)
- func (_m *GarbageCollector) GcPartitionData(ctx context.Context, pChannels []string, vchannels []string, ...) (uint64, error)
- func (_m *GarbageCollector) ReDropCollection(collMeta *model.Collection, ts uint64)
- func (_m *GarbageCollector) ReDropPartition(dbID int64, pChannels []string, vchannels []string, partition *model.Partition, ...)
- func (_m *GarbageCollector) RemoveCreatingCollection(collMeta *model.Collection)
- func (_m *GarbageCollector) RemoveCreatingPartition(dbID int64, partition *model.Partition, ts uint64)
- type GarbageCollector_Expecter
- func (_e *GarbageCollector_Expecter) GcCollectionData(ctx interface{}, coll interface{}) *GarbageCollector_GcCollectionData_Call
- func (_e *GarbageCollector_Expecter) GcPartitionData(ctx interface{}, pChannels interface{}, vchannels interface{}, ...) *GarbageCollector_GcPartitionData_Call
- func (_e *GarbageCollector_Expecter) ReDropCollection(collMeta interface{}, ts interface{}) *GarbageCollector_ReDropCollection_Call
- func (_e *GarbageCollector_Expecter) ReDropPartition(dbID interface{}, pChannels interface{}, vchannels interface{}, ...) *GarbageCollector_ReDropPartition_Call
- func (_e *GarbageCollector_Expecter) RemoveCreatingCollection(collMeta interface{}) *GarbageCollector_RemoveCreatingCollection_Call
- func (_e *GarbageCollector_Expecter) RemoveCreatingPartition(dbID interface{}, partition interface{}, ts interface{}) *GarbageCollector_RemoveCreatingPartition_Call
- type GarbageCollector_GcCollectionData_Call
- func (_c *GarbageCollector_GcCollectionData_Call) Return(ddlTs uint64, err error) *GarbageCollector_GcCollectionData_Call
- func (_c *GarbageCollector_GcCollectionData_Call) Run(run func(ctx context.Context, coll *model.Collection)) *GarbageCollector_GcCollectionData_Call
- func (_c *GarbageCollector_GcCollectionData_Call) RunAndReturn(run func(context.Context, *model.Collection) (uint64, error)) *GarbageCollector_GcCollectionData_Call
- type GarbageCollector_GcPartitionData_Call
- func (_c *GarbageCollector_GcPartitionData_Call) Return(ddlTs uint64, err error) *GarbageCollector_GcPartitionData_Call
- func (_c *GarbageCollector_GcPartitionData_Call) Run(run func(ctx context.Context, pChannels []string, vchannels []string, ...)) *GarbageCollector_GcPartitionData_Call
- func (_c *GarbageCollector_GcPartitionData_Call) RunAndReturn(...) *GarbageCollector_GcPartitionData_Call
- type GarbageCollector_ReDropCollection_Call
- func (_c *GarbageCollector_ReDropCollection_Call) Return() *GarbageCollector_ReDropCollection_Call
- func (_c *GarbageCollector_ReDropCollection_Call) Run(run func(collMeta *model.Collection, ts uint64)) *GarbageCollector_ReDropCollection_Call
- func (_c *GarbageCollector_ReDropCollection_Call) RunAndReturn(run func(*model.Collection, uint64)) *GarbageCollector_ReDropCollection_Call
- type GarbageCollector_ReDropPartition_Call
- func (_c *GarbageCollector_ReDropPartition_Call) Return() *GarbageCollector_ReDropPartition_Call
- func (_c *GarbageCollector_ReDropPartition_Call) Run(...) *GarbageCollector_ReDropPartition_Call
- func (_c *GarbageCollector_ReDropPartition_Call) RunAndReturn(run func(int64, []string, []string, *model.Partition, uint64)) *GarbageCollector_ReDropPartition_Call
- type GarbageCollector_RemoveCreatingCollection_Call
- func (_c *GarbageCollector_RemoveCreatingCollection_Call) Return() *GarbageCollector_RemoveCreatingCollection_Call
- func (_c *GarbageCollector_RemoveCreatingCollection_Call) Run(run func(collMeta *model.Collection)) *GarbageCollector_RemoveCreatingCollection_Call
- func (_c *GarbageCollector_RemoveCreatingCollection_Call) RunAndReturn(run func(*model.Collection)) *GarbageCollector_RemoveCreatingCollection_Call
- type GarbageCollector_RemoveCreatingPartition_Call
- func (_c *GarbageCollector_RemoveCreatingPartition_Call) Return() *GarbageCollector_RemoveCreatingPartition_Call
- func (_c *GarbageCollector_RemoveCreatingPartition_Call) Run(run func(dbID int64, partition *model.Partition, ts uint64)) *GarbageCollector_RemoveCreatingPartition_Call
- func (_c *GarbageCollector_RemoveCreatingPartition_Call) RunAndReturn(run func(int64, *model.Partition, uint64)) *GarbageCollector_RemoveCreatingPartition_Call
- type IMetaTable
- func (_m *IMetaTable) AddCollection(ctx context.Context, coll *model.Collection) error
- func (_m *IMetaTable) AddCredential(credInfo *internalpb.CredentialInfo) error
- func (_m *IMetaTable) AddPartition(ctx context.Context, partition *model.Partition) error
- func (_m *IMetaTable) AlterAlias(ctx context.Context, dbName string, alias string, collectionName string, ...) error
- func (_m *IMetaTable) AlterCollection(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ...) error
- func (_m *IMetaTable) AlterCredential(credInfo *internalpb.CredentialInfo) error
- func (_m *IMetaTable) AlterDatabase(ctx context.Context, oldDB *model.Database, newDB *model.Database, ts uint64) error
- func (_m *IMetaTable) ChangeCollectionState(ctx context.Context, collectionID int64, state etcdpb.CollectionState, ...) error
- func (_m *IMetaTable) ChangePartitionState(ctx context.Context, collectionID int64, partitionID int64, ...) error
- func (_m *IMetaTable) CreateAlias(ctx context.Context, dbName string, alias string, collectionName string, ...) error
- func (_m *IMetaTable) CreateDatabase(ctx context.Context, db *model.Database, ts uint64) error
- func (_m *IMetaTable) CreateRole(tenant string, entity *milvuspb.RoleEntity) error
- func (_m *IMetaTable) DeleteCredential(username string) error
- func (_m *IMetaTable) DescribeAlias(ctx context.Context, dbName string, alias string, ts uint64) (string, error)
- func (_m *IMetaTable) DropAlias(ctx context.Context, dbName string, alias string, ts uint64) error
- func (_m *IMetaTable) DropDatabase(ctx context.Context, dbName string, ts uint64) error
- func (_m *IMetaTable) DropGrant(tenant string, role *milvuspb.RoleEntity) error
- func (_m *IMetaTable) DropRole(tenant string, roleName string) error
- func (_m *IMetaTable) EXPECT() *IMetaTable_Expecter
- func (_m *IMetaTable) GetCollectionByID(ctx context.Context, dbName string, collectionID int64, ts uint64, ...) (*model.Collection, error)
- func (_m *IMetaTable) GetCollectionByIDWithMaxTs(ctx context.Context, collectionID int64) (*model.Collection, error)
- func (_m *IMetaTable) GetCollectionByName(ctx context.Context, dbName string, collectionName string, ts uint64) (*model.Collection, error)
- func (_m *IMetaTable) GetCollectionVirtualChannels(colID int64) []string
- func (_m *IMetaTable) GetCredential(username string) (*internalpb.CredentialInfo, error)
- func (_m *IMetaTable) GetDatabaseByID(ctx context.Context, dbID int64, ts uint64) (*model.Database, error)
- func (_m *IMetaTable) GetDatabaseByName(ctx context.Context, dbName string, ts uint64) (*model.Database, error)
- func (_m *IMetaTable) GetPChannelInfo(pchannel string) *rootcoordpb.GetPChannelInfoResponse
- func (_m *IMetaTable) IsAlias(db string, name string) bool
- func (_m *IMetaTable) ListAliases(ctx context.Context, dbName string, collectionName string, ts uint64) ([]string, error)
- func (_m *IMetaTable) ListAliasesByID(collID int64) []string
- func (_m *IMetaTable) ListAllAvailCollections(ctx context.Context) map[int64][]int64
- func (_m *IMetaTable) ListCollectionPhysicalChannels() map[int64][]string
- func (_m *IMetaTable) ListCollections(ctx context.Context, dbName string, ts uint64, onlyAvail bool) ([]*model.Collection, error)
- func (_m *IMetaTable) ListCredentialUsernames() (*milvuspb.ListCredUsersResponse, error)
- func (_m *IMetaTable) ListDatabases(ctx context.Context, ts uint64) ([]*model.Database, error)
- func (_m *IMetaTable) ListPolicy(tenant string) ([]string, error)
- func (_m *IMetaTable) ListUserRole(tenant string) ([]string, error)
- func (_m *IMetaTable) OperatePrivilege(tenant string, entity *milvuspb.GrantEntity, ...) error
- func (_m *IMetaTable) OperateUserRole(tenant string, userEntity *milvuspb.UserEntity, ...) error
- func (_m *IMetaTable) RemoveCollection(ctx context.Context, collectionID int64, ts uint64) error
- func (_m *IMetaTable) RemovePartition(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ...) error
- func (_m *IMetaTable) RenameCollection(ctx context.Context, dbName string, oldName string, newDBName string, ...) error
- func (_m *IMetaTable) SelectGrant(tenant string, entity *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)
- func (_m *IMetaTable) SelectRole(tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool) ([]*milvuspb.RoleResult, error)
- func (_m *IMetaTable) SelectUser(tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool) ([]*milvuspb.UserResult, error)
- type IMetaTable_AddCollection_Call
- func (_c *IMetaTable_AddCollection_Call) Return(_a0 error) *IMetaTable_AddCollection_Call
- func (_c *IMetaTable_AddCollection_Call) Run(run func(ctx context.Context, coll *model.Collection)) *IMetaTable_AddCollection_Call
- func (_c *IMetaTable_AddCollection_Call) RunAndReturn(run func(context.Context, *model.Collection) error) *IMetaTable_AddCollection_Call
- type IMetaTable_AddCredential_Call
- func (_c *IMetaTable_AddCredential_Call) Return(_a0 error) *IMetaTable_AddCredential_Call
- func (_c *IMetaTable_AddCredential_Call) Run(run func(credInfo *internalpb.CredentialInfo)) *IMetaTable_AddCredential_Call
- func (_c *IMetaTable_AddCredential_Call) RunAndReturn(run func(*internalpb.CredentialInfo) error) *IMetaTable_AddCredential_Call
- type IMetaTable_AddPartition_Call
- func (_c *IMetaTable_AddPartition_Call) Return(_a0 error) *IMetaTable_AddPartition_Call
- func (_c *IMetaTable_AddPartition_Call) Run(run func(ctx context.Context, partition *model.Partition)) *IMetaTable_AddPartition_Call
- func (_c *IMetaTable_AddPartition_Call) RunAndReturn(run func(context.Context, *model.Partition) error) *IMetaTable_AddPartition_Call
- type IMetaTable_AlterAlias_Call
- func (_c *IMetaTable_AlterAlias_Call) Return(_a0 error) *IMetaTable_AlterAlias_Call
- func (_c *IMetaTable_AlterAlias_Call) Run(...) *IMetaTable_AlterAlias_Call
- func (_c *IMetaTable_AlterAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_AlterAlias_Call
- type IMetaTable_AlterCollection_Call
- func (_c *IMetaTable_AlterCollection_Call) Return(_a0 error) *IMetaTable_AlterCollection_Call
- func (_c *IMetaTable_AlterCollection_Call) Run(...) *IMetaTable_AlterCollection_Call
- func (_c *IMetaTable_AlterCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, *model.Collection, uint64) error) *IMetaTable_AlterCollection_Call
- type IMetaTable_AlterCredential_Call
- func (_c *IMetaTable_AlterCredential_Call) Return(_a0 error) *IMetaTable_AlterCredential_Call
- func (_c *IMetaTable_AlterCredential_Call) Run(run func(credInfo *internalpb.CredentialInfo)) *IMetaTable_AlterCredential_Call
- func (_c *IMetaTable_AlterCredential_Call) RunAndReturn(run func(*internalpb.CredentialInfo) error) *IMetaTable_AlterCredential_Call
- type IMetaTable_AlterDatabase_Call
- func (_c *IMetaTable_AlterDatabase_Call) Return(_a0 error) *IMetaTable_AlterDatabase_Call
- func (_c *IMetaTable_AlterDatabase_Call) Run(...) *IMetaTable_AlterDatabase_Call
- func (_c *IMetaTable_AlterDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, *model.Database, uint64) error) *IMetaTable_AlterDatabase_Call
- type IMetaTable_ChangeCollectionState_Call
- func (_c *IMetaTable_ChangeCollectionState_Call) Return(_a0 error) *IMetaTable_ChangeCollectionState_Call
- func (_c *IMetaTable_ChangeCollectionState_Call) Run(...) *IMetaTable_ChangeCollectionState_Call
- func (_c *IMetaTable_ChangeCollectionState_Call) RunAndReturn(run func(context.Context, int64, etcdpb.CollectionState, uint64) error) *IMetaTable_ChangeCollectionState_Call
- type IMetaTable_ChangePartitionState_Call
- func (_c *IMetaTable_ChangePartitionState_Call) Return(_a0 error) *IMetaTable_ChangePartitionState_Call
- func (_c *IMetaTable_ChangePartitionState_Call) Run(run func(ctx context.Context, collectionID int64, partitionID int64, ...)) *IMetaTable_ChangePartitionState_Call
- func (_c *IMetaTable_ChangePartitionState_Call) RunAndReturn(run func(context.Context, int64, int64, etcdpb.PartitionState, uint64) error) *IMetaTable_ChangePartitionState_Call
- type IMetaTable_CreateAlias_Call
- func (_c *IMetaTable_CreateAlias_Call) Return(_a0 error) *IMetaTable_CreateAlias_Call
- func (_c *IMetaTable_CreateAlias_Call) Run(...) *IMetaTable_CreateAlias_Call
- func (_c *IMetaTable_CreateAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_CreateAlias_Call
- type IMetaTable_CreateDatabase_Call
- func (_c *IMetaTable_CreateDatabase_Call) Return(_a0 error) *IMetaTable_CreateDatabase_Call
- func (_c *IMetaTable_CreateDatabase_Call) Run(run func(ctx context.Context, db *model.Database, ts uint64)) *IMetaTable_CreateDatabase_Call
- func (_c *IMetaTable_CreateDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *IMetaTable_CreateDatabase_Call
- type IMetaTable_CreateRole_Call
- func (_c *IMetaTable_CreateRole_Call) Return(_a0 error) *IMetaTable_CreateRole_Call
- func (_c *IMetaTable_CreateRole_Call) Run(run func(tenant string, entity *milvuspb.RoleEntity)) *IMetaTable_CreateRole_Call
- func (_c *IMetaTable_CreateRole_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity) error) *IMetaTable_CreateRole_Call
- type IMetaTable_DeleteCredential_Call
- func (_c *IMetaTable_DeleteCredential_Call) Return(_a0 error) *IMetaTable_DeleteCredential_Call
- func (_c *IMetaTable_DeleteCredential_Call) Run(run func(username string)) *IMetaTable_DeleteCredential_Call
- func (_c *IMetaTable_DeleteCredential_Call) RunAndReturn(run func(string) error) *IMetaTable_DeleteCredential_Call
- type IMetaTable_DescribeAlias_Call
- func (_c *IMetaTable_DescribeAlias_Call) Return(_a0 string, _a1 error) *IMetaTable_DescribeAlias_Call
- func (_c *IMetaTable_DescribeAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DescribeAlias_Call
- func (_c *IMetaTable_DescribeAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) (string, error)) *IMetaTable_DescribeAlias_Call
- type IMetaTable_DropAlias_Call
- func (_c *IMetaTable_DropAlias_Call) Return(_a0 error) *IMetaTable_DropAlias_Call
- func (_c *IMetaTable_DropAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DropAlias_Call
- func (_c *IMetaTable_DropAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) error) *IMetaTable_DropAlias_Call
- type IMetaTable_DropDatabase_Call
- func (_c *IMetaTable_DropDatabase_Call) Return(_a0 error) *IMetaTable_DropDatabase_Call
- func (_c *IMetaTable_DropDatabase_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_DropDatabase_Call
- func (_c *IMetaTable_DropDatabase_Call) RunAndReturn(run func(context.Context, string, uint64) error) *IMetaTable_DropDatabase_Call
- type IMetaTable_DropGrant_Call
- func (_c *IMetaTable_DropGrant_Call) Return(_a0 error) *IMetaTable_DropGrant_Call
- func (_c *IMetaTable_DropGrant_Call) Run(run func(tenant string, role *milvuspb.RoleEntity)) *IMetaTable_DropGrant_Call
- func (_c *IMetaTable_DropGrant_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity) error) *IMetaTable_DropGrant_Call
- type IMetaTable_DropRole_Call
- type IMetaTable_Expecter
- func (_e *IMetaTable_Expecter) AddCollection(ctx interface{}, coll interface{}) *IMetaTable_AddCollection_Call
- func (_e *IMetaTable_Expecter) AddCredential(credInfo interface{}) *IMetaTable_AddCredential_Call
- func (_e *IMetaTable_Expecter) AddPartition(ctx interface{}, partition interface{}) *IMetaTable_AddPartition_Call
- func (_e *IMetaTable_Expecter) AlterAlias(ctx interface{}, dbName interface{}, alias interface{}, ...) *IMetaTable_AlterAlias_Call
- func (_e *IMetaTable_Expecter) AlterCollection(ctx interface{}, oldColl interface{}, newColl interface{}, ts interface{}) *IMetaTable_AlterCollection_Call
- func (_e *IMetaTable_Expecter) AlterCredential(credInfo interface{}) *IMetaTable_AlterCredential_Call
- func (_e *IMetaTable_Expecter) AlterDatabase(ctx interface{}, oldDB interface{}, newDB interface{}, ts interface{}) *IMetaTable_AlterDatabase_Call
- func (_e *IMetaTable_Expecter) ChangeCollectionState(ctx interface{}, collectionID interface{}, state interface{}, ts interface{}) *IMetaTable_ChangeCollectionState_Call
- func (_e *IMetaTable_Expecter) ChangePartitionState(ctx interface{}, collectionID interface{}, partitionID interface{}, ...) *IMetaTable_ChangePartitionState_Call
- func (_e *IMetaTable_Expecter) CreateAlias(ctx interface{}, dbName interface{}, alias interface{}, ...) *IMetaTable_CreateAlias_Call
- func (_e *IMetaTable_Expecter) CreateDatabase(ctx interface{}, db interface{}, ts interface{}) *IMetaTable_CreateDatabase_Call
- func (_e *IMetaTable_Expecter) CreateRole(tenant interface{}, entity interface{}) *IMetaTable_CreateRole_Call
- func (_e *IMetaTable_Expecter) DeleteCredential(username interface{}) *IMetaTable_DeleteCredential_Call
- func (_e *IMetaTable_Expecter) DescribeAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DescribeAlias_Call
- func (_e *IMetaTable_Expecter) DropAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DropAlias_Call
- func (_e *IMetaTable_Expecter) DropDatabase(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_DropDatabase_Call
- func (_e *IMetaTable_Expecter) DropGrant(tenant interface{}, role interface{}) *IMetaTable_DropGrant_Call
- func (_e *IMetaTable_Expecter) DropRole(tenant interface{}, roleName interface{}) *IMetaTable_DropRole_Call
- func (_e *IMetaTable_Expecter) GetCollectionByID(ctx interface{}, dbName interface{}, collectionID interface{}, ts interface{}, ...) *IMetaTable_GetCollectionByID_Call
- func (_e *IMetaTable_Expecter) GetCollectionByIDWithMaxTs(ctx interface{}, collectionID interface{}) *IMetaTable_GetCollectionByIDWithMaxTs_Call
- func (_e *IMetaTable_Expecter) GetCollectionByName(ctx interface{}, dbName interface{}, collectionName interface{}, ...) *IMetaTable_GetCollectionByName_Call
- func (_e *IMetaTable_Expecter) GetCollectionVirtualChannels(colID interface{}) *IMetaTable_GetCollectionVirtualChannels_Call
- func (_e *IMetaTable_Expecter) GetCredential(username interface{}) *IMetaTable_GetCredential_Call
- func (_e *IMetaTable_Expecter) GetDatabaseByID(ctx interface{}, dbID interface{}, ts interface{}) *IMetaTable_GetDatabaseByID_Call
- func (_e *IMetaTable_Expecter) GetDatabaseByName(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_GetDatabaseByName_Call
- func (_e *IMetaTable_Expecter) GetPChannelInfo(pchannel interface{}) *IMetaTable_GetPChannelInfo_Call
- func (_e *IMetaTable_Expecter) IsAlias(db interface{}, name interface{}) *IMetaTable_IsAlias_Call
- func (_e *IMetaTable_Expecter) ListAliases(ctx interface{}, dbName interface{}, collectionName interface{}, ...) *IMetaTable_ListAliases_Call
- func (_e *IMetaTable_Expecter) ListAliasesByID(collID interface{}) *IMetaTable_ListAliasesByID_Call
- func (_e *IMetaTable_Expecter) ListAllAvailCollections(ctx interface{}) *IMetaTable_ListAllAvailCollections_Call
- func (_e *IMetaTable_Expecter) ListCollectionPhysicalChannels() *IMetaTable_ListCollectionPhysicalChannels_Call
- func (_e *IMetaTable_Expecter) ListCollections(ctx interface{}, dbName interface{}, ts interface{}, onlyAvail interface{}) *IMetaTable_ListCollections_Call
- func (_e *IMetaTable_Expecter) ListCredentialUsernames() *IMetaTable_ListCredentialUsernames_Call
- func (_e *IMetaTable_Expecter) ListDatabases(ctx interface{}, ts interface{}) *IMetaTable_ListDatabases_Call
- func (_e *IMetaTable_Expecter) ListPolicy(tenant interface{}) *IMetaTable_ListPolicy_Call
- func (_e *IMetaTable_Expecter) ListUserRole(tenant interface{}) *IMetaTable_ListUserRole_Call
- func (_e *IMetaTable_Expecter) OperatePrivilege(tenant interface{}, entity interface{}, operateType interface{}) *IMetaTable_OperatePrivilege_Call
- func (_e *IMetaTable_Expecter) OperateUserRole(tenant interface{}, userEntity interface{}, roleEntity interface{}, ...) *IMetaTable_OperateUserRole_Call
- func (_e *IMetaTable_Expecter) RemoveCollection(ctx interface{}, collectionID interface{}, ts interface{}) *IMetaTable_RemoveCollection_Call
- func (_e *IMetaTable_Expecter) RemovePartition(ctx interface{}, dbID interface{}, collectionID interface{}, ...) *IMetaTable_RemovePartition_Call
- func (_e *IMetaTable_Expecter) RenameCollection(ctx interface{}, dbName interface{}, oldName interface{}, ...) *IMetaTable_RenameCollection_Call
- func (_e *IMetaTable_Expecter) SelectGrant(tenant interface{}, entity interface{}) *IMetaTable_SelectGrant_Call
- func (_e *IMetaTable_Expecter) SelectRole(tenant interface{}, entity interface{}, includeUserInfo interface{}) *IMetaTable_SelectRole_Call
- func (_e *IMetaTable_Expecter) SelectUser(tenant interface{}, entity interface{}, includeRoleInfo interface{}) *IMetaTable_SelectUser_Call
- type IMetaTable_GetCollectionByIDWithMaxTs_Call
- func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByIDWithMaxTs_Call
- func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Run(run func(ctx context.Context, collectionID int64)) *IMetaTable_GetCollectionByIDWithMaxTs_Call
- func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) RunAndReturn(run func(context.Context, int64) (*model.Collection, error)) *IMetaTable_GetCollectionByIDWithMaxTs_Call
- type IMetaTable_GetCollectionByID_Call
- func (_c *IMetaTable_GetCollectionByID_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByID_Call
- func (_c *IMetaTable_GetCollectionByID_Call) Run(...) *IMetaTable_GetCollectionByID_Call
- func (_c *IMetaTable_GetCollectionByID_Call) RunAndReturn(...) *IMetaTable_GetCollectionByID_Call
- type IMetaTable_GetCollectionByName_Call
- func (_c *IMetaTable_GetCollectionByName_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByName_Call
- func (_c *IMetaTable_GetCollectionByName_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_GetCollectionByName_Call
- func (_c *IMetaTable_GetCollectionByName_Call) RunAndReturn(run func(context.Context, string, string, uint64) (*model.Collection, error)) *IMetaTable_GetCollectionByName_Call
- type IMetaTable_GetCollectionVirtualChannels_Call
- func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Return(_a0 []string) *IMetaTable_GetCollectionVirtualChannels_Call
- func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Run(run func(colID int64)) *IMetaTable_GetCollectionVirtualChannels_Call
- func (_c *IMetaTable_GetCollectionVirtualChannels_Call) RunAndReturn(run func(int64) []string) *IMetaTable_GetCollectionVirtualChannels_Call
- type IMetaTable_GetCredential_Call
- func (_c *IMetaTable_GetCredential_Call) Return(_a0 *internalpb.CredentialInfo, _a1 error) *IMetaTable_GetCredential_Call
- func (_c *IMetaTable_GetCredential_Call) Run(run func(username string)) *IMetaTable_GetCredential_Call
- func (_c *IMetaTable_GetCredential_Call) RunAndReturn(run func(string) (*internalpb.CredentialInfo, error)) *IMetaTable_GetCredential_Call
- type IMetaTable_GetDatabaseByID_Call
- func (_c *IMetaTable_GetDatabaseByID_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByID_Call
- func (_c *IMetaTable_GetDatabaseByID_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *IMetaTable_GetDatabaseByID_Call
- func (_c *IMetaTable_GetDatabaseByID_Call) RunAndReturn(run func(context.Context, int64, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByID_Call
- type IMetaTable_GetDatabaseByName_Call
- func (_c *IMetaTable_GetDatabaseByName_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByName_Call
- func (_c *IMetaTable_GetDatabaseByName_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_GetDatabaseByName_Call
- func (_c *IMetaTable_GetDatabaseByName_Call) RunAndReturn(run func(context.Context, string, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByName_Call
- type IMetaTable_GetPChannelInfo_Call
- func (_c *IMetaTable_GetPChannelInfo_Call) Return(_a0 *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call
- func (_c *IMetaTable_GetPChannelInfo_Call) Run(run func(pchannel string)) *IMetaTable_GetPChannelInfo_Call
- func (_c *IMetaTable_GetPChannelInfo_Call) RunAndReturn(run func(string) *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call
- type IMetaTable_IsAlias_Call
- type IMetaTable_ListAliasesByID_Call
- func (_c *IMetaTable_ListAliasesByID_Call) Return(_a0 []string) *IMetaTable_ListAliasesByID_Call
- func (_c *IMetaTable_ListAliasesByID_Call) Run(run func(collID int64)) *IMetaTable_ListAliasesByID_Call
- func (_c *IMetaTable_ListAliasesByID_Call) RunAndReturn(run func(int64) []string) *IMetaTable_ListAliasesByID_Call
- type IMetaTable_ListAliases_Call
- func (_c *IMetaTable_ListAliases_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListAliases_Call
- func (_c *IMetaTable_ListAliases_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_ListAliases_Call
- func (_c *IMetaTable_ListAliases_Call) RunAndReturn(run func(context.Context, string, string, uint64) ([]string, error)) *IMetaTable_ListAliases_Call
- type IMetaTable_ListAllAvailCollections_Call
- func (_c *IMetaTable_ListAllAvailCollections_Call) Return(_a0 map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call
- func (_c *IMetaTable_ListAllAvailCollections_Call) Run(run func(ctx context.Context)) *IMetaTable_ListAllAvailCollections_Call
- func (_c *IMetaTable_ListAllAvailCollections_Call) RunAndReturn(run func(context.Context) map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call
- type IMetaTable_ListCollectionPhysicalChannels_Call
- func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Return(_a0 map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call
- func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Run(run func()) *IMetaTable_ListCollectionPhysicalChannels_Call
- func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) RunAndReturn(run func() map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call
- type IMetaTable_ListCollections_Call
- func (_c *IMetaTable_ListCollections_Call) Return(_a0 []*model.Collection, _a1 error) *IMetaTable_ListCollections_Call
- func (_c *IMetaTable_ListCollections_Call) Run(run func(ctx context.Context, dbName string, ts uint64, onlyAvail bool)) *IMetaTable_ListCollections_Call
- func (_c *IMetaTable_ListCollections_Call) RunAndReturn(run func(context.Context, string, uint64, bool) ([]*model.Collection, error)) *IMetaTable_ListCollections_Call
- type IMetaTable_ListCredentialUsernames_Call
- func (_c *IMetaTable_ListCredentialUsernames_Call) Return(_a0 *milvuspb.ListCredUsersResponse, _a1 error) *IMetaTable_ListCredentialUsernames_Call
- func (_c *IMetaTable_ListCredentialUsernames_Call) Run(run func()) *IMetaTable_ListCredentialUsernames_Call
- func (_c *IMetaTable_ListCredentialUsernames_Call) RunAndReturn(run func() (*milvuspb.ListCredUsersResponse, error)) *IMetaTable_ListCredentialUsernames_Call
- type IMetaTable_ListDatabases_Call
- func (_c *IMetaTable_ListDatabases_Call) Return(_a0 []*model.Database, _a1 error) *IMetaTable_ListDatabases_Call
- func (_c *IMetaTable_ListDatabases_Call) Run(run func(ctx context.Context, ts uint64)) *IMetaTable_ListDatabases_Call
- func (_c *IMetaTable_ListDatabases_Call) RunAndReturn(run func(context.Context, uint64) ([]*model.Database, error)) *IMetaTable_ListDatabases_Call
- type IMetaTable_ListPolicy_Call
- func (_c *IMetaTable_ListPolicy_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListPolicy_Call
- func (_c *IMetaTable_ListPolicy_Call) Run(run func(tenant string)) *IMetaTable_ListPolicy_Call
- func (_c *IMetaTable_ListPolicy_Call) RunAndReturn(run func(string) ([]string, error)) *IMetaTable_ListPolicy_Call
- type IMetaTable_ListUserRole_Call
- func (_c *IMetaTable_ListUserRole_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListUserRole_Call
- func (_c *IMetaTable_ListUserRole_Call) Run(run func(tenant string)) *IMetaTable_ListUserRole_Call
- func (_c *IMetaTable_ListUserRole_Call) RunAndReturn(run func(string) ([]string, error)) *IMetaTable_ListUserRole_Call
- type IMetaTable_OperatePrivilege_Call
- func (_c *IMetaTable_OperatePrivilege_Call) Return(_a0 error) *IMetaTable_OperatePrivilege_Call
- func (_c *IMetaTable_OperatePrivilege_Call) Run(run func(tenant string, entity *milvuspb.GrantEntity, ...)) *IMetaTable_OperatePrivilege_Call
- func (_c *IMetaTable_OperatePrivilege_Call) RunAndReturn(run func(string, *milvuspb.GrantEntity, milvuspb.OperatePrivilegeType) error) *IMetaTable_OperatePrivilege_Call
- type IMetaTable_OperateUserRole_Call
- func (_c *IMetaTable_OperateUserRole_Call) Return(_a0 error) *IMetaTable_OperateUserRole_Call
- func (_c *IMetaTable_OperateUserRole_Call) Run(run func(tenant string, userEntity *milvuspb.UserEntity, ...)) *IMetaTable_OperateUserRole_Call
- func (_c *IMetaTable_OperateUserRole_Call) RunAndReturn(run func(string, *milvuspb.UserEntity, *milvuspb.RoleEntity, ...) error) *IMetaTable_OperateUserRole_Call
- type IMetaTable_RemoveCollection_Call
- func (_c *IMetaTable_RemoveCollection_Call) Return(_a0 error) *IMetaTable_RemoveCollection_Call
- func (_c *IMetaTable_RemoveCollection_Call) Run(run func(ctx context.Context, collectionID int64, ts uint64)) *IMetaTable_RemoveCollection_Call
- func (_c *IMetaTable_RemoveCollection_Call) RunAndReturn(run func(context.Context, int64, uint64) error) *IMetaTable_RemoveCollection_Call
- type IMetaTable_RemovePartition_Call
- func (_c *IMetaTable_RemovePartition_Call) Return(_a0 error) *IMetaTable_RemovePartition_Call
- func (_c *IMetaTable_RemovePartition_Call) Run(...) *IMetaTable_RemovePartition_Call
- func (_c *IMetaTable_RemovePartition_Call) RunAndReturn(run func(context.Context, int64, int64, int64, uint64) error) *IMetaTable_RemovePartition_Call
- type IMetaTable_RenameCollection_Call
- func (_c *IMetaTable_RenameCollection_Call) Return(_a0 error) *IMetaTable_RenameCollection_Call
- func (_c *IMetaTable_RenameCollection_Call) Run(...) *IMetaTable_RenameCollection_Call
- func (_c *IMetaTable_RenameCollection_Call) RunAndReturn(run func(context.Context, string, string, string, string, uint64) error) *IMetaTable_RenameCollection_Call
- type IMetaTable_SelectGrant_Call
- func (_c *IMetaTable_SelectGrant_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *IMetaTable_SelectGrant_Call
- func (_c *IMetaTable_SelectGrant_Call) Run(run func(tenant string, entity *milvuspb.GrantEntity)) *IMetaTable_SelectGrant_Call
- func (_c *IMetaTable_SelectGrant_Call) RunAndReturn(run func(string, *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)) *IMetaTable_SelectGrant_Call
- type IMetaTable_SelectRole_Call
- func (_c *IMetaTable_SelectRole_Call) Return(_a0 []*milvuspb.RoleResult, _a1 error) *IMetaTable_SelectRole_Call
- func (_c *IMetaTable_SelectRole_Call) Run(run func(tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool)) *IMetaTable_SelectRole_Call
- func (_c *IMetaTable_SelectRole_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity, bool) ([]*milvuspb.RoleResult, error)) *IMetaTable_SelectRole_Call
- type IMetaTable_SelectUser_Call
- func (_c *IMetaTable_SelectUser_Call) Return(_a0 []*milvuspb.UserResult, _a1 error) *IMetaTable_SelectUser_Call
- func (_c *IMetaTable_SelectUser_Call) Run(run func(tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool)) *IMetaTable_SelectUser_Call
- func (_c *IMetaTable_SelectUser_Call) RunAndReturn(run func(string, *milvuspb.UserEntity, bool) ([]*milvuspb.UserResult, error)) *IMetaTable_SelectUser_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GarbageCollector ¶
GarbageCollector is an autogenerated mock type for the GarbageCollector type
func NewGarbageCollector ¶
func NewGarbageCollector(t interface { mock.TestingT Cleanup(func()) }) *GarbageCollector
NewGarbageCollector creates a new instance of GarbageCollector. 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 (*GarbageCollector) EXPECT ¶
func (_m *GarbageCollector) EXPECT() *GarbageCollector_Expecter
func (*GarbageCollector) GcCollectionData ¶
func (_m *GarbageCollector) GcCollectionData(ctx context.Context, coll *model.Collection) (uint64, error)
GcCollectionData provides a mock function with given fields: ctx, coll
func (*GarbageCollector) GcPartitionData ¶
func (_m *GarbageCollector) GcPartitionData(ctx context.Context, pChannels []string, vchannels []string, partition *model.Partition) (uint64, error)
GcPartitionData provides a mock function with given fields: ctx, pChannels, vchannels, partition
func (*GarbageCollector) ReDropCollection ¶
func (_m *GarbageCollector) ReDropCollection(collMeta *model.Collection, ts uint64)
ReDropCollection provides a mock function with given fields: collMeta, ts
func (*GarbageCollector) ReDropPartition ¶
func (_m *GarbageCollector) ReDropPartition(dbID int64, pChannels []string, vchannels []string, partition *model.Partition, ts uint64)
ReDropPartition provides a mock function with given fields: dbID, pChannels, vchannels, partition, ts
func (*GarbageCollector) RemoveCreatingCollection ¶
func (_m *GarbageCollector) RemoveCreatingCollection(collMeta *model.Collection)
RemoveCreatingCollection provides a mock function with given fields: collMeta
func (*GarbageCollector) RemoveCreatingPartition ¶
func (_m *GarbageCollector) RemoveCreatingPartition(dbID int64, partition *model.Partition, ts uint64)
RemoveCreatingPartition provides a mock function with given fields: dbID, partition, ts
type GarbageCollector_Expecter ¶
type GarbageCollector_Expecter struct {
// contains filtered or unexported fields
}
func (*GarbageCollector_Expecter) GcCollectionData ¶
func (_e *GarbageCollector_Expecter) GcCollectionData(ctx interface{}, coll interface{}) *GarbageCollector_GcCollectionData_Call
GcCollectionData is a helper method to define mock.On call
- ctx context.Context
- coll *model.Collection
func (*GarbageCollector_Expecter) GcPartitionData ¶
func (_e *GarbageCollector_Expecter) GcPartitionData(ctx interface{}, pChannels interface{}, vchannels interface{}, partition interface{}) *GarbageCollector_GcPartitionData_Call
GcPartitionData is a helper method to define mock.On call
- ctx context.Context
- pChannels []string
- vchannels []string
- partition *model.Partition
func (*GarbageCollector_Expecter) ReDropCollection ¶
func (_e *GarbageCollector_Expecter) ReDropCollection(collMeta interface{}, ts interface{}) *GarbageCollector_ReDropCollection_Call
ReDropCollection is a helper method to define mock.On call
- collMeta *model.Collection
- ts uint64
func (*GarbageCollector_Expecter) ReDropPartition ¶
func (_e *GarbageCollector_Expecter) ReDropPartition(dbID interface{}, pChannels interface{}, vchannels interface{}, partition interface{}, ts interface{}) *GarbageCollector_ReDropPartition_Call
ReDropPartition is a helper method to define mock.On call
- dbID int64
- pChannels []string
- vchannels []string
- partition *model.Partition
- ts uint64
func (*GarbageCollector_Expecter) RemoveCreatingCollection ¶
func (_e *GarbageCollector_Expecter) RemoveCreatingCollection(collMeta interface{}) *GarbageCollector_RemoveCreatingCollection_Call
RemoveCreatingCollection is a helper method to define mock.On call
- collMeta *model.Collection
func (*GarbageCollector_Expecter) RemoveCreatingPartition ¶
func (_e *GarbageCollector_Expecter) RemoveCreatingPartition(dbID interface{}, partition interface{}, ts interface{}) *GarbageCollector_RemoveCreatingPartition_Call
RemoveCreatingPartition is a helper method to define mock.On call
- dbID int64
- partition *model.Partition
- ts uint64
type GarbageCollector_GcCollectionData_Call ¶
GarbageCollector_GcCollectionData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GcCollectionData'
func (*GarbageCollector_GcCollectionData_Call) Return ¶
func (_c *GarbageCollector_GcCollectionData_Call) Return(ddlTs uint64, err error) *GarbageCollector_GcCollectionData_Call
func (*GarbageCollector_GcCollectionData_Call) Run ¶
func (_c *GarbageCollector_GcCollectionData_Call) Run(run func(ctx context.Context, coll *model.Collection)) *GarbageCollector_GcCollectionData_Call
func (*GarbageCollector_GcCollectionData_Call) RunAndReturn ¶
func (_c *GarbageCollector_GcCollectionData_Call) RunAndReturn(run func(context.Context, *model.Collection) (uint64, error)) *GarbageCollector_GcCollectionData_Call
type GarbageCollector_GcPartitionData_Call ¶
GarbageCollector_GcPartitionData_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GcPartitionData'
func (*GarbageCollector_GcPartitionData_Call) Return ¶
func (_c *GarbageCollector_GcPartitionData_Call) Return(ddlTs uint64, err error) *GarbageCollector_GcPartitionData_Call
func (*GarbageCollector_GcPartitionData_Call) Run ¶
func (_c *GarbageCollector_GcPartitionData_Call) Run(run func(ctx context.Context, pChannels []string, vchannels []string, partition *model.Partition)) *GarbageCollector_GcPartitionData_Call
func (*GarbageCollector_GcPartitionData_Call) RunAndReturn ¶
func (_c *GarbageCollector_GcPartitionData_Call) RunAndReturn(run func(context.Context, []string, []string, *model.Partition) (uint64, error)) *GarbageCollector_GcPartitionData_Call
type GarbageCollector_ReDropCollection_Call ¶
GarbageCollector_ReDropCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReDropCollection'
func (*GarbageCollector_ReDropCollection_Call) Return ¶
func (_c *GarbageCollector_ReDropCollection_Call) Return() *GarbageCollector_ReDropCollection_Call
func (*GarbageCollector_ReDropCollection_Call) Run ¶
func (_c *GarbageCollector_ReDropCollection_Call) Run(run func(collMeta *model.Collection, ts uint64)) *GarbageCollector_ReDropCollection_Call
func (*GarbageCollector_ReDropCollection_Call) RunAndReturn ¶
func (_c *GarbageCollector_ReDropCollection_Call) RunAndReturn(run func(*model.Collection, uint64)) *GarbageCollector_ReDropCollection_Call
type GarbageCollector_ReDropPartition_Call ¶
GarbageCollector_ReDropPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReDropPartition'
func (*GarbageCollector_ReDropPartition_Call) Return ¶
func (_c *GarbageCollector_ReDropPartition_Call) Return() *GarbageCollector_ReDropPartition_Call
func (*GarbageCollector_ReDropPartition_Call) Run ¶
func (_c *GarbageCollector_ReDropPartition_Call) Run(run func(dbID int64, pChannels []string, vchannels []string, partition *model.Partition, ts uint64)) *GarbageCollector_ReDropPartition_Call
func (*GarbageCollector_ReDropPartition_Call) RunAndReturn ¶
func (_c *GarbageCollector_ReDropPartition_Call) RunAndReturn(run func(int64, []string, []string, *model.Partition, uint64)) *GarbageCollector_ReDropPartition_Call
type GarbageCollector_RemoveCreatingCollection_Call ¶
GarbageCollector_RemoveCreatingCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveCreatingCollection'
func (*GarbageCollector_RemoveCreatingCollection_Call) Run ¶
func (_c *GarbageCollector_RemoveCreatingCollection_Call) Run(run func(collMeta *model.Collection)) *GarbageCollector_RemoveCreatingCollection_Call
func (*GarbageCollector_RemoveCreatingCollection_Call) RunAndReturn ¶
func (_c *GarbageCollector_RemoveCreatingCollection_Call) RunAndReturn(run func(*model.Collection)) *GarbageCollector_RemoveCreatingCollection_Call
type GarbageCollector_RemoveCreatingPartition_Call ¶
GarbageCollector_RemoveCreatingPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveCreatingPartition'
func (*GarbageCollector_RemoveCreatingPartition_Call) Run ¶
func (_c *GarbageCollector_RemoveCreatingPartition_Call) Run(run func(dbID int64, partition *model.Partition, ts uint64)) *GarbageCollector_RemoveCreatingPartition_Call
func (*GarbageCollector_RemoveCreatingPartition_Call) RunAndReturn ¶
func (_c *GarbageCollector_RemoveCreatingPartition_Call) RunAndReturn(run func(int64, *model.Partition, uint64)) *GarbageCollector_RemoveCreatingPartition_Call
type IMetaTable ¶
IMetaTable is an autogenerated mock type for the IMetaTable type
func NewIMetaTable ¶
func NewIMetaTable(t interface { mock.TestingT Cleanup(func()) }) *IMetaTable
NewIMetaTable creates a new instance of IMetaTable. 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 (*IMetaTable) AddCollection ¶
func (_m *IMetaTable) AddCollection(ctx context.Context, coll *model.Collection) error
AddCollection provides a mock function with given fields: ctx, coll
func (*IMetaTable) AddCredential ¶
func (_m *IMetaTable) AddCredential(credInfo *internalpb.CredentialInfo) error
AddCredential provides a mock function with given fields: credInfo
func (*IMetaTable) AddPartition ¶
AddPartition provides a mock function with given fields: ctx, partition
func (*IMetaTable) AlterAlias ¶
func (_m *IMetaTable) AlterAlias(ctx context.Context, dbName string, alias string, collectionName string, ts uint64) error
AlterAlias provides a mock function with given fields: ctx, dbName, alias, collectionName, ts
func (*IMetaTable) AlterCollection ¶
func (_m *IMetaTable) AlterCollection(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ts uint64) error
AlterCollection provides a mock function with given fields: ctx, oldColl, newColl, ts
func (*IMetaTable) AlterCredential ¶
func (_m *IMetaTable) AlterCredential(credInfo *internalpb.CredentialInfo) error
AlterCredential provides a mock function with given fields: credInfo
func (*IMetaTable) AlterDatabase ¶
func (_m *IMetaTable) AlterDatabase(ctx context.Context, oldDB *model.Database, newDB *model.Database, ts uint64) error
AlterDatabase provides a mock function with given fields: ctx, oldDB, newDB, ts
func (*IMetaTable) ChangeCollectionState ¶
func (_m *IMetaTable) ChangeCollectionState(ctx context.Context, collectionID int64, state etcdpb.CollectionState, ts uint64) error
ChangeCollectionState provides a mock function with given fields: ctx, collectionID, state, ts
func (*IMetaTable) ChangePartitionState ¶
func (_m *IMetaTable) ChangePartitionState(ctx context.Context, collectionID int64, partitionID int64, state etcdpb.PartitionState, ts uint64) error
ChangePartitionState provides a mock function with given fields: ctx, collectionID, partitionID, state, ts
func (*IMetaTable) CreateAlias ¶
func (_m *IMetaTable) CreateAlias(ctx context.Context, dbName string, alias string, collectionName string, ts uint64) error
CreateAlias provides a mock function with given fields: ctx, dbName, alias, collectionName, ts
func (*IMetaTable) CreateDatabase ¶
CreateDatabase provides a mock function with given fields: ctx, db, ts
func (*IMetaTable) CreateRole ¶
func (_m *IMetaTable) CreateRole(tenant string, entity *milvuspb.RoleEntity) error
CreateRole provides a mock function with given fields: tenant, entity
func (*IMetaTable) DeleteCredential ¶
func (_m *IMetaTable) DeleteCredential(username string) error
DeleteCredential provides a mock function with given fields: username
func (*IMetaTable) DescribeAlias ¶
func (_m *IMetaTable) DescribeAlias(ctx context.Context, dbName string, alias string, ts uint64) (string, error)
DescribeAlias provides a mock function with given fields: ctx, dbName, alias, ts
func (*IMetaTable) DropAlias ¶
DropAlias provides a mock function with given fields: ctx, dbName, alias, ts
func (*IMetaTable) DropDatabase ¶
DropDatabase provides a mock function with given fields: ctx, dbName, ts
func (*IMetaTable) DropGrant ¶
func (_m *IMetaTable) DropGrant(tenant string, role *milvuspb.RoleEntity) error
DropGrant provides a mock function with given fields: tenant, role
func (*IMetaTable) DropRole ¶
func (_m *IMetaTable) DropRole(tenant string, roleName string) error
DropRole provides a mock function with given fields: tenant, roleName
func (*IMetaTable) EXPECT ¶
func (_m *IMetaTable) EXPECT() *IMetaTable_Expecter
func (*IMetaTable) GetCollectionByID ¶
func (_m *IMetaTable) GetCollectionByID(ctx context.Context, dbName string, collectionID int64, ts uint64, allowUnavailable bool) (*model.Collection, error)
GetCollectionByID provides a mock function with given fields: ctx, dbName, collectionID, ts, allowUnavailable
func (*IMetaTable) GetCollectionByIDWithMaxTs ¶
func (_m *IMetaTable) GetCollectionByIDWithMaxTs(ctx context.Context, collectionID int64) (*model.Collection, error)
GetCollectionByIDWithMaxTs provides a mock function with given fields: ctx, collectionID
func (*IMetaTable) GetCollectionByName ¶
func (_m *IMetaTable) GetCollectionByName(ctx context.Context, dbName string, collectionName string, ts uint64) (*model.Collection, error)
GetCollectionByName provides a mock function with given fields: ctx, dbName, collectionName, ts
func (*IMetaTable) GetCollectionVirtualChannels ¶
func (_m *IMetaTable) GetCollectionVirtualChannels(colID int64) []string
GetCollectionVirtualChannels provides a mock function with given fields: colID
func (*IMetaTable) GetCredential ¶
func (_m *IMetaTable) GetCredential(username string) (*internalpb.CredentialInfo, error)
GetCredential provides a mock function with given fields: username
func (*IMetaTable) GetDatabaseByID ¶
func (_m *IMetaTable) GetDatabaseByID(ctx context.Context, dbID int64, ts uint64) (*model.Database, error)
GetDatabaseByID provides a mock function with given fields: ctx, dbID, ts
func (*IMetaTable) GetDatabaseByName ¶
func (_m *IMetaTable) GetDatabaseByName(ctx context.Context, dbName string, ts uint64) (*model.Database, error)
GetDatabaseByName provides a mock function with given fields: ctx, dbName, ts
func (*IMetaTable) GetPChannelInfo ¶
func (_m *IMetaTable) GetPChannelInfo(pchannel string) *rootcoordpb.GetPChannelInfoResponse
GetPChannelInfo provides a mock function with given fields: pchannel
func (*IMetaTable) IsAlias ¶
func (_m *IMetaTable) IsAlias(db string, name string) bool
IsAlias provides a mock function with given fields: db, name
func (*IMetaTable) ListAliases ¶
func (_m *IMetaTable) ListAliases(ctx context.Context, dbName string, collectionName string, ts uint64) ([]string, error)
ListAliases provides a mock function with given fields: ctx, dbName, collectionName, ts
func (*IMetaTable) ListAliasesByID ¶
func (_m *IMetaTable) ListAliasesByID(collID int64) []string
ListAliasesByID provides a mock function with given fields: collID
func (*IMetaTable) ListAllAvailCollections ¶
func (_m *IMetaTable) ListAllAvailCollections(ctx context.Context) map[int64][]int64
ListAllAvailCollections provides a mock function with given fields: ctx
func (*IMetaTable) ListCollectionPhysicalChannels ¶
func (_m *IMetaTable) ListCollectionPhysicalChannels() map[int64][]string
ListCollectionPhysicalChannels provides a mock function with given fields:
func (*IMetaTable) ListCollections ¶
func (_m *IMetaTable) ListCollections(ctx context.Context, dbName string, ts uint64, onlyAvail bool) ([]*model.Collection, error)
ListCollections provides a mock function with given fields: ctx, dbName, ts, onlyAvail
func (*IMetaTable) ListCredentialUsernames ¶
func (_m *IMetaTable) ListCredentialUsernames() (*milvuspb.ListCredUsersResponse, error)
ListCredentialUsernames provides a mock function with given fields:
func (*IMetaTable) ListDatabases ¶
ListDatabases provides a mock function with given fields: ctx, ts
func (*IMetaTable) ListPolicy ¶
func (_m *IMetaTable) ListPolicy(tenant string) ([]string, error)
ListPolicy provides a mock function with given fields: tenant
func (*IMetaTable) ListUserRole ¶
func (_m *IMetaTable) ListUserRole(tenant string) ([]string, error)
ListUserRole provides a mock function with given fields: tenant
func (*IMetaTable) OperatePrivilege ¶
func (_m *IMetaTable) OperatePrivilege(tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType) error
OperatePrivilege provides a mock function with given fields: tenant, entity, operateType
func (*IMetaTable) OperateUserRole ¶
func (_m *IMetaTable) OperateUserRole(tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType) error
OperateUserRole provides a mock function with given fields: tenant, userEntity, roleEntity, operateType
func (*IMetaTable) RemoveCollection ¶
RemoveCollection provides a mock function with given fields: ctx, collectionID, ts
func (*IMetaTable) RemovePartition ¶
func (_m *IMetaTable) RemovePartition(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64) error
RemovePartition provides a mock function with given fields: ctx, dbID, collectionID, partitionID, ts
func (*IMetaTable) RenameCollection ¶
func (_m *IMetaTable) RenameCollection(ctx context.Context, dbName string, oldName string, newDBName string, newName string, ts uint64) error
RenameCollection provides a mock function with given fields: ctx, dbName, oldName, newDBName, newName, ts
func (*IMetaTable) SelectGrant ¶
func (_m *IMetaTable) SelectGrant(tenant string, entity *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)
SelectGrant provides a mock function with given fields: tenant, entity
func (*IMetaTable) SelectRole ¶
func (_m *IMetaTable) SelectRole(tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool) ([]*milvuspb.RoleResult, error)
SelectRole provides a mock function with given fields: tenant, entity, includeUserInfo
func (*IMetaTable) SelectUser ¶
func (_m *IMetaTable) SelectUser(tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool) ([]*milvuspb.UserResult, error)
SelectUser provides a mock function with given fields: tenant, entity, includeRoleInfo
type IMetaTable_AddCollection_Call ¶
IMetaTable_AddCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddCollection'
func (*IMetaTable_AddCollection_Call) Return ¶
func (_c *IMetaTable_AddCollection_Call) Return(_a0 error) *IMetaTable_AddCollection_Call
func (*IMetaTable_AddCollection_Call) Run ¶
func (_c *IMetaTable_AddCollection_Call) Run(run func(ctx context.Context, coll *model.Collection)) *IMetaTable_AddCollection_Call
func (*IMetaTable_AddCollection_Call) RunAndReturn ¶
func (_c *IMetaTable_AddCollection_Call) RunAndReturn(run func(context.Context, *model.Collection) error) *IMetaTable_AddCollection_Call
type IMetaTable_AddCredential_Call ¶
IMetaTable_AddCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddCredential'
func (*IMetaTable_AddCredential_Call) Return ¶
func (_c *IMetaTable_AddCredential_Call) Return(_a0 error) *IMetaTable_AddCredential_Call
func (*IMetaTable_AddCredential_Call) Run ¶
func (_c *IMetaTable_AddCredential_Call) Run(run func(credInfo *internalpb.CredentialInfo)) *IMetaTable_AddCredential_Call
func (*IMetaTable_AddCredential_Call) RunAndReturn ¶
func (_c *IMetaTable_AddCredential_Call) RunAndReturn(run func(*internalpb.CredentialInfo) error) *IMetaTable_AddCredential_Call
type IMetaTable_AddPartition_Call ¶
IMetaTable_AddPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPartition'
func (*IMetaTable_AddPartition_Call) Return ¶
func (_c *IMetaTable_AddPartition_Call) Return(_a0 error) *IMetaTable_AddPartition_Call
func (*IMetaTable_AddPartition_Call) Run ¶
func (_c *IMetaTable_AddPartition_Call) Run(run func(ctx context.Context, partition *model.Partition)) *IMetaTable_AddPartition_Call
func (*IMetaTable_AddPartition_Call) RunAndReturn ¶
func (_c *IMetaTable_AddPartition_Call) RunAndReturn(run func(context.Context, *model.Partition) error) *IMetaTable_AddPartition_Call
type IMetaTable_AlterAlias_Call ¶
IMetaTable_AlterAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterAlias'
func (*IMetaTable_AlterAlias_Call) Return ¶
func (_c *IMetaTable_AlterAlias_Call) Return(_a0 error) *IMetaTable_AlterAlias_Call
func (*IMetaTable_AlterAlias_Call) Run ¶
func (_c *IMetaTable_AlterAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, collectionName string, ts uint64)) *IMetaTable_AlterAlias_Call
func (*IMetaTable_AlterAlias_Call) RunAndReturn ¶
func (_c *IMetaTable_AlterAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_AlterAlias_Call
type IMetaTable_AlterCollection_Call ¶
IMetaTable_AlterCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterCollection'
func (*IMetaTable_AlterCollection_Call) Return ¶
func (_c *IMetaTable_AlterCollection_Call) Return(_a0 error) *IMetaTable_AlterCollection_Call
func (*IMetaTable_AlterCollection_Call) Run ¶
func (_c *IMetaTable_AlterCollection_Call) Run(run func(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ts uint64)) *IMetaTable_AlterCollection_Call
func (*IMetaTable_AlterCollection_Call) RunAndReturn ¶
func (_c *IMetaTable_AlterCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, *model.Collection, uint64) error) *IMetaTable_AlterCollection_Call
type IMetaTable_AlterCredential_Call ¶
IMetaTable_AlterCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterCredential'
func (*IMetaTable_AlterCredential_Call) Return ¶
func (_c *IMetaTable_AlterCredential_Call) Return(_a0 error) *IMetaTable_AlterCredential_Call
func (*IMetaTable_AlterCredential_Call) Run ¶
func (_c *IMetaTable_AlterCredential_Call) Run(run func(credInfo *internalpb.CredentialInfo)) *IMetaTable_AlterCredential_Call
func (*IMetaTable_AlterCredential_Call) RunAndReturn ¶
func (_c *IMetaTable_AlterCredential_Call) RunAndReturn(run func(*internalpb.CredentialInfo) error) *IMetaTable_AlterCredential_Call
type IMetaTable_AlterDatabase_Call ¶
IMetaTable_AlterDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterDatabase'
func (*IMetaTable_AlterDatabase_Call) Return ¶
func (_c *IMetaTable_AlterDatabase_Call) Return(_a0 error) *IMetaTable_AlterDatabase_Call
func (*IMetaTable_AlterDatabase_Call) Run ¶
func (_c *IMetaTable_AlterDatabase_Call) Run(run func(ctx context.Context, oldDB *model.Database, newDB *model.Database, ts uint64)) *IMetaTable_AlterDatabase_Call
func (*IMetaTable_AlterDatabase_Call) RunAndReturn ¶
func (_c *IMetaTable_AlterDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, *model.Database, uint64) error) *IMetaTable_AlterDatabase_Call
type IMetaTable_ChangeCollectionState_Call ¶
IMetaTable_ChangeCollectionState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeCollectionState'
func (*IMetaTable_ChangeCollectionState_Call) Return ¶
func (_c *IMetaTable_ChangeCollectionState_Call) Return(_a0 error) *IMetaTable_ChangeCollectionState_Call
func (*IMetaTable_ChangeCollectionState_Call) Run ¶
func (_c *IMetaTable_ChangeCollectionState_Call) Run(run func(ctx context.Context, collectionID int64, state etcdpb.CollectionState, ts uint64)) *IMetaTable_ChangeCollectionState_Call
func (*IMetaTable_ChangeCollectionState_Call) RunAndReturn ¶
func (_c *IMetaTable_ChangeCollectionState_Call) RunAndReturn(run func(context.Context, int64, etcdpb.CollectionState, uint64) error) *IMetaTable_ChangeCollectionState_Call
type IMetaTable_ChangePartitionState_Call ¶
IMetaTable_ChangePartitionState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangePartitionState'
func (*IMetaTable_ChangePartitionState_Call) Return ¶
func (_c *IMetaTable_ChangePartitionState_Call) Return(_a0 error) *IMetaTable_ChangePartitionState_Call
func (*IMetaTable_ChangePartitionState_Call) Run ¶
func (_c *IMetaTable_ChangePartitionState_Call) Run(run func(ctx context.Context, collectionID int64, partitionID int64, state etcdpb.PartitionState, ts uint64)) *IMetaTable_ChangePartitionState_Call
func (*IMetaTable_ChangePartitionState_Call) RunAndReturn ¶
func (_c *IMetaTable_ChangePartitionState_Call) RunAndReturn(run func(context.Context, int64, int64, etcdpb.PartitionState, uint64) error) *IMetaTable_ChangePartitionState_Call
type IMetaTable_CreateAlias_Call ¶
IMetaTable_CreateAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateAlias'
func (*IMetaTable_CreateAlias_Call) Return ¶
func (_c *IMetaTable_CreateAlias_Call) Return(_a0 error) *IMetaTable_CreateAlias_Call
func (*IMetaTable_CreateAlias_Call) Run ¶
func (_c *IMetaTable_CreateAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, collectionName string, ts uint64)) *IMetaTable_CreateAlias_Call
func (*IMetaTable_CreateAlias_Call) RunAndReturn ¶
func (_c *IMetaTable_CreateAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_CreateAlias_Call
type IMetaTable_CreateDatabase_Call ¶
IMetaTable_CreateDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateDatabase'
func (*IMetaTable_CreateDatabase_Call) Return ¶
func (_c *IMetaTable_CreateDatabase_Call) Return(_a0 error) *IMetaTable_CreateDatabase_Call
func (*IMetaTable_CreateDatabase_Call) Run ¶
func (_c *IMetaTable_CreateDatabase_Call) Run(run func(ctx context.Context, db *model.Database, ts uint64)) *IMetaTable_CreateDatabase_Call
func (*IMetaTable_CreateDatabase_Call) RunAndReturn ¶
func (_c *IMetaTable_CreateDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *IMetaTable_CreateDatabase_Call
type IMetaTable_CreateRole_Call ¶
IMetaTable_CreateRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRole'
func (*IMetaTable_CreateRole_Call) Return ¶
func (_c *IMetaTable_CreateRole_Call) Return(_a0 error) *IMetaTable_CreateRole_Call
func (*IMetaTable_CreateRole_Call) Run ¶
func (_c *IMetaTable_CreateRole_Call) Run(run func(tenant string, entity *milvuspb.RoleEntity)) *IMetaTable_CreateRole_Call
func (*IMetaTable_CreateRole_Call) RunAndReturn ¶
func (_c *IMetaTable_CreateRole_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity) error) *IMetaTable_CreateRole_Call
type IMetaTable_DeleteCredential_Call ¶
IMetaTable_DeleteCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteCredential'
func (*IMetaTable_DeleteCredential_Call) Return ¶
func (_c *IMetaTable_DeleteCredential_Call) Return(_a0 error) *IMetaTable_DeleteCredential_Call
func (*IMetaTable_DeleteCredential_Call) Run ¶
func (_c *IMetaTable_DeleteCredential_Call) Run(run func(username string)) *IMetaTable_DeleteCredential_Call
func (*IMetaTable_DeleteCredential_Call) RunAndReturn ¶
func (_c *IMetaTable_DeleteCredential_Call) RunAndReturn(run func(string) error) *IMetaTable_DeleteCredential_Call
type IMetaTable_DescribeAlias_Call ¶
IMetaTable_DescribeAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeAlias'
func (*IMetaTable_DescribeAlias_Call) Return ¶
func (_c *IMetaTable_DescribeAlias_Call) Return(_a0 string, _a1 error) *IMetaTable_DescribeAlias_Call
func (*IMetaTable_DescribeAlias_Call) Run ¶
func (_c *IMetaTable_DescribeAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DescribeAlias_Call
func (*IMetaTable_DescribeAlias_Call) RunAndReturn ¶
func (_c *IMetaTable_DescribeAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) (string, error)) *IMetaTable_DescribeAlias_Call
type IMetaTable_DropAlias_Call ¶
IMetaTable_DropAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropAlias'
func (*IMetaTable_DropAlias_Call) Return ¶
func (_c *IMetaTable_DropAlias_Call) Return(_a0 error) *IMetaTable_DropAlias_Call
func (*IMetaTable_DropAlias_Call) Run ¶
func (_c *IMetaTable_DropAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DropAlias_Call
func (*IMetaTable_DropAlias_Call) RunAndReturn ¶
func (_c *IMetaTable_DropAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) error) *IMetaTable_DropAlias_Call
type IMetaTable_DropDatabase_Call ¶
IMetaTable_DropDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropDatabase'
func (*IMetaTable_DropDatabase_Call) Return ¶
func (_c *IMetaTable_DropDatabase_Call) Return(_a0 error) *IMetaTable_DropDatabase_Call
func (*IMetaTable_DropDatabase_Call) Run ¶
func (_c *IMetaTable_DropDatabase_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_DropDatabase_Call
func (*IMetaTable_DropDatabase_Call) RunAndReturn ¶
func (_c *IMetaTable_DropDatabase_Call) RunAndReturn(run func(context.Context, string, uint64) error) *IMetaTable_DropDatabase_Call
type IMetaTable_DropGrant_Call ¶
IMetaTable_DropGrant_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropGrant'
func (*IMetaTable_DropGrant_Call) Return ¶
func (_c *IMetaTable_DropGrant_Call) Return(_a0 error) *IMetaTable_DropGrant_Call
func (*IMetaTable_DropGrant_Call) Run ¶
func (_c *IMetaTable_DropGrant_Call) Run(run func(tenant string, role *milvuspb.RoleEntity)) *IMetaTable_DropGrant_Call
func (*IMetaTable_DropGrant_Call) RunAndReturn ¶
func (_c *IMetaTable_DropGrant_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity) error) *IMetaTable_DropGrant_Call
type IMetaTable_DropRole_Call ¶
IMetaTable_DropRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropRole'
func (*IMetaTable_DropRole_Call) Return ¶
func (_c *IMetaTable_DropRole_Call) Return(_a0 error) *IMetaTable_DropRole_Call
func (*IMetaTable_DropRole_Call) Run ¶
func (_c *IMetaTable_DropRole_Call) Run(run func(tenant string, roleName string)) *IMetaTable_DropRole_Call
func (*IMetaTable_DropRole_Call) RunAndReturn ¶
func (_c *IMetaTable_DropRole_Call) RunAndReturn(run func(string, string) error) *IMetaTable_DropRole_Call
type IMetaTable_Expecter ¶
type IMetaTable_Expecter struct {
// contains filtered or unexported fields
}
func (*IMetaTable_Expecter) AddCollection ¶
func (_e *IMetaTable_Expecter) AddCollection(ctx interface{}, coll interface{}) *IMetaTable_AddCollection_Call
AddCollection is a helper method to define mock.On call
- ctx context.Context
- coll *model.Collection
func (*IMetaTable_Expecter) AddCredential ¶
func (_e *IMetaTable_Expecter) AddCredential(credInfo interface{}) *IMetaTable_AddCredential_Call
AddCredential is a helper method to define mock.On call
- credInfo *internalpb.CredentialInfo
func (*IMetaTable_Expecter) AddPartition ¶
func (_e *IMetaTable_Expecter) AddPartition(ctx interface{}, partition interface{}) *IMetaTable_AddPartition_Call
AddPartition is a helper method to define mock.On call
- ctx context.Context
- partition *model.Partition
func (*IMetaTable_Expecter) AlterAlias ¶
func (_e *IMetaTable_Expecter) AlterAlias(ctx interface{}, dbName interface{}, alias interface{}, collectionName interface{}, ts interface{}) *IMetaTable_AlterAlias_Call
AlterAlias is a helper method to define mock.On call
- ctx context.Context
- dbName string
- alias string
- collectionName string
- ts uint64
func (*IMetaTable_Expecter) AlterCollection ¶
func (_e *IMetaTable_Expecter) AlterCollection(ctx interface{}, oldColl interface{}, newColl interface{}, ts interface{}) *IMetaTable_AlterCollection_Call
AlterCollection is a helper method to define mock.On call
- ctx context.Context
- oldColl *model.Collection
- newColl *model.Collection
- ts uint64
func (*IMetaTable_Expecter) AlterCredential ¶
func (_e *IMetaTable_Expecter) AlterCredential(credInfo interface{}) *IMetaTable_AlterCredential_Call
AlterCredential is a helper method to define mock.On call
- credInfo *internalpb.CredentialInfo
func (*IMetaTable_Expecter) AlterDatabase ¶
func (_e *IMetaTable_Expecter) AlterDatabase(ctx interface{}, oldDB interface{}, newDB interface{}, ts interface{}) *IMetaTable_AlterDatabase_Call
AlterDatabase is a helper method to define mock.On call
- ctx context.Context
- oldDB *model.Database
- newDB *model.Database
- ts uint64
func (*IMetaTable_Expecter) ChangeCollectionState ¶
func (_e *IMetaTable_Expecter) ChangeCollectionState(ctx interface{}, collectionID interface{}, state interface{}, ts interface{}) *IMetaTable_ChangeCollectionState_Call
ChangeCollectionState is a helper method to define mock.On call
- ctx context.Context
- collectionID int64
- state etcdpb.CollectionState
- ts uint64
func (*IMetaTable_Expecter) ChangePartitionState ¶
func (_e *IMetaTable_Expecter) ChangePartitionState(ctx interface{}, collectionID interface{}, partitionID interface{}, state interface{}, ts interface{}) *IMetaTable_ChangePartitionState_Call
ChangePartitionState is a helper method to define mock.On call
- ctx context.Context
- collectionID int64
- partitionID int64
- state etcdpb.PartitionState
- ts uint64
func (*IMetaTable_Expecter) CreateAlias ¶
func (_e *IMetaTable_Expecter) CreateAlias(ctx interface{}, dbName interface{}, alias interface{}, collectionName interface{}, ts interface{}) *IMetaTable_CreateAlias_Call
CreateAlias is a helper method to define mock.On call
- ctx context.Context
- dbName string
- alias string
- collectionName string
- ts uint64
func (*IMetaTable_Expecter) CreateDatabase ¶
func (_e *IMetaTable_Expecter) CreateDatabase(ctx interface{}, db interface{}, ts interface{}) *IMetaTable_CreateDatabase_Call
CreateDatabase is a helper method to define mock.On call
- ctx context.Context
- db *model.Database
- ts uint64
func (*IMetaTable_Expecter) CreateRole ¶
func (_e *IMetaTable_Expecter) CreateRole(tenant interface{}, entity interface{}) *IMetaTable_CreateRole_Call
CreateRole is a helper method to define mock.On call
- tenant string
- entity *milvuspb.RoleEntity
func (*IMetaTable_Expecter) DeleteCredential ¶
func (_e *IMetaTable_Expecter) DeleteCredential(username interface{}) *IMetaTable_DeleteCredential_Call
DeleteCredential is a helper method to define mock.On call
- username string
func (*IMetaTable_Expecter) DescribeAlias ¶
func (_e *IMetaTable_Expecter) DescribeAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DescribeAlias_Call
DescribeAlias is a helper method to define mock.On call
- ctx context.Context
- dbName string
- alias string
- ts uint64
func (*IMetaTable_Expecter) DropAlias ¶
func (_e *IMetaTable_Expecter) DropAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DropAlias_Call
DropAlias is a helper method to define mock.On call
- ctx context.Context
- dbName string
- alias string
- ts uint64
func (*IMetaTable_Expecter) DropDatabase ¶
func (_e *IMetaTable_Expecter) DropDatabase(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_DropDatabase_Call
DropDatabase is a helper method to define mock.On call
- ctx context.Context
- dbName string
- ts uint64
func (*IMetaTable_Expecter) DropGrant ¶
func (_e *IMetaTable_Expecter) DropGrant(tenant interface{}, role interface{}) *IMetaTable_DropGrant_Call
DropGrant is a helper method to define mock.On call
- tenant string
- role *milvuspb.RoleEntity
func (*IMetaTable_Expecter) DropRole ¶
func (_e *IMetaTable_Expecter) DropRole(tenant interface{}, roleName interface{}) *IMetaTable_DropRole_Call
DropRole is a helper method to define mock.On call
- tenant string
- roleName string
func (*IMetaTable_Expecter) GetCollectionByID ¶
func (_e *IMetaTable_Expecter) GetCollectionByID(ctx interface{}, dbName interface{}, collectionID interface{}, ts interface{}, allowUnavailable interface{}) *IMetaTable_GetCollectionByID_Call
GetCollectionByID is a helper method to define mock.On call
- ctx context.Context
- dbName string
- collectionID int64
- ts uint64
- allowUnavailable bool
func (*IMetaTable_Expecter) GetCollectionByIDWithMaxTs ¶
func (_e *IMetaTable_Expecter) GetCollectionByIDWithMaxTs(ctx interface{}, collectionID interface{}) *IMetaTable_GetCollectionByIDWithMaxTs_Call
GetCollectionByIDWithMaxTs is a helper method to define mock.On call
- ctx context.Context
- collectionID int64
func (*IMetaTable_Expecter) GetCollectionByName ¶
func (_e *IMetaTable_Expecter) GetCollectionByName(ctx interface{}, dbName interface{}, collectionName interface{}, ts interface{}) *IMetaTable_GetCollectionByName_Call
GetCollectionByName is a helper method to define mock.On call
- ctx context.Context
- dbName string
- collectionName string
- ts uint64
func (*IMetaTable_Expecter) GetCollectionVirtualChannels ¶
func (_e *IMetaTable_Expecter) GetCollectionVirtualChannels(colID interface{}) *IMetaTable_GetCollectionVirtualChannels_Call
GetCollectionVirtualChannels is a helper method to define mock.On call
- colID int64
func (*IMetaTable_Expecter) GetCredential ¶
func (_e *IMetaTable_Expecter) GetCredential(username interface{}) *IMetaTable_GetCredential_Call
GetCredential is a helper method to define mock.On call
- username string
func (*IMetaTable_Expecter) GetDatabaseByID ¶
func (_e *IMetaTable_Expecter) GetDatabaseByID(ctx interface{}, dbID interface{}, ts interface{}) *IMetaTable_GetDatabaseByID_Call
GetDatabaseByID is a helper method to define mock.On call
- ctx context.Context
- dbID int64
- ts uint64
func (*IMetaTable_Expecter) GetDatabaseByName ¶
func (_e *IMetaTable_Expecter) GetDatabaseByName(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_GetDatabaseByName_Call
GetDatabaseByName is a helper method to define mock.On call
- ctx context.Context
- dbName string
- ts uint64
func (*IMetaTable_Expecter) GetPChannelInfo ¶
func (_e *IMetaTable_Expecter) GetPChannelInfo(pchannel interface{}) *IMetaTable_GetPChannelInfo_Call
GetPChannelInfo is a helper method to define mock.On call
- pchannel string
func (*IMetaTable_Expecter) IsAlias ¶
func (_e *IMetaTable_Expecter) IsAlias(db interface{}, name interface{}) *IMetaTable_IsAlias_Call
IsAlias is a helper method to define mock.On call
- db string
- name string
func (*IMetaTable_Expecter) ListAliases ¶
func (_e *IMetaTable_Expecter) ListAliases(ctx interface{}, dbName interface{}, collectionName interface{}, ts interface{}) *IMetaTable_ListAliases_Call
ListAliases is a helper method to define mock.On call
- ctx context.Context
- dbName string
- collectionName string
- ts uint64
func (*IMetaTable_Expecter) ListAliasesByID ¶
func (_e *IMetaTable_Expecter) ListAliasesByID(collID interface{}) *IMetaTable_ListAliasesByID_Call
ListAliasesByID is a helper method to define mock.On call
- collID int64
func (*IMetaTable_Expecter) ListAllAvailCollections ¶
func (_e *IMetaTable_Expecter) ListAllAvailCollections(ctx interface{}) *IMetaTable_ListAllAvailCollections_Call
ListAllAvailCollections is a helper method to define mock.On call
- ctx context.Context
func (*IMetaTable_Expecter) ListCollectionPhysicalChannels ¶
func (_e *IMetaTable_Expecter) ListCollectionPhysicalChannels() *IMetaTable_ListCollectionPhysicalChannels_Call
ListCollectionPhysicalChannels is a helper method to define mock.On call
func (*IMetaTable_Expecter) ListCollections ¶
func (_e *IMetaTable_Expecter) ListCollections(ctx interface{}, dbName interface{}, ts interface{}, onlyAvail interface{}) *IMetaTable_ListCollections_Call
ListCollections is a helper method to define mock.On call
- ctx context.Context
- dbName string
- ts uint64
- onlyAvail bool
func (*IMetaTable_Expecter) ListCredentialUsernames ¶
func (_e *IMetaTable_Expecter) ListCredentialUsernames() *IMetaTable_ListCredentialUsernames_Call
ListCredentialUsernames is a helper method to define mock.On call
func (*IMetaTable_Expecter) ListDatabases ¶
func (_e *IMetaTable_Expecter) ListDatabases(ctx interface{}, ts interface{}) *IMetaTable_ListDatabases_Call
ListDatabases is a helper method to define mock.On call
- ctx context.Context
- ts uint64
func (*IMetaTable_Expecter) ListPolicy ¶
func (_e *IMetaTable_Expecter) ListPolicy(tenant interface{}) *IMetaTable_ListPolicy_Call
ListPolicy is a helper method to define mock.On call
- tenant string
func (*IMetaTable_Expecter) ListUserRole ¶
func (_e *IMetaTable_Expecter) ListUserRole(tenant interface{}) *IMetaTable_ListUserRole_Call
ListUserRole is a helper method to define mock.On call
- tenant string
func (*IMetaTable_Expecter) OperatePrivilege ¶
func (_e *IMetaTable_Expecter) OperatePrivilege(tenant interface{}, entity interface{}, operateType interface{}) *IMetaTable_OperatePrivilege_Call
OperatePrivilege is a helper method to define mock.On call
- tenant string
- entity *milvuspb.GrantEntity
- operateType milvuspb.OperatePrivilegeType
func (*IMetaTable_Expecter) OperateUserRole ¶
func (_e *IMetaTable_Expecter) OperateUserRole(tenant interface{}, userEntity interface{}, roleEntity interface{}, operateType interface{}) *IMetaTable_OperateUserRole_Call
OperateUserRole is a helper method to define mock.On call
- tenant string
- userEntity *milvuspb.UserEntity
- roleEntity *milvuspb.RoleEntity
- operateType milvuspb.OperateUserRoleType
func (*IMetaTable_Expecter) RemoveCollection ¶
func (_e *IMetaTable_Expecter) RemoveCollection(ctx interface{}, collectionID interface{}, ts interface{}) *IMetaTable_RemoveCollection_Call
RemoveCollection is a helper method to define mock.On call
- ctx context.Context
- collectionID int64
- ts uint64
func (*IMetaTable_Expecter) RemovePartition ¶
func (_e *IMetaTable_Expecter) RemovePartition(ctx interface{}, dbID interface{}, collectionID interface{}, partitionID interface{}, ts interface{}) *IMetaTable_RemovePartition_Call
RemovePartition is a helper method to define mock.On call
- ctx context.Context
- dbID int64
- collectionID int64
- partitionID int64
- ts uint64
func (*IMetaTable_Expecter) RenameCollection ¶
func (_e *IMetaTable_Expecter) RenameCollection(ctx interface{}, dbName interface{}, oldName interface{}, newDBName interface{}, newName interface{}, ts interface{}) *IMetaTable_RenameCollection_Call
RenameCollection is a helper method to define mock.On call
- ctx context.Context
- dbName string
- oldName string
- newDBName string
- newName string
- ts uint64
func (*IMetaTable_Expecter) SelectGrant ¶
func (_e *IMetaTable_Expecter) SelectGrant(tenant interface{}, entity interface{}) *IMetaTable_SelectGrant_Call
SelectGrant is a helper method to define mock.On call
- tenant string
- entity *milvuspb.GrantEntity
func (*IMetaTable_Expecter) SelectRole ¶
func (_e *IMetaTable_Expecter) SelectRole(tenant interface{}, entity interface{}, includeUserInfo interface{}) *IMetaTable_SelectRole_Call
SelectRole is a helper method to define mock.On call
- tenant string
- entity *milvuspb.RoleEntity
- includeUserInfo bool
func (*IMetaTable_Expecter) SelectUser ¶
func (_e *IMetaTable_Expecter) SelectUser(tenant interface{}, entity interface{}, includeRoleInfo interface{}) *IMetaTable_SelectUser_Call
SelectUser is a helper method to define mock.On call
- tenant string
- entity *milvuspb.UserEntity
- includeRoleInfo bool
type IMetaTable_GetCollectionByIDWithMaxTs_Call ¶
IMetaTable_GetCollectionByIDWithMaxTs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByIDWithMaxTs'
func (*IMetaTable_GetCollectionByIDWithMaxTs_Call) Return ¶
func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByIDWithMaxTs_Call
func (*IMetaTable_GetCollectionByIDWithMaxTs_Call) Run ¶
func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Run(run func(ctx context.Context, collectionID int64)) *IMetaTable_GetCollectionByIDWithMaxTs_Call
func (*IMetaTable_GetCollectionByIDWithMaxTs_Call) RunAndReturn ¶
func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) RunAndReturn(run func(context.Context, int64) (*model.Collection, error)) *IMetaTable_GetCollectionByIDWithMaxTs_Call
type IMetaTable_GetCollectionByID_Call ¶
IMetaTable_GetCollectionByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByID'
func (*IMetaTable_GetCollectionByID_Call) Return ¶
func (_c *IMetaTable_GetCollectionByID_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByID_Call
func (*IMetaTable_GetCollectionByID_Call) Run ¶
func (_c *IMetaTable_GetCollectionByID_Call) Run(run func(ctx context.Context, dbName string, collectionID int64, ts uint64, allowUnavailable bool)) *IMetaTable_GetCollectionByID_Call
func (*IMetaTable_GetCollectionByID_Call) RunAndReturn ¶
func (_c *IMetaTable_GetCollectionByID_Call) RunAndReturn(run func(context.Context, string, int64, uint64, bool) (*model.Collection, error)) *IMetaTable_GetCollectionByID_Call
type IMetaTable_GetCollectionByName_Call ¶
IMetaTable_GetCollectionByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByName'
func (*IMetaTable_GetCollectionByName_Call) Return ¶
func (_c *IMetaTable_GetCollectionByName_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByName_Call
func (*IMetaTable_GetCollectionByName_Call) Run ¶
func (_c *IMetaTable_GetCollectionByName_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_GetCollectionByName_Call
func (*IMetaTable_GetCollectionByName_Call) RunAndReturn ¶
func (_c *IMetaTable_GetCollectionByName_Call) RunAndReturn(run func(context.Context, string, string, uint64) (*model.Collection, error)) *IMetaTable_GetCollectionByName_Call
type IMetaTable_GetCollectionVirtualChannels_Call ¶
IMetaTable_GetCollectionVirtualChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionVirtualChannels'
func (*IMetaTable_GetCollectionVirtualChannels_Call) Return ¶
func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Return(_a0 []string) *IMetaTable_GetCollectionVirtualChannels_Call
func (*IMetaTable_GetCollectionVirtualChannels_Call) Run ¶
func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Run(run func(colID int64)) *IMetaTable_GetCollectionVirtualChannels_Call
func (*IMetaTable_GetCollectionVirtualChannels_Call) RunAndReturn ¶
func (_c *IMetaTable_GetCollectionVirtualChannels_Call) RunAndReturn(run func(int64) []string) *IMetaTable_GetCollectionVirtualChannels_Call
type IMetaTable_GetCredential_Call ¶
IMetaTable_GetCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCredential'
func (*IMetaTable_GetCredential_Call) Return ¶
func (_c *IMetaTable_GetCredential_Call) Return(_a0 *internalpb.CredentialInfo, _a1 error) *IMetaTable_GetCredential_Call
func (*IMetaTable_GetCredential_Call) Run ¶
func (_c *IMetaTable_GetCredential_Call) Run(run func(username string)) *IMetaTable_GetCredential_Call
func (*IMetaTable_GetCredential_Call) RunAndReturn ¶
func (_c *IMetaTable_GetCredential_Call) RunAndReturn(run func(string) (*internalpb.CredentialInfo, error)) *IMetaTable_GetCredential_Call
type IMetaTable_GetDatabaseByID_Call ¶
IMetaTable_GetDatabaseByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseByID'
func (*IMetaTable_GetDatabaseByID_Call) Return ¶
func (_c *IMetaTable_GetDatabaseByID_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByID_Call
func (*IMetaTable_GetDatabaseByID_Call) Run ¶
func (_c *IMetaTable_GetDatabaseByID_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *IMetaTable_GetDatabaseByID_Call
func (*IMetaTable_GetDatabaseByID_Call) RunAndReturn ¶
func (_c *IMetaTable_GetDatabaseByID_Call) RunAndReturn(run func(context.Context, int64, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByID_Call
type IMetaTable_GetDatabaseByName_Call ¶
IMetaTable_GetDatabaseByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseByName'
func (*IMetaTable_GetDatabaseByName_Call) Return ¶
func (_c *IMetaTable_GetDatabaseByName_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByName_Call
func (*IMetaTable_GetDatabaseByName_Call) Run ¶
func (_c *IMetaTable_GetDatabaseByName_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_GetDatabaseByName_Call
func (*IMetaTable_GetDatabaseByName_Call) RunAndReturn ¶
func (_c *IMetaTable_GetDatabaseByName_Call) RunAndReturn(run func(context.Context, string, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByName_Call
type IMetaTable_GetPChannelInfo_Call ¶
IMetaTable_GetPChannelInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPChannelInfo'
func (*IMetaTable_GetPChannelInfo_Call) Return ¶
func (_c *IMetaTable_GetPChannelInfo_Call) Return(_a0 *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call
func (*IMetaTable_GetPChannelInfo_Call) Run ¶
func (_c *IMetaTable_GetPChannelInfo_Call) Run(run func(pchannel string)) *IMetaTable_GetPChannelInfo_Call
func (*IMetaTable_GetPChannelInfo_Call) RunAndReturn ¶
func (_c *IMetaTable_GetPChannelInfo_Call) RunAndReturn(run func(string) *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call
type IMetaTable_IsAlias_Call ¶
IMetaTable_IsAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsAlias'
func (*IMetaTable_IsAlias_Call) Return ¶
func (_c *IMetaTable_IsAlias_Call) Return(_a0 bool) *IMetaTable_IsAlias_Call
func (*IMetaTable_IsAlias_Call) Run ¶
func (_c *IMetaTable_IsAlias_Call) Run(run func(db string, name string)) *IMetaTable_IsAlias_Call
func (*IMetaTable_IsAlias_Call) RunAndReturn ¶
func (_c *IMetaTable_IsAlias_Call) RunAndReturn(run func(string, string) bool) *IMetaTable_IsAlias_Call
type IMetaTable_ListAliasesByID_Call ¶
IMetaTable_ListAliasesByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAliasesByID'
func (*IMetaTable_ListAliasesByID_Call) Return ¶
func (_c *IMetaTable_ListAliasesByID_Call) Return(_a0 []string) *IMetaTable_ListAliasesByID_Call
func (*IMetaTable_ListAliasesByID_Call) Run ¶
func (_c *IMetaTable_ListAliasesByID_Call) Run(run func(collID int64)) *IMetaTable_ListAliasesByID_Call
func (*IMetaTable_ListAliasesByID_Call) RunAndReturn ¶
func (_c *IMetaTable_ListAliasesByID_Call) RunAndReturn(run func(int64) []string) *IMetaTable_ListAliasesByID_Call
type IMetaTable_ListAliases_Call ¶
IMetaTable_ListAliases_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAliases'
func (*IMetaTable_ListAliases_Call) Return ¶
func (_c *IMetaTable_ListAliases_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListAliases_Call
func (*IMetaTable_ListAliases_Call) Run ¶
func (_c *IMetaTable_ListAliases_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_ListAliases_Call
func (*IMetaTable_ListAliases_Call) RunAndReturn ¶
func (_c *IMetaTable_ListAliases_Call) RunAndReturn(run func(context.Context, string, string, uint64) ([]string, error)) *IMetaTable_ListAliases_Call
type IMetaTable_ListAllAvailCollections_Call ¶
IMetaTable_ListAllAvailCollections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllAvailCollections'
func (*IMetaTable_ListAllAvailCollections_Call) Return ¶
func (_c *IMetaTable_ListAllAvailCollections_Call) Return(_a0 map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call
func (*IMetaTable_ListAllAvailCollections_Call) Run ¶
func (_c *IMetaTable_ListAllAvailCollections_Call) Run(run func(ctx context.Context)) *IMetaTable_ListAllAvailCollections_Call
func (*IMetaTable_ListAllAvailCollections_Call) RunAndReturn ¶
func (_c *IMetaTable_ListAllAvailCollections_Call) RunAndReturn(run func(context.Context) map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call
type IMetaTable_ListCollectionPhysicalChannels_Call ¶
IMetaTable_ListCollectionPhysicalChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollectionPhysicalChannels'
func (*IMetaTable_ListCollectionPhysicalChannels_Call) Return ¶
func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Return(_a0 map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call
func (*IMetaTable_ListCollectionPhysicalChannels_Call) Run ¶
func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Run(run func()) *IMetaTable_ListCollectionPhysicalChannels_Call
func (*IMetaTable_ListCollectionPhysicalChannels_Call) RunAndReturn ¶
func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) RunAndReturn(run func() map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call
type IMetaTable_ListCollections_Call ¶
IMetaTable_ListCollections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollections'
func (*IMetaTable_ListCollections_Call) Return ¶
func (_c *IMetaTable_ListCollections_Call) Return(_a0 []*model.Collection, _a1 error) *IMetaTable_ListCollections_Call
func (*IMetaTable_ListCollections_Call) Run ¶
func (_c *IMetaTable_ListCollections_Call) Run(run func(ctx context.Context, dbName string, ts uint64, onlyAvail bool)) *IMetaTable_ListCollections_Call
func (*IMetaTable_ListCollections_Call) RunAndReturn ¶
func (_c *IMetaTable_ListCollections_Call) RunAndReturn(run func(context.Context, string, uint64, bool) ([]*model.Collection, error)) *IMetaTable_ListCollections_Call
type IMetaTable_ListCredentialUsernames_Call ¶
IMetaTable_ListCredentialUsernames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCredentialUsernames'
func (*IMetaTable_ListCredentialUsernames_Call) Return ¶
func (_c *IMetaTable_ListCredentialUsernames_Call) Return(_a0 *milvuspb.ListCredUsersResponse, _a1 error) *IMetaTable_ListCredentialUsernames_Call
func (*IMetaTable_ListCredentialUsernames_Call) Run ¶
func (_c *IMetaTable_ListCredentialUsernames_Call) Run(run func()) *IMetaTable_ListCredentialUsernames_Call
func (*IMetaTable_ListCredentialUsernames_Call) RunAndReturn ¶
func (_c *IMetaTable_ListCredentialUsernames_Call) RunAndReturn(run func() (*milvuspb.ListCredUsersResponse, error)) *IMetaTable_ListCredentialUsernames_Call
type IMetaTable_ListDatabases_Call ¶
IMetaTable_ListDatabases_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListDatabases'
func (*IMetaTable_ListDatabases_Call) Return ¶
func (_c *IMetaTable_ListDatabases_Call) Return(_a0 []*model.Database, _a1 error) *IMetaTable_ListDatabases_Call
func (*IMetaTable_ListDatabases_Call) Run ¶
func (_c *IMetaTable_ListDatabases_Call) Run(run func(ctx context.Context, ts uint64)) *IMetaTable_ListDatabases_Call
func (*IMetaTable_ListDatabases_Call) RunAndReturn ¶
func (_c *IMetaTable_ListDatabases_Call) RunAndReturn(run func(context.Context, uint64) ([]*model.Database, error)) *IMetaTable_ListDatabases_Call
type IMetaTable_ListPolicy_Call ¶
IMetaTable_ListPolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPolicy'
func (*IMetaTable_ListPolicy_Call) Return ¶
func (_c *IMetaTable_ListPolicy_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListPolicy_Call
func (*IMetaTable_ListPolicy_Call) Run ¶
func (_c *IMetaTable_ListPolicy_Call) Run(run func(tenant string)) *IMetaTable_ListPolicy_Call
func (*IMetaTable_ListPolicy_Call) RunAndReturn ¶
func (_c *IMetaTable_ListPolicy_Call) RunAndReturn(run func(string) ([]string, error)) *IMetaTable_ListPolicy_Call
type IMetaTable_ListUserRole_Call ¶
IMetaTable_ListUserRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListUserRole'
func (*IMetaTable_ListUserRole_Call) Return ¶
func (_c *IMetaTable_ListUserRole_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListUserRole_Call
func (*IMetaTable_ListUserRole_Call) Run ¶
func (_c *IMetaTable_ListUserRole_Call) Run(run func(tenant string)) *IMetaTable_ListUserRole_Call
func (*IMetaTable_ListUserRole_Call) RunAndReturn ¶
func (_c *IMetaTable_ListUserRole_Call) RunAndReturn(run func(string) ([]string, error)) *IMetaTable_ListUserRole_Call
type IMetaTable_OperatePrivilege_Call ¶
IMetaTable_OperatePrivilege_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperatePrivilege'
func (*IMetaTable_OperatePrivilege_Call) Return ¶
func (_c *IMetaTable_OperatePrivilege_Call) Return(_a0 error) *IMetaTable_OperatePrivilege_Call
func (*IMetaTable_OperatePrivilege_Call) Run ¶
func (_c *IMetaTable_OperatePrivilege_Call) Run(run func(tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType)) *IMetaTable_OperatePrivilege_Call
func (*IMetaTable_OperatePrivilege_Call) RunAndReturn ¶
func (_c *IMetaTable_OperatePrivilege_Call) RunAndReturn(run func(string, *milvuspb.GrantEntity, milvuspb.OperatePrivilegeType) error) *IMetaTable_OperatePrivilege_Call
type IMetaTable_OperateUserRole_Call ¶
IMetaTable_OperateUserRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperateUserRole'
func (*IMetaTable_OperateUserRole_Call) Return ¶
func (_c *IMetaTable_OperateUserRole_Call) Return(_a0 error) *IMetaTable_OperateUserRole_Call
func (*IMetaTable_OperateUserRole_Call) Run ¶
func (_c *IMetaTable_OperateUserRole_Call) Run(run func(tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType)) *IMetaTable_OperateUserRole_Call
func (*IMetaTable_OperateUserRole_Call) RunAndReturn ¶
func (_c *IMetaTable_OperateUserRole_Call) RunAndReturn(run func(string, *milvuspb.UserEntity, *milvuspb.RoleEntity, milvuspb.OperateUserRoleType) error) *IMetaTable_OperateUserRole_Call
type IMetaTable_RemoveCollection_Call ¶
IMetaTable_RemoveCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveCollection'
func (*IMetaTable_RemoveCollection_Call) Return ¶
func (_c *IMetaTable_RemoveCollection_Call) Return(_a0 error) *IMetaTable_RemoveCollection_Call
func (*IMetaTable_RemoveCollection_Call) Run ¶
func (_c *IMetaTable_RemoveCollection_Call) Run(run func(ctx context.Context, collectionID int64, ts uint64)) *IMetaTable_RemoveCollection_Call
func (*IMetaTable_RemoveCollection_Call) RunAndReturn ¶
func (_c *IMetaTable_RemoveCollection_Call) RunAndReturn(run func(context.Context, int64, uint64) error) *IMetaTable_RemoveCollection_Call
type IMetaTable_RemovePartition_Call ¶
IMetaTable_RemovePartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePartition'
func (*IMetaTable_RemovePartition_Call) Return ¶
func (_c *IMetaTable_RemovePartition_Call) Return(_a0 error) *IMetaTable_RemovePartition_Call
func (*IMetaTable_RemovePartition_Call) Run ¶
func (_c *IMetaTable_RemovePartition_Call) Run(run func(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64)) *IMetaTable_RemovePartition_Call
func (*IMetaTable_RemovePartition_Call) RunAndReturn ¶
func (_c *IMetaTable_RemovePartition_Call) RunAndReturn(run func(context.Context, int64, int64, int64, uint64) error) *IMetaTable_RemovePartition_Call
type IMetaTable_RenameCollection_Call ¶
IMetaTable_RenameCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RenameCollection'
func (*IMetaTable_RenameCollection_Call) Return ¶
func (_c *IMetaTable_RenameCollection_Call) Return(_a0 error) *IMetaTable_RenameCollection_Call
func (*IMetaTable_RenameCollection_Call) Run ¶
func (_c *IMetaTable_RenameCollection_Call) Run(run func(ctx context.Context, dbName string, oldName string, newDBName string, newName string, ts uint64)) *IMetaTable_RenameCollection_Call
func (*IMetaTable_RenameCollection_Call) RunAndReturn ¶
func (_c *IMetaTable_RenameCollection_Call) RunAndReturn(run func(context.Context, string, string, string, string, uint64) error) *IMetaTable_RenameCollection_Call
type IMetaTable_SelectGrant_Call ¶
IMetaTable_SelectGrant_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectGrant'
func (*IMetaTable_SelectGrant_Call) Return ¶
func (_c *IMetaTable_SelectGrant_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *IMetaTable_SelectGrant_Call
func (*IMetaTable_SelectGrant_Call) Run ¶
func (_c *IMetaTable_SelectGrant_Call) Run(run func(tenant string, entity *milvuspb.GrantEntity)) *IMetaTable_SelectGrant_Call
func (*IMetaTable_SelectGrant_Call) RunAndReturn ¶
func (_c *IMetaTable_SelectGrant_Call) RunAndReturn(run func(string, *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)) *IMetaTable_SelectGrant_Call
type IMetaTable_SelectRole_Call ¶
IMetaTable_SelectRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectRole'
func (*IMetaTable_SelectRole_Call) Return ¶
func (_c *IMetaTable_SelectRole_Call) Return(_a0 []*milvuspb.RoleResult, _a1 error) *IMetaTable_SelectRole_Call
func (*IMetaTable_SelectRole_Call) Run ¶
func (_c *IMetaTable_SelectRole_Call) Run(run func(tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool)) *IMetaTable_SelectRole_Call
func (*IMetaTable_SelectRole_Call) RunAndReturn ¶
func (_c *IMetaTable_SelectRole_Call) RunAndReturn(run func(string, *milvuspb.RoleEntity, bool) ([]*milvuspb.RoleResult, error)) *IMetaTable_SelectRole_Call
type IMetaTable_SelectUser_Call ¶
IMetaTable_SelectUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectUser'
func (*IMetaTable_SelectUser_Call) Return ¶
func (_c *IMetaTable_SelectUser_Call) Return(_a0 []*milvuspb.UserResult, _a1 error) *IMetaTable_SelectUser_Call
func (*IMetaTable_SelectUser_Call) Run ¶
func (_c *IMetaTable_SelectUser_Call) Run(run func(tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool)) *IMetaTable_SelectUser_Call
func (*IMetaTable_SelectUser_Call) RunAndReturn ¶
func (_c *IMetaTable_SelectUser_Call) RunAndReturn(run func(string, *milvuspb.UserEntity, bool) ([]*milvuspb.UserResult, error)) *IMetaTable_SelectUser_Call