mock_frontend

Sep 10, 2024

Changes in this version

type MockTxnOperator

+ func (m *MockTxnOperator) EnterIncrStmt()

+ func (m *MockTxnOperator) EnterRollbackStmt()

+ func (m *MockTxnOperator) ExitIncrStmt()

+ func (m *MockTxnOperator) ExitRollbackStmt()

+ func (m *MockTxnOperator) HasLockTable(table uint64) bool

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) EnterIncrStmt() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) EnterRollbackStmt() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) ExitIncrStmt() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) ExitRollbackStmt() *gomock.Call

Jul 11, 2024

Changes in this version

type MockWorkspace

+ func (m *MockWorkspace) GetHaveDDL() bool

+ func (m *MockWorkspace) SetHaveDDL(haveDDL bool)

type MockWorkspaceMockRecorder

+ func (mr *MockWorkspaceMockRecorder) GetHaveDDL() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) SetHaveDDL(haveDDL interface{}) *gomock.Call

Jun 28, 2024

Changes in this version

type MockComputationWrapper

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

type MockComputationWrapperMockRecorder

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

type MockTxnOperator

+ func (m *MockTxnOperator) SetFootPrints(prints [][2]uint32)

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) SetFootPrints(prints interface{}) *gomock.Call

May 17, 2024

Changes in this version

type MockBackgroundExec

+ func (m *MockBackgroundExec) Clear()

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

type MockBackgroundExecMockRecorder

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

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

type MockComputationWrapper

+ func (m *MockComputationWrapper) Clear()

+ func (m *MockComputationWrapper) Free()

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

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

type MockComputationWrapperMockRecorder

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

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

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

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

type MockEngine

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

+ func (m *MockEngine) TryToSubscribeTable(arg0 context.Context, arg1, arg2 uint64) error

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

type MockEngineMockRecorder

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

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

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

+ type MockLogtailEngine struct

+ func NewMockLogtailEngine(ctrl *gomock.Controller) *MockLogtailEngine

+ func (m *MockLogtailEngine) EXPECT() *MockLogtailEngineMockRecorder

+ func (m *MockLogtailEngine) TryToSubscribeTable(arg0 context.Context, arg1, arg2 uint64) error

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

+ type MockLogtailEngineMockRecorder struct

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

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

type MockReader

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

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

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

type MockReaderMockRecorder

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

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

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

type MockRelation

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

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

type MockRelationMockRecorder

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

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

+ type MockTxnAction struct

+ func NewMockTxnAction(ctrl *gomock.Controller) *MockTxnAction

+ func (m *MockTxnAction) AbortAllRunningTxn()

+ func (m *MockTxnAction) EXPECT() *MockTxnActionMockRecorder

+ func (m *MockTxnAction) Pause()

+ func (m *MockTxnAction) Resume()

+ type MockTxnActionMockRecorder struct

+ func (mr *MockTxnActionMockRecorder) AbortAllRunningTxn() *gomock.Call

+ func (mr *MockTxnActionMockRecorder) Pause() *gomock.Call

+ func (mr *MockTxnActionMockRecorder) Resume() *gomock.Call

type MockTxnOperator

+ func (m *MockTxnOperator) CloneSnapshotOp(snapshot timestamp.Timestamp) client.TxnOperator

+ func (m *MockTxnOperator) CreateTS() timestamp.Timestamp

+ func (m *MockTxnOperator) GetWaitActiveCost() time.Duration

+ func (m *MockTxnOperator) IsSnapOp() bool

+ func (m *MockTxnOperator) NextSequence() uint64

+ func (m *MockTxnOperator) TxnOptions() txn.TxnOptions

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) CloneSnapshotOp(snapshot interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) CreateTS() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) GetWaitActiveCost() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) IsSnapOp() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) NextSequence() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) TxnOptions() *gomock.Call

+ type MockTxnTimestampAware struct

+ func NewMockTxnTimestampAware(ctrl *gomock.Controller) *MockTxnTimestampAware

+ func (m *MockTxnTimestampAware) EXPECT() *MockTxnTimestampAwareMockRecorder

+ func (m *MockTxnTimestampAware) GetLatestCommitTS() timestamp.Timestamp

+ func (m *MockTxnTimestampAware) GetSyncLatestCommitTSTimes() uint64

+ func (m *MockTxnTimestampAware) MinTimestamp() timestamp.Timestamp

+ func (m *MockTxnTimestampAware) SyncLatestCommitTS(arg0 timestamp.Timestamp)

+ func (m *MockTxnTimestampAware) WaitLogTailAppliedAt(ctx context.Context, ts timestamp.Timestamp) (timestamp.Timestamp, error)

+ type MockTxnTimestampAwareMockRecorder struct

+ func (mr *MockTxnTimestampAwareMockRecorder) GetLatestCommitTS() *gomock.Call

+ func (mr *MockTxnTimestampAwareMockRecorder) GetSyncLatestCommitTSTimes() *gomock.Call

+ func (mr *MockTxnTimestampAwareMockRecorder) MinTimestamp() *gomock.Call

+ func (mr *MockTxnTimestampAwareMockRecorder) SyncLatestCommitTS(arg0 interface{}) *gomock.Call

+ func (mr *MockTxnTimestampAwareMockRecorder) WaitLogTailAppliedAt(ctx, ts interface{}) *gomock.Call

type MockWorkspace

+ func (m *MockWorkspace) BindTxnOp(op client.TxnOperator)

+ func (m *MockWorkspace) CloneSnapshotWS() client.Workspace

type MockWorkspaceMockRecorder

+ func (mr *MockWorkspaceMockRecorder) BindTxnOp(op interface{}) *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) CloneSnapshotWS() *gomock.Call

Apr 2, 2024

Changes in this version

type MockRelation

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

type MockRelationMockRecorder

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

type MockTxnOperator

