service

Documentation

Index

• type ServiceController
  • func NewServiceController(kubeclientset kubernetes.Interface, ...) *ServiceController
  • func (c *ServiceController) Run(threadiness int, stopCh <-chan struct{}) error

Types

type ServiceController

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

func NewServiceController

func NewServiceController(
	kubeclientset kubernetes.Interface,
	servicesInformer coreinformers.ServiceInformer,
	rolloutsInformer informers.RolloutInformer,
	resyncPeriod time.Duration,
	rolloutWorkQueue workqueue.RateLimitingInterface,
	serviceWorkQueue workqueue.RateLimitingInterface,
	metricServer *metrics.MetricsServer) *ServiceController

NewServiceController returns a new service controller

func (*ServiceController) Run

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