controller

Documentation

Index

• Variables
• func Hash(certificate *x509.Certificate) string
• type NodeTaskController
  • func NewNodeTaskController(kube kubernetes.Interface, ntclient clientset.Interface, ...) *NodeTaskController
  • func (ntController *NodeTaskController) Run(threadiness int, stopCh <-chan struct{}) error

Variables

var (
	KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc
)

Functions

func Hash

func Hash(certificate *x509.Certificate) string

Types

type NodeTaskController

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

func NewNodeTaskController

func NewNodeTaskController(kube kubernetes.Interface, ntclient clientset.Interface, ntInformer informers.NodeTaskInformer, nodetaskctx *context.NodeTaskContext, recorder record.EventRecorder) *NodeTaskController

func (*NodeTaskController) Run

func (ntController *NodeTaskController) Run(threadiness int, stopCh <-chan struct{}) error