e2e

package
Version: v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 26, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DeploymentLabelKey   string = "app"
	DeploymentLabelValue string = "nginx"
	PodLabelKey          string = "app"
	PodLabelValue        string = "testPod"
)

Variables

This section is empty.

Functions

func ClusterWithEdsV3

func ClusterWithEdsV3(clusterName string) (string, *envoy_config_cluster_v3.Cluster)

func ClusterWithStrictDNSV3

func ClusterWithStrictDNSV3(clusterName, host string, port uint32) (string, *envoy_config_cluster_v3.Cluster)

func DirectResponseRouteV3

func DirectResponseRouteV3(routeName, msg string) (string, *envoy_config_route_v3.RouteConfiguration)

func EndpointV3

func EndpointV3(clusterName, host string, port uint32) (string, *envoy_config_endpoint_v3.ClusterLoadAssignment)

func GenerateDeployment

func GenerateDeployment(key types.NamespacedName) *appsv1.Deployment

func GenerateDeploymentWithInjection

func GenerateDeploymentWithInjection(key types.NamespacedName, nodeID, envoyAPI, envoyVersion string, envoyPort uint32) *appsv1.Deployment

func GenerateEnvoyConfig

func GenerateEnvoyConfig(key types.NamespacedName, nodeID string, envoyAPI envoy.APIVersion,
	endpointsGenFn, clustersGenFn, routesGenFn, listenersGenFn func() map[string]envoy.Resource, secrets map[string]string) *marin3rv1alpha1.EnvoyConfig

func GenerateHeadlessService

func GenerateHeadlessService(key types.NamespacedName) *corev1.Service

func GeneratePod

func GeneratePod(key types.NamespacedName, nodeID, envoyAPI, envoyVersion, discoveryService string) *corev1.Pod

func GenerateTLSSecret

func GenerateTLSSecret(k8skey types.NamespacedName, commonName, duration string) (*corev1.Secret, error)

func GetAddressV3

func GetAddressV3(host string, port uint32) *envoy_config_core_v3.Address

func GetPodCondition

func GetPodCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition

func HTTPListenerWithRdsV3

func HTTPListenerWithRdsV3(listenerName, routeName string, address, transportSocket proto.Message) (string, *envoy_config_listener_v3.Listener)

func NewTestPortForwarder

func NewTestPortForwarder(cfg *rest.Config, pod corev1.Pod, localPort, podPort uint32,
	out io.Writer, stopCh chan struct{}, readyCh chan struct{}) (*portforward.PortForwarder, error)

func ProxyPassRouteV3

func ProxyPassRouteV3(routeName, clusterName string) (string, *envoy_config_route_v3.RouteConfiguration)

func ReadyReplicas

func ReadyReplicas(k8sClient client.Client, namespace string, matchingLabels client.MatchingLabels) int

func TransportSocketV3

func TransportSocketV3(secretName string) *envoy_config_core_v3.TransportSocket

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL