Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const AffinityConfirmCount + const KubeProxyEndpointLagTimeout + const KubeProxyLagTimeout + const LargeClusterMinNodesNumber + const LoadBalancerCleanupTimeout + const LoadBalancerCreateTimeoutDefault + const LoadBalancerCreateTimeoutLarge + const LoadBalancerLagTimeoutAWS + const LoadBalancerLagTimeoutDefault + const LoadBalancerPollInterval + const LoadBalancerPollTimeout + const MaxNodesForEndpointsTests + const RespondingTimeout + const ServiceEndpointsTimeout + const ServiceReachabilityShortPollTimeout + const TestTimeout + var NodePortRange = utilnet.PortRange + var PauseDeploymentLabels = map[string]string + func CleanupServiceResources(c clientset.Interface, loadBalancerName, region, zone string) + func CreateServiceSpec(serviceName, externalName string, isHeadless bool, selector map[string]string) *v1.Service + func DescribeSvc(ns string) + func EnableAndDisableInternalLB() (enable func(svc *v1.Service), disable func(svc *v1.Service)) + func GetIngressPoint(ing *v1.LoadBalancerIngress) string + func GetServiceLoadBalancerCreationTimeout(cs clientset.Interface) time.Duration + func GetServicesProxyRequest(c clientset.Interface, request *restclient.Request) (*restclient.Request, error) + func StartServeHostnameService(c clientset.Interface, svc *v1.Service, ns string, replicas int) ([]string, string, error) + func StopServeHostnameService(clientset clientset.Interface, ns, name string) error + func UpdateService(c clientset.Interface, namespace, serviceName string, update func(*v1.Service)) (*v1.Service, error) + func VerifyServeHostnameServiceDown(c clientset.Interface, host string, serviceIP string, servicePort int) error + func VerifyServeHostnameServiceUp(c clientset.Interface, ns, host string, expectedPods []string, ...) error + func WaitForServiceDeletedWithFinalizer(cs clientset.Interface, namespace, name string) + func WaitForServiceResponding(c clientset.Interface, ns, name string) error + func WaitForServiceUpdatedWithFinalizer(cs clientset.Interface, namespace, name string, hasFinalizer bool) + type TestFixture struct + Client clientset.Interface + Image string + Labels map[string]string + Name string + Namespace string + ServiceName string + TestID string + func NewServerTest(client clientset.Interface, namespace string, serviceName string) *TestFixture + func (t *TestFixture) BuildServiceSpec() *v1.Service + func (t *TestFixture) Cleanup() []error + func (t *TestFixture) CreateRC(rc *v1.ReplicationController) (*v1.ReplicationController, error) + func (t *TestFixture) CreateService(service *v1.Service) (*v1.Service, error) + func (t *TestFixture) DeleteService(serviceName string) error + type TestJig struct + Client clientset.Interface + ID string + Labels map[string]string + Name string + func NewTestJig(client clientset.Interface, name string) *TestJig + func (j *TestJig) AddRCAntiAffinity(rc *v1.ReplicationController) + func (j *TestJig) ChangeServiceNodePortOrFail(namespace, name string, initial int) *v1.Service + func (j *TestJig) ChangeServiceType(namespace, name string, newType v1.ServiceType, timeout time.Duration) + func (j *TestJig) CheckAffinity(execPod *v1.Pod, targetIP string, targetPort int, shouldHold bool) bool + func (j *TestJig) CheckServiceReachability(namespace string, svc *v1.Service, pod *v1.Pod) + func (j *TestJig) CreateExternalNameServiceOrFail(namespace string, tweak func(svc *v1.Service)) *v1.Service + func (j *TestJig) CreateLoadBalancerService(namespace, serviceName string, timeout time.Duration, ...) *v1.Service + func (j *TestJig) CreateOnlyLocalLoadBalancerService(namespace, serviceName string, timeout time.Duration, createPod bool, ...) *v1.Service + func (j *TestJig) CreateOnlyLocalNodePortService(namespace, serviceName string, createPod bool) *v1.Service + func (j *TestJig) CreatePDBOrFail(namespace string, rc *v1.ReplicationController) *policyv1beta1.PodDisruptionBudget + func (j *TestJig) CreatePausePodDeployment(name, ns string, replica int32) *appsv1.Deployment + func (j *TestJig) CreateServicePods(c clientset.Interface, ns string, replica int) + func (j *TestJig) CreateServiceWithServicePort(labels map[string]string, namespace string, ports []v1.ServicePort) (*v1.Service, error) + func (j *TestJig) CreateTCPServiceOrFail(namespace string, tweak func(svc *v1.Service)) *v1.Service + func (j *TestJig) CreateTCPServiceWithPort(namespace string, tweak func(svc *v1.Service), port int32) *v1.Service + func (j *TestJig) CreateUDPServiceOrFail(namespace string, tweak func(svc *v1.Service)) *v1.Service + func (j *TestJig) GetEndpointNodes(svc *v1.Service) map[string][]string + func (j *TestJig) GetHTTPContent(host string, port int, timeout time.Duration, url string) bytes.Buffer + func (j *TestJig) GetNodes(maxNodesForTest int) (nodes *v1.NodeList) + func (j *TestJig) GetNodesNames(maxNodesForTest int) []string + func (j *TestJig) RunOrFail(namespace string, tweak func(rc *v1.ReplicationController)) *v1.ReplicationController + func (j *TestJig) SanityCheckService(svc *v1.Service, svcType v1.ServiceType) + func (j *TestJig) Scale(namespace string, replicas int) + func (j *TestJig) TestHTTPHealthCheckNodePort(host string, port int, request string, timeout time.Duration, ...) error + func (j *TestJig) TestNotReachableHTTP(host string, port int, timeout time.Duration) + func (j *TestJig) TestNotReachableUDP(host string, port int, timeout time.Duration) + func (j *TestJig) TestReachableHTTP(host string, port int, timeout time.Duration) + func (j *TestJig) TestReachableHTTPWithRetriableErrorCodes(host string, port int, retriableErrCodes []int, timeout time.Duration) + func (j *TestJig) TestReachableUDP(host string, port int, timeout time.Duration) + func (j *TestJig) TestRejectedHTTP(host string, port int, timeout time.Duration) + func (j *TestJig) TestRejectedUDP(host string, port int, timeout time.Duration) + func (j *TestJig) UpdateService(namespace, name string, update func(*v1.Service)) (*v1.Service, error) + func (j *TestJig) UpdateServiceOrFail(namespace, name string, update func(*v1.Service)) *v1.Service + func (j *TestJig) WaitForAvailableEndpoint(namespace, serviceName string, timeout time.Duration) + func (j *TestJig) WaitForEndpointOnNode(namespace, serviceName, nodeName string) + func (j *TestJig) WaitForLoadBalancerDestroyOrFail(namespace, name string, ip string, port int, timeout time.Duration) *v1.Service + func (j *TestJig) WaitForLoadBalancerOrFail(namespace, name string, timeout time.Duration) *v1.Service + func (j *TestJig) WaitForNewIngressIPOrFail(namespace, name, existingIP string, timeout time.Duration) *v1.Service