mock_frontend

func (*MockAutoIncrementService) Close ¶

func (m *MockAutoIncrementService) Close()

Close mocks base method.

func (*MockAutoIncrementService) Create ¶

func (m *MockAutoIncrementService) Create(ctx context.Context, tableID uint64, caches []incrservice.AutoColumn, txn client.TxnOperator) error

Create mocks base method.

func (*MockAutoIncrementService) CurrentValue ¶

func (m *MockAutoIncrementService) CurrentValue(ctx context.Context, tableID uint64, col string) (uint64, error)

CurrentValue mocks base method.

func (*MockAutoIncrementService) Delete ¶

func (m *MockAutoIncrementService) Delete(ctx context.Context, tableID uint64, txn client.TxnOperator) error

Delete mocks base method.

func (*MockAutoIncrementService) EXPECT ¶

func (m *MockAutoIncrementService) EXPECT() *MockAutoIncrementServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAutoIncrementService) GetLastAllocateTS ¶

func (m *MockAutoIncrementService) GetLastAllocateTS(ctx context.Context, tableID uint64, colName string) (timestamp.Timestamp, error)

GetLastAllocateTS mocks base method.

func (*MockAutoIncrementService) InsertValues ¶

func (m *MockAutoIncrementService) InsertValues(ctx context.Context, tableID uint64, vecs []*vector.Vector, rows int, estimate int64) (uint64, error)

InsertValues mocks base method.

func (*MockAutoIncrementService) Reload ¶

func (m *MockAutoIncrementService) Reload(ctx context.Context, tableID uint64) error

Reload mocks base method.

func (*MockAutoIncrementService) Reset ¶

func (m *MockAutoIncrementService) Reset(ctx context.Context, oldTableID, newTableID uint64, keep bool, txn client.TxnOperator) error

Reset mocks base method.

func (*MockAutoIncrementService) UUID ¶

func (m *MockAutoIncrementService) UUID() string

UUID mocks base method.

func (*MockAutoIncrementServiceMockRecorder) Close ¶

func (mr *MockAutoIncrementServiceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockAutoIncrementServiceMockRecorder) Create ¶

func (mr *MockAutoIncrementServiceMockRecorder) Create(ctx, tableID, caches, txn interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockAutoIncrementServiceMockRecorder) CurrentValue ¶

func (mr *MockAutoIncrementServiceMockRecorder) CurrentValue(ctx, tableID, col interface{}) *gomock.Call

CurrentValue indicates an expected call of CurrentValue.

func (*MockAutoIncrementServiceMockRecorder) Delete ¶

func (mr *MockAutoIncrementServiceMockRecorder) Delete(ctx, tableID, txn interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockAutoIncrementServiceMockRecorder) GetLastAllocateTS ¶

func (mr *MockAutoIncrementServiceMockRecorder) GetLastAllocateTS(ctx, tableID, colName interface{}) *gomock.Call

GetLastAllocateTS indicates an expected call of GetLastAllocateTS.

func (*MockAutoIncrementServiceMockRecorder) InsertValues ¶

func (mr *MockAutoIncrementServiceMockRecorder) InsertValues(ctx, tableID, vecs, rows, estimate interface{}) *gomock.Call

InsertValues indicates an expected call of InsertValues.

func (*MockAutoIncrementServiceMockRecorder) Reload ¶

func (mr *MockAutoIncrementServiceMockRecorder) Reload(ctx, tableID interface{}) *gomock.Call

Reload indicates an expected call of Reload.

func (*MockAutoIncrementServiceMockRecorder) Reset ¶

func (mr *MockAutoIncrementServiceMockRecorder) Reset(ctx, oldTableID, newTableID, keep, txn interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockAutoIncrementServiceMockRecorder) UUID ¶

func (mr *MockAutoIncrementServiceMockRecorder) UUID() *gomock.Call

UUID indicates an expected call of UUID.

func (*MockBackgroundExec) Clear ¶ added in v1.2.0

func (m *MockBackgroundExec) Clear()

Clear mocks base method.

func (*MockBackgroundExec) ClearExecResultBatches ¶ added in v0.8.0

func (m *MockBackgroundExec) ClearExecResultBatches()

ClearExecResultBatches mocks base method.

func (*MockBackgroundExec) ClearExecResultSet ¶ added in v0.6.0

func (m *MockBackgroundExec) ClearExecResultSet()

ClearExecResultSet mocks base method.

func (*MockBackgroundExec) Close ¶ added in v0.6.0

func (m *MockBackgroundExec) Close()

Close mocks base method.

func (*MockBackgroundExec) EXPECT ¶ added in v0.6.0

func (m *MockBackgroundExec) EXPECT() *MockBackgroundExecMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBackgroundExec) Exec ¶ added in v0.6.0

func (m *MockBackgroundExec) Exec(arg0 context.Context, arg1 string) error

Exec mocks base method.

func (*MockBackgroundExec) ExecRestore ¶ added in v1.2.0

func (m *MockBackgroundExec) ExecRestore(arg0 context.Context, arg1 string, arg2, arg3 uint32) error

ExecRestore mocks base method.

func (*MockBackgroundExec) ExecStmt ¶ added in v0.8.0

func (m *MockBackgroundExec) ExecStmt(arg0 context.Context, arg1 tree.Statement) error

ExecStmt mocks base method.

func (*MockBackgroundExec) GetExecResultBatches ¶ added in v0.8.0

func (m *MockBackgroundExec) GetExecResultBatches() []*batch.Batch

GetExecResultBatches mocks base method.

func (*MockBackgroundExec) GetExecResultSet ¶ added in v0.6.0

func (m *MockBackgroundExec) GetExecResultSet() []interface{}

GetExecResultSet mocks base method.

func (*MockBackgroundExec) GetExecStatsArray ¶

func (m *MockBackgroundExec) GetExecStatsArray() statistic.StatsArray

GetExecStatsArray mocks base method.

func (*MockBackgroundExec) Service ¶

func (m *MockBackgroundExec) Service() string

Service mocks base method.

func (*MockBackgroundExec) SetRestore ¶

func (m *MockBackgroundExec) SetRestore(b bool)

SetRestore mocks base method.

func (*MockBackgroundExecMockRecorder) Clear ¶ added in v1.2.0

func (mr *MockBackgroundExecMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockBackgroundExecMockRecorder) ClearExecResultBatches ¶ added in v0.8.0

func (mr *MockBackgroundExecMockRecorder) ClearExecResultBatches() *gomock.Call

ClearExecResultBatches indicates an expected call of ClearExecResultBatches.

func (*MockBackgroundExecMockRecorder) ClearExecResultSet ¶ added in v0.6.0

func (mr *MockBackgroundExecMockRecorder) ClearExecResultSet() *gomock.Call

ClearExecResultSet indicates an expected call of ClearExecResultSet.

func (*MockBackgroundExecMockRecorder) Close ¶ added in v0.6.0

func (mr *MockBackgroundExecMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockBackgroundExecMockRecorder) Exec ¶ added in v0.6.0

func (mr *MockBackgroundExecMockRecorder) Exec(arg0, arg1 interface{}) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockBackgroundExecMockRecorder) ExecRestore ¶ added in v1.2.0

func (mr *MockBackgroundExecMockRecorder) ExecRestore(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

ExecRestore indicates an expected call of ExecRestore.

func (*MockBackgroundExecMockRecorder) ExecStmt ¶ added in v0.8.0

func (mr *MockBackgroundExecMockRecorder) ExecStmt(arg0, arg1 interface{}) *gomock.Call

ExecStmt indicates an expected call of ExecStmt.

func (*MockBackgroundExecMockRecorder) GetExecResultBatches ¶ added in v0.8.0

func (mr *MockBackgroundExecMockRecorder) GetExecResultBatches() *gomock.Call

GetExecResultBatches indicates an expected call of GetExecResultBatches.

func (*MockBackgroundExecMockRecorder) GetExecResultSet ¶ added in v0.6.0

func (mr *MockBackgroundExecMockRecorder) GetExecResultSet() *gomock.Call

GetExecResultSet indicates an expected call of GetExecResultSet.

func (*MockBackgroundExecMockRecorder) GetExecStatsArray ¶

func (mr *MockBackgroundExecMockRecorder) GetExecStatsArray() *gomock.Call

GetExecStatsArray indicates an expected call of GetExecStatsArray.

func (*MockBackgroundExecMockRecorder) Service ¶

func (mr *MockBackgroundExecMockRecorder) Service() *gomock.Call

Service indicates an expected call of Service.

func (*MockBackgroundExecMockRecorder) SetRestore ¶

func (mr *MockBackgroundExecMockRecorder) SetRestore(b interface{}) *gomock.Call

SetRestore indicates an expected call of SetRestore.

func (*MockBaseReader) Close ¶

func (m *MockBaseReader) Close() error

Close mocks base method.

func (*MockBaseReader) EXPECT ¶

func (m *MockBaseReader) EXPECT() *MockBaseReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockBaseReader) Read ¶

func (m *MockBaseReader) Read(arg0 context.Context, arg1 []string, arg2 *plan.Expr, arg3 *mpool.MPool, arg4 *batch.Batch) (bool, error)

Read mocks base method.

func (*MockBaseReaderMockRecorder) Close ¶

func (mr *MockBaseReaderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockBaseReaderMockRecorder) Read ¶

func (mr *MockBaseReaderMockRecorder) Read(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockChangesHandle) Close ¶

func (m *MockChangesHandle) Close() error

Close mocks base method.

func (*MockChangesHandle) EXPECT ¶

func (m *MockChangesHandle) EXPECT() *MockChangesHandleMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockChangesHandle) Next ¶

func (m *MockChangesHandle) Next(ctx context.Context, mp *mpool.MPool) (*batch.Batch, *batch.Batch, engine.ChangesHandle_Hint, error)

Next mocks base method.

func (*MockChangesHandleMockRecorder) Close ¶

func (mr *MockChangesHandleMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockChangesHandleMockRecorder) Next ¶

func (mr *MockChangesHandleMockRecorder) Next(ctx, mp interface{}) *gomock.Call

Next indicates an expected call of Next.

func (*MockColumnInfo) EXPECT ¶ added in v0.6.0

func (m *MockColumnInfo) EXPECT() *MockColumnInfoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockColumnInfo) GetName ¶ added in v0.6.0

func (m *MockColumnInfo) GetName() string

GetName mocks base method.

func (*MockColumnInfo) GetType ¶ added in v0.6.0

func (m *MockColumnInfo) GetType() types.T

GetType mocks base method.

func (*MockColumnInfoMockRecorder) GetName ¶ added in v0.6.0

func (mr *MockColumnInfoMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockColumnInfoMockRecorder) GetType ¶ added in v0.6.0

func (mr *MockColumnInfoMockRecorder) GetType() *gomock.Call

GetType indicates an expected call of GetType.

func (*MockComputationRunner) EXPECT ¶ added in v0.5.0

func (m *MockComputationRunner) EXPECT() *MockComputationRunnerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockComputationRunner) Run ¶ added in v0.5.0

func (m *MockComputationRunner) Run(ts uint64) (*util.RunResult, error)

Run mocks base method.

func (*MockComputationRunnerMockRecorder) Run ¶ added in v0.5.0

func (mr *MockComputationRunnerMockRecorder) Run(ts interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockComputationWrapper) BinaryExecute ¶

func (m *MockComputationWrapper) BinaryExecute() (bool, string)

BinaryExecute mocks base method.

func (*MockComputationWrapper) Clear ¶ added in v1.2.0

func (m *MockComputationWrapper) Clear()

Clear mocks base method.

func (*MockComputationWrapper) Compile ¶

func (m *MockComputationWrapper) Compile(any any, fill func(*batch.Batch, *perfcounter.CounterSet) error) (interface{}, error)

Compile mocks base method.

func (*MockComputationWrapper) EXPECT ¶

func (m *MockComputationWrapper) EXPECT() *MockComputationWrapperMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockComputationWrapper) Free ¶ added in v1.2.0

func (m *MockComputationWrapper) Free()

Free mocks base method.

func (*MockComputationWrapper) GetAst ¶

func (m *MockComputationWrapper) GetAst() tree.Statement

GetAst mocks base method.

func (*MockComputationWrapper) GetColumns ¶

func (m *MockComputationWrapper) GetColumns(ctx context.Context) ([]interface{}, error)

GetColumns mocks base method.

func (*MockComputationWrapper) GetLoadTag ¶ added in v0.6.0

func (m *MockComputationWrapper) GetLoadTag() bool

GetLoadTag mocks base method.

func (*MockComputationWrapper) GetProcess ¶ added in v0.6.0

func (m *MockComputationWrapper) GetProcess() *process.Process

GetProcess mocks base method.

func (*MockComputationWrapper) GetServerStatus ¶ added in v0.8.1

func (m *MockComputationWrapper) GetServerStatus() uint16

GetServerStatus mocks base method.

func (*MockComputationWrapper) GetUUID ¶ added in v0.6.0

func (m *MockComputationWrapper) GetUUID() []byte

GetUUID mocks base method.

func (*MockComputationWrapper) ParamVals ¶ added in v1.2.1

func (m *MockComputationWrapper) ParamVals() []any

ParamVals mocks base method.

func (*MockComputationWrapper) Plan ¶ added in v1.2.0

func (m *MockComputationWrapper) Plan() *plan.Plan

Plan mocks base method.

func (*MockComputationWrapper) RecordCompoundStmt ¶

func (m *MockComputationWrapper) RecordCompoundStmt(ctx context.Context, statsBytes statistic.StatsArray) error

RecordCompoundStmt mocks base method.

func (*MockComputationWrapper) RecordExecPlan ¶ added in v0.6.0

func (m *MockComputationWrapper) RecordExecPlan(ctx context.Context, phyPlan *models.PhyPlan) error

RecordExecPlan mocks base method.

func (*MockComputationWrapper) ResetPlanAndStmt ¶ added in v1.2.0

func (m *MockComputationWrapper) ResetPlanAndStmt(stmt tree.Statement)

ResetPlanAndStmt mocks base method.

func (*MockComputationWrapper) Run ¶

func (m *MockComputationWrapper) Run(ts uint64) (*util.RunResult, error)

Run mocks base method.

func (*MockComputationWrapper) SetExplainBuffer ¶

func (m *MockComputationWrapper) SetExplainBuffer(buf *bytes.Buffer)

SetExplainBuffer mocks base method.

func (*MockComputationWrapper) StatsCompositeSubStmtResource ¶

func (m *MockComputationWrapper) StatsCompositeSubStmtResource(ctx context.Context) statistic.StatsArray

StatsCompositeSubStmtResource mocks base method.

func (*MockComputationWrapperMockRecorder) BinaryExecute ¶

func (mr *MockComputationWrapperMockRecorder) BinaryExecute() *gomock.Call

BinaryExecute indicates an expected call of BinaryExecute.

func (*MockComputationWrapperMockRecorder) Clear ¶ added in v1.2.0

func (mr *MockComputationWrapperMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockComputationWrapperMockRecorder) Compile ¶

func (mr *MockComputationWrapperMockRecorder) Compile(any, fill interface{}) *gomock.Call

Compile indicates an expected call of Compile.

func (*MockComputationWrapperMockRecorder) Free ¶ added in v1.2.0

func (mr *MockComputationWrapperMockRecorder) Free() *gomock.Call

Free indicates an expected call of Free.

func (*MockComputationWrapperMockRecorder) GetAst ¶

func (mr *MockComputationWrapperMockRecorder) GetAst() *gomock.Call

GetAst indicates an expected call of GetAst.

func (*MockComputationWrapperMockRecorder) GetColumns ¶

func (mr *MockComputationWrapperMockRecorder) GetColumns(ctx interface{}) *gomock.Call

GetColumns indicates an expected call of GetColumns.

func (*MockComputationWrapperMockRecorder) GetLoadTag ¶ added in v0.6.0

func (mr *MockComputationWrapperMockRecorder) GetLoadTag() *gomock.Call

GetLoadTag indicates an expected call of GetLoadTag.

func (*MockComputationWrapperMockRecorder) GetProcess ¶ added in v0.6.0

func (mr *MockComputationWrapperMockRecorder) GetProcess() *gomock.Call

GetProcess indicates an expected call of GetProcess.

func (*MockComputationWrapperMockRecorder) GetServerStatus ¶ added in v0.8.1

func (mr *MockComputationWrapperMockRecorder) GetServerStatus() *gomock.Call

GetServerStatus indicates an expected call of GetServerStatus.

func (*MockComputationWrapperMockRecorder) GetUUID ¶ added in v0.6.0

func (mr *MockComputationWrapperMockRecorder) GetUUID() *gomock.Call

GetUUID indicates an expected call of GetUUID.

func (*MockComputationWrapperMockRecorder) ParamVals ¶ added in v1.2.1

func (mr *MockComputationWrapperMockRecorder) ParamVals() *gomock.Call

ParamVals indicates an expected call of ParamVals.

func (*MockComputationWrapperMockRecorder) Plan ¶ added in v1.2.0

func (mr *MockComputationWrapperMockRecorder) Plan() *gomock.Call

Plan indicates an expected call of Plan.

func (*MockComputationWrapperMockRecorder) RecordCompoundStmt ¶

func (mr *MockComputationWrapperMockRecorder) RecordCompoundStmt(ctx, statsBytes interface{}) *gomock.Call

RecordCompoundStmt indicates an expected call of RecordCompoundStmt.

func (*MockComputationWrapperMockRecorder) RecordExecPlan ¶ added in v0.6.0

func (mr *MockComputationWrapperMockRecorder) RecordExecPlan(ctx, phyPlan interface{}) *gomock.Call

RecordExecPlan indicates an expected call of RecordExecPlan.

func (*MockComputationWrapperMockRecorder) ResetPlanAndStmt ¶ added in v1.2.0

func (mr *MockComputationWrapperMockRecorder) ResetPlanAndStmt(stmt interface{}) *gomock.Call

ResetPlanAndStmt indicates an expected call of ResetPlanAndStmt.

func (*MockComputationWrapperMockRecorder) Run ¶

func (mr *MockComputationWrapperMockRecorder) Run(ts interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockComputationWrapperMockRecorder) SetExplainBuffer ¶

func (mr *MockComputationWrapperMockRecorder) SetExplainBuffer(buf interface{}) *gomock.Call

SetExplainBuffer indicates an expected call of SetExplainBuffer.

func (*MockComputationWrapperMockRecorder) StatsCompositeSubStmtResource ¶

func (mr *MockComputationWrapperMockRecorder) StatsCompositeSubStmtResource(ctx interface{}) *gomock.Call

StatsCompositeSubStmtResource indicates an expected call of StatsCompositeSubStmtResource.

func (*MockConstraint) EXPECT ¶ added in v0.7.0

func (m *MockConstraint) EXPECT() *MockConstraintMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConstraint) ToPBVersion ¶ added in v0.8.0

func (m *MockConstraint) ToPBVersion() engine.ConstraintPB

ToPBVersion mocks base method.

func (*MockConstraintMockRecorder) ToPBVersion ¶ added in v0.8.0

func (mr *MockConstraintMockRecorder) ToPBVersion() *gomock.Call

ToPBVersion indicates an expected call of ToPBVersion.

func (*MockDataSource) ApplyTombstones ¶

