e2e

Documentation

Index

• Constants
• func ClusterWithEdsV3(clusterName string) *envoy_config_cluster_v3.Cluster
• func ClusterWithStrictDNSV3(clusterName, host string, port uint32) *envoy_config_cluster_v3.Cluster
• func DirectResponseRouteV3(routeName, msg string) *envoy_config_route_v3.RouteConfiguration
• func EndpointV3(clusterName, host string, port uint32) *envoy_config_endpoint_v3.ClusterLoadAssignment
• func GenerateDeployment(key types.NamespacedName) *appsv1.Deployment
• func GenerateDeploymentWithInjection(key types.NamespacedName, nodeID, envoyAPI, envoyVersion string, ...) *appsv1.Deployment
• func GenerateEnvoyConfig(key types.NamespacedName, nodeID string, envoyAPI envoy.APIVersion, ...) *marin3rv1alpha1.EnvoyConfig
• func GenerateHeadlessService(key types.NamespacedName) *corev1.Service
• func GeneratePod(key types.NamespacedName, ...) *corev1.Pod
• func GenerateTLSSecret(k8skey types.NamespacedName, commonName, duration string) (*corev1.Secret, error)
• func GetAddressV3(host string, port uint32) *envoy_config_core_v3.Address
• func GetPodCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition
• func HTTPFilterRouter(extensionConfigName string) *envoy_config_core_v3.TypedExtensionConfig
• func HTTPListener(listenerName, routeName, extensionConfigName string, ...) *envoy_config_listener_v3.Listener
• func NewTestPortForwarder(cfg *rest.Config, pod corev1.Pod, localPort, podPort uint32, out io.Writer, ...) (*portforward.PortForwarder, error)
• func ProxyPassRouteV3(routeName, clusterName string) *envoy_config_route_v3.RouteConfiguration
• func ReadyReplicas(k8sClient client.Client, namespace string, ...) int
• func TransportSocketV3(secretName string) *envoy_config_core_v3.TransportSocket
• type EndpointDiscovery

Constants

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

Functions

func ClusterWithEdsV3

func ClusterWithEdsV3(clusterName string) *envoy_config_cluster_v3.Cluster

func ClusterWithStrictDNSV3

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

func DirectResponseRouteV3

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

func EndpointV3

func EndpointV3(clusterName, host string, port uint32) *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,
	staticEndpoints, clusters, routes, listeners, extension []envoy.Resource,
	secrets []string, eds []EndpointDiscovery) *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 HTTPFilterRouter

func HTTPFilterRouter(extensionConfigName string) *envoy_config_core_v3.TypedExtensionConfig

func HTTPListener

func HTTPListener(listenerName, routeName, extensionConfigName string,
	address, transportSocket proto.Message) *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) *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

type EndpointDiscovery

type EndpointDiscovery struct {
	ClusterName, PortName, LabelKey, LabelValue string
}