kubecli

Documentation

Index

• func Get() (*kubernetes.Clientset, error)
• func GetRESTClient() (*rest.RESTClient, error)
• func NewInformer(lw cache.ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) (cache.Indexer, *cache.Controller)
• func NewListWatchFromClient(c cache.Getter, resource string, namespace string, ...) *cache.ListWatch
• func NewPanicCatcher() func()
• type ResourceEventHandler
• type ResourceEventHandlerFuncs
  • func (r ResourceEventHandlerFuncs) OnAdd(obj interface{}) error
  • func (r ResourceEventHandlerFuncs) OnDelete(obj interface{}) error
  • func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{}) error

Functions

func Get

func Get() (*kubernetes.Clientset, error)

func GetRESTClient

func GetRESTClient() (*rest.RESTClient, error)

func NewInformer

func NewInformer(
	lw cache.ListerWatcher,
	objType runtime.Object,
	resyncPeriod time.Duration,
	h ResourceEventHandler,
) (cache.Indexer, *cache.Controller)

func NewListWatchFromClient

func NewListWatchFromClient(c cache.Getter, resource string, namespace string, fieldSelector fields.Selector, labelSelector labels.Selector) *cache.ListWatch

NewListWatchFromClient creates a new ListWatch from the specified client, resource, namespace and field selector.

func NewPanicCatcher

func NewPanicCatcher() func()

Types

type ResourceEventHandler

type ResourceEventHandler interface {
	OnAdd(obj interface{}) error
	OnUpdate(oldObj, newObj interface{}) error
	OnDelete(obj interface{}) error
}

type ResourceEventHandlerFuncs

type ResourceEventHandlerFuncs struct {
	AddFunc    func(obj interface{}) error
	UpdateFunc func(oldObj, newObj interface{}) error
	DeleteFunc func(obj interface{}) error
}

func (ResourceEventHandlerFuncs) OnAdd

func (r ResourceEventHandlerFuncs) OnAdd(obj interface{}) error

func (ResourceEventHandlerFuncs) OnDelete

func (r ResourceEventHandlerFuncs) OnDelete(obj interface{}) error

func (ResourceEventHandlerFuncs) OnUpdate

func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{}) error