agent

package
v7.1.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 29, 2019 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Initialize

func Initialize()

Initialize creates the informer factories and controllers.

func Run

func Run()

Run kicks off the informer factories and controller.

Types

type NodeLabelController

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

NodeLabelController reconciles node labels

func NewNodeLabelController

func NewNodeLabelController(
	clientset kubernetes.Interface,
	informerFactory informers.SharedInformerFactory) *NodeLabelController

NewNodeLabelController creates a new agent NodeLabelController

func (*NodeLabelController) Run

func (c *NodeLabelController) Run(numWorkers int, stopCh chan struct{}) error

Run kicks off the NodeLabelController with the given number of workers to process the workqueue

type UpgradeController

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

UpgradeController is the agent controller which watches for ClusterUpgrade updates and writes update script to host when it is that specific agents turn to update

func NewUpgradeController

func NewUpgradeController(
	kubeclientset kubernetes.Interface,
	csInformerFactory csinformers.SharedInformerFactory) *UpgradeController

NewUpgradeController creates a new agent UpgradeController

func (*UpgradeController) Run

func (uc *UpgradeController) Run(numWorkers int, stopCh <-chan struct{}) error

Run kicks off the Controller with the given number of workers to process the workqueue

type UserController

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

UserController is the agent controller which watches for CRD changes and reports back when a write to host is needed TODO this needs to be able to be instantiated with a different resource type

func NewUserController

func NewUserController(
	clientset csclientset.Interface,
	csInformerFactory csinformers.SharedInformerFactory) *UserController

NewUserController creates a new agent UserController

func (*UserController) Run

func (c *UserController) Run(numWorkers int, stopCh <-chan struct{}) error

Run kicks off the UserController with the given number of workers to process the workqueue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL