cache

Documentation

Index

• type QueueCache
  • func NewQueueCache(queueRepository repository.QueueRepository, ...) *QueueCache
  • func (c *QueueCache) GetQueueMetrics(queueName string) *metrics.QueueMetrics
  • func (c *QueueCache) PeekClusterQueue(clusterId, queue string, limit int64) ([]*api.Job, error)
  • func (c *QueueCache) Refresh()
  • func (c *QueueCache) TryLeaseJobs(clusterId string, queue string, jobs []*api.Job) ([]*api.Job, error)

Types

type QueueCache

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

func NewQueueCache

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

func (*QueueCache) GetQueueMetrics

func (c *QueueCache) GetQueueMetrics(queueName string) *metrics.QueueMetrics

func (*QueueCache) PeekClusterQueue

func (c *QueueCache) PeekClusterQueue(clusterId, queue string, limit int64) ([]*api.Job, error)

func (*QueueCache) Refresh

func (c *QueueCache) Refresh()

func (*QueueCache) TryLeaseJobs

func (c *QueueCache) TryLeaseJobs(clusterId string, queue string, jobs []*api.Job) ([]*api.Job, error)