Documentation ¶
Overview ¶
Package mocks4dal is a generated GoMock package.
Index ¶
- func NewSingleRecordReader(key *dal.Key, data string, into func() interface{}) *singleRecordReader
- type MockDatabase
- func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder
- func (m *MockDatabase) Get(ctx context.Context, record dal.Record) error
- func (m *MockDatabase) GetMulti(ctx context.Context, records []dal.Record) error
- func (m *MockDatabase) RunReadonlyTransaction(ctx context.Context, f dal.ROTxWorker, options ...dal.TransactionOption) error
- func (m *MockDatabase) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, options ...dal.TransactionOption) error
- func (m *MockDatabase) Select(ctx context.Context, query dal.Select) (dal.Reader, error)
- type MockDatabaseMockRecorder
- func (mr *MockDatabaseMockRecorder) Get(ctx, record interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunReadonlyTransaction(ctx, f interface{}, options ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) RunReadwriteTransaction(ctx, f interface{}, options ...interface{}) *gomock.Call
- func (mr *MockDatabaseMockRecorder) Select(ctx, query interface{}) *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) Select(ctx context.Context, query dal.Select) (dal.Reader, error)
- type MockReadSessionMockRecorder
- 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) Select(ctx context.Context, query dal.Select) (dal.Reader, error)
- type MockReadTransactionCoordinator
- type MockReadTransactionCoordinatorMockRecorder
- type MockReadTransactionMockRecorder
- func (mr *MockReadTransactionMockRecorder) Get(ctx, record interface{}) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockReadTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadTransactionMockRecorder) Select(ctx, query interface{}) *gomock.Call
- type MockReader
- type MockReaderMockRecorder
- 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(c context.Context, record dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteSession) Select(ctx context.Context, query dal.Select) (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(c context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockReadwriteSessionMockRecorder
- func (mr *MockReadwriteSessionMockRecorder) Delete(ctx, key interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Get(ctx, record interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Insert(c, record interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Select(ctx, query interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Set(ctx, record interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
- func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...interface{}) *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) Insert(c context.Context, record dal.Record, opts ...dal.InsertOption) error
- func (m *MockReadwriteTransaction) Options() dal.TransactionOptions
- func (m *MockReadwriteTransaction) Select(ctx context.Context, query dal.Select) (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(c context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockReadwriteTransactionCoordinator
- type MockReadwriteTransactionCoordinatorMockRecorder
- type MockReadwriteTransactionMockRecorder
- func (mr *MockReadwriteTransactionMockRecorder) Delete(ctx, key interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Get(ctx, record interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Insert(c, record interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Options() *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Select(ctx, query interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Set(ctx, record interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
- func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...interface{}) *gomock.Call
- type MockTransaction
- type MockTransactionCoordinator
- func (m *MockTransactionCoordinator) EXPECT() *MockTransactionCoordinatorMockRecorder
- func (m *MockTransactionCoordinator) RunReadonlyTransaction(ctx context.Context, f dal.ROTxWorker, options ...dal.TransactionOption) error
- func (m *MockTransactionCoordinator) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, options ...dal.TransactionOption) 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(c context.Context, record 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(c context.Context, keys []*dal.Key, updates []dal.Update, ...) error
- type MockWriteSessionMockRecorder
- func (mr *MockWriteSessionMockRecorder) Delete(ctx, key interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Insert(c, record interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Set(ctx, record interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
- func (mr *MockWriteSessionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...interface{}) *gomock.Call
- type SelectResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSingleRecordReader ¶
NewSingleRecordReader creates a reader that returns a single record
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) EXPECT ¶
func (m *MockDatabase) EXPECT() *MockDatabaseMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDatabase) RunReadonlyTransaction ¶
func (m *MockDatabase) RunReadonlyTransaction(ctx context.Context, f dal.ROTxWorker, options ...dal.TransactionOption) error
RunReadonlyTransaction mocks base method.
func (*MockDatabase) RunReadwriteTransaction ¶
func (m *MockDatabase) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, options ...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) Get ¶
func (mr *MockDatabaseMockRecorder) Get(ctx, record interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockDatabaseMockRecorder) GetMulti ¶
func (mr *MockDatabaseMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockDatabaseMockRecorder) RunReadonlyTransaction ¶
func (mr *MockDatabaseMockRecorder) RunReadonlyTransaction(ctx, f interface{}, options ...interface{}) *gomock.Call
RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.
func (*MockDatabaseMockRecorder) RunReadwriteTransaction ¶
func (mr *MockDatabaseMockRecorder) RunReadwriteTransaction(ctx, f interface{}, options ...interface{}) *gomock.Call
RunReadwriteTransaction indicates an expected call of RunReadwriteTransaction.
func (*MockDatabaseMockRecorder) Select ¶
func (mr *MockDatabaseMockRecorder) Select(ctx, query interface{}) *gomock.Call
Select indicates an expected call of Select.
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.
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 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadSessionMockRecorder) GetMulti ¶
func (mr *MockReadSessionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadSessionMockRecorder) Select ¶
func (mr *MockReadSessionMockRecorder) Select(ctx, query interface{}) *gomock.Call
Select indicates an expected call of Select.
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.
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 dal.ROTxWorker, 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 interface{}, options ...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(ctx, record interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadTransactionMockRecorder) GetMulti ¶
func (mr *MockReadTransactionMockRecorder) GetMulti(ctx, records 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) Select ¶
func (mr *MockReadTransactionMockRecorder) Select(ctx, query interface{}) *gomock.Call
Select indicates an expected call of Select.
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) 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) Next ¶
func (mr *MockReaderMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next.
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(c context.Context, record dal.Record, opts ...dal.InsertOption) error
Insert 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(c 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 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockReadwriteSessionMockRecorder) DeleteMulti ¶
func (mr *MockReadwriteSessionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockReadwriteSessionMockRecorder) Get ¶
func (mr *MockReadwriteSessionMockRecorder) Get(ctx, record interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadwriteSessionMockRecorder) GetMulti ¶
func (mr *MockReadwriteSessionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadwriteSessionMockRecorder) Insert ¶
func (mr *MockReadwriteSessionMockRecorder) Insert(c, record interface{}, opts ...interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockReadwriteSessionMockRecorder) Select ¶
func (mr *MockReadwriteSessionMockRecorder) Select(ctx, query interface{}) *gomock.Call
Select indicates an expected call of Select.
func (*MockReadwriteSessionMockRecorder) Set ¶
func (mr *MockReadwriteSessionMockRecorder) Set(ctx, record interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockReadwriteSessionMockRecorder) SetMulti ¶
func (mr *MockReadwriteSessionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockReadwriteSessionMockRecorder) Update ¶
func (mr *MockReadwriteSessionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockReadwriteSessionMockRecorder) UpdateMulti ¶
func (mr *MockReadwriteSessionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...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) Insert ¶
func (m *MockReadwriteTransaction) Insert(c context.Context, record dal.Record, opts ...dal.InsertOption) error
Insert mocks base method.
func (*MockReadwriteTransaction) Options ¶
func (m *MockReadwriteTransaction) Options() dal.TransactionOptions
Options mocks base method.
func (*MockReadwriteTransaction) Select ¶
func (m *MockReadwriteTransaction) Select(ctx context.Context, query dal.Select) (dal.Reader, error)
Select 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(c 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 dal.RWTxWorker, 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 interface{}, options ...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(ctx, key interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockReadwriteTransactionMockRecorder) DeleteMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockReadwriteTransactionMockRecorder) Get ¶
func (mr *MockReadwriteTransactionMockRecorder) Get(ctx, record interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReadwriteTransactionMockRecorder) GetMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) GetMulti(ctx, records interface{}) *gomock.Call
GetMulti indicates an expected call of GetMulti.
func (*MockReadwriteTransactionMockRecorder) Insert ¶
func (mr *MockReadwriteTransactionMockRecorder) Insert(c, record interface{}, opts ...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) Select ¶
func (mr *MockReadwriteTransactionMockRecorder) Select(ctx, query interface{}) *gomock.Call
Select indicates an expected call of Select.
func (*MockReadwriteTransactionMockRecorder) Set ¶
func (mr *MockReadwriteTransactionMockRecorder) Set(ctx, record interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockReadwriteTransactionMockRecorder) SetMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockReadwriteTransactionMockRecorder) Update ¶
func (mr *MockReadwriteTransactionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockReadwriteTransactionMockRecorder) UpdateMulti ¶
func (mr *MockReadwriteTransactionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...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(ctx context.Context, f dal.ROTxWorker, options ...dal.TransactionOption) error
RunReadonlyTransaction mocks base method.
func (*MockTransactionCoordinator) RunReadwriteTransaction ¶
func (m *MockTransactionCoordinator) RunReadwriteTransaction(ctx context.Context, f dal.RWTxWorker, 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 interface{}, options ...interface{}) *gomock.Call
RunReadonlyTransaction indicates an expected call of RunReadonlyTransaction.
func (*MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction ¶
func (mr *MockTransactionCoordinatorMockRecorder) RunReadwriteTransaction(ctx, f interface{}, options ...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(c context.Context, record dal.Record, opts ...dal.InsertOption) error
Insert 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(c 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 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockWriteSessionMockRecorder) DeleteMulti ¶
func (mr *MockWriteSessionMockRecorder) DeleteMulti(ctx, keys interface{}) *gomock.Call
DeleteMulti indicates an expected call of DeleteMulti.
func (*MockWriteSessionMockRecorder) Insert ¶
func (mr *MockWriteSessionMockRecorder) Insert(c, record interface{}, opts ...interface{}) *gomock.Call
Insert indicates an expected call of Insert.
func (*MockWriteSessionMockRecorder) Set ¶
func (mr *MockWriteSessionMockRecorder) Set(ctx, record interface{}) *gomock.Call
Set indicates an expected call of Set.
func (*MockWriteSessionMockRecorder) SetMulti ¶
func (mr *MockWriteSessionMockRecorder) SetMulti(ctx, records interface{}) *gomock.Call
SetMulti indicates an expected call of SetMulti.
func (*MockWriteSessionMockRecorder) Update ¶
func (mr *MockWriteSessionMockRecorder) Update(ctx, key, updates interface{}, preconditions ...interface{}) *gomock.Call
Update indicates an expected call of Update.
func (*MockWriteSessionMockRecorder) UpdateMulti ¶
func (mr *MockWriteSessionMockRecorder) UpdateMulti(c, keys, updates interface{}, preconditions ...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(getReader func(into func() interface{}) dal.Reader, err error) SelectResult
NewSelectResult creates new SelectResult