mocks

package
v0.0.0-...-34f85fd Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelManager 

type ChannelManager struct {
	mock.Mock
}

ChannelManager is an autogenerated mock type for the ChannelManager type

func NewChannelManager 

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

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

func (*ChannelManager) AddDroppedCollection 

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

AddDroppedCollection provides a mock function with given fields: ids

func (*ChannelManager) AddDroppedPartition 

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

AddDroppedPartition provides a mock function with given fields: ids

func (*ChannelManager) AddPartition 

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

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

func (*ChannelManager) EXPECT 

func (_m *ChannelManager) EXPECT() *ChannelManager_Expecter

func (*ChannelManager) GetChannelChan 

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

GetChannelChan provides a mock function with given fields:

func (*ChannelManager) GetEventChan 

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

GetEventChan provides a mock function with given fields:

func (*ChannelManager) GetMsgChan 

func (_m *ChannelManager) GetMsgChan(pChannel string) <-chan *msgstream.MsgPack

GetMsgChan provides a mock function with given fields: pChannel

func (*ChannelManager) SetCtx 

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

SetCtx provides a mock function with given fields: ctx

func (*ChannelManager) StartReadCollection 

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

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

func (*ChannelManager) StopReadCollection 

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

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

type ChannelManager_AddDroppedCollection_Call 

type ChannelManager_AddDroppedCollection_Call struct {
	*mock.Call
}

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

func (*ChannelManager_AddDroppedCollection_Call) Return 

func (_c *ChannelManager_AddDroppedCollection_Call) Return() *ChannelManager_AddDroppedCollection_Call

func (*ChannelManager_AddDroppedCollection_Call) Run 

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

func (*ChannelManager_AddDroppedCollection_Call) RunAndReturn 

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

type ChannelManager_AddDroppedPartition_Call 

type ChannelManager_AddDroppedPartition_Call struct {
	*mock.Call
}

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

func (*ChannelManager_AddDroppedPartition_Call) Return 

func (_c *ChannelManager_AddDroppedPartition_Call) Return() *ChannelManager_AddDroppedPartition_Call

func (*ChannelManager_AddDroppedPartition_Call) Run 

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

func (*ChannelManager_AddDroppedPartition_Call) RunAndReturn 

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

type ChannelManager_AddPartition_Call 

type ChannelManager_AddPartition_Call struct {
	*mock.Call
}

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

func (*ChannelManager_AddPartition_Call) Return 

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

func (*ChannelManager_AddPartition_Call) Run 

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

func (*ChannelManager_AddPartition_Call) RunAndReturn 

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

type ChannelManager_Expecter 

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

func (*ChannelManager_Expecter) AddDroppedCollection 

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

AddDroppedCollection is a helper method to define mock.On call

  • ids []int64

func (*ChannelManager_Expecter) AddDroppedPartition 

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

AddDroppedPartition is a helper method to define mock.On call

  • ids []int64

func (*ChannelManager_Expecter) AddPartition 

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

AddPartition is a helper method to define mock.On call

  • ctx context.Context
  • collectionInfo *pb.CollectionInfo
  • partitionInfo *pb.PartitionInfo

func (*ChannelManager_Expecter) GetChannelChan 

func (_e *ChannelManager_Expecter) GetChannelChan() *ChannelManager_GetChannelChan_Call

GetChannelChan is a helper method to define mock.On call

func (*ChannelManager_Expecter) GetEventChan 

func (_e *ChannelManager_Expecter) GetEventChan() *ChannelManager_GetEventChan_Call

GetEventChan is a helper method to define mock.On call

func (*ChannelManager_Expecter) GetMsgChan 

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

GetMsgChan is a helper method to define mock.On call

  • pChannel string

func (*ChannelManager_Expecter) SetCtx 

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

SetCtx is a helper method to define mock.On call

  • ctx context.Context

func (*ChannelManager_Expecter) StartReadCollection 

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

StartReadCollection is a helper method to define mock.On call

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

func (*ChannelManager_Expecter) StopReadCollection 

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

StopReadCollection is a helper method to define mock.On call

  • ctx context.Context
  • info *pb.CollectionInfo

type ChannelManager_GetChannelChan_Call 

type ChannelManager_GetChannelChan_Call struct {
	*mock.Call
}

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

func (*ChannelManager_GetChannelChan_Call) Return 

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

func (*ChannelManager_GetChannelChan_Call) Run 

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

func (*ChannelManager_GetChannelChan_Call) RunAndReturn 

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

type ChannelManager_GetEventChan_Call 

type ChannelManager_GetEventChan_Call struct {
	*mock.Call
}

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

func (*ChannelManager_GetEventChan_Call) Return 

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

func (*ChannelManager_GetEventChan_Call) Run 

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

func (*ChannelManager_GetEventChan_Call) RunAndReturn 

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

type ChannelManager_GetMsgChan_Call 

type ChannelManager_GetMsgChan_Call struct {
	*mock.Call
}

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

func (*ChannelManager_GetMsgChan_Call) Return 

func (_c *ChannelManager_GetMsgChan_Call) Return(_a0 <-chan *msgstream.MsgPack) *ChannelManager_GetMsgChan_Call

func (*ChannelManager_GetMsgChan_Call) Run 

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

func (*ChannelManager_GetMsgChan_Call) RunAndReturn 

func (_c *ChannelManager_GetMsgChan_Call) RunAndReturn(run func(string) <-chan *msgstream.MsgPack) *ChannelManager_GetMsgChan_Call

type ChannelManager_SetCtx_Call 

type ChannelManager_SetCtx_Call struct {
	*mock.Call
}

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

func (*ChannelManager_SetCtx_Call) Return 

func (_c *ChannelManager_SetCtx_Call) Return() *ChannelManager_SetCtx_Call

func (*ChannelManager_SetCtx_Call) Run 

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

func (*ChannelManager_SetCtx_Call) RunAndReturn 

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

type ChannelManager_StartReadCollection_Call 

type ChannelManager_StartReadCollection_Call struct {
	*mock.Call
}

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

func (*ChannelManager_StartReadCollection_Call) Return 

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

func (*ChannelManager_StartReadCollection_Call) Run 

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

func (*ChannelManager_StartReadCollection_Call) RunAndReturn 

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

type ChannelManager_StopReadCollection_Call 

type ChannelManager_StopReadCollection_Call struct {
	*mock.Call
}

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

func (*ChannelManager_StopReadCollection_Call) Return 

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

func (*ChannelManager_StopReadCollection_Call) Run 

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

func (*ChannelManager_StopReadCollection_Call) RunAndReturn 

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

type DataHandler 

type DataHandler struct {
	mock.Mock
}

DataHandler is an autogenerated mock type for the DataHandler type

func NewDataHandler 

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

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

func (*DataHandler) CreateCollection 

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

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

func (*DataHandler) CreateDatabase 

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

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

func (*DataHandler) CreateIndex 

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

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

func (*DataHandler) CreatePartition 

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

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

func (*DataHandler) Delete 

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

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

