wavefront

Documentation

Index

• Constants
• func Namespace() string
• type Provider
  • func NewWavefrontProvider(api WavefrontClientAPI, logCtx log.Entry) *Provider
  • func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, limit int) error
  • func (p *Provider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *Provider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement
  • func (p *Provider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *Provider) Type() string
• type WavefrontClient
  • func (wc *WavefrontClient) NewQuery(params *wavefront_api.QueryParams) WavefrontQueryAPI
• type WavefrontClientAPI
  • func NewWavefrontAPI(metric v1alpha1.Metric, kubeclientset kubernetes.Interface) (WavefrontClientAPI, error)
• type WavefrontQuery
  • func (wq *WavefrontQuery) Execute() (*wavefront_api.QueryResponse, error)
• type WavefrontQueryAPI

Constants

const (
	//ProviderType indicates the provider is wavefront
	ProviderType = "Wavefront"
	//k8s secret that has wavefront api tokens
	WavefrontTokensSecretName = "wavefront-api-tokens"
)

Functions

func Namespace

func Namespace() string

Types

type Provider

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

func NewWavefrontProvider

func NewWavefrontProvider(api WavefrontClientAPI, logCtx log.Entry) *Provider

NewWavefrontProvider Creates a new Wavefront client

func (*Provider) GarbageCollect

func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, limit int) error

GarbageCollect is a no-op for the Wavefront provider

func (*Provider) Resume

func (p *Provider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

Resume should not be used the Wavefront provider since all the work should occur in the Run method

func (*Provider) Run

func (p *Provider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement

Run queries with wavefront provider for the metric

func (*Provider) Terminate

func (p *Provider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

Terminate should not be used the Wavefront provider since all the work should occur in the Run method

func (*Provider) Type

func (p *Provider) Type() string

type WavefrontClient

type WavefrontClient struct {
	*wavefront_api.Client
}

func (*WavefrontClient) NewQuery

func (wc *WavefrontClient) NewQuery(params *wavefront_api.QueryParams) WavefrontQueryAPI

type WavefrontClientAPI

type WavefrontClientAPI interface {
	NewQuery(params *wavefront_api.QueryParams) WavefrontQueryAPI
}

func NewWavefrontAPI

func NewWavefrontAPI(metric v1alpha1.Metric, kubeclientset kubernetes.Interface) (WavefrontClientAPI, error)

NewWavefrontAPI generates a Wavefront API client from the metric configuration

type WavefrontQuery

type WavefrontQuery struct {
	*wavefront_api.Query
}

func (*WavefrontQuery) Execute

func (wq *WavefrontQuery) Execute() (*wavefront_api.QueryResponse, error)

type WavefrontQueryAPI

type WavefrontQueryAPI interface {
	Execute() (*wavefront_api.QueryResponse, error)
}