crdController

Documentation

Index

• Variables
• func AddHostAttributesTabObj(haobj *ha_schema.HostAttributesCrd, helper crdLabelAnnotate.APIHelpers, ...)
• func GetHaObjLabel(obj ha_schema.Host, node *corev1.Node, tagPrefix string) (crdLabelAnnotate.Labels, crdLabelAnnotate.Annotations, error)
• func NewIseclHAIndexerInformer(config *rest.Config, queue workqueue.RateLimitingInterface, ...) (cache.Indexer, cache.Controller)
• func NewIseclTaintHAIndexerInformer(config *rest.Config, queue workqueue.RateLimitingInterface, Mutex *sync.Mutex, ...) (cache.Indexer, cache.Controller)
• func TaintNode(Mutex *sync.Mutex, nodeHelper crdLabelAnnotate.APIHelpers, name string, ...)
• type CrdDefinition
  • func GetHACrdDef() CrdDefinition
• type IseclHAController
  • func NewIseclHAController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, ...) *IseclHAController
  • func (c *IseclHAController) Run(threadiness int, stopCh chan struct{})

Variables

var (
	TaintUntrustedNodes  = false
	TaintRegisteredNodes = false
	TaintRebootedNodes   = false
)

Functions

func AddHostAttributesTabObj

func AddHostAttributesTabObj(haobj *ha_schema.HostAttributesCrd, helper crdLabelAnnotate.APIHelpers, cli *k8sclient.Clientset, mutex *sync.Mutex, tagPrefix string)

AddHostAttributesTabObj Handler for addition event of the HA CRD

func GetHaObjLabel

func GetHaObjLabel(obj ha_schema.Host, node *corev1.Node, tagPrefix string) (crdLabelAnnotate.Labels, crdLabelAnnotate.Annotations, error)

GetHaObjLabel creates labels and annotations map based on HA CRD

func NewIseclHAIndexerInformer

func NewIseclHAIndexerInformer(config *rest.Config, queue workqueue.RateLimitingInterface, crdMutex *sync.Mutex, tagPrefix string) (cache.Indexer, cache.Controller)

NewIseclHAIndexerInformer returns informer for HA CRD object

func NewIseclTaintHAIndexerInformer

func NewIseclTaintHAIndexerInformer(config *rest.Config, queue workqueue.RateLimitingInterface, Mutex *sync.Mutex, tagPrefix string) (cache.Indexer, cache.Controller)

NewIseclTaintHAIndexerInformer for K8S Node Admission and Tainting

func TaintNode

func TaintNode(Mutex *sync.Mutex, nodeHelper crdLabelAnnotate.APIHelpers, name string, cli *k8sclient.Clientset)

TaintNode adds taint to nodes if the node is joined to the cluster or if the node is rebooted in the cluster

Types

type CrdDefinition

type CrdDefinition struct {
	Plural   string
	Singular string
	Group    string
	Kind     string
}

func GetHACrdDef

func GetHACrdDef() CrdDefinition

type IseclHAController

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

func NewIseclHAController

func NewIseclHAController(queue workqueue.RateLimitingInterface, indexer cache.Indexer, informer cache.Controller) *IseclHAController

func (*IseclHAController) Run

func (c *IseclHAController) Run(threadiness int, stopCh chan struct{})