Help us shape the future of Go! Take the 2026 Go Developer Survey

endpoint

package
v1.4.3 Latest Latest
Warning

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

Go to latest
Published: Oct 16, 2016 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package service provides EndpointController implementation to manage and sync service endpoints.

CAUTION: If you update code in this file, you may need to also update code

in contrib/mesos/pkg/service/endpoints_controller.go

Index

Constants

View Source
const (
	// We'll attempt to recompute EVERY service's endpoints at least this
	// often. Higher numbers = lower CPU/network load; lower numbers =
	// shorter amount of time before a mistaken endpoint is corrected.
	FullServiceResyncPeriod = 30 * time.Second

	// We must avoid syncing service until the pod store has synced. If it hasn't synced, to
	// avoid a hot loop, we'll wait this long between checks.
	PodStoreSyncedPollPeriod = 100 * time.Millisecond

	// An annotation on the Service denoting if the endpoints controller should
	// go ahead and create endpoints for unready pods. This annotation is
	// currently only used by PetSets, where we need the pet to be DNS
	// resolvable during initialization. In this situation we create a headless
	// service just for the PetSet, and clients shouldn't be using this Service
	// for anything so unready endpoints don't matter.
	TolerateUnreadyEndpointsAnnotation = "service.alpha.kubernetes.io/tolerate-unready-endpoints"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type EndpointController

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

EndpointController manages selector-based service endpoints.

func NewEndpointController

func NewEndpointController(podInformer cache.SharedIndexInformer, client *clientset.Clientset) *EndpointController

NewEndpointController returns a new *EndpointController.

func NewEndpointControllerFromClient added in v1.3.0

func NewEndpointControllerFromClient(client *clientset.Clientset, resyncPeriod controller.ResyncPeriodFunc) *EndpointController

NewEndpointControllerFromClient returns a new *EndpointController that runs its own informer.

func (*EndpointController) Run

func (e *EndpointController) Run(workers int, stopCh <-chan struct{})

Runs e; will not return until stopCh is closed. workers determines how many endpoints will be handled in parallel.

Jump to

Keyboard shortcuts

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