kubecli

Documentation

Index

• func Get() (*kubernetes.Clientset, error)
• func GetFromFlags(master string, kubeconfig string) (*kubernetes.Clientset, error)
• func GetRESTClient() (*rest.RESTClient, error)
• func GetRESTClientFromFlags(master string, kubeconfig string) (*rest.RESTClient, error)
• func HandlePanic()
• func NewListWatchFromClient(c cache.Getter, resource string, namespace string, ...) *cache.ListWatch
• func NewResourceEventHandlerFuncsForQorkqueue(queue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs
• type Controller
  • func NewController(lw cache.ListerWatcher, queue workqueue.RateLimitingInterface, ...) (cache.Store, *Controller)
  • func NewControllerFromInformer(indexer cache.Store, informer cache.ControllerInterface, ...) (cache.Store, *Controller)
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
  • func (c *Controller) ShutDownQueue()
  • func (c *Controller) StartInformer(stopCh chan struct{})
  • func (c *Controller) WaitForSync(stopCh chan struct{})
  • func (c *Controller) WaitUntilDone()
• type ControllerFunc

Functions

func Get

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

func GetFromFlags

func GetFromFlags(master string, kubeconfig string) (*kubernetes.Clientset, error)

func GetRESTClient

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

func GetRESTClientFromFlags

func GetRESTClientFromFlags(master string, kubeconfig string) (*rest.RESTClient, error)

func HandlePanic

func HandlePanic()

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 NewResourceEventHandlerFuncsForQorkqueue

func NewResourceEventHandlerFuncsForQorkqueue(queue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs

Types

type Controller

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

func NewController

func NewController(lw cache.ListerWatcher, queue workqueue.RateLimitingInterface, objType runtime.Object, f ControllerFunc) (cache.Store, *Controller)

func NewControllerFromInformer

func NewControllerFromInformer(indexer cache.Store, informer cache.ControllerInterface, queue workqueue.RateLimitingInterface, f ControllerFunc) (cache.Store, *Controller)

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{})

func (*Controller) ShutDownQueue

func (c *Controller) ShutDownQueue()

Shut down the embedded queue. After the shutdown was issued, all items already in the queue will be processed but no new items will be accepted. It is possible to wait via #WaitUntilDone() until the last item was processed.

func (*Controller) StartInformer

func (c *Controller) StartInformer(stopCh chan struct{})

func (*Controller) WaitForSync

func (c *Controller) WaitForSync(stopCh chan struct{})

func (*Controller) WaitUntilDone

func (c *Controller) WaitUntilDone()

type ControllerFunc

type ControllerFunc func(cache.Store, workqueue.RateLimitingInterface, interface{})