Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockActionAuthorizer
- func (m *MockActionAuthorizer) AuthorizeAction(arg0 *armadacontext.Context, arg1 permission.Permission) error
- func (m *MockActionAuthorizer) AuthorizeQueueAction(arg0 *armadacontext.Context, arg1 queue.Queue, arg2 permission.Permission, ...) error
- func (m *MockActionAuthorizer) EXPECT() *MockActionAuthorizerMockRecorder
- type MockActionAuthorizerMockRecorder
- type MockDeduplicator
- func (m *MockDeduplicator) EXPECT() *MockDeduplicatorMockRecorder
- func (m *MockDeduplicator) GetOriginalJobIds(arg0 *armadacontext.Context, arg1 string, arg2 []*api.JobSubmitRequestItem) (map[string]string, error)
- func (m *MockDeduplicator) StoreOriginalJobIds(arg0 *armadacontext.Context, arg1 string, arg2 map[string]string) error
- type MockDeduplicatorMockRecorder
- type MockJobRepository
- func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder
- func (m *MockJobRepository) ExpirePulsarSchedulerJobDetails(arg0 *armadacontext.Context, arg1 []string) error
- func (m *MockJobRepository) GetPulsarSchedulerJobDetails(arg0 *armadacontext.Context, arg1 string) (*schedulerobjects.PulsarSchedulerJobDetails, error)
- func (m *MockJobRepository) StorePulsarSchedulerJobDetails(arg0 *armadacontext.Context, ...) error
- type MockJobRepositoryMockRecorder
- func (mr *MockJobRepositoryMockRecorder) ExpirePulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) GetPulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockJobRepositoryMockRecorder) StorePulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
- type MockPublisher
- type MockPublisherMockRecorder
- type MockQueueRepository
- func (m *MockQueueRepository) CreateQueue(arg0 *armadacontext.Context, arg1 queue.Queue) error
- func (m *MockQueueRepository) DeleteQueue(arg0 *armadacontext.Context, arg1 string) error
- func (m *MockQueueRepository) EXPECT() *MockQueueRepositoryMockRecorder
- func (m *MockQueueRepository) GetAllQueues(arg0 *armadacontext.Context) ([]queue.Queue, error)
- func (m *MockQueueRepository) GetQueue(arg0 *armadacontext.Context, arg1 string) (queue.Queue, error)
- func (m *MockQueueRepository) UpdateQueue(arg0 *armadacontext.Context, arg1 queue.Queue) error
- type MockQueueRepositoryMockRecorder
- func (mr *MockQueueRepositoryMockRecorder) CreateQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueRepositoryMockRecorder) DeleteQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueRepositoryMockRecorder) GetAllQueues(arg0 interface{}) *gomock.Call
- func (mr *MockQueueRepositoryMockRecorder) GetQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueRepositoryMockRecorder) UpdateQueue(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockActionAuthorizer ¶
type MockActionAuthorizer struct {
// contains filtered or unexported fields
}
MockActionAuthorizer is a mock of ActionAuthorizer interface.
func NewMockActionAuthorizer ¶
func NewMockActionAuthorizer(ctrl *gomock.Controller) *MockActionAuthorizer
NewMockActionAuthorizer creates a new mock instance.
func (*MockActionAuthorizer) AuthorizeAction ¶
func (m *MockActionAuthorizer) AuthorizeAction(arg0 *armadacontext.Context, arg1 permission.Permission) error
AuthorizeAction mocks base method.
func (*MockActionAuthorizer) AuthorizeQueueAction ¶
func (m *MockActionAuthorizer) AuthorizeQueueAction(arg0 *armadacontext.Context, arg1 queue.Queue, arg2 permission.Permission, arg3 queue.PermissionVerb) error
AuthorizeQueueAction mocks base method.
func (*MockActionAuthorizer) EXPECT ¶
func (m *MockActionAuthorizer) EXPECT() *MockActionAuthorizerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockActionAuthorizerMockRecorder ¶
type MockActionAuthorizerMockRecorder struct {
// contains filtered or unexported fields
}
MockActionAuthorizerMockRecorder is the mock recorder for MockActionAuthorizer.
func (*MockActionAuthorizerMockRecorder) AuthorizeAction ¶
func (mr *MockActionAuthorizerMockRecorder) AuthorizeAction(arg0, arg1 interface{}) *gomock.Call
AuthorizeAction indicates an expected call of AuthorizeAction.
func (*MockActionAuthorizerMockRecorder) AuthorizeQueueAction ¶
func (mr *MockActionAuthorizerMockRecorder) AuthorizeQueueAction(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
AuthorizeQueueAction indicates an expected call of AuthorizeQueueAction.
type MockDeduplicator ¶
type MockDeduplicator struct {
// contains filtered or unexported fields
}
MockDeduplicator is a mock of Deduplicator interface.
func NewMockDeduplicator ¶
func NewMockDeduplicator(ctrl *gomock.Controller) *MockDeduplicator
NewMockDeduplicator creates a new mock instance.
func (*MockDeduplicator) EXPECT ¶
func (m *MockDeduplicator) EXPECT() *MockDeduplicatorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDeduplicator) GetOriginalJobIds ¶
func (m *MockDeduplicator) GetOriginalJobIds(arg0 *armadacontext.Context, arg1 string, arg2 []*api.JobSubmitRequestItem) (map[string]string, error)
GetOriginalJobIds mocks base method.
func (*MockDeduplicator) StoreOriginalJobIds ¶
func (m *MockDeduplicator) StoreOriginalJobIds(arg0 *armadacontext.Context, arg1 string, arg2 map[string]string) error
StoreOriginalJobIds mocks base method.
type MockDeduplicatorMockRecorder ¶
type MockDeduplicatorMockRecorder struct {
// contains filtered or unexported fields
}
MockDeduplicatorMockRecorder is the mock recorder for MockDeduplicator.
func (*MockDeduplicatorMockRecorder) GetOriginalJobIds ¶
func (mr *MockDeduplicatorMockRecorder) GetOriginalJobIds(arg0, arg1, arg2 interface{}) *gomock.Call
GetOriginalJobIds indicates an expected call of GetOriginalJobIds.
func (*MockDeduplicatorMockRecorder) StoreOriginalJobIds ¶
func (mr *MockDeduplicatorMockRecorder) StoreOriginalJobIds(arg0, arg1, arg2 interface{}) *gomock.Call
StoreOriginalJobIds indicates an expected call of StoreOriginalJobIds.
type MockJobRepository ¶
type MockJobRepository struct {
// contains filtered or unexported fields
}
MockJobRepository is a mock of JobRepository interface.
func NewMockJobRepository ¶
func NewMockJobRepository(ctrl *gomock.Controller) *MockJobRepository
NewMockJobRepository creates a new mock instance.
func (*MockJobRepository) EXPECT ¶
func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockJobRepository) ExpirePulsarSchedulerJobDetails ¶
func (m *MockJobRepository) ExpirePulsarSchedulerJobDetails(arg0 *armadacontext.Context, arg1 []string) error
ExpirePulsarSchedulerJobDetails mocks base method.
func (*MockJobRepository) GetPulsarSchedulerJobDetails ¶
func (m *MockJobRepository) GetPulsarSchedulerJobDetails(arg0 *armadacontext.Context, arg1 string) (*schedulerobjects.PulsarSchedulerJobDetails, error)
GetPulsarSchedulerJobDetails mocks base method.
func (*MockJobRepository) StorePulsarSchedulerJobDetails ¶
func (m *MockJobRepository) StorePulsarSchedulerJobDetails(arg0 *armadacontext.Context, arg1 []*schedulerobjects.PulsarSchedulerJobDetails) error
StorePulsarSchedulerJobDetails mocks base method.
type MockJobRepositoryMockRecorder ¶
type MockJobRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockJobRepositoryMockRecorder is the mock recorder for MockJobRepository.
func (*MockJobRepositoryMockRecorder) ExpirePulsarSchedulerJobDetails ¶
func (mr *MockJobRepositoryMockRecorder) ExpirePulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
ExpirePulsarSchedulerJobDetails indicates an expected call of ExpirePulsarSchedulerJobDetails.
func (*MockJobRepositoryMockRecorder) GetPulsarSchedulerJobDetails ¶
func (mr *MockJobRepositoryMockRecorder) GetPulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
GetPulsarSchedulerJobDetails indicates an expected call of GetPulsarSchedulerJobDetails.
func (*MockJobRepositoryMockRecorder) StorePulsarSchedulerJobDetails ¶
func (mr *MockJobRepositoryMockRecorder) StorePulsarSchedulerJobDetails(arg0, arg1 interface{}) *gomock.Call
StorePulsarSchedulerJobDetails indicates an expected call of StorePulsarSchedulerJobDetails.
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.
func (*MockPublisher) PublishMessages ¶
func (m *MockPublisher) PublishMessages(arg0 *armadacontext.Context, arg1 *armadaevents.EventSequence) error
PublishMessages mocks base method.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
func (*MockPublisherMockRecorder) Close ¶
func (mr *MockPublisherMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockPublisherMockRecorder) PublishMessages ¶
func (mr *MockPublisherMockRecorder) PublishMessages(arg0, arg1 interface{}) *gomock.Call
PublishMessages indicates an expected call of PublishMessages.
type MockQueueRepository ¶
type MockQueueRepository struct {
// contains filtered or unexported fields
}
MockQueueRepository is a mock of QueueRepository interface.
func NewMockQueueRepository ¶
func NewMockQueueRepository(ctrl *gomock.Controller) *MockQueueRepository
NewMockQueueRepository creates a new mock instance.
func (*MockQueueRepository) CreateQueue ¶
func (m *MockQueueRepository) CreateQueue(arg0 *armadacontext.Context, arg1 queue.Queue) error
CreateQueue mocks base method.
func (*MockQueueRepository) DeleteQueue ¶
func (m *MockQueueRepository) DeleteQueue(arg0 *armadacontext.Context, arg1 string) error
DeleteQueue mocks base method.
func (*MockQueueRepository) EXPECT ¶
func (m *MockQueueRepository) EXPECT() *MockQueueRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueRepository) GetAllQueues ¶
func (m *MockQueueRepository) GetAllQueues(arg0 *armadacontext.Context) ([]queue.Queue, error)
GetAllQueues mocks base method.
func (*MockQueueRepository) GetQueue ¶
func (m *MockQueueRepository) GetQueue(arg0 *armadacontext.Context, arg1 string) (queue.Queue, error)
GetQueue mocks base method.
func (*MockQueueRepository) UpdateQueue ¶
func (m *MockQueueRepository) UpdateQueue(arg0 *armadacontext.Context, arg1 queue.Queue) error
UpdateQueue mocks base method.
type MockQueueRepositoryMockRecorder ¶
type MockQueueRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueRepositoryMockRecorder is the mock recorder for MockQueueRepository.
func (*MockQueueRepositoryMockRecorder) CreateQueue ¶
func (mr *MockQueueRepositoryMockRecorder) CreateQueue(arg0, arg1 interface{}) *gomock.Call
CreateQueue indicates an expected call of CreateQueue.
func (*MockQueueRepositoryMockRecorder) DeleteQueue ¶
func (mr *MockQueueRepositoryMockRecorder) DeleteQueue(arg0, arg1 interface{}) *gomock.Call
DeleteQueue indicates an expected call of DeleteQueue.
func (*MockQueueRepositoryMockRecorder) GetAllQueues ¶
func (mr *MockQueueRepositoryMockRecorder) GetAllQueues(arg0 interface{}) *gomock.Call
GetAllQueues indicates an expected call of GetAllQueues.
func (*MockQueueRepositoryMockRecorder) GetQueue ¶
func (mr *MockQueueRepositoryMockRecorder) GetQueue(arg0, arg1 interface{}) *gomock.Call
GetQueue indicates an expected call of GetQueue.
func (*MockQueueRepositoryMockRecorder) UpdateQueue ¶
func (mr *MockQueueRepositoryMockRecorder) UpdateQueue(arg0, arg1 interface{}) *gomock.Call
UpdateQueue indicates an expected call of UpdateQueue.