func (m *MockDataSource) ApplyTombstones(ctx context.Context, bid *objectio.Blockid, rowsOffset []int64, applyPolicy engine.TombstoneApplyPolicy) ([]int64, error)

ApplyTombstones mocks base method.

func (*MockDataSource) Close ¶

func (m *MockDataSource) Close()

Close mocks base method.

func (*MockDataSource) EXPECT ¶

func (m *MockDataSource) EXPECT() *MockDataSourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDataSource) GetOrderBy ¶

func (m *MockDataSource) GetOrderBy() []*plan.OrderBySpec

GetOrderBy mocks base method.

func (*MockDataSource) GetTombstones ¶

func (m *MockDataSource) GetTombstones(ctx context.Context, bid *objectio.Blockid) (objectio.Bitmap, error)

GetTombstones mocks base method.

func (*MockDataSource) Next ¶

func (m *MockDataSource) Next(ctx context.Context, cols []string, types []types.Type, seqNums []uint16, pkSeqNum int32, memFilter any, mp *mpool.MPool, bat *batch.Batch) (*objectio.BlockInfo, engine.DataState, error)

Next mocks base method.

func (*MockDataSource) SetFilterZM ¶

func (m *MockDataSource) SetFilterZM(zm objectio.ZoneMap)

SetFilterZM mocks base method.

func (*MockDataSource) SetOrderBy ¶

func (m *MockDataSource) SetOrderBy(orderby []*plan.OrderBySpec)

SetOrderBy mocks base method.

func (*MockDataSource) String ¶

func (m *MockDataSource) String() string

String mocks base method.

func (*MockDataSourceMockRecorder) ApplyTombstones ¶

func (mr *MockDataSourceMockRecorder) ApplyTombstones(ctx, bid, rowsOffset, applyPolicy interface{}) *gomock.Call

ApplyTombstones indicates an expected call of ApplyTombstones.

func (*MockDataSourceMockRecorder) Close ¶

func (mr *MockDataSourceMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDataSourceMockRecorder) GetOrderBy ¶

func (mr *MockDataSourceMockRecorder) GetOrderBy() *gomock.Call

GetOrderBy indicates an expected call of GetOrderBy.

func (*MockDataSourceMockRecorder) GetTombstones ¶

func (mr *MockDataSourceMockRecorder) GetTombstones(ctx, bid interface{}) *gomock.Call

GetTombstones indicates an expected call of GetTombstones.

func (*MockDataSourceMockRecorder) Next ¶

func (mr *MockDataSourceMockRecorder) Next(ctx, cols, types, seqNums, pkSeqNum, memFilter, mp, bat interface{}) *gomock.Call

Next indicates an expected call of Next.

func (*MockDataSourceMockRecorder) SetFilterZM ¶

func (mr *MockDataSourceMockRecorder) SetFilterZM(zm interface{}) *gomock.Call

SetFilterZM indicates an expected call of SetFilterZM.

func (*MockDataSourceMockRecorder) SetOrderBy ¶

func (mr *MockDataSourceMockRecorder) SetOrderBy(orderby interface{}) *gomock.Call

SetOrderBy indicates an expected call of SetOrderBy.

func (*MockDataSourceMockRecorder) String ¶

func (mr *MockDataSourceMockRecorder) String() *gomock.Call

String indicates an expected call of String.

func (*MockDatabase) Create ¶

func (m *MockDatabase) Create(arg0 context.Context, arg1 string, arg2 []engine.TableDef) error

Create mocks base method.

func (*MockDatabase) Delete ¶

func (m *MockDatabase) Delete(arg0 context.Context, arg1 string) error

Delete mocks base method.

func (*MockDatabase) EXPECT ¶

func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDatabase) GetCreateSql ¶ added in v0.8.0

func (m *MockDatabase) GetCreateSql(arg0 context.Context) string

GetCreateSql mocks base method.

func (*MockDatabase) GetDatabaseId ¶ added in v0.6.0

func (m *MockDatabase) GetDatabaseId(arg0 context.Context) string

GetDatabaseId mocks base method.

func (*MockDatabase) IsSubscription ¶ added in v0.8.0

func (m *MockDatabase) IsSubscription(arg0 context.Context) bool

IsSubscription mocks base method.

func (*MockDatabase) Relation ¶

func (m *MockDatabase) Relation(arg0 context.Context, arg1 string, arg2 any) (engine.Relation, error)

Relation mocks base method.

func (*MockDatabase) RelationExists ¶

func (m *MockDatabase) RelationExists(arg0 context.Context, arg1 string, arg2 any) (bool, error)

RelationExists mocks base method.

func (*MockDatabase) Relations ¶

func (m *MockDatabase) Relations(arg0 context.Context) ([]string, error)

Relations mocks base method.

func (*MockDatabaseMockRecorder) Create ¶

func (mr *MockDatabaseMockRecorder) Create(arg0, arg1, arg2 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockDatabaseMockRecorder) Delete ¶

func (mr *MockDatabaseMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockDatabaseMockRecorder) GetCreateSql ¶ added in v0.8.0

func (mr *MockDatabaseMockRecorder) GetCreateSql(arg0 interface{}) *gomock.Call

GetCreateSql indicates an expected call of GetCreateSql.

func (*MockDatabaseMockRecorder) GetDatabaseId ¶ added in v0.6.0

func (mr *MockDatabaseMockRecorder) GetDatabaseId(arg0 interface{}) *gomock.Call

GetDatabaseId indicates an expected call of GetDatabaseId.

func (*MockDatabaseMockRecorder) IsSubscription ¶ added in v0.8.0

func (mr *MockDatabaseMockRecorder) IsSubscription(arg0 interface{}) *gomock.Call

IsSubscription indicates an expected call of IsSubscription.

func (*MockDatabaseMockRecorder) Relation ¶

func (mr *MockDatabaseMockRecorder) Relation(arg0, arg1, arg2 interface{}) *gomock.Call

Relation indicates an expected call of Relation.

func (*MockDatabaseMockRecorder) RelationExists ¶

func (mr *MockDatabaseMockRecorder) RelationExists(arg0, arg1, arg2 interface{}) *gomock.Call

RelationExists indicates an expected call of RelationExists.

func (*MockDatabaseMockRecorder) Relations ¶

func (mr *MockDatabaseMockRecorder) Relations(arg0 interface{}) *gomock.Call

Relations indicates an expected call of Relations.

func (*MockEngine) AllocateIDByKey ¶ added in v0.8.0

func (m *MockEngine) AllocateIDByKey(ctx context.Context, key string) (uint64, error)

AllocateIDByKey mocks base method.

func (*MockEngine) BuildBlockReaders ¶

func (m *MockEngine) BuildBlockReaders(ctx context.Context, proc any, ts timestamp.Timestamp, expr *plan.Expr, def *plan.TableDef, relData engine.RelData, num int) ([]engine.Reader, error)

BuildBlockReaders mocks base method.

func (*MockEngine) Create ¶

func (m *MockEngine) Create(ctx context.Context, databaseName string, op client.TxnOperator) error

Create mocks base method.

func (*MockEngine) Database ¶

func (m *MockEngine) Database(ctx context.Context, databaseName string, op client.TxnOperator) (engine.Database, error)

Database mocks base method.

func (*MockEngine) Databases ¶

func (m *MockEngine) Databases(ctx context.Context, op client.TxnOperator) ([]string, error)

Databases mocks base method.

func (*MockEngine) Delete ¶

func (m *MockEngine) Delete(ctx context.Context, databaseName string, op client.TxnOperator) error

Delete mocks base method.

func (*MockEngine) EXPECT ¶

func (m *MockEngine) EXPECT() *MockEngineMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEngine) GetMessageCenter ¶

func (m *MockEngine) GetMessageCenter() any

GetMessageCenter mocks base method.

func (*MockEngine) GetNameById ¶ added in v0.7.0

func (m *MockEngine) GetNameById(ctx context.Context, op client.TxnOperator, tableId uint64) (string, string, error)

GetNameById mocks base method.

func (*MockEngine) GetRelationById ¶ added in v0.7.0

func (m *MockEngine) GetRelationById(ctx context.Context, op client.TxnOperator, tableId uint64) (string, string, engine.Relation, error)

GetRelationById mocks base method.

func (*MockEngine) GetService ¶

func (m *MockEngine) GetService() string

GetService mocks base method.

func (*MockEngine) Hints ¶ added in v0.6.0

func (m *MockEngine) Hints() engine.Hints

Hints mocks base method.

func (*MockEngine) LatestLogtailAppliedTime ¶

func (m *MockEngine) LatestLogtailAppliedTime() timestamp.Timestamp

LatestLogtailAppliedTime mocks base method.

func (*MockEngine) New ¶ added in v0.6.0

func (m *MockEngine) New(ctx context.Context, op client.TxnOperator) error

New mocks base method.

func (*MockEngine) Nodes ¶ added in v0.6.0

func (m *MockEngine) Nodes(isInternal bool, tenant, username string, cnLabel map[string]string) (engine.Nodes, error)

Nodes mocks base method.

func (*MockEngine) PrefetchTableMeta ¶

func (m *MockEngine) PrefetchTableMeta(ctx context.Context, key statsinfo.StatsInfoKey) bool

PrefetchTableMeta mocks base method.

func (*MockEngine) Stats ¶ added in v1.2.0

func (m *MockEngine) Stats(ctx context.Context, key statsinfo.StatsInfoKey, sync bool) *statsinfo.StatsInfo

Stats mocks base method.

func (*MockEngine) TryToSubscribeTable ¶ added in v1.2.0

func (m *MockEngine) TryToSubscribeTable(arg0 context.Context, arg1, arg2, arg3 uint64, arg4, arg5 string) error

TryToSubscribeTable mocks base method.

