controller

Documentation

Index

• type Controller
  • func NewController(m model.Model) (*Controller, error)
  • func (c *Controller) ScanLoop(ctx context.Context, scanInterval, addressExpiration time.Duration) error
  • func (c *Controller) Sync(ctx context.Context) (rev string, err error)
  • func (c *Controller) Watch(ctx context.Context, rev string) error

Types

type Controller

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

Controller is the controller service.

func NewController

func NewController(m model.Model) (*Controller, error)

NewController creates Controller

func (*Controller) ScanLoop

func (c *Controller) ScanLoop(ctx context.Context, scanInterval, addressExpiration time.Duration) error

ScanLoop scans IP address assignment table and Pods information periodically.

func (*Controller) Sync

func (c *Controller) Sync(ctx context.Context) (rev string, err error)

Sync retrieves all existing Node from Kubernetes API server then look for nodes that exist only in the coil database. Address blocks and IP addresses allocated to such deleted nodes are then released.

The function returns ResourceVersion rev for use in Watch().

func (*Controller) Watch

func (c *Controller) Watch(ctx context.Context, rev string) error

Watch watches Kubernetes API server to be informed of node deletions. When a node is deleted from Kubernetes, the controller frees address blocks and IP addresses allocated to the node soon.