mock_dal

package
v0.41.7 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Package mock_dal is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRecordsReader 

func NewRecordsReader(delay time.Duration, records ...dal.Record) dal.RecordsReader

NewRecordsReader creates a reader that returns given records

Types

type MockDB 

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

MockDB is a mock of DB interface.

func NewMockDB 

func NewMockDB(ctrl *gomock.Controller) *MockDB

NewMockDB creates a new mock instance.

func (*MockDB) Adapter 

func (m *MockDB) Adapter() dal.Adapter

Adapter mocks base method.

func (*MockDB) EXPECT 

func (m *MockDB) EXPECT() *MockDBMockRecorder

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

func (*MockDB) ExecuteQueryToRecordsReader added in v0.39.1 

func (m *MockDB) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

GetRecordsReader mocks base method.

func (*MockDB) ExecuteQueryToRecordsetReader added in v0.39.1 

func (m *MockDB) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, options ...recordset.Option) (dal.RecordsetReader, error)

GetRecordsetReader mocks base method.

func (*MockDB) Exists 

func (m *MockDB) Exists(ctx context.Context, key *dal.Key) (bool, error)

Exists mocks base method.

func (*MockDB) Get 

func (m *MockDB) Get(ctx context.Context, record dal.Record) error

Get mocks base method.

func (*MockDB) GetMulti 

func (m *MockDB) GetMulti(ctx context.Context, records []dal.Record) error

GetMulti mocks base method.

func (*MockDB) ID 

func (m *MockDB) ID() string

ID mocks base method.

func (*MockDB) RunReadonlyTransaction 

func (m *MockDB) RunReadonlyTransaction(ctx context.Context, f func(context.Context, dal.ReadTransaction) error, options ...dal.TransactionOption) error

RunReadonlyTransaction mocks base method.

func (*MockDB) RunReadwriteTransaction 

func (m *MockDB) RunReadwriteTransaction(ctx context.Context, f func(context.Context, dal.ReadwriteTransaction) error, options ...dal.TransactionOption) error

RunReadwriteTransaction mocks base method.

func (*MockDB) Schema added in v0.37.0 

func (m *MockDB) Schema() dal.Schema

Schema mocks base method.

type MockDBMockRecorder 

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

MockDBMockRecorder is the mock recorder for MockDB.

func (*MockDBMockRecorder) Adapter 

func (mr *MockDBMockRecorder) Adapter() *gomock.Call

Adapter indicates an expected call of Adapter.

func (*MockDBMockRecorder) Exists 

func (mr *MockDBMockRecorder) Exists(ctx, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockDBMockRecorder) Get 

func (mr *MockDBMockRecorder) Get(ctx, record any) *gomock.Call

Get indicates an expected call of Get.

func (*MockDBMockRecorder) GetMulti 

func (mr *MockDBMockRecorder) GetMulti(ctx, records any) *gomock.Call

GetMulti indicates an expected call of GetMulti.

func (*MockDBMockRecorder) GetRecordsReader added in v0.37.0 

func (mr *MockDBMockRecorder) GetRecordsReader(ctx, query any) *gomock.Call

GetRecordsReader indicates an expected call of GetRecordsReader.

func (*MockDBMockRecorder) GetRecordsetReader added in v0.37.0 

func (mr *MockDBMockRecorder) GetRecordsetReader(ctx, query any, options ...any) *gomock.Call

GetRecordsetReader indicates an expected call of GetRecordsetReader.

func (*MockDBMockRecorder) ID 

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

ID indicates an expected call of ID.

func (*MockDBMockRecorder) RunReadonlyTransaction 

func (mr *MockDBMockRecorder) RunReadonlyTransaction(ctx, f any, options ...any) *gomock.Call

RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.

func (*MockDBMockRecorder) RunReadwriteTransaction 

func (mr *MockDBMockRecorder) RunReadwriteTransaction(ctx, f any, options ...any) *gomock.Call

RunReadwriteTransaction indicates an expected call of RunReadwriteTransaction.

func (*MockDBMockRecorder) Schema added in v0.37.0 

func (mr *MockDBMockRecorder) Schema() *gomock.Call

Schema indicates an expected call of Schema.

type MockReadSession 

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

MockReadSession is a mock of ReadSession interface.

func NewMockReadSession 

func NewMockReadSession(ctrl *gomock.Controller) *MockReadSession

NewMockReadSession creates a new mock instance.

func (*MockReadSession) EXPECT 

func (m *MockReadSession) EXPECT() *MockReadSessionMockRecorder

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

func (*MockReadSession) ExecuteQueryToRecordsReader added in v0.39.1 

func (m *MockReadSession) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

GetRecordsReader mocks base method.

func (*MockReadSession) ExecuteQueryToRecordsetReader added in v0.39.1 

