kubernetes: k8s.io/kubernetes/pkg/controller/util/endpoint Index | Files

package endpoint

import "k8s.io/kubernetes/pkg/controller/util/endpoint"


Package Files

controller_utils.go trigger_time_tracker.go

func DeepHashObjectToString Uses

func DeepHashObjectToString(objectToWrite interface{}) string

DeepHashObjectToString creates a unique hash string from a go object.

func GetPodFromDeleteAction Uses

func GetPodFromDeleteAction(obj interface{}) *v1.Pod

GetPodFromDeleteAction returns a pointer to a pod if one can be derived from obj (could be a *v1.Pod, or a DeletionFinalStateUnknown marker item).

func GetServicesToUpdateOnPodChange Uses

func GetServicesToUpdateOnPodChange(serviceLister v1listers.ServiceLister, selectorCache *ServiceSelectorCache, old, cur interface{}) sets.String

GetServicesToUpdateOnPodChange returns a set of Service keys for Services that have potentially been affected by a change to this pod.

func ShouldPodBeInEndpointSlice Uses

func ShouldPodBeInEndpointSlice(pod *v1.Pod, includeTerminating bool) bool

ShouldPodBeInEndpointSlice returns true if a specified pod should be in an EndpointSlice object. Terminating pods are only included if includeTerminating is true

func ShouldSetHostname Uses

func ShouldSetHostname(pod *v1.Pod, svc *v1.Service) bool

ShouldSetHostname returns true if the Hostname attribute should be set on an Endpoints Address or EndpointSlice Endpoint.

type PortMapKey Uses

type PortMapKey string

PortMapKey is used to uniquely identify groups of endpoint ports.

func NewPortMapKey Uses

func NewPortMapKey(endpointPorts []discovery.EndpointPort) PortMapKey

NewPortMapKey generates a PortMapKey from endpoint ports.

type ServiceKey Uses

type ServiceKey struct {
    // namespace, name composing a namespaced name - an unique identifier of every Service.
    Namespace, Name string

ServiceKey is a key uniquely identifying a Service.

type ServiceSelectorCache Uses

type ServiceSelectorCache struct {
    // contains filtered or unexported fields

ServiceSelectorCache is a cache of service selectors to avoid high CPU consumption caused by frequent calls to AsSelectorPreValidated (see #73527)

func NewServiceSelectorCache Uses

func NewServiceSelectorCache() *ServiceSelectorCache

NewServiceSelectorCache init ServiceSelectorCache for both endpoint controller and endpointSlice controller.

func (*ServiceSelectorCache) Delete Uses

func (sc *ServiceSelectorCache) Delete(key string)

Delete can delete selector which exist in ServiceSelectorCache.

func (*ServiceSelectorCache) Get Uses

func (sc *ServiceSelectorCache) Get(key string) (labels.Selector, bool)

Get return selector and existence in ServiceSelectorCache by key.

func (*ServiceSelectorCache) GetPodServiceMemberships Uses

func (sc *ServiceSelectorCache) GetPodServiceMemberships(serviceLister v1listers.ServiceLister, pod *v1.Pod) (sets.String, error)

GetPodServiceMemberships returns a set of Service keys for Services that have a selector matching the given pod.

func (*ServiceSelectorCache) Update Uses

func (sc *ServiceSelectorCache) Update(key string, rawSelector map[string]string) labels.Selector

Update can update or add a selector in ServiceSelectorCache while service's selector changed.

type ServiceState Uses

type ServiceState struct {
    // contains filtered or unexported fields

ServiceState represents a state of an Service object that is known to this util.

type TriggerTimeTracker Uses

type TriggerTimeTracker struct {
    // ServiceStates is a map, indexed by Service object key, storing the last
    // known Service object state observed during the most recent call of the
    // ComputeEndpointLastChangeTriggerTime function.
    ServiceStates map[ServiceKey]ServiceState
    // contains filtered or unexported fields

TriggerTimeTracker is used to compute an EndpointsLastChangeTriggerTime annotation. See the documentation for that annotation for more details.

Please note that this util may compute a wrong EndpointsLastChangeTriggerTime if the same object changes multiple times between two consecutive syncs. We're aware of this limitation but we decided to accept it, as fixing it would require a major rewrite of the endpoint(Slice) controller and Informer framework. Such situations, i.e. frequent updates of the same object in a single sync period, should be relatively rare and therefore this util should provide a good approximation of the EndpointsLastChangeTriggerTime.

func NewTriggerTimeTracker Uses

func NewTriggerTimeTracker() *TriggerTimeTracker

NewTriggerTimeTracker creates a new instance of the TriggerTimeTracker.

func (*TriggerTimeTracker) ComputeEndpointLastChangeTriggerTime Uses

func (t *TriggerTimeTracker) ComputeEndpointLastChangeTriggerTime(
    namespace string, service *v1.Service, pods []*v1.Pod) time.Time

ComputeEndpointLastChangeTriggerTime updates the state of the Service/Endpoint object being synced and returns the time that should be exported as the EndpointsLastChangeTriggerTime annotation.

If the method returns a 'zero' time the EndpointsLastChangeTriggerTime annotation shouldn't be exported.

Please note that this function may compute a wrong value if the same object (pod/service) changes multiple times between two consecutive syncs.

Important: This method is go-routing safe but only when called for different keys. The method shouldn't be called concurrently for the same key! This contract is fulfilled in the current implementation of the endpoint(slice) controller.

func (*TriggerTimeTracker) DeleteService Uses

func (t *TriggerTimeTracker) DeleteService(namespace, name string)

DeleteService deletes service state stored in this util.

Package endpoint imports 17 packages (graph) and is imported by 5 packages. Updated 2020-11-23. Refresh now. Tools for package owners.