const rsaBits … const validFor … const IngressClassKey … const MulticlusterIngressClassValue … const IngressStaticIPKey … const IngressAllowHTTPKey … const IngressPreSharedCertKey … const ServiceApplicationProtocolKey … const defaultBackendName … const IngressManifestPath … const GCEIngressManifestPath … const IngressReqTimeout … const NEGAnnotation … const NEGStatusAnnotation … const StatusPrefix … const poll … type TestLogger … type E2ELogger … // Infof outputs log. func (l *E2ELogger) Infof(format string, args ...interface{ … } // Errorf outputs log. func (l *E2ELogger) Errorf(format string, args ...interface{ … } type ConformanceTests … type NegStatus … // SimpleGET executes a get on the given url, returns error if non-200 returned. func SimpleGET(ctx context.Context, c *http.Client, url, host string) (string, error) { … } // PollURL polls till the url responds with a healthy http code. If // expectUnreachable is true, it breaks on first non-healthy http code instead. func PollURL(ctx context.Context, route, host string, timeout time.Duration, interval time.Duration, httpClient *http.Client, expectUnreachable bool) error { … } // CreateIngressComformanceTests generates an slice of sequential test cases: // a simple http ingress, ingress with HTTPS, ingress HTTPS with a modified hostname, // ingress https with a modified URLMap func CreateIngressComformanceTests(ctx context.Context, jig *TestJig, ns string, annotations map[string]string) []ConformanceTests { … } // GenerateRSACerts generates a basic self signed certificate using a key length // of rsaBits, valid for validFor time. func GenerateRSACerts(host string, isCA bool) ([]byte, []byte, error) { … } // buildTransportWithCA creates a transport for use in executing HTTPS requests with // the given certs. Note that the given rootCA must be configured with isCA=true. func buildTransportWithCA(serverName string, rootCA []byte) (*http.Transport, error) { … } // BuildInsecureClient returns an insecure http client. Can be used for "curl -k". func BuildInsecureClient(timeout time.Duration) *http.Client { … } // createTLSSecret creates a secret containing TLS certificates. // If a secret with the same name already pathExists in the namespace of the // Ingress, it's updated. func createTLSSecret(ctx context.Context, kubeClient clientset.Interface, namespace, secretName string, hosts ...string) (host string, rootCA, privKey []byte, err error) { … } type TestJig … // NewIngressTestJig instantiates struct with client func NewIngressTestJig(c clientset.Interface) *TestJig { … } // CreateIngress creates the Ingress and associated service/rc. // Required: ing.yaml, rc.yaml, svc.yaml must exist in manifestPath // Optional: secret.yaml, ingAnnotations // If ingAnnotations is specified it will overwrite any annotations in ing.yaml // If svcAnnotations is specified it will overwrite any annotations in svc.yaml func (j *TestJig) CreateIngress(ctx context.Context, manifestPath, ns string, ingAnnotations map[string]string, svcAnnotations map[string]string) { … } // marshalToYaml marshals an object into YAML for a given GroupVersion. // The object must be known in SupportedMediaTypes() for the Codecs under "client-go/kubernetes/scheme". func marshalToYaml(obj runtime.Object, gv schema.GroupVersion) ([]byte, error) { … } // ingressFromManifest reads a .json/yaml file and returns the ingress in it. func ingressFromManifest(fileName string) (*networkingv1.Ingress, error) { … } // ingressToManifest generates a yaml file in the given path with the given ingress. // Assumes that a directory exists at the given path. func ingressToManifest(ing *networkingv1.Ingress, path string) error { … } // runCreate runs the required command to create the given ingress. func (j *TestJig) runCreate(ctx context.Context, ing *networkingv1.Ingress) (*networkingv1.Ingress, error) { … } // runUpdate runs the required command to update the given ingress. func (j *TestJig) runUpdate(ctx context.Context, ing *networkingv1.Ingress) (*networkingv1.Ingress, error) { … } // DescribeIng describes information of ingress by running kubectl describe ing. func DescribeIng(ns string) { … } // Update retrieves the ingress, performs the passed function, and then updates it. func (j *TestJig) Update(ctx context.Context, update func(ing *networkingv1.Ingress)) { … } // AddHTTPS updates the ingress to add this secret for these hosts. func (j *TestJig) AddHTTPS(ctx context.Context, secretName string, hosts ...string) { … } // SetHTTPS updates the ingress to use only this secret for these hosts. func (j *TestJig) SetHTTPS(ctx context.Context, secretName string, hosts ...string) { … } // RemoveHTTPS updates the ingress to not use this secret for TLS. // Note: Does not delete the secret. func (j *TestJig) RemoveHTTPS(ctx context.Context, secretName string) { … } // PrepareTLSSecret creates a TLS secret and caches the cert. func (j *TestJig) PrepareTLSSecret(ctx context.Context, namespace, secretName string, hosts ...string) error { … } // GetRootCA returns a rootCA from the ingress test jig. func (j *TestJig) GetRootCA(secretName string) (rootCA []byte) { … } // TryDeleteIngress attempts to delete the ingress resource and logs errors if they occur. func (j *TestJig) TryDeleteIngress(ctx context.Context) { … } func (j *TestJig) tryDeleteGivenIngress(ctx context.Context, ing *networkingv1.Ingress) { … } // runDelete runs the required command to delete the given ingress. func (j *TestJig) runDelete(ctx context.Context, ing *networkingv1.Ingress) error { … } // getIngressAddressFromKubemci returns the IP address of the given multicluster ingress using kubemci. // TODO(nikhiljindal): Update this to be able to return hostname as well. func getIngressAddressFromKubemci(name string) ([]string, error) { … } // findIPv4 returns the first IPv4 address found in the given string. func findIPv4(input string) string { … } // getIngressAddress returns the ips/hostnames associated with the Ingress. func getIngressAddress(ctx context.Context, client clientset.Interface, ns, name, class string) ([]string, error) { … } // WaitForIngressAddress waits for the Ingress to acquire an address. func (j *TestJig) WaitForIngressAddress(ctx context.Context, c clientset.Interface, ns, ingName string, timeout time.Duration) (string, error) { … } func (j *TestJig) pollIngressWithCert(ctx context.Context, ing *networkingv1.Ingress, address string, knownHosts []string, cert []byte, waitForNodePort bool, timeout time.Duration) error { … } // WaitForIngress waits for the Ingress to get an address. // WaitForIngress returns when it gets the first 200 response func (j *TestJig) WaitForIngress(ctx context.Context, waitForNodePort bool) { … } // WaitForIngressToStable waits for the LB return 100 consecutive 200 responses. func (j *TestJig) WaitForIngressToStable(ctx context.Context) { … } // WaitForGivenIngressWithTimeout waits till the ingress acquires an IP, // then waits for its hosts/urls to respond to a protocol check (either // http or https). If waitForNodePort is true, the NodePort of the Service // is verified before verifying the Ingress. NodePort is currently a // requirement for cloudprovider Ingress. func (j *TestJig) WaitForGivenIngressWithTimeout(ctx context.Context, ing *networkingv1.Ingress, waitForNodePort bool, timeout time.Duration) error { … } // WaitForIngressWithCert waits till the ingress acquires an IP, then waits for its // hosts/urls to respond to a protocol check (either http or https). If // waitForNodePort is true, the NodePort of the Service is verified before // verifying the Ingress. NodePort is currently a requirement for cloudprovider // Ingress. Hostnames and certificate need to be explicitly passed in. func (j *TestJig) WaitForIngressWithCert(ctx context.Context, waitForNodePort bool, knownHosts []string, cert []byte) error { … } // VerifyURL polls for the given iterations, in intervals, and fails if the // given url returns a non-healthy http code even once. func (j *TestJig) VerifyURL(ctx context.Context, route, host string, iterations int, interval time.Duration, httpClient *http.Client) error { … } func (j *TestJig) pollServiceNodePort(ctx context.Context, ns, name string, port int) error { … } // getSvcNodePort returns the node port for the given service:port. func getSvcNodePort(ctx context.Context, client clientset.Interface, ns, name string, svcPort int) (int, error) { … } // getPortURL returns the url to a nodeport Service. func getPortURL(ctx context.Context, client clientset.Interface, ns, name string, svcPort int) (string, error) { … } // GetIngressNodePorts returns related backend services' nodePorts. // Current GCE ingress controller allows traffic to the default HTTP backend // by default, so retrieve its nodePort if includeDefaultBackend is true. func (j *TestJig) GetIngressNodePorts(ctx context.Context, includeDefaultBackend bool) []string { … } // GetServicePorts returns related backend services' svcPorts. // Current GCE ingress controller allows traffic to the default HTTP backend // by default, so retrieve its nodePort if includeDefaultBackend is true. func (j *TestJig) GetServicePorts(ctx context.Context, includeDefaultBackend bool) map[string]v1.ServicePort { … } // GetDistinctResponseFromIngress tries GET call to the ingress VIP and return all distinct responses. func (j *TestJig) GetDistinctResponseFromIngress(ctx context.Context) (sets.String, error) { … } type NginxIngressController … // Init initializes the NginxIngressController func (cont *NginxIngressController) Init(ctx context.Context) { … } // TearDown cleans up the NginxIngressController. func (cont *NginxIngressController) TearDown(ctx context.Context) { … } func generateBacksideHTTPSIngressSpec(ns string) *networkingv1.Ingress { … } func generateBacksideHTTPSServiceSpec() *v1.Service { … } func generateBacksideHTTPSDeploymentSpec() *appsv1.Deployment { … } // SetUpBacksideHTTPSIngress sets up deployment, service and ingress with backside HTTPS configured. func (j *TestJig) SetUpBacksideHTTPSIngress(ctx context.Context, cs clientset.Interface, namespace string, staticIPName string) (*appsv1.Deployment, *v1.Service, *networkingv1.Ingress, error) { … } // DeleteTestResource deletes given deployment, service and ingress. func (j *TestJig) DeleteTestResource(ctx context.Context, cs clientset.Interface, deploy *appsv1.Deployment, svc *v1.Service, ing *networkingv1.Ingress) []error { … }
Codebase Browser
kubernetes