controller

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 2, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL