Documentation
¶
Index ¶
- type QueueCache
- func (c *QueueCache) GetQueuedJobMetrics(queueName string) []*metrics.QueueMetrics
- func (c *QueueCache) GetRunningJobMetrics(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)
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 ¶ added in v0.3.30
func (c *QueueCache) GetQueuedJobMetrics(queueName string) []*metrics.QueueMetrics
func (*QueueCache) GetRunningJobMetrics ¶ added in v0.3.30
func (c *QueueCache) GetRunningJobMetrics(queueName string) []*metrics.QueueMetrics
func (*QueueCache) PeekClusterQueue ¶
func (*QueueCache) Refresh ¶
func (c *QueueCache) Refresh()
func (*QueueCache) TryLeaseJobs ¶
Click to show internal directories.
Click to hide internal directories.