plugin

Documentation

Index

• type RpcPlugin
  • func (p *RpcPlugin) InitPlugin() pluginTypes.RpcError
  • func (r *RpcPlugin) RemoveManagedRoutes(ro *v1alpha1.Rollout) pluginTypes.RpcError
  • func (r *RpcPlugin) SetHeaderRoute(ro *v1alpha1.Rollout, headerRouting *v1alpha1.SetHeaderRoute) pluginTypes.RpcError
  • func (r *RpcPlugin) SetMirrorRoute(ro *v1alpha1.Rollout, setMirrorRoute *v1alpha1.SetMirrorRoute) pluginTypes.RpcError
  • func (r *RpcPlugin) SetWeight(ro *v1alpha1.Rollout, desiredWeight int32, ...) pluginTypes.RpcError
  • func (r *RpcPlugin) Type() string
  • func (r *RpcPlugin) UpdateHash(ro *v1alpha1.Rollout, canaryHash, stableHash string, ...) pluginTypes.RpcError
  • func (r *RpcPlugin) VerifyWeight(ro *v1alpha1.Rollout, desiredWeight int32, ...) (pluginTypes.RpcVerified, pluginTypes.RpcError)

Types

type RpcPlugin

type RpcPlugin struct {
	LogCtx *logrus.Entry
	// contains filtered or unexported fields
}

func (*RpcPlugin) InitPlugin

func (p *RpcPlugin) InitPlugin() pluginTypes.RpcError

func (*RpcPlugin) RemoveManagedRoutes

func (r *RpcPlugin) RemoveManagedRoutes(ro *v1alpha1.Rollout) pluginTypes.RpcError

func (*RpcPlugin) SetHeaderRoute

func (r *RpcPlugin) SetHeaderRoute(ro *v1alpha1.Rollout, headerRouting *v1alpha1.SetHeaderRoute) pluginTypes.RpcError

func (*RpcPlugin) SetMirrorRoute

func (r *RpcPlugin) SetMirrorRoute(ro *v1alpha1.Rollout, setMirrorRoute *v1alpha1.SetMirrorRoute) pluginTypes.RpcError

func (*RpcPlugin) SetWeight

func (r *RpcPlugin) SetWeight(ro *v1alpha1.Rollout, desiredWeight int32, additionalDestinations []v1alpha1.WeightDestination) pluginTypes.RpcError

SetWeight modifies Nginx Ingress resources to reach desired state

func (*RpcPlugin) Type

func (r *RpcPlugin) Type() string

func (*RpcPlugin) UpdateHash

func (r *RpcPlugin) UpdateHash(ro *v1alpha1.Rollout, canaryHash, stableHash string, additionalDestinations []v1alpha1.WeightDestination) pluginTypes.RpcError

UpdateHash informs a traffic routing reconciler about new canary/stable pod hashes

func (*RpcPlugin) VerifyWeight

func (r *RpcPlugin) VerifyWeight(ro *v1alpha1.Rollout, desiredWeight int32, additionalDestinations []v1alpha1.WeightDestination) (pluginTypes.RpcVerified, pluginTypes.RpcError)