Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockcleanupRepository
- func (m *MockcleanupRepository) DeleteProcessedMessages(ctx context.Context, before time.Time, limit int) (int64, error)
- func (m *MockcleanupRepository) EXPECT() *MockcleanupRepositoryMockRecorder
- func (m *MockcleanupRepository) GetOldestProcessedMessageTime(ctx context.Context, before time.Time) (time.Time, bool, error)
- type MockcleanupRepositoryMockRecorder
- type Mockpublisher
- type MockpublisherMockRecorder
- type Mockrepository
- func (m *Mockrepository) EXPECT() *MockrepositoryMockRecorder
- func (m *Mockrepository) GetUnprocessedMessages(ctx context.Context, limit int) ([]models.Message, error)
- func (m *Mockrepository) SaveFailedMessages(ctx context.Context, messages []models.Message) error
- func (m *Mockrepository) SaveProcessedMessages(ctx context.Context, messages []models.Message) error
- func (m *Mockrepository) WithTransactionIsolation(ctx context.Context, isolationLvl sql.IsolationLevel, ...) error
- type MockrepositoryMockRecorder
- func (mr *MockrepositoryMockRecorder) GetUnprocessedMessages(ctx, limit any) *gomock.Call
- func (mr *MockrepositoryMockRecorder) SaveFailedMessages(ctx, messages any) *gomock.Call
- func (mr *MockrepositoryMockRecorder) SaveProcessedMessages(ctx, messages any) *gomock.Call
- func (mr *MockrepositoryMockRecorder) WithTransactionIsolation(ctx, isolationLvl, fn any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockcleanupRepository ¶ added in v0.9.79
type MockcleanupRepository struct {
// contains filtered or unexported fields
}
MockcleanupRepository is a mock of cleanupRepository interface.
func NewMockcleanupRepository ¶ added in v0.9.79
func NewMockcleanupRepository(ctrl *gomock.Controller) *MockcleanupRepository
NewMockcleanupRepository creates a new mock instance.
func (*MockcleanupRepository) DeleteProcessedMessages ¶ added in v0.9.79
func (m *MockcleanupRepository) DeleteProcessedMessages(ctx context.Context, before time.Time, limit int) (int64, error)
DeleteProcessedMessages mocks base method.
func (*MockcleanupRepository) EXPECT ¶ added in v0.9.79
func (m *MockcleanupRepository) EXPECT() *MockcleanupRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockcleanupRepositoryMockRecorder ¶ added in v0.9.79
type MockcleanupRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockcleanupRepositoryMockRecorder is the mock recorder for MockcleanupRepository.
func (*MockcleanupRepositoryMockRecorder) DeleteProcessedMessages ¶ added in v0.9.79
func (mr *MockcleanupRepositoryMockRecorder) DeleteProcessedMessages(ctx, before, limit any) *gomock.Call
DeleteProcessedMessages indicates an expected call of DeleteProcessedMessages.
func (*MockcleanupRepositoryMockRecorder) GetOldestProcessedMessageTime ¶ added in v0.9.80
func (mr *MockcleanupRepositoryMockRecorder) GetOldestProcessedMessageTime(ctx, before any) *gomock.Call
GetOldestProcessedMessageTime indicates an expected call of GetOldestProcessedMessageTime.
type Mockpublisher ¶
type Mockpublisher struct {
// contains filtered or unexported fields
}
Mockpublisher is a mock of publisher interface.
func NewMockpublisher ¶
func NewMockpublisher(ctrl *gomock.Controller) *Mockpublisher
NewMockpublisher creates a new mock instance.
func (*Mockpublisher) EXPECT ¶
func (m *Mockpublisher) EXPECT() *MockpublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockpublisherMockRecorder ¶
type MockpublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockpublisherMockRecorder is the mock recorder for Mockpublisher.
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) GetUnprocessedMessages ¶
func (m *Mockrepository) GetUnprocessedMessages(ctx context.Context, limit int) ([]models.Message, error)
GetUnprocessedMessages mocks base method.
func (*Mockrepository) SaveFailedMessages ¶
SaveFailedMessages mocks base method.
func (*Mockrepository) SaveProcessedMessages ¶
func (m *Mockrepository) SaveProcessedMessages(ctx context.Context, messages []models.Message) error
SaveProcessedMessages mocks base method.
func (*Mockrepository) WithTransactionIsolation ¶ added in v0.9.80
func (m *Mockrepository) WithTransactionIsolation(ctx context.Context, isolationLvl sql.IsolationLevel, fn func(context.Context) error) error
WithTransactionIsolation mocks base method.
type MockrepositoryMockRecorder ¶
type MockrepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockrepositoryMockRecorder is the mock recorder for Mockrepository.
func (*MockrepositoryMockRecorder) GetUnprocessedMessages ¶
func (mr *MockrepositoryMockRecorder) GetUnprocessedMessages(ctx, limit any) *gomock.Call
GetUnprocessedMessages indicates an expected call of GetUnprocessedMessages.
func (*MockrepositoryMockRecorder) SaveFailedMessages ¶
func (mr *MockrepositoryMockRecorder) SaveFailedMessages(ctx, messages any) *gomock.Call
SaveFailedMessages indicates an expected call of SaveFailedMessages.
func (*MockrepositoryMockRecorder) SaveProcessedMessages ¶
func (mr *MockrepositoryMockRecorder) SaveProcessedMessages(ctx, messages any) *gomock.Call
SaveProcessedMessages indicates an expected call of SaveProcessedMessages.
func (*MockrepositoryMockRecorder) WithTransactionIsolation ¶ added in v0.9.80
func (mr *MockrepositoryMockRecorder) WithTransactionIsolation(ctx, isolationLvl, fn any) *gomock.Call
WithTransactionIsolation indicates an expected call of WithTransactionIsolation.
Source Files