controller

Documentation

Index

• type Repair
  • func NewRepair(interval time.Duration, registry service.Registry, portRange util.PortRange, ...) *Repair
  • func (c *Repair) RunOnce() error
  • func (c *Repair) RunUntil(ch 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, registry service.Registry, portRange util.PortRange, alloc service.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

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

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

RunUntil starts the controller until the provided ch is closed.