+ func (m *MockTxnOperator) EnterRunSql()

+ func (m *MockTxnOperator) ExitRunSql()

+ func (m *MockTxnOperator) LockTableCount() int32

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) EnterRunSql() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) ExitRunSql() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) LockTableCount() *gomock.Call

type MockWorkspace

+ func (m *MockWorkspace) GetSnapshotWriteOffset() int

+ func (m *MockWorkspace) TransferRowID()

+ func (m *MockWorkspace) UpdateSnapshotWriteOffset()

type MockWorkspaceMockRecorder

+ func (mr *MockWorkspaceMockRecorder) GetSnapshotWriteOffset() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) TransferRowID() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) UpdateSnapshotWriteOffset() *gomock.Call

Feb 2, 2024

Changes in this version

+ type MockRanges struct

+ func NewMockRanges(ctrl *gomock.Controller) *MockRanges

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

+ func (m *MockRanges) EXPECT() *MockRangesMockRecorder

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

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

+ func (m *MockRanges) Len() int

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

+ func (m *MockRanges) Size() int

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

+ type MockRangesMockRecorder struct

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

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

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

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

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

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

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

type MockRelation

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

type MockRelationMockRecorder

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

type MockWorkspace

+ func (m *MockWorkspace) WriteOffset() uint64

type MockWorkspaceMockRecorder

+ func (mr *MockWorkspaceMockRecorder) WriteOffset() *gomock.Call

Dec 29, 2023

Changes in this version

type MockRelation

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

type MockRelationMockRecorder

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

type MockTimestampWaiter

+ func (m *MockTimestampWaiter) CancelC() chan struct{}

+ func (m *MockTimestampWaiter) LatestTS() timestamp.Timestamp

+ func (m *MockTimestampWaiter) Pause()

+ func (m *MockTimestampWaiter) Resume()

type MockTimestampWaiterMockRecorder

+ func (mr *MockTimestampWaiterMockRecorder) CancelC() *gomock.Call

+ func (mr *MockTimestampWaiterMockRecorder) LatestTS() *gomock.Call

+ func (mr *MockTimestampWaiterMockRecorder) Pause() *gomock.Call

+ func (mr *MockTimestampWaiterMockRecorder) Resume() *gomock.Call

type MockTxnClient

+ func (m *MockTxnClient) GetState() client.TxnState

type MockTxnClientMockRecorder

+ func (mr *MockTxnClientMockRecorder) GetState() *gomock.Call

type MockTxnOperator

+ func (m *MockTxnOperator) IsOpenLog() bool

+ func (m *MockTxnOperator) LockSkipped(tableID uint64, mode lock.LockMode) bool

+ func (m *MockTxnOperator) SetOpenLog(arg0 bool)

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) IsOpenLog() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) LockSkipped(tableID, mode interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) SetOpenLog(arg0 interface{}) *gomock.Call

Nov 13, 2023

Changes in this version

type MockReader

+ func (m *MockReader) Count() *engine.ReaderCount

type MockReaderMockRecorder

+ func (mr *MockReaderMockRecorder) Count() *gomock.Call

type MockRelation

+ func (m *MockRelation) UpdateObjectInfos(arg0 context.Context) error

type MockRelationMockRecorder

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

type MockTimestampWaiter

+ func (m *MockTimestampWaiter) Cancel()

type MockTimestampWaiterMockRecorder

+ func (mr *MockTimestampWaiterMockRecorder) Cancel() *gomock.Call

type MockTxnClient

+ func (m *MockTxnClient) CNBasedConsistencyEnabled() bool

+ func (m *MockTxnClient) GetLatestCommitTS() timestamp.Timestamp

+ func (m *MockTxnClient) GetSyncLatestCommitTSTimes() uint64

+ func (m *MockTxnClient) IterTxns(arg0 func(client.TxnOverview) bool)

+ func (m *MockTxnClient) Pause()

+ func (m *MockTxnClient) RefreshExpressionEnabled() bool

+ func (m *MockTxnClient) Resume()

+ func (m *MockTxnClient) SyncLatestCommitTS(arg0 timestamp.Timestamp)

type MockTxnClientMockRecorder

+ func (mr *MockTxnClientMockRecorder) CNBasedConsistencyEnabled() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) GetLatestCommitTS() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) GetSyncLatestCommitTSTimes() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) IterTxns(arg0 interface{}) *gomock.Call

+ func (mr *MockTxnClientMockRecorder) Pause() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) RefreshExpressionEnabled() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) Resume() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) SyncLatestCommitTS(arg0 interface{}) *gomock.Call

type MockTxnOperator

+ func (m *MockTxnOperator) AddWaitLock(tableID uint64, rows [][]byte, opt lock.LockOptions) uint64

+ func (m *MockTxnOperator) AppendEventCallback(event client.EventType, callbacks ...func(txn.TxnMeta))

+ func (m *MockTxnOperator) Debug(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockTxnOperator) GetOverview() client.TxnOverview

+ func (m *MockTxnOperator) IsRetry() bool

+ func (m *MockTxnOperator) RemoveWaitLock(key uint64)

+ func (m *MockTxnOperator) ResetRetry(arg0 bool)

+ func (m *MockTxnOperator) SetLastSql(sql string)

+ func (m *MockTxnOperator) SnapshotTS() timestamp.Timestamp

+ func (m *MockTxnOperator) Status() txn.TxnStatus

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) AddWaitLock(tableID, rows, opt interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) AppendEventCallback(event interface{}, callbacks ...interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Debug(ctx, ops interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) GetOverview() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) IsRetry() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) RemoveWaitLock(key interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) ResetRetry(arg0 interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) SetLastSql(sql interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) SnapshotTS() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Status() *gomock.Call

type MockWorkspace

+ func (m *MockWorkspace) Adjust() error

+ func (m *MockWorkspace) EndStatement()

