mocks

Documentation

Index

• type DataCoordCatalog
  • func NewDataCoordCatalog(t interface{ ... }) *DataCoordCatalog
  • func (_m *DataCoordCatalog) AddSegment(ctx context.Context, segment *datapb.SegmentInfo) error
  • func (_m *DataCoordCatalog) AlterIndexes(ctx context.Context, newIndexes []*model.Index) error
  • func (_m *DataCoordCatalog) AlterSegmentIndexes(ctx context.Context, newSegIdxes []*model.SegmentIndex) error
  • func (_m *DataCoordCatalog) AlterSegments(ctx context.Context, newSegments []*datapb.SegmentInfo, ...) error
  • func (_m *DataCoordCatalog) ChannelExists(ctx context.Context, channel string) bool
  • func (_m *DataCoordCatalog) CreateIndex(ctx context.Context, index *model.Index) error
  • func (_m *DataCoordCatalog) CreateSegmentIndex(ctx context.Context, segIdx *model.SegmentIndex) error
  • func (_m *DataCoordCatalog) DropAnalyzeTask(ctx context.Context, taskID int64) error
  • func (_m *DataCoordCatalog) DropChannel(ctx context.Context, channel string) error
  • func (_m *DataCoordCatalog) DropChannelCheckpoint(ctx context.Context, vChannel string) error
  • func (_m *DataCoordCatalog) DropCompactionTask(ctx context.Context, task *datapb.CompactionTask) error
  • func (_m *DataCoordCatalog) DropCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string) error
  • func (_m *DataCoordCatalog) DropImportJob(jobID int64) error
  • func (_m *DataCoordCatalog) DropImportTask(taskID int64) error
  • func (_m *DataCoordCatalog) DropIndex(ctx context.Context, collID int64, dropIdxID int64) error
  • func (_m *DataCoordCatalog) DropPartitionStatsInfo(ctx context.Context, info *datapb.PartitionStatsInfo) error
  • func (_m *DataCoordCatalog) DropPreImportTask(taskID int64) error
  • func (_m *DataCoordCatalog) DropSegment(ctx context.Context, segment *datapb.SegmentInfo) error
  • func (_m *DataCoordCatalog) DropSegmentIndex(ctx context.Context, collID int64, partID int64, segID int64, buildID int64) error
  • func (_m *DataCoordCatalog) EXPECT() *DataCoordCatalog_Expecter
  • func (_m *DataCoordCatalog) GcConfirm(ctx context.Context, collectionID int64, partitionID int64) bool
  • func (_m *DataCoordCatalog) GetCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string) (int64, error)
  • func (_m *DataCoordCatalog) ListAnalyzeTasks(ctx context.Context) ([]*indexpb.AnalyzeTask, error)
  • func (_m *DataCoordCatalog) ListChannelCheckpoint(ctx context.Context) (map[string]*msgpb.MsgPosition, error)
  • func (_m *DataCoordCatalog) ListCompactionTask(ctx context.Context) ([]*datapb.CompactionTask, error)
  • func (_m *DataCoordCatalog) ListImportJobs() ([]*datapb.ImportJob, error)
  • func (_m *DataCoordCatalog) ListImportTasks() ([]*datapb.ImportTaskV2, error)
  • func (_m *DataCoordCatalog) ListIndexes(ctx context.Context) ([]*model.Index, error)
  • func (_m *DataCoordCatalog) ListPartitionStatsInfos(ctx context.Context) ([]*datapb.PartitionStatsInfo, error)
  • func (_m *DataCoordCatalog) ListPreImportTasks() ([]*datapb.PreImportTask, error)
  • func (_m *DataCoordCatalog) ListSegmentIndexes(ctx context.Context) ([]*model.SegmentIndex, error)
  • func (_m *DataCoordCatalog) ListSegments(ctx context.Context) ([]*datapb.SegmentInfo, error)
  • func (_m *DataCoordCatalog) MarkChannelAdded(ctx context.Context, channel string) error
  • func (_m *DataCoordCatalog) MarkChannelDeleted(ctx context.Context, channel string) error
  • func (_m *DataCoordCatalog) SaveAnalyzeTask(ctx context.Context, task *indexpb.AnalyzeTask) error
  • func (_m *DataCoordCatalog) SaveChannelCheckpoint(ctx context.Context, vChannel string, pos *msgpb.MsgPosition) error
  • func (_m *DataCoordCatalog) SaveChannelCheckpoints(ctx context.Context, positions []*msgpb.MsgPosition) error
  • func (_m *DataCoordCatalog) SaveCompactionTask(ctx context.Context, task *datapb.CompactionTask) error
  • func (_m *DataCoordCatalog) SaveCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string, ...) error
  • func (_m *DataCoordCatalog) SaveDroppedSegmentsInBatch(ctx context.Context, segments []*datapb.SegmentInfo) error
  • func (_m *DataCoordCatalog) SaveImportJob(job *datapb.ImportJob) error
  • func (_m *DataCoordCatalog) SaveImportTask(task *datapb.ImportTaskV2) error
  • func (_m *DataCoordCatalog) SavePartitionStatsInfo(ctx context.Context, info *datapb.PartitionStatsInfo) error
  • func (_m *DataCoordCatalog) SavePreImportTask(task *datapb.PreImportTask) error
  • func (_m *DataCoordCatalog) ShouldDropChannel(ctx context.Context, channel string) bool
• type DataCoordCatalog_AddSegment_Call
  • func (_c *DataCoordCatalog_AddSegment_Call) Return(_a0 error) *DataCoordCatalog_AddSegment_Call
  • func (_c *DataCoordCatalog_AddSegment_Call) Run(run func(ctx context.Context, segment *datapb.SegmentInfo)) *DataCoordCatalog_AddSegment_Call
  • func (_c *DataCoordCatalog_AddSegment_Call) RunAndReturn(run func(context.Context, *datapb.SegmentInfo) error) *DataCoordCatalog_AddSegment_Call
• type DataCoordCatalog_AlterIndexes_Call
  • func (_c *DataCoordCatalog_AlterIndexes_Call) Return(_a0 error) *DataCoordCatalog_AlterIndexes_Call
  • func (_c *DataCoordCatalog_AlterIndexes_Call) Run(run func(ctx context.Context, newIndexes []*model.Index)) *DataCoordCatalog_AlterIndexes_Call
  • func (_c *DataCoordCatalog_AlterIndexes_Call) RunAndReturn(run func(context.Context, []*model.Index) error) *DataCoordCatalog_AlterIndexes_Call
• type DataCoordCatalog_AlterSegmentIndexes_Call
  • func (_c *DataCoordCatalog_AlterSegmentIndexes_Call) Return(_a0 error) *DataCoordCatalog_AlterSegmentIndexes_Call
  • func (_c *DataCoordCatalog_AlterSegmentIndexes_Call) Run(run func(ctx context.Context, newSegIdxes []*model.SegmentIndex)) *DataCoordCatalog_AlterSegmentIndexes_Call
  • func (_c *DataCoordCatalog_AlterSegmentIndexes_Call) RunAndReturn(run func(context.Context, []*model.SegmentIndex) error) *DataCoordCatalog_AlterSegmentIndexes_Call
• type DataCoordCatalog_AlterSegments_Call
  • func (_c *DataCoordCatalog_AlterSegments_Call) Return(_a0 error) *DataCoordCatalog_AlterSegments_Call
  • func (_c *DataCoordCatalog_AlterSegments_Call) Run(run func(ctx context.Context, newSegments []*datapb.SegmentInfo, ...)) *DataCoordCatalog_AlterSegments_Call
  • func (_c *DataCoordCatalog_AlterSegments_Call) RunAndReturn(...) *DataCoordCatalog_AlterSegments_Call
• type DataCoordCatalog_ChannelExists_Call
  • func (_c *DataCoordCatalog_ChannelExists_Call) Return(_a0 bool) *DataCoordCatalog_ChannelExists_Call
  • func (_c *DataCoordCatalog_ChannelExists_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_ChannelExists_Call
  • func (_c *DataCoordCatalog_ChannelExists_Call) RunAndReturn(run func(context.Context, string) bool) *DataCoordCatalog_ChannelExists_Call
• type DataCoordCatalog_CreateIndex_Call
  • func (_c *DataCoordCatalog_CreateIndex_Call) Return(_a0 error) *DataCoordCatalog_CreateIndex_Call
  • func (_c *DataCoordCatalog_CreateIndex_Call) Run(run func(ctx context.Context, index *model.Index)) *DataCoordCatalog_CreateIndex_Call
  • func (_c *DataCoordCatalog_CreateIndex_Call) RunAndReturn(run func(context.Context, *model.Index) error) *DataCoordCatalog_CreateIndex_Call
• type DataCoordCatalog_CreateSegmentIndex_Call
  • func (_c *DataCoordCatalog_CreateSegmentIndex_Call) Return(_a0 error) *DataCoordCatalog_CreateSegmentIndex_Call
  • func (_c *DataCoordCatalog_CreateSegmentIndex_Call) Run(run func(ctx context.Context, segIdx *model.SegmentIndex)) *DataCoordCatalog_CreateSegmentIndex_Call
  • func (_c *DataCoordCatalog_CreateSegmentIndex_Call) RunAndReturn(run func(context.Context, *model.SegmentIndex) error) *DataCoordCatalog_CreateSegmentIndex_Call
• type DataCoordCatalog_DropAnalyzeTask_Call
  • func (_c *DataCoordCatalog_DropAnalyzeTask_Call) Return(_a0 error) *DataCoordCatalog_DropAnalyzeTask_Call
  • func (_c *DataCoordCatalog_DropAnalyzeTask_Call) Run(run func(ctx context.Context, taskID int64)) *DataCoordCatalog_DropAnalyzeTask_Call
  • func (_c *DataCoordCatalog_DropAnalyzeTask_Call) RunAndReturn(run func(context.Context, int64) error) *DataCoordCatalog_DropAnalyzeTask_Call
• type DataCoordCatalog_DropChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_DropChannelCheckpoint_Call) Return(_a0 error) *DataCoordCatalog_DropChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_DropChannelCheckpoint_Call) Run(run func(ctx context.Context, vChannel string)) *DataCoordCatalog_DropChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_DropChannelCheckpoint_Call) RunAndReturn(run func(context.Context, string) error) *DataCoordCatalog_DropChannelCheckpoint_Call
• type DataCoordCatalog_DropChannel_Call
  • func (_c *DataCoordCatalog_DropChannel_Call) Return(_a0 error) *DataCoordCatalog_DropChannel_Call
  • func (_c *DataCoordCatalog_DropChannel_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_DropChannel_Call
  • func (_c *DataCoordCatalog_DropChannel_Call) RunAndReturn(run func(context.Context, string) error) *DataCoordCatalog_DropChannel_Call
• type DataCoordCatalog_DropCompactionTask_Call
  • func (_c *DataCoordCatalog_DropCompactionTask_Call) Return(_a0 error) *DataCoordCatalog_DropCompactionTask_Call
  • func (_c *DataCoordCatalog_DropCompactionTask_Call) Run(run func(ctx context.Context, task *datapb.CompactionTask)) *DataCoordCatalog_DropCompactionTask_Call
  • func (_c *DataCoordCatalog_DropCompactionTask_Call) RunAndReturn(run func(context.Context, *datapb.CompactionTask) error) *DataCoordCatalog_DropCompactionTask_Call
• type DataCoordCatalog_DropCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) Return(_a0 error) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) Run(run func(ctx context.Context, collID int64, partID int64, vChannel string)) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) RunAndReturn(run func(context.Context, int64, int64, string) error) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call
• type DataCoordCatalog_DropImportJob_Call
  • func (_c *DataCoordCatalog_DropImportJob_Call) Return(_a0 error) *DataCoordCatalog_DropImportJob_Call
  • func (_c *DataCoordCatalog_DropImportJob_Call) Run(run func(jobID int64)) *DataCoordCatalog_DropImportJob_Call
  • func (_c *DataCoordCatalog_DropImportJob_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropImportJob_Call
• type DataCoordCatalog_DropImportTask_Call
  • func (_c *DataCoordCatalog_DropImportTask_Call) Return(_a0 error) *DataCoordCatalog_DropImportTask_Call
  • func (_c *DataCoordCatalog_DropImportTask_Call) Run(run func(taskID int64)) *DataCoordCatalog_DropImportTask_Call
  • func (_c *DataCoordCatalog_DropImportTask_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropImportTask_Call
• type DataCoordCatalog_DropIndex_Call
  • func (_c *DataCoordCatalog_DropIndex_Call) Return(_a0 error) *DataCoordCatalog_DropIndex_Call
  • func (_c *DataCoordCatalog_DropIndex_Call) Run(run func(ctx context.Context, collID int64, dropIdxID int64)) *DataCoordCatalog_DropIndex_Call
  • func (_c *DataCoordCatalog_DropIndex_Call) RunAndReturn(run func(context.Context, int64, int64) error) *DataCoordCatalog_DropIndex_Call
• type DataCoordCatalog_DropPartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_DropPartitionStatsInfo_Call) Return(_a0 error) *DataCoordCatalog_DropPartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_DropPartitionStatsInfo_Call) Run(run func(ctx context.Context, info *datapb.PartitionStatsInfo)) *DataCoordCatalog_DropPartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_DropPartitionStatsInfo_Call) RunAndReturn(run func(context.Context, *datapb.PartitionStatsInfo) error) *DataCoordCatalog_DropPartitionStatsInfo_Call
• type DataCoordCatalog_DropPreImportTask_Call
  • func (_c *DataCoordCatalog_DropPreImportTask_Call) Return(_a0 error) *DataCoordCatalog_DropPreImportTask_Call
  • func (_c *DataCoordCatalog_DropPreImportTask_Call) Run(run func(taskID int64)) *DataCoordCatalog_DropPreImportTask_Call
  • func (_c *DataCoordCatalog_DropPreImportTask_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropPreImportTask_Call
• type DataCoordCatalog_DropSegmentIndex_Call
  • func (_c *DataCoordCatalog_DropSegmentIndex_Call) Return(_a0 error) *DataCoordCatalog_DropSegmentIndex_Call
  • func (_c *DataCoordCatalog_DropSegmentIndex_Call) Run(...) *DataCoordCatalog_DropSegmentIndex_Call
  • func (_c *DataCoordCatalog_DropSegmentIndex_Call) RunAndReturn(run func(context.Context, int64, int64, int64, int64) error) *DataCoordCatalog_DropSegmentIndex_Call
• type DataCoordCatalog_DropSegment_Call
  • func (_c *DataCoordCatalog_DropSegment_Call) Return(_a0 error) *DataCoordCatalog_DropSegment_Call
  • func (_c *DataCoordCatalog_DropSegment_Call) Run(run func(ctx context.Context, segment *datapb.SegmentInfo)) *DataCoordCatalog_DropSegment_Call
  • func (_c *DataCoordCatalog_DropSegment_Call) RunAndReturn(run func(context.Context, *datapb.SegmentInfo) error) *DataCoordCatalog_DropSegment_Call
• type DataCoordCatalog_Expecter
  • func (_e *DataCoordCatalog_Expecter) AddSegment(ctx interface{}, segment interface{}) *DataCoordCatalog_AddSegment_Call
  • func (_e *DataCoordCatalog_Expecter) AlterIndexes(ctx interface{}, newIndexes interface{}) *DataCoordCatalog_AlterIndexes_Call
  • func (_e *DataCoordCatalog_Expecter) AlterSegmentIndexes(ctx interface{}, newSegIdxes interface{}) *DataCoordCatalog_AlterSegmentIndexes_Call
  • func (_e *DataCoordCatalog_Expecter) AlterSegments(ctx interface{}, newSegments interface{}, binlogs ...interface{}) *DataCoordCatalog_AlterSegments_Call
  • func (_e *DataCoordCatalog_Expecter) ChannelExists(ctx interface{}, channel interface{}) *DataCoordCatalog_ChannelExists_Call
  • func (_e *DataCoordCatalog_Expecter) CreateIndex(ctx interface{}, index interface{}) *DataCoordCatalog_CreateIndex_Call
  • func (_e *DataCoordCatalog_Expecter) CreateSegmentIndex(ctx interface{}, segIdx interface{}) *DataCoordCatalog_CreateSegmentIndex_Call
  • func (_e *DataCoordCatalog_Expecter) DropAnalyzeTask(ctx interface{}, taskID interface{}) *DataCoordCatalog_DropAnalyzeTask_Call
  • func (_e *DataCoordCatalog_Expecter) DropChannel(ctx interface{}, channel interface{}) *DataCoordCatalog_DropChannel_Call
  • func (_e *DataCoordCatalog_Expecter) DropChannelCheckpoint(ctx interface{}, vChannel interface{}) *DataCoordCatalog_DropChannelCheckpoint_Call
  • func (_e *DataCoordCatalog_Expecter) DropCompactionTask(ctx interface{}, task interface{}) *DataCoordCatalog_DropCompactionTask_Call
  • func (_e *DataCoordCatalog_Expecter) DropCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call
  • func (_e *DataCoordCatalog_Expecter) DropImportJob(jobID interface{}) *DataCoordCatalog_DropImportJob_Call
  • func (_e *DataCoordCatalog_Expecter) DropImportTask(taskID interface{}) *DataCoordCatalog_DropImportTask_Call
  • func (_e *DataCoordCatalog_Expecter) DropIndex(ctx interface{}, collID interface{}, dropIdxID interface{}) *DataCoordCatalog_DropIndex_Call
  • func (_e *DataCoordCatalog_Expecter) DropPartitionStatsInfo(ctx interface{}, info interface{}) *DataCoordCatalog_DropPartitionStatsInfo_Call
  • func (_e *DataCoordCatalog_Expecter) DropPreImportTask(taskID interface{}) *DataCoordCatalog_DropPreImportTask_Call
  • func (_e *DataCoordCatalog_Expecter) DropSegment(ctx interface{}, segment interface{}) *DataCoordCatalog_DropSegment_Call
  • func (_e *DataCoordCatalog_Expecter) DropSegmentIndex(ctx interface{}, collID interface{}, partID interface{}, segID interface{}, ...) *DataCoordCatalog_DropSegmentIndex_Call
  • func (_e *DataCoordCatalog_Expecter) GcConfirm(ctx interface{}, collectionID interface{}, partitionID interface{}) *DataCoordCatalog_GcConfirm_Call
  • func (_e *DataCoordCatalog_Expecter) GetCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call
  • func (_e *DataCoordCatalog_Expecter) ListAnalyzeTasks(ctx interface{}) *DataCoordCatalog_ListAnalyzeTasks_Call
  • func (_e *DataCoordCatalog_Expecter) ListChannelCheckpoint(ctx interface{}) *DataCoordCatalog_ListChannelCheckpoint_Call
  • func (_e *DataCoordCatalog_Expecter) ListCompactionTask(ctx interface{}) *DataCoordCatalog_ListCompactionTask_Call
  • func (_e *DataCoordCatalog_Expecter) ListImportJobs() *DataCoordCatalog_ListImportJobs_Call
  • func (_e *DataCoordCatalog_Expecter) ListImportTasks() *DataCoordCatalog_ListImportTasks_Call
  • func (_e *DataCoordCatalog_Expecter) ListIndexes(ctx interface{}) *DataCoordCatalog_ListIndexes_Call
  • func (_e *DataCoordCatalog_Expecter) ListPartitionStatsInfos(ctx interface{}) *DataCoordCatalog_ListPartitionStatsInfos_Call
  • func (_e *DataCoordCatalog_Expecter) ListPreImportTasks() *DataCoordCatalog_ListPreImportTasks_Call
  • func (_e *DataCoordCatalog_Expecter) ListSegmentIndexes(ctx interface{}) *DataCoordCatalog_ListSegmentIndexes_Call
  • func (_e *DataCoordCatalog_Expecter) ListSegments(ctx interface{}) *DataCoordCatalog_ListSegments_Call
  • func (_e *DataCoordCatalog_Expecter) MarkChannelAdded(ctx interface{}, channel interface{}) *DataCoordCatalog_MarkChannelAdded_Call
  • func (_e *DataCoordCatalog_Expecter) MarkChannelDeleted(ctx interface{}, channel interface{}) *DataCoordCatalog_MarkChannelDeleted_Call
  • func (_e *DataCoordCatalog_Expecter) SaveAnalyzeTask(ctx interface{}, task interface{}) *DataCoordCatalog_SaveAnalyzeTask_Call
  • func (_e *DataCoordCatalog_Expecter) SaveChannelCheckpoint(ctx interface{}, vChannel interface{}, pos interface{}) *DataCoordCatalog_SaveChannelCheckpoint_Call
  • func (_e *DataCoordCatalog_Expecter) SaveChannelCheckpoints(ctx interface{}, positions interface{}) *DataCoordCatalog_SaveChannelCheckpoints_Call
  • func (_e *DataCoordCatalog_Expecter) SaveCompactionTask(ctx interface{}, task interface{}) *DataCoordCatalog_SaveCompactionTask_Call
  • func (_e *DataCoordCatalog_Expecter) SaveCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}, ...) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call
  • func (_e *DataCoordCatalog_Expecter) SaveDroppedSegmentsInBatch(ctx interface{}, segments interface{}) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call
  • func (_e *DataCoordCatalog_Expecter) SaveImportJob(job interface{}) *DataCoordCatalog_SaveImportJob_Call
  • func (_e *DataCoordCatalog_Expecter) SaveImportTask(task interface{}) *DataCoordCatalog_SaveImportTask_Call
  • func (_e *DataCoordCatalog_Expecter) SavePartitionStatsInfo(ctx interface{}, info interface{}) *DataCoordCatalog_SavePartitionStatsInfo_Call
  • func (_e *DataCoordCatalog_Expecter) SavePreImportTask(task interface{}) *DataCoordCatalog_SavePreImportTask_Call
  • func (_e *DataCoordCatalog_Expecter) ShouldDropChannel(ctx interface{}, channel interface{}) *DataCoordCatalog_ShouldDropChannel_Call
• type DataCoordCatalog_GcConfirm_Call
  • func (_c *DataCoordCatalog_GcConfirm_Call) Return(_a0 bool) *DataCoordCatalog_GcConfirm_Call
  • func (_c *DataCoordCatalog_GcConfirm_Call) Run(run func(ctx context.Context, collectionID int64, partitionID int64)) *DataCoordCatalog_GcConfirm_Call
  • func (_c *DataCoordCatalog_GcConfirm_Call) RunAndReturn(run func(context.Context, int64, int64) bool) *DataCoordCatalog_GcConfirm_Call
