mock

package

v0.0.0-...-8d22340 Latest Latest Go to latest Published: May 8, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tiflow

Links

Open Source Insights

Documentation ¶

Overview ¶

Package mock is a generated GoMock package.

Index ¶

Constants
func NewClientConnForSQLite(dsn string) (metaModel.ClientConn, error)
func NewClientConnWithDB(db *sql.DB) metaModel.ClientConn
func NewMockClientConn() metaModel.ClientConn
type MetaMock
- func NewMetaMock() *MetaMock
type MockKVClient
- func NewMockKVClient(ctrl *gomock.Controller) *MockKVClient
type MockKVClientMockRecorder

Constants ¶

View Source

const ThreadeSafeSqliteDriverName = "mock-sqlite"

ThreadeSafeSqliteDriverName is a thread-safe sqlite driver implementation.

Variables ¶

This section is empty.

Functions ¶

func NewClientConnForSQLite ¶

func NewClientConnForSQLite(dsn string) (metaModel.ClientConn, error)

NewClientConnForSQLite news a connection of sqlite Only for test

func NewClientConnWithDB ¶

func NewClientConnWithDB(db *sql.DB) metaModel.ClientConn

NewClientConnWithDB news a connection with an sql.DB inside Only for test

func NewMockClientConn ¶

func NewMockClientConn() metaModel.ClientConn

NewMockClientConn news a connection for mock kvclient Only for test

Types ¶

type MetaMock ¶

type MetaMock struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MetaMock uses a simple in memory kv storage to implement metaModel.Client and metaModel.KV interface. MetaMock is used in unit test. not support Option yet

func NewMetaMock ¶

func NewMetaMock() *MetaMock

NewMetaMock creates a new MetaMock instance

func (*MetaMock) Close ¶

func (m *MetaMock) Close() error

Close implements pkg/meta/metaModel.Close

func (*MetaMock) Delete ¶

func (m *MetaMock) Delete(ctx context.Context, key string, opts ...metaModel.OpOption) (*metaModel.DeleteResponse, metaModel.Error)

Delete implements metaModel.KV.Delete

func (*MetaMock) Do ¶

func (m *MetaMock) Do(ctx context.Context, op metaModel.Op) (metaModel.OpResponse, metaModel.Error)

Do implements Do of KVExt

func (*MetaMock) GenEpoch ¶

func (m *MetaMock) GenEpoch(ctx context.Context) (int64, error)

GenEpoch implements pkg/meta/metaModel.Client.GenEpoch

func (*MetaMock) Get ¶

func (m *MetaMock) Get(ctx context.Context, key string, opts ...metaModel.OpOption) (*metaModel.GetResponse, metaModel.Error)

Get implements metaModel.KV.Get

func (*MetaMock) Put ¶

func (m *MetaMock) Put(ctx context.Context, key, value string) (*metaModel.PutResponse, metaModel.Error)

Put implements metaModel.KV.Put

func (*MetaMock) Txn ¶

func (m *MetaMock) Txn(ctx context.Context) metaModel.Txn

Txn implements metaModel.KV.Txn

type MockKVClient ¶

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

MockKVClient is a mock of KVClient interface.

func NewMockKVClient ¶

func NewMockKVClient(ctrl *gomock.Controller) *MockKVClient

NewMockKVClient creates a new mock instance.

func (*MockKVClient) Close ¶

func (m *MockKVClient) Close() error

Close mocks base method.

func (*MockKVClient) Delete ¶

func (m *MockKVClient) Delete(arg0 context.Context, arg1 string, arg2 ...model.OpOption) (*model.DeleteResponse, model.Error)

Delete mocks base method.

func (*MockKVClient) EXPECT ¶

func (m *MockKVClient) EXPECT() *MockKVClientMockRecorder

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

func (*MockKVClient) GenEpoch ¶

func (m *MockKVClient) GenEpoch(arg0 context.Context) (int64, error)

GenEpoch mocks base method.

func (*MockKVClient) Get ¶

func (m *MockKVClient) Get(arg0 context.Context, arg1 string, arg2 ...model.OpOption) (*model.GetResponse, model.Error)

Get mocks base method.

func (*MockKVClient) Put ¶

func (m *MockKVClient) Put(arg0 context.Context, arg1, arg2 string) (*model.PutResponse, model.Error)

Put mocks base method.

func (*MockKVClient) Txn ¶

func (m *MockKVClient) Txn(arg0 context.Context) model.Txn

Txn mocks base method.

type MockKVClientMockRecorder ¶

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

MockKVClientMockRecorder is the mock recorder for MockKVClient.

func (*MockKVClientMockRecorder) Close ¶

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

Close indicates an expected call of Close.

func (*MockKVClientMockRecorder) Delete ¶

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

Delete indicates an expected call of Delete.

func (*MockKVClientMockRecorder) GenEpoch ¶

func (mr *MockKVClientMockRecorder) GenEpoch(arg0 interface{}) *gomock.Call

GenEpoch indicates an expected call of GenEpoch.

func (*MockKVClientMockRecorder) Get ¶

func (mr *MockKVClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockKVClientMockRecorder) Put ¶

func (mr *MockKVClientMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call

Put indicates an expected call of Put.

func (*MockKVClientMockRecorder) Txn ¶

func (mr *MockKVClientMockRecorder) Txn(arg0 interface{}) *gomock.Call

Txn indicates an expected call of Txn.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL