v1.30.0 Latest Latest

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

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 27 Imported by: 0




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

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


This section is empty.


This section is empty.


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

Jump to

Keyboard shortcuts

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