• type DataCoordCatalog_GetCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Return(_a0 int64, _a1 error) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Run(run func(ctx context.Context, collID int64, partID int64, vChannel string)) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) RunAndReturn(run func(context.Context, int64, int64, string) (int64, error)) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call
• type DataCoordCatalog_ListAnalyzeTasks_Call
  • func (_c *DataCoordCatalog_ListAnalyzeTasks_Call) Return(_a0 []*indexpb.AnalyzeTask, _a1 error) *DataCoordCatalog_ListAnalyzeTasks_Call
  • func (_c *DataCoordCatalog_ListAnalyzeTasks_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListAnalyzeTasks_Call
  • func (_c *DataCoordCatalog_ListAnalyzeTasks_Call) RunAndReturn(run func(context.Context) ([]*indexpb.AnalyzeTask, error)) *DataCoordCatalog_ListAnalyzeTasks_Call
• type DataCoordCatalog_ListChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_ListChannelCheckpoint_Call) Return(_a0 map[string]*msgpb.MsgPosition, _a1 error) *DataCoordCatalog_ListChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_ListChannelCheckpoint_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_ListChannelCheckpoint_Call) RunAndReturn(run func(context.Context) (map[string]*msgpb.MsgPosition, error)) *DataCoordCatalog_ListChannelCheckpoint_Call
• type DataCoordCatalog_ListCompactionTask_Call
  • func (_c *DataCoordCatalog_ListCompactionTask_Call) Return(_a0 []*datapb.CompactionTask, _a1 error) *DataCoordCatalog_ListCompactionTask_Call
  • func (_c *DataCoordCatalog_ListCompactionTask_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListCompactionTask_Call
  • func (_c *DataCoordCatalog_ListCompactionTask_Call) RunAndReturn(run func(context.Context) ([]*datapb.CompactionTask, error)) *DataCoordCatalog_ListCompactionTask_Call
• type DataCoordCatalog_ListImportJobs_Call
  • func (_c *DataCoordCatalog_ListImportJobs_Call) Return(_a0 []*datapb.ImportJob, _a1 error) *DataCoordCatalog_ListImportJobs_Call
  • func (_c *DataCoordCatalog_ListImportJobs_Call) Run(run func()) *DataCoordCatalog_ListImportJobs_Call
  • func (_c *DataCoordCatalog_ListImportJobs_Call) RunAndReturn(run func() ([]*datapb.ImportJob, error)) *DataCoordCatalog_ListImportJobs_Call
• type DataCoordCatalog_ListImportTasks_Call
  • func (_c *DataCoordCatalog_ListImportTasks_Call) Return(_a0 []*datapb.ImportTaskV2, _a1 error) *DataCoordCatalog_ListImportTasks_Call
  • func (_c *DataCoordCatalog_ListImportTasks_Call) Run(run func()) *DataCoordCatalog_ListImportTasks_Call
  • func (_c *DataCoordCatalog_ListImportTasks_Call) RunAndReturn(run func() ([]*datapb.ImportTaskV2, error)) *DataCoordCatalog_ListImportTasks_Call
• type DataCoordCatalog_ListIndexes_Call
  • func (_c *DataCoordCatalog_ListIndexes_Call) Return(_a0 []*model.Index, _a1 error) *DataCoordCatalog_ListIndexes_Call
  • func (_c *DataCoordCatalog_ListIndexes_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListIndexes_Call
  • func (_c *DataCoordCatalog_ListIndexes_Call) RunAndReturn(run func(context.Context) ([]*model.Index, error)) *DataCoordCatalog_ListIndexes_Call
• type DataCoordCatalog_ListPartitionStatsInfos_Call
  • func (_c *DataCoordCatalog_ListPartitionStatsInfos_Call) Return(_a0 []*datapb.PartitionStatsInfo, _a1 error) *DataCoordCatalog_ListPartitionStatsInfos_Call
  • func (_c *DataCoordCatalog_ListPartitionStatsInfos_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListPartitionStatsInfos_Call
  • func (_c *DataCoordCatalog_ListPartitionStatsInfos_Call) RunAndReturn(run func(context.Context) ([]*datapb.PartitionStatsInfo, error)) *DataCoordCatalog_ListPartitionStatsInfos_Call
• type DataCoordCatalog_ListPreImportTasks_Call
  • func (_c *DataCoordCatalog_ListPreImportTasks_Call) Return(_a0 []*datapb.PreImportTask, _a1 error) *DataCoordCatalog_ListPreImportTasks_Call
  • func (_c *DataCoordCatalog_ListPreImportTasks_Call) Run(run func()) *DataCoordCatalog_ListPreImportTasks_Call
  • func (_c *DataCoordCatalog_ListPreImportTasks_Call) RunAndReturn(run func() ([]*datapb.PreImportTask, error)) *DataCoordCatalog_ListPreImportTasks_Call
• type DataCoordCatalog_ListSegmentIndexes_Call
  • func (_c *DataCoordCatalog_ListSegmentIndexes_Call) Return(_a0 []*model.SegmentIndex, _a1 error) *DataCoordCatalog_ListSegmentIndexes_Call
  • func (_c *DataCoordCatalog_ListSegmentIndexes_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListSegmentIndexes_Call
  • func (_c *DataCoordCatalog_ListSegmentIndexes_Call) RunAndReturn(run func(context.Context) ([]*model.SegmentIndex, error)) *DataCoordCatalog_ListSegmentIndexes_Call
• type DataCoordCatalog_ListSegments_Call
  • func (_c *DataCoordCatalog_ListSegments_Call) Return(_a0 []*datapb.SegmentInfo, _a1 error) *DataCoordCatalog_ListSegments_Call
  • func (_c *DataCoordCatalog_ListSegments_Call) Run(run func(ctx context.Context)) *DataCoordCatalog_ListSegments_Call
  • func (_c *DataCoordCatalog_ListSegments_Call) RunAndReturn(run func(context.Context) ([]*datapb.SegmentInfo, error)) *DataCoordCatalog_ListSegments_Call
• type DataCoordCatalog_MarkChannelAdded_Call
  • func (_c *DataCoordCatalog_MarkChannelAdded_Call) Return(_a0 error) *DataCoordCatalog_MarkChannelAdded_Call
  • func (_c *DataCoordCatalog_MarkChannelAdded_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_MarkChannelAdded_Call
  • func (_c *DataCoordCatalog_MarkChannelAdded_Call) RunAndReturn(run func(context.Context, string) error) *DataCoordCatalog_MarkChannelAdded_Call
• type DataCoordCatalog_MarkChannelDeleted_Call
  • func (_c *DataCoordCatalog_MarkChannelDeleted_Call) Return(_a0 error) *DataCoordCatalog_MarkChannelDeleted_Call
  • func (_c *DataCoordCatalog_MarkChannelDeleted_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_MarkChannelDeleted_Call
  • func (_c *DataCoordCatalog_MarkChannelDeleted_Call) RunAndReturn(run func(context.Context, string) error) *DataCoordCatalog_MarkChannelDeleted_Call
• type DataCoordCatalog_SaveAnalyzeTask_Call
  • func (_c *DataCoordCatalog_SaveAnalyzeTask_Call) Return(_a0 error) *DataCoordCatalog_SaveAnalyzeTask_Call
  • func (_c *DataCoordCatalog_SaveAnalyzeTask_Call) Run(run func(ctx context.Context, task *indexpb.AnalyzeTask)) *DataCoordCatalog_SaveAnalyzeTask_Call
  • func (_c *DataCoordCatalog_SaveAnalyzeTask_Call) RunAndReturn(run func(context.Context, *indexpb.AnalyzeTask) error) *DataCoordCatalog_SaveAnalyzeTask_Call
• type DataCoordCatalog_SaveChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoint_Call) Return(_a0 error) *DataCoordCatalog_SaveChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoint_Call) Run(run func(ctx context.Context, vChannel string, pos *msgpb.MsgPosition)) *DataCoordCatalog_SaveChannelCheckpoint_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoint_Call) RunAndReturn(run func(context.Context, string, *msgpb.MsgPosition) error) *DataCoordCatalog_SaveChannelCheckpoint_Call
• type DataCoordCatalog_SaveChannelCheckpoints_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoints_Call) Return(_a0 error) *DataCoordCatalog_SaveChannelCheckpoints_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoints_Call) Run(run func(ctx context.Context, positions []*msgpb.MsgPosition)) *DataCoordCatalog_SaveChannelCheckpoints_Call
  • func (_c *DataCoordCatalog_SaveChannelCheckpoints_Call) RunAndReturn(run func(context.Context, []*msgpb.MsgPosition) error) *DataCoordCatalog_SaveChannelCheckpoints_Call
• type DataCoordCatalog_SaveCompactionTask_Call
  • func (_c *DataCoordCatalog_SaveCompactionTask_Call) Return(_a0 error) *DataCoordCatalog_SaveCompactionTask_Call
  • func (_c *DataCoordCatalog_SaveCompactionTask_Call) Run(run func(ctx context.Context, task *datapb.CompactionTask)) *DataCoordCatalog_SaveCompactionTask_Call
  • func (_c *DataCoordCatalog_SaveCompactionTask_Call) RunAndReturn(run func(context.Context, *datapb.CompactionTask) error) *DataCoordCatalog_SaveCompactionTask_Call
• type DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) Return(_a0 error) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) Run(...) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call
  • func (_c *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) RunAndReturn(run func(context.Context, int64, int64, string, int64) error) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call
• type DataCoordCatalog_SaveDroppedSegmentsInBatch_Call
  • func (_c *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) Return(_a0 error) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call
  • func (_c *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) Run(run func(ctx context.Context, segments []*datapb.SegmentInfo)) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call
  • func (_c *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) RunAndReturn(run func(context.Context, []*datapb.SegmentInfo) error) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call
• type DataCoordCatalog_SaveImportJob_Call
  • func (_c *DataCoordCatalog_SaveImportJob_Call) Return(_a0 error) *DataCoordCatalog_SaveImportJob_Call
  • func (_c *DataCoordCatalog_SaveImportJob_Call) Run(run func(job *datapb.ImportJob)) *DataCoordCatalog_SaveImportJob_Call
  • func (_c *DataCoordCatalog_SaveImportJob_Call) RunAndReturn(run func(*datapb.ImportJob) error) *DataCoordCatalog_SaveImportJob_Call
• type DataCoordCatalog_SaveImportTask_Call
  • func (_c *DataCoordCatalog_SaveImportTask_Call) Return(_a0 error) *DataCoordCatalog_SaveImportTask_Call
  • func (_c *DataCoordCatalog_SaveImportTask_Call) Run(run func(task *datapb.ImportTaskV2)) *DataCoordCatalog_SaveImportTask_Call
  • func (_c *DataCoordCatalog_SaveImportTask_Call) RunAndReturn(run func(*datapb.ImportTaskV2) error) *DataCoordCatalog_SaveImportTask_Call
• type DataCoordCatalog_SavePartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_SavePartitionStatsInfo_Call) Return(_a0 error) *DataCoordCatalog_SavePartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_SavePartitionStatsInfo_Call) Run(run func(ctx context.Context, info *datapb.PartitionStatsInfo)) *DataCoordCatalog_SavePartitionStatsInfo_Call
  • func (_c *DataCoordCatalog_SavePartitionStatsInfo_Call) RunAndReturn(run func(context.Context, *datapb.PartitionStatsInfo) error) *DataCoordCatalog_SavePartitionStatsInfo_Call
• type DataCoordCatalog_SavePreImportTask_Call
  • func (_c *DataCoordCatalog_SavePreImportTask_Call) Return(_a0 error) *DataCoordCatalog_SavePreImportTask_Call
  • func (_c *DataCoordCatalog_SavePreImportTask_Call) Run(run func(task *datapb.PreImportTask)) *DataCoordCatalog_SavePreImportTask_Call
  • func (_c *DataCoordCatalog_SavePreImportTask_Call) RunAndReturn(run func(*datapb.PreImportTask) error) *DataCoordCatalog_SavePreImportTask_Call
