Documentation
¶
Index ¶
- Constants
- type Provider
- func (p *Provider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, limit int) error
- func (p *Provider) GetMetadata(metric v1alpha1.Metric) map[string]string
- 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
- type WavefrontClientAPI
- type WavefrontQuery
- type WavefrontQueryAPI
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 ¶
This section is empty.
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) GetMetadata ¶ added in v1.2.0
GetMetadata returns any additional metadata which needs to be stored & displayed as part of the metrics result.
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
type WavefrontClient ¶
type WavefrontClient struct {
*wavefrontapi.Client
}
func (*WavefrontClient) NewQuery ¶
func (wc *WavefrontClient) NewQuery(params *wavefrontapi.QueryParams) WavefrontQueryAPI
type WavefrontClientAPI ¶
type WavefrontClientAPI interface {
NewQuery(params *wavefrontapi.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 {
*wavefrontapi.Query
}
func (*WavefrontQuery) Execute ¶
func (wq *WavefrontQuery) Execute() (*wavefrontapi.QueryResponse, error)
type WavefrontQueryAPI ¶
type WavefrontQueryAPI interface {
Execute() (*wavefrontapi.QueryResponse, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.