workload

Documentation

Index

• func CRDMeta() *crd.CRDMeta
• type Controller
  • func NewController(ctx *ControllerContext, logger klog.Logger) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{})
• type ControllerContext
  • func NewControllerContext(kubeClient kubernetes.Interface, workloadClient workloadclient.Interface, ...) *ControllerContext
  • func (ctx *ControllerContext) HasSynced() bool
  • func (ctx *ControllerContext) Start(stopCh chan struct{})

Functions

func CRDMeta

func CRDMeta() *crd.CRDMeta

Types

type Controller

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

Controller represents a workload controller.

func NewController

func NewController(ctx *ControllerContext, logger klog.Logger) *Controller

NewController returns a workload controller.

func (*Controller) Run

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

type ControllerContext

type ControllerContext struct {
	KubeClient     kubernetes.Interface
	WorkloadClient workloadclient.Interface

	WorkloadInformer      cache.SharedIndexInformer
	ServiceInformer       cache.SharedIndexInformer
	EndpointSliceInformer cache.SharedIndexInformer
}

ControllerContext holds the state needed for the execution of the workload controller.

func NewControllerContext

func NewControllerContext(
	kubeClient kubernetes.Interface,
	workloadClient workloadclient.Interface,
	namespace string,
	resyncPeriod time.Duration,
) *ControllerContext

NewControllerContext returns a new shared set of informers.

func (*ControllerContext) HasSynced

func (ctx *ControllerContext) HasSynced() bool

HasSynced returns true if all relevant informers has been synced.

func (*ControllerContext) Start

func (ctx *ControllerContext) Start(stopCh chan struct{})

Start all of the informers.