+ func (m *MockWorkspace) GetSQLCount() uint64

+ func (m *MockWorkspace) IncrSQLCount()

+ func (m *MockWorkspace) StartStatement()

type MockWorkspaceMockRecorder

+ func (mr *MockWorkspaceMockRecorder) Adjust() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) EndStatement() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) GetSQLCount() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) IncrSQLCount() *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) StartStatement() *gomock.Call

Oct 9, 2023

Changes in this version

type MockComputationWrapper

+ func (m *MockComputationWrapper) GetServerStatus() uint16

type MockComputationWrapperMockRecorder

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

Jun 30, 2023

Changes in this version

type MockBackgroundExec

+ func (m *MockBackgroundExec) ClearExecResultBatches()

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

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

type MockBackgroundExecMockRecorder

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

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

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

type MockConstraint

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

type MockConstraintMockRecorder

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

type MockDatabase

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

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

type MockDatabaseMockRecorder

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

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

type MockDebugableTxnOperator

+ func (m *MockDebugableTxnOperator) AddLockTable(locktable lock.LockTable) error

+ func (m *MockDebugableTxnOperator) AddWorkspace(workspace client.Workspace)

+ func (m *MockDebugableTxnOperator) GetWorkspace() client.Workspace

+ func (m *MockDebugableTxnOperator) TxnRef() *txn.TxnMeta

+ func (m *MockDebugableTxnOperator) UpdateSnapshot(ctx context.Context, ts timestamp.Timestamp) error

type MockDebugableTxnOperatorMockRecorder

+ func (mr *MockDebugableTxnOperatorMockRecorder) AddLockTable(locktable interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) AddWorkspace(workspace interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) GetWorkspace() *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) TxnRef() *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) UpdateSnapshot(ctx, ts interface{}) *gomock.Call

type MockEngine

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

type MockEngineMockRecorder

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

+ type MockEventableTxnOperator struct

+ func NewMockEventableTxnOperator(ctrl *gomock.Controller) *MockEventableTxnOperator

+ func (m *MockEventableTxnOperator) AddLockTable(locktable lock.LockTable) error

+ func (m *MockEventableTxnOperator) AddWorkspace(workspace client.Workspace)

+ func (m *MockEventableTxnOperator) AppendEventCallback(event client.EventType, callbacks ...func(txn.TxnMeta))

+ func (m *MockEventableTxnOperator) ApplySnapshot(data []byte) error

+ func (m *MockEventableTxnOperator) Commit(ctx context.Context) error

+ func (m *MockEventableTxnOperator) EXPECT() *MockEventableTxnOperatorMockRecorder

+ func (m *MockEventableTxnOperator) GetWorkspace() client.Workspace

+ func (m *MockEventableTxnOperator) Read(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockEventableTxnOperator) Rollback(ctx context.Context) error

+ func (m *MockEventableTxnOperator) Snapshot() ([]byte, error)

+ func (m *MockEventableTxnOperator) Txn() txn.TxnMeta

+ func (m *MockEventableTxnOperator) TxnRef() *txn.TxnMeta

+ func (m *MockEventableTxnOperator) UpdateSnapshot(ctx context.Context, ts timestamp.Timestamp) error

+ func (m *MockEventableTxnOperator) Write(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockEventableTxnOperator) WriteAndCommit(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ type MockEventableTxnOperatorMockRecorder struct

+ func (mr *MockEventableTxnOperatorMockRecorder) AddLockTable(locktable interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) AddWorkspace(workspace interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) AppendEventCallback(event interface{}, callbacks ...interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) ApplySnapshot(data interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Commit(ctx interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) GetWorkspace() *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Read(ctx, ops interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Rollback(ctx interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Snapshot() *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Txn() *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) TxnRef() *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) UpdateSnapshot(ctx, ts interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) Write(ctx, ops interface{}) *gomock.Call

+ func (mr *MockEventableTxnOperatorMockRecorder) WriteAndCommit(ctx, ops interface{}) *gomock.Call

type MockRelation

+ func (m *MockRelation) AlterTable(ctx context.Context, c *engine.ConstraintDef, constraint [][]byte) error

+ func (m *MockRelation) ApplyRuntimeFilters(arg0 context.Context, arg1 [][]byte, arg2 []*plan.Expr, ...) ([][]byte, error)

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

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

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

+ func (m *MockRelation) GetTableName() string

+ func (m *MockRelation) PrimaryKeysMayBeModified(ctx context.Context, from, to types.TS, keyVector *vector.Vector) (bool, error)

type MockRelationMockRecorder

+ func (mr *MockRelationMockRecorder) AlterTable(ctx, c, constraint interface{}) *gomock.Call

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

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

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

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

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

+ func (mr *MockRelationMockRecorder) PrimaryKeysMayBeModified(ctx, from, to, keyVector interface{}) *gomock.Call

type MockTableDef

+ func (m *MockTableDef) ToPBVersion() engine.TableDefPB

type MockTableDefMockRecorder

+ func (mr *MockTableDefMockRecorder) ToPBVersion() *gomock.Call

+ type MockTimestampWaiter struct

+ func NewMockTimestampWaiter(ctrl *gomock.Controller) *MockTimestampWaiter

+ func (m *MockTimestampWaiter) Close()

+ func (m *MockTimestampWaiter) EXPECT() *MockTimestampWaiterMockRecorder

+ func (m *MockTimestampWaiter) GetTimestamp(arg0 context.Context, arg1 timestamp.Timestamp) (timestamp.Timestamp, error)

+ func (m *MockTimestampWaiter) NotifyLatestCommitTS(appliedTS timestamp.Timestamp)

+ type MockTimestampWaiterMockRecorder struct

+ func (mr *MockTimestampWaiterMockRecorder) Close() *gomock.Call

+ func (mr *MockTimestampWaiterMockRecorder) GetTimestamp(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTimestampWaiterMockRecorder) NotifyLatestCommitTS(appliedTS interface{}) *gomock.Call

type MockTxnClient

+ func (m *MockTxnClient) AbortAllRunningTxn()

+ func (m *MockTxnClient) MinTimestamp() timestamp.Timestamp

+ func (m *MockTxnClient) WaitLogTailAppliedAt(ctx context.Context, ts timestamp.Timestamp) (timestamp.Timestamp, error)

type MockTxnClientMockRecorder

+ func (mr *MockTxnClientMockRecorder) AbortAllRunningTxn() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) MinTimestamp() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) WaitLogTailAppliedAt(ctx, ts interface{}) *gomock.Call