func (*MockEngine) UnsubscribeTable ¶ added in v1.2.0

func (m *MockEngine) UnsubscribeTable(arg0 context.Context, arg1, arg2, arg3 uint64) error

UnsubscribeTable mocks base method.

func (*MockEngineMockRecorder) AllocateIDByKey ¶ added in v0.8.0

func (mr *MockEngineMockRecorder) AllocateIDByKey(ctx, key interface{}) *gomock.Call

AllocateIDByKey indicates an expected call of AllocateIDByKey.

func (*MockEngineMockRecorder) BuildBlockReaders ¶

func (mr *MockEngineMockRecorder) BuildBlockReaders(ctx, proc, ts, expr, def, relData, num interface{}) *gomock.Call

BuildBlockReaders indicates an expected call of BuildBlockReaders.

func (*MockEngineMockRecorder) Create ¶

func (mr *MockEngineMockRecorder) Create(ctx, databaseName, op interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockEngineMockRecorder) Database ¶

func (mr *MockEngineMockRecorder) Database(ctx, databaseName, op interface{}) *gomock.Call

Database indicates an expected call of Database.

func (*MockEngineMockRecorder) Databases ¶

func (mr *MockEngineMockRecorder) Databases(ctx, op interface{}) *gomock.Call

Databases indicates an expected call of Databases.

func (*MockEngineMockRecorder) Delete ¶

func (mr *MockEngineMockRecorder) Delete(ctx, databaseName, op interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockEngineMockRecorder) GetMessageCenter ¶

func (mr *MockEngineMockRecorder) GetMessageCenter() *gomock.Call

GetMessageCenter indicates an expected call of GetMessageCenter.

func (*MockEngineMockRecorder) GetNameById ¶ added in v0.7.0

func (mr *MockEngineMockRecorder) GetNameById(ctx, op, tableId interface{}) *gomock.Call

GetNameById indicates an expected call of GetNameById.

func (*MockEngineMockRecorder) GetRelationById ¶ added in v0.7.0

func (mr *MockEngineMockRecorder) GetRelationById(ctx, op, tableId interface{}) *gomock.Call

GetRelationById indicates an expected call of GetRelationById.

func (*MockEngineMockRecorder) GetService ¶

func (mr *MockEngineMockRecorder) GetService() *gomock.Call

GetService indicates an expected call of GetService.

func (*MockEngineMockRecorder) Hints ¶ added in v0.6.0

func (mr *MockEngineMockRecorder) Hints() *gomock.Call

Hints indicates an expected call of Hints.

func (*MockEngineMockRecorder) LatestLogtailAppliedTime ¶

func (mr *MockEngineMockRecorder) LatestLogtailAppliedTime() *gomock.Call

LatestLogtailAppliedTime indicates an expected call of LatestLogtailAppliedTime.

func (*MockEngineMockRecorder) New ¶ added in v0.6.0

func (mr *MockEngineMockRecorder) New(ctx, op interface{}) *gomock.Call

New indicates an expected call of New.

func (*MockEngineMockRecorder) Nodes ¶ added in v0.6.0

func (mr *MockEngineMockRecorder) Nodes(isInternal, tenant, username, cnLabel interface{}) *gomock.Call

Nodes indicates an expected call of Nodes.

func (*MockEngineMockRecorder) PrefetchTableMeta ¶

func (mr *MockEngineMockRecorder) PrefetchTableMeta(ctx, key interface{}) *gomock.Call

PrefetchTableMeta indicates an expected call of PrefetchTableMeta.

func (*MockEngineMockRecorder) Stats ¶ added in v1.2.0

func (mr *MockEngineMockRecorder) Stats(ctx, key, sync interface{}) *gomock.Call

Stats indicates an expected call of Stats.

func (*MockEngineMockRecorder) TryToSubscribeTable ¶ added in v1.2.0

func (mr *MockEngineMockRecorder) TryToSubscribeTable(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

TryToSubscribeTable indicates an expected call of TryToSubscribeTable.

func (*MockEngineMockRecorder) UnsubscribeTable ¶ added in v1.2.0

func (mr *MockEngineMockRecorder) UnsubscribeTable(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UnsubscribeTable indicates an expected call of UnsubscribeTable.

func (*MockExecResult) ColumnIsNull ¶

func (m *MockExecResult) ColumnIsNull(ctx context.Context, rindex, cindex uint64) (bool, error)

ColumnIsNull mocks base method.

func (*MockExecResult) EXPECT ¶ added in v0.6.0

func (m *MockExecResult) EXPECT() *MockExecResultMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockExecResult) GetColumnCount ¶

func (m *MockExecResult) GetColumnCount() uint64

func (*MockExecResult) GetInt64 ¶ added in v0.6.0

func (m *MockExecResult) GetInt64(ctx context.Context, rindex, cindex uint64) (int64, error)

GetInt64 mocks base method.

func (*MockExecResult) GetRowCount ¶ added in v0.6.0

func (m *MockExecResult) GetRowCount() uint64

GetRowCount mocks base method.

func (*MockExecResult) GetString ¶ added in v0.6.0

func (m *MockExecResult) GetString(ctx context.Context, rindex, cindex uint64) (string, error)

GetString mocks base method.

func (*MockExecResult) GetUint64 ¶ added in v0.6.0

func (m *MockExecResult) GetUint64(ctx context.Context, rindex, cindex uint64) (uint64, error)

GetUint64 mocks base method.

func (*MockExecResultMockRecorder) ColumnIsNull ¶

func (mr *MockExecResultMockRecorder) ColumnIsNull(ctx, rindex, cindex interface{}) *gomock.Call

ColumnIsNull indicates an expected call of ColumnIsNull.

func (*MockExecResultMockRecorder) GetColumnCount ¶

func (mr *MockExecResultMockRecorder) GetColumnCount() *gomock.Call

GetColumnCount indicates an expected call of GetColumnCount.

func (*MockExecResultMockRecorder) GetInt64 ¶ added in v0.6.0

func (mr *MockExecResultMockRecorder) GetInt64(ctx, rindex, cindex interface{}) *gomock.Call

GetInt64 indicates an expected call of GetInt64.

func (*MockExecResultMockRecorder) GetRowCount ¶ added in v0.6.0

func (mr *MockExecResultMockRecorder) GetRowCount() *gomock.Call

GetRowCount indicates an expected call of GetRowCount.

func (*MockExecResultMockRecorder) GetString ¶ added in v0.6.0

func (mr *MockExecResultMockRecorder) GetString(ctx, rindex, cindex interface{}) *gomock.Call

GetString indicates an expected call of GetString.

func (*MockExecResultMockRecorder) GetUint64 ¶ added in v0.6.0

func (mr *MockExecResultMockRecorder) GetUint64(ctx, rindex, cindex interface{}) *gomock.Call

GetUint64 indicates an expected call of GetUint64.

func (*MockIOPackage) AppendUint8 ¶

func (m *MockIOPackage) AppendUint8(arg0 []byte, arg1 uint8) []byte

AppendUint8 mocks base method.

func (*MockIOPackage) AppendUint16 ¶

func (m *MockIOPackage) AppendUint16(arg0 []byte, arg1 uint16) []byte

AppendUint16 mocks base method.

func (*MockIOPackage) AppendUint32 ¶

func (m *MockIOPackage) AppendUint32(arg0 []byte, arg1 uint32) []byte

AppendUint32 mocks base method.

func (*MockIOPackage) AppendUint64 ¶

func (m *MockIOPackage) AppendUint64(arg0 []byte, arg1 uint64) []byte

AppendUint64 mocks base method.

func (*MockIOPackage) EXPECT ¶

func (m *MockIOPackage) EXPECT() *MockIOPackageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIOPackage) IsLittleEndian ¶

func (m *MockIOPackage) IsLittleEndian() bool

IsLittleEndian mocks base method.

func (*MockIOPackage) ReadUint8 ¶

func (m *MockIOPackage) ReadUint8(arg0 []byte, arg1 int) (uint8, int, bool)

ReadUint8 mocks base method.

func (*MockIOPackage) ReadUint16 ¶

func (m *MockIOPackage) ReadUint16(arg0 []byte, arg1 int) (uint16, int, bool)

ReadUint16 mocks base method.

func (*MockIOPackage) ReadUint32 ¶

func (m *MockIOPackage) ReadUint32(arg0 []byte, arg1 int) (uint32, int, bool)

ReadUint32 mocks base method.

func (*MockIOPackage) ReadUint64 ¶

func (m *MockIOPackage) ReadUint64(arg0 []byte, arg1 int) (uint64, int, bool)

ReadUint64 mocks base method.

func (*MockIOPackage) WriteUint8 ¶

func (m *MockIOPackage) WriteUint8(arg0 []byte, arg1 int, arg2 uint8) int

WriteUint8 mocks base method.

func (*MockIOPackage) WriteUint16 ¶

func (m *MockIOPackage) WriteUint16(arg0 []byte, arg1 int, arg2 uint16) int

WriteUint16 mocks base method.

func (*MockIOPackage) WriteUint32 ¶

func (m *MockIOPackage) WriteUint32(arg0 []byte, arg1 int, arg2 uint32) int

WriteUint32 mocks base method.

func (*MockIOPackage) WriteUint64 ¶

func (m *MockIOPackage) WriteUint64(arg0 []byte, arg1 int, arg2 uint64) int

WriteUint64 mocks base method.

func (*MockIOPackageMockRecorder) AppendUint8 ¶

func (mr *MockIOPackageMockRecorder) AppendUint8(arg0, arg1 interface{}) *gomock.Call

AppendUint8 indicates an expected call of AppendUint8.

func (*MockIOPackageMockRecorder) AppendUint16 ¶

func (mr *MockIOPackageMockRecorder) AppendUint16(arg0, arg1 interface{}) *gomock.Call

AppendUint16 indicates an expected call of AppendUint16.

func (*MockIOPackageMockRecorder) AppendUint32 ¶

func (mr *MockIOPackageMockRecorder) AppendUint32(arg0, arg1 interface{}) *gomock.Call

AppendUint32 indicates an expected call of AppendUint32.

func (*MockIOPackageMockRecorder) AppendUint64 ¶

func (mr *MockIOPackageMockRecorder) AppendUint64(arg0, arg1 interface{}) *gomock.Call

AppendUint64 indicates an expected call of AppendUint64.

func (*MockIOPackageMockRecorder) IsLittleEndian ¶

func (mr *MockIOPackageMockRecorder) IsLittleEndian() *gomock.Call

IsLittleEndian indicates an expected call of IsLittleEndian.

func (*MockIOPackageMockRecorder) ReadUint8 ¶

func (mr *MockIOPackageMockRecorder) ReadUint8(arg0, arg1 interface{}) *gomock.Call

ReadUint8 indicates an expected call of ReadUint8.

func (*MockIOPackageMockRecorder) ReadUint16 ¶

func (mr *MockIOPackageMockRecorder) ReadUint16(arg0, arg1 interface{}) *gomock.Call

ReadUint16 indicates an expected call of ReadUint16.

func (*MockIOPackageMockRecorder) ReadUint32 ¶

func (mr *MockIOPackageMockRecorder) ReadUint32(arg0, arg1 interface{}) *gomock.Call

ReadUint32 indicates an expected call of ReadUint32.

func (*MockIOPackageMockRecorder) ReadUint64 ¶

func (mr *MockIOPackageMockRecorder) ReadUint64(arg0, arg1 interface{}) *gomock.Call

ReadUint64 indicates an expected call of ReadUint64.

func (*MockIOPackageMockRecorder) WriteUint8 ¶

func (mr *MockIOPackageMockRecorder) WriteUint8(arg0, arg1, arg2 interface{}) *gomock.Call

WriteUint8 indicates an expected call of WriteUint8.

func (*MockIOPackageMockRecorder) WriteUint16 ¶

func (mr *MockIOPackageMockRecorder) WriteUint16(arg0, arg1, arg2 interface{}) *gomock.Call

WriteUint16 indicates an expected call of WriteUint16.

func (*MockIOPackageMockRecorder) WriteUint32 ¶

func (mr *MockIOPackageMockRecorder) WriteUint32(arg0, arg1, arg2 interface{}) *gomock.Call

WriteUint32 indicates an expected call of WriteUint32.

func (*MockIOPackageMockRecorder) WriteUint64 ¶

func (mr *MockIOPackageMockRecorder) WriteUint64(arg0, arg1, arg2 interface{}) *gomock.Call

WriteUint64 indicates an expected call of WriteUint64.

func (*MockIOSession) Close ¶

func (m *MockIOSession) Close() error

Close mocks base method.

func (*MockIOSession) Connect ¶

func (m *MockIOSession) Connect(addr string, timeout time.Duration) error

Connect mocks base method.

func (*MockIOSession) Connected ¶

func (m *MockIOSession) Connected() bool

Connected mocks base method.

func (*MockIOSession) Disconnect ¶ added in v0.6.0

func (m *MockIOSession) Disconnect() error

Disconnect mocks base method.

func (*MockIOSession) EXPECT ¶

func (m *MockIOSession) EXPECT() *MockIOSessionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIOSession) Flush ¶

func (m *MockIOSession) Flush(timeout time.Duration) error

Flush mocks base method.

func (*MockIOSession) ID ¶

func (m *MockIOSession) ID() uint64

ID mocks base method.

func (*MockIOSession) OutBuf ¶

func (m *MockIOSession) OutBuf() *buf.ByteBuf

OutBuf mocks base method.

func (*MockIOSession) RawConn ¶

func (m *MockIOSession) RawConn() net.Conn

RawConn mocks base method.

func (*MockIOSession) Read ¶

func (m *MockIOSession) Read(option goetty.ReadOptions) (any, error)

Read mocks base method.

func (*MockIOSession) Ref ¶ added in v0.6.0

func (m *MockIOSession) Ref()

Ref mocks base method.

func (*MockIOSession) RemoteAddress ¶ added in v0.6.0

func (m *MockIOSession) RemoteAddress() string

RemoteAddress mocks base method.

func (*MockIOSession) UseConn ¶ added in v0.6.0

func (m *MockIOSession) UseConn(arg0 net.Conn)

UseConn mocks base method.

func (*MockIOSession) Write ¶

func (m *MockIOSession) Write(msg any, options goetty.WriteOptions) error

Write mocks base method.

func (*MockIOSessionMockRecorder) Close ¶

func (mr *MockIOSessionMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockIOSessionMockRecorder) Connect ¶

func (mr *MockIOSessionMockRecorder) Connect(addr, timeout interface{}) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockIOSessionMockRecorder) Connected ¶

func (mr *MockIOSessionMockRecorder) Connected() *gomock.Call

Connected indicates an expected call of Connected.

func (*MockIOSessionMockRecorder) Disconnect ¶ added in v0.6.0

func (mr *MockIOSessionMockRecorder) Disconnect() *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockIOSessionMockRecorder) Flush ¶

func (mr *MockIOSessionMockRecorder) Flush(timeout interface{}) *gomock.Call

Flush indicates an expected call of Flush.

func (*MockIOSessionMockRecorder) ID ¶

func (mr *MockIOSessionMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockIOSessionMockRecorder) OutBuf ¶

func (mr *MockIOSessionMockRecorder) OutBuf() *gomock.Call

OutBuf indicates an expected call of OutBuf.

func (*MockIOSessionMockRecorder) RawConn ¶ added in v0.5.0

func (mr *MockIOSessionMockRecorder) RawConn() *gomock.Call

RawConn indicates an expected call of RawConn.

func (*MockIOSessionMockRecorder) Read ¶

func (mr *MockIOSessionMockRecorder) Read(option interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockIOSessionMockRecorder) Ref ¶ added in v0.6.0

func (mr *MockIOSessionMockRecorder) Ref() *gomock.Call

Ref indicates an expected call of Ref.

func (*MockIOSessionMockRecorder) RemoteAddress ¶ added in v0.6.0

func (mr *MockIOSessionMockRecorder) RemoteAddress() *gomock.Call

RemoteAddress indicates an expected call of RemoteAddress.

func (*MockIOSessionMockRecorder) UseConn ¶ added in v0.6.0

func (mr *MockIOSessionMockRecorder) UseConn(arg0 interface{}) *gomock.Call

UseConn indicates an expected call of UseConn.

func (*MockIOSessionMockRecorder) Write ¶

func (mr *MockIOSessionMockRecorder) Write(msg, options interface{}) *gomock.Call

Write indicates an expected call of Write.

func (*MockIncrValueStore) Allocate ¶

func (m *MockIncrValueStore) Allocate(ctx context.Context, tableID uint64, col string, count int, txnOp client.TxnOperator) (uint64, uint64, timestamp.Timestamp, error)

Allocate mocks base method.

func (*MockIncrValueStore) Close ¶

func (m *MockIncrValueStore) Close()

Close mocks base method.

func (*MockIncrValueStore) Create ¶

func (m *MockIncrValueStore) Create(ctx context.Context, tableID uint64, cols []incrservice.AutoColumn, txnOp client.TxnOperator) error

Create mocks base method.

func (*MockIncrValueStore) Delete ¶

func (m *MockIncrValueStore) Delete(ctx context.Context, tableID uint64) error

Delete mocks base method.

func (*MockIncrValueStore) EXPECT ¶

func (m *MockIncrValueStore) EXPECT() *MockIncrValueStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIncrValueStore) GetColumns ¶

func (m *MockIncrValueStore) GetColumns(ctx context.Context, tableID uint64, txnOp client.TxnOperator) ([]incrservice.AutoColumn, error)

GetColumns mocks base method.

func (*MockIncrValueStore) UpdateMinValue ¶

func (m *MockIncrValueStore) UpdateMinValue(ctx context.Context, tableID uint64, col string, minValue uint64, txnOp client.TxnOperator) error

UpdateMinValue mocks base method.

func (*MockIncrValueStoreMockRecorder) Allocate ¶

func (mr *MockIncrValueStoreMockRecorder) Allocate(ctx, tableID, col, count, txnOp interface{}) *gomock.Call

Allocate indicates an expected call of Allocate.

func (*MockIncrValueStoreMockRecorder) Close ¶

func (mr *MockIncrValueStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockIncrValueStoreMockRecorder) Create ¶

func (mr *MockIncrValueStoreMockRecorder) Create(ctx, tableID, cols, txnOp interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockIncrValueStoreMockRecorder) Delete ¶

func (mr *MockIncrValueStoreMockRecorder) Delete(ctx, tableID interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockIncrValueStoreMockRecorder) GetColumns ¶

func (mr *MockIncrValueStoreMockRecorder) GetColumns(ctx, tableID, txnOp interface{}) *gomock.Call

GetColumns indicates an expected call of GetColumns.

func (*MockIncrValueStoreMockRecorder) UpdateMinValue ¶

func (mr *MockIncrValueStoreMockRecorder) UpdateMinValue(ctx, tableID, col, minValue, txnOp interface{}) *gomock.Call

UpdateMinValue indicates an expected call of UpdateMinValue.

func (*MockLogtailEngine) EXPECT ¶ added in v1.2.0

func (m *MockLogtailEngine) EXPECT() *MockLogtailEngineMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLogtailEngine) TryToSubscribeTable ¶ added in v1.2.0

func (m *MockLogtailEngine) TryToSubscribeTable(arg0 context.Context, arg1, arg2, arg3 uint64, arg4, arg5 string) error