func (*DataHandler) DescribeCollection 

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

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

func (*DataHandler) DescribeDatabase 

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

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

func (*DataHandler) DescribePartition 

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

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

func (*DataHandler) DropCollection 

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

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

func (*DataHandler) DropDatabase 

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

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

func (*DataHandler) DropIndex 

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

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

func (*DataHandler) DropPartition 

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

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

func (*DataHandler) EXPECT 

func (_m *DataHandler) EXPECT() *DataHandler_Expecter

func (*DataHandler) Flush 

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

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

func (*DataHandler) Insert 

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

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

func (*DataHandler) LoadCollection 

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

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

func (*DataHandler) LoadPartitions 

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

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

func (*DataHandler) ReleaseCollection 

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

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

func (*DataHandler) ReleasePartitions 

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

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

func (*DataHandler) ReplicateMessage 

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

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

type DataHandler_CreateCollection_Call 

type DataHandler_CreateCollection_Call struct {
	*mock.Call
}

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

func (*DataHandler_CreateCollection_Call) Return 

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

func (*DataHandler_CreateCollection_Call) Run 

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

func (*DataHandler_CreateCollection_Call) RunAndReturn 

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

type DataHandler_CreateDatabase_Call 

type DataHandler_CreateDatabase_Call struct {
	*mock.Call
}

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

func (*DataHandler_CreateDatabase_Call) Return 

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

func (*DataHandler_CreateDatabase_Call) Run 

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

func (*DataHandler_CreateDatabase_Call) RunAndReturn 

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

type DataHandler_CreateIndex_Call 

type DataHandler_CreateIndex_Call struct {
	*mock.Call
}

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

func (*DataHandler_CreateIndex_Call) Return 

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

func (*DataHandler_CreateIndex_Call) Run 

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

func (*DataHandler_CreateIndex_Call) RunAndReturn 

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

type DataHandler_CreatePartition_Call 

type DataHandler_CreatePartition_Call struct {
	*mock.Call
}

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

func (*DataHandler_CreatePartition_Call) Return 

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

func (*DataHandler_CreatePartition_Call) Run 

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

func (*DataHandler_CreatePartition_Call) RunAndReturn 

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

type DataHandler_Delete_Call 

type DataHandler_Delete_Call struct {
	*mock.Call
}

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

func (*DataHandler_Delete_Call) Return 

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

func (*DataHandler_Delete_Call) Run 

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

func (*DataHandler_Delete_Call) RunAndReturn 

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

type DataHandler_DescribeCollection_Call 

type DataHandler_DescribeCollection_Call struct {
	*mock.Call
}

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

func (*DataHandler_DescribeCollection_Call) Return 

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

func (*DataHandler_DescribeCollection_Call) Run 

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

func (*DataHandler_DescribeCollection_Call) RunAndReturn 

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

type DataHandler_DescribeDatabase_Call 

type DataHandler_DescribeDatabase_Call struct {
	*mock.Call
}

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

func (*DataHandler_DescribeDatabase_Call) Return 

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

func (*DataHandler_DescribeDatabase_Call) Run 

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

func (*DataHandler_DescribeDatabase_Call) RunAndReturn 

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

type DataHandler_DescribePartition_Call 

type DataHandler_DescribePartition_Call struct {
	*mock.Call
}

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

func (*DataHandler_DescribePartition_Call) Return 

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

func (*DataHandler_DescribePartition_Call) Run 

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

func (*DataHandler_DescribePartition_Call) RunAndReturn 

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

type DataHandler_DropCollection_Call 

type DataHandler_DropCollection_Call struct {
	*mock.Call
}

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

func (*DataHandler_DropCollection_Call) Return 

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

func (*DataHandler_DropCollection_Call) Run 

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

func (*DataHandler_DropCollection_Call) RunAndReturn 

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

type DataHandler_DropDatabase_Call 

type DataHandler_DropDatabase_Call struct {
	*mock.Call
}

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

func (*DataHandler_DropDatabase_Call) Return 

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

func (*DataHandler_DropDatabase_Call) Run 

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

func (*DataHandler_DropDatabase_Call) RunAndReturn 

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

type DataHandler_DropIndex_Call 

type DataHandler_DropIndex_Call struct {
	*mock.Call
}

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

func (*DataHandler_DropIndex_Call) Return 

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

func (*DataHandler_DropIndex_Call) Run 

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

func (*DataHandler_DropIndex_Call) RunAndReturn 

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

type DataHandler_DropPartition_Call 

type DataHandler_DropPartition_Call struct {
	*mock.Call
}

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

func (*DataHandler_DropPartition_Call) Return 

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

func (*DataHandler_DropPartition_Call) Run 

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

func (*DataHandler_DropPartition_Call) RunAndReturn 

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

type DataHandler_Expecter 

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

func (*DataHandler_Expecter) CreateCollection 

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

CreateCollection is a helper method to define mock.On call

  • ctx context.Context
  • param *api.CreateCollectionParam

func (*DataHandler_Expecter) CreateDatabase 

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

CreateDatabase is a helper method to define mock.On call

  • ctx context.Context
  • param *api.CreateDatabaseParam

func (*DataHandler_Expecter) CreateIndex 

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

CreateIndex is a helper method to define mock.On call

  • ctx context.Context
  • param *api.CreateIndexParam

func (*DataHandler_Expecter) CreatePartition 

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

CreatePartition is a helper method to define mock.On call

  • ctx context.Context
  • param *api.CreatePartitionParam

func (*DataHandler_Expecter) Delete 

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

Delete is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DeleteParam

func (*DataHandler_Expecter) DescribeCollection 

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

DescribeCollection is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DescribeCollectionParam

func (*DataHandler_Expecter) DescribeDatabase 

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

DescribeDatabase is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DescribeDatabaseParam

func (*DataHandler_Expecter) DescribePartition 

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

DescribePartition is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DescribePartitionParam

func (*DataHandler_Expecter) DropCollection 

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

DropCollection is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DropCollectionParam

func (*DataHandler_Expecter) DropDatabase 

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

DropDatabase is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DropDatabaseParam

func (*DataHandler_Expecter) DropIndex 

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

DropIndex is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DropIndexParam

func (*DataHandler_Expecter) DropPartition 

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

DropPartition is a helper method to define mock.On call

  • ctx context.Context
  • param *api.DropPartitionParam

func (*DataHandler_Expecter) Flush 

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

Flush is a helper method to define mock.On call

  • ctx context.Context
  • param *api.FlushParam

func (*DataHandler_Expecter) Insert 

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

Insert is a helper method to define mock.On call

  • ctx context.Context
  • param *api.InsertParam

func (*DataHandler_Expecter) LoadCollection 

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

LoadCollection is a helper method to define mock.On call

  • ctx context.Context
  • param *api.LoadCollectionParam

func (*DataHandler_Expecter) LoadPartitions 

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

LoadPartitions is a helper method to define mock.On call

  • ctx context.Context
  • param *api.LoadPartitionsParam

