Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockConsumerInput
- func (m *MockConsumerInput) DownFn(ctx context.Context, payload types.PayloadInput) error
- func (m *MockConsumerInput) EXPECT() *MockConsumerInputMockRecorder
- func (m *MockConsumerInput) GetConfig() types.Opts
- func (m *MockConsumerInput) GetEventName() string
- func (m *MockConsumerInput) UpFn(ctx context.Context, payload types.PayloadInput) error
- type MockConsumerInputMockRecorder
- type MockLogger
- type MockLoggerMockRecorder
- func (mr *MockLoggerMockRecorder) Debug(msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Error(msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Info(msg any, keysAndValues ...any) *gomock.Call
- func (mr *MockLoggerMockRecorder) Warn(msg any, keysAndValues ...any) *gomock.Call
- type MockProducer
- type MockProducerMockRecorder
- type MockRepository
- func (m *MockRepository) Close()
- func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
- func (m *MockRepository) SagaSaveTx(ctx context.Context, input types.PayloadType) error
- func (m *MockRepository) SagaUpdateInfos(ctx context.Context, txID uuid.UUID, retry int, status string) error
- func (m *MockRepository) SaveTx(ctx context.Context, input types.PayloadType) error
- func (m *MockRepository) UpdateInfos(ctx context.Context, txID uuid.UUID, retry int, status string) error
- type MockRepositoryMockRecorder
- func (mr *MockRepositoryMockRecorder) Close() *gomock.Call
- func (mr *MockRepositoryMockRecorder) SagaSaveTx(ctx, input any) *gomock.Call
- func (mr *MockRepositoryMockRecorder) SagaUpdateInfos(ctx, txID, retry, status any) *gomock.Call
- func (mr *MockRepositoryMockRecorder) SaveTx(ctx, input any) *gomock.Call
- func (mr *MockRepositoryMockRecorder) UpdateInfos(ctx, txID, retry, status any) *gomock.Call
- type MockTimeProvider
- type MockTimeProviderMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumerInput ¶
type MockConsumerInput struct {
// contains filtered or unexported fields
}
MockConsumerInput is a mock of ConsumerInput interface.
func NewMockConsumerInput ¶
func NewMockConsumerInput(ctrl *gomock.Controller) *MockConsumerInput
NewMockConsumerInput creates a new mock instance.
func (*MockConsumerInput) DownFn ¶
func (m *MockConsumerInput) DownFn(ctx context.Context, payload types.PayloadInput) error
DownFn mocks base method.
func (*MockConsumerInput) EXPECT ¶
func (m *MockConsumerInput) EXPECT() *MockConsumerInputMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConsumerInput) GetConfig ¶
func (m *MockConsumerInput) GetConfig() types.Opts
GetConfig mocks base method.
func (*MockConsumerInput) GetEventName ¶
func (m *MockConsumerInput) GetEventName() string
GetEventName mocks base method.
func (*MockConsumerInput) UpFn ¶
func (m *MockConsumerInput) UpFn(ctx context.Context, payload types.PayloadInput) error
UpFn mocks base method.
type MockConsumerInputMockRecorder ¶
type MockConsumerInputMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerInputMockRecorder is the mock recorder for MockConsumerInput.
func (*MockConsumerInputMockRecorder) DownFn ¶
func (mr *MockConsumerInputMockRecorder) DownFn(ctx, payload any) *gomock.Call
DownFn indicates an expected call of DownFn.
func (*MockConsumerInputMockRecorder) GetConfig ¶
func (mr *MockConsumerInputMockRecorder) GetConfig() *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockConsumerInputMockRecorder) GetEventName ¶
func (mr *MockConsumerInputMockRecorder) GetEventName() *gomock.Call
GetEventName indicates an expected call of GetEventName.
type MockLogger ¶
type MockLogger struct {
// contains filtered or unexported fields
}
MockLogger is a mock of Logger interface.
func NewMockLogger ¶
func NewMockLogger(ctrl *gomock.Controller) *MockLogger
NewMockLogger creates a new mock instance.
func (*MockLogger) Debug ¶
func (m *MockLogger) Debug(msg string, keysAndValues ...any)
Debug mocks base method.
func (*MockLogger) EXPECT ¶
func (m *MockLogger) EXPECT() *MockLoggerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockLogger) Error ¶
func (m *MockLogger) Error(msg string, keysAndValues ...any)
Error mocks base method.
func (*MockLogger) Info ¶
func (m *MockLogger) Info(msg string, keysAndValues ...any)
Info mocks base method.
func (*MockLogger) Warn ¶
func (m *MockLogger) Warn(msg string, keysAndValues ...any)
Warn mocks base method.
type MockLoggerMockRecorder ¶
type MockLoggerMockRecorder struct {
// contains filtered or unexported fields
}
MockLoggerMockRecorder is the mock recorder for MockLogger.
func (*MockLoggerMockRecorder) Debug ¶
func (mr *MockLoggerMockRecorder) Debug(msg any, keysAndValues ...any) *gomock.Call
Debug indicates an expected call of Debug.
func (*MockLoggerMockRecorder) Error ¶
func (mr *MockLoggerMockRecorder) Error(msg any, keysAndValues ...any) *gomock.Call
Error indicates an expected call of Error.
type MockProducer ¶
type MockProducer struct {
// contains filtered or unexported fields
}
MockProducer is a mock of Producer interface.
func NewMockProducer ¶
func NewMockProducer(ctrl *gomock.Controller) *MockProducer
NewMockProducer creates a new mock instance.
func (*MockProducer) EXPECT ¶
func (m *MockProducer) EXPECT() *MockProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProducer) GenerateEventID ¶
func (m *MockProducer) GenerateEventID() uuid.UUID
GenerateEventID mocks base method.
func (*MockProducer) Producer ¶
func (m *MockProducer) Producer(ctx context.Context, input types.PayloadType) error
Producer mocks base method.
type MockProducerMockRecorder ¶
type MockProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockProducerMockRecorder is the mock recorder for MockProducer.
func (*MockProducerMockRecorder) Close ¶
func (mr *MockProducerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockProducerMockRecorder) GenerateEventID ¶
func (mr *MockProducerMockRecorder) GenerateEventID() *gomock.Call
GenerateEventID indicates an expected call of GenerateEventID.
type MockRepository ¶
type MockRepository struct {
// contains filtered or unexported fields
}
MockRepository is a mock of Repository interface.
func NewMockRepository ¶
func NewMockRepository(ctrl *gomock.Controller) *MockRepository
NewMockRepository creates a new mock instance.
func (*MockRepository) EXPECT ¶
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRepository) SagaSaveTx ¶
func (m *MockRepository) SagaSaveTx(ctx context.Context, input types.PayloadType) error
SagaSaveTx mocks base method.
func (*MockRepository) SagaUpdateInfos ¶
func (m *MockRepository) SagaUpdateInfos(ctx context.Context, txID uuid.UUID, retry int, status string) error
SagaUpdateInfos mocks base method.
func (*MockRepository) SaveTx ¶
func (m *MockRepository) SaveTx(ctx context.Context, input types.PayloadType) error
SaveTx mocks base method.
func (*MockRepository) UpdateInfos ¶
func (m *MockRepository) UpdateInfos(ctx context.Context, txID uuid.UUID, retry int, status string) error
UpdateInfos mocks base method.
type MockRepositoryMockRecorder ¶
type MockRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRepositoryMockRecorder is the mock recorder for MockRepository.
func (*MockRepositoryMockRecorder) Close ¶
func (mr *MockRepositoryMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockRepositoryMockRecorder) SagaSaveTx ¶
func (mr *MockRepositoryMockRecorder) SagaSaveTx(ctx, input any) *gomock.Call
SagaSaveTx indicates an expected call of SagaSaveTx.
func (*MockRepositoryMockRecorder) SagaUpdateInfos ¶
func (mr *MockRepositoryMockRecorder) SagaUpdateInfos(ctx, txID, retry, status any) *gomock.Call
SagaUpdateInfos indicates an expected call of SagaUpdateInfos.
func (*MockRepositoryMockRecorder) SaveTx ¶
func (mr *MockRepositoryMockRecorder) SaveTx(ctx, input any) *gomock.Call
SaveTx indicates an expected call of SaveTx.
func (*MockRepositoryMockRecorder) UpdateInfos ¶
func (mr *MockRepositoryMockRecorder) UpdateInfos(ctx, txID, retry, status any) *gomock.Call
UpdateInfos indicates an expected call of UpdateInfos.
type MockTimeProvider ¶
type MockTimeProvider struct {
// contains filtered or unexported fields
}
MockTimeProvider is a mock of TimeProvider interface.
func NewMockTimeProvider ¶
func NewMockTimeProvider(ctrl *gomock.Controller) *MockTimeProvider
NewMockTimeProvider creates a new mock instance.
func (*MockTimeProvider) EXPECT ¶
func (m *MockTimeProvider) EXPECT() *MockTimeProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTimeProviderMockRecorder ¶
type MockTimeProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockTimeProviderMockRecorder is the mock recorder for MockTimeProvider.
func (*MockTimeProviderMockRecorder) Now ¶
func (mr *MockTimeProviderMockRecorder) Now() *gomock.Call
Now indicates an expected call of Now.