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.
Index ¶
- func NewRecordsReader(delay time.Duration, records ...dal.Record) dal.Reader
- type MockDB
- func (m *MockDB) Adapter() dal.Adapter
- func (m *MockDB) EXPECT() *MockDBMockRecorder
- func (m *MockDB) Get(ctx context.Context, record dal.Record) error
- func (m *MockDB) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockDB) ID() string
- func (m *MockDB) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
- func (m *MockDB) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
- func (m *MockDB) RunReadonlyTransaction(ctx context.Context, f func(context.Context, dal.ReadTransaction) error, ...) error
- func (m *MockDB) RunReadwriteTransaction(ctx context.Context, f func(context.Context, dal.ReadwriteTransaction) error, ...) error
- type MockDBMockRecorder
- func (mr *MockDBMockRecorder) Adapter() *gomock.Call
- func (mr *MockDBMockRecorder) Get(ctx, record any) *gomock.Call
- func (mr *MockDBMockRecorder) GetMulti(ctx, records any) *gomock.Call
- func (mr *MockDBMockRecorder) ID() *gomock.Call
- func (mr *MockDBMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
- func (mr *MockDBMockRecorder) QueryReader(ctx, query any) *gomock.Call
- func (mr *MockDBMockRecorder) RunReadonlyTransaction(ctx, f any, options ...any) *gomock.Call
- func (mr *MockDBMockRecorder) RunReadwriteTransaction(ctx, f any, options ...any) *gomock.Call
- type MockReadSession
- func (m *MockReadSession) EXPECT() *MockReadSessionMockRecorder
- func (m *MockReadSession) Get(ctx context.Context, record dal.Record) error
- func (m *MockReadSession) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadSession) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
- func (m *MockReadSession) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
- type MockReadSessionMockRecorder
- func (mr *MockReadSessionMockRecorder) Get(ctx, record any) *gomock.Call
- func (mr *MockReadSessionMockRecorder) GetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadSessionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
- func (mr *MockReadSessionMockRecorder) QueryReader(ctx, query any) *gomock.Call
- type MockReadTransaction
- func (m *MockReadTransaction) EXPECT() *MockReadTransactionMockRecorder
- func (m *MockReadTransaction) Get(ctx context.Context, record dal.Record) error
- func (m *MockReadTransaction) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadTransaction) Options() dal.TransactionOptions
- func (m *MockReadTransaction) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
- func (m *MockReadTransaction) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
- type MockReadTransactionCoordinator
- type MockReadTransactionCoordinatorMockRecorder
- type MockReadTransactionMockRecorder
- func (mr *MockReadTransactionMockRecorder) Get(ctx, record any) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) GetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadTransactionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) QueryReader(ctx, query any) *gomock.Call
- type MockReadwriteSession
- func (m *MockReadwriteSession) Delete(ctx context.Context, key *dal.Key) error
- func (m *MockReadwriteSession) DeleteMulti(ctx context.Context, keys []*dal.Key) error
- func (m *MockReadwriteSession) EXPECT() *MockReadwriteSessionMockRecorder
- func (m *MockReadwriteSession) Get(ctx context.Context, record dal.Record) error
- func (m *MockReadwriteSession) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadwriteSession) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteSession) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
- func (m *MockReadwriteSession) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
- func (m *MockReadwriteSession) Set(ctx context.Context, record dal.Record) error
- func (m *MockReadwriteSession) SetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadwriteSession) Update(ctx context.Context, key *dal.Key, updates []dal.Update, ...) error
- func (m *MockReadwriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockReadwriteSessionMockRecorder
- func (mr *MockReadwriteSessionMockRecorder) Delete(ctx, key any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Get(ctx, record any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) GetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) QueryReader(ctx, query any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Set(ctx, record any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) SetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call
- type MockReadwriteTransaction
- func (m *MockReadwriteTransaction) Delete(ctx context.Context, key *dal.Key) error
- func (m *MockReadwriteTransaction) DeleteMulti(ctx context.Context, keys []*dal.Key) error
- func (m *MockReadwriteTransaction) EXPECT() *MockReadwriteTransactionMockRecorder
- func (m *MockReadwriteTransaction) Get(ctx context.Context, record dal.Record) error
- func (m *MockReadwriteTransaction) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadwriteTransaction) ID() string
- func (m *MockReadwriteTransaction) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteTransaction) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteTransaction) Options() dal.TransactionOptions
- func (m *MockReadwriteTransaction) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
- func (m *MockReadwriteTransaction) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
- func (m *MockReadwriteTransaction) Set(ctx context.Context, record dal.Record) error
- func (m *MockReadwriteTransaction) SetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockReadwriteTransaction) Update(ctx context.Context, key *dal.Key, updates []dal.Update, ...) error
- func (m *MockReadwriteTransaction) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockReadwriteTransactionCoordinator
- type MockReadwriteTransactionCoordinatorMockRecorder
- type MockReadwriteTransactionMockRecorder
- func (mr *MockReadwriteTransactionMockRecorder) Delete(ctx, key any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Get(ctx, record any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) GetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) ID() *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) QueryReader(ctx, query any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Set(ctx, record any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) SetMulti(ctx, records any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call
- type MockTransaction
- type MockTransactionCoordinator
- func (m *MockTransactionCoordinator) EXPECT() *MockTransactionCoordinatorMockRecorder
- func (m *MockTransactionCoordinator) RunReadonlyTransaction(ctx context.Context, f func(context.Context, dal.ReadTransaction) error, ...) error
- func (m *MockTransactionCoordinator) RunReadwriteTransaction(ctx context.Context, f func(context.Context, dal.ReadwriteTransaction) error, ...) error
- type MockTransactionCoordinatorMockRecorder
- type MockTransactionMockRecorder
- type MockWriteSession
- func (m *MockWriteSession) Delete(ctx context.Context, key *dal.Key) error
- func (m *MockWriteSession) DeleteMulti(ctx context.Context, keys []*dal.Key) error
- func (m *MockWriteSession) EXPECT() *MockWriteSessionMockRecorder
- func (m *MockWriteSession) Insert(ctx context.Context, record dal.Record, opts ...dal.InsertOption) error
- func (m *MockWriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
- func (m *MockWriteSession) Set(ctx context.Context, record dal.Record) error
- func (m *MockWriteSession) SetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockWriteSession) Update(ctx context.Context, key *dal.Key, updates []dal.Update, ...) error
- func (m *MockWriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockWriteSessionMockRecorder
- func (mr *MockWriteSessionMockRecorder) Delete(ctx, key any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) DeleteMulti(ctx, keys any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Insert(ctx, record any, opts ...any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) InsertMulti(ctx, records any, opts ...any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Set(ctx, record any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) SetMulti(ctx, records any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Update(ctx, key, updates any, preconditions ...any) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) UpdateMulti(ctx, keys, updates any, preconditions ...any) *gomock.Call
- type SelectResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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) EXPECT ¶
func (m *MockDB) EXPECT() *MockDBMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDB) QueryAllRecords ¶
QueryAllRecords mocks base method.
func (*MockDB) QueryReader ¶
QueryReader 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.
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) 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) ID ¶
func (mr *MockDBMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockDBMockRecorder) QueryAllRecords ¶
func (mr *MockDBMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockDBMockRecorder) QueryReader ¶
func (mr *MockDBMockRecorder) QueryReader(ctx, query any) *gomock.Call
QueryReader indicates an expected call of QueryReader.
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.
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) QueryAllRecords ¶
func (m *MockReadSession) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadSession) QueryReader ¶
QueryReader mocks base method.
type MockReadSessionMockRecorder ¶
type MockReadSessionMockRecorder struct {
// contains filtered or unexported fields
}
MockReadSessionMockRecorder is the mock recorder for MockReadSession.
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) QueryAllRecords ¶
func (mr *MockReadSessionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadSessionMockRecorder) QueryReader ¶
func (mr *MockReadSessionMockRecorder) QueryReader(ctx, query any) *gomock.Call
QueryReader indicates an expected call of QueryReader.
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) Options ¶
func (m *MockReadTransaction) Options() dal.TransactionOptions
Options mocks base method.
func (*MockReadTransaction) QueryAllRecords ¶
func (m *MockReadTransaction) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadTransaction) QueryReader ¶
QueryReader 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) 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) Options ¶
func (mr *MockReadTransactionMockRecorder) Options() *gomock.Call
Options indicates an expected call of Options.
func (*MockReadTransactionMockRecorder) QueryAllRecords ¶
func (mr *MockReadTransactionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadTransactionMockRecorder) QueryReader ¶
func (mr *MockReadTransactionMockRecorder) QueryReader(ctx, query any) *gomock.Call
QueryReader indicates an expected call of QueryReader.
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) DeleteMulti ¶
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) 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) QueryAllRecords ¶
func (m *MockReadwriteSession) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadwriteSession) QueryReader ¶
func (m *MockReadwriteSession) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
QueryReader mocks base method.
func (*MockReadwriteSession) Update ¶
func (m *MockReadwriteSession) Update(ctx context.Context, key *dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
Update mocks base method.
func (*MockReadwriteSession) UpdateMulti ¶
func (m *MockReadwriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
UpdateMulti 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) 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) 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) QueryAllRecords ¶
func (mr *MockReadwriteSessionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadwriteSessionMockRecorder) QueryReader ¶
func (mr *MockReadwriteSessionMockRecorder) QueryReader(ctx, query any) *gomock.Call
QueryReader indicates an expected call of QueryReader.
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.
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) DeleteMulti ¶
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) 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) QueryAllRecords ¶
func (m *MockReadwriteTransaction) QueryAllRecords(ctx context.Context, query dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadwriteTransaction) QueryReader ¶
func (m *MockReadwriteTransaction) QueryReader(ctx context.Context, query dal.Query) (dal.Reader, error)
QueryReader mocks base method.
func (*MockReadwriteTransaction) Update ¶
func (m *MockReadwriteTransaction) Update(ctx context.Context, key *dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
Update mocks base method.
func (*MockReadwriteTransaction) UpdateMulti ¶
func (m *MockReadwriteTransaction) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
UpdateMulti 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) 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) 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) QueryAllRecords ¶
func (mr *MockReadwriteTransactionMockRecorder) QueryAllRecords(ctx, query any) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadwriteTransactionMockRecorder) QueryReader ¶
func (mr *MockReadwriteTransactionMockRecorder) QueryReader(ctx, query any) *gomock.Call
QueryReader indicates an expected call of QueryReader.
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.
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) DeleteMulti ¶
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) Update ¶
func (m *MockWriteSession) Update(ctx context.Context, key *dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
Update mocks base method.
func (*MockWriteSession) UpdateMulti ¶
func (m *MockWriteSession) UpdateMulti(ctx context.Context, keys []*dal.Key, updates []dal.Update, preconditions ...dal.Precondition) error
UpdateMulti 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.
type SelectResult ¶
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