func (*DataHandler_Expecter) ReleaseCollection 

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

ReleaseCollection is a helper method to define mock.On call

  • ctx context.Context
  • param *api.ReleaseCollectionParam

func (*DataHandler_Expecter) ReleasePartitions 

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

ReleasePartitions is a helper method to define mock.On call

  • ctx context.Context
  • param *api.ReleasePartitionsParam

func (*DataHandler_Expecter) ReplicateMessage 

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

ReplicateMessage is a helper method to define mock.On call

  • ctx context.Context
  • param *api.ReplicateMessageParam

type DataHandler_Flush_Call 

type DataHandler_Flush_Call struct {
	*mock.Call
}

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

func (*DataHandler_Flush_Call) Return 

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

func (*DataHandler_Flush_Call) Run 

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

func (*DataHandler_Flush_Call) RunAndReturn 

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

type DataHandler_Insert_Call 

type DataHandler_Insert_Call struct {
	*mock.Call
}

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

func (*DataHandler_Insert_Call) Return 

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

func (*DataHandler_Insert_Call) Run 

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

func (*DataHandler_Insert_Call) RunAndReturn 

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

type DataHandler_LoadCollection_Call 

type DataHandler_LoadCollection_Call struct {
	*mock.Call
}

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

func (*DataHandler_LoadCollection_Call) Return 

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

func (*DataHandler_LoadCollection_Call) Run 

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

func (*DataHandler_LoadCollection_Call) RunAndReturn 

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

type DataHandler_LoadPartitions_Call 

type DataHandler_LoadPartitions_Call struct {
	*mock.Call
}

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

func (*DataHandler_LoadPartitions_Call) Return 

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

func (*DataHandler_LoadPartitions_Call) Run 

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

func (*DataHandler_LoadPartitions_Call) RunAndReturn 

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

type DataHandler_ReleaseCollection_Call 

type DataHandler_ReleaseCollection_Call struct {
	*mock.Call
}

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

func (*DataHandler_ReleaseCollection_Call) Return 

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

func (*DataHandler_ReleaseCollection_Call) Run 

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

func (*DataHandler_ReleaseCollection_Call) RunAndReturn 

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

type DataHandler_ReleasePartitions_Call 

type DataHandler_ReleasePartitions_Call struct {
	*mock.Call
}

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

func (*DataHandler_ReleasePartitions_Call) Return 

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

func (*DataHandler_ReleasePartitions_Call) Run 

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

func (*DataHandler_ReleasePartitions_Call) RunAndReturn 

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

type DataHandler_ReplicateMessage_Call 

type DataHandler_ReplicateMessage_Call struct {
	*mock.Call
}

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

func (*DataHandler_ReplicateMessage_Call) Return 

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

func (*DataHandler_ReplicateMessage_Call) Run 

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

func (*DataHandler_ReplicateMessage_Call) RunAndReturn 

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

type Factory 

type Factory struct {
	mock.Mock
}

Factory is an autogenerated mock type for the Factory type

func NewFactory 

func NewFactory(t mockConstructorTestingTNewFactory) *Factory

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

func (*Factory) EXPECT 

func (_m *Factory) EXPECT() *Factory_Expecter

func (*Factory) NewMsgStream 

func (_m *Factory) NewMsgStream(ctx context.Context) (msgstream.MsgStream, error)

NewMsgStream provides a mock function with given fields: ctx

func (*Factory) NewMsgStreamDisposer 

func (_m *Factory) NewMsgStreamDisposer(ctx context.Context) func([]string, string) error

NewMsgStreamDisposer provides a mock function with given fields: ctx

func (*Factory) NewQueryMsgStream 

func (_m *Factory) NewQueryMsgStream(ctx context.Context) (msgstream.MsgStream, error)

NewQueryMsgStream provides a mock function with given fields: ctx

func (*Factory) NewTtMsgStream 

func (_m *Factory) NewTtMsgStream(ctx context.Context) (msgstream.MsgStream, error)

NewTtMsgStream provides a mock function with given fields: ctx

type FactoryCreator 

type FactoryCreator struct {
	mock.Mock
}

FactoryCreator is an autogenerated mock type for the FactoryCreator type

func NewFactoryCreator 

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

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

func (*FactoryCreator) EXPECT 

func (_m *FactoryCreator) EXPECT() *FactoryCreator_Expecter

func (*FactoryCreator) NewKmsFactory 

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

NewKmsFactory provides a mock function with given fields: cfg

func (*FactoryCreator) NewPmsFactory 

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

NewPmsFactory provides a mock function with given fields: cfg

type FactoryCreator_Expecter 

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

func (*FactoryCreator_Expecter) NewKmsFactory 

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

NewKmsFactory is a helper method to define mock.On call

  • cfg *config.KafkaConfig

func (*FactoryCreator_Expecter) NewPmsFactory 

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

NewPmsFactory is a helper method to define mock.On call

  • cfg *config.PulsarConfig

type FactoryCreator_NewKmsFactory_Call 

type FactoryCreator_NewKmsFactory_Call struct {
	*mock.Call
}

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

func (*FactoryCreator_NewKmsFactory_Call) Return 

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

func (*FactoryCreator_NewKmsFactory_Call) Run 

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

func (*FactoryCreator_NewKmsFactory_Call) RunAndReturn 

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

type FactoryCreator_NewPmsFactory_Call 

type FactoryCreator_NewPmsFactory_Call struct {
	*mock.Call
}

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

func (*FactoryCreator_NewPmsFactory_Call) Return 

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

func (*FactoryCreator_NewPmsFactory_Call) Run 

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

func (*FactoryCreator_NewPmsFactory_Call) RunAndReturn 

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

type Factory_Expecter 

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

func (*Factory_Expecter) NewMsgStream 

func (_e *Factory_Expecter) NewMsgStream(ctx interface{}) *Factory_NewMsgStream_Call

NewMsgStream is a helper method to define mock.On call

  • ctx context.Context

func (*Factory_Expecter) NewMsgStreamDisposer 

func (_e *Factory_Expecter) NewMsgStreamDisposer(ctx interface{}) *Factory_NewMsgStreamDisposer_Call

NewMsgStreamDisposer is a helper method to define mock.On call

  • ctx context.Context

func (*Factory_Expecter) NewQueryMsgStream 

func (_e *Factory_Expecter) NewQueryMsgStream(ctx interface{}) *Factory_NewQueryMsgStream_Call

NewQueryMsgStream is a helper method to define mock.On call

  • ctx context.Context

func (*Factory_Expecter) NewTtMsgStream 

func (_e *Factory_Expecter) NewTtMsgStream(ctx interface{}) *Factory_NewTtMsgStream_Call

NewTtMsgStream is a helper method to define mock.On call

  • ctx context.Context

type Factory_NewMsgStreamDisposer_Call 

type Factory_NewMsgStreamDisposer_Call struct {
	*mock.Call
}

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

func (*Factory_NewMsgStreamDisposer_Call) Return 

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

