controller

Documentation

Index

• type StoreToIngressLister
• type TaskQueue
  • func NewTaskQueue(syncFn func(string)) *TaskQueue
  • func (t *TaskQueue) Enqueue(obj interface{})
  • func (t *TaskQueue) Requeue(key string, err error)
  • func (t *TaskQueue) Run(period time.Duration, stopCh <-chan struct{})
  • func (t *TaskQueue) Shutdown()

Types

type StoreToIngressLister

type StoreToIngressLister struct {
	cache.Store
}

StoreToIngressLister makes a Store that lists Ingress.

type TaskQueue

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

TaskQueue manages a work queue through an independent worker that invokes the given sync function for every work item inserted.

func NewTaskQueue

func NewTaskQueue(syncFn func(string)) *TaskQueue

NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.

func (*TaskQueue) Enqueue

func (t *TaskQueue) Enqueue(obj interface{})

Enqueue enqueues ns/name of the given api object in the task queue.

func (*TaskQueue) Requeue

func (t *TaskQueue) Requeue(key string, err error)

func (*TaskQueue) Run

func (t *TaskQueue) Run(period time.Duration, stopCh <-chan struct{})

func (*TaskQueue) Shutdown

func (t *TaskQueue) Shutdown()

Shutdown shuts down the work queue and waits for the worker to ACK