queue

Documentation

Index

• type ApiQueueCache
  • func NewQueueCache(apiClient api.SubmitClient, updateFrequency time.Duration) *ApiQueueCache
  • func (c *ApiQueueCache) GetAll(_ *armadacontext.Context) ([]*api.Queue, error)
  • func (c *ApiQueueCache) Run(ctx *armadacontext.Context) error
• type QueueCache

Types

type ApiQueueCache

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

ApiQueueCache is an implementation of QueueCache that fetches queues from the Armada API. We cache the queues in memory so that we can continue scheduling even if the API is unavailable

func NewQueueCache

func NewQueueCache(apiClient api.SubmitClient, updateFrequency time.Duration) *ApiQueueCache

func (*ApiQueueCache) GetAll

func (c *ApiQueueCache) GetAll(_ *armadacontext.Context) ([]*api.Queue, error)

func (*ApiQueueCache) Run

func (c *ApiQueueCache) Run(ctx *armadacontext.Context) error

type QueueCache

type QueueCache interface {
	// Get returns all available queues
	GetAll(ctx *armadacontext.Context) ([]*api.Queue, error)
}

QueueCache is an in-memory cache of available queues