plugin

Documentation

Index

• Constants
• type Config
• type RpcPlugin
  • func (g *RpcPlugin) GarbageCollect(*v1alpha1.AnalysisRun, v1alpha1.Metric, int) types.RpcError
  • func (g *RpcPlugin) GetMetadata(metric v1alpha1.Metric) map[string]string
  • func (g *RpcPlugin) InitPlugin() types.RpcError
  • func (g *RpcPlugin) Resume(analysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (g *RpcPlugin) Run(anaysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement
  • func (g *RpcPlugin) Terminate(analysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (g *RpcPlugin) Type() string

Constants

const EnvVarArgoRolloutsPrometheusAddress string = "ARGO_ROLLOUTS_PROMETHEUS_ADDRESS"

Types

type Config

type Config struct {
	// Address is the HTTP address and port of the prometheus server
	Address string `json:"address,omitempty" protobuf:"bytes,1,opt,name=address"`
	// Query is a raw prometheus query to perform
	Query string `json:"query,omitempty" protobuf:"bytes,2,opt,name=query"`
}

type RpcPlugin

type RpcPlugin struct {
	LogCtx log.Entry
}

Here is a real implementation of MetricProviderPlugin

func (*RpcPlugin) GarbageCollect

func (g *RpcPlugin) GarbageCollect(*v1alpha1.AnalysisRun, v1alpha1.Metric, int) types.RpcError

func (*RpcPlugin) GetMetadata

func (g *RpcPlugin) GetMetadata(metric v1alpha1.Metric) map[string]string

func (*RpcPlugin) InitPlugin

func (g *RpcPlugin) InitPlugin() types.RpcError

func (*RpcPlugin) Resume

func (g *RpcPlugin) Resume(analysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*RpcPlugin) Run

func (g *RpcPlugin) Run(anaysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement

func (*RpcPlugin) Terminate

func (g *RpcPlugin) Terminate(analysisRun *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*RpcPlugin) Type

func (g *RpcPlugin) Type() string