Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeckhouseQueue ¶
type DeckhouseQueue struct { Header string Tasks []DeckhouseQueueTask Summary []string }
type DeckhouseQueueFetcher ¶
type DeckhouseQueueFetcher struct {
// contains filtered or unexported fields
}
func New ¶
func New(kubeCl kubernetes.Interface, restConfig *rest.Config) *DeckhouseQueueFetcher
func (*DeckhouseQueueFetcher) GetQueue ¶
func (q *DeckhouseQueueFetcher) GetQueue(ctx context.Context) (DeckhouseQueue, error)
GetQueue fetches and processes queue from Deckhouse leader
type DeckhouseQueueTask ¶
type QueueFetcher ¶
type QueueFetcher interface {
GetQueue(ctx context.Context) (DeckhouseQueue, error)
}
QueueFetcher encapsulates access to a queue
Click to show internal directories.
Click to hide internal directories.