repository

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

type ErrQueueAlreadyExists struct {
	QueueName string
}

type ErrQueueNotFound struct {
	QueueName string
}

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

type QueueRepository interface {
	GetAllQueues(ctx *armadacontext.Context) ([]queue.Queue, error)
	GetQueue(ctx *armadacontext.Context, name string) (queue.Queue, error)
	CreateQueue(*armadacontext.Context, queue.Queue) error
	UpdateQueue(*armadacontext.Context, queue.Queue) error
	DeleteQueue(ctx *armadacontext.Context, name string) error
}

type ReadOnlyQueueRepository interface {
	GetAllQueues(ctx *armadacontext.Context) ([]queue.Queue, error)
	GetQueue(ctx *armadacontext.Context, name string) (queue.Queue, error)
}

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