+ type MockTxnClientWithCtl struct

+ func NewMockTxnClientWithCtl(ctrl *gomock.Controller) *MockTxnClientWithCtl

+ func (m *MockTxnClientWithCtl) AbortAllRunningTxn()

+ func (m *MockTxnClientWithCtl) Close() error

+ func (m *MockTxnClientWithCtl) EXPECT() *MockTxnClientWithCtlMockRecorder

+ func (m *MockTxnClientWithCtl) GetLatestCommitTS() timestamp.Timestamp

+ func (m *MockTxnClientWithCtl) MinTimestamp() timestamp.Timestamp

+ func (m *MockTxnClientWithCtl) New(ctx context.Context, commitTS timestamp.Timestamp, options ...client.TxnOption) (client.TxnOperator, error)

+ func (m *MockTxnClientWithCtl) NewWithSnapshot(snapshot []byte) (client.TxnOperator, error)

+ func (m *MockTxnClientWithCtl) SetLatestCommitTS(arg0 timestamp.Timestamp)

+ func (m *MockTxnClientWithCtl) WaitLogTailAppliedAt(ctx context.Context, ts timestamp.Timestamp) (timestamp.Timestamp, error)

+ type MockTxnClientWithCtlMockRecorder struct

+ func (mr *MockTxnClientWithCtlMockRecorder) AbortAllRunningTxn() *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) Close() *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) GetLatestCommitTS() *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) MinTimestamp() *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) New(ctx, commitTS interface{}, options ...interface{}) *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) NewWithSnapshot(snapshot interface{}) *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) SetLatestCommitTS(arg0 interface{}) *gomock.Call

+ func (mr *MockTxnClientWithCtlMockRecorder) WaitLogTailAppliedAt(ctx, ts interface{}) *gomock.Call

+ type MockTxnClientWithFeature struct

+ func NewMockTxnClientWithFeature(ctrl *gomock.Controller) *MockTxnClientWithFeature

+ func (m *MockTxnClientWithFeature) AbortAllRunningTxn()

+ func (m *MockTxnClientWithFeature) CNBasedConsistencyEnabled() bool

+ func (m *MockTxnClientWithFeature) Close() error

+ func (m *MockTxnClientWithFeature) EXPECT() *MockTxnClientWithFeatureMockRecorder

+ func (m *MockTxnClientWithFeature) MinTimestamp() timestamp.Timestamp

+ func (m *MockTxnClientWithFeature) New(ctx context.Context, commitTS timestamp.Timestamp, options ...client.TxnOption) (client.TxnOperator, error)

+ func (m *MockTxnClientWithFeature) NewWithSnapshot(snapshot []byte) (client.TxnOperator, error)

+ func (m *MockTxnClientWithFeature) Pause()

+ func (m *MockTxnClientWithFeature) RefreshExpressionEnabled() bool

+ func (m *MockTxnClientWithFeature) Resume()

+ func (m *MockTxnClientWithFeature) WaitLogTailAppliedAt(ctx context.Context, ts timestamp.Timestamp) (timestamp.Timestamp, error)

+ type MockTxnClientWithFeatureMockRecorder struct

+ func (mr *MockTxnClientWithFeatureMockRecorder) AbortAllRunningTxn() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) CNBasedConsistencyEnabled() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) Close() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) MinTimestamp() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) New(ctx, commitTS interface{}, options ...interface{}) *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) NewWithSnapshot(snapshot interface{}) *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) Pause() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) RefreshExpressionEnabled() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) Resume() *gomock.Call

+ func (mr *MockTxnClientWithFeatureMockRecorder) WaitLogTailAppliedAt(ctx, ts interface{}) *gomock.Call

type MockTxnOperator

+ func (m *MockTxnOperator) AddLockTable(locktable lock.LockTable) error

+ func (m *MockTxnOperator) AddWorkspace(workspace client.Workspace)

+ func (m *MockTxnOperator) GetWorkspace() client.Workspace

+ func (m *MockTxnOperator) TxnRef() *txn.TxnMeta

+ func (m *MockTxnOperator) UpdateSnapshot(ctx context.Context, ts timestamp.Timestamp) error

type MockTxnOperatorMockRecorder

+ func (mr *MockTxnOperatorMockRecorder) AddLockTable(locktable interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) AddWorkspace(workspace interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) GetWorkspace() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) TxnRef() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) UpdateSnapshot(ctx, ts interface{}) *gomock.Call

+ type MockVectorPool struct

+ func NewMockVectorPool(ctrl *gomock.Controller) *MockVectorPool

+ func (m *MockVectorPool) EXPECT() *MockVectorPoolMockRecorder

+ func (m *MockVectorPool) GetVector(typ types.Type) *vector.Vector

+ func (m *MockVectorPool) PutBatch(bat *batch.Batch)

+ type MockVectorPoolMockRecorder struct

+ func (mr *MockVectorPoolMockRecorder) GetVector(typ interface{}) *gomock.Call

+ func (mr *MockVectorPoolMockRecorder) PutBatch(bat interface{}) *gomock.Call

+ type MockWorkspace struct

+ func NewMockWorkspace(ctrl *gomock.Controller) *MockWorkspace