func (*Factory_NewMsgStreamDisposer_Call) Run 

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

func (*Factory_NewMsgStreamDisposer_Call) RunAndReturn 

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

type Factory_NewMsgStream_Call 

type Factory_NewMsgStream_Call struct {
	*mock.Call
}

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

func (*Factory_NewMsgStream_Call) Return 

func (_c *Factory_NewMsgStream_Call) Return(_a0 msgstream.MsgStream, _a1 error) *Factory_NewMsgStream_Call

func (*Factory_NewMsgStream_Call) Run 

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

func (*Factory_NewMsgStream_Call) RunAndReturn 

func (_c *Factory_NewMsgStream_Call) RunAndReturn(run func(context.Context) (msgstream.MsgStream, error)) *Factory_NewMsgStream_Call

type Factory_NewQueryMsgStream_Call 

type Factory_NewQueryMsgStream_Call struct {
	*mock.Call
}

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

func (*Factory_NewQueryMsgStream_Call) Return 

func (_c *Factory_NewQueryMsgStream_Call) Return(_a0 msgstream.MsgStream, _a1 error) *Factory_NewQueryMsgStream_Call

func (*Factory_NewQueryMsgStream_Call) Run 

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

func (*Factory_NewQueryMsgStream_Call) RunAndReturn 

func (_c *Factory_NewQueryMsgStream_Call) RunAndReturn(run func(context.Context) (msgstream.MsgStream, error)) *Factory_NewQueryMsgStream_Call

type Factory_NewTtMsgStream_Call 

type Factory_NewTtMsgStream_Call struct {
	*mock.Call
}

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

func (*Factory_NewTtMsgStream_Call) Return 

func (_c *Factory_NewTtMsgStream_Call) Return(_a0 msgstream.MsgStream, _a1 error) *Factory_NewTtMsgStream_Call

func (*Factory_NewTtMsgStream_Call) Run 

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

func (*Factory_NewTtMsgStream_Call) RunAndReturn 

func (_c *Factory_NewTtMsgStream_Call) RunAndReturn(run func(context.Context) (msgstream.MsgStream, error)) *Factory_NewTtMsgStream_Call

type KVApi 

type KVApi struct {
	mock.Mock
}

KVApi is an autogenerated mock type for the KVApi type

func NewKVApi 

func NewKVApi(t mockConstructorTestingTNewKVApi) *KVApi

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

func (*KVApi) Close 

func (_m *KVApi) Close() error

Close provides a mock function with given fields:

func (*KVApi) Compact 

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

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

func (*KVApi) Delete 

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

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

func (*KVApi) Do 

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

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

func (*KVApi) EXPECT 

func (_m *KVApi) EXPECT() *KVApi_Expecter

func (*KVApi) Endpoints 

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

Endpoints provides a mock function with given fields:

func (*KVApi) Get 

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

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

func (*KVApi) Put 

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

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

func (*KVApi) RequestProgress 

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

RequestProgress provides a mock function with given fields: ctx

func (*KVApi) Status 

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

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

func (*KVApi) Txn 

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

Txn provides a mock function with given fields: ctx

func (*KVApi) Watch 

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

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

type KVApi_Close_Call 

type KVApi_Close_Call struct {
	*mock.Call
}

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

func (*KVApi_Close_Call) Return 

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

func (*KVApi_Close_Call) Run 

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

func (*KVApi_Close_Call) RunAndReturn 

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

type KVApi_Compact_Call 

type KVApi_Compact_Call struct {
	*mock.Call
}

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

func (*KVApi_Compact_Call) Return 

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

func (*KVApi_Compact_Call) Run 

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

func (*KVApi_Compact_Call) RunAndReturn 

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

type KVApi_Delete_Call 

type KVApi_Delete_Call struct {
	*mock.Call
}

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

func (*KVApi_Delete_Call) Return 

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

func (*KVApi_Delete_Call) Run 

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

func (*KVApi_Delete_Call) RunAndReturn 

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

type KVApi_Do_Call 

type KVApi_Do_Call struct {
	*mock.Call
}

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

func (*KVApi_Do_Call) Return 

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

func (*KVApi_Do_Call) Run 

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

func (*KVApi_Do_Call) RunAndReturn 

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

type KVApi_Endpoints_Call 

type KVApi_Endpoints_Call struct {
	*mock.Call
}

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

func (*KVApi_Endpoints_Call) Return 

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

func (*KVApi_Endpoints_Call) Run 

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

func (*KVApi_Endpoints_Call) RunAndReturn 

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

type KVApi_Expecter 

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

func (*KVApi_Expecter) Close 

func (_e *KVApi_Expecter) Close() *KVApi_Close_Call

Close is a helper method to define mock.On call

func (*KVApi_Expecter) Compact 

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

Compact is a helper method to define mock.On call

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

func (*KVApi_Expecter) Delete 

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

Delete is a helper method to define mock.On call

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

func (*KVApi_Expecter) Do 

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

Do is a helper method to define mock.On call

  • ctx context.Context
  • op clientv3.Op

func (*KVApi_Expecter) Endpoints 

func (_e *KVApi_Expecter) Endpoints() *KVApi_Endpoints_Call

Endpoints is a helper method to define mock.On call

func (*KVApi_Expecter) Get 

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

Get is a helper method to define mock.On call

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

func (*KVApi_Expecter) Put 

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

Put is a helper method to define mock.On call

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

func (*KVApi_Expecter) RequestProgress 

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

RequestProgress is a helper method to define mock.On call

  • ctx context.Context

func (*KVApi_Expecter) Status 

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

Status is a helper method to define mock.On call

  • ctx context.Context
  • endpoint string

func (*KVApi_Expecter) Txn 

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

Txn is a helper method to define mock.On call

  • ctx context.Context

func (*KVApi_Expecter) Watch 

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

Watch is a helper method to define mock.On call

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

type KVApi_Get_Call 

type KVApi_Get_Call struct {
	*mock.Call
}

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

func (*KVApi_Get_Call) Return 

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

func (*KVApi_Get_Call) Run 

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

func (*KVApi_Get_Call) RunAndReturn 

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

type KVApi_Put_Call 

type KVApi_Put_Call struct {
	*mock.Call
}

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

func (*KVApi_Put_Call) Return 

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

func (*KVApi_Put_Call) Run 

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

func (*KVApi_Put_Call) RunAndReturn 

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

type KVApi_RequestProgress_Call 

type KVApi_RequestProgress_Call struct {
	*mock.Call
}

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

func (*KVApi_RequestProgress_Call) Return 

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

func (*KVApi_RequestProgress_Call) Run 

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

func (*KVApi_RequestProgress_Call) RunAndReturn 

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

type KVApi_Status_Call 

type KVApi_Status_Call struct {
	*mock.Call
}

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

func (*KVApi_Status_Call) Return 

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

func (*KVApi_Status_Call) Run 

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

func (*KVApi_Status_Call) RunAndReturn 

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

type KVApi_Txn_Call 

