plugin

Documentation

Index

• type Reconciler
  • func NewReconciler(cfg *ReconcilerConfig) (*Reconciler, error)
  • func (r *Reconciler) RemoveManagedRoutes() error
  • func (r *Reconciler) SetHeaderRoute(headerRouting *v1alpha1.SetHeaderRoute) error
  • func (r *Reconciler) SetMirrorRoute(setMirrorRoute *v1alpha1.SetMirrorRoute) error
  • func (r *Reconciler) SetWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) error
  • func (r *Reconciler) UpdateHash(canaryHash, stableHash string, ...) error
  • func (r *Reconciler) VerifyWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) (*bool, error)
• type ReconcilerConfig

Types

type Reconciler

type Reconciler struct {
	Rollout    *v1alpha1.Rollout
	PluginName string
	Client     kubernetes.Interface
	Recorder   record.EventRecorder
	rpc.TrafficRouterPlugin
}

func NewReconciler

func NewReconciler(cfg *ReconcilerConfig) (*Reconciler, error)

func (*Reconciler) RemoveManagedRoutes

func (r *Reconciler) RemoveManagedRoutes() error

RemoveManagedRoutes Removes all routes that are managed by rollouts by looking at spec.strategy.canary.trafficRouting.managedRoutes

func (*Reconciler) SetHeaderRoute

func (r *Reconciler) SetHeaderRoute(headerRouting *v1alpha1.SetHeaderRoute) error

SetHeaderRoute sets the header routing step

func (*Reconciler) SetMirrorRoute

func (r *Reconciler) SetMirrorRoute(setMirrorRoute *v1alpha1.SetMirrorRoute) error

SetMirrorRoute sets up the traffic router to mirror traffic to a service

func (*Reconciler) SetWeight

func (r *Reconciler) SetWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) error

SetWeight sets the canary weight to the desired weight

func (*Reconciler) UpdateHash

func (r *Reconciler) UpdateHash(canaryHash, stableHash string, additionalDestinations ...v1alpha1.WeightDestination) error

UpdateHash informs a traffic routing reconciler about new canary, stable, and additionalDestination(s) pod hashes

func (*Reconciler) VerifyWeight

func (r *Reconciler) VerifyWeight(desiredWeight int32, additionalDestinations ...v1alpha1.WeightDestination) (*bool, 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

type ReconcilerConfig

type ReconcilerConfig struct {
	Rollout    *v1alpha1.Rollout
	PluginName string
	Client     kubernetes.Interface
	Recorder   record.EventRecorder
}