mock_frontend

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package mock_frontend is a generated GoMock package.

Package mock_frontend is a generated GoMock package.

Package mock_frontend is a generated GoMock package.

Package mock_frontend is a generated GoMock package.

Package mock_frontend is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBackgroundExec added in v0.6.0 

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

MockBackgroundExec is a mock of BackgroundExec interface.

func NewMockBackgroundExec added in v0.6.0 

func NewMockBackgroundExec(ctrl *gomock.Controller) *MockBackgroundExec

NewMockBackgroundExec creates a new mock instance.

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) GetExecResultSet added in v0.6.0 

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

GetExecResultSet mocks base method.

type MockBackgroundExecMockRecorder added in v0.6.0 

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

MockBackgroundExecMockRecorder is the mock recorder for MockBackgroundExec.

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) GetExecResultSet added in v0.6.0 

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

GetExecResultSet indicates an expected call of GetExecResultSet.

type MockColumnInfo added in v0.6.0 

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

MockColumnInfo is a mock of ColumnInfo interface.

func NewMockColumnInfo added in v0.6.0 

func NewMockColumnInfo(ctrl *gomock.Controller) *MockColumnInfo

NewMockColumnInfo creates a new mock instance.

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.

type MockColumnInfoMockRecorder added in v0.6.0 

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

MockColumnInfoMockRecorder is the mock recorder for MockColumnInfo.

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.

type MockComputationRunner added in v0.5.0 

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

MockComputationRunner is a mock of ComputationRunner interface.

func NewMockComputationRunner added in v0.5.0 

func NewMockComputationRunner(ctrl *gomock.Controller) *MockComputationRunner

NewMockComputationRunner creates a new mock instance.

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) error

Run mocks base method.

type MockComputationRunnerMockRecorder added in v0.5.0 

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

MockComputationRunnerMockRecorder is the mock recorder for MockComputationRunner.

func (*MockComputationRunnerMockRecorder) Run added in v0.5.0 

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

Run indicates an expected call of Run.

type MockComputationWrapper 

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

MockComputationWrapper is a mock of ComputationWrapper interface.

func NewMockComputationWrapper 

func NewMockComputationWrapper(ctrl *gomock.Controller) *MockComputationWrapper

NewMockComputationWrapper creates a new mock instance.

func (*MockComputationWrapper) Compile 

func (m *MockComputationWrapper) Compile(requestCtx context.Context, u interface{}, fill func(interface{}, *batch.Batch) 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) GetAffectedRows 

func (m *MockComputationWrapper) GetAffectedRows() uint64

GetAffectedRows mocks base method.

func (*MockComputationWrapper) GetAst 

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

GetAst mocks base method.

func (*MockComputationWrapper) GetColumns 

func (m *MockComputationWrapper) GetColumns() ([]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) GetUUID added in v0.6.0 

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

GetUUID mocks base method.

func (*MockComputationWrapper) RecordExecPlan added in v0.6.0 

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

RecordExecPlan mocks base method.

func (*MockComputationWrapper) Run 

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

Run mocks base method.

func (*MockComputationWrapper) SetDatabaseName 

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

SetDatabaseName mocks base method.

type MockComputationWrapperMockRecorder 

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

MockComputationWrapperMockRecorder is the mock recorder for MockComputationWrapper.

func (*MockComputationWrapperMockRecorder) Compile 

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

Compile indicates an expected call of Compile.

func (*MockComputationWrapperMockRecorder) GetAffectedRows 

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

GetAffectedRows indicates an expected call of GetAffectedRows.

func (*MockComputationWrapperMockRecorder) GetAst 

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

GetAst indicates an expected call of GetAst.

func (*MockComputationWrapperMockRecorder) GetColumns 

func (mr *MockComputationWrapperMockRecorder) GetColumns() *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) GetUUID added in v0.6.0 

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

GetUUID indicates an expected call of GetUUID.

func (*MockComputationWrapperMockRecorder) RecordExecPlan added in v0.6.0 

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

RecordExecPlan indicates an expected call of RecordExecPlan.

func (*MockComputationWrapperMockRecorder) Run 

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

Run indicates an expected call of Run.

func (*MockComputationWrapperMockRecorder) SetDatabaseName 

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