func (m *MockReadSession) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, options ...recordset.Option) (dal.RecordsetReader, error)

GetRecordsetReader mocks base method.

func (*MockReadSession) Exists 

func (m *MockReadSession) Exists(ctx context.Context, key *dal.Key) (bool, error)

Exists mocks base method.

func (*MockReadSession) Get 

func (m *MockReadSession) Get(ctx context.Context, record dal.Record) error

Get mocks base method.

func (*MockReadSession) GetMulti 

func (m *MockReadSession) GetMulti(ctx context.Context, records []dal.Record) error

GetMulti mocks base method.

type MockReadSessionMockRecorder 

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

MockReadSessionMockRecorder is the mock recorder for MockReadSession.

func (*MockReadSessionMockRecorder) Exists 

func (mr *MockReadSessionMockRecorder) Exists(ctx, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockReadSessionMockRecorder) Get 

func (mr *MockReadSessionMockRecorder) Get(ctx, record any) *gomock.Call

Get indicates an expected call of Get.

func (*MockReadSessionMockRecorder) GetMulti 

func (mr *MockReadSessionMockRecorder) GetMulti(ctx, records any) *gomock.Call

GetMulti indicates an expected call of GetMulti.

func (*MockReadSessionMockRecorder) GetRecordsReader added in v0.37.0 

func (mr *MockReadSessionMockRecorder) GetRecordsReader(ctx, query any) *gomock.Call

GetRecordsReader indicates an expected call of GetRecordsReader.

func (*MockReadSessionMockRecorder) GetRecordsetReader added in v0.37.0 

func (mr *MockReadSessionMockRecorder) GetRecordsetReader(ctx, query any, options ...any) *gomock.Call

GetRecordsetReader indicates an expected call of GetRecordsetReader.

type MockReadTransaction 

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

MockReadTransaction is a mock of ReadTransaction interface.

func NewMockReadTransaction 

func NewMockReadTransaction(ctrl *gomock.Controller) *MockReadTransaction

NewMockReadTransaction creates a new mock instance.

func (*MockReadTransaction) EXPECT 

func (m *MockReadTransaction) EXPECT() *MockReadTransactionMockRecorder

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

func (*MockReadTransaction) ExecuteQueryToRecordsReader added in v0.39.1 

func (m *MockReadTransaction) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

GetRecordsReader mocks base method.

func (*MockReadTransaction) ExecuteQueryToRecordsetReader added in v0.39.1 

func (m *MockReadTransaction) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, options ...recordset.Option) (dal.RecordsetReader, error)

GetRecordsetReader mocks base method.

func (*MockReadTransaction) Exists 

func (m *MockReadTransaction) Exists(ctx context.Context, key *dal.Key) (bool, error)

Exists mocks base method.

func (*MockReadTransaction) Get 

func (m *MockReadTransaction) Get(ctx context.Context, record dal.Record) error

Get mocks base method.

func (*MockReadTransaction) GetMulti 

func (m *MockReadTransaction) GetMulti(ctx context.Context, records []dal.Record) error

GetMulti mocks base method.

func (*MockReadTransaction) Options 

func (m *MockReadTransaction) Options() dal.TransactionOptions

Options mocks base method.

type MockReadTransactionCoordinator 

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

MockReadTransactionCoordinator is a mock of ReadTransactionCoordinator interface.

func NewMockReadTransactionCoordinator 

func NewMockReadTransactionCoordinator(ctrl *gomock.Controller) *MockReadTransactionCoordinator

NewMockReadTransactionCoordinator creates a new mock instance.

func (*MockReadTransactionCoordinator) EXPECT 

func (m *MockReadTransactionCoordinator) EXPECT() *MockReadTransactionCoordinatorMockRecorder

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

func (*MockReadTransactionCoordinator) RunReadonlyTransaction 

func (m *MockReadTransactionCoordinator) RunReadonlyTransaction(ctx context.Context, f func(context.Context, dal.ReadTransaction) error, options ...dal.TransactionOption) error

RunReadonlyTransaction mocks base method.

type MockReadTransactionCoordinatorMockRecorder 

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

MockReadTransactionCoordinatorMockRecorder is the mock recorder for MockReadTransactionCoordinator.

func (*MockReadTransactionCoordinatorMockRecorder) RunReadonlyTransaction 

func (mr *MockReadTransactionCoordinatorMockRecorder) RunReadonlyTransaction(ctx, f any, options ...any) *gomock.Call

RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.

type MockReadTransactionMockRecorder 

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

MockReadTransactionMockRecorder is the mock recorder for MockReadTransaction.

func (*MockReadTransactionMockRecorder) Exists 

func (mr *MockReadTransactionMockRecorder) Exists(ctx, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockReadTransactionMockRecorder) Get 

