Documentation
¶
Index ¶
- type JobServiceMonitorClient
- type PoolManager
- type QueueManager
- type RedisClient
- func (_m *RedisClient) AllJobTypes(ctx context.Context) ([]string, error)
- func (_m *RedisClient) PauseJob(ctx context.Context, jobName string) error
- func (_m *RedisClient) StopPendingJobs(ctx context.Context, jobType string) ([]string, error)
- func (_m *RedisClient) UnpauseJob(ctx context.Context, jobName string) error
- type WorkerManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobServiceMonitorClient ¶
JobServiceMonitorClient is an autogenerated mock type for the JobServiceMonitorClient type
func NewJobServiceMonitorClient ¶
func NewJobServiceMonitorClient(t interface {
mock.TestingT
Cleanup(func())
}) *JobServiceMonitorClient
NewJobServiceMonitorClient creates a new instance of JobServiceMonitorClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*JobServiceMonitorClient) Queues ¶
func (_m *JobServiceMonitorClient) Queues() ([]*work.Queue, error)
Queues provides a mock function with given fields:
func (*JobServiceMonitorClient) WorkerObservations ¶
func (_m *JobServiceMonitorClient) WorkerObservations() ([]*work.WorkerObservation, error)
WorkerObservations provides a mock function with given fields:
func (*JobServiceMonitorClient) WorkerPoolHeartbeats ¶
func (_m *JobServiceMonitorClient) WorkerPoolHeartbeats() ([]*work.WorkerPoolHeartbeat, error)
WorkerPoolHeartbeats provides a mock function with given fields:
type PoolManager ¶
PoolManager is an autogenerated mock type for the PoolManager type
func NewPoolManager ¶
func NewPoolManager(t interface {
mock.TestingT
Cleanup(func())
}) *PoolManager
NewPoolManager creates a new instance of PoolManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PoolManager) List ¶
func (_m *PoolManager) List(ctx context.Context, monitorClient jobmonitor.JobServiceMonitorClient) ([]*jobmonitor.WorkerPool, error)
List provides a mock function with given fields: ctx, monitorClient
type QueueManager ¶
QueueManager is an autogenerated mock type for the QueueManager type
func NewQueueManager ¶
func NewQueueManager(t interface {
mock.TestingT
Cleanup(func())
}) *QueueManager
NewQueueManager creates a new instance of QueueManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*QueueManager) List ¶
func (_m *QueueManager) List(ctx context.Context, monitClient jobmonitor.JobServiceMonitorClient) ([]*jobmonitor.Queue, error)
List provides a mock function with given fields: ctx, monitClient
type RedisClient ¶
RedisClient is an autogenerated mock type for the RedisClient type
func NewRedisClient ¶
func NewRedisClient(t interface {
mock.TestingT
Cleanup(func())
}) *RedisClient
NewRedisClient creates a new instance of RedisClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*RedisClient) AllJobTypes ¶
func (_m *RedisClient) AllJobTypes(ctx context.Context) ([]string, error)
AllJobTypes provides a mock function with given fields: ctx
func (*RedisClient) PauseJob ¶
func (_m *RedisClient) PauseJob(ctx context.Context, jobName string) error
PauseJob provides a mock function with given fields: ctx, jobName
func (*RedisClient) StopPendingJobs ¶
StopPendingJobs provides a mock function with given fields: ctx, jobType
func (*RedisClient) UnpauseJob ¶
func (_m *RedisClient) UnpauseJob(ctx context.Context, jobName string) error
UnpauseJob provides a mock function with given fields: ctx, jobName
type WorkerManager ¶
WorkerManager is an autogenerated mock type for the WorkerManager type
func NewWorkerManager ¶
func NewWorkerManager(t interface {
mock.TestingT
Cleanup(func())
}) *WorkerManager
NewWorkerManager creates a new instance of WorkerManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*WorkerManager) List ¶
func (_m *WorkerManager) List(ctx context.Context, monitClient jobmonitor.JobServiceMonitorClient, poolID string) ([]*jobmonitor.Worker, error)
List provides a mock function with given fields: ctx, monitClient, poolID
Source Files