• type DataCoordCatalog_ShouldDropChannel_Call
  • func (_c *DataCoordCatalog_ShouldDropChannel_Call) Return(_a0 bool) *DataCoordCatalog_ShouldDropChannel_Call
  • func (_c *DataCoordCatalog_ShouldDropChannel_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_ShouldDropChannel_Call
  • func (_c *DataCoordCatalog_ShouldDropChannel_Call) RunAndReturn(run func(context.Context, string) bool) *DataCoordCatalog_ShouldDropChannel_Call
• type QueryCoordCatalog
  • func NewQueryCoordCatalog(t interface{ ... }) *QueryCoordCatalog
  • func (_m *QueryCoordCatalog) EXPECT() *QueryCoordCatalog_Expecter
  • func (_m *QueryCoordCatalog) GetCollectionTargets() (map[int64]*querypb.CollectionTarget, error)
  • func (_m *QueryCoordCatalog) GetCollections() ([]*querypb.CollectionLoadInfo, error)
  • func (_m *QueryCoordCatalog) GetPartitions() (map[int64][]*querypb.PartitionLoadInfo, error)
  • func (_m *QueryCoordCatalog) GetReplicas() ([]*querypb.Replica, error)
  • func (_m *QueryCoordCatalog) GetResourceGroups() ([]*querypb.ResourceGroup, error)
  • func (_m *QueryCoordCatalog) ReleaseCollection(collection int64) error
  • func (_m *QueryCoordCatalog) ReleasePartition(collection int64, partitions ...int64) error
  • func (_m *QueryCoordCatalog) ReleaseReplica(collection int64, replica int64) error
  • func (_m *QueryCoordCatalog) ReleaseReplicas(collectionID int64) error
  • func (_m *QueryCoordCatalog) RemoveCollectionTarget(collectionID int64) error
  • func (_m *QueryCoordCatalog) RemoveResourceGroup(rgName string) error
  • func (_m *QueryCoordCatalog) SaveCollection(collection *querypb.CollectionLoadInfo, ...) error
  • func (_m *QueryCoordCatalog) SaveCollectionTargets(target ...*querypb.CollectionTarget) error
  • func (_m *QueryCoordCatalog) SavePartition(info ...*querypb.PartitionLoadInfo) error
  • func (_m *QueryCoordCatalog) SaveReplica(replicas ...*querypb.Replica) error
  • func (_m *QueryCoordCatalog) SaveResourceGroup(rgs ...*querypb.ResourceGroup) error
• type QueryCoordCatalog_Expecter
  • func (_e *QueryCoordCatalog_Expecter) GetCollectionTargets() *QueryCoordCatalog_GetCollectionTargets_Call
  • func (_e *QueryCoordCatalog_Expecter) GetCollections() *QueryCoordCatalog_GetCollections_Call
  • func (_e *QueryCoordCatalog_Expecter) GetPartitions() *QueryCoordCatalog_GetPartitions_Call
  • func (_e *QueryCoordCatalog_Expecter) GetReplicas() *QueryCoordCatalog_GetReplicas_Call
  • func (_e *QueryCoordCatalog_Expecter) GetResourceGroups() *QueryCoordCatalog_GetResourceGroups_Call
  • func (_e *QueryCoordCatalog_Expecter) ReleaseCollection(collection interface{}) *QueryCoordCatalog_ReleaseCollection_Call
  • func (_e *QueryCoordCatalog_Expecter) ReleasePartition(collection interface{}, partitions ...interface{}) *QueryCoordCatalog_ReleasePartition_Call
  • func (_e *QueryCoordCatalog_Expecter) ReleaseReplica(collection interface{}, replica interface{}) *QueryCoordCatalog_ReleaseReplica_Call
  • func (_e *QueryCoordCatalog_Expecter) ReleaseReplicas(collectionID interface{}) *QueryCoordCatalog_ReleaseReplicas_Call
  • func (_e *QueryCoordCatalog_Expecter) RemoveCollectionTarget(collectionID interface{}) *QueryCoordCatalog_RemoveCollectionTarget_Call
  • func (_e *QueryCoordCatalog_Expecter) RemoveResourceGroup(rgName interface{}) *QueryCoordCatalog_RemoveResourceGroup_Call
  • func (_e *QueryCoordCatalog_Expecter) SaveCollection(collection interface{}, partitions ...interface{}) *QueryCoordCatalog_SaveCollection_Call
  • func (_e *QueryCoordCatalog_Expecter) SaveCollectionTargets(target ...interface{}) *QueryCoordCatalog_SaveCollectionTargets_Call
  • func (_e *QueryCoordCatalog_Expecter) SavePartition(info ...interface{}) *QueryCoordCatalog_SavePartition_Call
  • func (_e *QueryCoordCatalog_Expecter) SaveReplica(replicas ...interface{}) *QueryCoordCatalog_SaveReplica_Call
  • func (_e *QueryCoordCatalog_Expecter) SaveResourceGroup(rgs ...interface{}) *QueryCoordCatalog_SaveResourceGroup_Call
• type QueryCoordCatalog_GetCollectionTargets_Call
  • func (_c *QueryCoordCatalog_GetCollectionTargets_Call) Return(_a0 map[int64]*querypb.CollectionTarget, _a1 error) *QueryCoordCatalog_GetCollectionTargets_Call
  • func (_c *QueryCoordCatalog_GetCollectionTargets_Call) Run(run func()) *QueryCoordCatalog_GetCollectionTargets_Call
  • func (_c *QueryCoordCatalog_GetCollectionTargets_Call) RunAndReturn(run func() (map[int64]*querypb.CollectionTarget, error)) *QueryCoordCatalog_GetCollectionTargets_Call
• type QueryCoordCatalog_GetCollections_Call
  • func (_c *QueryCoordCatalog_GetCollections_Call) Return(_a0 []*querypb.CollectionLoadInfo, _a1 error) *QueryCoordCatalog_GetCollections_Call
  • func (_c *QueryCoordCatalog_GetCollections_Call) Run(run func()) *QueryCoordCatalog_GetCollections_Call
  • func (_c *QueryCoordCatalog_GetCollections_Call) RunAndReturn(run func() ([]*querypb.CollectionLoadInfo, error)) *QueryCoordCatalog_GetCollections_Call
• type QueryCoordCatalog_GetPartitions_Call
  • func (_c *QueryCoordCatalog_GetPartitions_Call) Return(_a0 map[int64][]*querypb.PartitionLoadInfo, _a1 error) *QueryCoordCatalog_GetPartitions_Call
  • func (_c *QueryCoordCatalog_GetPartitions_Call) Run(run func()) *QueryCoordCatalog_GetPartitions_Call
  • func (_c *QueryCoordCatalog_GetPartitions_Call) RunAndReturn(run func() (map[int64][]*querypb.PartitionLoadInfo, error)) *QueryCoordCatalog_GetPartitions_Call
• type QueryCoordCatalog_GetReplicas_Call
  • func (_c *QueryCoordCatalog_GetReplicas_Call) Return(_a0 []*querypb.Replica, _a1 error) *QueryCoordCatalog_GetReplicas_Call
  • func (_c *QueryCoordCatalog_GetReplicas_Call) Run(run func()) *QueryCoordCatalog_GetReplicas_Call
  • func (_c *QueryCoordCatalog_GetReplicas_Call) RunAndReturn(run func() ([]*querypb.Replica, error)) *QueryCoordCatalog_GetReplicas_Call
• type QueryCoordCatalog_GetResourceGroups_Call
  • func (_c *QueryCoordCatalog_GetResourceGroups_Call) Return(_a0 []*querypb.ResourceGroup, _a1 error) *QueryCoordCatalog_GetResourceGroups_Call
  • func (_c *QueryCoordCatalog_GetResourceGroups_Call) Run(run func()) *QueryCoordCatalog_GetResourceGroups_Call
  • func (_c *QueryCoordCatalog_GetResourceGroups_Call) RunAndReturn(run func() ([]*querypb.ResourceGroup, error)) *QueryCoordCatalog_GetResourceGroups_Call
• type QueryCoordCatalog_ReleaseCollection_Call
  • func (_c *QueryCoordCatalog_ReleaseCollection_Call) Return(_a0 error) *QueryCoordCatalog_ReleaseCollection_Call
  • func (_c *QueryCoordCatalog_ReleaseCollection_Call) Run(run func(collection int64)) *QueryCoordCatalog_ReleaseCollection_Call
  • func (_c *QueryCoordCatalog_ReleaseCollection_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_ReleaseCollection_Call
• type QueryCoordCatalog_ReleasePartition_Call
  • func (_c *QueryCoordCatalog_ReleasePartition_Call) Return(_a0 error) *QueryCoordCatalog_ReleasePartition_Call
  • func (_c *QueryCoordCatalog_ReleasePartition_Call) Run(run func(collection int64, partitions ...int64)) *QueryCoordCatalog_ReleasePartition_Call
  • func (_c *QueryCoordCatalog_ReleasePartition_Call) RunAndReturn(run func(int64, ...int64) error) *QueryCoordCatalog_ReleasePartition_Call
• type QueryCoordCatalog_ReleaseReplica_Call
  • func (_c *QueryCoordCatalog_ReleaseReplica_Call) Return(_a0 error) *QueryCoordCatalog_ReleaseReplica_Call
  • func (_c *QueryCoordCatalog_ReleaseReplica_Call) Run(run func(collection int64, replica int64)) *QueryCoordCatalog_ReleaseReplica_Call
  • func (_c *QueryCoordCatalog_ReleaseReplica_Call) RunAndReturn(run func(int64, int64) error) *QueryCoordCatalog_ReleaseReplica_Call
• type QueryCoordCatalog_ReleaseReplicas_Call
  • func (_c *QueryCoordCatalog_ReleaseReplicas_Call) Return(_a0 error) *QueryCoordCatalog_ReleaseReplicas_Call
  • func (_c *QueryCoordCatalog_ReleaseReplicas_Call) Run(run func(collectionID int64)) *QueryCoordCatalog_ReleaseReplicas_Call
  • func (_c *QueryCoordCatalog_ReleaseReplicas_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_ReleaseReplicas_Call
• type QueryCoordCatalog_RemoveCollectionTarget_Call
  • func (_c *QueryCoordCatalog_RemoveCollectionTarget_Call) Return(_a0 error) *QueryCoordCatalog_RemoveCollectionTarget_Call
  • func (_c *QueryCoordCatalog_RemoveCollectionTarget_Call) Run(run func(collectionID int64)) *QueryCoordCatalog_RemoveCollectionTarget_Call
  • func (_c *QueryCoordCatalog_RemoveCollectionTarget_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_RemoveCollectionTarget_Call
• type QueryCoordCatalog_RemoveResourceGroup_Call
  • func (_c *QueryCoordCatalog_RemoveResourceGroup_Call) Return(_a0 error) *QueryCoordCatalog_RemoveResourceGroup_Call
  • func (_c *QueryCoordCatalog_RemoveResourceGroup_Call) Run(run func(rgName string)) *QueryCoordCatalog_RemoveResourceGroup_Call
  • func (_c *QueryCoordCatalog_RemoveResourceGroup_Call) RunAndReturn(run func(string) error) *QueryCoordCatalog_RemoveResourceGroup_Call
• type QueryCoordCatalog_SaveCollectionTargets_Call
  • func (_c *QueryCoordCatalog_SaveCollectionTargets_Call) Return(_a0 error) *QueryCoordCatalog_SaveCollectionTargets_Call
  • func (_c *QueryCoordCatalog_SaveCollectionTargets_Call) Run(run func(target ...*querypb.CollectionTarget)) *QueryCoordCatalog_SaveCollectionTargets_Call
  • func (_c *QueryCoordCatalog_SaveCollectionTargets_Call) RunAndReturn(run func(...*querypb.CollectionTarget) error) *QueryCoordCatalog_SaveCollectionTargets_Call
• type QueryCoordCatalog_SaveCollection_Call
  • func (_c *QueryCoordCatalog_SaveCollection_Call) Return(_a0 error) *QueryCoordCatalog_SaveCollection_Call
  • func (_c *QueryCoordCatalog_SaveCollection_Call) Run(run func(collection *querypb.CollectionLoadInfo, ...)) *QueryCoordCatalog_SaveCollection_Call
  • func (_c *QueryCoordCatalog_SaveCollection_Call) RunAndReturn(run func(*querypb.CollectionLoadInfo, ...*querypb.PartitionLoadInfo) error) *QueryCoordCatalog_SaveCollection_Call
• type QueryCoordCatalog_SavePartition_Call
  • func (_c *QueryCoordCatalog_SavePartition_Call) Return(_a0 error) *QueryCoordCatalog_SavePartition_Call
  • func (_c *QueryCoordCatalog_SavePartition_Call) Run(run func(info ...*querypb.PartitionLoadInfo)) *QueryCoordCatalog_SavePartition_Call
  • func (_c *QueryCoordCatalog_SavePartition_Call) RunAndReturn(run func(...*querypb.PartitionLoadInfo) error) *QueryCoordCatalog_SavePartition_Call
• type QueryCoordCatalog_SaveReplica_Call
  • func (_c *QueryCoordCatalog_SaveReplica_Call) Return(_a0 error) *QueryCoordCatalog_SaveReplica_Call
  • func (_c *QueryCoordCatalog_SaveReplica_Call) Run(run func(replicas ...*querypb.Replica)) *QueryCoordCatalog_SaveReplica_Call
  • func (_c *QueryCoordCatalog_SaveReplica_Call) RunAndReturn(run func(...*querypb.Replica) error) *QueryCoordCatalog_SaveReplica_Call
• type QueryCoordCatalog_SaveResourceGroup_Call
  • func (_c *QueryCoordCatalog_SaveResourceGroup_Call) Return(_a0 error) *QueryCoordCatalog_SaveResourceGroup_Call
  • func (_c *QueryCoordCatalog_SaveResourceGroup_Call) Run(run func(rgs ...*querypb.ResourceGroup)) *QueryCoordCatalog_SaveResourceGroup_Call
  • func (_c *QueryCoordCatalog_SaveResourceGroup_Call) RunAndReturn(run func(...*querypb.ResourceGroup) error) *QueryCoordCatalog_SaveResourceGroup_Call
• type RootCoordCatalog
  • func NewRootCoordCatalog(t interface{ ... }) *RootCoordCatalog
  • func (_m *RootCoordCatalog) AlterAlias(ctx context.Context, alias *model.Alias, ts uint64) error
  • func (_m *RootCoordCatalog) AlterCollection(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, ...) error
  • func (_m *RootCoordCatalog) AlterCredential(ctx context.Context, credential *model.Credential) error
  • func (_m *RootCoordCatalog) AlterDatabase(ctx context.Context, newDB *model.Database, ts uint64) error
  • func (_m *RootCoordCatalog) AlterGrant(ctx context.Context, tenant string, entity *milvuspb.GrantEntity, ...) error
  • func (_m *RootCoordCatalog) AlterPartition(ctx context.Context, dbID int64, oldPart *model.Partition, ...) error
  • func (_m *RootCoordCatalog) AlterUserRole(ctx context.Context, tenant string, userEntity *milvuspb.UserEntity, ...) error
  • func (_m *RootCoordCatalog) Close()
  • func (_m *RootCoordCatalog) CollectionExists(ctx context.Context, dbID int64, collectionID int64, ts uint64) bool
  • func (_m *RootCoordCatalog) CreateAlias(ctx context.Context, alias *model.Alias, ts uint64) error
  • func (_m *RootCoordCatalog) CreateCollection(ctx context.Context, collectionInfo *model.Collection, ts uint64) error
  • func (_m *RootCoordCatalog) CreateCredential(ctx context.Context, credential *model.Credential) error
  • func (_m *RootCoordCatalog) CreateDatabase(ctx context.Context, db *model.Database, ts uint64) error
  • func (_m *RootCoordCatalog) CreatePartition(ctx context.Context, dbID int64, partition *model.Partition, ts uint64) error
  • func (_m *RootCoordCatalog) CreateRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity) error
  • func (_m *RootCoordCatalog) DeleteGrant(ctx context.Context, tenant string, role *milvuspb.RoleEntity) error
  • func (_m *RootCoordCatalog) DropAlias(ctx context.Context, dbID int64, alias string, ts uint64) error
  • func (_m *RootCoordCatalog) DropCollection(ctx context.Context, collectionInfo *model.Collection, ts uint64) error
  • func (_m *RootCoordCatalog) DropCredential(ctx context.Context, username string) error
  • func (_m *RootCoordCatalog) DropDatabase(ctx context.Context, dbID int64, ts uint64) error
  • func (_m *RootCoordCatalog) DropPartition(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ...) error
  • func (_m *RootCoordCatalog) DropRole(ctx context.Context, tenant string, roleName string) error
  • func (_m *RootCoordCatalog) EXPECT() *RootCoordCatalog_Expecter
  • func (_m *RootCoordCatalog) GetCollectionByID(ctx context.Context, dbID int64, ts uint64, collectionID int64) (*model.Collection, error)
  • func (_m *RootCoordCatalog) GetCollectionByName(ctx context.Context, dbID int64, collectionName string, ts uint64) (*model.Collection, error)
  • func (_m *RootCoordCatalog) GetCredential(ctx context.Context, username string) (*model.Credential, error)
  • func (_m *RootCoordCatalog) ListAliases(ctx context.Context, dbID int64, ts uint64) ([]*model.Alias, error)
  • func (_m *RootCoordCatalog) ListCollections(ctx context.Context, dbID int64, ts uint64) ([]*model.Collection, error)
  • func (_m *RootCoordCatalog) ListCredentials(ctx context.Context) ([]string, error)
  • func (_m *RootCoordCatalog) ListDatabases(ctx context.Context, ts uint64) ([]*model.Database, error)
  • func (_m *RootCoordCatalog) ListGrant(ctx context.Context, tenant string, entity *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)
  • func (_m *RootCoordCatalog) ListPolicy(ctx context.Context, tenant string) ([]string, error)
  • func (_m *RootCoordCatalog) ListRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, ...) ([]*milvuspb.RoleResult, error)
  • func (_m *RootCoordCatalog) ListUser(ctx context.Context, tenant string, entity *milvuspb.UserEntity, ...) ([]*milvuspb.UserResult, error)
  • func (_m *RootCoordCatalog) ListUserRole(ctx context.Context, tenant string) ([]string, error)
• type RootCoordCatalog_AlterAlias_Call
  • func (_c *RootCoordCatalog_AlterAlias_Call) Return(_a0 error) *RootCoordCatalog_AlterAlias_Call
  • func (_c *RootCoordCatalog_AlterAlias_Call) Run(run func(ctx context.Context, alias *model.Alias, ts uint64)) *RootCoordCatalog_AlterAlias_Call
  • func (_c *RootCoordCatalog_AlterAlias_Call) RunAndReturn(run func(context.Context, *model.Alias, uint64) error) *RootCoordCatalog_AlterAlias_Call
• type RootCoordCatalog_AlterCollection_Call
  • func (_c *RootCoordCatalog_AlterCollection_Call) Return(_a0 error) *RootCoordCatalog_AlterCollection_Call
  • func (_c *RootCoordCatalog_AlterCollection_Call) Run(...) *RootCoordCatalog_AlterCollection_Call
  • func (_c *RootCoordCatalog_AlterCollection_Call) RunAndReturn(...) *RootCoordCatalog_AlterCollection_Call
• type RootCoordCatalog_AlterCredential_Call
  • func (_c *RootCoordCatalog_AlterCredential_Call) Return(_a0 error) *RootCoordCatalog_AlterCredential_Call
  • func (_c *RootCoordCatalog_AlterCredential_Call) Run(run func(ctx context.Context, credential *model.Credential)) *RootCoordCatalog_AlterCredential_Call
  • func (_c *RootCoordCatalog_AlterCredential_Call) RunAndReturn(run func(context.Context, *model.Credential) error) *RootCoordCatalog_AlterCredential_Call
• type RootCoordCatalog_AlterDatabase_Call
  • func (_c *RootCoordCatalog_AlterDatabase_Call) Return(_a0 error) *RootCoordCatalog_AlterDatabase_Call
  • func (_c *RootCoordCatalog_AlterDatabase_Call) Run(run func(ctx context.Context, newDB *model.Database, ts uint64)) *RootCoordCatalog_AlterDatabase_Call
  • func (_c *RootCoordCatalog_AlterDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *RootCoordCatalog_AlterDatabase_Call
• type RootCoordCatalog_AlterGrant_Call
  • func (_c *RootCoordCatalog_AlterGrant_Call) Return(_a0 error) *RootCoordCatalog_AlterGrant_Call
  • func (_c *RootCoordCatalog_AlterGrant_Call) Run(...) *RootCoordCatalog_AlterGrant_Call
  • func (_c *RootCoordCatalog_AlterGrant_Call) RunAndReturn(...) *RootCoordCatalog_AlterGrant_Call
• type RootCoordCatalog_AlterPartition_Call
  • func (_c *RootCoordCatalog_AlterPartition_Call) Return(_a0 error) *RootCoordCatalog_AlterPartition_Call
  • func (_c *RootCoordCatalog_AlterPartition_Call) Run(run func(ctx context.Context, dbID int64, oldPart *model.Partition, ...)) *RootCoordCatalog_AlterPartition_Call
  • func (_c *RootCoordCatalog_AlterPartition_Call) RunAndReturn(...) *RootCoordCatalog_AlterPartition_Call
• type RootCoordCatalog_AlterUserRole_Call
  • func (_c *RootCoordCatalog_AlterUserRole_Call) Return(_a0 error) *RootCoordCatalog_AlterUserRole_Call
  • func (_c *RootCoordCatalog_AlterUserRole_Call) Run(...) *RootCoordCatalog_AlterUserRole_Call
  • func (_c *RootCoordCatalog_AlterUserRole_Call) RunAndReturn(...) *RootCoordCatalog_AlterUserRole_Call
• type RootCoordCatalog_Close_Call
  • func (_c *RootCoordCatalog_Close_Call) Return() *RootCoordCatalog_Close_Call
  • func (_c *RootCoordCatalog_Close_Call) Run(run func()) *RootCoordCatalog_Close_Call
  • func (_c *RootCoordCatalog_Close_Call) RunAndReturn(run func()) *RootCoordCatalog_Close_Call
• type RootCoordCatalog_CollectionExists_Call
  • func (_c *RootCoordCatalog_CollectionExists_Call) Return(_a0 bool) *RootCoordCatalog_CollectionExists_Call
  • func (_c *RootCoordCatalog_CollectionExists_Call) Run(run func(ctx context.Context, dbID int64, collectionID int64, ts uint64)) *RootCoordCatalog_CollectionExists_Call
  • func (_c *RootCoordCatalog_CollectionExists_Call) RunAndReturn(run func(context.Context, int64, int64, uint64) bool) *RootCoordCatalog_CollectionExists_Call
• type RootCoordCatalog_CreateAlias_Call
  • func (_c *RootCoordCatalog_CreateAlias_Call) Return(_a0 error) *RootCoordCatalog_CreateAlias_Call
  • func (_c *RootCoordCatalog_CreateAlias_Call) Run(run func(ctx context.Context, alias *model.Alias, ts uint64)) *RootCoordCatalog_CreateAlias_Call
  • func (_c *RootCoordCatalog_CreateAlias_Call) RunAndReturn(run func(context.Context, *model.Alias, uint64) error) *RootCoordCatalog_CreateAlias_Call
• type RootCoordCatalog_CreateCollection_Call
  • func (_c *RootCoordCatalog_CreateCollection_Call) Return(_a0 error) *RootCoordCatalog_CreateCollection_Call
  • func (_c *RootCoordCatalog_CreateCollection_Call) Run(run func(ctx context.Context, collectionInfo *model.Collection, ts uint64)) *RootCoordCatalog_CreateCollection_Call
  • func (_c *RootCoordCatalog_CreateCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, uint64) error) *RootCoordCatalog_CreateCollection_Call
• type RootCoordCatalog_CreateCredential_Call
  • func (_c *RootCoordCatalog_CreateCredential_Call) Return(_a0 error) *RootCoordCatalog_CreateCredential_Call
  • func (_c *RootCoordCatalog_CreateCredential_Call) Run(run func(ctx context.Context, credential *model.Credential)) *RootCoordCatalog_CreateCredential_Call
  • func (_c *RootCoordCatalog_CreateCredential_Call) RunAndReturn(run func(context.Context, *model.Credential) error) *RootCoordCatalog_CreateCredential_Call
• type RootCoordCatalog_CreateDatabase_Call
  • func (_c *RootCoordCatalog_CreateDatabase_Call) Return(_a0 error) *RootCoordCatalog_CreateDatabase_Call
  • func (_c *RootCoordCatalog_CreateDatabase_Call) Run(run func(ctx context.Context, db *model.Database, ts uint64)) *RootCoordCatalog_CreateDatabase_Call
  • func (_c *RootCoordCatalog_CreateDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *RootCoordCatalog_CreateDatabase_Call
• type RootCoordCatalog_CreatePartition_Call
  • func (_c *RootCoordCatalog_CreatePartition_Call) Return(_a0 error) *RootCoordCatalog_CreatePartition_Call
  • func (_c *RootCoordCatalog_CreatePartition_Call) Run(...) *RootCoordCatalog_CreatePartition_Call
  • func (_c *RootCoordCatalog_CreatePartition_Call) RunAndReturn(run func(context.Context, int64, *model.Partition, uint64) error) *RootCoordCatalog_CreatePartition_Call
• type RootCoordCatalog_CreateRole_Call
  • func (_c *RootCoordCatalog_CreateRole_Call) Return(_a0 error) *RootCoordCatalog_CreateRole_Call
  • func (_c *RootCoordCatalog_CreateRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity)) *RootCoordCatalog_CreateRole_Call
  • func (_c *RootCoordCatalog_CreateRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *RootCoordCatalog_CreateRole_Call
• type RootCoordCatalog_DeleteGrant_Call
  • func (_c *RootCoordCatalog_DeleteGrant_Call) Return(_a0 error) *RootCoordCatalog_DeleteGrant_Call
  • func (_c *RootCoordCatalog_DeleteGrant_Call) Run(run func(ctx context.Context, tenant string, role *milvuspb.RoleEntity)) *RootCoordCatalog_DeleteGrant_Call
  • func (_c *RootCoordCatalog_DeleteGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *RootCoordCatalog_DeleteGrant_Call
• type RootCoordCatalog_DropAlias_Call
  • func (_c *RootCoordCatalog_DropAlias_Call) Return(_a0 error) *RootCoordCatalog_DropAlias_Call
  • func (_c *RootCoordCatalog_DropAlias_Call) Run(run func(ctx context.Context, dbID int64, alias string, ts uint64)) *RootCoordCatalog_DropAlias_Call
  • func (_c *RootCoordCatalog_DropAlias_Call) RunAndReturn(run func(context.Context, int64, string, uint64) error) *RootCoordCatalog_DropAlias_Call
• type RootCoordCatalog_DropCollection_Call
  • func (_c *RootCoordCatalog_DropCollection_Call) Return(_a0 error) *RootCoordCatalog_DropCollection_Call
  • func (_c *RootCoordCatalog_DropCollection_Call) Run(run func(ctx context.Context, collectionInfo *model.Collection, ts uint64)) *RootCoordCatalog_DropCollection_Call
  • func (_c *RootCoordCatalog_DropCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, uint64) error) *RootCoordCatalog_DropCollection_Call
• type RootCoordCatalog_DropCredential_Call
  • func (_c *RootCoordCatalog_DropCredential_Call) Return(_a0 error) *RootCoordCatalog_DropCredential_Call
  • func (_c *RootCoordCatalog_DropCredential_Call) Run(run func(ctx context.Context, username string)) *RootCoordCatalog_DropCredential_Call
  • func (_c *RootCoordCatalog_DropCredential_Call) RunAndReturn(run func(context.Context, string) error) *RootCoordCatalog_DropCredential_Call
• type RootCoordCatalog_DropDatabase_Call
  • func (_c *RootCoordCatalog_DropDatabase_Call) Return(_a0 error) *RootCoordCatalog_DropDatabase_Call
  • func (_c *RootCoordCatalog_DropDatabase_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_DropDatabase_Call
  • func (_c *RootCoordCatalog_DropDatabase_Call) RunAndReturn(run func(context.Context, int64, uint64) error) *RootCoordCatalog_DropDatabase_Call
• type RootCoordCatalog_DropPartition_Call
  • func (_c *RootCoordCatalog_DropPartition_Call) Return(_a0 error) *RootCoordCatalog_DropPartition_Call
  • func (_c *RootCoordCatalog_DropPartition_Call) Run(...) *RootCoordCatalog_DropPartition_Call
  • func (_c *RootCoordCatalog_DropPartition_Call) RunAndReturn(run func(context.Context, int64, int64, int64, uint64) error) *RootCoordCatalog_DropPartition_Call
• type RootCoordCatalog_DropRole_Call
  • func (_c *RootCoordCatalog_DropRole_Call) Return(_a0 error) *RootCoordCatalog_DropRole_Call
  • func (_c *RootCoordCatalog_DropRole_Call) Run(run func(ctx context.Context, tenant string, roleName string)) *RootCoordCatalog_DropRole_Call
  • func (_c *RootCoordCatalog_DropRole_Call) RunAndReturn(run func(context.Context, string, string) error) *RootCoordCatalog_DropRole_Call
• type RootCoordCatalog_Expecter
  • func (_e *RootCoordCatalog_Expecter) AlterAlias(ctx interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_AlterAlias_Call
  • func (_e *RootCoordCatalog_Expecter) AlterCollection(ctx interface{}, oldColl interface{}, newColl interface{}, ...) *RootCoordCatalog_AlterCollection_Call
  • func (_e *RootCoordCatalog_Expecter) AlterCredential(ctx interface{}, credential interface{}) *RootCoordCatalog_AlterCredential_Call
  • func (_e *RootCoordCatalog_Expecter) AlterDatabase(ctx interface{}, newDB interface{}, ts interface{}) *RootCoordCatalog_AlterDatabase_Call
  • func (_e *RootCoordCatalog_Expecter) AlterGrant(ctx interface{}, tenant interface{}, entity interface{}, ...) *RootCoordCatalog_AlterGrant_Call
  • func (_e *RootCoordCatalog_Expecter) AlterPartition(ctx interface{}, dbID interface{}, oldPart interface{}, newPart interface{}, ...) *RootCoordCatalog_AlterPartition_Call
  • func (_e *RootCoordCatalog_Expecter) AlterUserRole(ctx interface{}, tenant interface{}, userEntity interface{}, ...) *RootCoordCatalog_AlterUserRole_Call
  • func (_e *RootCoordCatalog_Expecter) Close() *RootCoordCatalog_Close_Call
  • func (_e *RootCoordCatalog_Expecter) CollectionExists(ctx interface{}, dbID interface{}, collectionID interface{}, ts interface{}) *RootCoordCatalog_CollectionExists_Call
  • func (_e *RootCoordCatalog_Expecter) CreateAlias(ctx interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_CreateAlias_Call
  • func (_e *RootCoordCatalog_Expecter) CreateCollection(ctx interface{}, collectionInfo interface{}, ts interface{}) *RootCoordCatalog_CreateCollection_Call
  • func (_e *RootCoordCatalog_Expecter) CreateCredential(ctx interface{}, credential interface{}) *RootCoordCatalog_CreateCredential_Call
  • func (_e *RootCoordCatalog_Expecter) CreateDatabase(ctx interface{}, db interface{}, ts interface{}) *RootCoordCatalog_CreateDatabase_Call
  • func (_e *RootCoordCatalog_Expecter) CreatePartition(ctx interface{}, dbID interface{}, partition interface{}, ts interface{}) *RootCoordCatalog_CreatePartition_Call
  • func (_e *RootCoordCatalog_Expecter) CreateRole(ctx interface{}, tenant interface{}, entity interface{}) *RootCoordCatalog_CreateRole_Call
  • func (_e *RootCoordCatalog_Expecter) DeleteGrant(ctx interface{}, tenant interface{}, role interface{}) *RootCoordCatalog_DeleteGrant_Call
  • func (_e *RootCoordCatalog_Expecter) DropAlias(ctx interface{}, dbID interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_DropAlias_Call
  • func (_e *RootCoordCatalog_Expecter) DropCollection(ctx interface{}, collectionInfo interface{}, ts interface{}) *RootCoordCatalog_DropCollection_Call
  • func (_e *RootCoordCatalog_Expecter) DropCredential(ctx interface{}, username interface{}) *RootCoordCatalog_DropCredential_Call
  • func (_e *RootCoordCatalog_Expecter) DropDatabase(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_DropDatabase_Call
  • func (_e *RootCoordCatalog_Expecter) DropPartition(ctx interface{}, dbID interface{}, collectionID interface{}, ...) *RootCoordCatalog_DropPartition_Call
  • func (_e *RootCoordCatalog_Expecter) DropRole(ctx interface{}, tenant interface{}, roleName interface{}) *RootCoordCatalog_DropRole_Call
  • func (_e *RootCoordCatalog_Expecter) GetCollectionByID(ctx interface{}, dbID interface{}, ts interface{}, collectionID interface{}) *RootCoordCatalog_GetCollectionByID_Call
  • func (_e *RootCoordCatalog_Expecter) GetCollectionByName(ctx interface{}, dbID interface{}, collectionName interface{}, ts interface{}) *RootCoordCatalog_GetCollectionByName_Call
  • func (_e *RootCoordCatalog_Expecter) GetCredential(ctx interface{}, username interface{}) *RootCoordCatalog_GetCredential_Call
  • func (_e *RootCoordCatalog_Expecter) ListAliases(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_ListAliases_Call
  • func (_e *RootCoordCatalog_Expecter) ListCollections(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_ListCollections_Call
  • func (_e *RootCoordCatalog_Expecter) ListCredentials(ctx interface{}) *RootCoordCatalog_ListCredentials_Call
  • func (_e *RootCoordCatalog_Expecter) ListDatabases(ctx interface{}, ts interface{}) *RootCoordCatalog_ListDatabases_Call
  • func (_e *RootCoordCatalog_Expecter) ListGrant(ctx interface{}, tenant interface{}, entity interface{}) *RootCoordCatalog_ListGrant_Call
  • func (_e *RootCoordCatalog_Expecter) ListPolicy(ctx interface{}, tenant interface{}) *RootCoordCatalog_ListPolicy_Call
  • func (_e *RootCoordCatalog_Expecter) ListRole(ctx interface{}, tenant interface{}, entity interface{}, ...) *RootCoordCatalog_ListRole_Call
  • func (_e *RootCoordCatalog_Expecter) ListUser(ctx interface{}, tenant interface{}, entity interface{}, ...) *RootCoordCatalog_ListUser_Call
  • func (_e *RootCoordCatalog_Expecter) ListUserRole(ctx interface{}, tenant interface{}) *RootCoordCatalog_ListUserRole_Call
• type RootCoordCatalog_GetCollectionByID_Call
  • func (_c *RootCoordCatalog_GetCollectionByID_Call) Return(_a0 *model.Collection, _a1 error) *RootCoordCatalog_GetCollectionByID_Call
  • func (_c *RootCoordCatalog_GetCollectionByID_Call) Run(run func(ctx context.Context, dbID int64, ts uint64, collectionID int64)) *RootCoordCatalog_GetCollectionByID_Call
  • func (_c *RootCoordCatalog_GetCollectionByID_Call) RunAndReturn(run func(context.Context, int64, uint64, int64) (*model.Collection, error)) *RootCoordCatalog_GetCollectionByID_Call
• type RootCoordCatalog_GetCollectionByName_Call
  • func (_c *RootCoordCatalog_GetCollectionByName_Call) Return(_a0 *model.Collection, _a1 error) *RootCoordCatalog_GetCollectionByName_Call
  • func (_c *RootCoordCatalog_GetCollectionByName_Call) Run(run func(ctx context.Context, dbID int64, collectionName string, ts uint64)) *RootCoordCatalog_GetCollectionByName_Call
  • func (_c *RootCoordCatalog_GetCollectionByName_Call) RunAndReturn(run func(context.Context, int64, string, uint64) (*model.Collection, error)) *RootCoordCatalog_GetCollectionByName_Call
• type RootCoordCatalog_GetCredential_Call
  • func (_c *RootCoordCatalog_GetCredential_Call) Return(_a0 *model.Credential, _a1 error) *RootCoordCatalog_GetCredential_Call
  • func (_c *RootCoordCatalog_GetCredential_Call) Run(run func(ctx context.Context, username string)) *RootCoordCatalog_GetCredential_Call
  • func (_c *RootCoordCatalog_GetCredential_Call) RunAndReturn(run func(context.Context, string) (*model.Credential, error)) *RootCoordCatalog_GetCredential_Call
• type RootCoordCatalog_ListAliases_Call
  • func (_c *RootCoordCatalog_ListAliases_Call) Return(_a0 []*model.Alias, _a1 error) *RootCoordCatalog_ListAliases_Call
  • func (_c *RootCoordCatalog_ListAliases_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_ListAliases_Call
  • func (_c *RootCoordCatalog_ListAliases_Call) RunAndReturn(run func(context.Context, int64, uint64) ([]*model.Alias, error)) *RootCoordCatalog_ListAliases_Call
• type RootCoordCatalog_ListCollections_Call
  • func (_c *RootCoordCatalog_ListCollections_Call) Return(_a0 []*model.Collection, _a1 error) *RootCoordCatalog_ListCollections_Call
  • func (_c *RootCoordCatalog_ListCollections_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_ListCollections_Call
  • func (_c *RootCoordCatalog_ListCollections_Call) RunAndReturn(run func(context.Context, int64, uint64) ([]*model.Collection, error)) *RootCoordCatalog_ListCollections_Call
• type RootCoordCatalog_ListCredentials_Call
  • func (_c *RootCoordCatalog_ListCredentials_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListCredentials_Call
  • func (_c *RootCoordCatalog_ListCredentials_Call) Run(run func(ctx context.Context)) *RootCoordCatalog_ListCredentials_Call
  • func (_c *RootCoordCatalog_ListCredentials_Call) RunAndReturn(run func(context.Context) ([]string, error)) *RootCoordCatalog_ListCredentials_Call
• type RootCoordCatalog_ListDatabases_Call
  • func (_c *RootCoordCatalog_ListDatabases_Call) Return(_a0 []*model.Database, _a1 error) *RootCoordCatalog_ListDatabases_Call
  • func (_c *RootCoordCatalog_ListDatabases_Call) Run(run func(ctx context.Context, ts uint64)) *RootCoordCatalog_ListDatabases_Call
  • func (_c *RootCoordCatalog_ListDatabases_Call) RunAndReturn(run func(context.Context, uint64) ([]*model.Database, error)) *RootCoordCatalog_ListDatabases_Call
• type RootCoordCatalog_ListGrant_Call
  • func (_c *RootCoordCatalog_ListGrant_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *RootCoordCatalog_ListGrant_Call
  • func (_c *RootCoordCatalog_ListGrant_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.GrantEntity)) *RootCoordCatalog_ListGrant_Call
  • func (_c *RootCoordCatalog_ListGrant_Call) RunAndReturn(...) *RootCoordCatalog_ListGrant_Call
• type RootCoordCatalog_ListPolicy_Call
  • func (_c *RootCoordCatalog_ListPolicy_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListPolicy_Call
  • func (_c *RootCoordCatalog_ListPolicy_Call) Run(run func(ctx context.Context, tenant string)) *RootCoordCatalog_ListPolicy_Call
  • func (_c *RootCoordCatalog_ListPolicy_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *RootCoordCatalog_ListPolicy_Call
• type RootCoordCatalog_ListRole_Call
  • func (_c *RootCoordCatalog_ListRole_Call) Return(_a0 []*milvuspb.RoleResult, _a1 error) *RootCoordCatalog_ListRole_Call
  • func (_c *RootCoordCatalog_ListRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, ...)) *RootCoordCatalog_ListRole_Call
  • func (_c *RootCoordCatalog_ListRole_Call) RunAndReturn(...) *RootCoordCatalog_ListRole_Call
• type RootCoordCatalog_ListUserRole_Call
  • func (_c *RootCoordCatalog_ListUserRole_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListUserRole_Call
  • func (_c *RootCoordCatalog_ListUserRole_Call) Run(run func(ctx context.Context, tenant string)) *RootCoordCatalog_ListUserRole_Call
  • func (_c *RootCoordCatalog_ListUserRole_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *RootCoordCatalog_ListUserRole_Call
• type RootCoordCatalog_ListUser_Call
  • func (_c *RootCoordCatalog_ListUser_Call) Return(_a0 []*milvuspb.UserResult, _a1 error) *RootCoordCatalog_ListUser_Call
  • func (_c *RootCoordCatalog_ListUser_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.UserEntity, ...)) *RootCoordCatalog_ListUser_Call
  • func (_c *RootCoordCatalog_ListUser_Call) RunAndReturn(...) *RootCoordCatalog_ListUser_Call

Types

type DataCoordCatalog

type DataCoordCatalog struct {
	mock.Mock
}

DataCoordCatalog is an autogenerated mock type for the DataCoordCatalog type

func NewDataCoordCatalog

func NewDataCoordCatalog(t interface {
	mock.TestingT
	Cleanup(func())
}) *DataCoordCatalog

NewDataCoordCatalog creates a new instance of DataCoordCatalog. 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 (*DataCoordCatalog) AddSegment

func (_m *DataCoordCatalog) AddSegment(ctx context.Context, segment *datapb.SegmentInfo) error

AddSegment provides a mock function with given fields: ctx, segment

func (*DataCoordCatalog) AlterIndexes

func (_m *DataCoordCatalog) AlterIndexes(ctx context.Context, newIndexes []*model.Index) error

AlterIndexes provides a mock function with given fields: ctx, newIndexes

func (*DataCoordCatalog) AlterSegmentIndexes

func (_m *DataCoordCatalog) AlterSegmentIndexes(ctx context.Context, newSegIdxes []*model.SegmentIndex) error

AlterSegmentIndexes provides a mock function with given fields: ctx, newSegIdxes

func (*DataCoordCatalog) AlterSegments

func (_m *DataCoordCatalog) AlterSegments(ctx context.Context, newSegments []*datapb.SegmentInfo, binlogs ...metastore.BinlogsIncrement) error

AlterSegments provides a mock function with given fields: ctx, newSegments, binlogs

func (*DataCoordCatalog) ChannelExists

func (_m *DataCoordCatalog) ChannelExists(ctx context.Context, channel string) bool

ChannelExists provides a mock function with given fields: ctx, channel

func (*DataCoordCatalog) CreateIndex

func (_m *DataCoordCatalog) CreateIndex(ctx context.Context, index *model.Index) error

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

func (*DataCoordCatalog) CreateSegmentIndex

func (_m *DataCoordCatalog) CreateSegmentIndex(ctx context.Context, segIdx *model.SegmentIndex) error

CreateSegmentIndex provides a mock function with given fields: ctx, segIdx

func (*DataCoordCatalog) DropAnalyzeTask

func (_m *DataCoordCatalog) DropAnalyzeTask(ctx context.Context, taskID int64) error

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

func (*DataCoordCatalog) DropChannel

func (_m *DataCoordCatalog) DropChannel(ctx context.Context, channel string) error

DropChannel provides a mock function with given fields: ctx, channel

func (*DataCoordCatalog) DropChannelCheckpoint

func (_m *DataCoordCatalog) DropChannelCheckpoint(ctx context.Context, vChannel string) error

DropChannelCheckpoint provides a mock function with given fields: ctx, vChannel

func (*DataCoordCatalog) DropCompactionTask

func (_m *DataCoordCatalog) DropCompactionTask(ctx context.Context, task *datapb.CompactionTask) error

DropCompactionTask provides a mock function with given fields: ctx, task

func (*DataCoordCatalog) DropCurrentPartitionStatsVersion

func (_m *DataCoordCatalog) DropCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string) error

DropCurrentPartitionStatsVersion provides a mock function with given fields: ctx, collID, partID, vChannel

func (*DataCoordCatalog) DropImportJob

func (_m *DataCoordCatalog) DropImportJob(jobID int64) error

DropImportJob provides a mock function with given fields: jobID

func (*DataCoordCatalog) DropImportTask

func (_m *DataCoordCatalog) DropImportTask(taskID int64) error

DropImportTask provides a mock function with given fields: taskID

func (*DataCoordCatalog) DropIndex

func (_m *DataCoordCatalog) DropIndex(ctx context.Context, collID int64, dropIdxID int64) error

DropIndex provides a mock function with given fields: ctx, collID, dropIdxID

func (*DataCoordCatalog) DropPartitionStatsInfo

func (_m *DataCoordCatalog) DropPartitionStatsInfo(ctx context.Context, info *datapb.PartitionStatsInfo) error

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

func (*DataCoordCatalog) DropPreImportTask

func (_m *DataCoordCatalog) DropPreImportTask(taskID int64) error

DropPreImportTask provides a mock function with given fields: taskID

func (*DataCoordCatalog) DropSegment

func (_m *DataCoordCatalog) DropSegment(ctx context.Context, segment *datapb.SegmentInfo) error

DropSegment provides a mock function with given fields: ctx, segment

func (*DataCoordCatalog) DropSegmentIndex

func (_m *DataCoordCatalog) DropSegmentIndex(ctx context.Context, collID int64, partID int64, segID int64, buildID int64) error

DropSegmentIndex provides a mock function with given fields: ctx, collID, partID, segID, buildID

func (*DataCoordCatalog) EXPECT

func (_m *DataCoordCatalog) EXPECT() *DataCoordCatalog_Expecter

func (*DataCoordCatalog) GcConfirm

func (_m *DataCoordCatalog) GcConfirm(ctx context.Context, collectionID int64, partitionID int64) bool

GcConfirm provides a mock function with given fields: ctx, collectionID, partitionID

func (*DataCoordCatalog) GetCurrentPartitionStatsVersion

func (_m *DataCoordCatalog) GetCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string) (int64, error)

GetCurrentPartitionStatsVersion provides a mock function with given fields: ctx, collID, partID, vChannel

func (*DataCoordCatalog) ListAnalyzeTasks

func (_m *DataCoordCatalog) ListAnalyzeTasks(ctx context.Context) ([]*indexpb.AnalyzeTask, error)

ListAnalyzeTasks provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListChannelCheckpoint

func (_m *DataCoordCatalog) ListChannelCheckpoint(ctx context.Context) (map[string]*msgpb.MsgPosition, error)

ListChannelCheckpoint provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListCompactionTask

func (_m *DataCoordCatalog) ListCompactionTask(ctx context.Context) ([]*datapb.CompactionTask, error)

ListCompactionTask provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListImportJobs

func (_m *DataCoordCatalog) ListImportJobs() ([]*datapb.ImportJob, error)

ListImportJobs provides a mock function with given fields:

func (*DataCoordCatalog) ListImportTasks

func (_m *DataCoordCatalog) ListImportTasks() ([]*datapb.ImportTaskV2, error)

ListImportTasks provides a mock function with given fields:

func (*DataCoordCatalog) ListIndexes

func (_m *DataCoordCatalog) ListIndexes(ctx context.Context) ([]*model.Index, error)

ListIndexes provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListPartitionStatsInfos

func (_m *DataCoordCatalog) ListPartitionStatsInfos(ctx context.Context) ([]*datapb.PartitionStatsInfo, error)

ListPartitionStatsInfos provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListPreImportTasks

func (_m *DataCoordCatalog) ListPreImportTasks() ([]*datapb.PreImportTask, error)

ListPreImportTasks provides a mock function with given fields:

func (*DataCoordCatalog) ListSegmentIndexes

func (_m *DataCoordCatalog) ListSegmentIndexes(ctx context.Context) ([]*model.SegmentIndex, error)

ListSegmentIndexes provides a mock function with given fields: ctx

func (*DataCoordCatalog) ListSegments

func (_m *DataCoordCatalog) ListSegments(ctx context.Context) ([]*datapb.SegmentInfo, error)

ListSegments provides a mock function with given fields: ctx

func (*DataCoordCatalog) MarkChannelAdded

func (_m *DataCoordCatalog) MarkChannelAdded(ctx context.Context, channel string) error

MarkChannelAdded provides a mock function with given fields: ctx, channel

func (*DataCoordCatalog) MarkChannelDeleted

func (_m *DataCoordCatalog) MarkChannelDeleted(ctx context.Context, channel string) error

MarkChannelDeleted provides a mock function with given fields: ctx, channel

func (*DataCoordCatalog) SaveAnalyzeTask

func (_m *DataCoordCatalog) SaveAnalyzeTask(ctx context.Context, task *indexpb.AnalyzeTask) error

SaveAnalyzeTask provides a mock function with given fields: ctx, task

func (*DataCoordCatalog) SaveChannelCheckpoint

func (_m *DataCoordCatalog) SaveChannelCheckpoint(ctx context.Context, vChannel string, pos *msgpb.MsgPosition) error

SaveChannelCheckpoint provides a mock function with given fields: ctx, vChannel, pos

func (*DataCoordCatalog) SaveChannelCheckpoints

func (_m *DataCoordCatalog) SaveChannelCheckpoints(ctx context.Context, positions []*msgpb.MsgPosition) error

SaveChannelCheckpoints provides a mock function with given fields: ctx, positions

func (*DataCoordCatalog) SaveCompactionTask

func (_m *DataCoordCatalog) SaveCompactionTask(ctx context.Context, task *datapb.CompactionTask) error

SaveCompactionTask provides a mock function with given fields: ctx, task

func (*DataCoordCatalog) SaveCurrentPartitionStatsVersion

func (_m *DataCoordCatalog) SaveCurrentPartitionStatsVersion(ctx context.Context, collID int64, partID int64, vChannel string, currentVersion int64) error

SaveCurrentPartitionStatsVersion provides a mock function with given fields: ctx, collID, partID, vChannel, currentVersion

func (*DataCoordCatalog) SaveDroppedSegmentsInBatch

func (_m *DataCoordCatalog) SaveDroppedSegmentsInBatch(ctx context.Context, segments []*datapb.SegmentInfo) error

SaveDroppedSegmentsInBatch provides a mock function with given fields: ctx, segments

func (*DataCoordCatalog) SaveImportJob

func (_m *DataCoordCatalog) SaveImportJob(job *datapb.ImportJob) error

SaveImportJob provides a mock function with given fields: job

func (*DataCoordCatalog) SaveImportTask

func (_m *DataCoordCatalog) SaveImportTask(task *datapb.ImportTaskV2) error

SaveImportTask provides a mock function with given fields: task

func (*DataCoordCatalog) SavePartitionStatsInfo

func (_m *DataCoordCatalog) SavePartitionStatsInfo(ctx context.Context, info *datapb.PartitionStatsInfo) error

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

func (*DataCoordCatalog) SavePreImportTask

func (_m *DataCoordCatalog) SavePreImportTask(task *datapb.PreImportTask) error

SavePreImportTask provides a mock function with given fields: task

func (*DataCoordCatalog) ShouldDropChannel

func (_m *DataCoordCatalog) ShouldDropChannel(ctx context.Context, channel string) bool

ShouldDropChannel provides a mock function with given fields: ctx, channel

type DataCoordCatalog_AddSegment_Call

type DataCoordCatalog_AddSegment_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_AddSegment_Call) Return

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

func (*DataCoordCatalog_AddSegment_Call) Run

func (_c *DataCoordCatalog_AddSegment_Call) Run(run func(ctx context.Context, segment *datapb.SegmentInfo)) *DataCoordCatalog_AddSegment_Call

func (*DataCoordCatalog_AddSegment_Call) RunAndReturn

func (_c *DataCoordCatalog_AddSegment_Call) RunAndReturn(run func(context.Context, *datapb.SegmentInfo) error) *DataCoordCatalog_AddSegment_Call

type DataCoordCatalog_AlterIndexes_Call

type DataCoordCatalog_AlterIndexes_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_AlterIndexes_Call) Return

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

func (*DataCoordCatalog_AlterIndexes_Call) Run

func (_c *DataCoordCatalog_AlterIndexes_Call) Run(run func(ctx context.Context, newIndexes []*model.Index)) *DataCoordCatalog_AlterIndexes_Call

func (*DataCoordCatalog_AlterIndexes_Call) RunAndReturn

func (_c *DataCoordCatalog_AlterIndexes_Call) RunAndReturn(run func(context.Context, []*model.Index) error) *DataCoordCatalog_AlterIndexes_Call

type DataCoordCatalog_AlterSegmentIndexes_Call

type DataCoordCatalog_AlterSegmentIndexes_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_AlterSegmentIndexes_Call) Return

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

func (*DataCoordCatalog_AlterSegmentIndexes_Call) Run

func (_c *DataCoordCatalog_AlterSegmentIndexes_Call) Run(run func(ctx context.Context, newSegIdxes []*model.SegmentIndex)) *DataCoordCatalog_AlterSegmentIndexes_Call

func (*DataCoordCatalog_AlterSegmentIndexes_Call) RunAndReturn

func (_c *DataCoordCatalog_AlterSegmentIndexes_Call) RunAndReturn(run func(context.Context, []*model.SegmentIndex) error) *DataCoordCatalog_AlterSegmentIndexes_Call

type DataCoordCatalog_AlterSegments_Call

type DataCoordCatalog_AlterSegments_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_AlterSegments_Call) Return

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

func (*DataCoordCatalog_AlterSegments_Call) Run

func (_c *DataCoordCatalog_AlterSegments_Call) Run(run func(ctx context.Context, newSegments []*datapb.SegmentInfo, binlogs ...metastore.BinlogsIncrement)) *DataCoordCatalog_AlterSegments_Call

func (*DataCoordCatalog_AlterSegments_Call) RunAndReturn

func (_c *DataCoordCatalog_AlterSegments_Call) RunAndReturn(run func(context.Context, []*datapb.SegmentInfo, ...metastore.BinlogsIncrement) error) *DataCoordCatalog_AlterSegments_Call

type DataCoordCatalog_ChannelExists_Call

type DataCoordCatalog_ChannelExists_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ChannelExists_Call) Return

func (_c *DataCoordCatalog_ChannelExists_Call) Return(_a0 bool) *DataCoordCatalog_ChannelExists_Call

func (*DataCoordCatalog_ChannelExists_Call) Run

func (_c *DataCoordCatalog_ChannelExists_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_ChannelExists_Call

func (*DataCoordCatalog_ChannelExists_Call) RunAndReturn

func (_c *DataCoordCatalog_ChannelExists_Call) RunAndReturn(run func(context.Context, string) bool) *DataCoordCatalog_ChannelExists_Call

type DataCoordCatalog_CreateIndex_Call

type DataCoordCatalog_CreateIndex_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_CreateIndex_Call) Return

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

func (*DataCoordCatalog_CreateIndex_Call) Run

func (_c *DataCoordCatalog_CreateIndex_Call) Run(run func(ctx context.Context, index *model.Index)) *DataCoordCatalog_CreateIndex_Call

func (*DataCoordCatalog_CreateIndex_Call) RunAndReturn

func (_c *DataCoordCatalog_CreateIndex_Call) RunAndReturn(run func(context.Context, *model.Index) error) *DataCoordCatalog_CreateIndex_Call

type DataCoordCatalog_CreateSegmentIndex_Call

type DataCoordCatalog_CreateSegmentIndex_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_CreateSegmentIndex_Call) Return

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

func (*DataCoordCatalog_CreateSegmentIndex_Call) Run

func (_c *DataCoordCatalog_CreateSegmentIndex_Call) Run(run func(ctx context.Context, segIdx *model.SegmentIndex)) *DataCoordCatalog_CreateSegmentIndex_Call

func (*DataCoordCatalog_CreateSegmentIndex_Call) RunAndReturn

func (_c *DataCoordCatalog_CreateSegmentIndex_Call) RunAndReturn(run func(context.Context, *model.SegmentIndex) error) *DataCoordCatalog_CreateSegmentIndex_Call

type DataCoordCatalog_DropAnalyzeTask_Call

type DataCoordCatalog_DropAnalyzeTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropAnalyzeTask_Call) Return

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

func (*DataCoordCatalog_DropAnalyzeTask_Call) Run

func (_c *DataCoordCatalog_DropAnalyzeTask_Call) Run(run func(ctx context.Context, taskID int64)) *DataCoordCatalog_DropAnalyzeTask_Call

func (*DataCoordCatalog_DropAnalyzeTask_Call) RunAndReturn

func (_c *DataCoordCatalog_DropAnalyzeTask_Call) RunAndReturn(run func(context.Context, int64) error) *DataCoordCatalog_DropAnalyzeTask_Call

type DataCoordCatalog_DropChannelCheckpoint_Call

type DataCoordCatalog_DropChannelCheckpoint_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropChannelCheckpoint_Call) Return

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

func (*DataCoordCatalog_DropChannelCheckpoint_Call) Run

func (_c *DataCoordCatalog_DropChannelCheckpoint_Call) Run(run func(ctx context.Context, vChannel string)) *DataCoordCatalog_DropChannelCheckpoint_Call

func (*DataCoordCatalog_DropChannelCheckpoint_Call) RunAndReturn

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

type DataCoordCatalog_DropChannel_Call

type DataCoordCatalog_DropChannel_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropChannel_Call) Return

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

func (*DataCoordCatalog_DropChannel_Call) Run

func (_c *DataCoordCatalog_DropChannel_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_DropChannel_Call

func (*DataCoordCatalog_DropChannel_Call) RunAndReturn

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

type DataCoordCatalog_DropCompactionTask_Call

type DataCoordCatalog_DropCompactionTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropCompactionTask_Call) Return

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

func (*DataCoordCatalog_DropCompactionTask_Call) Run

func (_c *DataCoordCatalog_DropCompactionTask_Call) Run(run func(ctx context.Context, task *datapb.CompactionTask)) *DataCoordCatalog_DropCompactionTask_Call

func (*DataCoordCatalog_DropCompactionTask_Call) RunAndReturn

func (_c *DataCoordCatalog_DropCompactionTask_Call) RunAndReturn(run func(context.Context, *datapb.CompactionTask) error) *DataCoordCatalog_DropCompactionTask_Call

type DataCoordCatalog_DropCurrentPartitionStatsVersion_Call

type DataCoordCatalog_DropCurrentPartitionStatsVersion_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) Return

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

func (*DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) Run

func (_c *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) Run(run func(ctx context.Context, collID int64, partID int64, vChannel string)) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call

func (*DataCoordCatalog_DropCurrentPartitionStatsVersion_Call) RunAndReturn

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

type DataCoordCatalog_DropImportJob_Call

type DataCoordCatalog_DropImportJob_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropImportJob_Call) Return

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

func (*DataCoordCatalog_DropImportJob_Call) Run

func (_c *DataCoordCatalog_DropImportJob_Call) Run(run func(jobID int64)) *DataCoordCatalog_DropImportJob_Call

func (*DataCoordCatalog_DropImportJob_Call) RunAndReturn

func (_c *DataCoordCatalog_DropImportJob_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropImportJob_Call

type DataCoordCatalog_DropImportTask_Call

type DataCoordCatalog_DropImportTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropImportTask_Call) Return

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

func (*DataCoordCatalog_DropImportTask_Call) Run

func (_c *DataCoordCatalog_DropImportTask_Call) Run(run func(taskID int64)) *DataCoordCatalog_DropImportTask_Call

func (*DataCoordCatalog_DropImportTask_Call) RunAndReturn

func (_c *DataCoordCatalog_DropImportTask_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropImportTask_Call

type DataCoordCatalog_DropIndex_Call

type DataCoordCatalog_DropIndex_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropIndex_Call) Return

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

func (*DataCoordCatalog_DropIndex_Call) Run

func (_c *DataCoordCatalog_DropIndex_Call) Run(run func(ctx context.Context, collID int64, dropIdxID int64)) *DataCoordCatalog_DropIndex_Call

func (*DataCoordCatalog_DropIndex_Call) RunAndReturn

func (_c *DataCoordCatalog_DropIndex_Call) RunAndReturn(run func(context.Context, int64, int64) error) *DataCoordCatalog_DropIndex_Call

type DataCoordCatalog_DropPartitionStatsInfo_Call

type DataCoordCatalog_DropPartitionStatsInfo_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropPartitionStatsInfo_Call) Return

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

func (*DataCoordCatalog_DropPartitionStatsInfo_Call) Run

func (_c *DataCoordCatalog_DropPartitionStatsInfo_Call) Run(run func(ctx context.Context, info *datapb.PartitionStatsInfo)) *DataCoordCatalog_DropPartitionStatsInfo_Call

func (*DataCoordCatalog_DropPartitionStatsInfo_Call) RunAndReturn

func (_c *DataCoordCatalog_DropPartitionStatsInfo_Call) RunAndReturn(run func(context.Context, *datapb.PartitionStatsInfo) error) *DataCoordCatalog_DropPartitionStatsInfo_Call

type DataCoordCatalog_DropPreImportTask_Call

type DataCoordCatalog_DropPreImportTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropPreImportTask_Call) Return

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

func (*DataCoordCatalog_DropPreImportTask_Call) Run

func (_c *DataCoordCatalog_DropPreImportTask_Call) Run(run func(taskID int64)) *DataCoordCatalog_DropPreImportTask_Call

func (*DataCoordCatalog_DropPreImportTask_Call) RunAndReturn

func (_c *DataCoordCatalog_DropPreImportTask_Call) RunAndReturn(run func(int64) error) *DataCoordCatalog_DropPreImportTask_Call

type DataCoordCatalog_DropSegmentIndex_Call

type DataCoordCatalog_DropSegmentIndex_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropSegmentIndex_Call) Return

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

func (*DataCoordCatalog_DropSegmentIndex_Call) Run

func (_c *DataCoordCatalog_DropSegmentIndex_Call) Run(run func(ctx context.Context, collID int64, partID int64, segID int64, buildID int64)) *DataCoordCatalog_DropSegmentIndex_Call

func (*DataCoordCatalog_DropSegmentIndex_Call) RunAndReturn

func (_c *DataCoordCatalog_DropSegmentIndex_Call) RunAndReturn(run func(context.Context, int64, int64, int64, int64) error) *DataCoordCatalog_DropSegmentIndex_Call

type DataCoordCatalog_DropSegment_Call

type DataCoordCatalog_DropSegment_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_DropSegment_Call) Return

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

