plugin

Documentation

Index

• 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

Types

type Config

type Config struct {
	// Address is the HTTP address and port of the opensearch server
	Address string `json:"address,omitempty" protobuf:"bytes,1,opt,name=address"`
	// Username is the username to authenticate with
	Username string `json:"username,omitempty" protobuf:"bytes,2,opt,name=username"`
	// Username is password to authenticate with
	Password string `json:"password,omitempty" protobuf:"bytes,3,opt,name=password"`
	// InsecureSkipVerify skips the certificate verification step when set to true
	InsecureSkipVerify bool `json:"insecureSkipVerify,omitempty" protobuf:"bytes,4,opt,name=insecureSkipVerify"`
	// Query is a raw opensearch query to perform
	Index string `json:"index,omitempty" protobuf:"bytes,5,opt,name=index"`
	// Query is a raw opensearch query to perform
	Query string `json:"query,omitempty" protobuf:"bytes,6,opt,name=query"`
}

type RpcPlugin

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

Here is a real implementation of MetricsPlugin

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