Documentation ¶
Overview ¶
Package mock_storage is a generated GoMock package.
Index ¶
- type MockBusinessUnitStorage
- func (m *MockBusinessUnitStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockBusinessUnitStorage) EXPECT() *MockBusinessUnitStorageMockRecorder
- func (m *MockBusinessUnitStorage) ListAuthentication(ctx context.Context, tx storage.Tx, req storage.ListAuthenticationRequest) (storage.ListAuthenticationResult, error)
- func (m *MockBusinessUnitStorage) ListBusinessUnits(ctx context.Context, tx storage.Tx, req storage.ListBusinessUnitsRequest) (storage.ListBusinessUnitsResult, error)
- func (m *MockBusinessUnitStorage) StoreAuthentication(ctx context.Context, tx storage.Tx, auth model.BusinessUnitAuthentication) error
- func (m *MockBusinessUnitStorage) StoreBusinessUnit(ctx context.Context, tx storage.Tx, bu model.BusinessUnit) error
- type MockBusinessUnitStorageMockRecorder
- func (mr *MockBusinessUnitStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockBusinessUnitStorageMockRecorder) ListAuthentication(ctx, tx, req interface{}) *gomock.Call
- func (mr *MockBusinessUnitStorageMockRecorder) ListBusinessUnits(ctx, tx, req interface{}) *gomock.Call
- func (mr *MockBusinessUnitStorageMockRecorder) StoreAuthentication(ctx, tx, auth interface{}) *gomock.Call
- func (mr *MockBusinessUnitStorageMockRecorder) StoreBusinessUnit(ctx, tx, bu interface{}) *gomock.Call
- type MockCertStorage
- func (m *MockCertStorage) AddCRL(ctx context.Context, tx storage.Tx, ts int64, ...) error
- func (m *MockCertStorage) AddRootCert(ctx context.Context, tx storage.Tx, ts int64, fingerPrint string, cert []byte) error
- func (m *MockCertStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockCertStorage) EXPECT() *MockCertStorageMockRecorder
- func (m *MockCertStorage) GetActiveRootCert(ctx context.Context, tx storage.Tx) ([][]byte, error)
- func (m *MockCertStorage) GetCRL(ctx context.Context, tx storage.Tx, req storage.GetCRLRequest) (storage.GetCRLResult, error)
- func (m *MockCertStorage) RevokeRootCert(ctx context.Context, tx storage.Tx, ts int64, fingerPrinter string) error
- type MockCertStorageMockRecorder
- func (mr *MockCertStorageMockRecorder) AddCRL(ctx, tx, ts, issuerKeyID, certSerialNumber, revokedAt, crl interface{}) *gomock.Call
- func (mr *MockCertStorageMockRecorder) AddRootCert(ctx, tx, ts, fingerPrint, cert interface{}) *gomock.Call
- func (mr *MockCertStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockCertStorageMockRecorder) GetActiveRootCert(ctx, tx interface{}) *gomock.Call
- func (mr *MockCertStorageMockRecorder) GetCRL(ctx, tx, req interface{}) *gomock.Call
- func (mr *MockCertStorageMockRecorder) RevokeRootCert(ctx, tx, ts, fingerPrinter interface{}) *gomock.Call
- type MockOffsetStorage
- func (m *MockOffsetStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockOffsetStorage) EXPECT() *MockOffsetStorageMockRecorder
- func (m *MockOffsetStorage) GetRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string) (int64, error)
- func (m *MockOffsetStorage) UpdateRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string, offset int64) error
- type MockOffsetStorageMockRecorder
- func (mr *MockOffsetStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockOffsetStorageMockRecorder) GetRelayServerOffset(ctx, tx, serverID interface{}) *gomock.Call
- func (mr *MockOffsetStorageMockRecorder) UpdateRelayServerOffset(ctx, tx, serverID, offset interface{}) *gomock.Call
- type MockResult
- type MockResultMockRecorder
- type MockRow
- type MockRowMockRecorder
- type MockRows
- type MockRowsMockRecorder
- type MockTradeDocumentInboxStorage
- func (m *MockTradeDocumentInboxStorage) AddTradeDocument(ctx context.Context, tx storage.Tx, tradeDoc storage.TradeDocument) error
- func (m *MockTradeDocumentInboxStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockTradeDocumentInboxStorage) EXPECT() *MockTradeDocumentInboxStorageMockRecorder
- func (m *MockTradeDocumentInboxStorage) GetRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string) (int64, error)
- func (m *MockTradeDocumentInboxStorage) ListAuthentication(ctx context.Context, tx storage.Tx, req storage.ListAuthenticationRequest) (storage.ListAuthenticationResult, error)
- func (m *MockTradeDocumentInboxStorage) UpdateRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string, offset int64) error
- type MockTradeDocumentInboxStorageMockRecorder
- func (mr *MockTradeDocumentInboxStorageMockRecorder) AddTradeDocument(ctx, tx, tradeDoc interface{}) *gomock.Call
- func (mr *MockTradeDocumentInboxStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockTradeDocumentInboxStorageMockRecorder) GetRelayServerOffset(ctx, tx, serverID interface{}) *gomock.Call
- func (mr *MockTradeDocumentInboxStorageMockRecorder) ListAuthentication(ctx, tx, req interface{}) *gomock.Call
- func (mr *MockTradeDocumentInboxStorageMockRecorder) UpdateRelayServerOffset(ctx, tx, serverID, offset interface{}) *gomock.Call
- type MockTradeDocumentOutboxStorage
- func (m *MockTradeDocumentOutboxStorage) AddTradeDocumentOutbox(ctx context.Context, tx storage.Tx, ts int64, key string, kind int, ...) error
- func (m *MockTradeDocumentOutboxStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockTradeDocumentOutboxStorage) DeleteTradeDocumentOutbox(ctx context.Context, tx storage.Tx, recIDs ...int64) error
- func (m *MockTradeDocumentOutboxStorage) EXPECT() *MockTradeDocumentOutboxStorageMockRecorder
- func (m *MockTradeDocumentOutboxStorage) GetTradeDocumentOutbox(ctx context.Context, tx storage.Tx, batchSize int) ([]storage.OutboxMsg, error)
- type MockTradeDocumentOutboxStorageMockRecorder
- func (mr *MockTradeDocumentOutboxStorageMockRecorder) AddTradeDocumentOutbox(ctx, tx, ts, key, kind, payload interface{}) *gomock.Call
- func (mr *MockTradeDocumentOutboxStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockTradeDocumentOutboxStorageMockRecorder) DeleteTradeDocumentOutbox(ctx, tx interface{}, recIDs ...interface{}) *gomock.Call
- func (mr *MockTradeDocumentOutboxStorageMockRecorder) GetTradeDocumentOutbox(ctx, tx, batchSize interface{}) *gomock.Call
- type MockTradeDocumentStorage
- func (m *MockTradeDocumentStorage) AddTradeDocument(ctx context.Context, tx storage.Tx, tradeDoc storage.TradeDocument) error
- func (m *MockTradeDocumentStorage) AddTradeDocumentOutbox(ctx context.Context, tx storage.Tx, ts int64, key string, kind int, ...) error
- func (m *MockTradeDocumentStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockTradeDocumentStorage) EXPECT() *MockTradeDocumentStorageMockRecorder
- func (m *MockTradeDocumentStorage) ListTradeDocument(ctx context.Context, tx storage.Tx, req storage.ListTradeDocumentRequest) (storage.ListTradeDocumentResponse, error)
- type MockTradeDocumentStorageMockRecorder
- func (mr *MockTradeDocumentStorageMockRecorder) AddTradeDocument(ctx, tx, tradeDoc interface{}) *gomock.Call
- func (mr *MockTradeDocumentStorageMockRecorder) AddTradeDocumentOutbox(ctx, tx, ts, key, kind, payload interface{}) *gomock.Call
- func (mr *MockTradeDocumentStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockTradeDocumentStorageMockRecorder) ListTradeDocument(ctx, tx, req interface{}) *gomock.Call
- type MockTransactionInterface
- type MockTransactionInterfaceMockRecorder
- type MockTx
- func (m *MockTx) Commit(ctx context.Context) error
- func (m *MockTx) EXPECT() *MockTxMockRecorder
- func (m *MockTx) Exec(ctx context.Context, sql string, arguments ...any) (storage.Result, error)
- func (m *MockTx) Query(ctx context.Context, sql string, args ...any) (storage.Rows, error)
- func (m *MockTx) QueryRow(ctx context.Context, sql string, args ...any) storage.Row
- func (m *MockTx) Rollback(ctx context.Context) error
- type MockTxMockRecorder
- func (mr *MockTxMockRecorder) Commit(ctx interface{}) *gomock.Call
- func (mr *MockTxMockRecorder) Exec(ctx, sql interface{}, arguments ...interface{}) *gomock.Call
- func (mr *MockTxMockRecorder) Query(ctx, sql interface{}, args ...interface{}) *gomock.Call
- func (mr *MockTxMockRecorder) QueryRow(ctx, sql interface{}, args ...interface{}) *gomock.Call
- func (mr *MockTxMockRecorder) Rollback(ctx interface{}) *gomock.Call
- type MockWebhookStorage
- func (m *MockWebhookStorage) AddWebhook(ctx context.Context, tx storage.Tx, webhook model.Webhook) error
- func (m *MockWebhookStorage) AddWebhookEvent(ctx context.Context, tx storage.Tx, ts int64, key string, ...) error
- func (m *MockWebhookStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
- func (m *MockWebhookStorage) DeleteWebhookEvent(ctx context.Context, tx storage.Tx, recIDs ...int64) error
- func (m *MockWebhookStorage) EXPECT() *MockWebhookStorageMockRecorder
- func (m *MockWebhookStorage) GetWebhookEvent(ctx context.Context, tx storage.Tx, batchSize int) ([]storage.OutboxMsg, error)
- func (m *MockWebhookStorage) ListWebhook(ctx context.Context, tx storage.Tx, req storage.ListWebhookRequest) (storage.ListWebhookResult, error)
- type MockWebhookStorageMockRecorder
- func (mr *MockWebhookStorageMockRecorder) AddWebhook(ctx, tx, webhook interface{}) *gomock.Call
- func (mr *MockWebhookStorageMockRecorder) AddWebhookEvent(ctx, tx, ts, key, event interface{}) *gomock.Call
- func (mr *MockWebhookStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
- func (mr *MockWebhookStorageMockRecorder) DeleteWebhookEvent(ctx, tx interface{}, recIDs ...interface{}) *gomock.Call
- func (mr *MockWebhookStorageMockRecorder) GetWebhookEvent(ctx, tx, batchSize interface{}) *gomock.Call
- func (mr *MockWebhookStorageMockRecorder) ListWebhook(ctx, tx, req interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBusinessUnitStorage ¶
type MockBusinessUnitStorage struct {
// contains filtered or unexported fields
}
MockBusinessUnitStorage is a mock of BusinessUnitStorage interface.
func NewMockBusinessUnitStorage ¶
func NewMockBusinessUnitStorage(ctrl *gomock.Controller) *MockBusinessUnitStorage
NewMockBusinessUnitStorage creates a new mock instance.
func (*MockBusinessUnitStorage) CreateTx ¶
func (m *MockBusinessUnitStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockBusinessUnitStorage) EXPECT ¶
func (m *MockBusinessUnitStorage) EXPECT() *MockBusinessUnitStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBusinessUnitStorage) ListAuthentication ¶
func (m *MockBusinessUnitStorage) ListAuthentication(ctx context.Context, tx storage.Tx, req storage.ListAuthenticationRequest) (storage.ListAuthenticationResult, error)
ListAuthentication mocks base method.
func (*MockBusinessUnitStorage) ListBusinessUnits ¶
func (m *MockBusinessUnitStorage) ListBusinessUnits(ctx context.Context, tx storage.Tx, req storage.ListBusinessUnitsRequest) (storage.ListBusinessUnitsResult, error)
ListBusinessUnits mocks base method.
func (*MockBusinessUnitStorage) StoreAuthentication ¶
func (m *MockBusinessUnitStorage) StoreAuthentication(ctx context.Context, tx storage.Tx, auth model.BusinessUnitAuthentication) error
StoreAuthentication mocks base method.
func (*MockBusinessUnitStorage) StoreBusinessUnit ¶
func (m *MockBusinessUnitStorage) StoreBusinessUnit(ctx context.Context, tx storage.Tx, bu model.BusinessUnit) error
StoreBusinessUnit mocks base method.
type MockBusinessUnitStorageMockRecorder ¶
type MockBusinessUnitStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockBusinessUnitStorageMockRecorder is the mock recorder for MockBusinessUnitStorage.
func (*MockBusinessUnitStorageMockRecorder) CreateTx ¶
func (mr *MockBusinessUnitStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockBusinessUnitStorageMockRecorder) ListAuthentication ¶
func (mr *MockBusinessUnitStorageMockRecorder) ListAuthentication(ctx, tx, req interface{}) *gomock.Call
ListAuthentication indicates an expected call of ListAuthentication.
func (*MockBusinessUnitStorageMockRecorder) ListBusinessUnits ¶
func (mr *MockBusinessUnitStorageMockRecorder) ListBusinessUnits(ctx, tx, req interface{}) *gomock.Call
ListBusinessUnits indicates an expected call of ListBusinessUnits.
func (*MockBusinessUnitStorageMockRecorder) StoreAuthentication ¶
func (mr *MockBusinessUnitStorageMockRecorder) StoreAuthentication(ctx, tx, auth interface{}) *gomock.Call
StoreAuthentication indicates an expected call of StoreAuthentication.
func (*MockBusinessUnitStorageMockRecorder) StoreBusinessUnit ¶
func (mr *MockBusinessUnitStorageMockRecorder) StoreBusinessUnit(ctx, tx, bu interface{}) *gomock.Call
StoreBusinessUnit indicates an expected call of StoreBusinessUnit.
type MockCertStorage ¶
type MockCertStorage struct {
// contains filtered or unexported fields
}
MockCertStorage is a mock of CertStorage interface.
func NewMockCertStorage ¶
func NewMockCertStorage(ctrl *gomock.Controller) *MockCertStorage
NewMockCertStorage creates a new mock instance.
func (*MockCertStorage) AddCRL ¶
func (m *MockCertStorage) AddCRL(ctx context.Context, tx storage.Tx, ts int64, issuerKeyID, certSerialNumber string, revokedAt int64, crl []byte) error
AddCRL mocks base method.
func (*MockCertStorage) AddRootCert ¶
func (m *MockCertStorage) AddRootCert(ctx context.Context, tx storage.Tx, ts int64, fingerPrint string, cert []byte) error
AddRootCert mocks base method.
func (*MockCertStorage) CreateTx ¶
func (m *MockCertStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockCertStorage) EXPECT ¶
func (m *MockCertStorage) EXPECT() *MockCertStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCertStorage) GetActiveRootCert ¶
GetActiveRootCert mocks base method.
func (*MockCertStorage) GetCRL ¶
func (m *MockCertStorage) GetCRL(ctx context.Context, tx storage.Tx, req storage.GetCRLRequest) (storage.GetCRLResult, error)
GetCRL mocks base method.
func (*MockCertStorage) RevokeRootCert ¶
func (m *MockCertStorage) RevokeRootCert(ctx context.Context, tx storage.Tx, ts int64, fingerPrinter string) error
RevokeRootCert mocks base method.
type MockCertStorageMockRecorder ¶
type MockCertStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockCertStorageMockRecorder is the mock recorder for MockCertStorage.
func (*MockCertStorageMockRecorder) AddCRL ¶
func (mr *MockCertStorageMockRecorder) AddCRL(ctx, tx, ts, issuerKeyID, certSerialNumber, revokedAt, crl interface{}) *gomock.Call
AddCRL indicates an expected call of AddCRL.
func (*MockCertStorageMockRecorder) AddRootCert ¶
func (mr *MockCertStorageMockRecorder) AddRootCert(ctx, tx, ts, fingerPrint, cert interface{}) *gomock.Call
AddRootCert indicates an expected call of AddRootCert.
func (*MockCertStorageMockRecorder) CreateTx ¶
func (mr *MockCertStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockCertStorageMockRecorder) GetActiveRootCert ¶
func (mr *MockCertStorageMockRecorder) GetActiveRootCert(ctx, tx interface{}) *gomock.Call
GetActiveRootCert indicates an expected call of GetActiveRootCert.
func (*MockCertStorageMockRecorder) GetCRL ¶
func (mr *MockCertStorageMockRecorder) GetCRL(ctx, tx, req interface{}) *gomock.Call
GetCRL indicates an expected call of GetCRL.
func (*MockCertStorageMockRecorder) RevokeRootCert ¶
func (mr *MockCertStorageMockRecorder) RevokeRootCert(ctx, tx, ts, fingerPrinter interface{}) *gomock.Call
RevokeRootCert indicates an expected call of RevokeRootCert.
type MockOffsetStorage ¶
type MockOffsetStorage struct {
// contains filtered or unexported fields
}
MockOffsetStorage is a mock of OffsetStorage interface.
func NewMockOffsetStorage ¶
func NewMockOffsetStorage(ctrl *gomock.Controller) *MockOffsetStorage
NewMockOffsetStorage creates a new mock instance.
func (*MockOffsetStorage) CreateTx ¶
func (m *MockOffsetStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockOffsetStorage) EXPECT ¶
func (m *MockOffsetStorage) EXPECT() *MockOffsetStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockOffsetStorage) GetRelayServerOffset ¶
func (m *MockOffsetStorage) GetRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string) (int64, error)
GetRelayServerOffset mocks base method.
func (*MockOffsetStorage) UpdateRelayServerOffset ¶
func (m *MockOffsetStorage) UpdateRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string, offset int64) error
UpdateRelayServerOffset mocks base method.
type MockOffsetStorageMockRecorder ¶
type MockOffsetStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockOffsetStorageMockRecorder is the mock recorder for MockOffsetStorage.
func (*MockOffsetStorageMockRecorder) CreateTx ¶
func (mr *MockOffsetStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockOffsetStorageMockRecorder) GetRelayServerOffset ¶
func (mr *MockOffsetStorageMockRecorder) GetRelayServerOffset(ctx, tx, serverID interface{}) *gomock.Call
GetRelayServerOffset indicates an expected call of GetRelayServerOffset.
func (*MockOffsetStorageMockRecorder) UpdateRelayServerOffset ¶
func (mr *MockOffsetStorageMockRecorder) UpdateRelayServerOffset(ctx, tx, serverID, offset interface{}) *gomock.Call
UpdateRelayServerOffset indicates an expected call of UpdateRelayServerOffset.
type MockResult ¶
type MockResult struct {
// contains filtered or unexported fields
}
MockResult is a mock of Result interface.
func NewMockResult ¶
func NewMockResult(ctrl *gomock.Controller) *MockResult
NewMockResult creates a new mock instance.
func (*MockResult) EXPECT ¶
func (m *MockResult) EXPECT() *MockResultMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockResult) RowsAffected ¶
func (m *MockResult) RowsAffected() (int64, error)
RowsAffected mocks base method.
type MockResultMockRecorder ¶
type MockResultMockRecorder struct {
// contains filtered or unexported fields
}
MockResultMockRecorder is the mock recorder for MockResult.
func (*MockResultMockRecorder) RowsAffected ¶
func (mr *MockResultMockRecorder) RowsAffected() *gomock.Call
RowsAffected indicates an expected call of RowsAffected.
type MockRow ¶
type MockRow struct {
// contains filtered or unexported fields
}
MockRow is a mock of Row interface.
func NewMockRow ¶
func NewMockRow(ctrl *gomock.Controller) *MockRow
NewMockRow creates a new mock instance.
func (*MockRow) EXPECT ¶
func (m *MockRow) EXPECT() *MockRowMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockRowMockRecorder ¶
type MockRowMockRecorder struct {
// contains filtered or unexported fields
}
MockRowMockRecorder is the mock recorder for MockRow.
func (*MockRowMockRecorder) Scan ¶
func (mr *MockRowMockRecorder) Scan(dest ...interface{}) *gomock.Call
Scan indicates an expected call of Scan.
type MockRows ¶
type MockRows struct {
// contains filtered or unexported fields
}
MockRows is a mock of Rows interface.
func NewMockRows ¶
func NewMockRows(ctrl *gomock.Controller) *MockRows
NewMockRows creates a new mock instance.
func (*MockRows) EXPECT ¶
func (m *MockRows) EXPECT() *MockRowsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockRowsMockRecorder ¶
type MockRowsMockRecorder struct {
// contains filtered or unexported fields
}
MockRowsMockRecorder is the mock recorder for MockRows.
func (*MockRowsMockRecorder) Close ¶
func (mr *MockRowsMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockRowsMockRecorder) Err ¶
func (mr *MockRowsMockRecorder) Err() *gomock.Call
Err indicates an expected call of Err.
func (*MockRowsMockRecorder) Next ¶
func (mr *MockRowsMockRecorder) Next() *gomock.Call
Next indicates an expected call of Next.
func (*MockRowsMockRecorder) Scan ¶
func (mr *MockRowsMockRecorder) Scan(dest ...interface{}) *gomock.Call
Scan indicates an expected call of Scan.
type MockTradeDocumentInboxStorage ¶
type MockTradeDocumentInboxStorage struct {
// contains filtered or unexported fields
}
MockTradeDocumentInboxStorage is a mock of TradeDocumentInboxStorage interface.
func NewMockTradeDocumentInboxStorage ¶
func NewMockTradeDocumentInboxStorage(ctrl *gomock.Controller) *MockTradeDocumentInboxStorage
NewMockTradeDocumentInboxStorage creates a new mock instance.
func (*MockTradeDocumentInboxStorage) AddTradeDocument ¶
func (m *MockTradeDocumentInboxStorage) AddTradeDocument(ctx context.Context, tx storage.Tx, tradeDoc storage.TradeDocument) error
AddTradeDocument mocks base method.
func (*MockTradeDocumentInboxStorage) CreateTx ¶
func (m *MockTradeDocumentInboxStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockTradeDocumentInboxStorage) EXPECT ¶
func (m *MockTradeDocumentInboxStorage) EXPECT() *MockTradeDocumentInboxStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTradeDocumentInboxStorage) GetRelayServerOffset ¶
func (m *MockTradeDocumentInboxStorage) GetRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string) (int64, error)
GetRelayServerOffset mocks base method.
func (*MockTradeDocumentInboxStorage) ListAuthentication ¶
func (m *MockTradeDocumentInboxStorage) ListAuthentication(ctx context.Context, tx storage.Tx, req storage.ListAuthenticationRequest) (storage.ListAuthenticationResult, error)
ListAuthentication mocks base method.
func (*MockTradeDocumentInboxStorage) UpdateRelayServerOffset ¶
func (m *MockTradeDocumentInboxStorage) UpdateRelayServerOffset(ctx context.Context, tx storage.Tx, serverID string, offset int64) error
UpdateRelayServerOffset mocks base method.
type MockTradeDocumentInboxStorageMockRecorder ¶
type MockTradeDocumentInboxStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockTradeDocumentInboxStorageMockRecorder is the mock recorder for MockTradeDocumentInboxStorage.
func (*MockTradeDocumentInboxStorageMockRecorder) AddTradeDocument ¶
func (mr *MockTradeDocumentInboxStorageMockRecorder) AddTradeDocument(ctx, tx, tradeDoc interface{}) *gomock.Call
AddTradeDocument indicates an expected call of AddTradeDocument.
func (*MockTradeDocumentInboxStorageMockRecorder) CreateTx ¶
func (mr *MockTradeDocumentInboxStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockTradeDocumentInboxStorageMockRecorder) GetRelayServerOffset ¶
func (mr *MockTradeDocumentInboxStorageMockRecorder) GetRelayServerOffset(ctx, tx, serverID interface{}) *gomock.Call
GetRelayServerOffset indicates an expected call of GetRelayServerOffset.
func (*MockTradeDocumentInboxStorageMockRecorder) ListAuthentication ¶
func (mr *MockTradeDocumentInboxStorageMockRecorder) ListAuthentication(ctx, tx, req interface{}) *gomock.Call
ListAuthentication indicates an expected call of ListAuthentication.
func (*MockTradeDocumentInboxStorageMockRecorder) UpdateRelayServerOffset ¶
func (mr *MockTradeDocumentInboxStorageMockRecorder) UpdateRelayServerOffset(ctx, tx, serverID, offset interface{}) *gomock.Call
UpdateRelayServerOffset indicates an expected call of UpdateRelayServerOffset.
type MockTradeDocumentOutboxStorage ¶
type MockTradeDocumentOutboxStorage struct {
// contains filtered or unexported fields
}
MockTradeDocumentOutboxStorage is a mock of TradeDocumentOutboxStorage interface.
func NewMockTradeDocumentOutboxStorage ¶
func NewMockTradeDocumentOutboxStorage(ctrl *gomock.Controller) *MockTradeDocumentOutboxStorage
NewMockTradeDocumentOutboxStorage creates a new mock instance.
func (*MockTradeDocumentOutboxStorage) AddTradeDocumentOutbox ¶
func (m *MockTradeDocumentOutboxStorage) AddTradeDocumentOutbox(ctx context.Context, tx storage.Tx, ts int64, key string, kind int, payload []byte) error
AddTradeDocumentOutbox mocks base method.
func (*MockTradeDocumentOutboxStorage) CreateTx ¶
func (m *MockTradeDocumentOutboxStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockTradeDocumentOutboxStorage) DeleteTradeDocumentOutbox ¶
func (m *MockTradeDocumentOutboxStorage) DeleteTradeDocumentOutbox(ctx context.Context, tx storage.Tx, recIDs ...int64) error
DeleteTradeDocumentOutbox mocks base method.
func (*MockTradeDocumentOutboxStorage) EXPECT ¶
func (m *MockTradeDocumentOutboxStorage) EXPECT() *MockTradeDocumentOutboxStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTradeDocumentOutboxStorageMockRecorder ¶
type MockTradeDocumentOutboxStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockTradeDocumentOutboxStorageMockRecorder is the mock recorder for MockTradeDocumentOutboxStorage.
func (*MockTradeDocumentOutboxStorageMockRecorder) AddTradeDocumentOutbox ¶
func (mr *MockTradeDocumentOutboxStorageMockRecorder) AddTradeDocumentOutbox(ctx, tx, ts, key, kind, payload interface{}) *gomock.Call
AddTradeDocumentOutbox indicates an expected call of AddTradeDocumentOutbox.
func (*MockTradeDocumentOutboxStorageMockRecorder) CreateTx ¶
func (mr *MockTradeDocumentOutboxStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockTradeDocumentOutboxStorageMockRecorder) DeleteTradeDocumentOutbox ¶
func (mr *MockTradeDocumentOutboxStorageMockRecorder) DeleteTradeDocumentOutbox(ctx, tx interface{}, recIDs ...interface{}) *gomock.Call
DeleteTradeDocumentOutbox indicates an expected call of DeleteTradeDocumentOutbox.
func (*MockTradeDocumentOutboxStorageMockRecorder) GetTradeDocumentOutbox ¶
func (mr *MockTradeDocumentOutboxStorageMockRecorder) GetTradeDocumentOutbox(ctx, tx, batchSize interface{}) *gomock.Call
GetTradeDocumentOutbox indicates an expected call of GetTradeDocumentOutbox.
type MockTradeDocumentStorage ¶
type MockTradeDocumentStorage struct {
// contains filtered or unexported fields
}
MockTradeDocumentStorage is a mock of TradeDocumentStorage interface.
func NewMockTradeDocumentStorage ¶
func NewMockTradeDocumentStorage(ctrl *gomock.Controller) *MockTradeDocumentStorage
NewMockTradeDocumentStorage creates a new mock instance.
func (*MockTradeDocumentStorage) AddTradeDocument ¶
func (m *MockTradeDocumentStorage) AddTradeDocument(ctx context.Context, tx storage.Tx, tradeDoc storage.TradeDocument) error
AddTradeDocument mocks base method.
func (*MockTradeDocumentStorage) AddTradeDocumentOutbox ¶
func (m *MockTradeDocumentStorage) AddTradeDocumentOutbox(ctx context.Context, tx storage.Tx, ts int64, key string, kind int, payload []byte) error
AddTradeDocumentOutbox mocks base method.
func (*MockTradeDocumentStorage) CreateTx ¶
func (m *MockTradeDocumentStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockTradeDocumentStorage) EXPECT ¶
func (m *MockTradeDocumentStorage) EXPECT() *MockTradeDocumentStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTradeDocumentStorage) ListTradeDocument ¶
func (m *MockTradeDocumentStorage) ListTradeDocument(ctx context.Context, tx storage.Tx, req storage.ListTradeDocumentRequest) (storage.ListTradeDocumentResponse, error)
ListTradeDocument mocks base method.
type MockTradeDocumentStorageMockRecorder ¶
type MockTradeDocumentStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockTradeDocumentStorageMockRecorder is the mock recorder for MockTradeDocumentStorage.
func (*MockTradeDocumentStorageMockRecorder) AddTradeDocument ¶
func (mr *MockTradeDocumentStorageMockRecorder) AddTradeDocument(ctx, tx, tradeDoc interface{}) *gomock.Call
AddTradeDocument indicates an expected call of AddTradeDocument.
func (*MockTradeDocumentStorageMockRecorder) AddTradeDocumentOutbox ¶
func (mr *MockTradeDocumentStorageMockRecorder) AddTradeDocumentOutbox(ctx, tx, ts, key, kind, payload interface{}) *gomock.Call
AddTradeDocumentOutbox indicates an expected call of AddTradeDocumentOutbox.
func (*MockTradeDocumentStorageMockRecorder) CreateTx ¶
func (mr *MockTradeDocumentStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockTradeDocumentStorageMockRecorder) ListTradeDocument ¶
func (mr *MockTradeDocumentStorageMockRecorder) ListTradeDocument(ctx, tx, req interface{}) *gomock.Call
ListTradeDocument indicates an expected call of ListTradeDocument.
type MockTransactionInterface ¶
type MockTransactionInterface struct {
// contains filtered or unexported fields
}
MockTransactionInterface is a mock of TransactionInterface interface.
func NewMockTransactionInterface ¶
func NewMockTransactionInterface(ctrl *gomock.Controller) *MockTransactionInterface
NewMockTransactionInterface creates a new mock instance.
func (*MockTransactionInterface) CreateTx ¶
func (m *MockTransactionInterface) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockTransactionInterface) EXPECT ¶
func (m *MockTransactionInterface) EXPECT() *MockTransactionInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTransactionInterfaceMockRecorder ¶
type MockTransactionInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockTransactionInterfaceMockRecorder is the mock recorder for MockTransactionInterface.
func (*MockTransactionInterfaceMockRecorder) CreateTx ¶
func (mr *MockTransactionInterfaceMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
type MockTx ¶
type MockTx struct {
// contains filtered or unexported fields
}
MockTx is a mock of Tx interface.
func NewMockTx ¶
func NewMockTx(ctrl *gomock.Controller) *MockTx
NewMockTx creates a new mock instance.
func (*MockTx) EXPECT ¶
func (m *MockTx) EXPECT() *MockTxMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTxMockRecorder ¶
type MockTxMockRecorder struct {
// contains filtered or unexported fields
}
MockTxMockRecorder is the mock recorder for MockTx.
func (*MockTxMockRecorder) Commit ¶
func (mr *MockTxMockRecorder) Commit(ctx interface{}) *gomock.Call
Commit indicates an expected call of Commit.
func (*MockTxMockRecorder) Exec ¶
func (mr *MockTxMockRecorder) Exec(ctx, sql interface{}, arguments ...interface{}) *gomock.Call
Exec indicates an expected call of Exec.
func (*MockTxMockRecorder) Query ¶
func (mr *MockTxMockRecorder) Query(ctx, sql interface{}, args ...interface{}) *gomock.Call
Query indicates an expected call of Query.
func (*MockTxMockRecorder) QueryRow ¶
func (mr *MockTxMockRecorder) QueryRow(ctx, sql interface{}, args ...interface{}) *gomock.Call
QueryRow indicates an expected call of QueryRow.
func (*MockTxMockRecorder) Rollback ¶
func (mr *MockTxMockRecorder) Rollback(ctx interface{}) *gomock.Call
Rollback indicates an expected call of Rollback.
type MockWebhookStorage ¶
type MockWebhookStorage struct {
// contains filtered or unexported fields
}
MockWebhookStorage is a mock of WebhookStorage interface.
func NewMockWebhookStorage ¶
func NewMockWebhookStorage(ctrl *gomock.Controller) *MockWebhookStorage
NewMockWebhookStorage creates a new mock instance.
func (*MockWebhookStorage) AddWebhook ¶
func (m *MockWebhookStorage) AddWebhook(ctx context.Context, tx storage.Tx, webhook model.Webhook) error
AddWebhook mocks base method.
func (*MockWebhookStorage) AddWebhookEvent ¶
func (m *MockWebhookStorage) AddWebhookEvent(ctx context.Context, tx storage.Tx, ts int64, key string, event *model.WebhookEvent) error
AddWebhookEvent mocks base method.
func (*MockWebhookStorage) CreateTx ¶
func (m *MockWebhookStorage) CreateTx(ctx context.Context, options ...storage.CreateTxOption) (storage.Tx, context.Context, error)
CreateTx mocks base method.
func (*MockWebhookStorage) DeleteWebhookEvent ¶
func (m *MockWebhookStorage) DeleteWebhookEvent(ctx context.Context, tx storage.Tx, recIDs ...int64) error
DeleteWebhookEvent mocks base method.
func (*MockWebhookStorage) EXPECT ¶
func (m *MockWebhookStorage) EXPECT() *MockWebhookStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWebhookStorage) GetWebhookEvent ¶
func (m *MockWebhookStorage) GetWebhookEvent(ctx context.Context, tx storage.Tx, batchSize int) ([]storage.OutboxMsg, error)
GetWebhookEvent mocks base method.
func (*MockWebhookStorage) ListWebhook ¶
func (m *MockWebhookStorage) ListWebhook(ctx context.Context, tx storage.Tx, req storage.ListWebhookRequest) (storage.ListWebhookResult, error)
ListWebhook mocks base method.
type MockWebhookStorageMockRecorder ¶
type MockWebhookStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockWebhookStorageMockRecorder is the mock recorder for MockWebhookStorage.
func (*MockWebhookStorageMockRecorder) AddWebhook ¶
func (mr *MockWebhookStorageMockRecorder) AddWebhook(ctx, tx, webhook interface{}) *gomock.Call
AddWebhook indicates an expected call of AddWebhook.
func (*MockWebhookStorageMockRecorder) AddWebhookEvent ¶
func (mr *MockWebhookStorageMockRecorder) AddWebhookEvent(ctx, tx, ts, key, event interface{}) *gomock.Call
AddWebhookEvent indicates an expected call of AddWebhookEvent.
func (*MockWebhookStorageMockRecorder) CreateTx ¶
func (mr *MockWebhookStorageMockRecorder) CreateTx(ctx interface{}, options ...interface{}) *gomock.Call
CreateTx indicates an expected call of CreateTx.
func (*MockWebhookStorageMockRecorder) DeleteWebhookEvent ¶
func (mr *MockWebhookStorageMockRecorder) DeleteWebhookEvent(ctx, tx interface{}, recIDs ...interface{}) *gomock.Call
DeleteWebhookEvent indicates an expected call of DeleteWebhookEvent.
func (*MockWebhookStorageMockRecorder) GetWebhookEvent ¶
func (mr *MockWebhookStorageMockRecorder) GetWebhookEvent(ctx, tx, batchSize interface{}) *gomock.Call
GetWebhookEvent indicates an expected call of GetWebhookEvent.
func (*MockWebhookStorageMockRecorder) ListWebhook ¶
func (mr *MockWebhookStorageMockRecorder) ListWebhook(ctx, tx, req interface{}) *gomock.Call
ListWebhook indicates an expected call of ListWebhook.