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 …
func (l *E2ELogger) Infof(format string, args ...interface{ … }
func (l *E2ELogger) Errorf(format string, args ...interface{ … }
type ConformanceTests …
type NegStatus …
func SimpleGET(ctx context.Context, c *http.Client, url, host string) (string, error) { … }
func PollURL(ctx context.Context, route, host string, timeout time.Duration, interval time.Duration, httpClient *http.Client, expectUnreachable bool) error { … }
func CreateIngressComformanceTests(ctx context.Context, jig *TestJig, ns string, annotations map[string]string) []ConformanceTests { … }
func GenerateRSACerts(host string, isCA bool) ([]byte, []byte, error) { … }
func buildTransportWithCA(serverName string, rootCA []byte) (*http.Transport, error) { … }
func BuildInsecureClient(timeout time.Duration) *http.Client { … }
func createTLSSecret(ctx context.Context, kubeClient clientset.Interface, namespace, secretName string, hosts ...string) (host string, rootCA, privKey []byte, err error) { … }
type TestJig …
func NewIngressTestJig(c clientset.Interface) *TestJig { … }
func (j *TestJig) CreateIngress(ctx context.Context, manifestPath, ns string, ingAnnotations map[string]string, svcAnnotations map[string]string) { … }
func marshalToYaml(obj runtime.Object, gv schema.GroupVersion) ([]byte, error) { … }
func ingressFromManifest(fileName string) (*networkingv1.Ingress, error) { … }
func ingressToManifest(ing *networkingv1.Ingress, path string) error { … }
func (j *TestJig) runCreate(ctx context.Context, ing *networkingv1.Ingress) (*networkingv1.Ingress, error) { … }
func (j *TestJig) runUpdate(ctx context.Context, ing *networkingv1.Ingress) (*networkingv1.Ingress, error) { … }
func DescribeIng(ns string) { … }
func (j *TestJig) Update(ctx context.Context, update func(ing *networkingv1.Ingress)) { … }
func (j *TestJig) AddHTTPS(ctx context.Context, secretName string, hosts ...string) { … }
func (j *TestJig) SetHTTPS(ctx context.Context, secretName string, hosts ...string) { … }
func (j *TestJig) RemoveHTTPS(ctx context.Context, secretName string) { … }
func (j *TestJig) PrepareTLSSecret(ctx context.Context, namespace, secretName string, hosts ...string) error { … }
func (j *TestJig) GetRootCA(secretName string) (rootCA []byte) { … }
func (j *TestJig) TryDeleteIngress(ctx context.Context) { … }
func (j *TestJig) tryDeleteGivenIngress(ctx context.Context, ing *networkingv1.Ingress) { … }
func (j *TestJig) runDelete(ctx context.Context, ing *networkingv1.Ingress) error { … }
func getIngressAddressFromKubemci(name string) ([]string, error) { … }
func findIPv4(input string) string { … }
func getIngressAddress(ctx context.Context, client clientset.Interface, ns, name, class string) ([]string, error) { … }
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 { … }
func (j *TestJig) WaitForIngress(ctx context.Context, waitForNodePort bool) { … }
func (j *TestJig) WaitForIngressToStable(ctx context.Context) { … }
func (j *TestJig) WaitForGivenIngressWithTimeout(ctx context.Context, ing *networkingv1.Ingress, waitForNodePort bool, timeout time.Duration) error { … }
func (j *TestJig) WaitForIngressWithCert(ctx context.Context, waitForNodePort bool, knownHosts []string, cert []byte) error { … }
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 { … }
func getSvcNodePort(ctx context.Context, client clientset.Interface, ns, name string, svcPort int) (int, error) { … }
func getPortURL(ctx context.Context, client clientset.Interface, ns, name string, svcPort int) (string, error) { … }
func (j *TestJig) GetIngressNodePorts(ctx context.Context, includeDefaultBackend bool) []string { … }
func (j *TestJig) GetServicePorts(ctx context.Context, includeDefaultBackend bool) map[string]v1.ServicePort { … }
func (j *TestJig) GetDistinctResponseFromIngress(ctx context.Context) (sets.String, error) { … }
type NginxIngressController …
func (cont *NginxIngressController) Init(ctx context.Context) { … }
func (cont *NginxIngressController) TearDown(ctx context.Context) { … }
func generateBacksideHTTPSIngressSpec(ns string) *networkingv1.Ingress { … }
func generateBacksideHTTPSServiceSpec() *v1.Service { … }
func generateBacksideHTTPSDeploymentSpec() *appsv1.Deployment { … }
func (j *TestJig) SetUpBacksideHTTPSIngress(ctx context.Context, cs clientset.Interface, namespace string, staticIPName string) (*appsv1.Deployment, *v1.Service, *networkingv1.Ingress, error) { … }
func (j *TestJig) DeleteTestResource(ctx context.Context, cs clientset.Interface, deploy *appsv1.Deployment, svc *v1.Service, ing *networkingv1.Ingress) []error { … }