agent

Documentation

Index

• func Initialize()
• func Run()
• type NodeLabelController
  • func NewNodeLabelController(clientset kubernetes.Interface, ...) *NodeLabelController
  • func (c *NodeLabelController) Run(numWorkers int, stopCh chan struct{}) error
• type UpgradeController
  • func NewUpgradeController(kubeclientset kubernetes.Interface, ...) *UpgradeController
  • func (uc *UpgradeController) Run(numWorkers int, stopCh <-chan struct{}) error
• type UserController
  • func NewUserController(clientset hksclientset.Interface, ...) *UserController
  • func (c *UserController) Run(numWorkers int, stopCh <-chan struct{}) error

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,
	hksInformerFactory hksinformers.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 hksclientset.Interface,
	hksInformerFactory hksinformers.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