kubernetes: k8s.io/kubernetes/pkg/registry/core/service/portallocator/controller Index | Files

package controller

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


Package Files


type Repair Uses

type Repair struct {
    // contains filtered or unexported fields

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

func NewRepair Uses

func NewRepair(interval time.Duration, serviceClient corev1client.ServicesGetter, eventClient corev1client.EventsGetter, 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) RunOnce Uses

func (c *Repair) RunOnce() error

RunOnce verifies the state of the port allocations and returns an error if an unrecoverable problem occurs.

func (*Repair) RunUntil Uses

func (c *Repair) RunUntil(ch chan struct{})

RunUntil starts the controller until the provided ch is closed.

Package controller imports 15 packages (graph) and is imported by 1 packages. Updated 2019-08-17. Refresh now. Tools for package owners.