Documentation ¶
Index ¶
- func GetPodFromDeleteAction(obj interface{}) *v1.Pod
- func GetPodServiceMemberships(serviceLister v1listers.ServiceLister, pod *v1.Pod) (sets.String, error)
- func GetServicesToUpdateOnPodChange(serviceLister v1listers.ServiceLister, old, cur interface{}, ...) sets.String
- func PodChanged(oldPod, newPod *v1.Pod, endpointChanged EndpointsMatch) (bool, bool)
- func ShouldPodBeInEndpoints(pod *v1.Pod) bool
- type EndpointsMatch
- type ServiceKey
- type ServiceState
- type TriggerTimeTracker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPodFromDeleteAction ¶
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 GetPodServiceMemberships ¶
func 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 GetServicesToUpdateOnPodChange ¶
func GetServicesToUpdateOnPodChange(serviceLister v1listers.ServiceLister, old, cur interface{}, endpointChanged EndpointsMatch) sets.String
GetServicesToUpdateOnPodChange returns a set of Service keys for Services that have potentially been affected by a change to this pod.
func PodChanged ¶
func PodChanged(oldPod, newPod *v1.Pod, endpointChanged EndpointsMatch) (bool, bool)
PodChanged returns two boolean values, the first returns true if the pod. has changed, the second value returns true if the pod labels have changed.
func ShouldPodBeInEndpoints ¶
ShouldPodBeInEndpoints returns true if a specified pod should be in an endpoints object.
Types ¶
type EndpointsMatch ¶
EndpointsMatch is a type of function that returns true if pod endpoints match.
type ServiceKey ¶
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 ServiceState ¶
type ServiceState struct {
// contains filtered or unexported fields
}
ServiceState represents a state of an Service object that is known to this util.
type TriggerTimeTracker ¶
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 ¶
func NewTriggerTimeTracker() *TriggerTimeTracker
NewTriggerTimeTracker creates a new instance of the TriggerTimeTracker.
func (*TriggerTimeTracker) ComputeEndpointLastChangeTriggerTime ¶
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 ¶
func (t *TriggerTimeTracker) DeleteService(namespace, name string)
DeleteService deletes service state stored in this util.