observers

Documentation

Index

• func RenderQuery(queryTemplate string, model flaggerv1.MetricTemplateModel) (string, error)
• type ApisixObserver
  • func (ob *ApisixObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *ApisixObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type AppMeshObserver
  • func (ob *AppMeshObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *AppMeshObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type ContourObserver
  • func (ob *ContourObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *ContourObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type Factory
  • func NewFactory(metricsServer string) (*Factory, error)
  • func (factory Factory) Observer(provider string) Interface
• type GlooObserver
  • func (ob *GlooObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *GlooObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type HttpObserver
  • func (ob *HttpObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *HttpObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type Interface
• type IstioObserver
  • func (ob *IstioObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *IstioObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type KumaObserver
  • func (ob *KumaObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *KumaObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type LinkerdObserver
  • func (ob *LinkerdObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *LinkerdObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type NginxObserver
  • func (ob *NginxObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *NginxObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type OsmObserver
  • func (ob *OsmObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *OsmObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type SkipperObserver
  • func (ob *SkipperObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *SkipperObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
• type TraefikObserver
  • func (ob *TraefikObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
  • func (ob *TraefikObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

Functions

func RenderQuery

func RenderQuery(queryTemplate string, model flaggerv1.MetricTemplateModel) (string, error)

Types

type ApisixObserver

type ApisixObserver struct {
	// contains filtered or unexported fields
}

func (*ApisixObserver) GetRequestDuration

func (ob *ApisixObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*ApisixObserver) GetRequestSuccessRate

func (ob *ApisixObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type AppMeshObserver

type AppMeshObserver struct {
	// contains filtered or unexported fields
}

func (*AppMeshObserver) GetRequestDuration

func (ob *AppMeshObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*AppMeshObserver) GetRequestSuccessRate

func (ob *AppMeshObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type ContourObserver

type ContourObserver struct {
	// contains filtered or unexported fields
}

func (*ContourObserver) GetRequestDuration

func (ob *ContourObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*ContourObserver) GetRequestSuccessRate

func (ob *ContourObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type Factory

type Factory struct {
	Client providers.Interface
}

func NewFactory

func NewFactory(metricsServer string) (*Factory, error)

func (Factory) Observer

func (factory Factory) Observer(provider string) Interface

type GlooObserver

type GlooObserver struct {
	// contains filtered or unexported fields
}

func (*GlooObserver) GetRequestDuration

func (ob *GlooObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*GlooObserver) GetRequestSuccessRate

func (ob *GlooObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type HttpObserver

type HttpObserver struct {
	// contains filtered or unexported fields
}

func (*HttpObserver) GetRequestDuration

func (ob *HttpObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*HttpObserver) GetRequestSuccessRate

func (ob *HttpObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type Interface

type Interface interface {
	GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)
	GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)
}

type IstioObserver

type IstioObserver struct {
	// contains filtered or unexported fields
}

func (*IstioObserver) GetRequestDuration

func (ob *IstioObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*IstioObserver) GetRequestSuccessRate

func (ob *IstioObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type KumaObserver

type KumaObserver struct {
	// contains filtered or unexported fields
}

func (*KumaObserver) GetRequestDuration

func (ob *KumaObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*KumaObserver) GetRequestSuccessRate

func (ob *KumaObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type LinkerdObserver

type LinkerdObserver struct {
	// contains filtered or unexported fields
}

func (*LinkerdObserver) GetRequestDuration

func (ob *LinkerdObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*LinkerdObserver) GetRequestSuccessRate

func (ob *LinkerdObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type NginxObserver

type NginxObserver struct {
	// contains filtered or unexported fields
}

func (*NginxObserver) GetRequestDuration

func (ob *NginxObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*NginxObserver) GetRequestSuccessRate

func (ob *NginxObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type OsmObserver

type OsmObserver struct {
	// contains filtered or unexported fields
}

func (*OsmObserver) GetRequestDuration

func (ob *OsmObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*OsmObserver) GetRequestSuccessRate

func (ob *OsmObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

type SkipperObserver

type SkipperObserver struct {
	// contains filtered or unexported fields
}

SkipperObserver Implementation for Skipper (https://github.com/zalando/skipper)

func (*SkipperObserver) GetRequestDuration

func (ob *SkipperObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

GetRequestDuration return value for Skipper Request Duration

func (*SkipperObserver) GetRequestSuccessRate

func (ob *SkipperObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)

GetRequestSuccessRate return value for Skipper Request Success Rate

type TraefikObserver

type TraefikObserver struct {
	// contains filtered or unexported fields
}

func (*TraefikObserver) GetRequestDuration

func (ob *TraefikObserver) GetRequestDuration(model flaggerv1.MetricTemplateModel) (time.Duration, error)

func (*TraefikObserver) GetRequestSuccessRate

func (ob *TraefikObserver) GetRequestSuccessRate(model flaggerv1.MetricTemplateModel) (float64, error)