trafficpolicyutils

Documentation

Index

• func ContainsPort(...) bool
• func TranslateCorsPolicy(corsPolicy *v1.TrafficPolicySpec_Policy_CorsPolicy) (*istiov1alpha3.CorsPolicy, error)
• func TranslateFault(faultInjection *v1.TrafficPolicySpec_Policy_FaultInjection) (*networkingv1alpha3spec.HTTPFaultInjection, error)
• func TranslateHeaderManipulation(headerManipulation *v1.HeaderManipulation) *networkingv1alpha3spec.Headers
• func TranslateMirror(mirror *v1.TrafficPolicySpec_Policy_Mirror, sourceClusterName string, ...) (*networkingv1alpha3spec.Destination, *networkingv1alpha3spec.Percent, error)
• func TranslateRetries(retries *v1.TrafficPolicySpec_Policy_RetryPolicy) *istiov1alpha3.HTTPRetry
• func TranslateTimeout(timeout *duration.Duration) *types.Duration

Functions

func ContainsPort

func ContainsPort(
	destKubeServicePorts []*discoveryv1.DestinationSpec_KubeService_KubeServicePort,
	port uint32,
) bool

func TranslateCorsPolicy

func TranslateCorsPolicy(
	corsPolicy *v1.TrafficPolicySpec_Policy_CorsPolicy,
) (*istiov1alpha3.CorsPolicy, error)

func TranslateFault

func TranslateFault(faultInjection *v1.TrafficPolicySpec_Policy_FaultInjection) (*networkingv1alpha3spec.HTTPFaultInjection, error)

func TranslateHeaderManipulation

func TranslateHeaderManipulation(
	headerManipulation *v1.HeaderManipulation,
) *networkingv1alpha3spec.Headers

func TranslateMirror

func TranslateMirror(
	mirror *v1.TrafficPolicySpec_Policy_Mirror,
	sourceClusterName string,
	clusterDomains hostutils.ClusterDomainRegistry,
	destinations v1sets.DestinationSet,
) (*networkingv1alpha3spec.Destination, *networkingv1alpha3spec.Percent, error)

If federatedClusterName is non-empty, it indicates translation for a federated VirtualService, so use it as the source cluster name.

func TranslateRetries

func TranslateRetries(
	retries *v1.TrafficPolicySpec_Policy_RetryPolicy,
) *istiov1alpha3.HTTPRetry

func TranslateTimeout

func TranslateTimeout(
	timeout *duration.Duration,
) *types.Duration