SetDatabaseName indicates an expected call of SetDatabaseName.

type MockConstraint added in v0.7.0 

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

MockConstraint is a mock of Constraint interface.

func NewMockConstraint added in v0.7.0 

func NewMockConstraint(ctrl *gomock.Controller) *MockConstraint

NewMockConstraint creates a new mock instance.

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.

type MockConstraintMockRecorder added in v0.7.0 

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

MockConstraintMockRecorder is the mock recorder for MockConstraint.

type MockDatabase 

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

MockDatabase is a mock of Database interface.

func NewMockDatabase 

func NewMockDatabase(ctrl *gomock.Controller) *MockDatabase

NewMockDatabase creates a new mock instance.

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) GetDatabaseId added in v0.6.0 

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

GetDatabaseId mocks base method.

func (*MockDatabase) Relation 

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

Relation mocks base method.

func (*MockDatabase) Relations 

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

Relations mocks base method.

func (*MockDatabase) Truncate added in v0.6.0 

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

Truncate mocks base method.

type MockDatabaseMockRecorder 

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

MockDatabaseMockRecorder is the mock recorder for MockDatabase.

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) GetDatabaseId added in v0.6.0 

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

GetDatabaseId indicates an expected call of GetDatabaseId.

func (*MockDatabaseMockRecorder) Relation 

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

Relation indicates an expected call of Relation.

func (*MockDatabaseMockRecorder) Relations 

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

Relations indicates an expected call of Relations.

func (*MockDatabaseMockRecorder) Truncate added in v0.6.0 

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

Truncate indicates an expected call of Truncate.

type MockDebugableTxnOperator added in v0.6.0 

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

MockDebugableTxnOperator is a mock of DebugableTxnOperator interface.

func NewMockDebugableTxnOperator added in v0.6.0 

func NewMockDebugableTxnOperator(ctrl *gomock.Controller) *MockDebugableTxnOperator

NewMockDebugableTxnOperator creates a new mock instance.

func (*MockDebugableTxnOperator) ApplySnapshot added in v0.6.0 

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

ApplySnapshot mocks base method.

func (*MockDebugableTxnOperator) Commit added in v0.6.0 

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

Commit mocks base method.

func (*MockDebugableTxnOperator) Debug added in v0.6.0 

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

Debug mocks base method.

func (*MockDebugableTxnOperator) EXPECT added in v0.6.0 

func (m *MockDebugableTxnOperator) EXPECT() *MockDebugableTxnOperatorMockRecorder

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

func (*MockDebugableTxnOperator) Read added in v0.6.0 

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

Read mocks base method.

func (*MockDebugableTxnOperator) Rollback added in v0.6.0 

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

Rollback mocks base method.

func (*MockDebugableTxnOperator) Snapshot added in v0.6.0 

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

Snapshot mocks base method.

func (*MockDebugableTxnOperator) Txn added in v0.6.0 

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

Txn mocks base method.

func (*MockDebugableTxnOperator) Write added in v0.6.0 

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

Write mocks base method.

func (*MockDebugableTxnOperator) WriteAndCommit added in v0.6.0 

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

WriteAndCommit mocks base method.

type MockDebugableTxnOperatorMockRecorder added in v0.6.0 

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

MockDebugableTxnOperatorMockRecorder is the mock recorder for MockDebugableTxnOperator.

func (*MockDebugableTxnOperatorMockRecorder) ApplySnapshot added in v0.6.0 

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

ApplySnapshot indicates an expected call of ApplySnapshot.

func (*MockDebugableTxnOperatorMockRecorder) Commit added in v0.6.0 

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

Commit indicates an expected call of Commit.

func (*MockDebugableTxnOperatorMockRecorder) Debug added in v0.6.0 

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

Debug indicates an expected call of Debug.

func (*MockDebugableTxnOperatorMockRecorder) Read added in v0.6.0 

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

Read indicates an expected call of Read.

func (*MockDebugableTxnOperatorMockRecorder) Rollback added in v0.6.0 

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

Rollback indicates an expected call of Rollback.

func (*MockDebugableTxnOperatorMockRecorder) Snapshot added in v0.6.0 

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

Snapshot indicates an expected call of Snapshot.

func (*MockDebugableTxnOperatorMockRecorder) Txn added in v0.6.0 

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

Txn indicates an expected call of Txn.

func (*MockDebugableTxnOperatorMockRecorder) Write added in v0.6.0 

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

Write indicates an expected call of Write.

func (*MockDebugableTxnOperatorMockRecorder) WriteAndCommit added in v0.6.0 

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

WriteAndCommit indicates an expected call of WriteAndCommit.

type MockEngine 

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

MockEngine is a mock of Engine interface.

func NewMockEngine 

func NewMockEngine(ctrl *gomock.Controller) *MockEngine

NewMockEngine creates a new mock instance.

func (*MockEngine) Commit added in v0.6.0 

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

Commit 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) 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) Hints added in v0.6.0 

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

Hints 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) NewBlockReader added in v0.6.0 

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

NewBlockReader mocks base method.

func (*MockEngine) Nodes added in v0.6.0 

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

Nodes mocks base method.

func (*MockEngine) Rollback added in v0.6.0 

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

Rollback mocks base method.

type MockEngineMockRecorder 

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

MockEngineMockRecorder is the mock recorder for MockEngine.

func (*MockEngineMockRecorder) Commit added in v0.6.0 

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

Commit indicates an expected call of Commit.

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) 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) Hints added in v0.6.0 

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

Hints indicates an expected call of Hints.

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) NewBlockReader added in v0.6.0 

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

NewBlockReader indicates an expected call of NewBlockReader.

func (*MockEngineMockRecorder) Nodes added in v0.6.0 

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

Nodes indicates an expected call of Nodes.

func (*MockEngineMockRecorder) Rollback added in v0.6.0 

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

Rollback indicates an expected call of Rollback.

type MockExecResult added in v0.6.0 

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

MockExecResult is a mock of ExecResult interface.

func NewMockExecResult added in v0.6.0 

func NewMockExecResult(ctrl *gomock.Controller) *MockExecResult

NewMockExecResult creates a new mock instance.

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) 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.

type MockExecResultMockRecorder added in v0.6.0 

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

MockExecResultMockRecorder is the mock recorder for MockExecResult.

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.

type MockIOPackage 

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

MockIOPackage is a mock of IOPackage interface.

func NewMockIOPackage 

func NewMockIOPackage(ctrl *gomock.Controller) *MockIOPackage

NewMockIOPackage creates a new mock instance.

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) AppendUint8 

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

AppendUint8 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) 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) ReadUint8 

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

ReadUint8 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 (*MockIOPackage) WriteUint8 

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

WriteUint8 mocks base method.

type MockIOPackageMockRecorder 

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

MockIOPackageMockRecorder is the mock recorder for MockIOPackage.

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) AppendUint8 

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

AppendUint8 indicates an expected call of AppendUint8.

func (*MockIOPackageMockRecorder) IsLittleEndian 

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

IsLittleEndian indicates an expected call of IsLittleEndian.

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) ReadUint8 

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

ReadUint8 indicates an expected call of ReadUint8.

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 (*MockIOPackageMockRecorder) WriteUint8 

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

WriteUint8 indicates an expected call of WriteUint8.

type MockIOSession 

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

MockIOSession is a mock of IOSession interface.

func NewMockIOSession 

func NewMockIOSession(ctrl *gomock.Controller) *MockIOSession

NewMockIOSession creates a new mock instance.

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.

type MockIOSessionMockRecorder 

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

MockIOSessionMockRecorder is the mock recorder for MockIOSession.

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.

type MockReader 

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

MockReader is a mock of Reader interface.

func NewMockReader 

func NewMockReader(ctrl *gomock.Controller) *MockReader

NewMockReader creates a new mock instance.

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) Read 

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

Read mocks base method.

type MockReaderMockRecorder 

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

MockReaderMockRecorder is the mock recorder for MockReader.

func (*MockReaderMockRecorder) Close added in v0.6.0 

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

Close indicates an expected call of Close.

func (*MockReaderMockRecorder) Read 

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

Read indicates an expected call of Read.

type MockRelation 

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

MockRelation is a mock of Relation interface.

func NewMockRelation 

func NewMockRelation(ctrl *gomock.Controller) *MockRelation

NewMockRelation creates a new mock instance.

func (*MockRelation) AddTableDef 

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

