controller

Documentation

Index

• type Repair
  • func NewRepair(interval time.Duration, serviceClient corev1client.ServicesGetter, ...) *Repair
  • func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{})
• type RepairIPAddress
  • func NewRepairIPAddress(interval time.Duration, client kubernetes.Interface, network *net.IPNet, ...) *RepairIPAddress
  • func (r *RepairIPAddress) RunUntil(onFirstSuccess func(), stopCh chan struct{})

Types

type Repair

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

Repair is a controller loop that periodically examines all service ClusterIP allocations and logs any errors, and then sets the compacted and accurate list of all allocated IPs.

Handles: * Duplicate ClusterIP assignments caused by operator action or undetected race conditions * ClusterIPs that do not match the currently configured range * Allocations to services that were not actually created due to a crash or powerloss * Migrates old versions of Kubernetes services into the atomic ipallocator model automatically

Can be run at infrequent intervals, and is best performed on startup of the master. Is level driven and idempotent - all valid ClusterIPs will be updated into the ipallocator map at the end of a single execution loop if no race is encountered.

TODO: allocate new IPs if necessary TODO: perform repair?

func NewRepair

func NewRepair(interval time.Duration, serviceClient corev1client.ServicesGetter, eventClient eventsv1client.EventsV1Interface, network *net.IPNet, alloc rangeallocation.RangeRegistry, secondaryNetwork *net.IPNet, secondaryAlloc rangeallocation.RangeRegistry) *Repair

NewRepair creates a controller that periodically ensures that all clusterIPs 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.

type RepairIPAddress

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

func NewRepairIPAddress

func NewRepairIPAddress(interval time.Duration,
	client kubernetes.Interface,
	network *net.IPNet,
	secondaryNetwork *net.IPNet,
	serviceInformer coreinformers.ServiceInformer,
	ipAddressInformer networkinginformers.IPAddressInformer) *RepairIPAddress

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

func (*RepairIPAddress) RunUntil

func (r *RepairIPAddress) RunUntil(onFirstSuccess func(), stopCh chan struct{})

RunUntil starts the controller until the provided ch is closed.