func (mr *MockReadTransactionMockRecorder) Get(ctx, record any) *gomock.Call

Get indicates an expected call of Get.

func (*MockReadTransactionMockRecorder) GetMulti 

func (mr *MockReadTransactionMockRecorder) GetMulti(ctx, records any) *gomock.Call

GetMulti indicates an expected call of GetMulti.

func (*MockReadTransactionMockRecorder) GetRecordsReader added in v0.37.0 

func (mr *MockReadTransactionMockRecorder) GetRecordsReader(ctx, query any) *gomock.Call

GetRecordsReader indicates an expected call of GetRecordsReader.

func (*MockReadTransactionMockRecorder) GetRecordsetReader added in v0.37.0 

func (mr *MockReadTransactionMockRecorder) GetRecordsetReader(ctx, query any, options ...any) *gomock.Call

GetRecordsetReader indicates an expected call of GetRecordsetReader.

func (*MockReadTransactionMockRecorder) Options 

func (mr *MockReadTransactionMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options.

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 

func (m *MockReader) Close() error

Close mocks base method.

func (*MockReader) Cursor 

func (m *MockReader) Cursor() (string, error)

Cursor mocks base method.

func (*MockReader) EXPECT 

func (m *MockReader) EXPECT() *MockReaderMockRecorder

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

type MockReaderMockRecorder 

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

MockReaderMockRecorder is the mock recorder for MockReader.

func (*MockReaderMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockReaderMockRecorder) Cursor 

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

Cursor indicates an expected call of Cursor.

type MockReadwriteSession 

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

MockReadwriteSession is a mock of ReadwriteSession interface.

func NewMockReadwriteSession 

func NewMockReadwriteSession(ctrl *gomock.Controller) *MockReadwriteSession

NewMockReadwriteSession creates a new mock instance.

func (*MockReadwriteSession) Delete 

func (m *MockReadwriteSession) Delete(ctx context.Context, key *dal.Key) error

Delete mocks base method.

func (*MockReadwriteSession) DeleteMulti 

func (m *MockReadwriteSession) DeleteMulti(ctx context.Context, keys []*dal.Key) error

DeleteMulti mocks base method.

func (*MockReadwriteSession) EXPECT 

func (m *MockReadwriteSession) EXPECT() *MockReadwriteSessionMockRecorder

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

func (*MockReadwriteSession) ExecuteQueryToRecordsReader added in v0.39.1 

func (m *MockReadwriteSession) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

GetRecordsReader mocks base method.

func (*MockReadwriteSession) ExecuteQueryToRecordsetReader added in v0.39.1 

func (m *MockReadwriteSession) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, options ...recordset.Option) (dal.RecordsetReader, error)

GetRecordsetReader mocks base method.

func (*MockReadwriteSession) Exists 

func (m *MockReadwriteSession) Exists(ctx context.Context, key *dal.Key) (bool, error)

Exists mocks base method.

func (*MockReadwriteSession) Get 

func (m *MockReadwriteSession) Get(ctx context.Context, record dal.Record) error

Get mocks base method.

func (*MockReadwriteSession) GetMulti 

func (m *MockReadwriteSession) GetMulti(ctx context.Context, records []dal.Record) error

GetMulti mocks base method.

func (*MockReadwriteSession) Insert 

func (m *MockReadwriteSession) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error

Insert mocks base method.

func (*MockReadwriteSession) InsertMulti 