type KVApi_Txn_Call struct {
	*mock.Call
}

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

func (*KVApi_Txn_Call) Return 

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

func (*KVApi_Txn_Call) Run 

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

func (*KVApi_Txn_Call) RunAndReturn 

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

type KVApi_Watch_Call 

type KVApi_Watch_Call struct {
	*mock.Call
}

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

func (*KVApi_Watch_Call) Return 

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

func (*KVApi_Watch_Call) Run 

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

func (*KVApi_Watch_Call) RunAndReturn 

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

type MessageManager 

type MessageManager struct {
	mock.Mock
}

MessageManager is an autogenerated mock type for the MessageManager type

func NewMessageManager 

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

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

func (*MessageManager) Close 

func (_m *MessageManager) Close(channelName string)

Close provides a mock function with given fields: channelName

func (*MessageManager) EXPECT 

func (_m *MessageManager) EXPECT() *MessageManager_Expecter

func (*MessageManager) ReplicateMessage 

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

ReplicateMessage provides a mock function with given fields: message

type MessageManager_Close_Call 

type MessageManager_Close_Call struct {
	*mock.Call
}

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

func (*MessageManager_Close_Call) Return 

func (_c *MessageManager_Close_Call) Return() *MessageManager_Close_Call

func (*MessageManager_Close_Call) Run 

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

func (*MessageManager_Close_Call) RunAndReturn 

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

type MessageManager_Expecter 

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

func (*MessageManager_Expecter) Close 

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

Close is a helper method to define mock.On call

  • channelName string

func (*MessageManager_Expecter) ReplicateMessage 

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

ReplicateMessage is a helper method to define mock.On call

  • message *api.ReplicateMessage

type MessageManager_ReplicateMessage_Call 

type MessageManager_ReplicateMessage_Call struct {
	*mock.Call
}

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

func (*MessageManager_ReplicateMessage_Call) Return 

func (_c *MessageManager_ReplicateMessage_Call) Return() *MessageManager_ReplicateMessage_Call

func (*MessageManager_ReplicateMessage_Call) Run 

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

func (*MessageManager_ReplicateMessage_Call) RunAndReturn 

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

type MetaOp 

type MetaOp struct {
	mock.Mock
}

MetaOp is an autogenerated mock type for the MetaOp type

func NewMetaOp 

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

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

func (*MetaOp) EXPECT 

func (_m *MetaOp) EXPECT() *MetaOp_Expecter

func (*MetaOp) GetAllCollection 

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

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

func (*MetaOp) GetAllDroppedObj 

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

GetAllDroppedObj provides a mock function with given fields:

func (*MetaOp) GetAllPartition 

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

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

func (*MetaOp) GetCollectionNameByID 

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

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

func (*MetaOp) GetDatabaseInfoForCollection 

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

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

func (*MetaOp) StartWatch 

func (_m *MetaOp) StartWatch()

StartWatch provides a mock function with given fields:

func (*MetaOp) SubscribeCollectionEvent 

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

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

func (*MetaOp) SubscribePartitionEvent 

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

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

func (*MetaOp) UnsubscribeEvent 

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

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

func (*MetaOp) WatchCollection 

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

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

func (*MetaOp) WatchPartition 

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

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

type MetaOp_Expecter 

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

func (*MetaOp_Expecter) GetAllCollection 

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

GetAllCollection is a helper method to define mock.On call

  • ctx context.Context
  • filter api.CollectionFilter

func (*MetaOp_Expecter) GetAllDroppedObj 

func (_e *MetaOp_Expecter) GetAllDroppedObj() *MetaOp_GetAllDroppedObj_Call

GetAllDroppedObj is a helper method to define mock.On call

func (*MetaOp_Expecter) GetAllPartition 

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

GetAllPartition is a helper method to define mock.On call

  • ctx context.Context
  • filter api.PartitionFilter

func (*MetaOp_Expecter) GetCollectionNameByID 

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

GetCollectionNameByID is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*MetaOp_Expecter) GetDatabaseInfoForCollection 

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

GetDatabaseInfoForCollection is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*MetaOp_Expecter) StartWatch 

func (_e *MetaOp_Expecter) StartWatch() *MetaOp_StartWatch_Call

StartWatch is a helper method to define mock.On call

func (*MetaOp_Expecter) SubscribeCollectionEvent 

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

SubscribeCollectionEvent is a helper method to define mock.On call

  • taskID string
  • consumer api.CollectionEventConsumer

func (*MetaOp_Expecter) SubscribePartitionEvent 

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

SubscribePartitionEvent is a helper method to define mock.On call

  • taskID string
  • consumer api.PartitionEventConsumer

func (*MetaOp_Expecter) UnsubscribeEvent 

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

UnsubscribeEvent is a helper method to define mock.On call

  • taskID string
  • eventType api.WatchEventType

func (*MetaOp_Expecter) WatchCollection 

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

WatchCollection is a helper method to define mock.On call

  • ctx context.Context
  • filter api.CollectionFilter

func (*MetaOp_Expecter) WatchPartition 

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

WatchPartition is a helper method to define mock.On call

  • ctx context.Context
  • filter api.PartitionFilter

type MetaOp_GetAllCollection_Call 

type MetaOp_GetAllCollection_Call struct {
	*mock.Call
}

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

func (*MetaOp_GetAllCollection_Call) Return 

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

func (*MetaOp_GetAllCollection_Call) Run 

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

func (*MetaOp_GetAllCollection_Call) RunAndReturn 

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

type MetaOp_GetAllDroppedObj_Call 

type MetaOp_GetAllDroppedObj_Call struct {
	*mock.Call
}

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

func (*MetaOp_GetAllDroppedObj_Call) Return 

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

func (*MetaOp_GetAllDroppedObj_Call) Run 

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

func (*MetaOp_GetAllDroppedObj_Call) RunAndReturn 

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

type MetaOp_GetAllPartition_Call 

type MetaOp_GetAllPartition_Call struct {
	*mock.Call
}

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

func (*MetaOp_GetAllPartition_Call) Return 

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

func (*MetaOp_GetAllPartition_Call) Run 

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

func (*MetaOp_GetAllPartition_Call) RunAndReturn 

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

type MetaOp_GetCollectionNameByID_Call 

type MetaOp_GetCollectionNameByID_Call struct {
	*mock.Call
}

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

func (*MetaOp_GetCollectionNameByID_Call) Return 

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

func (*MetaOp_GetCollectionNameByID_Call) Run 

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

func (*MetaOp_GetCollectionNameByID_Call) RunAndReturn 

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

type MetaOp_GetDatabaseInfoForCollection_Call 

type MetaOp_GetDatabaseInfoForCollection_Call struct {
	*mock.Call
}

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

func (*MetaOp_GetDatabaseInfoForCollection_Call) Return 

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

func (*MetaOp_GetDatabaseInfoForCollection_Call) Run 

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

func (*MetaOp_GetDatabaseInfoForCollection_Call) RunAndReturn 

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

type MetaOp_StartWatch_Call 

