controller

type Controller ¶

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

Controller is the controller implementation for machine resources

func NewMachineController(
	kubeClient kubernetes.Interface,
	machineClient machineclientset.Interface,
	nodeInformer cache.SharedIndexInformer,
	nodeLister listerscorev1.NodeLister,
	machineInformer cache.SharedIndexInformer,
	machineLister machinelistersv1alpha1.MachineLister,
	secretSystemNsLister listerscorev1.SecretLister,
	clusterDNSIPs []net.IP,
	metrics *MetricsCollection,
	prometheusRegistry prometheus.Registerer,
	kubeconfigProvider KubeconfigProvider,
	name string) *Controller

func (c *Controller) ReadinessChecks() map[string]healthcheck.Check

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

type KubeconfigProvider ¶ added in v0.1.1

type KubeconfigProvider interface {
	GetKubeconfig() (*clientcmdapi.Config, error)
}

type MachineCollector ¶ added in v0.7.11

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

func NewMachineCollector(lister v1alpha1.MachineLister) *MachineCollector

func (mc MachineCollector) Collect(ch chan<- prometheus.Metric)

func (mc MachineCollector) Describe(ch chan<- *prometheus.Desc)

type MetricsCollection ¶ added in v0.1.0

type MetricsCollection struct {
	Workers prometheus.Gauge
	Errors  prometheus.Counter
}

MetricsCollection is a struct of all metrics used in this controller.

func NewMachineControllerMetrics() *MetricsCollection