func (m *MockReadwriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error

InsertMulti mocks base method.

func (*MockReadwriteSession) Set 

func (m *MockReadwriteSession) Set(ctx context.Context, record dal.Record) error

Set mocks base method.

func (*MockReadwriteSession) SetMulti 

func (m *MockReadwriteSession) SetMulti(ctx context.Context, records []dal.Record) error

SetMulti mocks base method.

func (*MockReadwriteSession) Update 

func (m *MockReadwriteSession) Update(ctx context.Context, key *dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

Update mocks base method.

func (*MockReadwriteSession) UpdateMulti 

func (m *MockReadwriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

UpdateMulti mocks base method.

func (*MockReadwriteSession) UpdateRecord 

func (m *MockReadwriteSession) UpdateRecord(ctx context.Context, record dal.Record, updates []update.Update, preconditions ...dal.Precondition) error

UpdateRecord mocks base method.

type MockReadwriteSessionMockRecorder 

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

MockReadwriteSessionMockRecorder is the mock recorder for MockReadwriteSession.

func (*MockReadwriteSessionMockRecorder) Delete 

func (mr *MockReadwriteSessionMockRecorder) Delete(ctx, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockReadwriteSessionMockRecorder) DeleteMulti 

func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call

DeleteMulti indicates an expected call of DeleteMulti.

func (*MockReadwriteSessionMockRecorder) Exists 

func (mr *MockReadwriteSessionMockRecorder) Exists(ctx, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockReadwriteSessionMockRecorder) Get 

func (mr *MockReadwriteSessionMockRecorder) Get(ctx, record any) *gomock.Call

Get indicates an expected call of Get.

func (*MockReadwriteSessionMockRecorder) GetMulti 

func (mr *MockReadwriteSessionMockRecorder) GetMulti(ctx, records any) *gomock.Call

GetMulti indicates an expected call of GetMulti.

func (*MockReadwriteSessionMockRecorder) GetRecordsReader added in v0.37.0 

func (mr *MockReadwriteSessionMockRecorder) GetRecordsReader(ctx, query any) *gomock.Call

GetRecordsReader indicates an expected call of GetRecordsReader.

func (*MockReadwriteSessionMockRecorder) GetRecordsetReader added in v0.37.0 

func (mr *MockReadwriteSessionMockRecorder) GetRecordsetReader(ctx, query any, options ...any) *gomock.Call

GetRecordsetReader indicates an expected call of GetRecordsetReader.

func (*MockReadwriteSessionMockRecorder) Insert 

func (mr *MockReadwriteSessionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call

Insert indicates an expected call of Insert.

func (*MockReadwriteSessionMockRecorder) InsertMulti 

func (mr *MockReadwriteSessionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call

InsertMulti indicates an expected call of InsertMulti.

func (*MockReadwriteSessionMockRecorder) Set 

func (mr *MockReadwriteSessionMockRecorder) Set(ctx, record any) *gomock.Call

Set indicates an expected call of Set.

func (*MockReadwriteSessionMockRecorder) SetMulti 

func (mr *MockReadwriteSessionMockRecorder) SetMulti(ctx, records any) *gomock.Call

SetMulti indicates an expected call of SetMulti.

func (*MockReadwriteSessionMockRecorder) Update 

func (mr *MockReadwriteSessionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call

Update indicates an expected call of Update.

func (*MockReadwriteSessionMockRecorder) UpdateMulti 

func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call

UpdateMulti indicates an expected call of UpdateMulti.

func (*MockReadwriteSessionMockRecorder) UpdateRecord 

func (mr *MockReadwriteSessionMockRecorder) UpdateRecord(ctx, record, updates any, preconditions ...any) *gomock.Call

UpdateRecord indicates an expected call of UpdateRecord.

type MockReadwriteTransaction 

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

MockReadwriteTransaction is a mock of ReadwriteTransaction interface.

func NewMockReadwriteTransaction 

func NewMockReadwriteTransaction(ctrl *gomock.Controller) *MockReadwriteTransaction

NewMockReadwriteTransaction creates a new mock instance.

func (*MockReadwriteTransaction) Delete 

func (m *MockReadwriteTransaction) Delete(ctx context.Context, key *dal.Key) error

Delete mocks base method.

func (*MockReadwriteTransaction) DeleteMulti 

func (m *MockReadwriteTransaction) DeleteMulti(ctx context.Context, keys []*dal.Key) error

DeleteMulti mocks base method.

func (*MockReadwriteTransaction) EXPECT 

func (m *MockReadwriteTransaction) EXPECT() *MockReadwriteTransactionMockRecorder

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

func (*MockReadwriteTransaction) ExecuteQueryToRecordsReader added in v0.39.1 

func (m *MockReadwriteTransaction) ExecuteQueryToRecordsReader(ctx context.Context, query dal.Query) (dal.RecordsReader, error)

GetRecordsReader mocks base method.

func (*MockReadwriteTransaction) ExecuteQueryToRecordsetReader added in v0.39.1 

func (m *MockReadwriteTransaction) ExecuteQueryToRecordsetReader(ctx context.Context, query dal.Query, options ...recordset.Option) (dal.RecordsetReader, error)

GetRecordsetReader mocks base method.

func (*MockReadwriteTransaction) Exists 

func (m *MockReadwriteTransaction) Exists(ctx context.Context, key *dal.Key) (bool, error)

Exists mocks base method.

func (*MockReadwriteTransaction) Get 

func (m *MockReadwriteTransaction) Get(ctx context.Context, record dal.Record) error

Get mocks base method.

func (*MockReadwriteTransaction) GetMulti 

func (m *MockReadwriteTransaction) GetMulti(ctx context.Context, records []dal.Record) error

GetMulti mocks base method.

func (*MockReadwriteTransaction) ID 

func (m *MockReadwriteTransaction) ID() string

ID mocks base method.

func (*MockReadwriteTransaction) Insert 

func (m *MockReadwriteTransaction) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error

Insert mocks base method.

func (*MockReadwriteTransaction) InsertMulti 

func (m *MockReadwriteTransaction) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error

InsertMulti mocks base method.

func (*MockReadwriteTransaction) Options 

func (m *MockReadwriteTransaction) Options() dal.TransactionOptions

Options mocks base method.

func (*MockReadwriteTransaction) Set 

func (m *MockReadwriteTransaction) Set(ctx context.Context, record dal.Record) error

Set mocks base method.

func (*MockReadwriteTransaction) SetMulti 

func (m *MockReadwriteTransaction) SetMulti(ctx context.Context, records []dal.Record) error

SetMulti mocks base method.

func (*MockReadwriteTransaction) Update 

func (m *MockReadwriteTransaction) Update(ctx context.Context, key *dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

Update mocks base method.

func (*MockReadwriteTransaction) UpdateMulti 

func (m *MockReadwriteTransaction) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

UpdateMulti mocks base method.

func (*MockReadwriteTransaction) UpdateRecord 

func (m *MockReadwriteTransaction) UpdateRecord(ctx context.Context, record dal.Record, updates []update.Update, preconditions ...dal.Precondition) error

UpdateRecord mocks base method.

type MockReadwriteTransactionCoordinator 

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

MockReadwriteTransactionCoordinator is a mock of ReadwriteTransactionCoordinator interface.

func NewMockReadwriteTransactionCoordinator 

func NewMockReadwriteTransactionCoordinator(ctrl *gomock.Controller) *MockReadwriteTransactionCoordinator

NewMockReadwriteTransactionCoordinator creates a new mock instance.

func (*MockReadwriteTransactionCoordinator) EXPECT 

func (m *MockReadwriteTransactionCoordinator) EXPECT() *MockReadwriteTransactionCoordinatorMockRecorder

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

func (*MockReadwriteTransactionCoordinator) RunReadwriteTransaction 

func (m *MockReadwriteTransactionCoordinator) RunReadwriteTransaction(ctx context.Context, f func(context.Context, dal.ReadwriteTransaction) error, options ...dal.TransactionOption) error

RunReadwriteTransaction mocks base method.

type MockReadwriteTransactionCoordinatorMockRecorder 

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

MockReadwriteTransactionCoordinatorMockRecorder is the mock recorder for MockReadwriteTransactionCoordinator.

func (*MockReadwriteTransactionCoordinatorMockRecorder) RunReadwriteTransaction 

func (mr *MockReadwriteTransactionCoordinatorMockRecorder) RunReadwriteTransaction(ctx, f any, options ...any) *gomock.Call

RunReadwriteTransaction indicates an expected call of RunReadwriteTransaction.

type MockReadwriteTransactionMockRecorder 

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

MockReadwriteTransactionMockRecorder is the mock recorder for MockReadwriteTransaction.

func (*MockReadwriteTransactionMockRecorder) Delete 

func (mr *MockReadwriteTransactionMockRecorder) Delete(ctx, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockReadwriteTransactionMockRecorder) DeleteMulti 

func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call

DeleteMulti indicates an expected call of DeleteMulti.

func (*MockReadwriteTransactionMockRecorder) Exists 

func (mr *MockReadwriteTransactionMockRecorder) Exists(ctx, key any) *gomock.Call

Exists indicates an expected call of Exists.

func (*MockReadwriteTransactionMockRecorder) Get 

func (mr *MockReadwriteTransactionMockRecorder) Get(ctx, record any) *gomock.Call

Get indicates an expected call of Get.

func (*MockReadwriteTransactionMockRecorder) GetMulti 

func (mr *MockReadwriteTransactionMockRecorder) GetMulti(ctx, records any) *gomock.Call

GetMulti indicates an expected call of GetMulti.

func (*MockReadwriteTransactionMockRecorder) GetRecordsReader added in v0.37.0 

func (mr *MockReadwriteTransactionMockRecorder) GetRecordsReader(ctx, query any) *gomock.Call

GetRecordsReader indicates an expected call of GetRecordsReader.

func (*MockReadwriteTransactionMockRecorder) GetRecordsetReader added in v0.37.0 

func (mr *MockReadwriteTransactionMockRecorder) GetRecordsetReader(ctx, query any, options ...any) *gomock.Call

GetRecordsetReader indicates an expected call of GetRecordsetReader.

func (*MockReadwriteTransactionMockRecorder) ID 

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

ID indicates an expected call of ID.

func (*MockReadwriteTransactionMockRecorder) Insert 

func (mr *MockReadwriteTransactionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call

Insert indicates an expected call of Insert.

func (*MockReadwriteTransactionMockRecorder) InsertMulti 

func (mr *MockReadwriteTransactionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call

InsertMulti indicates an expected call of InsertMulti.

func (*MockReadwriteTransactionMockRecorder) Options 

func (mr *MockReadwriteTransactionMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options.

func (*MockReadwriteTransactionMockRecorder) Set 

func (mr *MockReadwriteTransactionMockRecorder) Set(ctx, record any) *gomock.Call

Set indicates an expected call of Set.

func (*MockReadwriteTransactionMockRecorder) SetMulti 

func (mr *MockReadwriteTransactionMockRecorder) SetMulti(ctx, records any) *gomock.Call

SetMulti indicates an expected call of SetMulti.

func (*MockReadwriteTransactionMockRecorder) Update 

func (mr *MockReadwriteTransactionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call

Update indicates an expected call of Update.

func (*MockReadwriteTransactionMockRecorder) UpdateMulti 

func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call

UpdateMulti indicates an expected call of UpdateMulti.

func (*MockReadwriteTransactionMockRecorder) UpdateRecord 

func (mr *MockReadwriteTransactionMockRecorder) UpdateRecord(ctx, record, updates any, preconditions ...any) *gomock.Call

UpdateRecord indicates an expected call of UpdateRecord.

type MockRecord added in v0.37.0 

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

MockRecord is a mock of Record interface.

func NewMockRecord added in v0.37.0 

func NewMockRecord(ctrl *gomock.Controller) *MockRecord

NewMockRecord creates a new mock instance.

func (*MockRecord) Data added in v0.37.0 

func (m *MockRecord) Data() any

Data mocks base method.

func (*MockRecord) EXPECT added in v0.37.0 

func (m *MockRecord) EXPECT() *MockRecordMockRecorder

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

func (*MockRecord) Error added in v0.37.0 

func (m *MockRecord) Error() error

Error mocks base method.

func (*MockRecord) Exists added in v0.37.0 

func (m *MockRecord) Exists() bool

Exists mocks base method.

func (*MockRecord) HasChanged added in v0.37.0 

func (m *MockRecord) HasChanged() bool

HasChanged mocks base method.

func (*MockRecord) Key added in v0.37.0 

func (m *MockRecord) Key() *dal.Key

Key mocks base method.

func (*MockRecord) MarkAsChanged added in v0.37.0 

func (m *MockRecord) MarkAsChanged()

MarkAsChanged mocks base method.

func (*MockRecord) SetError added in v0.37.0 

func (m *MockRecord) SetError(err error) dal.Record

SetError mocks base method.

type MockRecordMockRecorder added in v0.37.0 

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

MockRecordMockRecorder is the mock recorder for MockRecord.

func (*MockRecordMockRecorder) Data added in v0.37.0 

func (mr *MockRecordMockRecorder) Data() *gomock.Call

Data indicates an expected call of Data.

func (*MockRecordMockRecorder) Error added in v0.37.0 

func (mr *MockRecordMockRecorder) Error() *gomock.Call

Error indicates an expected call of Error.

func (*MockRecordMockRecorder) Exists added in v0.37.0 

func (mr *MockRecordMockRecorder) Exists() *gomock.Call

Exists indicates an expected call of Exists.

func (*MockRecordMockRecorder) HasChanged added in v0.37.0 

func (mr *MockRecordMockRecorder) HasChanged() *gomock.Call

HasChanged indicates an expected call of HasChanged.

func (*MockRecordMockRecorder) Key added in v0.37.0 

func (mr *MockRecordMockRecorder) Key() *gomock.Call

Key indicates an expected call of Key.

func (*MockRecordMockRecorder) MarkAsChanged added in v0.37.0 

func (mr *MockRecordMockRecorder) MarkAsChanged() *gomock.Call

MarkAsChanged indicates an expected call of MarkAsChanged.

func (*MockRecordMockRecorder) SetError added in v0.37.0 

func (mr *MockRecordMockRecorder) SetError(err any) *gomock.Call

SetError indicates an expected call of SetError.

type MockRecordsReader added in v0.37.0 

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

MockRecordsReader is a mock of RecordsReader interface.

func NewMockRecordsReader added in v0.37.0 

func NewMockRecordsReader(ctrl *gomock.Controller) *MockRecordsReader

NewMockRecordsReader creates a new mock instance.

func (*MockRecordsReader) Close added in v0.37.0 

func (m *MockRecordsReader) Close() error

Close mocks base method.

func (*MockRecordsReader) Cursor added in v0.37.0 

func (m *MockRecordsReader) Cursor() (string, error)

Cursor mocks base method.

func (*MockRecordsReader) EXPECT added in v0.37.0 

func (m *MockRecordsReader) EXPECT() *MockRecordsReaderMockRecorder

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

func (*MockRecordsReader) Next added in v0.37.0 

func (m *MockRecordsReader) Next() (dal.Record, error)

Next mocks base method.

type MockRecordsReaderMockRecorder added in v0.37.0 

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

MockRecordsReaderMockRecorder is the mock recorder for MockRecordsReader.

func (*MockRecordsReaderMockRecorder) Close added in v0.37.0 

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

Close indicates an expected call of Close.

func (*MockRecordsReaderMockRecorder) Cursor added in v0.37.0 

func (mr *MockRecordsReaderMockRecorder) Cursor() *gomock.Call

Cursor indicates an expected call of Cursor.

func (*MockRecordsReaderMockRecorder) Next added in v0.37.0 

func (mr *MockRecordsReaderMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

type MockRecordsetReader added in v0.37.0 

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

MockRecordsetReader is a mock of RecordsetReader interface.

func NewMockRecordsetReader added in v0.37.0 

func NewMockRecordsetReader(ctrl *gomock.Controller) *MockRecordsetReader

NewMockRecordsetReader creates a new mock instance.

func (*MockRecordsetReader) Close added in v0.37.0 

func (m *MockRecordsetReader) Close() error

Close mocks base method.

func (*MockRecordsetReader) Cursor added in v0.37.0 

func (m *MockRecordsetReader) Cursor() (string, error)

Cursor mocks base method.

func (*MockRecordsetReader) EXPECT added in v0.37.0 

func (m *MockRecordsetReader) EXPECT() *MockRecordsetReaderMockRecorder

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

func (*MockRecordsetReader) Next added in v0.37.0 

func (m *MockRecordsetReader) Next() (recordset.Row, recordset.Recordset, error)

Next mocks base method.

func (*MockRecordsetReader) Recordset added in v0.37.0 

func (m *MockRecordsetReader) Recordset() recordset.Recordset

Recordset mocks base method.

type MockRecordsetReaderMockRecorder added in v0.37.0 

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

MockRecordsetReaderMockRecorder is the mock recorder for MockRecordsetReader.

func (*MockRecordsetReaderMockRecorder) Close added in v0.37.0 

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

Close indicates an expected call of Close.

func (*MockRecordsetReaderMockRecorder) Cursor added in v0.37.0 

func (mr *MockRecordsetReaderMockRecorder) Cursor() *gomock.Call

Cursor indicates an expected call of Cursor.

func (*MockRecordsetReaderMockRecorder) Next added in v0.37.0 

func (mr *MockRecordsetReaderMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next.

func (*MockRecordsetReaderMockRecorder) Recordset added in v0.37.0 

func (mr *MockRecordsetReaderMockRecorder) Recordset() *gomock.Call

Recordset indicates an expected call of Recordset.

type MockSchema added in v0.37.0 

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

MockSchema is a mock of Schema interface.

func NewMockSchema added in v0.37.0 

func NewMockSchema(ctrl *gomock.Controller) *MockSchema

NewMockSchema creates a new mock instance.

func (*MockSchema) DataToKey added in v0.37.0 

func (m *MockSchema) DataToKey(incompleteKey *dal.Key, data any) (*dal.Key, error)

DataToKey mocks base method.

func (*MockSchema) EXPECT added in v0.37.0 

func (m *MockSchema) EXPECT() *MockSchemaMockRecorder

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

func (*MockSchema) KeyToFields added in v0.37.0 

func (m *MockSchema) KeyToFields(key *dal.Key, data any) ([]dal.ExtraField, error)

KeyToFields mocks base method.

type MockSchemaMockRecorder added in v0.37.0 

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

MockSchemaMockRecorder is the mock recorder for MockSchema.

func (*MockSchemaMockRecorder) DataToKey added in v0.37.0 

func (mr *MockSchemaMockRecorder) DataToKey(incompleteKey, data any) *gomock.Call

DataToKey indicates an expected call of DataToKey.

func (*MockSchemaMockRecorder) KeyToFields added in v0.37.0 

func (mr *MockSchemaMockRecorder) KeyToFields(key, data any) *gomock.Call

KeyToFields indicates an expected call of KeyToFields.

type MockTransaction 

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

MockTransaction is a mock of Transaction interface.

func NewMockTransaction 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) EXPECT 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

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

func (*MockTransaction) Options 

func (m *MockTransaction) Options() dal.TransactionOptions

Options mocks base method.

type MockTransactionCoordinator 

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

MockTransactionCoordinator is a mock of TransactionCoordinator interface.

func NewMockTransactionCoordinator 

func NewMockTransactionCoordinator(ctrl *gomock.Controller) *MockTransactionCoordinator

NewMockTransactionCoordinator creates a new mock instance.

func (*MockTransactionCoordinator) EXPECT 

func (m *MockTransactionCoordinator) EXPECT() *MockTransactionCoordinatorMockRecorder

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

func (*MockTransactionCoordinator) RunReadonlyTransaction 

func (m *MockTransactionCoordinator) RunReadonlyTransaction(ctx context.Context, f func(context.Context, dal.ReadTransaction) error, options ...dal.TransactionOption) error

RunReadonlyTransaction mocks base method.

func (*MockTransactionCoordinator) RunReadwriteTransaction 

func (m *MockTransactionCoordinator) RunReadwriteTransaction(ctx context.Context, f func(context.Context, dal.ReadwriteTransaction) error, options ...dal.TransactionOption) error

RunReadwriteTransaction mocks base method.

type MockTransactionCoordinatorMockRecorder 

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

MockTransactionCoordinatorMockRecorder is the mock recorder for MockTransactionCoordinator.

func (*MockTransactionCoordinatorMockRecorder) RunReadonlyTransaction 

func (mr *MockTransactionCoordinatorMockRecorder) RunReadonlyTransaction(ctx, f any, options ...any) *gomock.Call

RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.

func (*MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction 

func (mr *MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction(ctx, f any, options ...any) *gomock.Call

RunReadwriteTransaction indicates an expected call of RunReadwriteTransaction.

type MockTransactionMockRecorder 

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

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) Options 

func (mr *MockTransactionMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options.

type MockWriteSession 

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

MockWriteSession is a mock of WriteSession interface.

func NewMockWriteSession 

func NewMockWriteSession(ctrl *gomock.Controller) *MockWriteSession

NewMockWriteSession creates a new mock instance.

func (*MockWriteSession) Delete 

func (m *MockWriteSession) Delete(ctx context.Context, key *dal.Key) error

Delete mocks base method.

func (*MockWriteSession) DeleteMulti 

func (m *MockWriteSession) DeleteMulti(ctx context.Context, keys []*dal.Key) error

DeleteMulti mocks base method.

func (*MockWriteSession) EXPECT 

func (m *MockWriteSession) EXPECT() *MockWriteSessionMockRecorder

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

func (*MockWriteSession) Insert 

func (m *MockWriteSession) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error

Insert mocks base method.

func (*MockWriteSession) InsertMulti 

func (m *MockWriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error

InsertMulti mocks base method.

func (*MockWriteSession) Set 

func (m *MockWriteSession) Set(ctx context.Context, record dal.Record) error

Set mocks base method.

func (*MockWriteSession) SetMulti 

func (m *MockWriteSession) SetMulti(ctx context.Context, records []dal.Record) error

SetMulti mocks base method.

func (*MockWriteSession) Update 

func (m *MockWriteSession) Update(ctx context.Context, key *dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

Update mocks base method.

func (*MockWriteSession) UpdateMulti 

func (m *MockWriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []update.Update, preconditions ...dal.Precondition) error

UpdateMulti mocks base method.

func (*MockWriteSession) UpdateRecord 

func (m *MockWriteSession) UpdateRecord(ctx context.Context, record dal.Record, updates []update.Update, preconditions ...dal.Precondition) error

UpdateRecord mocks base method.

type MockWriteSessionMockRecorder 

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

MockWriteSessionMockRecorder is the mock recorder for MockWriteSession.

func (*MockWriteSessionMockRecorder) Delete 

func (mr *MockWriteSessionMockRecorder) Delete(ctx, key any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockWriteSessionMockRecorder) DeleteMulti 

func (mr *MockWriteSessionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call

DeleteMulti indicates an expected call of DeleteMulti.

func (*MockWriteSessionMockRecorder) Insert 

func (mr *MockWriteSessionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call

Insert indicates an expected call of Insert.

func (*MockWriteSessionMockRecorder) InsertMulti 

func (mr *MockWriteSessionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call

InsertMulti indicates an expected call of InsertMulti.

func (*MockWriteSessionMockRecorder) Set 

func (mr *MockWriteSessionMockRecorder) Set(ctx, record any) *gomock.Call

Set indicates an expected call of Set.

func (*MockWriteSessionMockRecorder) SetMulti 

func (mr *MockWriteSessionMockRecorder) SetMulti(ctx, records any) *gomock.Call

SetMulti indicates an expected call of SetMulti.

func (*MockWriteSessionMockRecorder) Update 

func (mr *MockWriteSessionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call

Update indicates an expected call of Update.

func (*MockWriteSessionMockRecorder) UpdateMulti 

func (mr *MockWriteSessionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call

UpdateMulti indicates an expected call of UpdateMulti.

func (*MockWriteSessionMockRecorder) UpdateRecord 

func (mr *MockWriteSessionMockRecorder) UpdateRecord(ctx, record, updates any, preconditions ...any) *gomock.Call

UpdateRecord indicates an expected call of UpdateRecord.

type SelectResult 

type SelectResult struct {
	Reader dal.Reader
	Err    error
}

SelectResult is a helper class that can be used in test definitions (TT)

func NewSelectResult 

func NewSelectResult(reader dal.Reader, err error) SelectResult

NewSelectResult creates new SelectResult

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.