cache

Documentation

Index

• type QueueCache
  • func NewQueueCache(clock util.Clock, queueRepository repository.QueueRepository, ...) *QueueCache
  • func (c *QueueCache) GetQueuedJobMetrics(queueName string) []*metrics.QueueMetrics
  • func (c *QueueCache) GetRunningJobMetrics(queueName string) []*metrics.QueueMetrics
  • func (c *QueueCache) Refresh()

Types

type QueueCache

type QueueCache struct {
	// contains filtered or unexported fields
}

func NewQueueCache

func NewQueueCache(
	clock util.Clock,
	queueRepository repository.QueueRepository,
	jobRepository repository.JobRepository,
	schedulingInfoRepository repository.SchedulingInfoRepository,
) *QueueCache

func (*QueueCache) GetQueuedJobMetrics

func (c *QueueCache) GetQueuedJobMetrics(queueName string) []*metrics.QueueMetrics

func (*QueueCache) GetRunningJobMetrics

func (c *QueueCache) GetRunningJobMetrics(queueName string) []*metrics.QueueMetrics

func (*QueueCache) Refresh

func (c *QueueCache) Refresh()