controllers

Documentation

Index

• type Controller
  • func BucketController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func DeploymentController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func EventController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func GitRepositoryController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func HelmChartController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func HelmReleaseController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func HelmRepositoryController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func IngressController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func KustomizeController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func NewController(name string, listWatcher cache.ListerWatcher, objType converterRuntime.Object, ...) *Controller
  • func NewDynamicController(name string, dynamicClient dynamic.Interface, ...) (*Controller, error)
  • func OciRepositoryController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func PodController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func ServiceController(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...) (*Controller, error)
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
• type Event

Types

type Controller

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

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

func BucketController

func BucketController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func DeploymentController

func DeploymentController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func EventController

func EventController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func GitRepositoryController

func GitRepositoryController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func HelmChartController

func HelmChartController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func HelmReleaseController

func HelmReleaseController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func HelmRepositoryController

func HelmRepositoryController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func IngressController

func IngressController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func KustomizeController

func KustomizeController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func NewController

func NewController(
	name string,
	listWatcher cache.ListerWatcher,
	objType converterRuntime.Object,
	eventHandler func(informerEvent Event, objectMeta metav1.ObjectMeta, obj interface{}) error,
) *Controller

NewController creates a new Controller.

func NewDynamicController

func NewDynamicController(
	name string,
	dynamicClient dynamic.Interface,
	resource schema.GroupVersionResource,
	eventHandler func(informerEvent Event, objectMeta metav1.ObjectMeta, obj interface{}) error,
) (*Controller, error)

func OciRepositoryController

func OciRepositoryController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func PodController

func PodController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func ServiceController

func ServiceController(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	clientHub *streaming.ClientHub,
) (*Controller, error)

func (*Controller) Run

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

Run begins watching and syncing.

type Event

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

Event indicate the informerEvent