Documentation
¶
Overview ¶
Package mocks4dal is a generated GoMock package.
Package mocks4dal is a generated GoMock package.
Index ¶
- func NewRecordsReader(delay time.Duration, records ...dal.Record) dal.Reader
- type MockDatabase
- func (m *MockDatabase) Adapter() dal.Adapter
- func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder
- func (m *MockDatabase) Get(arg0 context.Context, arg1 dal.Record) error
- func (m *MockDatabase) GetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockDatabase) ID() string
- func (m *MockDatabase) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
- func (m *MockDatabase) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
- func (m *MockDatabase) RunReadonlyTransaction(arg0 context.Context, arg1 func(context.Context, dal.ReadTransaction) error, ...) error
- func (m *MockDatabase) RunReadwriteTransaction(arg0 context.Context, ...) error
- type MockDatabaseMockRecorder
- func (mr *MockDatabaseMockRecorder) Client() *gomock.Call
- func (mr *MockDatabaseMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) ID() *gomock.Call
- func (mr *MockDatabaseMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunReadonlyTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunReadwriteTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockReadSession
- func (m *MockReadSession) EXPECT() *MockReadSessionMockRecorder
- func (m *MockReadSession) Get(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadSession) GetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadSession) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
- func (m *MockReadSession) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
- type MockReadSessionMockRecorder
- func (mr *MockReadSessionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadSessionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadSessionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadSessionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
- type MockReadTransaction
- func (m *MockReadTransaction) EXPECT() *MockReadTransactionMockRecorder
- func (m *MockReadTransaction) Get(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadTransaction) GetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadTransaction) Options() dal.TransactionOptions
- func (m *MockReadTransaction) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
- func (m *MockReadTransaction) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
- type MockReadTransactionCoordinator
- type MockReadTransactionCoordinatorMockRecorder
- type MockReadTransactionMockRecorder
- func (mr *MockReadTransactionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadTransactionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
- type MockReadwriteSession
- func (m *MockReadwriteSession) Delete(arg0 context.Context, arg1 *dal.Key) error
- func (m *MockReadwriteSession) DeleteMulti(arg0 context.Context, arg1 []*dal.Key) error
- func (m *MockReadwriteSession) EXPECT() *MockReadwriteSessionMockRecorder
- func (m *MockReadwriteSession) Get(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadwriteSession) GetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadwriteSession) Insert(arg0 context.Context, arg1 dal.Record, arg2 ...dal.InsertOption) error
- func (m *MockReadwriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteSession) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
- func (m *MockReadwriteSession) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
- func (m *MockReadwriteSession) Set(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadwriteSession) SetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadwriteSession) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, ...) error
- func (m *MockReadwriteSession) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, ...) error
- type MockReadwriteSessionMockRecorder
- func (mr *MockReadwriteSessionMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- type MockReadwriteTransaction
- func (m *MockReadwriteTransaction) Delete(arg0 context.Context, arg1 *dal.Key) error
- func (m *MockReadwriteTransaction) DeleteMulti(arg0 context.Context, arg1 []*dal.Key) error
- func (m *MockReadwriteTransaction) EXPECT() *MockReadwriteTransactionMockRecorder
- func (m *MockReadwriteTransaction) Get(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadwriteTransaction) GetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadwriteTransaction) ID() string
- func (m *MockReadwriteTransaction) Insert(arg0 context.Context, arg1 dal.Record, arg2 ...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(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
- func (m *MockReadwriteTransaction) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
- func (m *MockReadwriteTransaction) Set(arg0 context.Context, arg1 dal.Record) error
- func (m *MockReadwriteTransaction) SetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockReadwriteTransaction) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, ...) error
- func (m *MockReadwriteTransaction) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, ...) error
- type MockReadwriteTransactionCoordinator
- type MockReadwriteTransactionCoordinatorMockRecorder
- type MockReadwriteTransactionMockRecorder
- func (mr *MockReadwriteTransactionMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) ID() *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- type MockTransaction
- type MockTransactionCoordinator
- func (m *MockTransactionCoordinator) EXPECT() *MockTransactionCoordinatorMockRecorder
- func (m *MockTransactionCoordinator) RunReadonlyTransaction(arg0 context.Context, arg1 func(context.Context, dal.ReadTransaction) error, ...) error
- func (m *MockTransactionCoordinator) RunReadwriteTransaction(arg0 context.Context, ...) error
- type MockTransactionCoordinatorMockRecorder
- type MockTransactionMockRecorder
- type MockWriteSession
- func (m *MockWriteSession) Delete(arg0 context.Context, arg1 *dal.Key) error
- func (m *MockWriteSession) DeleteMulti(arg0 context.Context, arg1 []*dal.Key) error
- func (m *MockWriteSession) EXPECT() *MockWriteSessionMockRecorder
- func (m *MockWriteSession) Insert(arg0 context.Context, arg1 dal.Record, arg2 ...dal.InsertOption) error
- func (m *MockWriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
- func (m *MockWriteSession) Set(arg0 context.Context, arg1 dal.Record) error
- func (m *MockWriteSession) SetMulti(arg0 context.Context, arg1 []dal.Record) error
- func (m *MockWriteSession) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, ...) error
- func (m *MockWriteSession) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, ...) error
- type MockWriteSessionMockRecorder
- func (mr *MockWriteSessionMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- type SelectResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
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) Adapter ¶ added in v0.1.14
func (m *MockDatabase) Adapter() dal.Adapter
Client 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) QueryAllRecords ¶ added in v0.1.3
QueryAllRecords mocks base method.
func (*MockDatabase) QueryReader ¶ added in v0.1.3
QueryReader mocks base method.
func (*MockDatabase) RunReadonlyTransaction ¶
func (m *MockDatabase) RunReadonlyTransaction(arg0 context.Context, arg1 func(context.Context, dal.ReadTransaction) error, arg2 ...dal.TransactionOption) error
RunReadonlyTransaction mocks base method.
func (*MockDatabase) RunReadwriteTransaction ¶
func (m *MockDatabase) RunReadwriteTransaction(arg0 context.Context, arg1 func(context.Context, dal.ReadwriteTransaction) error, arg2 ...dal.TransactionOption) error
RunReadwriteTransaction mocks base method.
type MockDatabaseMockRecorder ¶
type MockDatabaseMockRecorder struct {
// contains filtered or unexported fields
}
MockDatabaseMockRecorder is the mock recorder for MockDatabase.
func (*MockDatabaseMockRecorder) Client ¶ added in v0.1.1
func (mr *MockDatabaseMockRecorder) Client() *gomock.Call
Client indicates an expected call of Client.
func (*MockDatabaseMockRecorder) Get ¶
func (mr *MockDatabaseMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockDatabaseMockRecorder) GetMulti ¶
func (mr *MockDatabaseMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockDatabaseMockRecorder) ID ¶ added in v0.1.1
func (mr *MockDatabaseMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockDatabaseMockRecorder) QueryAllRecords ¶ added in v0.1.3
func (mr *MockDatabaseMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockDatabaseMockRecorder) QueryReader ¶ added in v0.1.3
func (mr *MockDatabaseMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
QueryReader indicates an expected call of QueryReader.
func (*MockDatabaseMockRecorder) RunReadonlyTransaction ¶
func (mr *MockDatabaseMockRecorder) RunReadonlyTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.
func (*MockDatabaseMockRecorder) RunReadwriteTransaction ¶
func (mr *MockDatabaseMockRecorder) RunReadwriteTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *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 ¶ added in v0.1.3
func (m *MockReadSession) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadSession) QueryReader ¶ added in v0.1.3
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(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadSessionMockRecorder) GetMulti ¶
func (mr *MockReadSessionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadSessionMockRecorder) QueryAllRecords ¶ added in v0.1.3
func (mr *MockReadSessionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadSessionMockRecorder) QueryReader ¶ added in v0.1.3
func (mr *MockReadSessionMockRecorder) QueryReader(arg0, arg1 interface{}) *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 ¶ added in v0.1.3
func (m *MockReadTransaction) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadTransaction) QueryReader ¶ added in v0.1.3
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(arg0 context.Context, arg1 func(context.Context, dal.ReadTransaction) error, arg2 ...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(arg0, arg1 interface{}, arg2 ...interface{}) *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(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadTransactionMockRecorder) GetMulti ¶
func (mr *MockReadTransactionMockRecorder) GetMulti(arg0, arg1 interface{}) *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 ¶ added in v0.1.3
func (mr *MockReadTransactionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadTransactionMockRecorder) QueryReader ¶ added in v0.1.3
func (mr *MockReadTransactionMockRecorder) QueryReader(arg0, arg1 interface{}) *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(arg0 context.Context, arg1 dal.Record, arg2 ...dal.InsertOption) error
Insert mocks base method.
func (*MockReadwriteSession) InsertMulti ¶ added in v0.1.21
func (m *MockReadwriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
func (*MockReadwriteSession) QueryAllRecords ¶ added in v0.1.3
func (m *MockReadwriteSession) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadwriteSession) QueryReader ¶ added in v0.1.3
func (m *MockReadwriteSession) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
QueryReader mocks base method.
func (*MockReadwriteSession) Update ¶
func (m *MockReadwriteSession) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, arg3 ...dal.Precondition) error
Update mocks base method.
func (*MockReadwriteSession) UpdateMulti ¶
func (m *MockReadwriteSession) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, arg3 ...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(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockReadwriteSessionMockRecorder) DeleteMulti ¶
func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockReadwriteSessionMockRecorder) Get ¶
func (mr *MockReadwriteSessionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadwriteSessionMockRecorder) GetMulti ¶
func (mr *MockReadwriteSessionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadwriteSessionMockRecorder) Insert ¶
func (mr *MockReadwriteSessionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockReadwriteSessionMockRecorder) QueryAllRecords ¶ added in v0.1.3
func (mr *MockReadwriteSessionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadwriteSessionMockRecorder) QueryReader ¶ added in v0.1.3
func (mr *MockReadwriteSessionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
QueryReader indicates an expected call of QueryReader.
func (*MockReadwriteSessionMockRecorder) Set ¶
func (mr *MockReadwriteSessionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockReadwriteSessionMockRecorder) SetMulti ¶
func (mr *MockReadwriteSessionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockReadwriteSessionMockRecorder) Update ¶
func (mr *MockReadwriteSessionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockReadwriteSessionMockRecorder) UpdateMulti ¶
func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *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 ¶ added in v0.1.1
func (m *MockReadwriteTransaction) ID() string
ID mocks base method.
func (*MockReadwriteTransaction) Insert ¶
func (m *MockReadwriteTransaction) Insert(arg0 context.Context, arg1 dal.Record, arg2 ...dal.InsertOption) error
Insert mocks base method.
func (*MockReadwriteTransaction) InsertMulti ¶ added in v0.1.21
func (m *MockReadwriteTransaction) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
func (*MockReadwriteTransaction) Options ¶
func (m *MockReadwriteTransaction) Options() dal.TransactionOptions
Options mocks base method.
func (*MockReadwriteTransaction) QueryAllRecords ¶ added in v0.1.3
func (m *MockReadwriteTransaction) QueryAllRecords(arg0 context.Context, arg1 dal.Query) ([]dal.Record, error)
QueryAllRecords mocks base method.
func (*MockReadwriteTransaction) QueryReader ¶ added in v0.1.3
func (m *MockReadwriteTransaction) QueryReader(arg0 context.Context, arg1 dal.Query) (dal.Reader, error)
QueryReader mocks base method.
func (*MockReadwriteTransaction) Update ¶
func (m *MockReadwriteTransaction) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, arg3 ...dal.Precondition) error
Update mocks base method.
func (*MockReadwriteTransaction) UpdateMulti ¶
func (m *MockReadwriteTransaction) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, arg3 ...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(arg0 context.Context, arg1 func(context.Context, dal.ReadwriteTransaction) error, arg2 ...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(arg0, arg1 interface{}, arg2 ...interface{}) *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(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockReadwriteTransactionMockRecorder) DeleteMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockReadwriteTransactionMockRecorder) Get ¶
func (mr *MockReadwriteTransactionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadwriteTransactionMockRecorder) GetMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) GetMulti(arg0, arg1 interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadwriteTransactionMockRecorder) ID ¶ added in v0.1.1
func (mr *MockReadwriteTransactionMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
func (*MockReadwriteTransactionMockRecorder) Insert ¶
func (mr *MockReadwriteTransactionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockReadwriteTransactionMockRecorder) Options ¶
func (mr *MockReadwriteTransactionMockRecorder) Options() *gomock.Call
Options indicates an expected call of Options.
func (*MockReadwriteTransactionMockRecorder) QueryAllRecords ¶ added in v0.1.3
func (mr *MockReadwriteTransactionMockRecorder) QueryAllRecords(arg0, arg1 interface{}) *gomock.Call
QueryAllRecords indicates an expected call of QueryAllRecords.
func (*MockReadwriteTransactionMockRecorder) QueryReader ¶ added in v0.1.3
func (mr *MockReadwriteTransactionMockRecorder) QueryReader(arg0, arg1 interface{}) *gomock.Call
QueryReader indicates an expected call of QueryReader.
func (*MockReadwriteTransactionMockRecorder) Set ¶
func (mr *MockReadwriteTransactionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockReadwriteTransactionMockRecorder) SetMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockReadwriteTransactionMockRecorder) Update ¶
func (mr *MockReadwriteTransactionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockReadwriteTransactionMockRecorder) UpdateMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *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(arg0 context.Context, arg1 func(context.Context, dal.ReadTransaction) error, arg2 ...dal.TransactionOption) error
RunReadonlyTransaction mocks base method.
func (*MockTransactionCoordinator) RunReadwriteTransaction ¶
func (m *MockTransactionCoordinator) RunReadwriteTransaction(arg0 context.Context, arg1 func(context.Context, dal.ReadwriteTransaction) error, arg2 ...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(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.
func (*MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction ¶
func (mr *MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction(arg0, arg1 interface{}, arg2 ...interface{}) *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(arg0 context.Context, arg1 dal.Record, arg2 ...dal.InsertOption) error
Insert mocks base method.
func (*MockWriteSession) InsertMulti ¶ added in v0.1.21
func (m *MockWriteSession) InsertMulti(ctx context.Context, records []dal.Record, opts ...dal.InsertOption) error
func (*MockWriteSession) Update ¶
func (m *MockWriteSession) Update(arg0 context.Context, arg1 *dal.Key, arg2 []dal.Update, arg3 ...dal.Precondition) error
Update mocks base method.
func (*MockWriteSession) UpdateMulti ¶
func (m *MockWriteSession) UpdateMulti(arg0 context.Context, arg1 []*dal.Key, arg2 []dal.Update, arg3 ...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(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockWriteSessionMockRecorder) DeleteMulti ¶
func (mr *MockWriteSessionMockRecorder) DeleteMulti(arg0, arg1 interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockWriteSessionMockRecorder) Insert ¶
func (mr *MockWriteSessionMockRecorder) Insert(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockWriteSessionMockRecorder) Set ¶
func (mr *MockWriteSessionMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockWriteSessionMockRecorder) SetMulti ¶
func (mr *MockWriteSessionMockRecorder) SetMulti(arg0, arg1 interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockWriteSessionMockRecorder) Update ¶
func (mr *MockWriteSessionMockRecorder) Update(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockWriteSessionMockRecorder) UpdateMulti ¶
func (mr *MockWriteSessionMockRecorder) UpdateMulti(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *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