AddTableDef 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) GetHideKeys added in v0.6.0 

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

GetHideKeys 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) GetTableID added in v0.6.0 

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

GetTableID 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) NewReader 

func (m *MockRelation) NewReader(arg0 context.Context, arg1 int, arg2 *plan.Expr, arg3 [][]byte) ([]engine.Reader, error)

NewReader mocks base method.

func (*MockRelation) Ranges added in v0.6.0 

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

Ranges mocks base method.

func (*MockRelation) Rows 

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

Rows mocks base method.

func (*MockRelation) Size 

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

Size mocks base method.

func (*MockRelation) Stats added in v0.7.0 

func (m *MockRelation) Stats(ctx context.Context, expr *plan.Expr) (*plan.Stats, 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) Update added in v0.5.0 

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

Update 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.

type MockRelationMockRecorder 

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

MockRelationMockRecorder is the mock recorder for MockRelation.

func (*MockRelationMockRecorder) AddTableDef 

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

AddTableDef indicates an expected call of AddTableDef.

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) GetHideKeys added in v0.6.0 

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

GetHideKeys indicates an expected call of GetHideKeys.

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) GetTableID added in v0.6.0 

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

GetTableID indicates an expected call of GetTableID.

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) NewReader 

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

NewReader indicates an expected call of NewReader.

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) 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) Stats added in v0.7.0 

func (mr *MockRelationMockRecorder) Stats(ctx, expr 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) Update added in v0.5.0 

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

Update indicates an expected call of Update.

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.

type MockStatistics 

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

MockStatistics is a mock of Statistics interface.

func NewMockStatistics 

func NewMockStatistics(ctrl *gomock.Controller) *MockStatistics

NewMockStatistics creates a new mock instance.

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) (int64, error)

Rows mocks base method.

func (*MockStatistics) Size 

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

Size mocks base method.

func (*MockStatistics) Stats added in v0.7.0 

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

Stats mocks base method.

type MockStatisticsMockRecorder 

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

MockStatisticsMockRecorder is the mock recorder for MockStatistics.

func (*MockStatisticsMockRecorder) Rows 

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

Rows indicates an expected call of Rows.

func (*MockStatisticsMockRecorder) Size 

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

Size indicates an expected call of Size.

func (*MockStatisticsMockRecorder) Stats added in v0.7.0 

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

Stats indicates an expected call of Stats.

type MockTableDef 

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

MockTableDef is a mock of TableDef interface.

func NewMockTableDef 

func NewMockTableDef(ctrl *gomock.Controller) *MockTableDef

NewMockTableDef creates a new mock instance.

func (*MockTableDef) EXPECT 

func (m *MockTableDef) EXPECT() *MockTableDefMockRecorder

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

type MockTableDefMockRecorder 

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

MockTableDefMockRecorder is the mock recorder for MockTableDef.

type MockTableInfo added in v0.6.0 

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

MockTableInfo is a mock of TableInfo interface.

func NewMockTableInfo added in v0.6.0 

func NewMockTableInfo(ctrl *gomock.Controller) *MockTableInfo

NewMockTableInfo creates a new mock instance.

func (*MockTableInfo) EXPECT added in v0.6.0 

func (m *MockTableInfo) EXPECT() *MockTableInfoMockRecorder

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

func (*MockTableInfo) GetColumns added in v0.6.0 

func (m *MockTableInfo) GetColumns()

GetColumns mocks base method.

type MockTableInfoMockRecorder added in v0.6.0 

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

MockTableInfoMockRecorder is the mock recorder for MockTableInfo.

func (*MockTableInfoMockRecorder) GetColumns added in v0.6.0 

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

GetColumns indicates an expected call of GetColumns.

type MockTxnClient added in v0.6.0 

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

MockTxnClient is a mock of TxnClient interface.

func NewMockTxnClient added in v0.6.0 

func NewMockTxnClient(ctrl *gomock.Controller) *MockTxnClient

NewMockTxnClient creates a new mock instance.

func (*MockTxnClient) Close added in v0.6.0 

func (m *MockTxnClient) Close() error

Close mocks base method.

func (*MockTxnClient) EXPECT added in v0.6.0 

func (m *MockTxnClient) EXPECT() *MockTxnClientMockRecorder

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

func (*MockTxnClient) New added in v0.6.0 

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

New mocks base method.

func (*MockTxnClient) NewWithSnapshot added in v0.6.0 

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

NewWithSnapshot mocks base method.

type MockTxnClientMockRecorder added in v0.6.0 

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

MockTxnClientMockRecorder is the mock recorder for MockTxnClient.

func (*MockTxnClientMockRecorder) Close added in v0.6.0 

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

Close indicates an expected call of Close.

func (*MockTxnClientMockRecorder) New added in v0.6.0 

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

New indicates an expected call of New.

func (*MockTxnClientMockRecorder) NewWithSnapshot added in v0.6.0 

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

NewWithSnapshot indicates an expected call of NewWithSnapshot.

type MockTxnIDGenerator added in v0.6.0 

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

MockTxnIDGenerator is a mock of TxnIDGenerator interface.

func NewMockTxnIDGenerator added in v0.6.0 

func NewMockTxnIDGenerator(ctrl *gomock.Controller) *MockTxnIDGenerator

NewMockTxnIDGenerator creates a new mock instance.

func (*MockTxnIDGenerator) EXPECT added in v0.6.0 

func (m *MockTxnIDGenerator) EXPECT() *MockTxnIDGeneratorMockRecorder

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

func (*MockTxnIDGenerator) Generate added in v0.6.0 

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

Generate mocks base method.

type MockTxnIDGeneratorMockRecorder added in v0.6.0 

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

MockTxnIDGeneratorMockRecorder is the mock recorder for MockTxnIDGenerator.

func (*MockTxnIDGeneratorMockRecorder) Generate added in v0.6.0 

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

Generate indicates an expected call of Generate.

type MockTxnOperator added in v0.6.0 

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

MockTxnOperator is a mock of TxnOperator interface.

func NewMockTxnOperator added in v0.6.0 

func NewMockTxnOperator(ctrl *gomock.Controller) *MockTxnOperator

NewMockTxnOperator creates a new mock instance.

func (*MockTxnOperator) ApplySnapshot added in v0.6.0 

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

ApplySnapshot mocks base method.

func (*MockTxnOperator) Commit added in v0.6.0 

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

Commit mocks base method.

func (*MockTxnOperator) EXPECT added in v0.6.0 

func (m *MockTxnOperator) EXPECT() *MockTxnOperatorMockRecorder

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

func (*MockTxnOperator) Read added in v0.6.0 

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

Read mocks base method.

func (*MockTxnOperator) Rollback added in v0.6.0 

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

Rollback mocks base method.

func (*MockTxnOperator) Snapshot added in v0.6.0 

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

Snapshot mocks base method.

func (*MockTxnOperator) Txn added in v0.6.0 

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

Txn mocks base method.

func (*MockTxnOperator) Write added in v0.6.0 

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

Write mocks base method.

func (*MockTxnOperator) WriteAndCommit added in v0.6.0 

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

WriteAndCommit mocks base method.

type MockTxnOperatorMockRecorder added in v0.6.0 

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

MockTxnOperatorMockRecorder is the mock recorder for MockTxnOperator.

func (*MockTxnOperatorMockRecorder) ApplySnapshot added in v0.6.0 

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

ApplySnapshot indicates an expected call of ApplySnapshot.

func (*MockTxnOperatorMockRecorder) Commit added in v0.6.0 

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

Commit indicates an expected call of Commit.

func (*MockTxnOperatorMockRecorder) Read added in v0.6.0 

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

Read indicates an expected call of Read.

func (*MockTxnOperatorMockRecorder) Rollback added in v0.6.0 

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

Rollback indicates an expected call of Rollback.

func (*MockTxnOperatorMockRecorder) Snapshot added in v0.6.0 

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

Snapshot indicates an expected call of Snapshot.

func (*MockTxnOperatorMockRecorder) Txn added in v0.6.0 

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

Txn indicates an expected call of Txn.

func (*MockTxnOperatorMockRecorder) Write added in v0.6.0 

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

Write indicates an expected call of Write.

func (*MockTxnOperatorMockRecorder) WriteAndCommit added in v0.6.0 

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

WriteAndCommit indicates an expected call of WriteAndCommit.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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