Versions in this module Expand all Collapse all v1 v1.11.1 Jan 18, 2024 Changes in this version + var DNSProgrammingLatency = promauto.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... }) + var DurationSinceFunc = time.Since + func EndpointSliceToEndpoints(obj meta.Object) (meta.Object, error) + func EndpointsKey(name, namespace string) string + func NewIndexerInformer(lw cache.ListerWatcher, objType runtime.Object, h cache.ResourceEventHandler, ...) (cache.Indexer, cache.Controller) + func ServiceKey(name, namespace string) string + func ToNamespace(obj meta.Object) (meta.Object, error) + func ToPod(obj meta.Object) (meta.Object, error) + func ToService(obj meta.Object) (meta.Object, error) + type Empty struct + func (e *Empty) GetAnnotations() map[string]string + func (e *Empty) GetCreationTimestamp() v1.Time + func (e *Empty) GetDeletionGracePeriodSeconds() *int64 + func (e *Empty) GetDeletionTimestamp() *v1.Time + func (e *Empty) GetFinalizers() []string + func (e *Empty) GetGenerateName() string + func (e *Empty) GetGeneration() int64 + func (e *Empty) GetLabels() map[string]string + func (e *Empty) GetManagedFields() []v1.ManagedFieldsEntry + func (e *Empty) GetObjectKind() schema.ObjectKind + func (e *Empty) GetOwnerReferences() []v1.OwnerReference + func (e *Empty) GetSelfLink() string + func (e *Empty) GetUID() types.UID + func (e *Empty) GetZZZ_DeprecatedClusterName() string + func (e *Empty) SetAnnotations(annotations map[string]string) + func (e *Empty) SetCreationTimestamp(timestamp v1.Time) + func (e *Empty) SetDeletionGracePeriodSeconds(*int64) + func (e *Empty) SetDeletionTimestamp(timestamp *v1.Time) + func (e *Empty) SetFinalizers(finalizers []string) + func (e *Empty) SetGenerateName(name string) + func (e *Empty) SetGeneration(generation int64) + func (e *Empty) SetLabels(labels map[string]string) + func (e *Empty) SetManagedFields(managedFields []v1.ManagedFieldsEntry) + func (e *Empty) SetOwnerReferences([]v1.OwnerReference) + func (e *Empty) SetSelfLink(selfLink string) + func (e *Empty) SetUID(uid types.UID) + func (e *Empty) SetZZZ_DeprecatedClusterName(clusterName string) + type EndpointAddress struct + Hostname string + IP string + NodeName string + TargetRefName string + type EndpointLatencyRecorder struct + ServiceFunc func(meta.Object) []*Service + Services []*Service + TT time.Time + type EndpointPort struct + Name string + Port int32 + Protocol string + type EndpointSubset struct + Addresses []EndpointAddress + Ports []EndpointPort + type Endpoints struct + Index string + IndexIP []string + Name string + Namespace string + Subsets []EndpointSubset + Version string + func (e *Endpoints) CopyWithoutSubsets() *Endpoints + func (e *Endpoints) DeepCopyObject() runtime.Object + func (e *Endpoints) GetName() string + func (e *Endpoints) GetNamespace() string + func (e *Endpoints) GetResourceVersion() string + func (e *Endpoints) SetName(name string) + func (e *Endpoints) SetNamespace(namespace string) + func (e *Endpoints) SetResourceVersion(version string) + type Namespace struct + Name string + Version string + func (n *Namespace) DeepCopyObject() runtime.Object + func (n *Namespace) GetName() string + func (n *Namespace) GetNamespace() string + func (n *Namespace) GetResourceVersion() string + func (n *Namespace) SetName(name string) + func (n *Namespace) SetNamespace(namespace string) + func (n *Namespace) SetResourceVersion(version string) + type Pod struct + Name string + Namespace string + PodIP string + Version string + func (p *Pod) DeepCopyObject() runtime.Object + func (p *Pod) GetName() string + func (p *Pod) GetNamespace() string + func (p *Pod) GetResourceVersion() string + func (p *Pod) SetName(name string) + func (p *Pod) SetNamespace(namespace string) + func (p *Pod) SetResourceVersion(version string) + type ProcessorBuilder func(cache.Indexer, cache.ResourceEventHandler) cache.ProcessFunc + func DefaultProcessor(convert ToFunc, recordLatency *EndpointLatencyRecorder) ProcessorBuilder + type RecordLatencyFunc func(meta.Object) + type Service struct + ClusterIPs []string + ExternalIPs []string + ExternalName string + Index string + Name string + Namespace string + Ports []api.ServicePort + Type api.ServiceType + Version string + func (s *Service) DeepCopyObject() runtime.Object + func (s *Service) GetName() string + func (s *Service) GetNamespace() string + func (s *Service) GetResourceVersion() string + func (s *Service) Headless() bool + func (s *Service) SetName(name string) + func (s *Service) SetNamespace(namespace string) + func (s *Service) SetResourceVersion(version string) + type ToFunc func(v1.Object) (v1.Object, error)