workqueue

Documentation

Index

• type MultiClusterQueues
  • func (s *MultiClusterQueues) All() []workqueue.RateLimitingInterface
  • func (s *MultiClusterQueues) Get(cluster string) workqueue.RateLimitingInterface
  • func (s *MultiClusterQueues) Remove(cluster string)
  • func (s *MultiClusterQueues) Set(cluster string, queue workqueue.RateLimitingInterface)

Types

type MultiClusterQueues

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

MultiClusterQueues multiplexes queues across multiple k8s clusters.

func (*MultiClusterQueues) All

func (s *MultiClusterQueues) All() []workqueue.RateLimitingInterface

currently unused, useful for debugging

func (*MultiClusterQueues) Get

func (s *MultiClusterQueues) Get(cluster string) workqueue.RateLimitingInterface

get the stored queues for the cluster

func (*MultiClusterQueues) Remove

func (s *MultiClusterQueues) Remove(cluster string)

removes the queue for a cluster

func (*MultiClusterQueues) Set

func (s *MultiClusterQueues) Set(cluster string, queue workqueue.RateLimitingInterface)

sets the queue for a cluster