trafficconfig

Documentation

Index

• func HandleRateLimiter(ctx context.Context, trafficConfig *admiralv1.TrafficConfig, ...)
• func HandleVirtualServiceForTrafficConfig(ctx context.Context, trafficconfig *admiralv1.TrafficConfig, ...)
• type AppDialingDetails
• type DefaultTrafficConfigHandler
  • func (tch *DefaultTrafficConfigHandler) Added(ctx context.Context, obj interface{}, ...) controller.EventStatus
  • func (tch *DefaultTrafficConfigHandler) Deleted(ctx context.Context, obj interface{}, ...) controller.EventStatus
  • func (tch *DefaultTrafficConfigHandler) OnStatus(_ context.Context, _ controller.EventProcessStatus)
  • func (tch *DefaultTrafficConfigHandler) TriggerTrafficConfigHandlerForIdentity(ctx context.Context, identity string, ...)
  • func (tch *DefaultTrafficConfigHandler) Updated(ctx context.Context, newObj interface{}, _ interface{}, ...) controller.EventStatus
• type Opts
• type RouteDetails
• type TrafficConfigHandler
  • func NewTrafficConfigHandler() TrafficConfigHandler

Functions

func HandleRateLimiter

func HandleRateLimiter(ctx context.Context, trafficConfig *admiralv1.TrafficConfig, eventType types.EventType)

func HandleVirtualServiceForTrafficConfig

func HandleVirtualServiceForTrafficConfig(ctx context.Context, trafficconfig *admiralv1.TrafficConfig, _ chan controller.EventProcessStatus)

Types

type AppDialingDetails

type AppDialingDetails map[string]map[string]map[string]int // map[TGgroupName][AppAssetName][hostName][weightPercentage]  == per targetGroup - group all app assets and then host Details

type DefaultTrafficConfigHandler

type DefaultTrafficConfigHandler struct{}

func (*DefaultTrafficConfigHandler) Added

func (tch *DefaultTrafficConfigHandler) Added(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus

func (*DefaultTrafficConfigHandler) Deleted

func (tch *DefaultTrafficConfigHandler) Deleted(ctx context.Context, obj interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus

func (*DefaultTrafficConfigHandler) OnStatus

func (tch *DefaultTrafficConfigHandler) OnStatus(_ context.Context, _ controller.EventProcessStatus)

func (*DefaultTrafficConfigHandler) TriggerTrafficConfigHandlerForIdentity

func (tch *DefaultTrafficConfigHandler) TriggerTrafficConfigHandlerForIdentity(ctx context.Context, identity string, statusChan chan controller.EventProcessStatus)

func (*DefaultTrafficConfigHandler) Updated

func (tch *DefaultTrafficConfigHandler) Updated(ctx context.Context, newObj interface{}, _ interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus

type Opts

type Opts struct{}

type RouteDetails

type RouteDetails struct {
	RouteName          string
	Inbound            string
	Outbound           string
	ConfigDetails      []*routeTargetInfo
	Timeout            *durationpb.Duration
	ServiceDialDetails []*endpointWeight
	AppDialingDetails  map[string][]*endpointWeight
}

type TrafficConfigHandler

type TrafficConfigHandler interface {
	handler.Handler
	TriggerTrafficConfigHandlerForIdentity(ctx context.Context, identity string, statusChan chan controller.EventProcessStatus)
}

func NewTrafficConfigHandler

func NewTrafficConfigHandler() TrafficConfigHandler