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.
Index ¶
- type MockApplicationRepository
- func (m *MockApplicationRepository) CreateApplication(arg0 context.Context, arg1 *convoy.Application) error
- func (m *MockApplicationRepository) DeleteApplication(arg0 context.Context, arg1 *convoy.Application) error
- func (m *MockApplicationRepository) EXPECT() *MockApplicationRepositoryMockRecorder
- func (m *MockApplicationRepository) FindApplicationByID(arg0 context.Context, arg1 string) (*convoy.Application, error)
- func (m *MockApplicationRepository) FindApplicationEndpointByID(arg0 context.Context, arg1, arg2 string) (*convoy.Endpoint, error)
- func (m *MockApplicationRepository) LoadApplicationsPaged(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Application, mongopagination.PaginationData, error)
- func (m *MockApplicationRepository) LoadApplicationsPagedByGroupId(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Application, mongopagination.PaginationData, error)
- func (m *MockApplicationRepository) SearchApplicationsByGroupId(arg0 context.Context, arg1 string, arg2 models.SearchParams) ([]convoy.Application, error)
- func (m *MockApplicationRepository) UpdateApplication(arg0 context.Context, arg1 *convoy.Application) error
- func (m *MockApplicationRepository) UpdateApplicationEndpointsStatus(arg0 context.Context, arg1 string, arg2 []string, arg3 convoy.EndpointStatus) error
- type MockApplicationRepositoryMockRecorder
- func (mr *MockApplicationRepositoryMockRecorder) CreateApplication(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) DeleteApplication(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) FindApplicationByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) FindApplicationEndpointByID(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPaged(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPagedByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) SearchApplicationsByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) UpdateApplication(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockApplicationRepositoryMockRecorder) UpdateApplicationEndpointsStatus(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- type MockGroupRepository
- func (m *MockGroupRepository) CreateGroup(arg0 context.Context, arg1 *convoy.Group) error
- func (m *MockGroupRepository) EXPECT() *MockGroupRepositoryMockRecorder
- func (m *MockGroupRepository) FetchGroupByID(arg0 context.Context, arg1 string) (*convoy.Group, error)
- func (m *MockGroupRepository) LoadGroups(arg0 context.Context, arg1 *convoy.GroupFilter) ([]*convoy.Group, error)
- func (m *MockGroupRepository) UpdateGroup(arg0 context.Context, arg1 *convoy.Group) error
- type MockGroupRepositoryMockRecorder
- func (mr *MockGroupRepositoryMockRecorder) CreateGroup(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockGroupRepositoryMockRecorder) FetchGroupByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockGroupRepositoryMockRecorder) LoadGroups(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockGroupRepositoryMockRecorder) UpdateGroup(arg0, arg1 interface{}) *gomock.Call
- type MockMessageRepository
- func (m *MockMessageRepository) CreateMessage(arg0 context.Context, arg1 *convoy.Message) error
- func (m *MockMessageRepository) EXPECT() *MockMessageRepositoryMockRecorder
- func (m *MockMessageRepository) FindMessageByID(ctx context.Context, id string) (*convoy.Message, error)
- func (m *MockMessageRepository) LoadAbandonedMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)
- func (m *MockMessageRepository) LoadMessageIntervals(arg0 context.Context, arg1 string, arg2 models.SearchParams, ...) ([]models.MessageInterval, error)
- func (m *MockMessageRepository) LoadMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)
- func (m *MockMessageRepository) LoadMessagesPaged(arg0 context.Context, arg1, arg2 string, arg3 models.SearchParams, ...) ([]convoy.Message, mongopagination.PaginationData, error)
- func (m *MockMessageRepository) LoadMessagesPagedByAppId(arg0 context.Context, arg1 string, arg2 models.SearchParams, ...) ([]convoy.Message, mongopagination.PaginationData, error)
- func (m *MockMessageRepository) LoadMessagesScheduledForPosting(arg0 context.Context) ([]convoy.Message, error)
- func (m_2 *MockMessageRepository) UpdateMessageWithAttempt(ctx context.Context, m convoy.Message, attempt convoy.MessageAttempt) error
- func (m *MockMessageRepository) UpdateStatusOfMessages(arg0 context.Context, arg1 []convoy.Message, arg2 convoy.MessageStatus) error
- type MockMessageRepositoryMockRecorder
- func (mr *MockMessageRepositoryMockRecorder) CreateMessage(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) FindMessageByID(ctx, id interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadAbandonedMessagesForPostingRetry(arg0 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadMessageIntervals(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadMessagesForPostingRetry(arg0 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPaged(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPagedByAppId(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) LoadMessagesScheduledForPosting(arg0 interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) UpdateMessageWithAttempt(ctx, m, attempt interface{}) *gomock.Call
- func (mr *MockMessageRepositoryMockRecorder) UpdateStatusOfMessages(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockQueuer
- type MockQueuerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockApplicationRepository ¶
type MockApplicationRepository struct {
// contains filtered or unexported fields
}
MockApplicationRepository is a mock of ApplicationRepository interface.
func NewMockApplicationRepository ¶
func NewMockApplicationRepository(ctrl *gomock.Controller) *MockApplicationRepository
NewMockApplicationRepository creates a new mock instance.
func (*MockApplicationRepository) CreateApplication ¶
func (m *MockApplicationRepository) CreateApplication(arg0 context.Context, arg1 *convoy.Application) error
CreateApplication mocks base method.
func (*MockApplicationRepository) DeleteApplication ¶
func (m *MockApplicationRepository) DeleteApplication(arg0 context.Context, arg1 *convoy.Application) error
DeleteApplication mocks base method.
func (*MockApplicationRepository) EXPECT ¶
func (m *MockApplicationRepository) EXPECT() *MockApplicationRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockApplicationRepository) FindApplicationByID ¶
func (m *MockApplicationRepository) FindApplicationByID(arg0 context.Context, arg1 string) (*convoy.Application, error)
FindApplicationByID mocks base method.
func (*MockApplicationRepository) FindApplicationEndpointByID ¶
func (m *MockApplicationRepository) FindApplicationEndpointByID(arg0 context.Context, arg1, arg2 string) (*convoy.Endpoint, error)
FindApplicationEndpointByID mocks base method.
func (*MockApplicationRepository) LoadApplicationsPaged ¶
func (m *MockApplicationRepository) LoadApplicationsPaged(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Application, mongopagination.PaginationData, error)
LoadApplicationsPaged mocks base method.
func (*MockApplicationRepository) LoadApplicationsPagedByGroupId ¶
func (m *MockApplicationRepository) LoadApplicationsPagedByGroupId(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Application, mongopagination.PaginationData, error)
LoadApplicationsPagedByGroupId mocks base method.
func (*MockApplicationRepository) SearchApplicationsByGroupId ¶
func (m *MockApplicationRepository) SearchApplicationsByGroupId(arg0 context.Context, arg1 string, arg2 models.SearchParams) ([]convoy.Application, error)
SearchApplicationsByGroupId mocks base method.
func (*MockApplicationRepository) UpdateApplication ¶
func (m *MockApplicationRepository) UpdateApplication(arg0 context.Context, arg1 *convoy.Application) error
UpdateApplication mocks base method.
func (*MockApplicationRepository) UpdateApplicationEndpointsStatus ¶
func (m *MockApplicationRepository) UpdateApplicationEndpointsStatus(arg0 context.Context, arg1 string, arg2 []string, arg3 convoy.EndpointStatus) error
UpdateApplicationEndpointsStatus mocks base method.
type MockApplicationRepositoryMockRecorder ¶
type MockApplicationRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockApplicationRepositoryMockRecorder is the mock recorder for MockApplicationRepository.
func (*MockApplicationRepositoryMockRecorder) CreateApplication ¶
func (mr *MockApplicationRepositoryMockRecorder) CreateApplication(arg0, arg1 interface{}) *gomock.Call
CreateApplication indicates an expected call of CreateApplication.
func (*MockApplicationRepositoryMockRecorder) DeleteApplication ¶
func (mr *MockApplicationRepositoryMockRecorder) DeleteApplication(arg0, arg1 interface{}) *gomock.Call
DeleteApplication indicates an expected call of DeleteApplication.
func (*MockApplicationRepositoryMockRecorder) FindApplicationByID ¶
func (mr *MockApplicationRepositoryMockRecorder) FindApplicationByID(arg0, arg1 interface{}) *gomock.Call
FindApplicationByID indicates an expected call of FindApplicationByID.
func (*MockApplicationRepositoryMockRecorder) FindApplicationEndpointByID ¶
func (mr *MockApplicationRepositoryMockRecorder) FindApplicationEndpointByID(arg0, arg1, arg2 interface{}) *gomock.Call
FindApplicationEndpointByID indicates an expected call of FindApplicationEndpointByID.
func (*MockApplicationRepositoryMockRecorder) LoadApplicationsPaged ¶
func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPaged(arg0, arg1, arg2 interface{}) *gomock.Call
LoadApplicationsPaged indicates an expected call of LoadApplicationsPaged.
func (*MockApplicationRepositoryMockRecorder) LoadApplicationsPagedByGroupId ¶
func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPagedByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call
LoadApplicationsPagedByGroupId indicates an expected call of LoadApplicationsPagedByGroupId.
func (*MockApplicationRepositoryMockRecorder) SearchApplicationsByGroupId ¶
func (mr *MockApplicationRepositoryMockRecorder) SearchApplicationsByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call
SearchApplicationsByGroupId indicates an expected call of SearchApplicationsByGroupId.
func (*MockApplicationRepositoryMockRecorder) UpdateApplication ¶
func (mr *MockApplicationRepositoryMockRecorder) UpdateApplication(arg0, arg1 interface{}) *gomock.Call
UpdateApplication indicates an expected call of UpdateApplication.
func (*MockApplicationRepositoryMockRecorder) UpdateApplicationEndpointsStatus ¶
func (mr *MockApplicationRepositoryMockRecorder) UpdateApplicationEndpointsStatus(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
UpdateApplicationEndpointsStatus indicates an expected call of UpdateApplicationEndpointsStatus.
type MockGroupRepository ¶
type MockGroupRepository struct {
// contains filtered or unexported fields
}
MockGroupRepository is a mock of GroupRepository interface.
func NewMockGroupRepository ¶
func NewMockGroupRepository(ctrl *gomock.Controller) *MockGroupRepository
NewMockGroupRepository creates a new mock instance.
func (*MockGroupRepository) CreateGroup ¶
CreateGroup mocks base method.
func (*MockGroupRepository) EXPECT ¶
func (m *MockGroupRepository) EXPECT() *MockGroupRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGroupRepository) FetchGroupByID ¶
func (m *MockGroupRepository) FetchGroupByID(arg0 context.Context, arg1 string) (*convoy.Group, error)
FetchGroupByID mocks base method.
func (*MockGroupRepository) LoadGroups ¶
func (m *MockGroupRepository) LoadGroups(arg0 context.Context, arg1 *convoy.GroupFilter) ([]*convoy.Group, error)
LoadGroups mocks base method.
func (*MockGroupRepository) UpdateGroup ¶
UpdateGroup mocks base method.
type MockGroupRepositoryMockRecorder ¶
type MockGroupRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockGroupRepositoryMockRecorder is the mock recorder for MockGroupRepository.
func (*MockGroupRepositoryMockRecorder) CreateGroup ¶
func (mr *MockGroupRepositoryMockRecorder) CreateGroup(arg0, arg1 interface{}) *gomock.Call
CreateGroup indicates an expected call of CreateGroup.
func (*MockGroupRepositoryMockRecorder) FetchGroupByID ¶
func (mr *MockGroupRepositoryMockRecorder) FetchGroupByID(arg0, arg1 interface{}) *gomock.Call
FetchGroupByID indicates an expected call of FetchGroupByID.
func (*MockGroupRepositoryMockRecorder) LoadGroups ¶
func (mr *MockGroupRepositoryMockRecorder) LoadGroups(arg0, arg1 interface{}) *gomock.Call
LoadGroups indicates an expected call of LoadGroups.
func (*MockGroupRepositoryMockRecorder) UpdateGroup ¶
func (mr *MockGroupRepositoryMockRecorder) UpdateGroup(arg0, arg1 interface{}) *gomock.Call
UpdateGroup indicates an expected call of UpdateGroup.
type MockMessageRepository ¶ added in v0.1.0
type MockMessageRepository struct {
// contains filtered or unexported fields
}
MockMessageRepository is a mock of MessageRepository interface.
func NewMockMessageRepository ¶ added in v0.1.0
func NewMockMessageRepository(ctrl *gomock.Controller) *MockMessageRepository
NewMockMessageRepository creates a new mock instance.
func (*MockMessageRepository) CreateMessage ¶ added in v0.1.0
CreateMessage mocks base method.
func (*MockMessageRepository) EXPECT ¶ added in v0.1.0
func (m *MockMessageRepository) EXPECT() *MockMessageRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMessageRepository) FindMessageByID ¶ added in v0.1.0
func (m *MockMessageRepository) FindMessageByID(ctx context.Context, id string) (*convoy.Message, error)
FindMessageByID mocks base method.
func (*MockMessageRepository) LoadAbandonedMessagesForPostingRetry ¶ added in v0.1.0
func (m *MockMessageRepository) LoadAbandonedMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)
LoadAbandonedMessagesForPostingRetry mocks base method.
func (*MockMessageRepository) LoadMessageIntervals ¶ added in v0.1.0
func (m *MockMessageRepository) LoadMessageIntervals(arg0 context.Context, arg1 string, arg2 models.SearchParams, arg3 convoy.Period, arg4 int) ([]models.MessageInterval, error)
LoadMessageIntervals mocks base method.
func (*MockMessageRepository) LoadMessagesForPostingRetry ¶ added in v0.1.0
func (m *MockMessageRepository) LoadMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)
LoadMessagesForPostingRetry mocks base method.
func (*MockMessageRepository) LoadMessagesPaged ¶ added in v0.1.0
func (m *MockMessageRepository) LoadMessagesPaged(arg0 context.Context, arg1, arg2 string, arg3 models.SearchParams, arg4 models.Pageable) ([]convoy.Message, mongopagination.PaginationData, error)
LoadMessagesPaged mocks base method.
func (*MockMessageRepository) LoadMessagesPagedByAppId ¶ added in v0.1.0
func (m *MockMessageRepository) LoadMessagesPagedByAppId(arg0 context.Context, arg1 string, arg2 models.SearchParams, arg3 models.Pageable) ([]convoy.Message, mongopagination.PaginationData, error)
LoadMessagesPagedByAppId mocks base method.
func (*MockMessageRepository) LoadMessagesScheduledForPosting ¶ added in v0.1.0
func (m *MockMessageRepository) LoadMessagesScheduledForPosting(arg0 context.Context) ([]convoy.Message, error)
LoadMessagesScheduledForPosting mocks base method.
func (*MockMessageRepository) UpdateMessageWithAttempt ¶ added in v0.1.0
func (m_2 *MockMessageRepository) UpdateMessageWithAttempt(ctx context.Context, m convoy.Message, attempt convoy.MessageAttempt) error
UpdateMessageWithAttempt mocks base method.
func (*MockMessageRepository) UpdateStatusOfMessages ¶ added in v0.1.0
func (m *MockMessageRepository) UpdateStatusOfMessages(arg0 context.Context, arg1 []convoy.Message, arg2 convoy.MessageStatus) error
UpdateStatusOfMessages mocks base method.
type MockMessageRepositoryMockRecorder ¶ added in v0.1.0
type MockMessageRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageRepositoryMockRecorder is the mock recorder for MockMessageRepository.
func (*MockMessageRepositoryMockRecorder) CreateMessage ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) CreateMessage(arg0, arg1 interface{}) *gomock.Call
CreateMessage indicates an expected call of CreateMessage.
func (*MockMessageRepositoryMockRecorder) FindMessageByID ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) FindMessageByID(ctx, id interface{}) *gomock.Call
FindMessageByID indicates an expected call of FindMessageByID.
func (*MockMessageRepositoryMockRecorder) LoadAbandonedMessagesForPostingRetry ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadAbandonedMessagesForPostingRetry(arg0 interface{}) *gomock.Call
LoadAbandonedMessagesForPostingRetry indicates an expected call of LoadAbandonedMessagesForPostingRetry.
func (*MockMessageRepositoryMockRecorder) LoadMessageIntervals ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadMessageIntervals(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
LoadMessageIntervals indicates an expected call of LoadMessageIntervals.
func (*MockMessageRepositoryMockRecorder) LoadMessagesForPostingRetry ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadMessagesForPostingRetry(arg0 interface{}) *gomock.Call
LoadMessagesForPostingRetry indicates an expected call of LoadMessagesForPostingRetry.
func (*MockMessageRepositoryMockRecorder) LoadMessagesPaged ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPaged(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
LoadMessagesPaged indicates an expected call of LoadMessagesPaged.
func (*MockMessageRepositoryMockRecorder) LoadMessagesPagedByAppId ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPagedByAppId(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
LoadMessagesPagedByAppId indicates an expected call of LoadMessagesPagedByAppId.
func (*MockMessageRepositoryMockRecorder) LoadMessagesScheduledForPosting ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) LoadMessagesScheduledForPosting(arg0 interface{}) *gomock.Call
LoadMessagesScheduledForPosting indicates an expected call of LoadMessagesScheduledForPosting.
func (*MockMessageRepositoryMockRecorder) UpdateMessageWithAttempt ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) UpdateMessageWithAttempt(ctx, m, attempt interface{}) *gomock.Call
UpdateMessageWithAttempt indicates an expected call of UpdateMessageWithAttempt.
func (*MockMessageRepositoryMockRecorder) UpdateStatusOfMessages ¶ added in v0.1.0
func (mr *MockMessageRepositoryMockRecorder) UpdateStatusOfMessages(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateStatusOfMessages indicates an expected call of UpdateStatusOfMessages.
type MockQueuer ¶
type MockQueuer struct {
// contains filtered or unexported fields
}
MockQueuer is a mock of Queuer interface.
func NewMockQueuer ¶
func NewMockQueuer(ctrl *gomock.Controller) *MockQueuer
NewMockQueuer creates a new mock instance.
func (*MockQueuer) EXPECT ¶
func (m *MockQueuer) EXPECT() *MockQueuerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockQueuerMockRecorder ¶
type MockQueuerMockRecorder struct {
// contains filtered or unexported fields
}
MockQueuerMockRecorder is the mock recorder for MockQueuer.
func (*MockQueuerMockRecorder) Close ¶
func (mr *MockQueuerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockQueuerMockRecorder) Write ¶
func (mr *MockQueuerMockRecorder) Write(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
Write indicates an expected call of Write.