controller

Documentation

Index

• Constants
• func EndpointUpdateNeeded(healthyTargets []string, endpointAddresses []corev1.EndpointAddress) bool
• type Controller
  • func (c *Controller) Run()
  • func (c *Controller) UpdateEndpointTargets(endpoints corev1.Endpoints, ips []string) error

Constants

const (
	EndpointControllerEnable  = "endpoint-controller/enable"
	EndpointControllerTargets = "endpoint-controller/targets"
)

Functions

func EndpointUpdateNeeded

func EndpointUpdateNeeded(
	healthyTargets []string,
	endpointAddresses []corev1.EndpointAddress,
) bool

endpointUpdateNeeded check if the endpoint needs to be updated return true if update is needed return false if update is not needed.

Types

type Controller

type Controller struct {
	Clientset kubernetes.Interface
	Resync    time.Duration
	BlockMiss int
}

Controller defines the endpoint controller.

func (*Controller) Run

func (c *Controller) Run()

Run starts the endpoint controller.

func (*Controller) UpdateEndpointTargets

func (c *Controller) UpdateEndpointTargets(endpoints corev1.Endpoints, ips []string) error

Update endpoint targets.