package controller

import "k8s.io/kubernetes/pkg/registry/core/service/portallocator/controller"

Index ¶

• type Repair
• func NewRepair(interval time.Duration, serviceClient corev1client.ServicesGetter, eventClient eventsv1client.EventsV1Interface, portRange net.PortRange, alloc rangeallocation.RangeRegistry) *Repair
• func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{})

Types ¶

type Repair ¶

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

See ipallocator/controller/repair.go; this is a copy for ports.

func NewRepair ¶

func NewRepair(interval time.Duration, serviceClient corev1client.ServicesGetter, eventClient eventsv1client.EventsV1Interface, portRange net.PortRange, alloc rangeallocation.RangeRegistry) *Repair

NewRepair creates a controller that periodically ensures that all ports are uniquely allocated across the cluster and generates informational warnings for a cluster that is not in sync.

func (*Repair) RunUntil ¶

func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{})

RunUntil starts the controller until the provided ch is closed.

Source Files ¶

metrics.go repair.go