plugin

Documentation

Index

• Constants
• type ConsulTrafficRouting
• type RpcPlugin
  • func (r *RpcPlugin) InitPlugin() pluginTypes.RpcError
  • func (r *RpcPlugin) RemoveManagedRoutes(_ *v1alpha1.Rollout) pluginTypes.RpcError
  • func (r *RpcPlugin) SetHeaderRoute(_ *v1alpha1.Rollout, _ *v1alpha1.SetHeaderRoute) pluginTypes.RpcError
  • func (r *RpcPlugin) SetMirrorRoute(_ *v1alpha1.Rollout, _ *v1alpha1.SetMirrorRoute) pluginTypes.RpcError
  • func (r *RpcPlugin) SetWeight(rollout *v1alpha1.Rollout, desiredWeight int32, _ []v1alpha1.WeightDestination) pluginTypes.RpcError
  • func (r *RpcPlugin) Type() string
  • func (r *RpcPlugin) UpdateHash(_ *v1alpha1.Rollout, _, _ string, _ []v1alpha1.WeightDestination) pluginTypes.RpcError
  • func (r *RpcPlugin) VerifyWeight(_ *v1alpha1.Rollout, _ int32, _ []v1alpha1.WeightDestination) (pluginTypes.RpcVerified, pluginTypes.RpcError)

Constants

const ConfigKey = "hashicorp/consul"

ConfigKey used to identify the plugin in argo-rollouts configmap. see https://argoproj.github.io/argo-rollouts/features/traffic-management/plugins/

const Type = "Consul"

Type holds this plugin type

Types

type ConsulTrafficRouting

type ConsulTrafficRouting struct {
	ServiceName                 string `json:"serviceName" protobuf:"bytes,1,opt,name=serviceName"`
	CanarySubsetName            string `json:"canarySubsetName" protobuf:"bytes,2,opt,name=canarySubsetName"`
	StableSubsetName            string `json:"stableSubsetName" protobuf:"bytes,3,opt,name=stableSubsetName"`
	ServiceMetaAnnotationSuffix string `json:"serviceMetaAnnotationSuffix" protobuf:"bytes,4,opt,name=serviceMetaAnnotationSuffix"`
}

type RpcPlugin

type RpcPlugin struct {
	K8SClient client.Client
	LogCtx    *logrus.Entry
	IsTest    bool
}

func (*RpcPlugin) InitPlugin

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

func (*RpcPlugin) RemoveManagedRoutes

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

func (*RpcPlugin) SetHeaderRoute

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

func (*RpcPlugin) SetMirrorRoute

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

func (*RpcPlugin) SetWeight

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

func (*RpcPlugin) Type

func (r *RpcPlugin) Type() string

func (*RpcPlugin) UpdateHash

func (r *RpcPlugin) UpdateHash(_ *v1alpha1.Rollout, _, _ string, _ []v1alpha1.WeightDestination) pluginTypes.RpcError

func (*RpcPlugin) VerifyWeight

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