tagging

Documentation

Index

• Constants
• type Controller
  • func NewTaggingController(nodeInformer coreinformers.NodeInformer, kubeClient clientset.Interface, ...) (*Controller, error)
  • func (tc *Controller) Run(stopCh <-chan struct{})
• type ControllerWrapper
  • func (tc *ControllerWrapper) StartTaggingControllerWrapper(initContext app.ControllerInitContext, ...) app.InitFunc

Constants

const (
	// TaggingControllerClientName is the name of the tagging controller
	TaggingControllerClientName = "tagging-controller"

	// TaggingControllerKey is the key used to register this controller
	TaggingControllerKey = "tagging"
)

Types

type Controller

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

Controller is the controller implementation for tagging cluster resources. It periodically checks for Node events (creating/deleting) to apply/delete appropriate tags to resources.

func NewTaggingController

func NewTaggingController(
	nodeInformer coreinformers.NodeInformer,
	kubeClient clientset.Interface,
	cloud cloudprovider.Interface,
	nodeMonitorPeriod time.Duration,
	tags map[string]string,
	resources []string,
	rateLimit float64,
	burstLimit int) (*Controller, error)

NewTaggingController creates a NewTaggingController object

func (*Controller) Run

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

Run will start the controller to tag resources attached to the cluster and untag resources detached from the cluster.

type ControllerWrapper

type ControllerWrapper struct {
	Options options.TaggingControllerOptions
}

ControllerWrapper is the wrapper for the tagging controller

func (*ControllerWrapper) StartTaggingControllerWrapper

func (tc *ControllerWrapper) StartTaggingControllerWrapper(initContext app.ControllerInitContext, completedConfig *cloudcontrollerconfig.CompletedConfig, cloud cloudprovider.Interface) app.InitFunc

StartTaggingControllerWrapper is used to take cloud config as input and start the tagging controller