func (*DataCoordCatalog_DropSegment_Call) Run

func (_c *DataCoordCatalog_DropSegment_Call) Run(run func(ctx context.Context, segment *datapb.SegmentInfo)) *DataCoordCatalog_DropSegment_Call

func (*DataCoordCatalog_DropSegment_Call) RunAndReturn

func (_c *DataCoordCatalog_DropSegment_Call) RunAndReturn(run func(context.Context, *datapb.SegmentInfo) error) *DataCoordCatalog_DropSegment_Call

type DataCoordCatalog_Expecter

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

func (*DataCoordCatalog_Expecter) AddSegment

func (_e *DataCoordCatalog_Expecter) AddSegment(ctx interface{}, segment interface{}) *DataCoordCatalog_AddSegment_Call

AddSegment is a helper method to define mock.On call

• ctx context.Context
• segment *datapb.SegmentInfo

func (*DataCoordCatalog_Expecter) AlterIndexes

func (_e *DataCoordCatalog_Expecter) AlterIndexes(ctx interface{}, newIndexes interface{}) *DataCoordCatalog_AlterIndexes_Call

AlterIndexes is a helper method to define mock.On call

• ctx context.Context
• newIndexes []*model.Index

func (*DataCoordCatalog_Expecter) AlterSegmentIndexes

func (_e *DataCoordCatalog_Expecter) AlterSegmentIndexes(ctx interface{}, newSegIdxes interface{}) *DataCoordCatalog_AlterSegmentIndexes_Call

AlterSegmentIndexes is a helper method to define mock.On call

• ctx context.Context
• newSegIdxes []*model.SegmentIndex

func (*DataCoordCatalog_Expecter) AlterSegments

func (_e *DataCoordCatalog_Expecter) AlterSegments(ctx interface{}, newSegments interface{}, binlogs ...interface{}) *DataCoordCatalog_AlterSegments_Call

AlterSegments is a helper method to define mock.On call

• ctx context.Context
• newSegments []*datapb.SegmentInfo
• binlogs ...metastore.BinlogsIncrement

func (*DataCoordCatalog_Expecter) ChannelExists

func (_e *DataCoordCatalog_Expecter) ChannelExists(ctx interface{}, channel interface{}) *DataCoordCatalog_ChannelExists_Call

ChannelExists is a helper method to define mock.On call

• ctx context.Context
• channel string

func (*DataCoordCatalog_Expecter) CreateIndex

func (_e *DataCoordCatalog_Expecter) CreateIndex(ctx interface{}, index interface{}) *DataCoordCatalog_CreateIndex_Call

CreateIndex is a helper method to define mock.On call

• ctx context.Context
• index *model.Index

func (*DataCoordCatalog_Expecter) CreateSegmentIndex

func (_e *DataCoordCatalog_Expecter) CreateSegmentIndex(ctx interface{}, segIdx interface{}) *DataCoordCatalog_CreateSegmentIndex_Call

CreateSegmentIndex is a helper method to define mock.On call

• ctx context.Context
• segIdx *model.SegmentIndex

func (*DataCoordCatalog_Expecter) DropAnalyzeTask

func (_e *DataCoordCatalog_Expecter) DropAnalyzeTask(ctx interface{}, taskID interface{}) *DataCoordCatalog_DropAnalyzeTask_Call

DropAnalyzeTask is a helper method to define mock.On call

• ctx context.Context
• taskID int64

func (*DataCoordCatalog_Expecter) DropChannel

func (_e *DataCoordCatalog_Expecter) DropChannel(ctx interface{}, channel interface{}) *DataCoordCatalog_DropChannel_Call

DropChannel is a helper method to define mock.On call

• ctx context.Context
• channel string

func (*DataCoordCatalog_Expecter) DropChannelCheckpoint

func (_e *DataCoordCatalog_Expecter) DropChannelCheckpoint(ctx interface{}, vChannel interface{}) *DataCoordCatalog_DropChannelCheckpoint_Call

DropChannelCheckpoint is a helper method to define mock.On call

• ctx context.Context
• vChannel string

func (*DataCoordCatalog_Expecter) DropCompactionTask

func (_e *DataCoordCatalog_Expecter) DropCompactionTask(ctx interface{}, task interface{}) *DataCoordCatalog_DropCompactionTask_Call

DropCompactionTask is a helper method to define mock.On call

• ctx context.Context
• task *datapb.CompactionTask

func (*DataCoordCatalog_Expecter) DropCurrentPartitionStatsVersion

func (_e *DataCoordCatalog_Expecter) DropCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}) *DataCoordCatalog_DropCurrentPartitionStatsVersion_Call

DropCurrentPartitionStatsVersion is a helper method to define mock.On call

• ctx context.Context
• collID int64
• partID int64
• vChannel string

func (*DataCoordCatalog_Expecter) DropImportJob

func (_e *DataCoordCatalog_Expecter) DropImportJob(jobID interface{}) *DataCoordCatalog_DropImportJob_Call

DropImportJob is a helper method to define mock.On call

• jobID int64

func (*DataCoordCatalog_Expecter) DropImportTask

func (_e *DataCoordCatalog_Expecter) DropImportTask(taskID interface{}) *DataCoordCatalog_DropImportTask_Call

DropImportTask is a helper method to define mock.On call

• taskID int64

func (*DataCoordCatalog_Expecter) DropIndex

func (_e *DataCoordCatalog_Expecter) DropIndex(ctx interface{}, collID interface{}, dropIdxID interface{}) *DataCoordCatalog_DropIndex_Call

DropIndex is a helper method to define mock.On call

• ctx context.Context
• collID int64
• dropIdxID int64

func (*DataCoordCatalog_Expecter) DropPartitionStatsInfo

func (_e *DataCoordCatalog_Expecter) DropPartitionStatsInfo(ctx interface{}, info interface{}) *DataCoordCatalog_DropPartitionStatsInfo_Call

DropPartitionStatsInfo is a helper method to define mock.On call

• ctx context.Context
• info *datapb.PartitionStatsInfo

func (*DataCoordCatalog_Expecter) DropPreImportTask

func (_e *DataCoordCatalog_Expecter) DropPreImportTask(taskID interface{}) *DataCoordCatalog_DropPreImportTask_Call

DropPreImportTask is a helper method to define mock.On call

• taskID int64

func (*DataCoordCatalog_Expecter) DropSegment

func (_e *DataCoordCatalog_Expecter) DropSegment(ctx interface{}, segment interface{}) *DataCoordCatalog_DropSegment_Call

DropSegment is a helper method to define mock.On call

• ctx context.Context
• segment *datapb.SegmentInfo

func (*DataCoordCatalog_Expecter) DropSegmentIndex

func (_e *DataCoordCatalog_Expecter) DropSegmentIndex(ctx interface{}, collID interface{}, partID interface{}, segID interface{}, buildID interface{}) *DataCoordCatalog_DropSegmentIndex_Call

DropSegmentIndex is a helper method to define mock.On call

• ctx context.Context
• collID int64
• partID int64
• segID int64
• buildID int64

func (*DataCoordCatalog_Expecter) GcConfirm

func (_e *DataCoordCatalog_Expecter) GcConfirm(ctx interface{}, collectionID interface{}, partitionID interface{}) *DataCoordCatalog_GcConfirm_Call

GcConfirm is a helper method to define mock.On call

• ctx context.Context
• collectionID int64
• partitionID int64

func (*DataCoordCatalog_Expecter) GetCurrentPartitionStatsVersion

func (_e *DataCoordCatalog_Expecter) GetCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call

GetCurrentPartitionStatsVersion is a helper method to define mock.On call

• ctx context.Context
• collID int64
• partID int64
• vChannel string

func (*DataCoordCatalog_Expecter) ListAnalyzeTasks

func (_e *DataCoordCatalog_Expecter) ListAnalyzeTasks(ctx interface{}) *DataCoordCatalog_ListAnalyzeTasks_Call

ListAnalyzeTasks is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListChannelCheckpoint

func (_e *DataCoordCatalog_Expecter) ListChannelCheckpoint(ctx interface{}) *DataCoordCatalog_ListChannelCheckpoint_Call

ListChannelCheckpoint is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListCompactionTask

func (_e *DataCoordCatalog_Expecter) ListCompactionTask(ctx interface{}) *DataCoordCatalog_ListCompactionTask_Call

ListCompactionTask is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListImportJobs

func (_e *DataCoordCatalog_Expecter) ListImportJobs() *DataCoordCatalog_ListImportJobs_Call

ListImportJobs is a helper method to define mock.On call

func (*DataCoordCatalog_Expecter) ListImportTasks

func (_e *DataCoordCatalog_Expecter) ListImportTasks() *DataCoordCatalog_ListImportTasks_Call

ListImportTasks is a helper method to define mock.On call

func (*DataCoordCatalog_Expecter) ListIndexes

func (_e *DataCoordCatalog_Expecter) ListIndexes(ctx interface{}) *DataCoordCatalog_ListIndexes_Call

ListIndexes is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListPartitionStatsInfos

func (_e *DataCoordCatalog_Expecter) ListPartitionStatsInfos(ctx interface{}) *DataCoordCatalog_ListPartitionStatsInfos_Call

ListPartitionStatsInfos is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListPreImportTasks

func (_e *DataCoordCatalog_Expecter) ListPreImportTasks() *DataCoordCatalog_ListPreImportTasks_Call

ListPreImportTasks is a helper method to define mock.On call

func (*DataCoordCatalog_Expecter) ListSegmentIndexes

func (_e *DataCoordCatalog_Expecter) ListSegmentIndexes(ctx interface{}) *DataCoordCatalog_ListSegmentIndexes_Call

ListSegmentIndexes is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) ListSegments

func (_e *DataCoordCatalog_Expecter) ListSegments(ctx interface{}) *DataCoordCatalog_ListSegments_Call

ListSegments is a helper method to define mock.On call

• ctx context.Context

func (*DataCoordCatalog_Expecter) MarkChannelAdded

func (_e *DataCoordCatalog_Expecter) MarkChannelAdded(ctx interface{}, channel interface{}) *DataCoordCatalog_MarkChannelAdded_Call

MarkChannelAdded is a helper method to define mock.On call

• ctx context.Context
• channel string

func (*DataCoordCatalog_Expecter) MarkChannelDeleted

func (_e *DataCoordCatalog_Expecter) MarkChannelDeleted(ctx interface{}, channel interface{}) *DataCoordCatalog_MarkChannelDeleted_Call

MarkChannelDeleted is a helper method to define mock.On call

• ctx context.Context
• channel string

func (*DataCoordCatalog_Expecter) SaveAnalyzeTask

func (_e *DataCoordCatalog_Expecter) SaveAnalyzeTask(ctx interface{}, task interface{}) *DataCoordCatalog_SaveAnalyzeTask_Call

SaveAnalyzeTask is a helper method to define mock.On call

• ctx context.Context
• task *indexpb.AnalyzeTask

func (*DataCoordCatalog_Expecter) SaveChannelCheckpoint

func (_e *DataCoordCatalog_Expecter) SaveChannelCheckpoint(ctx interface{}, vChannel interface{}, pos interface{}) *DataCoordCatalog_SaveChannelCheckpoint_Call

SaveChannelCheckpoint is a helper method to define mock.On call

• ctx context.Context
• vChannel string
• pos *msgpb.MsgPosition

func (*DataCoordCatalog_Expecter) SaveChannelCheckpoints

func (_e *DataCoordCatalog_Expecter) SaveChannelCheckpoints(ctx interface{}, positions interface{}) *DataCoordCatalog_SaveChannelCheckpoints_Call

SaveChannelCheckpoints is a helper method to define mock.On call

• ctx context.Context
• positions []*msgpb.MsgPosition

func (*DataCoordCatalog_Expecter) SaveCompactionTask

func (_e *DataCoordCatalog_Expecter) SaveCompactionTask(ctx interface{}, task interface{}) *DataCoordCatalog_SaveCompactionTask_Call

SaveCompactionTask is a helper method to define mock.On call

• ctx context.Context
• task *datapb.CompactionTask

func (*DataCoordCatalog_Expecter) SaveCurrentPartitionStatsVersion

func (_e *DataCoordCatalog_Expecter) SaveCurrentPartitionStatsVersion(ctx interface{}, collID interface{}, partID interface{}, vChannel interface{}, currentVersion interface{}) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call

SaveCurrentPartitionStatsVersion is a helper method to define mock.On call

• ctx context.Context
• collID int64
• partID int64
• vChannel string
• currentVersion int64

func (*DataCoordCatalog_Expecter) SaveDroppedSegmentsInBatch

func (_e *DataCoordCatalog_Expecter) SaveDroppedSegmentsInBatch(ctx interface{}, segments interface{}) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call

SaveDroppedSegmentsInBatch is a helper method to define mock.On call

• ctx context.Context
• segments []*datapb.SegmentInfo

func (*DataCoordCatalog_Expecter) SaveImportJob

func (_e *DataCoordCatalog_Expecter) SaveImportJob(job interface{}) *DataCoordCatalog_SaveImportJob_Call

SaveImportJob is a helper method to define mock.On call

• job *datapb.ImportJob

func (*DataCoordCatalog_Expecter) SaveImportTask

func (_e *DataCoordCatalog_Expecter) SaveImportTask(task interface{}) *DataCoordCatalog_SaveImportTask_Call

SaveImportTask is a helper method to define mock.On call

• task *datapb.ImportTaskV2

func (*DataCoordCatalog_Expecter) SavePartitionStatsInfo

func (_e *DataCoordCatalog_Expecter) SavePartitionStatsInfo(ctx interface{}, info interface{}) *DataCoordCatalog_SavePartitionStatsInfo_Call

SavePartitionStatsInfo is a helper method to define mock.On call

• ctx context.Context
• info *datapb.PartitionStatsInfo

func (*DataCoordCatalog_Expecter) SavePreImportTask

func (_e *DataCoordCatalog_Expecter) SavePreImportTask(task interface{}) *DataCoordCatalog_SavePreImportTask_Call

SavePreImportTask is a helper method to define mock.On call

• task *datapb.PreImportTask

func (*DataCoordCatalog_Expecter) ShouldDropChannel

func (_e *DataCoordCatalog_Expecter) ShouldDropChannel(ctx interface{}, channel interface{}) *DataCoordCatalog_ShouldDropChannel_Call

ShouldDropChannel is a helper method to define mock.On call

• ctx context.Context
• channel string

type DataCoordCatalog_GcConfirm_Call

type DataCoordCatalog_GcConfirm_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_GcConfirm_Call) Return

func (_c *DataCoordCatalog_GcConfirm_Call) Return(_a0 bool) *DataCoordCatalog_GcConfirm_Call

func (*DataCoordCatalog_GcConfirm_Call) Run

func (_c *DataCoordCatalog_GcConfirm_Call) Run(run func(ctx context.Context, collectionID int64, partitionID int64)) *DataCoordCatalog_GcConfirm_Call

func (*DataCoordCatalog_GcConfirm_Call) RunAndReturn

func (_c *DataCoordCatalog_GcConfirm_Call) RunAndReturn(run func(context.Context, int64, int64) bool) *DataCoordCatalog_GcConfirm_Call

type DataCoordCatalog_GetCurrentPartitionStatsVersion_Call

type DataCoordCatalog_GetCurrentPartitionStatsVersion_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Return

func (_c *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Return(_a0 int64, _a1 error) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call

func (*DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Run

func (_c *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) Run(run func(ctx context.Context, collID int64, partID int64, vChannel string)) *DataCoordCatalog_GetCurrentPartitionStatsVersion_Call

func (*DataCoordCatalog_GetCurrentPartitionStatsVersion_Call) RunAndReturn

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

type DataCoordCatalog_ListAnalyzeTasks_Call

type DataCoordCatalog_ListAnalyzeTasks_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListAnalyzeTasks_Call) Return

func (_c *DataCoordCatalog_ListAnalyzeTasks_Call) Return(_a0 []*indexpb.AnalyzeTask, _a1 error) *DataCoordCatalog_ListAnalyzeTasks_Call

func (*DataCoordCatalog_ListAnalyzeTasks_Call) Run

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

func (*DataCoordCatalog_ListAnalyzeTasks_Call) RunAndReturn

func (_c *DataCoordCatalog_ListAnalyzeTasks_Call) RunAndReturn(run func(context.Context) ([]*indexpb.AnalyzeTask, error)) *DataCoordCatalog_ListAnalyzeTasks_Call

type DataCoordCatalog_ListChannelCheckpoint_Call

type DataCoordCatalog_ListChannelCheckpoint_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListChannelCheckpoint_Call) Return

func (_c *DataCoordCatalog_ListChannelCheckpoint_Call) Return(_a0 map[string]*msgpb.MsgPosition, _a1 error) *DataCoordCatalog_ListChannelCheckpoint_Call

func (*DataCoordCatalog_ListChannelCheckpoint_Call) Run

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

func (*DataCoordCatalog_ListChannelCheckpoint_Call) RunAndReturn

func (_c *DataCoordCatalog_ListChannelCheckpoint_Call) RunAndReturn(run func(context.Context) (map[string]*msgpb.MsgPosition, error)) *DataCoordCatalog_ListChannelCheckpoint_Call

type DataCoordCatalog_ListCompactionTask_Call

type DataCoordCatalog_ListCompactionTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListCompactionTask_Call) Return

func (_c *DataCoordCatalog_ListCompactionTask_Call) Return(_a0 []*datapb.CompactionTask, _a1 error) *DataCoordCatalog_ListCompactionTask_Call

func (*DataCoordCatalog_ListCompactionTask_Call) Run

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

func (*DataCoordCatalog_ListCompactionTask_Call) RunAndReturn

func (_c *DataCoordCatalog_ListCompactionTask_Call) RunAndReturn(run func(context.Context) ([]*datapb.CompactionTask, error)) *DataCoordCatalog_ListCompactionTask_Call

type DataCoordCatalog_ListImportJobs_Call

type DataCoordCatalog_ListImportJobs_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListImportJobs_Call) Return

func (_c *DataCoordCatalog_ListImportJobs_Call) Return(_a0 []*datapb.ImportJob, _a1 error) *DataCoordCatalog_ListImportJobs_Call

func (*DataCoordCatalog_ListImportJobs_Call) Run

func (_c *DataCoordCatalog_ListImportJobs_Call) Run(run func()) *DataCoordCatalog_ListImportJobs_Call

func (*DataCoordCatalog_ListImportJobs_Call) RunAndReturn

func (_c *DataCoordCatalog_ListImportJobs_Call) RunAndReturn(run func() ([]*datapb.ImportJob, error)) *DataCoordCatalog_ListImportJobs_Call

type DataCoordCatalog_ListImportTasks_Call

type DataCoordCatalog_ListImportTasks_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListImportTasks_Call) Return

func (_c *DataCoordCatalog_ListImportTasks_Call) Return(_a0 []*datapb.ImportTaskV2, _a1 error) *DataCoordCatalog_ListImportTasks_Call

func (*DataCoordCatalog_ListImportTasks_Call) Run

func (_c *DataCoordCatalog_ListImportTasks_Call) Run(run func()) *DataCoordCatalog_ListImportTasks_Call

func (*DataCoordCatalog_ListImportTasks_Call) RunAndReturn

func (_c *DataCoordCatalog_ListImportTasks_Call) RunAndReturn(run func() ([]*datapb.ImportTaskV2, error)) *DataCoordCatalog_ListImportTasks_Call

type DataCoordCatalog_ListIndexes_Call

type DataCoordCatalog_ListIndexes_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListIndexes_Call) Return

func (_c *DataCoordCatalog_ListIndexes_Call) Return(_a0 []*model.Index, _a1 error) *DataCoordCatalog_ListIndexes_Call

func (*DataCoordCatalog_ListIndexes_Call) Run

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

func (*DataCoordCatalog_ListIndexes_Call) RunAndReturn

func (_c *DataCoordCatalog_ListIndexes_Call) RunAndReturn(run func(context.Context) ([]*model.Index, error)) *DataCoordCatalog_ListIndexes_Call

type DataCoordCatalog_ListPartitionStatsInfos_Call

type DataCoordCatalog_ListPartitionStatsInfos_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListPartitionStatsInfos_Call) Return

func (_c *DataCoordCatalog_ListPartitionStatsInfos_Call) Return(_a0 []*datapb.PartitionStatsInfo, _a1 error) *DataCoordCatalog_ListPartitionStatsInfos_Call

func (*DataCoordCatalog_ListPartitionStatsInfos_Call) Run

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

func (*DataCoordCatalog_ListPartitionStatsInfos_Call) RunAndReturn

func (_c *DataCoordCatalog_ListPartitionStatsInfos_Call) RunAndReturn(run func(context.Context) ([]*datapb.PartitionStatsInfo, error)) *DataCoordCatalog_ListPartitionStatsInfos_Call

type DataCoordCatalog_ListPreImportTasks_Call

type DataCoordCatalog_ListPreImportTasks_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListPreImportTasks_Call) Return

func (_c *DataCoordCatalog_ListPreImportTasks_Call) Return(_a0 []*datapb.PreImportTask, _a1 error) *DataCoordCatalog_ListPreImportTasks_Call

func (*DataCoordCatalog_ListPreImportTasks_Call) Run

func (_c *DataCoordCatalog_ListPreImportTasks_Call) Run(run func()) *DataCoordCatalog_ListPreImportTasks_Call

func (*DataCoordCatalog_ListPreImportTasks_Call) RunAndReturn

func (_c *DataCoordCatalog_ListPreImportTasks_Call) RunAndReturn(run func() ([]*datapb.PreImportTask, error)) *DataCoordCatalog_ListPreImportTasks_Call

type DataCoordCatalog_ListSegmentIndexes_Call

type DataCoordCatalog_ListSegmentIndexes_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListSegmentIndexes_Call) Return

func (_c *DataCoordCatalog_ListSegmentIndexes_Call) Return(_a0 []*model.SegmentIndex, _a1 error) *DataCoordCatalog_ListSegmentIndexes_Call

func (*DataCoordCatalog_ListSegmentIndexes_Call) Run

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

func (*DataCoordCatalog_ListSegmentIndexes_Call) RunAndReturn

func (_c *DataCoordCatalog_ListSegmentIndexes_Call) RunAndReturn(run func(context.Context) ([]*model.SegmentIndex, error)) *DataCoordCatalog_ListSegmentIndexes_Call

type DataCoordCatalog_ListSegments_Call

type DataCoordCatalog_ListSegments_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ListSegments_Call) Return

func (_c *DataCoordCatalog_ListSegments_Call) Return(_a0 []*datapb.SegmentInfo, _a1 error) *DataCoordCatalog_ListSegments_Call

func (*DataCoordCatalog_ListSegments_Call) Run

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

func (*DataCoordCatalog_ListSegments_Call) RunAndReturn

func (_c *DataCoordCatalog_ListSegments_Call) RunAndReturn(run func(context.Context) ([]*datapb.SegmentInfo, error)) *DataCoordCatalog_ListSegments_Call

type DataCoordCatalog_MarkChannelAdded_Call

type DataCoordCatalog_MarkChannelAdded_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_MarkChannelAdded_Call) Return

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

func (*DataCoordCatalog_MarkChannelAdded_Call) Run

func (_c *DataCoordCatalog_MarkChannelAdded_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_MarkChannelAdded_Call

func (*DataCoordCatalog_MarkChannelAdded_Call) RunAndReturn

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

type DataCoordCatalog_MarkChannelDeleted_Call

type DataCoordCatalog_MarkChannelDeleted_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_MarkChannelDeleted_Call) Return

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

func (*DataCoordCatalog_MarkChannelDeleted_Call) Run

func (_c *DataCoordCatalog_MarkChannelDeleted_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_MarkChannelDeleted_Call

func (*DataCoordCatalog_MarkChannelDeleted_Call) RunAndReturn

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

type DataCoordCatalog_SaveAnalyzeTask_Call

type DataCoordCatalog_SaveAnalyzeTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveAnalyzeTask_Call) Return

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

func (*DataCoordCatalog_SaveAnalyzeTask_Call) Run

func (_c *DataCoordCatalog_SaveAnalyzeTask_Call) Run(run func(ctx context.Context, task *indexpb.AnalyzeTask)) *DataCoordCatalog_SaveAnalyzeTask_Call

func (*DataCoordCatalog_SaveAnalyzeTask_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveAnalyzeTask_Call) RunAndReturn(run func(context.Context, *indexpb.AnalyzeTask) error) *DataCoordCatalog_SaveAnalyzeTask_Call

type DataCoordCatalog_SaveChannelCheckpoint_Call

type DataCoordCatalog_SaveChannelCheckpoint_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveChannelCheckpoint_Call) Return

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

func (*DataCoordCatalog_SaveChannelCheckpoint_Call) Run

func (_c *DataCoordCatalog_SaveChannelCheckpoint_Call) Run(run func(ctx context.Context, vChannel string, pos *msgpb.MsgPosition)) *DataCoordCatalog_SaveChannelCheckpoint_Call

func (*DataCoordCatalog_SaveChannelCheckpoint_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveChannelCheckpoint_Call) RunAndReturn(run func(context.Context, string, *msgpb.MsgPosition) error) *DataCoordCatalog_SaveChannelCheckpoint_Call

type DataCoordCatalog_SaveChannelCheckpoints_Call

type DataCoordCatalog_SaveChannelCheckpoints_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveChannelCheckpoints_Call) Return

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

func (*DataCoordCatalog_SaveChannelCheckpoints_Call) Run

func (_c *DataCoordCatalog_SaveChannelCheckpoints_Call) Run(run func(ctx context.Context, positions []*msgpb.MsgPosition)) *DataCoordCatalog_SaveChannelCheckpoints_Call

func (*DataCoordCatalog_SaveChannelCheckpoints_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveChannelCheckpoints_Call) RunAndReturn(run func(context.Context, []*msgpb.MsgPosition) error) *DataCoordCatalog_SaveChannelCheckpoints_Call

type DataCoordCatalog_SaveCompactionTask_Call

type DataCoordCatalog_SaveCompactionTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveCompactionTask_Call) Return

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

func (*DataCoordCatalog_SaveCompactionTask_Call) Run

func (_c *DataCoordCatalog_SaveCompactionTask_Call) Run(run func(ctx context.Context, task *datapb.CompactionTask)) *DataCoordCatalog_SaveCompactionTask_Call

func (*DataCoordCatalog_SaveCompactionTask_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveCompactionTask_Call) RunAndReturn(run func(context.Context, *datapb.CompactionTask) error) *DataCoordCatalog_SaveCompactionTask_Call

type DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call

type DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) Return

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

func (*DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) Run

func (_c *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) Run(run func(ctx context.Context, collID int64, partID int64, vChannel string, currentVersion int64)) *DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call

func (*DataCoordCatalog_SaveCurrentPartitionStatsVersion_Call) RunAndReturn

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

type DataCoordCatalog_SaveDroppedSegmentsInBatch_Call

type DataCoordCatalog_SaveDroppedSegmentsInBatch_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) Return

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

func (*DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) Run

func (_c *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) Run(run func(ctx context.Context, segments []*datapb.SegmentInfo)) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call

func (*DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call) RunAndReturn(run func(context.Context, []*datapb.SegmentInfo) error) *DataCoordCatalog_SaveDroppedSegmentsInBatch_Call

type DataCoordCatalog_SaveImportJob_Call

type DataCoordCatalog_SaveImportJob_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveImportJob_Call) Return

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

func (*DataCoordCatalog_SaveImportJob_Call) Run

func (_c *DataCoordCatalog_SaveImportJob_Call) Run(run func(job *datapb.ImportJob)) *DataCoordCatalog_SaveImportJob_Call

func (*DataCoordCatalog_SaveImportJob_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveImportJob_Call) RunAndReturn(run func(*datapb.ImportJob) error) *DataCoordCatalog_SaveImportJob_Call

type DataCoordCatalog_SaveImportTask_Call

type DataCoordCatalog_SaveImportTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SaveImportTask_Call) Return

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

func (*DataCoordCatalog_SaveImportTask_Call) Run

func (_c *DataCoordCatalog_SaveImportTask_Call) Run(run func(task *datapb.ImportTaskV2)) *DataCoordCatalog_SaveImportTask_Call

func (*DataCoordCatalog_SaveImportTask_Call) RunAndReturn

func (_c *DataCoordCatalog_SaveImportTask_Call) RunAndReturn(run func(*datapb.ImportTaskV2) error) *DataCoordCatalog_SaveImportTask_Call

type DataCoordCatalog_SavePartitionStatsInfo_Call

type DataCoordCatalog_SavePartitionStatsInfo_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SavePartitionStatsInfo_Call) Return

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

func (*DataCoordCatalog_SavePartitionStatsInfo_Call) Run

func (_c *DataCoordCatalog_SavePartitionStatsInfo_Call) Run(run func(ctx context.Context, info *datapb.PartitionStatsInfo)) *DataCoordCatalog_SavePartitionStatsInfo_Call

func (*DataCoordCatalog_SavePartitionStatsInfo_Call) RunAndReturn

func (_c *DataCoordCatalog_SavePartitionStatsInfo_Call) RunAndReturn(run func(context.Context, *datapb.PartitionStatsInfo) error) *DataCoordCatalog_SavePartitionStatsInfo_Call

type DataCoordCatalog_SavePreImportTask_Call

type DataCoordCatalog_SavePreImportTask_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_SavePreImportTask_Call) Return

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

func (*DataCoordCatalog_SavePreImportTask_Call) Run

func (_c *DataCoordCatalog_SavePreImportTask_Call) Run(run func(task *datapb.PreImportTask)) *DataCoordCatalog_SavePreImportTask_Call

func (*DataCoordCatalog_SavePreImportTask_Call) RunAndReturn

func (_c *DataCoordCatalog_SavePreImportTask_Call) RunAndReturn(run func(*datapb.PreImportTask) error) *DataCoordCatalog_SavePreImportTask_Call

type DataCoordCatalog_ShouldDropChannel_Call

type DataCoordCatalog_ShouldDropChannel_Call struct {
	*mock.Call
}

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

func (*DataCoordCatalog_ShouldDropChannel_Call) Return

func (_c *DataCoordCatalog_ShouldDropChannel_Call) Return(_a0 bool) *DataCoordCatalog_ShouldDropChannel_Call

func (*DataCoordCatalog_ShouldDropChannel_Call) Run

func (_c *DataCoordCatalog_ShouldDropChannel_Call) Run(run func(ctx context.Context, channel string)) *DataCoordCatalog_ShouldDropChannel_Call

func (*DataCoordCatalog_ShouldDropChannel_Call) RunAndReturn

func (_c *DataCoordCatalog_ShouldDropChannel_Call) RunAndReturn(run func(context.Context, string) bool) *DataCoordCatalog_ShouldDropChannel_Call

type QueryCoordCatalog

type QueryCoordCatalog struct {
	mock.Mock
}

QueryCoordCatalog is an autogenerated mock type for the QueryCoordCatalog type

func NewQueryCoordCatalog

func NewQueryCoordCatalog(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueryCoordCatalog

NewQueryCoordCatalog creates a new instance of QueryCoordCatalog. 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 (*QueryCoordCatalog) EXPECT

func (_m *QueryCoordCatalog) EXPECT() *QueryCoordCatalog_Expecter

func (*QueryCoordCatalog) GetCollectionTargets

func (_m *QueryCoordCatalog) GetCollectionTargets() (map[int64]*querypb.CollectionTarget, error)

GetCollectionTargets provides a mock function with given fields:

func (*QueryCoordCatalog) GetCollections

func (_m *QueryCoordCatalog) GetCollections() ([]*querypb.CollectionLoadInfo, error)

GetCollections provides a mock function with given fields:

func (*QueryCoordCatalog) GetPartitions

func (_m *QueryCoordCatalog) GetPartitions() (map[int64][]*querypb.PartitionLoadInfo, error)

GetPartitions provides a mock function with given fields:

func (*QueryCoordCatalog) GetReplicas

func (_m *QueryCoordCatalog) GetReplicas() ([]*querypb.Replica, error)

GetReplicas provides a mock function with given fields:

func (*QueryCoordCatalog) GetResourceGroups

func (_m *QueryCoordCatalog) GetResourceGroups() ([]*querypb.ResourceGroup, error)

GetResourceGroups provides a mock function with given fields:

func (*QueryCoordCatalog) ReleaseCollection

func (_m *QueryCoordCatalog) ReleaseCollection(collection int64) error

ReleaseCollection provides a mock function with given fields: collection

func (*QueryCoordCatalog) ReleasePartition

func (_m *QueryCoordCatalog) ReleasePartition(collection int64, partitions ...int64) error

ReleasePartition provides a mock function with given fields: collection, partitions

func (*QueryCoordCatalog) ReleaseReplica

func (_m *QueryCoordCatalog) ReleaseReplica(collection int64, replica int64) error

ReleaseReplica provides a mock function with given fields: collection, replica

func (*QueryCoordCatalog) ReleaseReplicas

func (_m *QueryCoordCatalog) ReleaseReplicas(collectionID int64) error

ReleaseReplicas provides a mock function with given fields: collectionID

func (*QueryCoordCatalog) RemoveCollectionTarget

func (_m *QueryCoordCatalog) RemoveCollectionTarget(collectionID int64) error

RemoveCollectionTarget provides a mock function with given fields: collectionID

func (*QueryCoordCatalog) RemoveResourceGroup

func (_m *QueryCoordCatalog) RemoveResourceGroup(rgName string) error

RemoveResourceGroup provides a mock function with given fields: rgName

func (*QueryCoordCatalog) SaveCollection

func (_m *QueryCoordCatalog) SaveCollection(collection *querypb.CollectionLoadInfo, partitions ...*querypb.PartitionLoadInfo) error

SaveCollection provides a mock function with given fields: collection, partitions

func (*QueryCoordCatalog) SaveCollectionTargets

func (_m *QueryCoordCatalog) SaveCollectionTargets(target ...*querypb.CollectionTarget) error

SaveCollectionTargets provides a mock function with given fields: target

func (*QueryCoordCatalog) SavePartition

func (_m *QueryCoordCatalog) SavePartition(info ...*querypb.PartitionLoadInfo) error

SavePartition provides a mock function with given fields: info

func (*QueryCoordCatalog) SaveReplica

func (_m *QueryCoordCatalog) SaveReplica(replicas ...*querypb.Replica) error

SaveReplica provides a mock function with given fields: replicas

func (*QueryCoordCatalog) SaveResourceGroup

func (_m *QueryCoordCatalog) SaveResourceGroup(rgs ...*querypb.ResourceGroup) error

SaveResourceGroup provides a mock function with given fields: rgs

type QueryCoordCatalog_Expecter

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

func (*QueryCoordCatalog_Expecter) GetCollectionTargets

func (_e *QueryCoordCatalog_Expecter) GetCollectionTargets() *QueryCoordCatalog_GetCollectionTargets_Call

GetCollectionTargets is a helper method to define mock.On call

func (*QueryCoordCatalog_Expecter) GetCollections

func (_e *QueryCoordCatalog_Expecter) GetCollections() *QueryCoordCatalog_GetCollections_Call

GetCollections is a helper method to define mock.On call

func (*QueryCoordCatalog_Expecter) GetPartitions

func (_e *QueryCoordCatalog_Expecter) GetPartitions() *QueryCoordCatalog_GetPartitions_Call

GetPartitions is a helper method to define mock.On call

func (*QueryCoordCatalog_Expecter) GetReplicas

func (_e *QueryCoordCatalog_Expecter) GetReplicas() *QueryCoordCatalog_GetReplicas_Call

GetReplicas is a helper method to define mock.On call

func (*QueryCoordCatalog_Expecter) GetResourceGroups

func (_e *QueryCoordCatalog_Expecter) GetResourceGroups() *QueryCoordCatalog_GetResourceGroups_Call

GetResourceGroups is a helper method to define mock.On call

func (*QueryCoordCatalog_Expecter) ReleaseCollection

func (_e *QueryCoordCatalog_Expecter) ReleaseCollection(collection interface{}) *QueryCoordCatalog_ReleaseCollection_Call

ReleaseCollection is a helper method to define mock.On call

• collection int64

func (*QueryCoordCatalog_Expecter) ReleasePartition

func (_e *QueryCoordCatalog_Expecter) ReleasePartition(collection interface{}, partitions ...interface{}) *QueryCoordCatalog_ReleasePartition_Call

ReleasePartition is a helper method to define mock.On call

• collection int64
• partitions ...int64

func (*QueryCoordCatalog_Expecter) ReleaseReplica

func (_e *QueryCoordCatalog_Expecter) ReleaseReplica(collection interface{}, replica interface{}) *QueryCoordCatalog_ReleaseReplica_Call

ReleaseReplica is a helper method to define mock.On call

• collection int64
• replica int64

func (*QueryCoordCatalog_Expecter) ReleaseReplicas

func (_e *QueryCoordCatalog_Expecter) ReleaseReplicas(collectionID interface{}) *QueryCoordCatalog_ReleaseReplicas_Call

ReleaseReplicas is a helper method to define mock.On call

• collectionID int64

func (*QueryCoordCatalog_Expecter) RemoveCollectionTarget

func (_e *QueryCoordCatalog_Expecter) RemoveCollectionTarget(collectionID interface{}) *QueryCoordCatalog_RemoveCollectionTarget_Call

RemoveCollectionTarget is a helper method to define mock.On call

• collectionID int64

func (*QueryCoordCatalog_Expecter) RemoveResourceGroup

func (_e *QueryCoordCatalog_Expecter) RemoveResourceGroup(rgName interface{}) *QueryCoordCatalog_RemoveResourceGroup_Call

RemoveResourceGroup is a helper method to define mock.On call

• rgName string

func (*QueryCoordCatalog_Expecter) SaveCollection

func (_e *QueryCoordCatalog_Expecter) SaveCollection(collection interface{}, partitions ...interface{}) *QueryCoordCatalog_SaveCollection_Call

SaveCollection is a helper method to define mock.On call

• collection *querypb.CollectionLoadInfo
• partitions ...*querypb.PartitionLoadInfo

func (*QueryCoordCatalog_Expecter) SaveCollectionTargets

func (_e *QueryCoordCatalog_Expecter) SaveCollectionTargets(target ...interface{}) *QueryCoordCatalog_SaveCollectionTargets_Call

SaveCollectionTargets is a helper method to define mock.On call

• target ...*querypb.CollectionTarget

func (*QueryCoordCatalog_Expecter) SavePartition

func (_e *QueryCoordCatalog_Expecter) SavePartition(info ...interface{}) *QueryCoordCatalog_SavePartition_Call

SavePartition is a helper method to define mock.On call

• info ...*querypb.PartitionLoadInfo

func (*QueryCoordCatalog_Expecter) SaveReplica

func (_e *QueryCoordCatalog_Expecter) SaveReplica(replicas ...interface{}) *QueryCoordCatalog_SaveReplica_Call

SaveReplica is a helper method to define mock.On call

• replicas ...*querypb.Replica

func (*QueryCoordCatalog_Expecter) SaveResourceGroup

func (_e *QueryCoordCatalog_Expecter) SaveResourceGroup(rgs ...interface{}) *QueryCoordCatalog_SaveResourceGroup_Call

SaveResourceGroup is a helper method to define mock.On call

• rgs ...*querypb.ResourceGroup

type QueryCoordCatalog_GetCollectionTargets_Call

type QueryCoordCatalog_GetCollectionTargets_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_GetCollectionTargets_Call) Return

func (_c *QueryCoordCatalog_GetCollectionTargets_Call) Return(_a0 map[int64]*querypb.CollectionTarget, _a1 error) *QueryCoordCatalog_GetCollectionTargets_Call

func (*QueryCoordCatalog_GetCollectionTargets_Call) Run

func (_c *QueryCoordCatalog_GetCollectionTargets_Call) Run(run func()) *QueryCoordCatalog_GetCollectionTargets_Call

func (*QueryCoordCatalog_GetCollectionTargets_Call) RunAndReturn

func (_c *QueryCoordCatalog_GetCollectionTargets_Call) RunAndReturn(run func() (map[int64]*querypb.CollectionTarget, error)) *QueryCoordCatalog_GetCollectionTargets_Call

type QueryCoordCatalog_GetCollections_Call

type QueryCoordCatalog_GetCollections_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_GetCollections_Call) Return

func (_c *QueryCoordCatalog_GetCollections_Call) Return(_a0 []*querypb.CollectionLoadInfo, _a1 error) *QueryCoordCatalog_GetCollections_Call

func (*QueryCoordCatalog_GetCollections_Call) Run

func (_c *QueryCoordCatalog_GetCollections_Call) Run(run func()) *QueryCoordCatalog_GetCollections_Call

func (*QueryCoordCatalog_GetCollections_Call) RunAndReturn

func (_c *QueryCoordCatalog_GetCollections_Call) RunAndReturn(run func() ([]*querypb.CollectionLoadInfo, error)) *QueryCoordCatalog_GetCollections_Call

type QueryCoordCatalog_GetPartitions_Call

type QueryCoordCatalog_GetPartitions_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_GetPartitions_Call) Return

func (_c *QueryCoordCatalog_GetPartitions_Call) Return(_a0 map[int64][]*querypb.PartitionLoadInfo, _a1 error) *QueryCoordCatalog_GetPartitions_Call

func (*QueryCoordCatalog_GetPartitions_Call) Run

func (_c *QueryCoordCatalog_GetPartitions_Call) Run(run func()) *QueryCoordCatalog_GetPartitions_Call

func (*QueryCoordCatalog_GetPartitions_Call) RunAndReturn

func (_c *QueryCoordCatalog_GetPartitions_Call) RunAndReturn(run func() (map[int64][]*querypb.PartitionLoadInfo, error)) *QueryCoordCatalog_GetPartitions_Call

type QueryCoordCatalog_GetReplicas_Call

type QueryCoordCatalog_GetReplicas_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_GetReplicas_Call) Return

func (_c *QueryCoordCatalog_GetReplicas_Call) Return(_a0 []*querypb.Replica, _a1 error) *QueryCoordCatalog_GetReplicas_Call

func (*QueryCoordCatalog_GetReplicas_Call) Run

func (_c *QueryCoordCatalog_GetReplicas_Call) Run(run func()) *QueryCoordCatalog_GetReplicas_Call

func (*QueryCoordCatalog_GetReplicas_Call) RunAndReturn

func (_c *QueryCoordCatalog_GetReplicas_Call) RunAndReturn(run func() ([]*querypb.Replica, error)) *QueryCoordCatalog_GetReplicas_Call

type QueryCoordCatalog_GetResourceGroups_Call

type QueryCoordCatalog_GetResourceGroups_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_GetResourceGroups_Call) Return

func (_c *QueryCoordCatalog_GetResourceGroups_Call) Return(_a0 []*querypb.ResourceGroup, _a1 error) *QueryCoordCatalog_GetResourceGroups_Call

func (*QueryCoordCatalog_GetResourceGroups_Call) Run

func (_c *QueryCoordCatalog_GetResourceGroups_Call) Run(run func()) *QueryCoordCatalog_GetResourceGroups_Call

func (*QueryCoordCatalog_GetResourceGroups_Call) RunAndReturn

func (_c *QueryCoordCatalog_GetResourceGroups_Call) RunAndReturn(run func() ([]*querypb.ResourceGroup, error)) *QueryCoordCatalog_GetResourceGroups_Call

type QueryCoordCatalog_ReleaseCollection_Call

type QueryCoordCatalog_ReleaseCollection_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_ReleaseCollection_Call) Return

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

func (*QueryCoordCatalog_ReleaseCollection_Call) Run

func (_c *QueryCoordCatalog_ReleaseCollection_Call) Run(run func(collection int64)) *QueryCoordCatalog_ReleaseCollection_Call

func (*QueryCoordCatalog_ReleaseCollection_Call) RunAndReturn

func (_c *QueryCoordCatalog_ReleaseCollection_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_ReleaseCollection_Call

type QueryCoordCatalog_ReleasePartition_Call

type QueryCoordCatalog_ReleasePartition_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_ReleasePartition_Call) Return

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

func (*QueryCoordCatalog_ReleasePartition_Call) Run

func (_c *QueryCoordCatalog_ReleasePartition_Call) Run(run func(collection int64, partitions ...int64)) *QueryCoordCatalog_ReleasePartition_Call

func (*QueryCoordCatalog_ReleasePartition_Call) RunAndReturn

func (_c *QueryCoordCatalog_ReleasePartition_Call) RunAndReturn(run func(int64, ...int64) error) *QueryCoordCatalog_ReleasePartition_Call

type QueryCoordCatalog_ReleaseReplica_Call

type QueryCoordCatalog_ReleaseReplica_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_ReleaseReplica_Call) Return

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

func (*QueryCoordCatalog_ReleaseReplica_Call) Run

func (_c *QueryCoordCatalog_ReleaseReplica_Call) Run(run func(collection int64, replica int64)) *QueryCoordCatalog_ReleaseReplica_Call

func (*QueryCoordCatalog_ReleaseReplica_Call) RunAndReturn

func (_c *QueryCoordCatalog_ReleaseReplica_Call) RunAndReturn(run func(int64, int64) error) *QueryCoordCatalog_ReleaseReplica_Call

type QueryCoordCatalog_ReleaseReplicas_Call

type QueryCoordCatalog_ReleaseReplicas_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_ReleaseReplicas_Call) Return

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

func (*QueryCoordCatalog_ReleaseReplicas_Call) Run

func (_c *QueryCoordCatalog_ReleaseReplicas_Call) Run(run func(collectionID int64)) *QueryCoordCatalog_ReleaseReplicas_Call

func (*QueryCoordCatalog_ReleaseReplicas_Call) RunAndReturn

func (_c *QueryCoordCatalog_ReleaseReplicas_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_ReleaseReplicas_Call

type QueryCoordCatalog_RemoveCollectionTarget_Call

type QueryCoordCatalog_RemoveCollectionTarget_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_RemoveCollectionTarget_Call) Return

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

func (*QueryCoordCatalog_RemoveCollectionTarget_Call) Run

func (_c *QueryCoordCatalog_RemoveCollectionTarget_Call) Run(run func(collectionID int64)) *QueryCoordCatalog_RemoveCollectionTarget_Call

func (*QueryCoordCatalog_RemoveCollectionTarget_Call) RunAndReturn

func (_c *QueryCoordCatalog_RemoveCollectionTarget_Call) RunAndReturn(run func(int64) error) *QueryCoordCatalog_RemoveCollectionTarget_Call

type QueryCoordCatalog_RemoveResourceGroup_Call

type QueryCoordCatalog_RemoveResourceGroup_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_RemoveResourceGroup_Call) Return

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

func (*QueryCoordCatalog_RemoveResourceGroup_Call) Run

func (_c *QueryCoordCatalog_RemoveResourceGroup_Call) Run(run func(rgName string)) *QueryCoordCatalog_RemoveResourceGroup_Call

func (*QueryCoordCatalog_RemoveResourceGroup_Call) RunAndReturn

func (_c *QueryCoordCatalog_RemoveResourceGroup_Call) RunAndReturn(run func(string) error) *QueryCoordCatalog_RemoveResourceGroup_Call

type QueryCoordCatalog_SaveCollectionTargets_Call

type QueryCoordCatalog_SaveCollectionTargets_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_SaveCollectionTargets_Call) Return

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

func (*QueryCoordCatalog_SaveCollectionTargets_Call) Run

func (_c *QueryCoordCatalog_SaveCollectionTargets_Call) Run(run func(target ...*querypb.CollectionTarget)) *QueryCoordCatalog_SaveCollectionTargets_Call

func (*QueryCoordCatalog_SaveCollectionTargets_Call) RunAndReturn

func (_c *QueryCoordCatalog_SaveCollectionTargets_Call) RunAndReturn(run func(...*querypb.CollectionTarget) error) *QueryCoordCatalog_SaveCollectionTargets_Call

type QueryCoordCatalog_SaveCollection_Call

type QueryCoordCatalog_SaveCollection_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_SaveCollection_Call) Return

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

func (*QueryCoordCatalog_SaveCollection_Call) Run

func (_c *QueryCoordCatalog_SaveCollection_Call) Run(run func(collection *querypb.CollectionLoadInfo, partitions ...*querypb.PartitionLoadInfo)) *QueryCoordCatalog_SaveCollection_Call

func (*QueryCoordCatalog_SaveCollection_Call) RunAndReturn

func (_c *QueryCoordCatalog_SaveCollection_Call) RunAndReturn(run func(*querypb.CollectionLoadInfo, ...*querypb.PartitionLoadInfo) error) *QueryCoordCatalog_SaveCollection_Call

type QueryCoordCatalog_SavePartition_Call

type QueryCoordCatalog_SavePartition_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_SavePartition_Call) Return

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

func (*QueryCoordCatalog_SavePartition_Call) Run

func (_c *QueryCoordCatalog_SavePartition_Call) Run(run func(info ...*querypb.PartitionLoadInfo)) *QueryCoordCatalog_SavePartition_Call

func (*QueryCoordCatalog_SavePartition_Call) RunAndReturn

func (_c *QueryCoordCatalog_SavePartition_Call) RunAndReturn(run func(...*querypb.PartitionLoadInfo) error) *QueryCoordCatalog_SavePartition_Call

type QueryCoordCatalog_SaveReplica_Call

type QueryCoordCatalog_SaveReplica_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_SaveReplica_Call) Return

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

func (*QueryCoordCatalog_SaveReplica_Call) Run

func (_c *QueryCoordCatalog_SaveReplica_Call) Run(run func(replicas ...*querypb.Replica)) *QueryCoordCatalog_SaveReplica_Call

func (*QueryCoordCatalog_SaveReplica_Call) RunAndReturn

func (_c *QueryCoordCatalog_SaveReplica_Call) RunAndReturn(run func(...*querypb.Replica) error) *QueryCoordCatalog_SaveReplica_Call

type QueryCoordCatalog_SaveResourceGroup_Call

type QueryCoordCatalog_SaveResourceGroup_Call struct {
	*mock.Call
}

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

func (*QueryCoordCatalog_SaveResourceGroup_Call) Return

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

func (*QueryCoordCatalog_SaveResourceGroup_Call) Run

func (_c *QueryCoordCatalog_SaveResourceGroup_Call) Run(run func(rgs ...*querypb.ResourceGroup)) *QueryCoordCatalog_SaveResourceGroup_Call

func (*QueryCoordCatalog_SaveResourceGroup_Call) RunAndReturn

func (_c *QueryCoordCatalog_SaveResourceGroup_Call) RunAndReturn(run func(...*querypb.ResourceGroup) error) *QueryCoordCatalog_SaveResourceGroup_Call

type RootCoordCatalog

type RootCoordCatalog struct {
	mock.Mock
}

RootCoordCatalog is an autogenerated mock type for the RootCoordCatalog type

func NewRootCoordCatalog

func NewRootCoordCatalog(t interface {
	mock.TestingT
	Cleanup(func())
}) *RootCoordCatalog

NewRootCoordCatalog creates a new instance of RootCoordCatalog. 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 (*RootCoordCatalog) AlterAlias

func (_m *RootCoordCatalog) AlterAlias(ctx context.Context, alias *model.Alias, ts uint64) error

AlterAlias provides a mock function with given fields: ctx, alias, ts

func (*RootCoordCatalog) AlterCollection

func (_m *RootCoordCatalog) AlterCollection(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, alterType metastore.AlterType, ts uint64) error

AlterCollection provides a mock function with given fields: ctx, oldColl, newColl, alterType, ts

func (*RootCoordCatalog) AlterCredential

func (_m *RootCoordCatalog) AlterCredential(ctx context.Context, credential *model.Credential) error

AlterCredential provides a mock function with given fields: ctx, credential

func (*RootCoordCatalog) AlterDatabase

func (_m *RootCoordCatalog) AlterDatabase(ctx context.Context, newDB *model.Database, ts uint64) error

AlterDatabase provides a mock function with given fields: ctx, newDB, ts

func (*RootCoordCatalog) AlterGrant

func (_m *RootCoordCatalog) AlterGrant(ctx context.Context, tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType) error

AlterGrant provides a mock function with given fields: ctx, tenant, entity, operateType

func (*RootCoordCatalog) AlterPartition

func (_m *RootCoordCatalog) AlterPartition(ctx context.Context, dbID int64, oldPart *model.Partition, newPart *model.Partition, alterType metastore.AlterType, ts uint64) error

AlterPartition provides a mock function with given fields: ctx, dbID, oldPart, newPart, alterType, ts

func (*RootCoordCatalog) AlterUserRole

func (_m *RootCoordCatalog) AlterUserRole(ctx context.Context, tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType) error

AlterUserRole provides a mock function with given fields: ctx, tenant, userEntity, roleEntity, operateType

func (*RootCoordCatalog) Close

func (_m *RootCoordCatalog) Close()

Close provides a mock function with given fields:

func (*RootCoordCatalog) CollectionExists

func (_m *RootCoordCatalog) CollectionExists(ctx context.Context, dbID int64, collectionID int64, ts uint64) bool

CollectionExists provides a mock function with given fields: ctx, dbID, collectionID, ts

func (*RootCoordCatalog) CreateAlias

func (_m *RootCoordCatalog) CreateAlias(ctx context.Context, alias *model.Alias, ts uint64) error

CreateAlias provides a mock function with given fields: ctx, alias, ts

func (*RootCoordCatalog) CreateCollection

func (_m *RootCoordCatalog) CreateCollection(ctx context.Context, collectionInfo *model.Collection, ts uint64) error

CreateCollection provides a mock function with given fields: ctx, collectionInfo, ts

func (*RootCoordCatalog) CreateCredential

func (_m *RootCoordCatalog) CreateCredential(ctx context.Context, credential *model.Credential) error

CreateCredential provides a mock function with given fields: ctx, credential

func (*RootCoordCatalog) CreateDatabase

func (_m *RootCoordCatalog) CreateDatabase(ctx context.Context, db *model.Database, ts uint64) error

CreateDatabase provides a mock function with given fields: ctx, db, ts

func (*RootCoordCatalog) CreatePartition

func (_m *RootCoordCatalog) CreatePartition(ctx context.Context, dbID int64, partition *model.Partition, ts uint64) error

CreatePartition provides a mock function with given fields: ctx, dbID, partition, ts

func (*RootCoordCatalog) CreateRole

func (_m *RootCoordCatalog) CreateRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity) error

CreateRole provides a mock function with given fields: ctx, tenant, entity

func (*RootCoordCatalog) DeleteGrant

func (_m *RootCoordCatalog) DeleteGrant(ctx context.Context, tenant string, role *milvuspb.RoleEntity) error

DeleteGrant provides a mock function with given fields: ctx, tenant, role

func (*RootCoordCatalog) DropAlias

func (_m *RootCoordCatalog) DropAlias(ctx context.Context, dbID int64, alias string, ts uint64) error

DropAlias provides a mock function with given fields: ctx, dbID, alias, ts

func (*RootCoordCatalog) DropCollection

func (_m *RootCoordCatalog) DropCollection(ctx context.Context, collectionInfo *model.Collection, ts uint64) error

DropCollection provides a mock function with given fields: ctx, collectionInfo, ts

func (*RootCoordCatalog) DropCredential

func (_m *RootCoordCatalog) DropCredential(ctx context.Context, username string) error

DropCredential provides a mock function with given fields: ctx, username

func (*RootCoordCatalog) DropDatabase

func (_m *RootCoordCatalog) DropDatabase(ctx context.Context, dbID int64, ts uint64) error

DropDatabase provides a mock function with given fields: ctx, dbID, ts

func (*RootCoordCatalog) DropPartition

func (_m *RootCoordCatalog) DropPartition(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64) error

DropPartition provides a mock function with given fields: ctx, dbID, collectionID, partitionID, ts

func (*RootCoordCatalog) DropRole

func (_m *RootCoordCatalog) DropRole(ctx context.Context, tenant string, roleName string) error

DropRole provides a mock function with given fields: ctx, tenant, roleName

func (*RootCoordCatalog) EXPECT

func (_m *RootCoordCatalog) EXPECT() *RootCoordCatalog_Expecter

func (*RootCoordCatalog) GetCollectionByID

func (_m *RootCoordCatalog) GetCollectionByID(ctx context.Context, dbID int64, ts uint64, collectionID int64) (*model.Collection, error)

GetCollectionByID provides a mock function with given fields: ctx, dbID, ts, collectionID

func (*RootCoordCatalog) GetCollectionByName

func (_m *RootCoordCatalog) GetCollectionByName(ctx context.Context, dbID int64, collectionName string, ts uint64) (*model.Collection, error)

GetCollectionByName provides a mock function with given fields: ctx, dbID, collectionName, ts

func (*RootCoordCatalog) GetCredential

func (_m *RootCoordCatalog) GetCredential(ctx context.Context, username string) (*model.Credential, error)

GetCredential provides a mock function with given fields: ctx, username

func (*RootCoordCatalog) ListAliases

func (_m *RootCoordCatalog) ListAliases(ctx context.Context, dbID int64, ts uint64) ([]*model.Alias, error)

ListAliases provides a mock function with given fields: ctx, dbID, ts

func (*RootCoordCatalog) ListCollections

func (_m *RootCoordCatalog) ListCollections(ctx context.Context, dbID int64, ts uint64) ([]*model.Collection, error)

ListCollections provides a mock function with given fields: ctx, dbID, ts

func (*RootCoordCatalog) ListCredentials

func (_m *RootCoordCatalog) ListCredentials(ctx context.Context) ([]string, error)

ListCredentials provides a mock function with given fields: ctx

func (*RootCoordCatalog) ListDatabases

func (_m *RootCoordCatalog) ListDatabases(ctx context.Context, ts uint64) ([]*model.Database, error)

ListDatabases provides a mock function with given fields: ctx, ts

func (*RootCoordCatalog) ListGrant

func (_m *RootCoordCatalog) ListGrant(ctx context.Context, tenant string, entity *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)

ListGrant provides a mock function with given fields: ctx, tenant, entity

func (*RootCoordCatalog) ListPolicy

func (_m *RootCoordCatalog) ListPolicy(ctx context.Context, tenant string) ([]string, error)

ListPolicy provides a mock function with given fields: ctx, tenant

func (*RootCoordCatalog) ListRole

func (_m *RootCoordCatalog) ListRole(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool) ([]*milvuspb.RoleResult, error)

ListRole provides a mock function with given fields: ctx, tenant, entity, includeUserInfo

func (*RootCoordCatalog) ListUser

func (_m *RootCoordCatalog) ListUser(ctx context.Context, tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool) ([]*milvuspb.UserResult, error)

ListUser provides a mock function with given fields: ctx, tenant, entity, includeRoleInfo

func (*RootCoordCatalog) ListUserRole

func (_m *RootCoordCatalog) ListUserRole(ctx context.Context, tenant string) ([]string, error)

ListUserRole provides a mock function with given fields: ctx, tenant

type RootCoordCatalog_AlterAlias_Call

type RootCoordCatalog_AlterAlias_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterAlias_Call) Return

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

func (*RootCoordCatalog_AlterAlias_Call) Run

func (_c *RootCoordCatalog_AlterAlias_Call) Run(run func(ctx context.Context, alias *model.Alias, ts uint64)) *RootCoordCatalog_AlterAlias_Call

func (*RootCoordCatalog_AlterAlias_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterAlias_Call) RunAndReturn(run func(context.Context, *model.Alias, uint64) error) *RootCoordCatalog_AlterAlias_Call

type RootCoordCatalog_AlterCollection_Call

type RootCoordCatalog_AlterCollection_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterCollection_Call) Return

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

func (*RootCoordCatalog_AlterCollection_Call) Run

func (_c *RootCoordCatalog_AlterCollection_Call) Run(run func(ctx context.Context, oldColl *model.Collection, newColl *model.Collection, alterType metastore.AlterType, ts uint64)) *RootCoordCatalog_AlterCollection_Call

func (*RootCoordCatalog_AlterCollection_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, *model.Collection, metastore.AlterType, uint64) error) *RootCoordCatalog_AlterCollection_Call

type RootCoordCatalog_AlterCredential_Call

type RootCoordCatalog_AlterCredential_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterCredential_Call) Return

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

func (*RootCoordCatalog_AlterCredential_Call) Run

func (_c *RootCoordCatalog_AlterCredential_Call) Run(run func(ctx context.Context, credential *model.Credential)) *RootCoordCatalog_AlterCredential_Call

func (*RootCoordCatalog_AlterCredential_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterCredential_Call) RunAndReturn(run func(context.Context, *model.Credential) error) *RootCoordCatalog_AlterCredential_Call

type RootCoordCatalog_AlterDatabase_Call

type RootCoordCatalog_AlterDatabase_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterDatabase_Call) Return

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

func (*RootCoordCatalog_AlterDatabase_Call) Run

func (_c *RootCoordCatalog_AlterDatabase_Call) Run(run func(ctx context.Context, newDB *model.Database, ts uint64)) *RootCoordCatalog_AlterDatabase_Call

func (*RootCoordCatalog_AlterDatabase_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *RootCoordCatalog_AlterDatabase_Call

type RootCoordCatalog_AlterGrant_Call

type RootCoordCatalog_AlterGrant_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterGrant_Call) Return

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

func (*RootCoordCatalog_AlterGrant_Call) Run

func (_c *RootCoordCatalog_AlterGrant_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.GrantEntity, operateType milvuspb.OperatePrivilegeType)) *RootCoordCatalog_AlterGrant_Call

func (*RootCoordCatalog_AlterGrant_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.GrantEntity, milvuspb.OperatePrivilegeType) error) *RootCoordCatalog_AlterGrant_Call

type RootCoordCatalog_AlterPartition_Call

type RootCoordCatalog_AlterPartition_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterPartition_Call) Return

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

func (*RootCoordCatalog_AlterPartition_Call) Run

func (_c *RootCoordCatalog_AlterPartition_Call) Run(run func(ctx context.Context, dbID int64, oldPart *model.Partition, newPart *model.Partition, alterType metastore.AlterType, ts uint64)) *RootCoordCatalog_AlterPartition_Call

func (*RootCoordCatalog_AlterPartition_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterPartition_Call) RunAndReturn(run func(context.Context, int64, *model.Partition, *model.Partition, metastore.AlterType, uint64) error) *RootCoordCatalog_AlterPartition_Call

type RootCoordCatalog_AlterUserRole_Call

type RootCoordCatalog_AlterUserRole_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_AlterUserRole_Call) Return

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

func (*RootCoordCatalog_AlterUserRole_Call) Run

func (_c *RootCoordCatalog_AlterUserRole_Call) Run(run func(ctx context.Context, tenant string, userEntity *milvuspb.UserEntity, roleEntity *milvuspb.RoleEntity, operateType milvuspb.OperateUserRoleType)) *RootCoordCatalog_AlterUserRole_Call

func (*RootCoordCatalog_AlterUserRole_Call) RunAndReturn

func (_c *RootCoordCatalog_AlterUserRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.UserEntity, *milvuspb.RoleEntity, milvuspb.OperateUserRoleType) error) *RootCoordCatalog_AlterUserRole_Call

type RootCoordCatalog_Close_Call

type RootCoordCatalog_Close_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_Close_Call) Return

func (_c *RootCoordCatalog_Close_Call) Return() *RootCoordCatalog_Close_Call

func (*RootCoordCatalog_Close_Call) Run

func (_c *RootCoordCatalog_Close_Call) Run(run func()) *RootCoordCatalog_Close_Call

func (*RootCoordCatalog_Close_Call) RunAndReturn

func (_c *RootCoordCatalog_Close_Call) RunAndReturn(run func()) *RootCoordCatalog_Close_Call

type RootCoordCatalog_CollectionExists_Call

type RootCoordCatalog_CollectionExists_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CollectionExists_Call) Return

func (_c *RootCoordCatalog_CollectionExists_Call) Return(_a0 bool) *RootCoordCatalog_CollectionExists_Call

func (*RootCoordCatalog_CollectionExists_Call) Run

func (_c *RootCoordCatalog_CollectionExists_Call) Run(run func(ctx context.Context, dbID int64, collectionID int64, ts uint64)) *RootCoordCatalog_CollectionExists_Call

func (*RootCoordCatalog_CollectionExists_Call) RunAndReturn

func (_c *RootCoordCatalog_CollectionExists_Call) RunAndReturn(run func(context.Context, int64, int64, uint64) bool) *RootCoordCatalog_CollectionExists_Call

type RootCoordCatalog_CreateAlias_Call

type RootCoordCatalog_CreateAlias_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreateAlias_Call) Return

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

func (*RootCoordCatalog_CreateAlias_Call) Run

func (_c *RootCoordCatalog_CreateAlias_Call) Run(run func(ctx context.Context, alias *model.Alias, ts uint64)) *RootCoordCatalog_CreateAlias_Call

func (*RootCoordCatalog_CreateAlias_Call) RunAndReturn

func (_c *RootCoordCatalog_CreateAlias_Call) RunAndReturn(run func(context.Context, *model.Alias, uint64) error) *RootCoordCatalog_CreateAlias_Call

type RootCoordCatalog_CreateCollection_Call

type RootCoordCatalog_CreateCollection_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreateCollection_Call) Return

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

func (*RootCoordCatalog_CreateCollection_Call) Run

func (_c *RootCoordCatalog_CreateCollection_Call) Run(run func(ctx context.Context, collectionInfo *model.Collection, ts uint64)) *RootCoordCatalog_CreateCollection_Call

func (*RootCoordCatalog_CreateCollection_Call) RunAndReturn

func (_c *RootCoordCatalog_CreateCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, uint64) error) *RootCoordCatalog_CreateCollection_Call

type RootCoordCatalog_CreateCredential_Call

type RootCoordCatalog_CreateCredential_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreateCredential_Call) Return

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

func (*RootCoordCatalog_CreateCredential_Call) Run

func (_c *RootCoordCatalog_CreateCredential_Call) Run(run func(ctx context.Context, credential *model.Credential)) *RootCoordCatalog_CreateCredential_Call

func (*RootCoordCatalog_CreateCredential_Call) RunAndReturn

func (_c *RootCoordCatalog_CreateCredential_Call) RunAndReturn(run func(context.Context, *model.Credential) error) *RootCoordCatalog_CreateCredential_Call

type RootCoordCatalog_CreateDatabase_Call

type RootCoordCatalog_CreateDatabase_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreateDatabase_Call) Return

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

func (*RootCoordCatalog_CreateDatabase_Call) Run

func (_c *RootCoordCatalog_CreateDatabase_Call) Run(run func(ctx context.Context, db *model.Database, ts uint64)) *RootCoordCatalog_CreateDatabase_Call

func (*RootCoordCatalog_CreateDatabase_Call) RunAndReturn

func (_c *RootCoordCatalog_CreateDatabase_Call) RunAndReturn(run func(context.Context, *model.Database, uint64) error) *RootCoordCatalog_CreateDatabase_Call

type RootCoordCatalog_CreatePartition_Call

type RootCoordCatalog_CreatePartition_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreatePartition_Call) Return

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

func (*RootCoordCatalog_CreatePartition_Call) Run

func (_c *RootCoordCatalog_CreatePartition_Call) Run(run func(ctx context.Context, dbID int64, partition *model.Partition, ts uint64)) *RootCoordCatalog_CreatePartition_Call

func (*RootCoordCatalog_CreatePartition_Call) RunAndReturn

func (_c *RootCoordCatalog_CreatePartition_Call) RunAndReturn(run func(context.Context, int64, *model.Partition, uint64) error) *RootCoordCatalog_CreatePartition_Call

type RootCoordCatalog_CreateRole_Call

type RootCoordCatalog_CreateRole_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_CreateRole_Call) Return

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

func (*RootCoordCatalog_CreateRole_Call) Run

func (_c *RootCoordCatalog_CreateRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity)) *RootCoordCatalog_CreateRole_Call

func (*RootCoordCatalog_CreateRole_Call) RunAndReturn

func (_c *RootCoordCatalog_CreateRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *RootCoordCatalog_CreateRole_Call

type RootCoordCatalog_DeleteGrant_Call

type RootCoordCatalog_DeleteGrant_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DeleteGrant_Call) Return

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

func (*RootCoordCatalog_DeleteGrant_Call) Run

func (_c *RootCoordCatalog_DeleteGrant_Call) Run(run func(ctx context.Context, tenant string, role *milvuspb.RoleEntity)) *RootCoordCatalog_DeleteGrant_Call

func (*RootCoordCatalog_DeleteGrant_Call) RunAndReturn

func (_c *RootCoordCatalog_DeleteGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity) error) *RootCoordCatalog_DeleteGrant_Call

type RootCoordCatalog_DropAlias_Call

type RootCoordCatalog_DropAlias_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropAlias_Call) Return

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

func (*RootCoordCatalog_DropAlias_Call) Run

func (_c *RootCoordCatalog_DropAlias_Call) Run(run func(ctx context.Context, dbID int64, alias string, ts uint64)) *RootCoordCatalog_DropAlias_Call

func (*RootCoordCatalog_DropAlias_Call) RunAndReturn

func (_c *RootCoordCatalog_DropAlias_Call) RunAndReturn(run func(context.Context, int64, string, uint64) error) *RootCoordCatalog_DropAlias_Call

type RootCoordCatalog_DropCollection_Call

type RootCoordCatalog_DropCollection_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropCollection_Call) Return

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

func (*RootCoordCatalog_DropCollection_Call) Run

func (_c *RootCoordCatalog_DropCollection_Call) Run(run func(ctx context.Context, collectionInfo *model.Collection, ts uint64)) *RootCoordCatalog_DropCollection_Call

func (*RootCoordCatalog_DropCollection_Call) RunAndReturn

func (_c *RootCoordCatalog_DropCollection_Call) RunAndReturn(run func(context.Context, *model.Collection, uint64) error) *RootCoordCatalog_DropCollection_Call

type RootCoordCatalog_DropCredential_Call

type RootCoordCatalog_DropCredential_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropCredential_Call) Return

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

func (*RootCoordCatalog_DropCredential_Call) Run

func (_c *RootCoordCatalog_DropCredential_Call) Run(run func(ctx context.Context, username string)) *RootCoordCatalog_DropCredential_Call

func (*RootCoordCatalog_DropCredential_Call) RunAndReturn

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

type RootCoordCatalog_DropDatabase_Call

type RootCoordCatalog_DropDatabase_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropDatabase_Call) Return

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

func (*RootCoordCatalog_DropDatabase_Call) Run

func (_c *RootCoordCatalog_DropDatabase_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_DropDatabase_Call

func (*RootCoordCatalog_DropDatabase_Call) RunAndReturn

func (_c *RootCoordCatalog_DropDatabase_Call) RunAndReturn(run func(context.Context, int64, uint64) error) *RootCoordCatalog_DropDatabase_Call

type RootCoordCatalog_DropPartition_Call

type RootCoordCatalog_DropPartition_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropPartition_Call) Return

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

func (*RootCoordCatalog_DropPartition_Call) Run

func (_c *RootCoordCatalog_DropPartition_Call) Run(run func(ctx context.Context, dbID int64, collectionID int64, partitionID int64, ts uint64)) *RootCoordCatalog_DropPartition_Call

func (*RootCoordCatalog_DropPartition_Call) RunAndReturn

func (_c *RootCoordCatalog_DropPartition_Call) RunAndReturn(run func(context.Context, int64, int64, int64, uint64) error) *RootCoordCatalog_DropPartition_Call

type RootCoordCatalog_DropRole_Call

type RootCoordCatalog_DropRole_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_DropRole_Call) Return

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

func (*RootCoordCatalog_DropRole_Call) Run

func (_c *RootCoordCatalog_DropRole_Call) Run(run func(ctx context.Context, tenant string, roleName string)) *RootCoordCatalog_DropRole_Call

func (*RootCoordCatalog_DropRole_Call) RunAndReturn

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

type RootCoordCatalog_Expecter

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

func (*RootCoordCatalog_Expecter) AlterAlias

func (_e *RootCoordCatalog_Expecter) AlterAlias(ctx interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_AlterAlias_Call

AlterAlias is a helper method to define mock.On call

• ctx context.Context
• alias *model.Alias
• ts uint64

func (*RootCoordCatalog_Expecter) AlterCollection

func (_e *RootCoordCatalog_Expecter) AlterCollection(ctx interface{}, oldColl interface{}, newColl interface{}, alterType interface{}, ts interface{}) *RootCoordCatalog_AlterCollection_Call

AlterCollection is a helper method to define mock.On call

• ctx context.Context
• oldColl *model.Collection
• newColl *model.Collection
• alterType metastore.AlterType
• ts uint64

func (*RootCoordCatalog_Expecter) AlterCredential

func (_e *RootCoordCatalog_Expecter) AlterCredential(ctx interface{}, credential interface{}) *RootCoordCatalog_AlterCredential_Call

AlterCredential is a helper method to define mock.On call

• ctx context.Context
• credential *model.Credential

func (*RootCoordCatalog_Expecter) AlterDatabase

func (_e *RootCoordCatalog_Expecter) AlterDatabase(ctx interface{}, newDB interface{}, ts interface{}) *RootCoordCatalog_AlterDatabase_Call

AlterDatabase is a helper method to define mock.On call

• ctx context.Context
• newDB *model.Database
• ts uint64

func (*RootCoordCatalog_Expecter) AlterGrant

func (_e *RootCoordCatalog_Expecter) AlterGrant(ctx interface{}, tenant interface{}, entity interface{}, operateType interface{}) *RootCoordCatalog_AlterGrant_Call

AlterGrant is a helper method to define mock.On call

• ctx context.Context
• tenant string
• entity *milvuspb.GrantEntity
• operateType milvuspb.OperatePrivilegeType

func (*RootCoordCatalog_Expecter) AlterPartition

func (_e *RootCoordCatalog_Expecter) AlterPartition(ctx interface{}, dbID interface{}, oldPart interface{}, newPart interface{}, alterType interface{}, ts interface{}) *RootCoordCatalog_AlterPartition_Call

AlterPartition is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• oldPart *model.Partition
• newPart *model.Partition
• alterType metastore.AlterType
• ts uint64

func (*RootCoordCatalog_Expecter) AlterUserRole

func (_e *RootCoordCatalog_Expecter) AlterUserRole(ctx interface{}, tenant interface{}, userEntity interface{}, roleEntity interface{}, operateType interface{}) *RootCoordCatalog_AlterUserRole_Call

AlterUserRole is a helper method to define mock.On call

• ctx context.Context
• tenant string
• userEntity *milvuspb.UserEntity
• roleEntity *milvuspb.RoleEntity
• operateType milvuspb.OperateUserRoleType

func (*RootCoordCatalog_Expecter) Close

func (_e *RootCoordCatalog_Expecter) Close() *RootCoordCatalog_Close_Call

Close is a helper method to define mock.On call

func (*RootCoordCatalog_Expecter) CollectionExists

func (_e *RootCoordCatalog_Expecter) CollectionExists(ctx interface{}, dbID interface{}, collectionID interface{}, ts interface{}) *RootCoordCatalog_CollectionExists_Call

CollectionExists is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• collectionID int64
• ts uint64

func (*RootCoordCatalog_Expecter) CreateAlias

func (_e *RootCoordCatalog_Expecter) CreateAlias(ctx interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_CreateAlias_Call

CreateAlias is a helper method to define mock.On call

• ctx context.Context
• alias *model.Alias
• ts uint64

func (*RootCoordCatalog_Expecter) CreateCollection

func (_e *RootCoordCatalog_Expecter) CreateCollection(ctx interface{}, collectionInfo interface{}, ts interface{}) *RootCoordCatalog_CreateCollection_Call

CreateCollection is a helper method to define mock.On call

• ctx context.Context
• collectionInfo *model.Collection
• ts uint64

func (*RootCoordCatalog_Expecter) CreateCredential

func (_e *RootCoordCatalog_Expecter) CreateCredential(ctx interface{}, credential interface{}) *RootCoordCatalog_CreateCredential_Call

CreateCredential is a helper method to define mock.On call

• ctx context.Context
• credential *model.Credential

func (*RootCoordCatalog_Expecter) CreateDatabase

func (_e *RootCoordCatalog_Expecter) CreateDatabase(ctx interface{}, db interface{}, ts interface{}) *RootCoordCatalog_CreateDatabase_Call

CreateDatabase is a helper method to define mock.On call

• ctx context.Context
• db *model.Database
• ts uint64

func (*RootCoordCatalog_Expecter) CreatePartition

func (_e *RootCoordCatalog_Expecter) CreatePartition(ctx interface{}, dbID interface{}, partition interface{}, ts interface{}) *RootCoordCatalog_CreatePartition_Call

CreatePartition is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• partition *model.Partition
• ts uint64

func (*RootCoordCatalog_Expecter) CreateRole

func (_e *RootCoordCatalog_Expecter) CreateRole(ctx interface{}, tenant interface{}, entity interface{}) *RootCoordCatalog_CreateRole_Call

CreateRole is a helper method to define mock.On call

• ctx context.Context
• tenant string
• entity *milvuspb.RoleEntity

func (*RootCoordCatalog_Expecter) DeleteGrant

func (_e *RootCoordCatalog_Expecter) DeleteGrant(ctx interface{}, tenant interface{}, role interface{}) *RootCoordCatalog_DeleteGrant_Call

DeleteGrant is a helper method to define mock.On call

• ctx context.Context
• tenant string
• role *milvuspb.RoleEntity

func (*RootCoordCatalog_Expecter) DropAlias

func (_e *RootCoordCatalog_Expecter) DropAlias(ctx interface{}, dbID interface{}, alias interface{}, ts interface{}) *RootCoordCatalog_DropAlias_Call

DropAlias is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• alias string
• ts uint64

func (*RootCoordCatalog_Expecter) DropCollection

func (_e *RootCoordCatalog_Expecter) DropCollection(ctx interface{}, collectionInfo interface{}, ts interface{}) *RootCoordCatalog_DropCollection_Call

DropCollection is a helper method to define mock.On call

• ctx context.Context
• collectionInfo *model.Collection
• ts uint64

func (*RootCoordCatalog_Expecter) DropCredential

func (_e *RootCoordCatalog_Expecter) DropCredential(ctx interface{}, username interface{}) *RootCoordCatalog_DropCredential_Call

DropCredential is a helper method to define mock.On call

• ctx context.Context
• username string

func (*RootCoordCatalog_Expecter) DropDatabase

func (_e *RootCoordCatalog_Expecter) DropDatabase(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_DropDatabase_Call

DropDatabase is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• ts uint64

func (*RootCoordCatalog_Expecter) DropPartition

func (_e *RootCoordCatalog_Expecter) DropPartition(ctx interface{}, dbID interface{}, collectionID interface{}, partitionID interface{}, ts interface{}) *RootCoordCatalog_DropPartition_Call

DropPartition is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• collectionID int64
• partitionID int64
• ts uint64

func (*RootCoordCatalog_Expecter) DropRole

func (_e *RootCoordCatalog_Expecter) DropRole(ctx interface{}, tenant interface{}, roleName interface{}) *RootCoordCatalog_DropRole_Call

DropRole is a helper method to define mock.On call

• ctx context.Context
• tenant string
• roleName string

func (*RootCoordCatalog_Expecter) GetCollectionByID

func (_e *RootCoordCatalog_Expecter) GetCollectionByID(ctx interface{}, dbID interface{}, ts interface{}, collectionID interface{}) *RootCoordCatalog_GetCollectionByID_Call

GetCollectionByID is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• ts uint64
• collectionID int64

func (*RootCoordCatalog_Expecter) GetCollectionByName

func (_e *RootCoordCatalog_Expecter) GetCollectionByName(ctx interface{}, dbID interface{}, collectionName interface{}, ts interface{}) *RootCoordCatalog_GetCollectionByName_Call

GetCollectionByName is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• collectionName string
• ts uint64

func (*RootCoordCatalog_Expecter) GetCredential

func (_e *RootCoordCatalog_Expecter) GetCredential(ctx interface{}, username interface{}) *RootCoordCatalog_GetCredential_Call

GetCredential is a helper method to define mock.On call

• ctx context.Context
• username string

func (*RootCoordCatalog_Expecter) ListAliases

func (_e *RootCoordCatalog_Expecter) ListAliases(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_ListAliases_Call

ListAliases is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• ts uint64

func (*RootCoordCatalog_Expecter) ListCollections

func (_e *RootCoordCatalog_Expecter) ListCollections(ctx interface{}, dbID interface{}, ts interface{}) *RootCoordCatalog_ListCollections_Call

ListCollections is a helper method to define mock.On call

• ctx context.Context
• dbID int64
• ts uint64

func (*RootCoordCatalog_Expecter) ListCredentials

func (_e *RootCoordCatalog_Expecter) ListCredentials(ctx interface{}) *RootCoordCatalog_ListCredentials_Call

ListCredentials is a helper method to define mock.On call

• ctx context.Context

func (*RootCoordCatalog_Expecter) ListDatabases

func (_e *RootCoordCatalog_Expecter) ListDatabases(ctx interface{}, ts interface{}) *RootCoordCatalog_ListDatabases_Call

ListDatabases is a helper method to define mock.On call

• ctx context.Context
• ts uint64

func (*RootCoordCatalog_Expecter) ListGrant

func (_e *RootCoordCatalog_Expecter) ListGrant(ctx interface{}, tenant interface{}, entity interface{}) *RootCoordCatalog_ListGrant_Call

ListGrant is a helper method to define mock.On call

• ctx context.Context
• tenant string
• entity *milvuspb.GrantEntity

func (*RootCoordCatalog_Expecter) ListPolicy

func (_e *RootCoordCatalog_Expecter) ListPolicy(ctx interface{}, tenant interface{}) *RootCoordCatalog_ListPolicy_Call

ListPolicy is a helper method to define mock.On call

• ctx context.Context
• tenant string

func (*RootCoordCatalog_Expecter) ListRole

func (_e *RootCoordCatalog_Expecter) ListRole(ctx interface{}, tenant interface{}, entity interface{}, includeUserInfo interface{}) *RootCoordCatalog_ListRole_Call

ListRole is a helper method to define mock.On call

• ctx context.Context
• tenant string
• entity *milvuspb.RoleEntity
• includeUserInfo bool

func (*RootCoordCatalog_Expecter) ListUser

func (_e *RootCoordCatalog_Expecter) ListUser(ctx interface{}, tenant interface{}, entity interface{}, includeRoleInfo interface{}) *RootCoordCatalog_ListUser_Call

ListUser is a helper method to define mock.On call

• ctx context.Context
• tenant string
• entity *milvuspb.UserEntity
• includeRoleInfo bool

func (*RootCoordCatalog_Expecter) ListUserRole

func (_e *RootCoordCatalog_Expecter) ListUserRole(ctx interface{}, tenant interface{}) *RootCoordCatalog_ListUserRole_Call

ListUserRole is a helper method to define mock.On call

• ctx context.Context
• tenant string

type RootCoordCatalog_GetCollectionByID_Call

type RootCoordCatalog_GetCollectionByID_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_GetCollectionByID_Call) Return

func (_c *RootCoordCatalog_GetCollectionByID_Call) Return(_a0 *model.Collection, _a1 error) *RootCoordCatalog_GetCollectionByID_Call

func (*RootCoordCatalog_GetCollectionByID_Call) Run

func (_c *RootCoordCatalog_GetCollectionByID_Call) Run(run func(ctx context.Context, dbID int64, ts uint64, collectionID int64)) *RootCoordCatalog_GetCollectionByID_Call

func (*RootCoordCatalog_GetCollectionByID_Call) RunAndReturn

func (_c *RootCoordCatalog_GetCollectionByID_Call) RunAndReturn(run func(context.Context, int64, uint64, int64) (*model.Collection, error)) *RootCoordCatalog_GetCollectionByID_Call

type RootCoordCatalog_GetCollectionByName_Call

type RootCoordCatalog_GetCollectionByName_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_GetCollectionByName_Call) Return

func (_c *RootCoordCatalog_GetCollectionByName_Call) Return(_a0 *model.Collection, _a1 error) *RootCoordCatalog_GetCollectionByName_Call

func (*RootCoordCatalog_GetCollectionByName_Call) Run

func (_c *RootCoordCatalog_GetCollectionByName_Call) Run(run func(ctx context.Context, dbID int64, collectionName string, ts uint64)) *RootCoordCatalog_GetCollectionByName_Call

func (*RootCoordCatalog_GetCollectionByName_Call) RunAndReturn

func (_c *RootCoordCatalog_GetCollectionByName_Call) RunAndReturn(run func(context.Context, int64, string, uint64) (*model.Collection, error)) *RootCoordCatalog_GetCollectionByName_Call

type RootCoordCatalog_GetCredential_Call

type RootCoordCatalog_GetCredential_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_GetCredential_Call) Return

func (_c *RootCoordCatalog_GetCredential_Call) Return(_a0 *model.Credential, _a1 error) *RootCoordCatalog_GetCredential_Call

func (*RootCoordCatalog_GetCredential_Call) Run

func (_c *RootCoordCatalog_GetCredential_Call) Run(run func(ctx context.Context, username string)) *RootCoordCatalog_GetCredential_Call

func (*RootCoordCatalog_GetCredential_Call) RunAndReturn

func (_c *RootCoordCatalog_GetCredential_Call) RunAndReturn(run func(context.Context, string) (*model.Credential, error)) *RootCoordCatalog_GetCredential_Call

type RootCoordCatalog_ListAliases_Call

type RootCoordCatalog_ListAliases_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListAliases_Call) Return

func (_c *RootCoordCatalog_ListAliases_Call) Return(_a0 []*model.Alias, _a1 error) *RootCoordCatalog_ListAliases_Call

func (*RootCoordCatalog_ListAliases_Call) Run

func (_c *RootCoordCatalog_ListAliases_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_ListAliases_Call

func (*RootCoordCatalog_ListAliases_Call) RunAndReturn

func (_c *RootCoordCatalog_ListAliases_Call) RunAndReturn(run func(context.Context, int64, uint64) ([]*model.Alias, error)) *RootCoordCatalog_ListAliases_Call

type RootCoordCatalog_ListCollections_Call

type RootCoordCatalog_ListCollections_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListCollections_Call) Return

func (_c *RootCoordCatalog_ListCollections_Call) Return(_a0 []*model.Collection, _a1 error) *RootCoordCatalog_ListCollections_Call

func (*RootCoordCatalog_ListCollections_Call) Run

func (_c *RootCoordCatalog_ListCollections_Call) Run(run func(ctx context.Context, dbID int64, ts uint64)) *RootCoordCatalog_ListCollections_Call

func (*RootCoordCatalog_ListCollections_Call) RunAndReturn

func (_c *RootCoordCatalog_ListCollections_Call) RunAndReturn(run func(context.Context, int64, uint64) ([]*model.Collection, error)) *RootCoordCatalog_ListCollections_Call

type RootCoordCatalog_ListCredentials_Call

type RootCoordCatalog_ListCredentials_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListCredentials_Call) Return

func (_c *RootCoordCatalog_ListCredentials_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListCredentials_Call

func (*RootCoordCatalog_ListCredentials_Call) Run

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

func (*RootCoordCatalog_ListCredentials_Call) RunAndReturn

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

type RootCoordCatalog_ListDatabases_Call

type RootCoordCatalog_ListDatabases_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListDatabases_Call) Return

func (_c *RootCoordCatalog_ListDatabases_Call) Return(_a0 []*model.Database, _a1 error) *RootCoordCatalog_ListDatabases_Call

func (*RootCoordCatalog_ListDatabases_Call) Run

func (_c *RootCoordCatalog_ListDatabases_Call) Run(run func(ctx context.Context, ts uint64)) *RootCoordCatalog_ListDatabases_Call

func (*RootCoordCatalog_ListDatabases_Call) RunAndReturn

func (_c *RootCoordCatalog_ListDatabases_Call) RunAndReturn(run func(context.Context, uint64) ([]*model.Database, error)) *RootCoordCatalog_ListDatabases_Call

type RootCoordCatalog_ListGrant_Call

type RootCoordCatalog_ListGrant_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListGrant_Call) Return

func (_c *RootCoordCatalog_ListGrant_Call) Return(_a0 []*milvuspb.GrantEntity, _a1 error) *RootCoordCatalog_ListGrant_Call

func (*RootCoordCatalog_ListGrant_Call) Run

func (_c *RootCoordCatalog_ListGrant_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.GrantEntity)) *RootCoordCatalog_ListGrant_Call

func (*RootCoordCatalog_ListGrant_Call) RunAndReturn

func (_c *RootCoordCatalog_ListGrant_Call) RunAndReturn(run func(context.Context, string, *milvuspb.GrantEntity) ([]*milvuspb.GrantEntity, error)) *RootCoordCatalog_ListGrant_Call

type RootCoordCatalog_ListPolicy_Call

type RootCoordCatalog_ListPolicy_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListPolicy_Call) Return

func (_c *RootCoordCatalog_ListPolicy_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListPolicy_Call

func (*RootCoordCatalog_ListPolicy_Call) Run

func (_c *RootCoordCatalog_ListPolicy_Call) Run(run func(ctx context.Context, tenant string)) *RootCoordCatalog_ListPolicy_Call

func (*RootCoordCatalog_ListPolicy_Call) RunAndReturn

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

type RootCoordCatalog_ListRole_Call

type RootCoordCatalog_ListRole_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListRole_Call) Return

func (_c *RootCoordCatalog_ListRole_Call) Return(_a0 []*milvuspb.RoleResult, _a1 error) *RootCoordCatalog_ListRole_Call

func (*RootCoordCatalog_ListRole_Call) Run

func (_c *RootCoordCatalog_ListRole_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.RoleEntity, includeUserInfo bool)) *RootCoordCatalog_ListRole_Call

func (*RootCoordCatalog_ListRole_Call) RunAndReturn

func (_c *RootCoordCatalog_ListRole_Call) RunAndReturn(run func(context.Context, string, *milvuspb.RoleEntity, bool) ([]*milvuspb.RoleResult, error)) *RootCoordCatalog_ListRole_Call

type RootCoordCatalog_ListUserRole_Call

type RootCoordCatalog_ListUserRole_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListUserRole_Call) Return

func (_c *RootCoordCatalog_ListUserRole_Call) Return(_a0 []string, _a1 error) *RootCoordCatalog_ListUserRole_Call

func (*RootCoordCatalog_ListUserRole_Call) Run

func (_c *RootCoordCatalog_ListUserRole_Call) Run(run func(ctx context.Context, tenant string)) *RootCoordCatalog_ListUserRole_Call

func (*RootCoordCatalog_ListUserRole_Call) RunAndReturn

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

type RootCoordCatalog_ListUser_Call

type RootCoordCatalog_ListUser_Call struct {
	*mock.Call
}

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

func (*RootCoordCatalog_ListUser_Call) Return

func (_c *RootCoordCatalog_ListUser_Call) Return(_a0 []*milvuspb.UserResult, _a1 error) *RootCoordCatalog_ListUser_Call

func (*RootCoordCatalog_ListUser_Call) Run

func (_c *RootCoordCatalog_ListUser_Call) Run(run func(ctx context.Context, tenant string, entity *milvuspb.UserEntity, includeRoleInfo bool)) *RootCoordCatalog_ListUser_Call

func (*RootCoordCatalog_ListUser_Call) RunAndReturn

func (_c *RootCoordCatalog_ListUser_Call) RunAndReturn(run func(context.Context, string, *milvuspb.UserEntity, bool) ([]*milvuspb.UserResult, error)) *RootCoordCatalog_ListUser_Call