TryToSubscribeTable mocks base method.

func (*MockLogtailEngine) UnsubscribeTable ¶ added in v1.2.0

func (m *MockLogtailEngine) UnsubscribeTable(arg0 context.Context, arg1, arg2, arg3 uint64) error

UnsubscribeTable mocks base method.

func (*MockLogtailEngineMockRecorder) TryToSubscribeTable ¶ added in v1.2.0

func (mr *MockLogtailEngineMockRecorder) TryToSubscribeTable(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

TryToSubscribeTable indicates an expected call of TryToSubscribeTable.

func (*MockLogtailEngineMockRecorder) UnsubscribeTable ¶ added in v1.2.0

func (mr *MockLogtailEngineMockRecorder) UnsubscribeTable(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UnsubscribeTable indicates an expected call of UnsubscribeTable.

func (*MockRanges) Append ¶ added in v1.1.1

func (m *MockRanges) Append(arg0 []byte)

Append mocks base method.

func (*MockRanges) EXPECT ¶ added in v1.1.1

func (m *MockRanges) EXPECT() *MockRangesMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRanges) GetAllBytes ¶ added in v1.1.1

func (m *MockRanges) GetAllBytes() []byte

GetAllBytes mocks base method.

func (*MockRanges) GetBytes ¶ added in v1.1.1

func (m *MockRanges) GetBytes(i int) []byte

GetBytes mocks base method.

func (*MockRanges) Len ¶ added in v1.1.1

func (m *MockRanges) Len() int

Len mocks base method.

func (*MockRanges) SetBytes ¶ added in v1.1.1

func (m *MockRanges) SetBytes(arg0 []byte)

SetBytes mocks base method.

func (*MockRanges) Size ¶ added in v1.1.1

func (m *MockRanges) Size() int

Size mocks base method.

func (*MockRanges) Slice ¶ added in v1.1.1

func (m *MockRanges) Slice(i, j int) []byte

Slice mocks base method.

func (*MockRangesMockRecorder) Append ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) Append(arg0 interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockRangesMockRecorder) GetAllBytes ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) GetAllBytes() *gomock.Call

GetAllBytes indicates an expected call of GetAllBytes.

func (*MockRangesMockRecorder) GetBytes ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) GetBytes(i interface{}) *gomock.Call

GetBytes indicates an expected call of GetBytes.

func (*MockRangesMockRecorder) Len ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockRangesMockRecorder) SetBytes ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) SetBytes(arg0 interface{}) *gomock.Call

SetBytes indicates an expected call of SetBytes.

func (*MockRangesMockRecorder) Size ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

func (*MockRangesMockRecorder) Slice ¶ added in v1.1.1

func (mr *MockRangesMockRecorder) Slice(i, j interface{}) *gomock.Call

Slice indicates an expected call of Slice.

func (*MockReader) Close ¶ added in v0.6.0

func (m *MockReader) Close() error

Close mocks base method.

func (*MockReader) EXPECT ¶

func (m *MockReader) EXPECT() *MockReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReader) GetOrderBy ¶ added in v1.2.0

func (m *MockReader) GetOrderBy() []*plan.OrderBySpec

GetOrderBy mocks base method.

func (*MockReader) Read ¶

func (m *MockReader) Read(arg0 context.Context, arg1 []string, arg2 *plan.Expr, arg3 *mpool.MPool, arg4 *batch.Batch) (bool, error)

Read mocks base method.

func (*MockReader) SetFilterZM ¶ added in v1.2.0

func (m *MockReader) SetFilterZM(arg0 objectio.ZoneMap)

SetFilterZM mocks base method.

func (*MockReader) SetIndexParam ¶

func (m *MockReader) SetIndexParam(arg0 *plan.IndexReaderParam)

SetIndexParam mocks base method.

func (*MockReader) SetOrderBy ¶ added in v1.2.0

func (m *MockReader) SetOrderBy(arg0 []*plan.OrderBySpec)

SetOrderBy mocks base method.

func (*MockReaderMockRecorder) Close ¶ added in v0.6.0

func (mr *MockReaderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockReaderMockRecorder) GetOrderBy ¶ added in v1.2.0

func (mr *MockReaderMockRecorder) GetOrderBy() *gomock.Call

GetOrderBy indicates an expected call of GetOrderBy.

func (*MockReaderMockRecorder) Read ¶

func (mr *MockReaderMockRecorder) Read(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockReaderMockRecorder) SetFilterZM ¶ added in v1.2.0

func (mr *MockReaderMockRecorder) SetFilterZM(arg0 interface{}) *gomock.Call

SetFilterZM indicates an expected call of SetFilterZM.

func (*MockReaderMockRecorder) SetIndexParam ¶

func (mr *MockReaderMockRecorder) SetIndexParam(arg0 interface{}) *gomock.Call

SetIndexParam indicates an expected call of SetIndexParam.

func (*MockReaderMockRecorder) SetOrderBy ¶ added in v1.2.0

func (mr *MockReaderMockRecorder) SetOrderBy(arg0 interface{}) *gomock.Call

SetOrderBy indicates an expected call of SetOrderBy.

func (*MockRelData) AppendBlockInfo ¶

func (m *MockRelData) AppendBlockInfo(blk *objectio.BlockInfo)

AppendBlockInfo mocks base method.

func (*MockRelData) AppendBlockInfoSlice ¶

func (m *MockRelData) AppendBlockInfoSlice(arg0 objectio.BlockInfoSlice)

AppendBlockInfoSlice mocks base method.

func (*MockRelData) AppendShardID ¶

func (m *MockRelData) AppendShardID(id uint64)

AppendShardID mocks base method.

func (*MockRelData) AttachTombstones ¶

func (m *MockRelData) AttachTombstones(tombstones engine.Tombstoner) error

AttachTombstones mocks base method.

func (*MockRelData) BuildEmptyRelData ¶

func (m *MockRelData) BuildEmptyRelData(preAllocSize int) engine.RelData

BuildEmptyRelData mocks base method.

func (*MockRelData) DataCnt ¶

func (m *MockRelData) DataCnt() int

DataCnt mocks base method.

func (*MockRelData) DataSlice ¶

func (m *MockRelData) DataSlice(begin, end int) engine.RelData

DataSlice mocks base method.

func (*MockRelData) EXPECT ¶

func (m *MockRelData) EXPECT() *MockRelDataMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRelData) GetBlockInfo ¶

func (m *MockRelData) GetBlockInfo(i int) objectio.BlockInfo

GetBlockInfo mocks base method.

func (*MockRelData) GetBlockInfoSlice ¶

func (m *MockRelData) GetBlockInfoSlice() objectio.BlockInfoSlice

GetBlockInfoSlice mocks base method.

func (*MockRelData) GetShardID ¶

func (m *MockRelData) GetShardID(i int) uint64

GetShardID mocks base method.

func (*MockRelData) GetShardIDList ¶

func (m *MockRelData) GetShardIDList() []uint64

GetShardIDList mocks base method.

func (*MockRelData) GetTombstones ¶

func (m *MockRelData) GetTombstones() engine.Tombstoner

GetTombstones mocks base method.

func (*MockRelData) GetType ¶

func (m *MockRelData) GetType() engine.RelDataType

GetType mocks base method.

func (*MockRelData) MarshalBinary ¶

func (m *MockRelData) MarshalBinary() ([]byte, error)

MarshalBinary mocks base method.

func (*MockRelData) SetBlockInfo ¶

func (m *MockRelData) SetBlockInfo(i int, blk *objectio.BlockInfo)

SetBlockInfo mocks base method.

func (*MockRelData) SetShardID ¶

func (m *MockRelData) SetShardID(i int, id uint64)

SetShardID mocks base method.

func (*MockRelData) Split ¶

func (m *MockRelData) Split(i int) []engine.RelData

Split mocks base method.

func (*MockRelData) String ¶

func (m *MockRelData) String() string

String mocks base method.

func (*MockRelData) UnmarshalBinary ¶

func (m *MockRelData) UnmarshalBinary(buf []byte) error

UnmarshalBinary mocks base method.

func (*MockRelDataMockRecorder) AppendBlockInfo ¶

func (mr *MockRelDataMockRecorder) AppendBlockInfo(blk interface{}) *gomock.Call

AppendBlockInfo indicates an expected call of AppendBlockInfo.

func (*MockRelDataMockRecorder) AppendBlockInfoSlice ¶

func (mr *MockRelDataMockRecorder) AppendBlockInfoSlice(arg0 interface{}) *gomock.Call

AppendBlockInfoSlice indicates an expected call of AppendBlockInfoSlice.

func (*MockRelDataMockRecorder) AppendShardID ¶

func (mr *MockRelDataMockRecorder) AppendShardID(id interface{}) *gomock.Call

AppendShardID indicates an expected call of AppendShardID.

func (*MockRelDataMockRecorder) AttachTombstones ¶

func (mr *MockRelDataMockRecorder) AttachTombstones(tombstones interface{}) *gomock.Call

AttachTombstones indicates an expected call of AttachTombstones.

func (*MockRelDataMockRecorder) BuildEmptyRelData ¶

func (mr *MockRelDataMockRecorder) BuildEmptyRelData(preAllocSize interface{}) *gomock.Call

BuildEmptyRelData indicates an expected call of BuildEmptyRelData.

func (*MockRelDataMockRecorder) DataCnt ¶

func (mr *MockRelDataMockRecorder) DataCnt() *gomock.Call

DataCnt indicates an expected call of DataCnt.

func (*MockRelDataMockRecorder) DataSlice ¶

func (mr *MockRelDataMockRecorder) DataSlice(begin, end interface{}) *gomock.Call

DataSlice indicates an expected call of DataSlice.

func (*MockRelDataMockRecorder) GetBlockInfo ¶