type MetaOp_StartWatch_Call struct {
	*mock.Call
}

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

func (*MetaOp_StartWatch_Call) Return 

func (_c *MetaOp_StartWatch_Call) Return() *MetaOp_StartWatch_Call

func (*MetaOp_StartWatch_Call) Run 

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

func (*MetaOp_StartWatch_Call) RunAndReturn 

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

type MetaOp_SubscribeCollectionEvent_Call 

type MetaOp_SubscribeCollectionEvent_Call struct {
	*mock.Call
}

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

func (*MetaOp_SubscribeCollectionEvent_Call) Return 

func (_c *MetaOp_SubscribeCollectionEvent_Call) Return() *MetaOp_SubscribeCollectionEvent_Call

func (*MetaOp_SubscribeCollectionEvent_Call) Run 

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

func (*MetaOp_SubscribeCollectionEvent_Call) RunAndReturn 

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

type MetaOp_SubscribePartitionEvent_Call 

type MetaOp_SubscribePartitionEvent_Call struct {
	*mock.Call
}

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

func (*MetaOp_SubscribePartitionEvent_Call) Return 

func (_c *MetaOp_SubscribePartitionEvent_Call) Return() *MetaOp_SubscribePartitionEvent_Call

func (*MetaOp_SubscribePartitionEvent_Call) Run 

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

func (*MetaOp_SubscribePartitionEvent_Call) RunAndReturn 

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

type MetaOp_UnsubscribeEvent_Call 

type MetaOp_UnsubscribeEvent_Call struct {
	*mock.Call
}

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

func (*MetaOp_UnsubscribeEvent_Call) Return 

func (_c *MetaOp_UnsubscribeEvent_Call) Return() *MetaOp_UnsubscribeEvent_Call

func (*MetaOp_UnsubscribeEvent_Call) Run 

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

func (*MetaOp_UnsubscribeEvent_Call) RunAndReturn 

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

type MetaOp_WatchCollection_Call 

type MetaOp_WatchCollection_Call struct {
	*mock.Call
}

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

func (*MetaOp_WatchCollection_Call) Return 

func (_c *MetaOp_WatchCollection_Call) Return() *MetaOp_WatchCollection_Call

func (*MetaOp_WatchCollection_Call) Run 

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

func (*MetaOp_WatchCollection_Call) RunAndReturn 

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

type MetaOp_WatchPartition_Call 

type MetaOp_WatchPartition_Call struct {
	*mock.Call
}

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

func (*MetaOp_WatchPartition_Call) Return 

func (_c *MetaOp_WatchPartition_Call) Return() *MetaOp_WatchPartition_Call

func (*MetaOp_WatchPartition_Call) Run 

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

func (*MetaOp_WatchPartition_Call) RunAndReturn 

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

type MsgStream 

type MsgStream struct {
	mock.Mock
}

MsgStream is an autogenerated mock type for the MsgStream type

func NewMsgStream 

func NewMsgStream(t mockConstructorTestingTNewMsgStream) *MsgStream

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

func (*MsgStream) AsConsumer 

func (_m *MsgStream) AsConsumer(channels []string, subName string, position mqwrapper.SubscriptionInitialPosition)

AsConsumer provides a mock function with given fields: channels, subName, position

func (*MsgStream) AsProducer 

func (_m *MsgStream) AsProducer(channels []string)

AsProducer provides a mock function with given fields: channels

func (*MsgStream) Broadcast 

func (_m *MsgStream) Broadcast(_a0 *msgstream.MsgPack) (map[string][]mqwrapper.MessageID, error)

Broadcast provides a mock function with given fields: _a0

func (*MsgStream) Chan 

func (_m *MsgStream) Chan() <-chan *msgstream.MsgPack

Chan provides a mock function with given fields:

func (*MsgStream) CheckTopicValid 

func (_m *MsgStream) CheckTopicValid(channel string) error

CheckTopicValid provides a mock function with given fields: channel

func (*MsgStream) Close 

func (_m *MsgStream) Close()

Close provides a mock function with given fields:

func (*MsgStream) EXPECT 

func (_m *MsgStream) EXPECT() *MsgStream_Expecter

func (*MsgStream) GetLatestMsgID 

func (_m *MsgStream) GetLatestMsgID(channel string) (mqwrapper.MessageID, error)

GetLatestMsgID provides a mock function with given fields: channel

func (*MsgStream) GetProduceChannels 

func (_m *MsgStream) GetProduceChannels() []string

GetProduceChannels provides a mock function with given fields:

func (*MsgStream) Produce 

func (_m *MsgStream) Produce(_a0 *msgstream.MsgPack) error

Produce provides a mock function with given fields: _a0

func (*MsgStream) Seek 

func (_m *MsgStream) Seek(offset []*msgpb.MsgPosition) error

Seek provides a mock function with given fields: offset

func (*MsgStream) SetRepackFunc 

func (_m *MsgStream) SetRepackFunc(repackFunc msgstream.RepackFunc)

SetRepackFunc provides a mock function with given fields: repackFunc

type MsgStream_AsConsumer_Call 

type MsgStream_AsConsumer_Call struct {
	*mock.Call
}

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

func (*MsgStream_AsConsumer_Call) Return 

func (_c *MsgStream_AsConsumer_Call) Return() *MsgStream_AsConsumer_Call

func (*MsgStream_AsConsumer_Call) Run 

func (_c *MsgStream_AsConsumer_Call) Run(run func(channels []string, subName string, position mqwrapper.SubscriptionInitialPosition)) *MsgStream_AsConsumer_Call

func (*MsgStream_AsConsumer_Call) RunAndReturn 

func (_c *MsgStream_AsConsumer_Call) RunAndReturn(run func([]string, string, mqwrapper.SubscriptionInitialPosition)) *MsgStream_AsConsumer_Call

type MsgStream_AsProducer_Call 

type MsgStream_AsProducer_Call struct {
	*mock.Call
}

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

func (*MsgStream_AsProducer_Call) Return 

func (_c *MsgStream_AsProducer_Call) Return() *MsgStream_AsProducer_Call

func (*MsgStream_AsProducer_Call) Run 

func (_c *MsgStream_AsProducer_Call) Run(run func(channels []string)) *MsgStream_AsProducer_Call

func (*MsgStream_AsProducer_Call) RunAndReturn 

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

type MsgStream_Broadcast_Call 

type MsgStream_Broadcast_Call struct {
	*mock.Call
}

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

func (*MsgStream_Broadcast_Call) Return 

func (_c *MsgStream_Broadcast_Call) Return(_a0 map[string][]mqwrapper.MessageID, _a1 error) *MsgStream_Broadcast_Call

func (*MsgStream_Broadcast_Call) Run 

func (_c *MsgStream_Broadcast_Call) Run(run func(_a0 *msgstream.MsgPack)) *MsgStream_Broadcast_Call

func (*MsgStream_Broadcast_Call) RunAndReturn 

func (_c *MsgStream_Broadcast_Call) RunAndReturn(run func(*msgstream.MsgPack) (map[string][]mqwrapper.MessageID, error)) *MsgStream_Broadcast_Call

type MsgStream_Chan_Call 

type MsgStream_Chan_Call struct {
	*mock.Call
}

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

func (*MsgStream_Chan_Call) Return 

func (_c *MsgStream_Chan_Call) Return(_a0 <-chan *msgstream.MsgPack) *MsgStream_Chan_Call

func (*MsgStream_Chan_Call) Run 

func (_c *MsgStream_Chan_Call) Run(run func()) *MsgStream_Chan_Call

func (*MsgStream_Chan_Call) RunAndReturn 

func (_c *MsgStream_Chan_Call) RunAndReturn(run func() <-chan *msgstream.MsgPack) *MsgStream_Chan_Call

type MsgStream_CheckTopicValid_Call 

type MsgStream_CheckTopicValid_Call struct {
	*mock.Call
}

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

func (*MsgStream_CheckTopicValid_Call) Return 

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

func (*MsgStream_CheckTopicValid_Call) Run 

func (_c *MsgStream_CheckTopicValid_Call) Run(run func(channel string)) *MsgStream_CheckTopicValid_Call

func (*MsgStream_CheckTopicValid_Call) RunAndReturn 

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

type MsgStream_Close_Call 

type MsgStream_Close_Call struct {
	*mock.Call
}

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

func (*MsgStream_Close_Call) Return 

func (_c *MsgStream_Close_Call) Return() *MsgStream_Close_Call

func (*MsgStream_Close_Call) Run 

func (_c *MsgStream_Close_Call) Run(run func()) *MsgStream_Close_Call

func (*MsgStream_Close_Call) RunAndReturn 

func (_c *MsgStream_Close_Call) RunAndReturn(run func()) *MsgStream_Close_Call

type MsgStream_Expecter 

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

func (*MsgStream_Expecter) AsConsumer 

func (_e *MsgStream_Expecter) AsConsumer(channels interface{}, subName interface{}, position interface{}) *MsgStream_AsConsumer_Call

AsConsumer is a helper method to define mock.On call

  • channels []string
  • subName string
  • position mqwrapper.SubscriptionInitialPosition

func (*MsgStream_Expecter) AsProducer 

func (_e *MsgStream_Expecter) AsProducer(channels interface{}) *MsgStream_AsProducer_Call

AsProducer is a helper method to define mock.On call

  • channels []string

func (*MsgStream_Expecter) Broadcast 

func (_e *MsgStream_Expecter) Broadcast(_a0 interface{}) *MsgStream_Broadcast_Call

Broadcast is a helper method to define mock.On call

  • _a0 *msgstream.MsgPack

func (*MsgStream_Expecter) Chan 

func (_e *MsgStream_Expecter) Chan() *MsgStream_Chan_Call

Chan is a helper method to define mock.On call

func (*MsgStream_Expecter) CheckTopicValid 

func (_e *MsgStream_Expecter) CheckTopicValid(channel interface{}) *MsgStream_CheckTopicValid_Call

CheckTopicValid is a helper method to define mock.On call

  • channel string

func (*MsgStream_Expecter) Close 

func (_e *MsgStream_Expecter) Close() *MsgStream_Close_Call

Close is a helper method to define mock.On call

func (*MsgStream_Expecter) GetLatestMsgID 

func (_e *MsgStream_Expecter) GetLatestMsgID(channel interface{}) *MsgStream_GetLatestMsgID_Call

GetLatestMsgID is a helper method to define mock.On call

  • channel string

func (*MsgStream_Expecter) GetProduceChannels 

func (_e *MsgStream_Expecter) GetProduceChannels() *MsgStream_GetProduceChannels_Call

GetProduceChannels is a helper method to define mock.On call

func (*MsgStream_Expecter) Produce 

func (_e *MsgStream_Expecter) Produce(_a0 interface{}) *MsgStream_Produce_Call

Produce is a helper method to define mock.On call

  • _a0 *msgstream.MsgPack

func (*MsgStream_Expecter) Seek 

func (_e *MsgStream_Expecter) Seek(offset interface{}) *MsgStream_Seek_Call

Seek is a helper method to define mock.On call

  • offset []*msgpb.MsgPosition

func (*MsgStream_Expecter) SetRepackFunc 

func (_e *MsgStream_Expecter) SetRepackFunc(repackFunc interface{}) *MsgStream_SetRepackFunc_Call

SetRepackFunc is a helper method to define mock.On call

  • repackFunc msgstream.RepackFunc

type MsgStream_GetLatestMsgID_Call 

type MsgStream_GetLatestMsgID_Call struct {
	*mock.Call
}

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

func (*MsgStream_GetLatestMsgID_Call) Return 

func (_c *MsgStream_GetLatestMsgID_Call) Return(_a0 mqwrapper.MessageID, _a1 error) *MsgStream_GetLatestMsgID_Call

func (*MsgStream_GetLatestMsgID_Call) Run 

func (_c *MsgStream_GetLatestMsgID_Call) Run(run func(channel string)) *MsgStream_GetLatestMsgID_Call

func (*MsgStream_GetLatestMsgID_Call) RunAndReturn 

func (_c *MsgStream_GetLatestMsgID_Call) RunAndReturn(run func(string) (mqwrapper.MessageID, error)) *MsgStream_GetLatestMsgID_Call

type MsgStream_GetProduceChannels_Call 

type MsgStream_GetProduceChannels_Call struct {
	*mock.Call
}

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

func (*MsgStream_GetProduceChannels_Call) Return 

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

func (*MsgStream_GetProduceChannels_Call) Run 

func (_c *MsgStream_GetProduceChannels_Call) Run(run func()) *MsgStream_GetProduceChannels_Call

func (*MsgStream_GetProduceChannels_Call) RunAndReturn 

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

type MsgStream_Produce_Call 

type MsgStream_Produce_Call struct {
	*mock.Call
}

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

func (*MsgStream_Produce_Call) Return 

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

func (*MsgStream_Produce_Call) Run 

func (_c *MsgStream_Produce_Call) Run(run func(_a0 *msgstream.MsgPack)) *MsgStream_Produce_Call

func (*MsgStream_Produce_Call) RunAndReturn 

func (_c *MsgStream_Produce_Call) RunAndReturn(run func(*msgstream.MsgPack) error) *MsgStream_Produce_Call

type MsgStream_Seek_Call 

type MsgStream_Seek_Call struct {
	*mock.Call
}

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

func (*MsgStream_Seek_Call) Return 

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

func (*MsgStream_Seek_Call) Run 

func (_c *MsgStream_Seek_Call) Run(run func(offset []*msgpb.MsgPosition)) *MsgStream_Seek_Call

func (*MsgStream_Seek_Call) RunAndReturn 

func (_c *MsgStream_Seek_Call) RunAndReturn(run func([]*msgpb.MsgPosition) error) *MsgStream_Seek_Call

type MsgStream_SetRepackFunc_Call 

