wavefront

package
v0.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 25, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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

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

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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL