faultinjections

Documentation

Index

• func BuildExternalServiceFaultInjectionMapForZoneEgress(externalServices []*core_mesh.ExternalServiceResource, ...) core_xds.ExternalServiceFaultInjectionMap
• func BuildFaultInjectionMap(dataplane *core_mesh.DataplaneResource, ...) core_xds.FaultInjectionMap
• type FaultInjectionMatcher
  • func (f *FaultInjectionMatcher) Match(ctx context.Context, dataplane *core_mesh.DataplaneResource, ...) (core_xds.FaultInjectionMap, error)

Functions

func BuildExternalServiceFaultInjectionMapForZoneEgress

func BuildExternalServiceFaultInjectionMapForZoneEgress(
	externalServices []*core_mesh.ExternalServiceResource,
	faultInjections []*core_mesh.FaultInjectionResource,
) core_xds.ExternalServiceFaultInjectionMap

BuildExternalServiceFaultInjectionMapForZoneEgress creates mapping between Service's name and the list of FaultInjections. todo(lobkovilya): that's not really correct way to build a policy map for External Services. Policies such as Fault Injections, Rate Limit and Traffic Permissions support arbitrary tags in Destination, but we lose this information if putting policies in map just by Service's name. See https://github.com/kumahq/kuma/issues/3999

func BuildFaultInjectionMap

func BuildFaultInjectionMap(
	dataplane *core_mesh.DataplaneResource,
	inbounds []*mesh_proto.Dataplane_Networking_Inbound,
	faultInjections []*core_mesh.FaultInjectionResource,
) core_xds.FaultInjectionMap

Types

type FaultInjectionMatcher

type FaultInjectionMatcher struct {
	ResourceManager manager.ReadOnlyResourceManager
}

func (*FaultInjectionMatcher) Match

func (f *FaultInjectionMatcher) Match(ctx context.Context, dataplane *core_mesh.DataplaneResource, mesh *core_mesh.MeshResource) (core_xds.FaultInjectionMap, error)