func (mr *MockRelDataMockRecorder) GetBlockInfo(i interface{}) *gomock.Call

GetBlockInfo indicates an expected call of GetBlockInfo.

func (*MockRelDataMockRecorder) GetBlockInfoSlice ¶

func (mr *MockRelDataMockRecorder) GetBlockInfoSlice() *gomock.Call

GetBlockInfoSlice indicates an expected call of GetBlockInfoSlice.

func (*MockRelDataMockRecorder) GetShardID ¶

func (mr *MockRelDataMockRecorder) GetShardID(i interface{}) *gomock.Call

GetShardID indicates an expected call of GetShardID.

func (*MockRelDataMockRecorder) GetShardIDList ¶

func (mr *MockRelDataMockRecorder) GetShardIDList() *gomock.Call

GetShardIDList indicates an expected call of GetShardIDList.

func (*MockRelDataMockRecorder) GetTombstones ¶

func (mr *MockRelDataMockRecorder) GetTombstones() *gomock.Call

GetTombstones indicates an expected call of GetTombstones.

func (*MockRelDataMockRecorder) GetType ¶

func (mr *MockRelDataMockRecorder) GetType() *gomock.Call

GetType indicates an expected call of GetType.

func (*MockRelDataMockRecorder) MarshalBinary ¶

func (mr *MockRelDataMockRecorder) MarshalBinary() *gomock.Call

MarshalBinary indicates an expected call of MarshalBinary.

func (*MockRelDataMockRecorder) SetBlockInfo ¶

func (mr *MockRelDataMockRecorder) SetBlockInfo(i, blk interface{}) *gomock.Call

SetBlockInfo indicates an expected call of SetBlockInfo.

func (*MockRelDataMockRecorder) SetShardID ¶

func (mr *MockRelDataMockRecorder) SetShardID(i, id interface{}) *gomock.Call

SetShardID indicates an expected call of SetShardID.

func (*MockRelDataMockRecorder) Split ¶

func (mr *MockRelDataMockRecorder) Split(i interface{}) *gomock.Call

Split indicates an expected call of Split.

func (*MockRelDataMockRecorder) String ¶

func (mr *MockRelDataMockRecorder) String() *gomock.Call

String indicates an expected call of String.

func (*MockRelDataMockRecorder) UnmarshalBinary ¶

func (mr *MockRelDataMockRecorder) UnmarshalBinary(buf interface{}) *gomock.Call

UnmarshalBinary indicates an expected call of UnmarshalBinary.

func (*MockRelation) AddTableDef ¶

func (m *MockRelation) AddTableDef(arg0 context.Context, arg1 engine.TableDef) error

AddTableDef mocks base method.

func (*MockRelation) AlterTable ¶ added in v0.8.0

func (m *MockRelation) AlterTable(arg0 context.Context, arg1 *engine.ConstraintDef, arg2 []*api.AlterTableReq) error

AlterTable mocks base method.

func (*MockRelation) ApproxObjectsNum ¶ added in v1.2.0

func (m *MockRelation) ApproxObjectsNum(ctx context.Context) int

ApproxObjectsNum mocks base method.

func (*MockRelation) BuildReaders ¶

func (m *MockRelation) BuildReaders(ctx context.Context, proc any, expr *plan.Expr, relData engine.RelData, num, txnOffset int, orderBy bool, policy engine.TombstoneApplyPolicy, filterHint engine.FilterHint) ([]engine.Reader, error)

BuildReaders mocks base method.

func (*MockRelation) BuildShardingReaders ¶

func (m *MockRelation) BuildShardingReaders(ctx context.Context, proc any, expr *plan.Expr, relData engine.RelData, num, txnOffset int, orderBy bool, policy engine.TombstoneApplyPolicy) ([]engine.Reader, error)

BuildShardingReaders mocks base method.

func (*MockRelation) CollectChanges ¶

func (m *MockRelation) CollectChanges(ctx context.Context, from, to types.TS, skipDeletes bool, mp *mpool.MPool) (engine.ChangesHandle, error)

CollectChanges mocks base method.

func (*MockRelation) CollectObjectList ¶

func (m *MockRelation) CollectObjectList(ctx context.Context, from, to types.TS, bat *batch.Batch, mp *mpool.MPool) error

CollectObjectList mocks base method.

func (*MockRelation) CollectTombstones ¶

func (m *MockRelation) CollectTombstones(ctx context.Context, txnOffset int, policy engine.TombstoneCollectPolicy) (engine.Tombstoner, error)

CollectTombstones mocks base method.

func (*MockRelation) CopyTableDef ¶ added in v1.1.2

func (m *MockRelation) CopyTableDef(arg0 context.Context) *plan.TableDef

CopyTableDef mocks base method.

func (*MockRelation) DelTableDef ¶

func (m *MockRelation) DelTableDef(arg0 context.Context, arg1 engine.TableDef) error

DelTableDef mocks base method.

func (*MockRelation) Delete ¶ added in v0.5.0

func (m *MockRelation) Delete(arg0 context.Context, arg1 *batch.Batch, arg2 string) error

Delete mocks base method.

func (*MockRelation) EXPECT ¶

func (m *MockRelation) EXPECT() *MockRelationMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRelation) EstimateCommittedTombstoneCount ¶

func (m *MockRelation) EstimateCommittedTombstoneCount(ctx context.Context) (int, error)

EstimateCommittedTombstoneCount mocks base method.

func (*MockRelation) GetColumMetadataScanInfo ¶ added in v0.8.0

func (m *MockRelation) GetColumMetadataScanInfo(ctx context.Context, name string, visitTombstone bool) ([]*plan.MetadataScanInfo, error)

GetColumMetadataScanInfo mocks base method.

func (*MockRelation) GetDBID ¶ added in v0.8.0

func (m *MockRelation) GetDBID(arg0 context.Context) uint64

GetDBID mocks base method.

func (*MockRelation) GetEngineType ¶ added in v0.8.0

func (m *MockRelation) GetEngineType() engine.EngineType

GetEngineType mocks base method.

func (*MockRelation) GetExtraInfo ¶

func (m *MockRelation) GetExtraInfo() *api.SchemaExtra

GetExtraInfo mocks base method.

func (*MockRelation) GetFlushTS ¶

func (m *MockRelation) GetFlushTS(ctx context.Context) (types.TS, error)

GetFlushTS mocks base method.

func (*MockRelation) GetNonAppendableObjectStats ¶

func (m *MockRelation) GetNonAppendableObjectStats(ctx context.Context) ([]objectio.ObjectStats, error)

GetNonAppendableObjectStats mocks base method.

func (*MockRelation) GetPrimaryKeys ¶ added in v0.5.0

func (m *MockRelation) GetPrimaryKeys(arg0 context.Context) ([]*engine.Attribute, error)

GetPrimaryKeys mocks base method.

func (*MockRelation) GetProcess ¶

func (m *MockRelation) GetProcess() any

GetProcess mocks base method.

func (*MockRelation) GetTableDef ¶ added in v1.1.0

func (m *MockRelation) GetTableDef(arg0 context.Context) *plan.TableDef

GetTableDef mocks base method.

func (*MockRelation) GetTableID ¶ added in v0.6.0

func (m *MockRelation) GetTableID(arg0 context.Context) uint64

GetTableID mocks base method.

func (*MockRelation) GetTableName ¶ added in v0.8.0

func (m *MockRelation) GetTableName() string

GetTableName mocks base method.

func (*MockRelation) MaxAndMinValues ¶ added in v0.7.0

func (m *MockRelation) MaxAndMinValues(ctx context.Context) ([][2]any, []uint8, error)

MaxAndMinValues mocks base method.

func (*MockRelation) MergeObjects ¶ added in v1.2.0

func (m *MockRelation) MergeObjects(ctx context.Context, objstats []objectio.ObjectStats, targetObjSize uint32) (*api.MergeCommitEntry, error)

MergeObjects mocks base method.

func (*MockRelation) PrimaryKeysMayBeModified ¶ added in v0.8.0

func (m *MockRelation) PrimaryKeysMayBeModified(ctx context.Context, from, to types.TS, batch *batch.Batch, pkIndex, partitionIndex int32) (bool, error)

PrimaryKeysMayBeModified mocks base method.

func (*MockRelation) PrimaryKeysMayBeUpserted ¶

func (m *MockRelation) PrimaryKeysMayBeUpserted(ctx context.Context, from, to types.TS, batch *batch.Batch, pkIndex int32) (bool, error)

PrimaryKeysMayBeUpserted mocks base method.

func (*MockRelation) Ranges ¶ added in v0.6.0

func (m *MockRelation) Ranges(arg0 context.Context, arg1 engine.RangesParam) (engine.RelData, error)

Ranges mocks base method.

func (*MockRelation) Reset ¶

func (m *MockRelation) Reset(op client.TxnOperator) error

Reset mocks base method.

func (*MockRelation) Rows ¶

func (m *MockRelation) Rows(ctx context.Context) (uint64, error)

Rows mocks base method.

func (*MockRelation) Size ¶

func (m *MockRelation) Size(ctx context.Context, columnName string) (uint64, error)

Size mocks base method.

func (*MockRelation) StarCount ¶

func (m *MockRelation) StarCount(ctx context.Context) (uint64, error)

StarCount mocks base method.

func (*MockRelation) Stats ¶ added in v0.7.0

func (m *MockRelation) Stats(ctx context.Context, sync bool) (*statsinfo.StatsInfo, error)

Stats mocks base method.

func (*MockRelation) TableColumns ¶ added in v0.6.0

func (m *MockRelation) TableColumns(ctx context.Context) ([]*engine.Attribute, error)

TableColumns mocks base method.

func (*MockRelation) TableDefs ¶

func (m *MockRelation) TableDefs(arg0 context.Context) ([]engine.TableDef, error)