+ func (m *MockWorkspace) Commit(ctx context.Context) error

+ func (m *MockWorkspace) EXPECT() *MockWorkspaceMockRecorder

+ func (m *MockWorkspace) IncrStatementID(ctx context.Context, commit bool) error

+ func (m *MockWorkspace) Rollback(ctx context.Context) error

+ func (m *MockWorkspace) RollbackLastStatement(ctx context.Context) error

+ type MockWorkspaceMockRecorder struct

+ func (mr *MockWorkspaceMockRecorder) Commit(ctx interface{}) *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) IncrStatementID(ctx, commit interface{}) *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) Rollback(ctx interface{}) *gomock.Call

+ func (mr *MockWorkspaceMockRecorder) RollbackLastStatement(ctx interface{}) *gomock.Call

+ type MockoutputPool struct

+ func NewMockoutputPool(ctrl *gomock.Controller) *MockoutputPool

+ func (m *MockoutputPool) EXPECT() *MockoutputPoolMockRecorder

+ type MockoutputPoolMockRecorder struct

Feb 18, 2023

Changes in this version

+ type MockConstraint struct

+ func NewMockConstraint(ctrl *gomock.Controller) *MockConstraint

+ func (m *MockConstraint) EXPECT() *MockConstraintMockRecorder

+ type MockConstraintMockRecorder struct

type MockEngine

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

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

type MockEngineMockRecorder

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

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

type MockRelation

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

+ func (m *MockRelation) Stats(ctx context.Context, expr *plan.Expr) (*plan.Stats, error)

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

type MockRelationMockRecorder

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

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

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

type MockStatistics

+ func (m *MockStatistics) Stats(ctx context.Context, expr *plan.Expr) (*plan.Stats, error)

type MockStatisticsMockRecorder

+ func (mr *MockStatisticsMockRecorder) Stats(ctx, expr interface{}) *gomock.Call

Nov 29, 2022

Changes in this version

+ type MockBackgroundExec struct

+ func NewMockBackgroundExec(ctrl *gomock.Controller) *MockBackgroundExec

+ func (m *MockBackgroundExec) ClearExecResultSet()

+ func (m *MockBackgroundExec) Close()

+ func (m *MockBackgroundExec) EXPECT() *MockBackgroundExecMockRecorder

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

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

+ type MockBackgroundExecMockRecorder struct

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

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

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

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

+ type MockColumnInfo struct

+ func NewMockColumnInfo(ctrl *gomock.Controller) *MockColumnInfo

+ func (m *MockColumnInfo) EXPECT() *MockColumnInfoMockRecorder

+ func (m *MockColumnInfo) GetName() string

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

+ type MockColumnInfoMockRecorder struct

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

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

type MockComputationWrapper

+ func (m *MockComputationWrapper) GetLoadTag() bool

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

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

+ func (m *MockComputationWrapper) RecordExecPlan(ctx context.Context) error

type MockComputationWrapperMockRecorder

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

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

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

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

type MockDatabase

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

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

type MockDatabaseMockRecorder

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

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

+ type MockDebugableTxnOperator struct

+ func NewMockDebugableTxnOperator(ctrl *gomock.Controller) *MockDebugableTxnOperator

+ func (m *MockDebugableTxnOperator) ApplySnapshot(data []byte) error

+ func (m *MockDebugableTxnOperator) Commit(ctx context.Context) error

+ func (m *MockDebugableTxnOperator) Debug(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockDebugableTxnOperator) EXPECT() *MockDebugableTxnOperatorMockRecorder

+ func (m *MockDebugableTxnOperator) Read(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockDebugableTxnOperator) Rollback(ctx context.Context) error

+ func (m *MockDebugableTxnOperator) Snapshot() ([]byte, error)

+ func (m *MockDebugableTxnOperator) Txn() txn.TxnMeta

