trafficrouting

Documentation

Index

• func GetStableAndCanaryServices(ro *v1alpha1.Rollout) (string, string)
• func IsPingPongEnabled(ro *v1alpha1.Rollout) bool
• func IsStablePing(ro *v1alpha1.Rollout) bool
• type TrafficRoutingReconciler

Functions

func GetStableAndCanaryServices

func GetStableAndCanaryServices(ro *v1alpha1.Rollout) (string, string)

GetStableAndCanaryServices return a service names for current stable and canary services. If ping-pong feature enabled then the current ping or pong service will be returned. Which is a stable is defined based on a rollout status field Status.Canary.StablePingPong

func IsPingPongEnabled

func IsPingPongEnabled(ro *v1alpha1.Rollout) bool

func IsStablePing

func IsStablePing(ro *v1alpha1.Rollout) bool

IsStablePing return true if the 'ping' service is pointing to the stable replica set. Which of the service currently is using is stored in a status.canary.stablePingPong. Return true in a case if status StablePingPong value equal to 'ping'. Return false in case when the status value is 'pong' or empty

Types

type TrafficRoutingReconciler

type TrafficRoutingReconciler interface {
	// UpdateHash informs a traffic routing reconciler about new canary, stable, and additionalDestination(s) pod hashes
	UpdateHash(canaryHash, stableHash string, additionalDestinations ...v1alpha1.WeightDestination) error
	// SetWeight sets the canary weight to the desired weight
	SetWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) error
	// VerifyWeight returns true if the canary is at the desired weight and additionalDestinations are at the weights specified
	// Returns nil if weight verification is not supported or not applicable
	VerifyWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) (*bool, error)
	// Type returns the type of the traffic routing reconciler
	Type() string
}

TrafficRoutingReconciler common function across all TrafficRouting implementation