workqueue

Documentation

Overview

Package workqueue provides a simplified wrapper interface for Kubernetes workqueues.

Index

• type Interface
  • func New(name string) Interface
• type ProcessFunc

Types

type Interface

type Interface interface {
	Enqueue(obj interface{})
	NumRequeues(key string) int
	Run(stopCh <-chan struct{}, process ProcessFunc)
	ShutDown()
	ShutDownWithDrain()
}

func New

func New(name string) Interface

type ProcessFunc

type ProcessFunc func(key, name, namespace string) (bool, error)