+ func (m *MockDebugableTxnOperator) Write(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockDebugableTxnOperator) WriteAndCommit(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ type MockDebugableTxnOperatorMockRecorder struct

+ func (mr *MockDebugableTxnOperatorMockRecorder) ApplySnapshot(data interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Commit(ctx interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Debug(ctx, ops interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Read(ctx, ops interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Rollback(ctx interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Snapshot() *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Txn() *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) Write(ctx, ops interface{}) *gomock.Call

+ func (mr *MockDebugableTxnOperatorMockRecorder) WriteAndCommit(ctx, ops interface{}) *gomock.Call

type MockEngine

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

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

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

+ func (m *MockEngine) NewBlockReader(ctx context.Context, num int, ts timestamp.Timestamp, expr *plan.Expr, ...) ([]engine.Reader, error)

+ func (m *MockEngine) Nodes() (engine.Nodes, error)

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

type MockEngineMockRecorder

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

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

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

+ func (mr *MockEngineMockRecorder) NewBlockReader(ctx, num, ts, expr, ranges, tblDef interface{}) *gomock.Call

+ func (mr *MockEngineMockRecorder) Nodes() *gomock.Call

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

+ type MockExecResult struct

+ func NewMockExecResult(ctrl *gomock.Controller) *MockExecResult

+ func (m *MockExecResult) EXPECT() *MockExecResultMockRecorder

+ func (m *MockExecResult) GetInt64(rindex, cindex uint64) (int64, error)

+ func (m *MockExecResult) GetRowCount() uint64

+ func (m *MockExecResult) GetString(rindex, cindex uint64) (string, error)

+ func (m *MockExecResult) GetUint64(rindex, cindex uint64) (uint64, error)

+ type MockExecResultMockRecorder struct

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

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

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

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

type MockIOSession

+ func (m *MockIOSession) Disconnect() error

+ func (m *MockIOSession) Ref()

+ func (m *MockIOSession) RemoteAddress() string

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

type MockIOSessionMockRecorder

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

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

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

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

type MockReader

+ func (m *MockReader) Close() error

type MockReaderMockRecorder

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

type MockRelation

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

+ func (m *MockRelation) GetTableID(arg0 context.Context) string

+ func (m *MockRelation) Ranges(arg0 context.Context, arg1 *plan.Expr) ([][]byte, error)

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

type MockRelationMockRecorder

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

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

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

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

+ type MockTableInfo struct

+ func NewMockTableInfo(ctrl *gomock.Controller) *MockTableInfo

+ func (m *MockTableInfo) EXPECT() *MockTableInfoMockRecorder

+ func (m *MockTableInfo) GetColumns()

+ type MockTableInfoMockRecorder struct

+ func (mr *MockTableInfoMockRecorder) GetColumns() *gomock.Call

+ type MockTxnClient struct

+ func NewMockTxnClient(ctrl *gomock.Controller) *MockTxnClient

+ func (m *MockTxnClient) Close() error

+ func (m *MockTxnClient) EXPECT() *MockTxnClientMockRecorder

+ func (m *MockTxnClient) New(options ...client.TxnOption) (client.TxnOperator, error)

+ func (m *MockTxnClient) NewWithSnapshot(snapshot []byte) (client.TxnOperator, error)

+ type MockTxnClientMockRecorder struct

+ func (mr *MockTxnClientMockRecorder) Close() *gomock.Call

+ func (mr *MockTxnClientMockRecorder) New(options ...interface{}) *gomock.Call

+ func (mr *MockTxnClientMockRecorder) NewWithSnapshot(snapshot interface{}) *gomock.Call

+ type MockTxnIDGenerator struct

+ func NewMockTxnIDGenerator(ctrl *gomock.Controller) *MockTxnIDGenerator

+ func (m *MockTxnIDGenerator) EXPECT() *MockTxnIDGeneratorMockRecorder

+ func (m *MockTxnIDGenerator) Generate() []byte

+ type MockTxnIDGeneratorMockRecorder struct

+ func (mr *MockTxnIDGeneratorMockRecorder) Generate() *gomock.Call

+ type MockTxnOperator struct

+ func NewMockTxnOperator(ctrl *gomock.Controller) *MockTxnOperator

+ func (m *MockTxnOperator) ApplySnapshot(data []byte) error

+ func (m *MockTxnOperator) Commit(ctx context.Context) error

+ func (m *MockTxnOperator) EXPECT() *MockTxnOperatorMockRecorder

+ func (m *MockTxnOperator) Read(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockTxnOperator) Rollback(ctx context.Context) error

+ func (m *MockTxnOperator) Snapshot() ([]byte, error)

+ func (m *MockTxnOperator) Txn() txn.TxnMeta

+ func (m *MockTxnOperator) Write(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ func (m *MockTxnOperator) WriteAndCommit(ctx context.Context, ops []txn.TxnRequest) (*rpc.SendResult, error)

+ type MockTxnOperatorMockRecorder struct

+ func (mr *MockTxnOperatorMockRecorder) ApplySnapshot(data interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Commit(ctx interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Read(ctx, ops interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Rollback(ctx interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Snapshot() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Txn() *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) Write(ctx, ops interface{}) *gomock.Call

+ func (mr *MockTxnOperatorMockRecorder) WriteAndCommit(ctx, ops interface{}) *gomock.Call

Jul 14, 2022

Changes in this version

+ type MockComputationRunner struct

+ func NewMockComputationRunner(ctrl *gomock.Controller) *MockComputationRunner

+ func (m *MockComputationRunner) EXPECT() *MockComputationRunnerMockRecorder

+ func (m *MockComputationRunner) Run(ts uint64) error

+ type MockComputationRunnerMockRecorder struct

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

type MockIOSessionMockRecorder

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

type MockRelation

+ func (m *MockRelation) Delete(arg0 uint64, arg1 *vector.Vector, arg2 string, arg3 engine.Snapshot) error

+ func (m *MockRelation) GetHideKey(arg0 engine.Snapshot) *engine.Attribute

+ func (m *MockRelation) GetPrimaryKeys(arg0 engine.Snapshot) []*engine.Attribute

+ func (m *MockRelation) Truncate(arg0 engine.Snapshot) (uint64, error)

+ func (m *MockRelation) Update(arg0 uint64, arg1 *batch.Batch, arg2 engine.Snapshot) error

type MockRelationMockRecorder

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

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

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

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

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

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

+ type MockTxn struct

+ func NewMockTxn(ctrl *gomock.Controller) *MockTxn

+ func (m *MockTxn) Commit() error

+ func (m *MockTxn) EXPECT() *MockTxnMockRecorder

+ func (m *MockTxn) GetCtx() []byte

+ func (m *MockTxn) GetError() error

+ func (m *MockTxn) GetID() uint64

+ func (m *MockTxn) Repr() string

+ func (m *MockTxn) Rollback() error

+ func (m *MockTxn) String() string

+ type MockTxnEngine struct

+ func NewMockTxnEngine(ctrl *gomock.Controller) *MockTxnEngine

+ func (m *MockTxnEngine) Create(arg0 uint64, arg1 string, arg2 int, arg3 engine.Snapshot) error

+ func (m *MockTxnEngine) Database(arg0 string, arg1 engine.Snapshot) (engine.Database, error)

+ func (m *MockTxnEngine) Databases(arg0 engine.Snapshot) []string

+ func (m *MockTxnEngine) Delete(arg0 uint64, arg1 string, arg2 engine.Snapshot) error

+ func (m *MockTxnEngine) EXPECT() *MockTxnEngineMockRecorder

+ func (m *MockTxnEngine) Node(arg0 string, arg1 engine.Snapshot) *engine.NodeInfo

+ func (m *MockTxnEngine) StartTxn(info []byte) (moengine.Txn, error)

+ type MockTxnEngineMockRecorder struct

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

+ func (mr *MockTxnEngineMockRecorder) Database(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTxnEngineMockRecorder) Databases(arg0 interface{}) *gomock.Call

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

+ func (mr *MockTxnEngineMockRecorder) Node(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTxnEngineMockRecorder) StartTxn(info interface{}) *gomock.Call

+ type MockTxnMockRecorder struct

+ func (mr *MockTxnMockRecorder) Commit() *gomock.Call

+ func (mr *MockTxnMockRecorder) GetCtx() *gomock.Call

+ func (mr *MockTxnMockRecorder) GetError() *gomock.Call

+ func (mr *MockTxnMockRecorder) GetID() *gomock.Call

+ func (mr *MockTxnMockRecorder) Repr() *gomock.Call

+ func (mr *MockTxnMockRecorder) Rollback() *gomock.Call

+ func (mr *MockTxnMockRecorder) String() *gomock.Call

May 5, 2022

Changes in this version

+ type MockComputationWrapper struct

+ func NewMockComputationWrapper(ctrl *gomock.Controller) *MockComputationWrapper

+ func (m *MockComputationWrapper) Compile(u interface{}, fill func(interface{}, *batch.Batch) error) error

+ func (m *MockComputationWrapper) EXPECT() *MockComputationWrapperMockRecorder

+ func (m *MockComputationWrapper) GetAffectedRows() uint64

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

+ func (m *MockComputationWrapper) GetColumns() ([]interface{}, error)

+ func (m *MockComputationWrapper) Run(ts uint64) error

+ func (m *MockComputationWrapper) SetDatabaseName(db string) error

+ type MockComputationWrapperMockRecorder struct

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

+ func (mr *MockComputationWrapperMockRecorder) GetAffectedRows() *gomock.Call

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

+ func (mr *MockComputationWrapperMockRecorder) GetColumns() *gomock.Call

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

+ func (mr *MockComputationWrapperMockRecorder) SetDatabaseName(db interface{}) *gomock.Call

+ type MockDatabase struct

+ func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase

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

+ func (m *MockDatabase) Delete(arg0 uint64, arg1 string) error

+ func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder

+ func (m *MockDatabase) Relation(arg0 string) (engine.Relation, error)

+ func (m *MockDatabase) Relations() []string

+ type MockDatabaseMockRecorder struct

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

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

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

+ func (mr *MockDatabaseMockRecorder) Relations() *gomock.Call

+ type MockEngine struct

+ func NewMockEngine(ctrl *gomock.Controller) *MockEngine

+ func (m *MockEngine) Create(arg0 uint64, arg1 string, arg2 int) error

+ func (m *MockEngine) Database(arg0 string) (engine.Database, error)

+ func (m *MockEngine) Databases() []string

+ func (m *MockEngine) Delete(arg0 uint64, arg1 string) error

+ func (m *MockEngine) EXPECT() *MockEngineMockRecorder

+ func (m *MockEngine) Node(arg0 string) *engine.NodeInfo

+ type MockEngineMockRecorder struct

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

+ func (mr *MockEngineMockRecorder) Database(arg0 interface{}) *gomock.Call

+ func (mr *MockEngineMockRecorder) Databases() *gomock.Call

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

+ func (mr *MockEngineMockRecorder) Node(arg0 interface{}) *gomock.Call

+ type MockFilter struct

+ func NewMockFilter(ctrl *gomock.Controller) *MockFilter

+ func (m *MockFilter) Btw(arg0 string, arg1, arg2 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) EXPECT() *MockFilterMockRecorder

+ func (m *MockFilter) Eq(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) Ge(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) Gt(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) Le(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) Lt(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ func (m *MockFilter) Ne(arg0 string, arg1 interface{}) (*roaring64.Bitmap, error)

+ type MockFilterMockRecorder struct

+ func (mr *MockFilterMockRecorder) Btw(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Eq(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Ge(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Gt(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Le(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Lt(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockFilterMockRecorder) Ne(arg0, arg1 interface{}) *gomock.Call

+ type MockIOPackage struct

+ func NewMockIOPackage(ctrl *gomock.Controller) *MockIOPackage

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

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

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

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

+ func (m *MockIOPackage) EXPECT() *MockIOPackageMockRecorder

+ func (m *MockIOPackage) IsLittleEndian() bool

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

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

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

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

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

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

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

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

+ type MockIOPackageMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockIOSession struct

+ func NewMockIOSession(ctrl *gomock.Controller) *MockIOSession

+ func (m *MockIOSession) Close() error

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

+ func (m *MockIOSession) Connected() bool

+ func (m *MockIOSession) EXPECT() *MockIOSessionMockRecorder

+ func (m *MockIOSession) Flush() error

+ func (m *MockIOSession) GetAttr(key string) interface{}

+ func (m *MockIOSession) ID() uint64

+ func (m *MockIOSession) InBuf() *buf.ByteBuf

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

+ func (m *MockIOSession) RawConn() (net.Conn, error)

+ func (m *MockIOSession) Read() (interface{}, error)

+ func (m *MockIOSession) RemoteAddr() string

+ func (m *MockIOSession) RemoteIP() string

+ func (m *MockIOSession) SetAttr(key string, value interface{})

+ func (m *MockIOSession) Write(msg interface{}) error

+ func (m *MockIOSession) WriteAndFlush(msg interface{}) error

+ type MockIOSessionMockRecorder struct

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

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

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

+ func (mr *MockIOSessionMockRecorder) Flush() *gomock.Call

+ func (mr *MockIOSessionMockRecorder) GetAttr(key interface{}) *gomock.Call

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

+ func (mr *MockIOSessionMockRecorder) InBuf() *gomock.Call

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

+ func (mr *MockIOSessionMockRecorder) Read() *gomock.Call

+ func (mr *MockIOSessionMockRecorder) RemoteAddr() *gomock.Call

+ func (mr *MockIOSessionMockRecorder) RemoteIP() *gomock.Call

+ func (mr *MockIOSessionMockRecorder) SetAttr(key, value interface{}) *gomock.Call

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

+ func (mr *MockIOSessionMockRecorder) WriteAndFlush(msg interface{}) *gomock.Call

+ type MockReader struct

+ func NewMockReader(ctrl *gomock.Controller) *MockReader

+ func (m *MockReader) EXPECT() *MockReaderMockRecorder

+ func (m *MockReader) NewFilter() engine.Filter

+ func (m *MockReader) NewSparseFilter() engine.SparseFilter

+ func (m *MockReader) NewSummarizer() engine.Summarizer

+ func (m *MockReader) Read(arg0 []uint64, arg1 []string) (*batch.Batch, error)

+ type MockReaderMockRecorder struct

+ func (mr *MockReaderMockRecorder) NewFilter() *gomock.Call

+ func (mr *MockReaderMockRecorder) NewSparseFilter() *gomock.Call

+ func (mr *MockReaderMockRecorder) NewSummarizer() *gomock.Call

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

+ type MockRelation struct

+ func NewMockRelation(ctrl *gomock.Controller) *MockRelation

+ func (m *MockRelation) AddTableDef(arg0 uint64, arg1 engine.TableDef) error

+ func (m *MockRelation) Close()

+ func (m *MockRelation) CreateIndex(epoch uint64, defs []engine.TableDef) error

+ func (m *MockRelation) DelTableDef(arg0 uint64, arg1 engine.TableDef) error

+ func (m *MockRelation) DropIndex(epoch uint64, name string) error

+ func (m *MockRelation) EXPECT() *MockRelationMockRecorder

+ func (m *MockRelation) GetPriKeyOrHideKey() ([]engine.Attribute, bool)

+ func (m *MockRelation) ID() string

+ func (m *MockRelation) NewReader(arg0 int, _ extend.Extend, _ []byte) []engine.Reader

+ func (m *MockRelation) Nodes() engine.Nodes

+ func (m *MockRelation) Rows() int64

+ func (m *MockRelation) Size(arg0 string) int64

+ func (m *MockRelation) TableDefs() []engine.TableDef

+ func (m *MockRelation) Write(arg0 uint64, arg1 *batch.Batch) error

+ type MockRelationMockRecorder struct

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

+ func (mr *MockRelationMockRecorder) Close() *gomock.Call

+ func (mr *MockRelationMockRecorder) CreateIndex(epoch, defs interface{}) *gomock.Call

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

+ func (mr *MockRelationMockRecorder) DropIndex(epoch, name interface{}) *gomock.Call

+ func (mr *MockRelationMockRecorder) ID() *gomock.Call

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

+ func (mr *MockRelationMockRecorder) Nodes() *gomock.Call

+ func (mr *MockRelationMockRecorder) Rows() *gomock.Call

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

+ func (mr *MockRelationMockRecorder) TableDefs() *gomock.Call

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

+ type MockSparseFilter struct

+ func NewMockSparseFilter(ctrl *gomock.Controller) *MockSparseFilter

+ func (m *MockSparseFilter) Btw(arg0 string, arg1, arg2 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) EXPECT() *MockSparseFilterMockRecorder

+ func (m *MockSparseFilter) Eq(arg0 string, arg1 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) Ge(arg0 string, arg1 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) Gt(arg0 string, arg1 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) Le(arg0 string, arg1 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) Lt(arg0 string, arg1 interface{}) (engine.Reader, error)

+ func (m *MockSparseFilter) Ne(arg0 string, arg1 interface{}) (engine.Reader, error)

+ type MockSparseFilterMockRecorder struct

+ func (mr *MockSparseFilterMockRecorder) Btw(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Eq(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Ge(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Gt(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Le(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Lt(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSparseFilterMockRecorder) Ne(arg0, arg1 interface{}) *gomock.Call

+ type MockStatistics struct

+ func NewMockStatistics(ctrl *gomock.Controller) *MockStatistics

+ func (m *MockStatistics) EXPECT() *MockStatisticsMockRecorder

+ func (m *MockStatistics) Rows() int64

+ func (m *MockStatistics) Size(arg0 string) int64

+ type MockStatisticsMockRecorder struct

+ func (mr *MockStatisticsMockRecorder) Rows() *gomock.Call

+ func (mr *MockStatisticsMockRecorder) Size(arg0 interface{}) *gomock.Call

+ type MockSummarizer struct

+ func NewMockSummarizer(ctrl *gomock.Controller) *MockSummarizer

+ func (m *MockSummarizer) Count(arg0 string, arg1 *roaring64.Bitmap) (uint64, error)

+ func (m *MockSummarizer) EXPECT() *MockSummarizerMockRecorder

+ func (m *MockSummarizer) Max(arg0 string, arg1 *roaring64.Bitmap) (interface{}, error)

+ func (m *MockSummarizer) Min(arg0 string, arg1 *roaring64.Bitmap) (interface{}, error)

+ func (m *MockSummarizer) NullCount(arg0 string, arg1 *roaring64.Bitmap) (uint64, error)

+ func (m *MockSummarizer) Sum(arg0 string, arg1 *roaring64.Bitmap) (int64, uint64, error)

+ type MockSummarizerMockRecorder struct

+ func (mr *MockSummarizerMockRecorder) Count(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSummarizerMockRecorder) Max(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSummarizerMockRecorder) Min(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSummarizerMockRecorder) NullCount(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSummarizerMockRecorder) Sum(arg0, arg1 interface{}) *gomock.Call

+ type MockTableDef struct

+ func NewMockTableDef(ctrl *gomock.Controller) *MockTableDef

+ func (m *MockTableDef) EXPECT() *MockTableDefMockRecorder

+ type MockTableDefMockRecorder struct