jobmonitor

Documentation

Index

• type JobServiceMonitorClient
  • func NewJobServiceMonitorClient(t interface{ ... }) *JobServiceMonitorClient
  • func (_m *JobServiceMonitorClient) Queues() ([]*work.Queue, error)
  • func (_m *JobServiceMonitorClient) WorkerObservations() ([]*work.WorkerObservation, error)
  • func (_m *JobServiceMonitorClient) WorkerPoolHeartbeats() ([]*work.WorkerPoolHeartbeat, error)
• type PoolManager
  • func NewPoolManager(t interface{ ... }) *PoolManager
  • func (_m *PoolManager) List(ctx context.Context, monitorClient jobmonitor.JobServiceMonitorClient) ([]*jobmonitor.WorkerPool, error)
• type QueueManager
  • func NewQueueManager(t interface{ ... }) *QueueManager
  • func (_m *QueueManager) List(ctx context.Context, monitClient jobmonitor.JobServiceMonitorClient) ([]*jobmonitor.Queue, error)
• type RedisClient
  • func NewRedisClient(t interface{ ... }) *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
  • func NewWorkerManager(t interface{ ... }) *WorkerManager
  • func (_m *WorkerManager) List(ctx context.Context, monitClient jobmonitor.JobServiceMonitorClient, ...) ([]*jobmonitor.Worker, error)

Types

type JobServiceMonitorClient

type JobServiceMonitorClient struct {
	mock.Mock
}

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

type PoolManager struct {
	mock.Mock
}

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

type QueueManager struct {
	mock.Mock
}

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

type RedisClient struct {
	mock.Mock
}

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

func (_m *RedisClient) StopPendingJobs(ctx context.Context, jobType string) ([]string, error)

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

type WorkerManager struct {
	mock.Mock
}

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