Documentation
¶
Index ¶
- type Reconciler
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.