trafficpolicyutils

func ContainsPort ¶

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

func ConvertDeprecatedRequestMatchers ¶ added in v1.1.0

func ConvertDeprecatedRequestMatchers(deprecated []*v1.DeprecatedHttpMatcher) []*v1.HttpMatcher

conversion function to make it easy to work with the deprecated request matchers

func TranslateCorsPolicy ¶ added in v1.1.0

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

func TranslateFault ¶ added in v1.1.0

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

func TranslateHeaderManipulation ¶ added in v1.1.0

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

func TranslateMirror ¶ added in v1.1.0

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 ¶ added in v1.1.0

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

func TranslateTimeout ¶ added in v1.1.0

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