// Code generated by mockery v2.53.3. DO NOT EDIT. package mockrootcoord import ( context "context" etcdpb "github.com/milvus-io/milvus/pkg/v2/proto/etcdpb" internalpb "github.com/milvus-io/milvus/pkg/v2/proto/internalpb" milvuspb "github.com/milvus-io/milvus-proto/go-api/v2/milvuspb" mock "github.com/stretchr/testify/mock" model "github.com/milvus-io/milvus/internal/metastore/model" rootcoordpb "github.com/milvus-io/milvus/pkg/v2/proto/rootcoordpb" ) // IMetaTable is an autogenerated mock type for the IMetaTable type type IMetaTable struct { mock.Mock } type IMetaTable_Expecter struct { mock *mock.Mock } func (_m *IMetaTable) EXPECT() *IMetaTable_Expecter { return &IMetaTable_Expecter{mock: &_m.Mock} } // AddCollection provides a mock function with given fields: ctx, coll func (_m *IMetaTable) AddCollection(ctx context.Context, coll *model.Collection) error { ret := _m.Called(ctx, coll) if len(ret) == 0 { panic("no return value specified for AddCollection") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *model.Collection) error); ok { r0 = rf(ctx, coll) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AddCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddCollection' type IMetaTable_AddCollection_Call struct { *mock.Call } // AddCollection is a helper method to define mock.On call // - ctx context.Context // - coll *model.Collection func (_e *IMetaTable_Expecter) AddCollection(ctx interface{}, coll interface{}) *IMetaTable_AddCollection_Call { return &IMetaTable_AddCollection_Call{Call: _e.mock.On("AddCollection", ctx, coll)} } func (_c *IMetaTable_AddCollection_Call) Run(run func(ctx context.Context, coll *model.Collection)) *IMetaTable_AddCollection_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*model.Collection)) }) return _c } func (_c *IMetaTable_AddCollection_Call) Return(_a0 error) *IMetaTable_AddCollection_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AddCollection_Call) RunAndReturn(run func(context.Context, *model.Collection) error) *IMetaTable_AddCollection_Call { _c.Call.Return(run) return _c } // AddCredential provides a mock function with given fields: ctx, credInfo func (_m *IMetaTable) AddCredential(ctx context.Context, credInfo *internalpb.CredentialInfo) error { ret := _m.Called(ctx, credInfo) if len(ret) == 0 { panic("no return value specified for AddCredential") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *internalpb.CredentialInfo) error); ok { r0 = rf(ctx, credInfo) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AddCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddCredential' type IMetaTable_AddCredential_Call struct { *mock.Call } // AddCredential is a helper method to define mock.On call // - ctx context.Context // - credInfo *internalpb.CredentialInfo func (_e *IMetaTable_Expecter) AddCredential(ctx interface{}, credInfo interface{}) *IMetaTable_AddCredential_Call { return &IMetaTable_AddCredential_Call{Call: _e.mock.On("AddCredential", ctx, credInfo)} } func (_c *IMetaTable_AddCredential_Call) Run(run func(ctx context.Context, credInfo *internalpb.CredentialInfo)) *IMetaTable_AddCredential_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*internalpb.CredentialInfo)) }) return _c } func (_c *IMetaTable_AddCredential_Call) Return(_a0 error) *IMetaTable_AddCredential_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AddCredential_Call) RunAndReturn(run func(context.Context, *internalpb.CredentialInfo) error) *IMetaTable_AddCredential_Call { _c.Call.Return(run) return _c } // AddPartition provides a mock function with given fields: ctx, partition func (_m *IMetaTable) AddPartition(ctx context.Context, partition *model.Partition) error { ret := _m.Called(ctx, partition) if len(ret) == 0 { panic("no return value specified for AddPartition") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *model.Partition) error); ok { r0 = rf(ctx, partition) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AddPartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPartition' type IMetaTable_AddPartition_Call struct { *mock.Call } // AddPartition is a helper method to define mock.On call // - ctx context.Context // - partition *model.Partition func (_e *IMetaTable_Expecter) AddPartition(ctx interface{}, partition interface{}) *IMetaTable_AddPartition_Call { return &IMetaTable_AddPartition_Call{Call: _e.mock.On("AddPartition", ctx, partition)} } func (_c *IMetaTable_AddPartition_Call) Run(run func(ctx context.Context, partition *model.Partition)) *IMetaTable_AddPartition_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*model.Partition)) }) return _c } func (_c *IMetaTable_AddPartition_Call) Return(_a0 error) *IMetaTable_AddPartition_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AddPartition_Call) RunAndReturn(run func(context.Context, *model.Partition) error) *IMetaTable_AddPartition_Call { _c.Call.Return(run) return _c } // AlterAlias provides a mock function with given fields: ctx, dbName, alias, collectionName, ts func (_m *IMetaTable) AlterAlias(ctx context.Context, dbName string, alias string, collectionName string, ts uint64) error { ret := _m.Called(ctx, dbName, alias, collectionName, ts) if len(ret) == 0 { panic("no return value specified for AlterAlias") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, string, string, uint64) error); ok { r0 = rf(ctx, dbName, alias, collectionName, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AlterAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterAlias' type IMetaTable_AlterAlias_Call struct { *mock.Call } // AlterAlias is a helper method to define mock.On call // - ctx context.Context // - dbName string // - alias string // - collectionName string // - ts uint64 func (_e *IMetaTable_Expecter) AlterAlias(ctx interface{}, dbName interface{}, alias interface{}, collectionName interface{}, ts interface{}) *IMetaTable_AlterAlias_Call { return &IMetaTable_AlterAlias_Call{Call: _e.mock.On("AlterAlias", ctx, dbName, alias, collectionName, ts)} } func (_c *IMetaTable_AlterAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, collectionName string, ts uint64)) *IMetaTable_AlterAlias_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(string), args[4].(uint64)) }) return _c } func (_c *IMetaTable_AlterAlias_Call) Return(_a0 error) *IMetaTable_AlterAlias_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AlterAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_AlterAlias_Call { _c.Call.Return(run) return _c } // AlterCollection provides a mock function with given fields: ctx, oldColl, newColl, ts, fieldModify func (_m *IMetaTable) AlterCollection(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ts uint64, fieldModify bool) error { ret := _m.Called(ctx, oldColl, newColl, ts, fieldModify) if len(ret) == 0 { panic("no return value specified for AlterCollection") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *model.Collection, *model.Collection, uint64, bool) error); ok { r0 = rf(ctx, oldColl, newColl, ts, fieldModify) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AlterCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterCollection' type IMetaTable_AlterCollection_Call struct { *mock.Call } // AlterCollection is a helper method to define mock.On call // - ctx context.Context // - oldColl *model.Collection // - newColl *model.Collection // - ts uint64 // - fieldModify bool func (_e *IMetaTable_Expecter) AlterCollection(ctx interface{}, oldColl interface{}, newColl interface{}, ts interface{}, fieldModify interface{}) *IMetaTable_AlterCollection_Call { return &IMetaTable_AlterCollection_Call{Call: _e.mock.On("AlterCollection", ctx, oldColl, newColl, ts, fieldModify)} } func (_c *IMetaTable_AlterCollection_Call) Run(run func(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ts uint64, fieldModify bool)) *IMetaTable_AlterCollection_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*model.Collection), args[2].(*model.Collection), args[3].(uint64), args[4].(bool)) }) return _c } func (_c *IMetaTable_AlterCollection_Call) Return(_a0 error) *IMetaTable_AlterCollection_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AlterCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, *model.Collection, uint64, bool) error) *IMetaTable_AlterCollection_Call { _c.Call.Return(run) return _c } // AlterCredential provides a mock function with given fields: ctx, credInfo func (_m *IMetaTable) AlterCredential(ctx context.Context, credInfo *internalpb.CredentialInfo) error { ret := _m.Called(ctx, credInfo) if len(ret) == 0 { panic("no return value specified for AlterCredential") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *internalpb.CredentialInfo) error); ok { r0 = rf(ctx, credInfo) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AlterCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterCredential' type IMetaTable_AlterCredential_Call struct { *mock.Call } // AlterCredential is a helper method to define mock.On call // - ctx context.Context // - credInfo *internalpb.CredentialInfo func (_e *IMetaTable_Expecter) AlterCredential(ctx interface{}, credInfo interface{}) *IMetaTable_AlterCredential_Call { return &IMetaTable_AlterCredential_Call{Call: _e.mock.On("AlterCredential", ctx, credInfo)} } func (_c *IMetaTable_AlterCredential_Call) Run(run func(ctx context.Context, credInfo *internalpb.CredentialInfo)) *IMetaTable_AlterCredential_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*internalpb.CredentialInfo)) }) return _c } func (_c *IMetaTable_AlterCredential_Call) Return(_a0 error) *IMetaTable_AlterCredential_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AlterCredential_Call) RunAndReturn(run func(context.Context, *internalpb.CredentialInfo) error) *IMetaTable_AlterCredential_Call { _c.Call.Return(run) return _c } // AlterDatabase provides a mock function with given fields: ctx, oldDB, newDB, ts func (_m *IMetaTable) AlterDatabase(ctx context.Context, oldDB *model.Database, newDB *model.Database, ts uint64) error { ret := _m.Called(ctx, oldDB, newDB, ts) if len(ret) == 0 { panic("no return value specified for AlterDatabase") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *model.Database, *model.Database, uint64) error); ok { r0 = rf(ctx, oldDB, newDB, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_AlterDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AlterDatabase' type IMetaTable_AlterDatabase_Call struct { *mock.Call } // AlterDatabase is a helper method to define mock.On call // - ctx context.Context // - oldDB *model.Database // - newDB *model.Database // - ts uint64 func (_e *IMetaTable_Expecter) AlterDatabase(ctx interface{}, oldDB interface{}, newDB interface{}, ts interface{}) *IMetaTable_AlterDatabase_Call { return &IMetaTable_AlterDatabase_Call{Call: _e.mock.On("AlterDatabase", ctx, oldDB, newDB, ts)} } func (_c *IMetaTable_AlterDatabase_Call) Run(run func(ctx context.Context, oldDB *model.Database, newDB *model.Database, ts uint64)) *IMetaTable_AlterDatabase_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*model.Database), args[2].(*model.Database), args[3].(uint64)) }) return _c } func (_c *IMetaTable_AlterDatabase_Call) Return(_a0 error) *IMetaTable_AlterDatabase_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_AlterDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, *model.Database, uint64) error) *IMetaTable_AlterDatabase_Call { _c.Call.Return(run) return _c } // BackupRBAC provides a mock function with given fields: ctx, tenant func (_m *IMetaTable) BackupRBAC(ctx context.Context, tenant string) (*milvuspb.RBACMeta, error) { ret := _m.Called(ctx, tenant) if len(ret) == 0 { panic("no return value specified for BackupRBAC") } var r0 *milvuspb.RBACMeta var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) (*milvuspb.RBACMeta, error)); ok { return rf(ctx, tenant) } if rf, ok := ret.Get(0).(func(context.Context, string) *milvuspb.RBACMeta); ok { r0 = rf(ctx, tenant) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*milvuspb.RBACMeta) } } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, tenant) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_BackupRBAC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BackupRBAC' type IMetaTable_BackupRBAC_Call struct { *mock.Call } // BackupRBAC is a helper method to define mock.On call // - ctx context.Context // - tenant string func (_e *IMetaTable_Expecter) BackupRBAC(ctx interface{}, tenant interface{}) *IMetaTable_BackupRBAC_Call { return &IMetaTable_BackupRBAC_Call{Call: _e.mock.On("BackupRBAC", ctx, tenant)} } func (_c *IMetaTable_BackupRBAC_Call) Run(run func(ctx context.Context, tenant string)) *IMetaTable_BackupRBAC_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_BackupRBAC_Call) Return(_a0 *milvuspb.RBACMeta, _a1 error) *IMetaTable_BackupRBAC_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_BackupRBAC_Call) RunAndReturn(run func(context.Context, string) (*milvuspb.RBACMeta, error)) *IMetaTable_BackupRBAC_Call { _c.Call.Return(run) return _c } // ChangeCollectionState provides a mock function with given fields: ctx, collectionID, state, ts func (_m *IMetaTable) ChangeCollectionState(ctx context.Context, collectionID int64, state etcdpb.CollectionState, ts uint64) error { ret := _m.Called(ctx, collectionID, state, ts) if len(ret) == 0 { panic("no return value specified for ChangeCollectionState") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, int64, etcdpb.CollectionState, uint64) error); ok { r0 = rf(ctx, collectionID, state, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_ChangeCollectionState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeCollectionState' type IMetaTable_ChangeCollectionState_Call struct { *mock.Call } // ChangeCollectionState is a helper method to define mock.On call // - ctx context.Context // - collectionID int64 // - state etcdpb.CollectionState // - ts uint64 func (_e *IMetaTable_Expecter) ChangeCollectionState(ctx interface{}, collectionID interface{}, state interface{}, ts interface{}) *IMetaTable_ChangeCollectionState_Call { return &IMetaTable_ChangeCollectionState_Call{Call: _e.mock.On("ChangeCollectionState", ctx, collectionID, state, ts)} } func (_c *IMetaTable_ChangeCollectionState_Call) Run(run func(ctx context.Context, collectionID int64, state etcdpb.CollectionState, ts uint64)) *IMetaTable_ChangeCollectionState_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64), args[2].(etcdpb.CollectionState), args[3].(uint64)) }) return _c } func (_c *IMetaTable_ChangeCollectionState_Call) Return(_a0 error) *IMetaTable_ChangeCollectionState_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ChangeCollectionState_Call) RunAndReturn(run func(context.Context, int64, etcdpb.CollectionState, uint64) error) *IMetaTable_ChangeCollectionState_Call { _c.Call.Return(run) return _c } // ChangePartitionState provides a mock function with given fields: ctx, collectionID, partitionID, state, ts func (_m *IMetaTable) ChangePartitionState(ctx context.Context, collectionID int64, partitionID int64, state etcdpb.PartitionState, ts uint64) error { ret := _m.Called(ctx, collectionID, partitionID, state, ts) if len(ret) == 0 { panic("no return value specified for ChangePartitionState") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, int64, int64, etcdpb.PartitionState, uint64) error); ok { r0 = rf(ctx, collectionID, partitionID, state, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_ChangePartitionState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangePartitionState' type IMetaTable_ChangePartitionState_Call struct { *mock.Call } // ChangePartitionState is a helper method to define mock.On call // - ctx context.Context // - collectionID int64 // - partitionID int64 // - state etcdpb.PartitionState // - ts uint64 func (_e *IMetaTable_Expecter) ChangePartitionState(ctx interface{}, collectionID interface{}, partitionID interface{}, state interface{}, ts interface{}) *IMetaTable_ChangePartitionState_Call { return &IMetaTable_ChangePartitionState_Call{Call: _e.mock.On("ChangePartitionState", ctx, collectionID, partitionID, state, ts)} } func (_c *IMetaTable_ChangePartitionState_Call) Run(run func(ctx context.Context, collectionID int64, partitionID int64, state etcdpb.PartitionState, ts uint64)) *IMetaTable_ChangePartitionState_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64), args[2].(int64), args[3].(etcdpb.PartitionState), args[4].(uint64)) }) return _c } func (_c *IMetaTable_ChangePartitionState_Call) Return(_a0 error) *IMetaTable_ChangePartitionState_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ChangePartitionState_Call) RunAndReturn(run func(context.Context, int64, int64, etcdpb.PartitionState, uint64) error) *IMetaTable_ChangePartitionState_Call { _c.Call.Return(run) return _c } // CreateAlias provides a mock function with given fields: ctx, dbName, alias, collectionName, ts func (_m *IMetaTable) CreateAlias(ctx context.Context, dbName string, alias string, collectionName string, ts uint64) error { ret := _m.Called(ctx, dbName, alias, collectionName, ts) if len(ret) == 0 { panic("no return value specified for CreateAlias") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, string, string, uint64) error); ok { r0 = rf(ctx, dbName, alias, collectionName, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_CreateAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateAlias' type IMetaTable_CreateAlias_Call struct { *mock.Call } // CreateAlias is a helper method to define mock.On call // - ctx context.Context // - dbName string // - alias string // - collectionName string // - ts uint64 func (_e *IMetaTable_Expecter) CreateAlias(ctx interface{}, dbName interface{}, alias interface{}, collectionName interface{}, ts interface{}) *IMetaTable_CreateAlias_Call { return &IMetaTable_CreateAlias_Call{Call: _e.mock.On("CreateAlias", ctx, dbName, alias, collectionName, ts)} } func (_c *IMetaTable_CreateAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, collectionName string, ts uint64)) *IMetaTable_CreateAlias_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(string), args[4].(uint64)) }) return _c } func (_c *IMetaTable_CreateAlias_Call) Return(_a0 error) *IMetaTable_CreateAlias_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_CreateAlias_Call) RunAndReturn(run func(context.Context, string, string, string, uint64) error) *IMetaTable_CreateAlias_Call { _c.Call.Return(run) return _c } // CreateDatabase provides a mock function with given fields: ctx, db, ts func (_m *IMetaTable) CreateDatabase(ctx context.Context, db *model.Database, ts uint64) error { ret := _m.Called(ctx, db, ts) if len(ret) == 0 { panic("no return value specified for CreateDatabase") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, *model.Database, uint64) error); ok { r0 = rf(ctx, db, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_CreateDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateDatabase' type IMetaTable_CreateDatabase_Call struct { *mock.Call } // CreateDatabase is a helper method to define mock.On call // - ctx context.Context // - db *model.Database // - ts uint64 func (_e *IMetaTable_Expecter) CreateDatabase(ctx interface{}, db interface{}, ts interface{}) *IMetaTable_CreateDatabase_Call { return &IMetaTable_CreateDatabase_Call{Call: _e.mock.On("CreateDatabase", ctx, db, ts)} } func (_c *IMetaTable_CreateDatabase_Call) Run(run func(ctx context.Context, db *model.Database, ts uint64)) *IMetaTable_CreateDatabase_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(*model.Database), args[2].(uint64)) }) return _c } func (_c *IMetaTable_CreateDatabase_Call) Return(_a0 error) *IMetaTable_CreateDatabase_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_CreateDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *IMetaTable_CreateDatabase_Call { _c.Call.Return(run) return _c } // CreatePrivilegeGroup provides a mock function with given fields: ctx, groupName func (_m *IMetaTable) CreatePrivilegeGroup(ctx context.Context, groupName string) error { ret := _m.Called(ctx, groupName) if len(ret) == 0 { panic("no return value specified for CreatePrivilegeGroup") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string) error); ok { r0 = rf(ctx, groupName) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_CreatePrivilegeGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreatePrivilegeGroup' type IMetaTable_CreatePrivilegeGroup_Call struct { *mock.Call } // CreatePrivilegeGroup is a helper method to define mock.On call // - ctx context.Context // - groupName string func (_e *IMetaTable_Expecter) CreatePrivilegeGroup(ctx interface{}, groupName interface{}) *IMetaTable_CreatePrivilegeGroup_Call { return &IMetaTable_CreatePrivilegeGroup_Call{Call: _e.mock.On("CreatePrivilegeGroup", ctx, groupName)} } func (_c *IMetaTable_CreatePrivilegeGroup_Call) Run(run func(ctx context.Context, groupName string)) *IMetaTable_CreatePrivilegeGroup_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_CreatePrivilegeGroup_Call) Return(_a0 error) *IMetaTable_CreatePrivilegeGroup_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_CreatePrivilegeGroup_Call) RunAndReturn(run func(context.Context, string) error) *IMetaTable_CreatePrivilegeGroup_Call { _c.Call.Return(run) return _c } // CreateRole provides a mock function with given fields: ctx, tenant, entity func (_m *IMetaTable) CreateRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity) error { ret := _m.Called(ctx, tenant, entity) if len(ret) == 0 { panic("no return value specified for CreateRole") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.RoleEntity) error); ok { r0 = rf(ctx, tenant, entity) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_CreateRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRole' type IMetaTable_CreateRole_Call struct { *mock.Call } // CreateRole is a helper method to define mock.On call // - ctx context.Context // - tenant string // - entity *milvuspb.RoleEntity func (_e *IMetaTable_Expecter) CreateRole(ctx interface{}, tenant interface{}, entity interface{}) *IMetaTable_CreateRole_Call { return &IMetaTable_CreateRole_Call{Call: _e.mock.On("CreateRole", ctx, tenant, entity)} } func (_c *IMetaTable_CreateRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity)) *IMetaTable_CreateRole_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.RoleEntity)) }) return _c } func (_c *IMetaTable_CreateRole_Call) Return(_a0 error) *IMetaTable_CreateRole_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_CreateRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *IMetaTable_CreateRole_Call { _c.Call.Return(run) return _c } // DeleteCredential provides a mock function with given fields: ctx, username func (_m *IMetaTable) DeleteCredential(ctx context.Context, username string) error { ret := _m.Called(ctx, username) if len(ret) == 0 { panic("no return value specified for DeleteCredential") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string) error); ok { r0 = rf(ctx, username) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DeleteCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteCredential' type IMetaTable_DeleteCredential_Call struct { *mock.Call } // DeleteCredential is a helper method to define mock.On call // - ctx context.Context // - username string func (_e *IMetaTable_Expecter) DeleteCredential(ctx interface{}, username interface{}) *IMetaTable_DeleteCredential_Call { return &IMetaTable_DeleteCredential_Call{Call: _e.mock.On("DeleteCredential", ctx, username)} } func (_c *IMetaTable_DeleteCredential_Call) Run(run func(ctx context.Context, username string)) *IMetaTable_DeleteCredential_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_DeleteCredential_Call) Return(_a0 error) *IMetaTable_DeleteCredential_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DeleteCredential_Call) RunAndReturn(run func(context.Context, string) error) *IMetaTable_DeleteCredential_Call { _c.Call.Return(run) return _c } // DescribeAlias provides a mock function with given fields: ctx, dbName, alias, ts func (_m *IMetaTable) DescribeAlias(ctx context.Context, dbName string, alias string, ts uint64) (string, error) { ret := _m.Called(ctx, dbName, alias, ts) if len(ret) == 0 { panic("no return value specified for DescribeAlias") } var r0 string var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) (string, error)); ok { return rf(ctx, dbName, alias, ts) } if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) string); ok { r0 = rf(ctx, dbName, alias, ts) } else { r0 = ret.Get(0).(string) } if rf, ok := ret.Get(1).(func(context.Context, string, string, uint64) error); ok { r1 = rf(ctx, dbName, alias, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_DescribeAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeAlias' type IMetaTable_DescribeAlias_Call struct { *mock.Call } // DescribeAlias is a helper method to define mock.On call // - ctx context.Context // - dbName string // - alias string // - ts uint64 func (_e *IMetaTable_Expecter) DescribeAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DescribeAlias_Call { return &IMetaTable_DescribeAlias_Call{Call: _e.mock.On("DescribeAlias", ctx, dbName, alias, ts)} } func (_c *IMetaTable_DescribeAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DescribeAlias_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(uint64)) }) return _c } func (_c *IMetaTable_DescribeAlias_Call) Return(_a0 string, _a1 error) *IMetaTable_DescribeAlias_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_DescribeAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) (string, error)) *IMetaTable_DescribeAlias_Call { _c.Call.Return(run) return _c } // DropAlias provides a mock function with given fields: ctx, dbName, alias, ts func (_m *IMetaTable) DropAlias(ctx context.Context, dbName string, alias string, ts uint64) error { ret := _m.Called(ctx, dbName, alias, ts) if len(ret) == 0 { panic("no return value specified for DropAlias") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) error); ok { r0 = rf(ctx, dbName, alias, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DropAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropAlias' type IMetaTable_DropAlias_Call struct { *mock.Call } // DropAlias is a helper method to define mock.On call // - ctx context.Context // - dbName string // - alias string // - ts uint64 func (_e *IMetaTable_Expecter) DropAlias(ctx interface{}, dbName interface{}, alias interface{}, ts interface{}) *IMetaTable_DropAlias_Call { return &IMetaTable_DropAlias_Call{Call: _e.mock.On("DropAlias", ctx, dbName, alias, ts)} } func (_c *IMetaTable_DropAlias_Call) Run(run func(ctx context.Context, dbName string, alias string, ts uint64)) *IMetaTable_DropAlias_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(uint64)) }) return _c } func (_c *IMetaTable_DropAlias_Call) Return(_a0 error) *IMetaTable_DropAlias_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DropAlias_Call) RunAndReturn(run func(context.Context, string, string, uint64) error) *IMetaTable_DropAlias_Call { _c.Call.Return(run) return _c } // DropDatabase provides a mock function with given fields: ctx, dbName, ts func (_m *IMetaTable) DropDatabase(ctx context.Context, dbName string, ts uint64) error { ret := _m.Called(ctx, dbName, ts) if len(ret) == 0 { panic("no return value specified for DropDatabase") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, uint64) error); ok { r0 = rf(ctx, dbName, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DropDatabase_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropDatabase' type IMetaTable_DropDatabase_Call struct { *mock.Call } // DropDatabase is a helper method to define mock.On call // - ctx context.Context // - dbName string // - ts uint64 func (_e *IMetaTable_Expecter) DropDatabase(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_DropDatabase_Call { return &IMetaTable_DropDatabase_Call{Call: _e.mock.On("DropDatabase", ctx, dbName, ts)} } func (_c *IMetaTable_DropDatabase_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_DropDatabase_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(uint64)) }) return _c } func (_c *IMetaTable_DropDatabase_Call) Return(_a0 error) *IMetaTable_DropDatabase_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DropDatabase_Call) RunAndReturn(run func(context.Context, string, uint64) error) *IMetaTable_DropDatabase_Call { _c.Call.Return(run) return _c } // DropGrant provides a mock function with given fields: ctx, tenant, role func (_m *IMetaTable) DropGrant(ctx context.Context, tenant string, role *milvuspb.RoleEntity) error { ret := _m.Called(ctx, tenant, role) if len(ret) == 0 { panic("no return value specified for DropGrant") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.RoleEntity) error); ok { r0 = rf(ctx, tenant, role) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DropGrant_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropGrant' type IMetaTable_DropGrant_Call struct { *mock.Call } // DropGrant is a helper method to define mock.On call // - ctx context.Context // - tenant string // - role *milvuspb.RoleEntity func (_e *IMetaTable_Expecter) DropGrant(ctx interface{}, tenant interface{}, role interface{}) *IMetaTable_DropGrant_Call { return &IMetaTable_DropGrant_Call{Call: _e.mock.On("DropGrant", ctx, tenant, role)} } func (_c *IMetaTable_DropGrant_Call) Run(run func(ctx context.Context, tenant string, role *milvuspb.RoleEntity)) *IMetaTable_DropGrant_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.RoleEntity)) }) return _c } func (_c *IMetaTable_DropGrant_Call) Return(_a0 error) *IMetaTable_DropGrant_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DropGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *IMetaTable_DropGrant_Call { _c.Call.Return(run) return _c } // DropPrivilegeGroup provides a mock function with given fields: ctx, groupName func (_m *IMetaTable) DropPrivilegeGroup(ctx context.Context, groupName string) error { ret := _m.Called(ctx, groupName) if len(ret) == 0 { panic("no return value specified for DropPrivilegeGroup") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string) error); ok { r0 = rf(ctx, groupName) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DropPrivilegeGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropPrivilegeGroup' type IMetaTable_DropPrivilegeGroup_Call struct { *mock.Call } // DropPrivilegeGroup is a helper method to define mock.On call // - ctx context.Context // - groupName string func (_e *IMetaTable_Expecter) DropPrivilegeGroup(ctx interface{}, groupName interface{}) *IMetaTable_DropPrivilegeGroup_Call { return &IMetaTable_DropPrivilegeGroup_Call{Call: _e.mock.On("DropPrivilegeGroup", ctx, groupName)} } func (_c *IMetaTable_DropPrivilegeGroup_Call) Run(run func(ctx context.Context, groupName string)) *IMetaTable_DropPrivilegeGroup_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_DropPrivilegeGroup_Call) Return(_a0 error) *IMetaTable_DropPrivilegeGroup_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DropPrivilegeGroup_Call) RunAndReturn(run func(context.Context, string) error) *IMetaTable_DropPrivilegeGroup_Call { _c.Call.Return(run) return _c } // DropRole provides a mock function with given fields: ctx, tenant, roleName func (_m *IMetaTable) DropRole(ctx context.Context, tenant string, roleName string) error { ret := _m.Called(ctx, tenant, roleName) if len(ret) == 0 { panic("no return value specified for DropRole") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, string) error); ok { r0 = rf(ctx, tenant, roleName) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_DropRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropRole' type IMetaTable_DropRole_Call struct { *mock.Call } // DropRole is a helper method to define mock.On call // - ctx context.Context // - tenant string // - roleName string func (_e *IMetaTable_Expecter) DropRole(ctx interface{}, tenant interface{}, roleName interface{}) *IMetaTable_DropRole_Call { return &IMetaTable_DropRole_Call{Call: _e.mock.On("DropRole", ctx, tenant, roleName)} } func (_c *IMetaTable_DropRole_Call) Run(run func(ctx context.Context, tenant string, roleName string)) *IMetaTable_DropRole_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string)) }) return _c } func (_c *IMetaTable_DropRole_Call) Return(_a0 error) *IMetaTable_DropRole_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_DropRole_Call) RunAndReturn(run func(context.Context, string, string) error) *IMetaTable_DropRole_Call { _c.Call.Return(run) return _c } // GetCollectionByID provides a mock function with given fields: ctx, dbName, collectionID, ts, allowUnavailable func (_m *IMetaTable) GetCollectionByID(ctx context.Context, dbName string, collectionID int64, ts uint64, allowUnavailable bool) (*model.Collection, error) { ret := _m.Called(ctx, dbName, collectionID, ts, allowUnavailable) if len(ret) == 0 { panic("no return value specified for GetCollectionByID") } var r0 *model.Collection var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, int64, uint64, bool) (*model.Collection, error)); ok { return rf(ctx, dbName, collectionID, ts, allowUnavailable) } if rf, ok := ret.Get(0).(func(context.Context, string, int64, uint64, bool) *model.Collection); ok { r0 = rf(ctx, dbName, collectionID, ts, allowUnavailable) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*model.Collection) } } if rf, ok := ret.Get(1).(func(context.Context, string, int64, uint64, bool) error); ok { r1 = rf(ctx, dbName, collectionID, ts, allowUnavailable) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetCollectionByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByID' type IMetaTable_GetCollectionByID_Call struct { *mock.Call } // GetCollectionByID is a helper method to define mock.On call // - ctx context.Context // - dbName string // - collectionID int64 // - ts uint64 // - allowUnavailable bool func (_e *IMetaTable_Expecter) GetCollectionByID(ctx interface{}, dbName interface{}, collectionID interface{}, ts interface{}, allowUnavailable interface{}) *IMetaTable_GetCollectionByID_Call { return &IMetaTable_GetCollectionByID_Call{Call: _e.mock.On("GetCollectionByID", ctx, dbName, collectionID, ts, allowUnavailable)} } func (_c *IMetaTable_GetCollectionByID_Call) Run(run func(ctx context.Context, dbName string, collectionID int64, ts uint64, allowUnavailable bool)) *IMetaTable_GetCollectionByID_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(int64), args[3].(uint64), args[4].(bool)) }) return _c } func (_c *IMetaTable_GetCollectionByID_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByID_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetCollectionByID_Call) RunAndReturn(run func(context.Context, string, int64, uint64, bool) (*model.Collection, error)) *IMetaTable_GetCollectionByID_Call { _c.Call.Return(run) return _c } // GetCollectionByIDWithMaxTs provides a mock function with given fields: ctx, collectionID func (_m *IMetaTable) GetCollectionByIDWithMaxTs(ctx context.Context, collectionID int64) (*model.Collection, error) { ret := _m.Called(ctx, collectionID) if len(ret) == 0 { panic("no return value specified for GetCollectionByIDWithMaxTs") } var r0 *model.Collection var r1 error if rf, ok := ret.Get(0).(func(context.Context, int64) (*model.Collection, error)); ok { return rf(ctx, collectionID) } if rf, ok := ret.Get(0).(func(context.Context, int64) *model.Collection); ok { r0 = rf(ctx, collectionID) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*model.Collection) } } if rf, ok := ret.Get(1).(func(context.Context, int64) error); ok { r1 = rf(ctx, collectionID) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetCollectionByIDWithMaxTs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByIDWithMaxTs' type IMetaTable_GetCollectionByIDWithMaxTs_Call struct { *mock.Call } // GetCollectionByIDWithMaxTs is a helper method to define mock.On call // - ctx context.Context // - collectionID int64 func (_e *IMetaTable_Expecter) GetCollectionByIDWithMaxTs(ctx interface{}, collectionID interface{}) *IMetaTable_GetCollectionByIDWithMaxTs_Call { return &IMetaTable_GetCollectionByIDWithMaxTs_Call{Call: _e.mock.On("GetCollectionByIDWithMaxTs", ctx, collectionID)} } func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Run(run func(ctx context.Context, collectionID int64)) *IMetaTable_GetCollectionByIDWithMaxTs_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64)) }) return _c } func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByIDWithMaxTs_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetCollectionByIDWithMaxTs_Call) RunAndReturn(run func(context.Context, int64) (*model.Collection, error)) *IMetaTable_GetCollectionByIDWithMaxTs_Call { _c.Call.Return(run) return _c } // GetCollectionByName provides a mock function with given fields: ctx, dbName, collectionName, ts func (_m *IMetaTable) GetCollectionByName(ctx context.Context, dbName string, collectionName string, ts uint64) (*model.Collection, error) { ret := _m.Called(ctx, dbName, collectionName, ts) if len(ret) == 0 { panic("no return value specified for GetCollectionByName") } var r0 *model.Collection var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) (*model.Collection, error)); ok { return rf(ctx, dbName, collectionName, ts) } if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) *model.Collection); ok { r0 = rf(ctx, dbName, collectionName, ts) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*model.Collection) } } if rf, ok := ret.Get(1).(func(context.Context, string, string, uint64) error); ok { r1 = rf(ctx, dbName, collectionName, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetCollectionByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionByName' type IMetaTable_GetCollectionByName_Call struct { *mock.Call } // GetCollectionByName is a helper method to define mock.On call // - ctx context.Context // - dbName string // - collectionName string // - ts uint64 func (_e *IMetaTable_Expecter) GetCollectionByName(ctx interface{}, dbName interface{}, collectionName interface{}, ts interface{}) *IMetaTable_GetCollectionByName_Call { return &IMetaTable_GetCollectionByName_Call{Call: _e.mock.On("GetCollectionByName", ctx, dbName, collectionName, ts)} } func (_c *IMetaTable_GetCollectionByName_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_GetCollectionByName_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(uint64)) }) return _c } func (_c *IMetaTable_GetCollectionByName_Call) Return(_a0 *model.Collection, _a1 error) *IMetaTable_GetCollectionByName_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetCollectionByName_Call) RunAndReturn(run func(context.Context, string, string, uint64) (*model.Collection, error)) *IMetaTable_GetCollectionByName_Call { _c.Call.Return(run) return _c } // GetCollectionID provides a mock function with given fields: ctx, dbName, collectionName func (_m *IMetaTable) GetCollectionID(ctx context.Context, dbName string, collectionName string) int64 { ret := _m.Called(ctx, dbName, collectionName) if len(ret) == 0 { panic("no return value specified for GetCollectionID") } var r0 int64 if rf, ok := ret.Get(0).(func(context.Context, string, string) int64); ok { r0 = rf(ctx, dbName, collectionName) } else { r0 = ret.Get(0).(int64) } return r0 } // IMetaTable_GetCollectionID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionID' type IMetaTable_GetCollectionID_Call struct { *mock.Call } // GetCollectionID is a helper method to define mock.On call // - ctx context.Context // - dbName string // - collectionName string func (_e *IMetaTable_Expecter) GetCollectionID(ctx interface{}, dbName interface{}, collectionName interface{}) *IMetaTable_GetCollectionID_Call { return &IMetaTable_GetCollectionID_Call{Call: _e.mock.On("GetCollectionID", ctx, dbName, collectionName)} } func (_c *IMetaTable_GetCollectionID_Call) Run(run func(ctx context.Context, dbName string, collectionName string)) *IMetaTable_GetCollectionID_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string)) }) return _c } func (_c *IMetaTable_GetCollectionID_Call) Return(_a0 int64) *IMetaTable_GetCollectionID_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_GetCollectionID_Call) RunAndReturn(run func(context.Context, string, string) int64) *IMetaTable_GetCollectionID_Call { _c.Call.Return(run) return _c } // GetCollectionVirtualChannels provides a mock function with given fields: ctx, colID func (_m *IMetaTable) GetCollectionVirtualChannels(ctx context.Context, colID int64) []string { ret := _m.Called(ctx, colID) if len(ret) == 0 { panic("no return value specified for GetCollectionVirtualChannels") } var r0 []string if rf, ok := ret.Get(0).(func(context.Context, int64) []string); ok { r0 = rf(ctx, colID) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]string) } } return r0 } // IMetaTable_GetCollectionVirtualChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCollectionVirtualChannels' type IMetaTable_GetCollectionVirtualChannels_Call struct { *mock.Call } // GetCollectionVirtualChannels is a helper method to define mock.On call // - ctx context.Context // - colID int64 func (_e *IMetaTable_Expecter) GetCollectionVirtualChannels(ctx interface{}, colID interface{}) *IMetaTable_GetCollectionVirtualChannels_Call { return &IMetaTable_GetCollectionVirtualChannels_Call{Call: _e.mock.On("GetCollectionVirtualChannels", ctx, colID)} } func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Run(run func(ctx context.Context, colID int64)) *IMetaTable_GetCollectionVirtualChannels_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64)) }) return _c } func (_c *IMetaTable_GetCollectionVirtualChannels_Call) Return(_a0 []string) *IMetaTable_GetCollectionVirtualChannels_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_GetCollectionVirtualChannels_Call) RunAndReturn(run func(context.Context, int64) []string) *IMetaTable_GetCollectionVirtualChannels_Call { _c.Call.Return(run) return _c } // GetCredential provides a mock function with given fields: ctx, username func (_m *IMetaTable) GetCredential(ctx context.Context, username string) (*internalpb.CredentialInfo, error) { ret := _m.Called(ctx, username) if len(ret) == 0 { panic("no return value specified for GetCredential") } var r0 *internalpb.CredentialInfo var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) (*internalpb.CredentialInfo, error)); ok { return rf(ctx, username) } if rf, ok := ret.Get(0).(func(context.Context, string) *internalpb.CredentialInfo); ok { r0 = rf(ctx, username) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*internalpb.CredentialInfo) } } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, username) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetCredential_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCredential' type IMetaTable_GetCredential_Call struct { *mock.Call } // GetCredential is a helper method to define mock.On call // - ctx context.Context // - username string func (_e *IMetaTable_Expecter) GetCredential(ctx interface{}, username interface{}) *IMetaTable_GetCredential_Call { return &IMetaTable_GetCredential_Call{Call: _e.mock.On("GetCredential", ctx, username)} } func (_c *IMetaTable_GetCredential_Call) Run(run func(ctx context.Context, username string)) *IMetaTable_GetCredential_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_GetCredential_Call) Return(_a0 *internalpb.CredentialInfo, _a1 error) *IMetaTable_GetCredential_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetCredential_Call) RunAndReturn(run func(context.Context, string) (*internalpb.CredentialInfo, error)) *IMetaTable_GetCredential_Call { _c.Call.Return(run) return _c } // GetDatabaseByID provides a mock function with given fields: ctx, dbID, ts func (_m *IMetaTable) GetDatabaseByID(ctx context.Context, dbID int64, ts uint64) (*model.Database, error) { ret := _m.Called(ctx, dbID, ts) if len(ret) == 0 { panic("no return value specified for GetDatabaseByID") } var r0 *model.Database var r1 error if rf, ok := ret.Get(0).(func(context.Context, int64, uint64) (*model.Database, error)); ok { return rf(ctx, dbID, ts) } if rf, ok := ret.Get(0).(func(context.Context, int64, uint64) *model.Database); ok { r0 = rf(ctx, dbID, ts) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*model.Database) } } if rf, ok := ret.Get(1).(func(context.Context, int64, uint64) error); ok { r1 = rf(ctx, dbID, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetDatabaseByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseByID' type IMetaTable_GetDatabaseByID_Call struct { *mock.Call } // GetDatabaseByID is a helper method to define mock.On call // - ctx context.Context // - dbID int64 // - ts uint64 func (_e *IMetaTable_Expecter) GetDatabaseByID(ctx interface{}, dbID interface{}, ts interface{}) *IMetaTable_GetDatabaseByID_Call { return &IMetaTable_GetDatabaseByID_Call{Call: _e.mock.On("GetDatabaseByID", ctx, dbID, ts)} } func (_c *IMetaTable_GetDatabaseByID_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *IMetaTable_GetDatabaseByID_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64), args[2].(uint64)) }) return _c } func (_c *IMetaTable_GetDatabaseByID_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByID_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetDatabaseByID_Call) RunAndReturn(run func(context.Context, int64, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByID_Call { _c.Call.Return(run) return _c } // GetDatabaseByName provides a mock function with given fields: ctx, dbName, ts func (_m *IMetaTable) GetDatabaseByName(ctx context.Context, dbName string, ts uint64) (*model.Database, error) { ret := _m.Called(ctx, dbName, ts) if len(ret) == 0 { panic("no return value specified for GetDatabaseByName") } var r0 *model.Database var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, uint64) (*model.Database, error)); ok { return rf(ctx, dbName, ts) } if rf, ok := ret.Get(0).(func(context.Context, string, uint64) *model.Database); ok { r0 = rf(ctx, dbName, ts) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*model.Database) } } if rf, ok := ret.Get(1).(func(context.Context, string, uint64) error); ok { r1 = rf(ctx, dbName, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetDatabaseByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDatabaseByName' type IMetaTable_GetDatabaseByName_Call struct { *mock.Call } // GetDatabaseByName is a helper method to define mock.On call // - ctx context.Context // - dbName string // - ts uint64 func (_e *IMetaTable_Expecter) GetDatabaseByName(ctx interface{}, dbName interface{}, ts interface{}) *IMetaTable_GetDatabaseByName_Call { return &IMetaTable_GetDatabaseByName_Call{Call: _e.mock.On("GetDatabaseByName", ctx, dbName, ts)} } func (_c *IMetaTable_GetDatabaseByName_Call) Run(run func(ctx context.Context, dbName string, ts uint64)) *IMetaTable_GetDatabaseByName_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(uint64)) }) return _c } func (_c *IMetaTable_GetDatabaseByName_Call) Return(_a0 *model.Database, _a1 error) *IMetaTable_GetDatabaseByName_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetDatabaseByName_Call) RunAndReturn(run func(context.Context, string, uint64) (*model.Database, error)) *IMetaTable_GetDatabaseByName_Call { _c.Call.Return(run) return _c } // GetGeneralCount provides a mock function with given fields: ctx func (_m *IMetaTable) GetGeneralCount(ctx context.Context) int { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for GetGeneralCount") } var r0 int if rf, ok := ret.Get(0).(func(context.Context) int); ok { r0 = rf(ctx) } else { r0 = ret.Get(0).(int) } return r0 } // IMetaTable_GetGeneralCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGeneralCount' type IMetaTable_GetGeneralCount_Call struct { *mock.Call } // GetGeneralCount is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) GetGeneralCount(ctx interface{}) *IMetaTable_GetGeneralCount_Call { return &IMetaTable_GetGeneralCount_Call{Call: _e.mock.On("GetGeneralCount", ctx)} } func (_c *IMetaTable_GetGeneralCount_Call) Run(run func(ctx context.Context)) *IMetaTable_GetGeneralCount_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_GetGeneralCount_Call) Return(_a0 int) *IMetaTable_GetGeneralCount_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_GetGeneralCount_Call) RunAndReturn(run func(context.Context) int) *IMetaTable_GetGeneralCount_Call { _c.Call.Return(run) return _c } // GetPChannelInfo provides a mock function with given fields: ctx, pchannel func (_m *IMetaTable) GetPChannelInfo(ctx context.Context, pchannel string) *rootcoordpb.GetPChannelInfoResponse { ret := _m.Called(ctx, pchannel) if len(ret) == 0 { panic("no return value specified for GetPChannelInfo") } var r0 *rootcoordpb.GetPChannelInfoResponse if rf, ok := ret.Get(0).(func(context.Context, string) *rootcoordpb.GetPChannelInfoResponse); ok { r0 = rf(ctx, pchannel) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*rootcoordpb.GetPChannelInfoResponse) } } return r0 } // IMetaTable_GetPChannelInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPChannelInfo' type IMetaTable_GetPChannelInfo_Call struct { *mock.Call } // GetPChannelInfo is a helper method to define mock.On call // - ctx context.Context // - pchannel string func (_e *IMetaTable_Expecter) GetPChannelInfo(ctx interface{}, pchannel interface{}) *IMetaTable_GetPChannelInfo_Call { return &IMetaTable_GetPChannelInfo_Call{Call: _e.mock.On("GetPChannelInfo", ctx, pchannel)} } func (_c *IMetaTable_GetPChannelInfo_Call) Run(run func(ctx context.Context, pchannel string)) *IMetaTable_GetPChannelInfo_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_GetPChannelInfo_Call) Return(_a0 *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_GetPChannelInfo_Call) RunAndReturn(run func(context.Context, string) *rootcoordpb.GetPChannelInfoResponse) *IMetaTable_GetPChannelInfo_Call { _c.Call.Return(run) return _c } // GetPrivilegeGroupRoles provides a mock function with given fields: ctx, groupName func (_m *IMetaTable) GetPrivilegeGroupRoles(ctx context.Context, groupName string) ([]*milvuspb.RoleEntity, error) { ret := _m.Called(ctx, groupName) if len(ret) == 0 { panic("no return value specified for GetPrivilegeGroupRoles") } var r0 []*milvuspb.RoleEntity var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) ([]*milvuspb.RoleEntity, error)); ok { return rf(ctx, groupName) } if rf, ok := ret.Get(0).(func(context.Context, string) []*milvuspb.RoleEntity); ok { r0 = rf(ctx, groupName) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.RoleEntity) } } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, groupName) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_GetPrivilegeGroupRoles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPrivilegeGroupRoles' type IMetaTable_GetPrivilegeGroupRoles_Call struct { *mock.Call } // GetPrivilegeGroupRoles is a helper method to define mock.On call // - ctx context.Context // - groupName string func (_e *IMetaTable_Expecter) GetPrivilegeGroupRoles(ctx interface{}, groupName interface{}) *IMetaTable_GetPrivilegeGroupRoles_Call { return &IMetaTable_GetPrivilegeGroupRoles_Call{Call: _e.mock.On("GetPrivilegeGroupRoles", ctx, groupName)} } func (_c *IMetaTable_GetPrivilegeGroupRoles_Call) Run(run func(ctx context.Context, groupName string)) *IMetaTable_GetPrivilegeGroupRoles_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_GetPrivilegeGroupRoles_Call) Return(_a0 []*milvuspb.RoleEntity, _a1 error) *IMetaTable_GetPrivilegeGroupRoles_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_GetPrivilegeGroupRoles_Call) RunAndReturn(run func(context.Context, string) ([]*milvuspb.RoleEntity, error)) *IMetaTable_GetPrivilegeGroupRoles_Call { _c.Call.Return(run) return _c } // IsAlias provides a mock function with given fields: ctx, db, name func (_m *IMetaTable) IsAlias(ctx context.Context, db string, name string) bool { ret := _m.Called(ctx, db, name) if len(ret) == 0 { panic("no return value specified for IsAlias") } var r0 bool if rf, ok := ret.Get(0).(func(context.Context, string, string) bool); ok { r0 = rf(ctx, db, name) } else { r0 = ret.Get(0).(bool) } return r0 } // IMetaTable_IsAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsAlias' type IMetaTable_IsAlias_Call struct { *mock.Call } // IsAlias is a helper method to define mock.On call // - ctx context.Context // - db string // - name string func (_e *IMetaTable_Expecter) IsAlias(ctx interface{}, db interface{}, name interface{}) *IMetaTable_IsAlias_Call { return &IMetaTable_IsAlias_Call{Call: _e.mock.On("IsAlias", ctx, db, name)} } func (_c *IMetaTable_IsAlias_Call) Run(run func(ctx context.Context, db string, name string)) *IMetaTable_IsAlias_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string)) }) return _c } func (_c *IMetaTable_IsAlias_Call) Return(_a0 bool) *IMetaTable_IsAlias_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_IsAlias_Call) RunAndReturn(run func(context.Context, string, string) bool) *IMetaTable_IsAlias_Call { _c.Call.Return(run) return _c } // IsCustomPrivilegeGroup provides a mock function with given fields: ctx, groupName func (_m *IMetaTable) IsCustomPrivilegeGroup(ctx context.Context, groupName string) (bool, error) { ret := _m.Called(ctx, groupName) if len(ret) == 0 { panic("no return value specified for IsCustomPrivilegeGroup") } var r0 bool var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) (bool, error)); ok { return rf(ctx, groupName) } if rf, ok := ret.Get(0).(func(context.Context, string) bool); ok { r0 = rf(ctx, groupName) } else { r0 = ret.Get(0).(bool) } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, groupName) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_IsCustomPrivilegeGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsCustomPrivilegeGroup' type IMetaTable_IsCustomPrivilegeGroup_Call struct { *mock.Call } // IsCustomPrivilegeGroup is a helper method to define mock.On call // - ctx context.Context // - groupName string func (_e *IMetaTable_Expecter) IsCustomPrivilegeGroup(ctx interface{}, groupName interface{}) *IMetaTable_IsCustomPrivilegeGroup_Call { return &IMetaTable_IsCustomPrivilegeGroup_Call{Call: _e.mock.On("IsCustomPrivilegeGroup", ctx, groupName)} } func (_c *IMetaTable_IsCustomPrivilegeGroup_Call) Run(run func(ctx context.Context, groupName string)) *IMetaTable_IsCustomPrivilegeGroup_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_IsCustomPrivilegeGroup_Call) Return(_a0 bool, _a1 error) *IMetaTable_IsCustomPrivilegeGroup_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_IsCustomPrivilegeGroup_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *IMetaTable_IsCustomPrivilegeGroup_Call { _c.Call.Return(run) return _c } // ListAliases provides a mock function with given fields: ctx, dbName, collectionName, ts func (_m *IMetaTable) ListAliases(ctx context.Context, dbName string, collectionName string, ts uint64) ([]string, error) { ret := _m.Called(ctx, dbName, collectionName, ts) if len(ret) == 0 { panic("no return value specified for ListAliases") } var r0 []string var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) ([]string, error)); ok { return rf(ctx, dbName, collectionName, ts) } if rf, ok := ret.Get(0).(func(context.Context, string, string, uint64) []string); ok { r0 = rf(ctx, dbName, collectionName, ts) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]string) } } if rf, ok := ret.Get(1).(func(context.Context, string, string, uint64) error); ok { r1 = rf(ctx, dbName, collectionName, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListAliases_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAliases' type IMetaTable_ListAliases_Call struct { *mock.Call } // ListAliases is a helper method to define mock.On call // - ctx context.Context // - dbName string // - collectionName string // - ts uint64 func (_e *IMetaTable_Expecter) ListAliases(ctx interface{}, dbName interface{}, collectionName interface{}, ts interface{}) *IMetaTable_ListAliases_Call { return &IMetaTable_ListAliases_Call{Call: _e.mock.On("ListAliases", ctx, dbName, collectionName, ts)} } func (_c *IMetaTable_ListAliases_Call) Run(run func(ctx context.Context, dbName string, collectionName string, ts uint64)) *IMetaTable_ListAliases_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(uint64)) }) return _c } func (_c *IMetaTable_ListAliases_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListAliases_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListAliases_Call) RunAndReturn(run func(context.Context, string, string, uint64) ([]string, error)) *IMetaTable_ListAliases_Call { _c.Call.Return(run) return _c } // ListAliasesByID provides a mock function with given fields: ctx, collID func (_m *IMetaTable) ListAliasesByID(ctx context.Context, collID int64) []string { ret := _m.Called(ctx, collID) if len(ret) == 0 { panic("no return value specified for ListAliasesByID") } var r0 []string if rf, ok := ret.Get(0).(func(context.Context, int64) []string); ok { r0 = rf(ctx, collID) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]string) } } return r0 } // IMetaTable_ListAliasesByID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAliasesByID' type IMetaTable_ListAliasesByID_Call struct { *mock.Call } // ListAliasesByID is a helper method to define mock.On call // - ctx context.Context // - collID int64 func (_e *IMetaTable_Expecter) ListAliasesByID(ctx interface{}, collID interface{}) *IMetaTable_ListAliasesByID_Call { return &IMetaTable_ListAliasesByID_Call{Call: _e.mock.On("ListAliasesByID", ctx, collID)} } func (_c *IMetaTable_ListAliasesByID_Call) Run(run func(ctx context.Context, collID int64)) *IMetaTable_ListAliasesByID_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64)) }) return _c } func (_c *IMetaTable_ListAliasesByID_Call) Return(_a0 []string) *IMetaTable_ListAliasesByID_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ListAliasesByID_Call) RunAndReturn(run func(context.Context, int64) []string) *IMetaTable_ListAliasesByID_Call { _c.Call.Return(run) return _c } // ListAllAvailCollections provides a mock function with given fields: ctx func (_m *IMetaTable) ListAllAvailCollections(ctx context.Context) map[int64][]int64 { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for ListAllAvailCollections") } var r0 map[int64][]int64 if rf, ok := ret.Get(0).(func(context.Context) map[int64][]int64); ok { r0 = rf(ctx) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(map[int64][]int64) } } return r0 } // IMetaTable_ListAllAvailCollections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllAvailCollections' type IMetaTable_ListAllAvailCollections_Call struct { *mock.Call } // ListAllAvailCollections is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) ListAllAvailCollections(ctx interface{}) *IMetaTable_ListAllAvailCollections_Call { return &IMetaTable_ListAllAvailCollections_Call{Call: _e.mock.On("ListAllAvailCollections", ctx)} } func (_c *IMetaTable_ListAllAvailCollections_Call) Run(run func(ctx context.Context)) *IMetaTable_ListAllAvailCollections_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_ListAllAvailCollections_Call) Return(_a0 map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ListAllAvailCollections_Call) RunAndReturn(run func(context.Context) map[int64][]int64) *IMetaTable_ListAllAvailCollections_Call { _c.Call.Return(run) return _c } // ListAllAvailPartitions provides a mock function with given fields: ctx func (_m *IMetaTable) ListAllAvailPartitions(ctx context.Context) map[int64]map[int64][]int64 { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for ListAllAvailPartitions") } var r0 map[int64]map[int64][]int64 if rf, ok := ret.Get(0).(func(context.Context) map[int64]map[int64][]int64); ok { r0 = rf(ctx) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(map[int64]map[int64][]int64) } } return r0 } // IMetaTable_ListAllAvailPartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllAvailPartitions' type IMetaTable_ListAllAvailPartitions_Call struct { *mock.Call } // ListAllAvailPartitions is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) ListAllAvailPartitions(ctx interface{}) *IMetaTable_ListAllAvailPartitions_Call { return &IMetaTable_ListAllAvailPartitions_Call{Call: _e.mock.On("ListAllAvailPartitions", ctx)} } func (_c *IMetaTable_ListAllAvailPartitions_Call) Run(run func(ctx context.Context)) *IMetaTable_ListAllAvailPartitions_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_ListAllAvailPartitions_Call) Return(_a0 map[int64]map[int64][]int64) *IMetaTable_ListAllAvailPartitions_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ListAllAvailPartitions_Call) RunAndReturn(run func(context.Context) map[int64]map[int64][]int64) *IMetaTable_ListAllAvailPartitions_Call { _c.Call.Return(run) return _c } // ListCollectionPhysicalChannels provides a mock function with given fields: ctx func (_m *IMetaTable) ListCollectionPhysicalChannels(ctx context.Context) map[int64][]string { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for ListCollectionPhysicalChannels") } var r0 map[int64][]string if rf, ok := ret.Get(0).(func(context.Context) map[int64][]string); ok { r0 = rf(ctx) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(map[int64][]string) } } return r0 } // IMetaTable_ListCollectionPhysicalChannels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollectionPhysicalChannels' type IMetaTable_ListCollectionPhysicalChannels_Call struct { *mock.Call } // ListCollectionPhysicalChannels is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) ListCollectionPhysicalChannels(ctx interface{}) *IMetaTable_ListCollectionPhysicalChannels_Call { return &IMetaTable_ListCollectionPhysicalChannels_Call{Call: _e.mock.On("ListCollectionPhysicalChannels", ctx)} } func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Run(run func(ctx context.Context)) *IMetaTable_ListCollectionPhysicalChannels_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) Return(_a0 map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_ListCollectionPhysicalChannels_Call) RunAndReturn(run func(context.Context) map[int64][]string) *IMetaTable_ListCollectionPhysicalChannels_Call { _c.Call.Return(run) return _c } // ListCollections provides a mock function with given fields: ctx, dbName, ts, onlyAvail func (_m *IMetaTable) ListCollections(ctx context.Context, dbName string, ts uint64, onlyAvail bool) ([]*model.Collection, error) { ret := _m.Called(ctx, dbName, ts, onlyAvail) if len(ret) == 0 { panic("no return value specified for ListCollections") } var r0 []*model.Collection var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, uint64, bool) ([]*model.Collection, error)); ok { return rf(ctx, dbName, ts, onlyAvail) } if rf, ok := ret.Get(0).(func(context.Context, string, uint64, bool) []*model.Collection); ok { r0 = rf(ctx, dbName, ts, onlyAvail) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*model.Collection) } } if rf, ok := ret.Get(1).(func(context.Context, string, uint64, bool) error); ok { r1 = rf(ctx, dbName, ts, onlyAvail) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListCollections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCollections' type IMetaTable_ListCollections_Call struct { *mock.Call } // ListCollections is a helper method to define mock.On call // - ctx context.Context // - dbName string // - ts uint64 // - onlyAvail bool func (_e *IMetaTable_Expecter) ListCollections(ctx interface{}, dbName interface{}, ts interface{}, onlyAvail interface{}) *IMetaTable_ListCollections_Call { return &IMetaTable_ListCollections_Call{Call: _e.mock.On("ListCollections", ctx, dbName, ts, onlyAvail)} } func (_c *IMetaTable_ListCollections_Call) Run(run func(ctx context.Context, dbName string, ts uint64, onlyAvail bool)) *IMetaTable_ListCollections_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(uint64), args[3].(bool)) }) return _c } func (_c *IMetaTable_ListCollections_Call) Return(_a0 []*model.Collection, _a1 error) *IMetaTable_ListCollections_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListCollections_Call) RunAndReturn(run func(context.Context, string, uint64, bool) ([]*model.Collection, error)) *IMetaTable_ListCollections_Call { _c.Call.Return(run) return _c } // ListCredentialUsernames provides a mock function with given fields: ctx func (_m *IMetaTable) ListCredentialUsernames(ctx context.Context) (*milvuspb.ListCredUsersResponse, error) { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for ListCredentialUsernames") } var r0 *milvuspb.ListCredUsersResponse var r1 error if rf, ok := ret.Get(0).(func(context.Context) (*milvuspb.ListCredUsersResponse, error)); ok { return rf(ctx) } if rf, ok := ret.Get(0).(func(context.Context) *milvuspb.ListCredUsersResponse); ok { r0 = rf(ctx) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*milvuspb.ListCredUsersResponse) } } if rf, ok := ret.Get(1).(func(context.Context) error); ok { r1 = rf(ctx) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListCredentialUsernames_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListCredentialUsernames' type IMetaTable_ListCredentialUsernames_Call struct { *mock.Call } // ListCredentialUsernames is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) ListCredentialUsernames(ctx interface{}) *IMetaTable_ListCredentialUsernames_Call { return &IMetaTable_ListCredentialUsernames_Call{Call: _e.mock.On("ListCredentialUsernames", ctx)} } func (_c *IMetaTable_ListCredentialUsernames_Call) Run(run func(ctx context.Context)) *IMetaTable_ListCredentialUsernames_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_ListCredentialUsernames_Call) Return(_a0 *milvuspb.ListCredUsersResponse, _a1 error) *IMetaTable_ListCredentialUsernames_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListCredentialUsernames_Call) RunAndReturn(run func(context.Context) (*milvuspb.ListCredUsersResponse, error)) *IMetaTable_ListCredentialUsernames_Call { _c.Call.Return(run) return _c } // ListDatabases provides a mock function with given fields: ctx, ts func (_m *IMetaTable) ListDatabases(ctx context.Context, ts uint64) ([]*model.Database, error) { ret := _m.Called(ctx, ts) if len(ret) == 0 { panic("no return value specified for ListDatabases") } var r0 []*model.Database var r1 error if rf, ok := ret.Get(0).(func(context.Context, uint64) ([]*model.Database, error)); ok { return rf(ctx, ts) } if rf, ok := ret.Get(0).(func(context.Context, uint64) []*model.Database); ok { r0 = rf(ctx, ts) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*model.Database) } } if rf, ok := ret.Get(1).(func(context.Context, uint64) error); ok { r1 = rf(ctx, ts) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListDatabases_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListDatabases' type IMetaTable_ListDatabases_Call struct { *mock.Call } // ListDatabases is a helper method to define mock.On call // - ctx context.Context // - ts uint64 func (_e *IMetaTable_Expecter) ListDatabases(ctx interface{}, ts interface{}) *IMetaTable_ListDatabases_Call { return &IMetaTable_ListDatabases_Call{Call: _e.mock.On("ListDatabases", ctx, ts)} } func (_c *IMetaTable_ListDatabases_Call) Run(run func(ctx context.Context, ts uint64)) *IMetaTable_ListDatabases_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(uint64)) }) return _c } func (_c *IMetaTable_ListDatabases_Call) Return(_a0 []*model.Database, _a1 error) *IMetaTable_ListDatabases_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListDatabases_Call) RunAndReturn(run func(context.Context, uint64) ([]*model.Database, error)) *IMetaTable_ListDatabases_Call { _c.Call.Return(run) return _c } // ListPolicy provides a mock function with given fields: ctx, tenant func (_m *IMetaTable) ListPolicy(ctx context.Context, tenant string) ([]*milvuspb.GrantEntity, error) { ret := _m.Called(ctx, tenant) if len(ret) == 0 { panic("no return value specified for ListPolicy") } var r0 []*milvuspb.GrantEntity var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) ([]*milvuspb.GrantEntity, error)); ok { return rf(ctx, tenant) } if rf, ok := ret.Get(0).(func(context.Context, string) []*milvuspb.GrantEntity); ok { r0 = rf(ctx, tenant) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.GrantEntity) } } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, tenant) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListPolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPolicy' type IMetaTable_ListPolicy_Call struct { *mock.Call } // ListPolicy is a helper method to define mock.On call // - ctx context.Context // - tenant string func (_e *IMetaTable_Expecter) ListPolicy(ctx interface{}, tenant interface{}) *IMetaTable_ListPolicy_Call { return &IMetaTable_ListPolicy_Call{Call: _e.mock.On("ListPolicy", ctx, tenant)} } func (_c *IMetaTable_ListPolicy_Call) Run(run func(ctx context.Context, tenant string)) *IMetaTable_ListPolicy_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_ListPolicy_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *IMetaTable_ListPolicy_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListPolicy_Call) RunAndReturn(run func(context.Context, string) ([]*milvuspb.GrantEntity, error)) *IMetaTable_ListPolicy_Call { _c.Call.Return(run) return _c } // ListPrivilegeGroups provides a mock function with given fields: ctx func (_m *IMetaTable) ListPrivilegeGroups(ctx context.Context) ([]*milvuspb.PrivilegeGroupInfo, error) { ret := _m.Called(ctx) if len(ret) == 0 { panic("no return value specified for ListPrivilegeGroups") } var r0 []*milvuspb.PrivilegeGroupInfo var r1 error if rf, ok := ret.Get(0).(func(context.Context) ([]*milvuspb.PrivilegeGroupInfo, error)); ok { return rf(ctx) } if rf, ok := ret.Get(0).(func(context.Context) []*milvuspb.PrivilegeGroupInfo); ok { r0 = rf(ctx) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.PrivilegeGroupInfo) } } if rf, ok := ret.Get(1).(func(context.Context) error); ok { r1 = rf(ctx) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListPrivilegeGroups_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPrivilegeGroups' type IMetaTable_ListPrivilegeGroups_Call struct { *mock.Call } // ListPrivilegeGroups is a helper method to define mock.On call // - ctx context.Context func (_e *IMetaTable_Expecter) ListPrivilegeGroups(ctx interface{}) *IMetaTable_ListPrivilegeGroups_Call { return &IMetaTable_ListPrivilegeGroups_Call{Call: _e.mock.On("ListPrivilegeGroups", ctx)} } func (_c *IMetaTable_ListPrivilegeGroups_Call) Run(run func(ctx context.Context)) *IMetaTable_ListPrivilegeGroups_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context)) }) return _c } func (_c *IMetaTable_ListPrivilegeGroups_Call) Return(_a0 []*milvuspb.PrivilegeGroupInfo, _a1 error) *IMetaTable_ListPrivilegeGroups_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListPrivilegeGroups_Call) RunAndReturn(run func(context.Context) ([]*milvuspb.PrivilegeGroupInfo, error)) *IMetaTable_ListPrivilegeGroups_Call { _c.Call.Return(run) return _c } // ListUserRole provides a mock function with given fields: ctx, tenant func (_m *IMetaTable) ListUserRole(ctx context.Context, tenant string) ([]string, error) { ret := _m.Called(ctx, tenant) if len(ret) == 0 { panic("no return value specified for ListUserRole") } var r0 []string var r1 error if rf, ok := ret.Get(0).(func(context.Context, string) ([]string, error)); ok { return rf(ctx, tenant) } if rf, ok := ret.Get(0).(func(context.Context, string) []string); ok { r0 = rf(ctx, tenant) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]string) } } if rf, ok := ret.Get(1).(func(context.Context, string) error); ok { r1 = rf(ctx, tenant) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_ListUserRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListUserRole' type IMetaTable_ListUserRole_Call struct { *mock.Call } // ListUserRole is a helper method to define mock.On call // - ctx context.Context // - tenant string func (_e *IMetaTable_Expecter) ListUserRole(ctx interface{}, tenant interface{}) *IMetaTable_ListUserRole_Call { return &IMetaTable_ListUserRole_Call{Call: _e.mock.On("ListUserRole", ctx, tenant)} } func (_c *IMetaTable_ListUserRole_Call) Run(run func(ctx context.Context, tenant string)) *IMetaTable_ListUserRole_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string)) }) return _c } func (_c *IMetaTable_ListUserRole_Call) Return(_a0 []string, _a1 error) *IMetaTable_ListUserRole_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_ListUserRole_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *IMetaTable_ListUserRole_Call { _c.Call.Return(run) return _c } // OperatePrivilege provides a mock function with given fields: ctx, tenant, entity, operateType func (_m *IMetaTable) OperatePrivilege(ctx context.Context, tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType) error { ret := _m.Called(ctx, tenant, entity, operateType) if len(ret) == 0 { panic("no return value specified for OperatePrivilege") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.GrantEntity, milvuspb.OperatePrivilegeType) error); ok { r0 = rf(ctx, tenant, entity, operateType) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_OperatePrivilege_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperatePrivilege' type IMetaTable_OperatePrivilege_Call struct { *mock.Call } // OperatePrivilege is a helper method to define mock.On call // - ctx context.Context // - tenant string // - entity *milvuspb.GrantEntity // - operateType milvuspb.OperatePrivilegeType func (_e *IMetaTable_Expecter) OperatePrivilege(ctx interface{}, tenant interface{}, entity interface{}, operateType interface{}) *IMetaTable_OperatePrivilege_Call { return &IMetaTable_OperatePrivilege_Call{Call: _e.mock.On("OperatePrivilege", ctx, tenant, entity, operateType)} } func (_c *IMetaTable_OperatePrivilege_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType)) *IMetaTable_OperatePrivilege_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.GrantEntity), args[3].(milvuspb.OperatePrivilegeType)) }) return _c } func (_c *IMetaTable_OperatePrivilege_Call) Return(_a0 error) *IMetaTable_OperatePrivilege_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_OperatePrivilege_Call) RunAndReturn(run func(context.Context, string, *milvuspb.GrantEntity, milvuspb.OperatePrivilegeType) error) *IMetaTable_OperatePrivilege_Call { _c.Call.Return(run) return _c } // OperatePrivilegeGroup provides a mock function with given fields: ctx, groupName, privileges, operateType func (_m *IMetaTable) OperatePrivilegeGroup(ctx context.Context, groupName string, privileges []*milvuspb.PrivilegeEntity, operateType milvuspb.OperatePrivilegeGroupType) error { ret := _m.Called(ctx, groupName, privileges, operateType) if len(ret) == 0 { panic("no return value specified for OperatePrivilegeGroup") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, []*milvuspb.PrivilegeEntity, milvuspb.OperatePrivilegeGroupType) error); ok { r0 = rf(ctx, groupName, privileges, operateType) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_OperatePrivilegeGroup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperatePrivilegeGroup' type IMetaTable_OperatePrivilegeGroup_Call struct { *mock.Call } // OperatePrivilegeGroup is a helper method to define mock.On call // - ctx context.Context // - groupName string // - privileges []*milvuspb.PrivilegeEntity // - operateType milvuspb.OperatePrivilegeGroupType func (_e *IMetaTable_Expecter) OperatePrivilegeGroup(ctx interface{}, groupName interface{}, privileges interface{}, operateType interface{}) *IMetaTable_OperatePrivilegeGroup_Call { return &IMetaTable_OperatePrivilegeGroup_Call{Call: _e.mock.On("OperatePrivilegeGroup", ctx, groupName, privileges, operateType)} } func (_c *IMetaTable_OperatePrivilegeGroup_Call) Run(run func(ctx context.Context, groupName string, privileges []*milvuspb.PrivilegeEntity, operateType milvuspb.OperatePrivilegeGroupType)) *IMetaTable_OperatePrivilegeGroup_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].([]*milvuspb.PrivilegeEntity), args[3].(milvuspb.OperatePrivilegeGroupType)) }) return _c } func (_c *IMetaTable_OperatePrivilegeGroup_Call) Return(_a0 error) *IMetaTable_OperatePrivilegeGroup_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_OperatePrivilegeGroup_Call) RunAndReturn(run func(context.Context, string, []*milvuspb.PrivilegeEntity, milvuspb.OperatePrivilegeGroupType) error) *IMetaTable_OperatePrivilegeGroup_Call { _c.Call.Return(run) return _c } // OperateUserRole provides a mock function with given fields: ctx, tenant, userEntity, roleEntity, operateType func (_m *IMetaTable) OperateUserRole(ctx context.Context, tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType) error { ret := _m.Called(ctx, tenant, userEntity, roleEntity, operateType) if len(ret) == 0 { panic("no return value specified for OperateUserRole") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.UserEntity, *milvuspb.RoleEntity, milvuspb.OperateUserRoleType) error); ok { r0 = rf(ctx, tenant, userEntity, roleEntity, operateType) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_OperateUserRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OperateUserRole' type IMetaTable_OperateUserRole_Call struct { *mock.Call } // OperateUserRole is a helper method to define mock.On call // - ctx context.Context // - tenant string // - userEntity *milvuspb.UserEntity // - roleEntity *milvuspb.RoleEntity // - operateType milvuspb.OperateUserRoleType func (_e *IMetaTable_Expecter) OperateUserRole(ctx interface{}, tenant interface{}, userEntity interface{}, roleEntity interface{}, operateType interface{}) *IMetaTable_OperateUserRole_Call { return &IMetaTable_OperateUserRole_Call{Call: _e.mock.On("OperateUserRole", ctx, tenant, userEntity, roleEntity, operateType)} } func (_c *IMetaTable_OperateUserRole_Call) Run(run func(ctx context.Context, tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType)) *IMetaTable_OperateUserRole_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.UserEntity), args[3].(*milvuspb.RoleEntity), args[4].(milvuspb.OperateUserRoleType)) }) return _c } func (_c *IMetaTable_OperateUserRole_Call) Return(_a0 error) *IMetaTable_OperateUserRole_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_OperateUserRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.UserEntity, *milvuspb.RoleEntity, milvuspb.OperateUserRoleType) error) *IMetaTable_OperateUserRole_Call { _c.Call.Return(run) return _c } // RemoveCollection provides a mock function with given fields: ctx, collectionID, ts func (_m *IMetaTable) RemoveCollection(ctx context.Context, collectionID int64, ts uint64) error { ret := _m.Called(ctx, collectionID, ts) if len(ret) == 0 { panic("no return value specified for RemoveCollection") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, int64, uint64) error); ok { r0 = rf(ctx, collectionID, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_RemoveCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveCollection' type IMetaTable_RemoveCollection_Call struct { *mock.Call } // RemoveCollection is a helper method to define mock.On call // - ctx context.Context // - collectionID int64 // - ts uint64 func (_e *IMetaTable_Expecter) RemoveCollection(ctx interface{}, collectionID interface{}, ts interface{}) *IMetaTable_RemoveCollection_Call { return &IMetaTable_RemoveCollection_Call{Call: _e.mock.On("RemoveCollection", ctx, collectionID, ts)} } func (_c *IMetaTable_RemoveCollection_Call) Run(run func(ctx context.Context, collectionID int64, ts uint64)) *IMetaTable_RemoveCollection_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64), args[2].(uint64)) }) return _c } func (_c *IMetaTable_RemoveCollection_Call) Return(_a0 error) *IMetaTable_RemoveCollection_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_RemoveCollection_Call) RunAndReturn(run func(context.Context, int64, uint64) error) *IMetaTable_RemoveCollection_Call { _c.Call.Return(run) return _c } // RemovePartition provides a mock function with given fields: ctx, dbID, collectionID, partitionID, ts func (_m *IMetaTable) RemovePartition(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64) error { ret := _m.Called(ctx, dbID, collectionID, partitionID, ts) if len(ret) == 0 { panic("no return value specified for RemovePartition") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, int64, int64, int64, uint64) error); ok { r0 = rf(ctx, dbID, collectionID, partitionID, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_RemovePartition_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePartition' type IMetaTable_RemovePartition_Call struct { *mock.Call } // RemovePartition is a helper method to define mock.On call // - ctx context.Context // - dbID int64 // - collectionID int64 // - partitionID int64 // - ts uint64 func (_e *IMetaTable_Expecter) RemovePartition(ctx interface{}, dbID interface{}, collectionID interface{}, partitionID interface{}, ts interface{}) *IMetaTable_RemovePartition_Call { return &IMetaTable_RemovePartition_Call{Call: _e.mock.On("RemovePartition", ctx, dbID, collectionID, partitionID, ts)} } func (_c *IMetaTable_RemovePartition_Call) Run(run func(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64)) *IMetaTable_RemovePartition_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(int64), args[2].(int64), args[3].(int64), args[4].(uint64)) }) return _c } func (_c *IMetaTable_RemovePartition_Call) Return(_a0 error) *IMetaTable_RemovePartition_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_RemovePartition_Call) RunAndReturn(run func(context.Context, int64, int64, int64, uint64) error) *IMetaTable_RemovePartition_Call { _c.Call.Return(run) return _c } // RenameCollection provides a mock function with given fields: ctx, dbName, oldName, newDBName, newName, ts func (_m *IMetaTable) RenameCollection(ctx context.Context, dbName string, oldName string, newDBName string, newName string, ts uint64) error { ret := _m.Called(ctx, dbName, oldName, newDBName, newName, ts) if len(ret) == 0 { panic("no return value specified for RenameCollection") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, uint64) error); ok { r0 = rf(ctx, dbName, oldName, newDBName, newName, ts) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_RenameCollection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RenameCollection' type IMetaTable_RenameCollection_Call struct { *mock.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 (_e *IMetaTable_Expecter) RenameCollection(ctx interface{}, dbName interface{}, oldName interface{}, newDBName interface{}, newName interface{}, ts interface{}) *IMetaTable_RenameCollection_Call { return &IMetaTable_RenameCollection_Call{Call: _e.mock.On("RenameCollection", ctx, dbName, oldName, newDBName, newName, ts)} } func (_c *IMetaTable_RenameCollection_Call) Run(run func(ctx context.Context, dbName string, oldName string, newDBName string, newName string, ts uint64)) *IMetaTable_RenameCollection_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(string), args[3].(string), args[4].(string), args[5].(uint64)) }) return _c } func (_c *IMetaTable_RenameCollection_Call) Return(_a0 error) *IMetaTable_RenameCollection_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_RenameCollection_Call) RunAndReturn(run func(context.Context, string, string, string, string, uint64) error) *IMetaTable_RenameCollection_Call { _c.Call.Return(run) return _c } // RestoreRBAC provides a mock function with given fields: ctx, tenant, meta func (_m *IMetaTable) RestoreRBAC(ctx context.Context, tenant string, meta *milvuspb.RBACMeta) error { ret := _m.Called(ctx, tenant, meta) if len(ret) == 0 { panic("no return value specified for RestoreRBAC") } var r0 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.RBACMeta) error); ok { r0 = rf(ctx, tenant, meta) } else { r0 = ret.Error(0) } return r0 } // IMetaTable_RestoreRBAC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RestoreRBAC' type IMetaTable_RestoreRBAC_Call struct { *mock.Call } // RestoreRBAC is a helper method to define mock.On call // - ctx context.Context // - tenant string // - meta *milvuspb.RBACMeta func (_e *IMetaTable_Expecter) RestoreRBAC(ctx interface{}, tenant interface{}, meta interface{}) *IMetaTable_RestoreRBAC_Call { return &IMetaTable_RestoreRBAC_Call{Call: _e.mock.On("RestoreRBAC", ctx, tenant, meta)} } func (_c *IMetaTable_RestoreRBAC_Call) Run(run func(ctx context.Context, tenant string, meta *milvuspb.RBACMeta)) *IMetaTable_RestoreRBAC_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.RBACMeta)) }) return _c } func (_c *IMetaTable_RestoreRBAC_Call) Return(_a0 error) *IMetaTable_RestoreRBAC_Call { _c.Call.Return(_a0) return _c } func (_c *IMetaTable_RestoreRBAC_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RBACMeta) error) *IMetaTable_RestoreRBAC_Call { _c.Call.Return(run) return _c } // SelectGrant provides a mock function with given fields: ctx, tenant, entity func (_m *IMetaTable) SelectGrant(ctx context.Context, tenant string, entity *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error) { ret := _m.Called(ctx, tenant, entity) if len(ret) == 0 { panic("no return value specified for SelectGrant") } var r0 []*milvuspb.GrantEntity var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)); ok { return rf(ctx, tenant, entity) } if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.GrantEntity) []*milvuspb.GrantEntity); ok { r0 = rf(ctx, tenant, entity) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.GrantEntity) } } if rf, ok := ret.Get(1).(func(context.Context, string, *milvuspb.GrantEntity) error); ok { r1 = rf(ctx, tenant, entity) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_SelectGrant_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectGrant' type IMetaTable_SelectGrant_Call struct { *mock.Call } // SelectGrant is a helper method to define mock.On call // - ctx context.Context // - tenant string // - entity *milvuspb.GrantEntity func (_e *IMetaTable_Expecter) SelectGrant(ctx interface{}, tenant interface{}, entity interface{}) *IMetaTable_SelectGrant_Call { return &IMetaTable_SelectGrant_Call{Call: _e.mock.On("SelectGrant", ctx, tenant, entity)} } func (_c *IMetaTable_SelectGrant_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.GrantEntity)) *IMetaTable_SelectGrant_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.GrantEntity)) }) return _c } func (_c *IMetaTable_SelectGrant_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *IMetaTable_SelectGrant_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_SelectGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)) *IMetaTable_SelectGrant_Call { _c.Call.Return(run) return _c } // SelectRole provides a mock function with given fields: ctx, tenant, entity, includeUserInfo func (_m *IMetaTable) SelectRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool) ([]*milvuspb.RoleResult, error) { ret := _m.Called(ctx, tenant, entity, includeUserInfo) if len(ret) == 0 { panic("no return value specified for SelectRole") } var r0 []*milvuspb.RoleResult var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.RoleEntity, bool) ([]*milvuspb.RoleResult, error)); ok { return rf(ctx, tenant, entity, includeUserInfo) } if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.RoleEntity, bool) []*milvuspb.RoleResult); ok { r0 = rf(ctx, tenant, entity, includeUserInfo) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.RoleResult) } } if rf, ok := ret.Get(1).(func(context.Context, string, *milvuspb.RoleEntity, bool) error); ok { r1 = rf(ctx, tenant, entity, includeUserInfo) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_SelectRole_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectRole' type IMetaTable_SelectRole_Call struct { *mock.Call } // SelectRole is a helper method to define mock.On call // - ctx context.Context // - tenant string // - entity *milvuspb.RoleEntity // - includeUserInfo bool func (_e *IMetaTable_Expecter) SelectRole(ctx interface{}, tenant interface{}, entity interface{}, includeUserInfo interface{}) *IMetaTable_SelectRole_Call { return &IMetaTable_SelectRole_Call{Call: _e.mock.On("SelectRole", ctx, tenant, entity, includeUserInfo)} } func (_c *IMetaTable_SelectRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool)) *IMetaTable_SelectRole_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.RoleEntity), args[3].(bool)) }) return _c } func (_c *IMetaTable_SelectRole_Call) Return(_a0 []*milvuspb.RoleResult, _a1 error) *IMetaTable_SelectRole_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_SelectRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity, bool) ([]*milvuspb.RoleResult, error)) *IMetaTable_SelectRole_Call { _c.Call.Return(run) return _c } // SelectUser provides a mock function with given fields: ctx, tenant, entity, includeRoleInfo func (_m *IMetaTable) SelectUser(ctx context.Context, tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool) ([]*milvuspb.UserResult, error) { ret := _m.Called(ctx, tenant, entity, includeRoleInfo) if len(ret) == 0 { panic("no return value specified for SelectUser") } var r0 []*milvuspb.UserResult var r1 error if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.UserEntity, bool) ([]*milvuspb.UserResult, error)); ok { return rf(ctx, tenant, entity, includeRoleInfo) } if rf, ok := ret.Get(0).(func(context.Context, string, *milvuspb.UserEntity, bool) []*milvuspb.UserResult); ok { r0 = rf(ctx, tenant, entity, includeRoleInfo) } else { if ret.Get(0) != nil { r0 = ret.Get(0).([]*milvuspb.UserResult) } } if rf, ok := ret.Get(1).(func(context.Context, string, *milvuspb.UserEntity, bool) error); ok { r1 = rf(ctx, tenant, entity, includeRoleInfo) } else { r1 = ret.Error(1) } return r0, r1 } // IMetaTable_SelectUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectUser' type IMetaTable_SelectUser_Call struct { *mock.Call } // SelectUser is a helper method to define mock.On call // - ctx context.Context // - tenant string // - entity *milvuspb.UserEntity // - includeRoleInfo bool func (_e *IMetaTable_Expecter) SelectUser(ctx interface{}, tenant interface{}, entity interface{}, includeRoleInfo interface{}) *IMetaTable_SelectUser_Call { return &IMetaTable_SelectUser_Call{Call: _e.mock.On("SelectUser", ctx, tenant, entity, includeRoleInfo)} } func (_c *IMetaTable_SelectUser_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool)) *IMetaTable_SelectUser_Call { _c.Call.Run(func(args mock.Arguments) { run(args[0].(context.Context), args[1].(string), args[2].(*milvuspb.UserEntity), args[3].(bool)) }) return _c } func (_c *IMetaTable_SelectUser_Call) Return(_a0 []*milvuspb.UserResult, _a1 error) *IMetaTable_SelectUser_Call { _c.Call.Return(_a0, _a1) return _c } func (_c *IMetaTable_SelectUser_Call) RunAndReturn(run func(context.Context, string, *milvuspb.UserEntity, bool) ([]*milvuspb.UserResult, error)) *IMetaTable_SelectUser_Call { _c.Call.Return(run) return _c } // 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 NewIMetaTable(t interface { mock.TestingT Cleanup(func()) }) *IMetaTable { mock := &IMetaTable{} mock.Mock.Test(t) t.Cleanup(func() { mock.AssertExpectations(t) }) return mock }