package endpoints

import "k8s.io/kubernetes/test/e2e/framework/endpoints"

Index ¶

• Constants
• func ValidateEndpointsPorts(c clientset.Interface, namespace, serviceName string, expectedEndpoints PortsByPodName) error
• func WaitForEndpoint(c clientset.Interface, ns, name string) error
• type PortsByPodName
• type PortsByPodUID
• func GetContainerPortsByPodUID(ep *v1.Endpoints) PortsByPodUID

Constants ¶

const ServiceStartTimeout = 3 * time.Minute

ServiceStartTimeout is how long to wait for a service endpoint to be resolvable.

Functions ¶

func ValidateEndpointsPorts ¶

func ValidateEndpointsPorts(c clientset.Interface, namespace, serviceName string, expectedEndpoints PortsByPodName) error

ValidateEndpointsPorts validates that the given service exists and is served by the given expectedEndpoints.

func WaitForEndpoint ¶

func WaitForEndpoint(c clientset.Interface, ns, name string) error

WaitForEndpoint waits for the specified endpoint to be ready.

Types ¶

type PortsByPodName ¶

type PortsByPodName map[string][]int

PortsByPodName is a map that maps pod name to container ports.

type PortsByPodUID ¶

type PortsByPodUID map[types.UID][]int

PortsByPodUID is a map that maps pod UID to container ports.

func GetContainerPortsByPodUID ¶

func GetContainerPortsByPodUID(ep *v1.Endpoints) PortsByPodUID

GetContainerPortsByPodUID returns a PortsByPodUID map on the given endpoints.

Source Files ¶

ports.go wait.go