informer_extra

Documentation

Index

• func NewListWatchFromFunc(listFunc cache.ListFunc, watchFunc cache.WatchFunc) *cache.ListWatch
• type Controller
  • func NewController(lw cache.ListerWatcher, requeueTimes int, objType pkg_runtime.Object, ...) *Controller
  • func (c *Controller) Run(workers int, stopCh <-chan struct{})

Functions

func NewListWatchFromFunc

func NewListWatchFromFunc(listFunc cache.ListFunc, watchFunc cache.WatchFunc) *cache.ListWatch

NewListWatchFromFunc creates a new ListWatch from the specified func

Types

type Controller

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

Controller demonstrates how to implement a controller with client-go.

func NewController

func NewController(
	lw cache.ListerWatcher,
	requeueTimes int,
	objType pkg_runtime.Object,
	businessFunc func(key string, count int, object interface{}) error,
	loopDoneErrFunc func(err error, count int, key interface{}, obj interface{}),
	transformer cache.TransformFunc,
	shouldReSync cache.ShouldResyncFunc,
	watchErrorHandler cache.WatchErrorHandler,
	retryOnError bool,
	watchListPageSize int64,
) *Controller

NewController creates a new Controller.

func (*Controller) Run

func (c *Controller) Run(workers int, stopCh <-chan struct{})

Run begins watching and syncing.