type MsgStream_SetRepackFunc_Call struct {
	*mock.Call
}

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

func (*MsgStream_SetRepackFunc_Call) Return 

func (_c *MsgStream_SetRepackFunc_Call) Return() *MsgStream_SetRepackFunc_Call

func (*MsgStream_SetRepackFunc_Call) Run 

func (_c *MsgStream_SetRepackFunc_Call) Run(run func(repackFunc msgstream.RepackFunc)) *MsgStream_SetRepackFunc_Call

func (*MsgStream_SetRepackFunc_Call) RunAndReturn 

func (_c *MsgStream_SetRepackFunc_Call) RunAndReturn(run func(msgstream.RepackFunc)) *MsgStream_SetRepackFunc_Call

type Reader 

type Reader struct {
	mock.Mock
}

Reader is an autogenerated mock type for the Reader type

func NewReader 

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

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

func (*Reader) EXPECT 

func (_m *Reader) EXPECT() *Reader_Expecter

func (*Reader) ErrorChan 

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

ErrorChan provides a mock function with given fields:

func (*Reader) QuitRead 

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

QuitRead provides a mock function with given fields: ctx

func (*Reader) StartRead 

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

StartRead provides a mock function with given fields: ctx

type Reader_ErrorChan_Call 

type Reader_ErrorChan_Call struct {
	*mock.Call
}

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

func (*Reader_ErrorChan_Call) Return 

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

func (*Reader_ErrorChan_Call) Run 

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

func (*Reader_ErrorChan_Call) RunAndReturn 

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

type Reader_Expecter 

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

func (*Reader_Expecter) ErrorChan 

func (_e *Reader_Expecter) ErrorChan() *Reader_ErrorChan_Call

ErrorChan is a helper method to define mock.On call

func (*Reader_Expecter) QuitRead 

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

QuitRead is a helper method to define mock.On call

  • ctx context.Context

func (*Reader_Expecter) StartRead 

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

StartRead is a helper method to define mock.On call

  • ctx context.Context

type Reader_QuitRead_Call 

type Reader_QuitRead_Call struct {
	*mock.Call
}

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

func (*Reader_QuitRead_Call) Return 

func (_c *Reader_QuitRead_Call) Return() *Reader_QuitRead_Call

func (*Reader_QuitRead_Call) Run 

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

func (*Reader_QuitRead_Call) RunAndReturn 

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

type Reader_StartRead_Call 

type Reader_StartRead_Call struct {
	*mock.Call
}

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

func (*Reader_StartRead_Call) Return 

func (_c *Reader_StartRead_Call) Return() *Reader_StartRead_Call

func (*Reader_StartRead_Call) Run 

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

func (*Reader_StartRead_Call) RunAndReturn 

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

type TargetAPI 

type TargetAPI struct {
	mock.Mock
}

TargetAPI is an autogenerated mock type for the TargetAPI type

func NewTargetAPI 

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

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

func (*TargetAPI) EXPECT 

func (_m *TargetAPI) EXPECT() *TargetAPI_Expecter

func (*TargetAPI) GetCollectionInfo 

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

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

func (*TargetAPI) GetDatabaseName 

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

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

func (*TargetAPI) GetPartitionInfo 

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

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

type TargetAPI_Expecter 

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

func (*TargetAPI_Expecter) GetCollectionInfo 

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

GetCollectionInfo is a helper method to define mock.On call

  • ctx context.Context
  • collectionName string
  • databaseName string

func (*TargetAPI_Expecter) GetDatabaseName 

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

GetDatabaseName is a helper method to define mock.On call

  • ctx context.Context
  • collectionName string
  • databaseName string

func (*TargetAPI_Expecter) GetPartitionInfo 

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

GetPartitionInfo is a helper method to define mock.On call

  • ctx context.Context
  • collectionName string
  • databaseName string

type TargetAPI_GetCollectionInfo_Call 

type TargetAPI_GetCollectionInfo_Call struct {
	*mock.Call
}

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

func (*TargetAPI_GetCollectionInfo_Call) Return 

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

func (*TargetAPI_GetCollectionInfo_Call) Run 

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

func (*TargetAPI_GetCollectionInfo_Call) RunAndReturn 

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

type TargetAPI_GetDatabaseName_Call 

type TargetAPI_GetDatabaseName_Call struct {
	*mock.Call
}

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

func (*TargetAPI_GetDatabaseName_Call) Return 

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

func (*TargetAPI_GetDatabaseName_Call) Run 

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

func (*TargetAPI_GetDatabaseName_Call) RunAndReturn 

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

type TargetAPI_GetPartitionInfo_Call 

type TargetAPI_GetPartitionInfo_Call struct {
	*mock.Call
}

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

func (*TargetAPI_GetPartitionInfo_Call) Return 

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

func (*TargetAPI_GetPartitionInfo_Call) Run 

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

func (*TargetAPI_GetPartitionInfo_Call) RunAndReturn 

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

type Writer 

type Writer struct {
	mock.Mock
}

Writer is an autogenerated mock type for the Writer type

func NewWriter 

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

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

func (*Writer) EXPECT 

func (_m *Writer) EXPECT() *Writer_Expecter

func (*Writer) HandleOpMessagePack 

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

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

func (*Writer) HandleReplicateAPIEvent 

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

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

func (*Writer) HandleReplicateMessage 

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

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

type Writer_Expecter 

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

func (*Writer_Expecter) HandleOpMessagePack 

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

HandleOpMessagePack is a helper method to define mock.On call

  • ctx context.Context
  • msgPack *msgstream.MsgPack

func (*Writer_Expecter) HandleReplicateAPIEvent 

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

HandleReplicateAPIEvent is a helper method to define mock.On call

  • ctx context.Context
  • apiEvent *api.ReplicateAPIEvent

func (*Writer_Expecter) HandleReplicateMessage 

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

HandleReplicateMessage is a helper method to define mock.On call

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

type Writer_HandleOpMessagePack_Call 

type Writer_HandleOpMessagePack_Call struct {
	*mock.Call
}

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

func (*Writer_HandleOpMessagePack_Call) Return 

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

func (*Writer_HandleOpMessagePack_Call) Run 

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

func (*Writer_HandleOpMessagePack_Call) RunAndReturn 

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

type Writer_HandleReplicateAPIEvent_Call 

type Writer_HandleReplicateAPIEvent_Call struct {
	*mock.Call
}

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

func (*Writer_HandleReplicateAPIEvent_Call) Return 

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

func (*Writer_HandleReplicateAPIEvent_Call) Run 

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

func (*Writer_HandleReplicateAPIEvent_Call) RunAndReturn 

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

type Writer_HandleReplicateMessage_Call 

type Writer_HandleReplicateMessage_Call struct {
	*mock.Call
}

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

func (*Writer_HandleReplicateMessage_Call) Return 

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

func (*Writer_HandleReplicateMessage_Call) Run 

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

func (*Writer_HandleReplicateMessage_Call) RunAndReturn 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.