cache

package
v0.3.71-rc-5e18b42 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL