watcher

Documentation

Index

• Variables
• type ConfigController
• type Controller
  • func NewController(kubeClient kubernetes.Interface, s coreinformer.ServiceInformer, ...) *Controller
  • func (c *Controller) Run(workers uint) func(<-chan struct{})
• type ControllerHandlers
• type PostSyncHandler

Variables

var (
	SyncTimeMetric = prometheus.NewHistogram(prometheus.HistogramOpts{
		Namespace: "balanced_controllers",
		Name:      "sync_time",
		Help:      "Controller Sync Time",
		Buckets:   prometheus.ExponentialBuckets(100000, float64(2), 20),
	})
	LastSyncTime = prometheus.NewGauge(prometheus.GaugeOpts{
		Namespace: "balanced_controllers",
		Name:      "sync_time_last",
		Help:      "Controller Last Sync Time",
	})
)

Types

type ConfigController

type ConfigController struct {
	Concurrency uint `json:"concurrency"`
}

type Controller

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

func NewController

func NewController(
	kubeClient kubernetes.Interface, s coreinformer.ServiceInformer, e coreinformer.EndpointsInformer,
	additionalInformers []cache.SharedIndexInformer, healthCheck *health.GenericHealthCheck,
	serviceManager v1alpha1.ServiceManager,
	chs *ControllerHandlers) *Controller

func (*Controller) Run

func (c *Controller) Run(workers uint) func(<-chan struct{})

type ControllerHandlers

type ControllerHandlers struct {
	// handlers that would be called during controller start up; during service manager population
	// WARNING: do not rely on serviceManager.List() or .Get() operations during service manager population
	// as it will not contain the full set of Kubernetes Services and Endpoints
	InitServiceOnChangeHandlers   []v1alpha1.ServiceOnChangeHandler
	InitEndpointsOnChangeHandlers []v1alpha1.EndpointOnChangeHandler

	// handlers that would be called during actual Kubernetes service/endpoints changes
	// it is safe to rely on serviceManager.List() or .Get() operations at this point
	ServiceOnChangeHandlers   []v1alpha1.ServiceOnChangeHandler
	EndpointsOnChangeHandlers []v1alpha1.EndpointOnChangeHandler

	// handlers to be done post sync (eg. garbage collection)
	PostSyncHandlers []PostSyncHandler
}

type PostSyncHandler

type PostSyncHandler func() error