TableDefs mocks base method.

func (*MockRelation) TableRenameInTxn ¶ added in v1.1.1

func (m *MockRelation) TableRenameInTxn(ctx context.Context, constraint [][]byte) error

TableRenameInTxn mocks base method.

func (*MockRelation) UpdateConstraint ¶ added in v0.7.0

func (m *MockRelation) UpdateConstraint(arg0 context.Context, arg1 *engine.ConstraintDef) error

UpdateConstraint mocks base method.

func (*MockRelation) Write ¶

func (m *MockRelation) Write(arg0 context.Context, arg1 *batch.Batch) error

Write mocks base method.

func (*MockRelationMockRecorder) AddTableDef ¶

func (mr *MockRelationMockRecorder) AddTableDef(arg0, arg1 interface{}) *gomock.Call

AddTableDef indicates an expected call of AddTableDef.

func (*MockRelationMockRecorder) AlterTable ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) AlterTable(arg0, arg1, arg2 interface{}) *gomock.Call

AlterTable indicates an expected call of AlterTable.

func (*MockRelationMockRecorder) ApproxObjectsNum ¶ added in v1.2.0

func (mr *MockRelationMockRecorder) ApproxObjectsNum(ctx interface{}) *gomock.Call

ApproxObjectsNum indicates an expected call of ApproxObjectsNum.

func (*MockRelationMockRecorder) BuildReaders ¶

func (mr *MockRelationMockRecorder) BuildReaders(ctx, proc, expr, relData, num, txnOffset, orderBy, policy, filterHint interface{}) *gomock.Call

BuildReaders indicates an expected call of BuildReaders.

func (*MockRelationMockRecorder) BuildShardingReaders ¶

func (mr *MockRelationMockRecorder) BuildShardingReaders(ctx, proc, expr, relData, num, txnOffset, orderBy, policy interface{}) *gomock.Call

BuildShardingReaders indicates an expected call of BuildShardingReaders.

func (*MockRelationMockRecorder) CollectChanges ¶

func (mr *MockRelationMockRecorder) CollectChanges(ctx, from, to, skipDeletes, mp interface{}) *gomock.Call

CollectChanges indicates an expected call of CollectChanges.

func (*MockRelationMockRecorder) CollectObjectList ¶

func (mr *MockRelationMockRecorder) CollectObjectList(ctx, from, to, bat, mp interface{}) *gomock.Call

CollectObjectList indicates an expected call of CollectObjectList.

func (*MockRelationMockRecorder) CollectTombstones ¶

func (mr *MockRelationMockRecorder) CollectTombstones(ctx, txnOffset, policy interface{}) *gomock.Call

CollectTombstones indicates an expected call of CollectTombstones.

func (*MockRelationMockRecorder) CopyTableDef ¶ added in v1.1.2

func (mr *MockRelationMockRecorder) CopyTableDef(arg0 interface{}) *gomock.Call

CopyTableDef indicates an expected call of CopyTableDef.

func (*MockRelationMockRecorder) DelTableDef ¶

func (mr *MockRelationMockRecorder) DelTableDef(arg0, arg1 interface{}) *gomock.Call

DelTableDef indicates an expected call of DelTableDef.

func (*MockRelationMockRecorder) Delete ¶ added in v0.5.0

func (mr *MockRelationMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRelationMockRecorder) EstimateCommittedTombstoneCount ¶

func (mr *MockRelationMockRecorder) EstimateCommittedTombstoneCount(ctx interface{}) *gomock.Call

EstimateCommittedTombstoneCount indicates an expected call of EstimateCommittedTombstoneCount.

func (*MockRelationMockRecorder) GetColumMetadataScanInfo ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) GetColumMetadataScanInfo(ctx, name, visitTombstone interface{}) *gomock.Call

GetColumMetadataScanInfo indicates an expected call of GetColumMetadataScanInfo.

func (*MockRelationMockRecorder) GetDBID ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) GetDBID(arg0 interface{}) *gomock.Call

GetDBID indicates an expected call of GetDBID.

func (*MockRelationMockRecorder) GetEngineType ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) GetEngineType() *gomock.Call

GetEngineType indicates an expected call of GetEngineType.

func (*MockRelationMockRecorder) GetExtraInfo ¶

func (mr *MockRelationMockRecorder) GetExtraInfo() *gomock.Call

GetExtraInfo indicates an expected call of GetExtraInfo.

func (*MockRelationMockRecorder) GetFlushTS ¶

func (mr *MockRelationMockRecorder) GetFlushTS(ctx interface{}) *gomock.Call

GetFlushTS indicates an expected call of GetFlushTS.

func (*MockRelationMockRecorder) GetNonAppendableObjectStats ¶

func (mr *MockRelationMockRecorder) GetNonAppendableObjectStats(ctx interface{}) *gomock.Call

GetNonAppendableObjectStats indicates an expected call of GetNonAppendableObjectStats.

func (*MockRelationMockRecorder) GetPrimaryKeys ¶ added in v0.5.0

func (mr *MockRelationMockRecorder) GetPrimaryKeys(arg0 interface{}) *gomock.Call

GetPrimaryKeys indicates an expected call of GetPrimaryKeys.

func (*MockRelationMockRecorder) GetProcess ¶

func (mr *MockRelationMockRecorder) GetProcess() *gomock.Call

GetProcess indicates an expected call of GetProcess.

func (*MockRelationMockRecorder) GetTableDef ¶ added in v1.1.0

func (mr *MockRelationMockRecorder) GetTableDef(arg0 interface{}) *gomock.Call

GetTableDef indicates an expected call of GetTableDef.

func (*MockRelationMockRecorder) GetTableID ¶ added in v0.6.0

func (mr *MockRelationMockRecorder) GetTableID(arg0 interface{}) *gomock.Call

GetTableID indicates an expected call of GetTableID.

func (*MockRelationMockRecorder) GetTableName ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) GetTableName() *gomock.Call

GetTableName indicates an expected call of GetTableName.

func (*MockRelationMockRecorder) MaxAndMinValues ¶ added in v0.7.0

func (mr *MockRelationMockRecorder) MaxAndMinValues(ctx interface{}) *gomock.Call

MaxAndMinValues indicates an expected call of MaxAndMinValues.

func (*MockRelationMockRecorder) MergeObjects ¶ added in v1.2.0

func (mr *MockRelationMockRecorder) MergeObjects(ctx, objstats, targetObjSize interface{}) *gomock.Call

MergeObjects indicates an expected call of MergeObjects.

func (*MockRelationMockRecorder) PrimaryKeysMayBeModified ¶ added in v0.8.0

func (mr *MockRelationMockRecorder) PrimaryKeysMayBeModified(ctx, from, to, batch, pkIndex, partitionIndex interface{}) *gomock.Call

PrimaryKeysMayBeModified indicates an expected call of PrimaryKeysMayBeModified.

func (*MockRelationMockRecorder) PrimaryKeysMayBeUpserted ¶

func (mr *MockRelationMockRecorder) PrimaryKeysMayBeUpserted(ctx, from, to, batch, pkIndex interface{}) *gomock.Call

PrimaryKeysMayBeUpserted indicates an expected call of PrimaryKeysMayBeUpserted.

func (*MockRelationMockRecorder) Ranges ¶ added in v0.6.0

func (mr *MockRelationMockRecorder) Ranges(arg0, arg1 interface{}) *gomock.Call

Ranges indicates an expected call of Ranges.

func (*MockRelationMockRecorder) Reset ¶

func (mr *MockRelationMockRecorder) Reset(op interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockRelationMockRecorder) Rows ¶

func (mr *MockRelationMockRecorder) Rows(ctx interface{}) *gomock.Call

Rows indicates an expected call of Rows.

func (*MockRelationMockRecorder) Size ¶

func (mr *MockRelationMockRecorder) Size(ctx, columnName interface{}) *gomock.Call

Size indicates an expected call of Size.

func (*MockRelationMockRecorder) StarCount ¶

func (mr *MockRelationMockRecorder) StarCount(ctx interface{}) *gomock.Call

StarCount indicates an expected call of StarCount.

func (*MockRelationMockRecorder) Stats ¶ added in v0.7.0

func (mr *MockRelationMockRecorder) Stats(ctx, sync interface{}) *gomock.Call

Stats indicates an expected call of Stats.

func (*MockRelationMockRecorder) TableColumns ¶ added in v0.6.0

func (mr *MockRelationMockRecorder) TableColumns(ctx interface{}) *gomock.Call

TableColumns indicates an expected call of TableColumns.

func (*MockRelationMockRecorder) TableDefs ¶

func (mr *MockRelationMockRecorder) TableDefs(arg0 interface{}) *gomock.Call

TableDefs indicates an expected call of TableDefs.

func (*MockRelationMockRecorder) TableRenameInTxn ¶ added in v1.1.1

func (mr *MockRelationMockRecorder) TableRenameInTxn(ctx, constraint interface{}) *gomock.Call

TableRenameInTxn indicates an expected call of TableRenameInTxn.

func (*MockRelationMockRecorder) UpdateConstraint ¶ added in v0.7.0

func (mr *MockRelationMockRecorder) UpdateConstraint(arg0, arg1 interface{}) *gomock.Call

UpdateConstraint indicates an expected call of UpdateConstraint.

func (*MockRelationMockRecorder) Write ¶

func (mr *MockRelationMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call

Write indicates an expected call of Write.

func (*MockStatistics) EXPECT ¶

func (m *MockStatistics) EXPECT() *MockStatisticsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStatistics) Rows ¶

func (m *MockStatistics) Rows(ctx context.Context) (uint64, error)

Rows mocks base method.

func (*MockStatistics) Size ¶

func (m *MockStatistics) Size(ctx context.Context, columnName string) (uint64, error)