integration

package

Go to main page

Versions in this module

v1

v1.5.0

Jun 10, 2020

v1.4.0

Jun 2, 2020

v1.3.0

Feb 5, 2020

v1.2.2

Oct 24, 2019

v1.2.1

Oct 16, 2019

v1.2.0

Oct 16, 2019

Changes in this version

type TelemetryEmitterConfig

+ Percentiles []float64

type TelemetryHarvesterOpt

+ func TelemetryHarvesterWithHarvestPeriod(t time.Duration) TelemetryHarvesterOpt

v1.1.0

Sep 20, 2019

v1.0.1-rc1

Sep 20, 2019

v1.0.0

Sep 19, 2019

Changes in this version

type TelemetryEmitter

+ func NewTelemetryEmitterWithRoundTripper(apiURL, apiKey string, rt roundTripperFunc) *TelemetryEmitter

v0

v0.2.0

Feb 17, 2021

Changes in this version

+ const BoundedHarvesterDefaultHarvestPeriod

+ const BoundedHarvesterDefaultMetricsCap

+ const BoundedHarvesterDefaultMinReportInterval

+ const Name

+ var Version = "dev"

+ func AddAttributes(targetMetrics *TargetMetrics, rules []AddAttributesRule)

+ func AutoDecorateLabels(targetMetrics *TargetMetrics)

+ func CopyAttributes(targetMetrics *TargetMetrics, rules []DecorateRule)

+ func Decorate(targetMetrics *TargetMetrics, decorateRules []DecorateRule)

+ func Execute(scrapeDuration time.Duration, selfRetriever endpoints.TargetRetriever, ...)

+ func ExecuteOnce(retrievers []endpoints.TargetRetriever, fetcher Fetcher, processor Processor, ...)

+ func Filter(targetMetrics *TargetMetrics, rules ignoreRules)

+ func NewBearerAuthFileRoundTripper(bearerFile string, rt http.RoundTripper) http.RoundTripper

+ func NewMutualTLSRoundTripper(cfg endpoints.TLSConfig) (http.RoundTripper, error)

+ func NewRoundTripper(BearerTokenFile string, CaFile string, InsecureSkipVerify bool) (http.RoundTripper, error)

+ func NewTLSConfig(CAFile string, InsecureSkipVerify bool) (*tls.Config, error)

+ func Rename(targetMetrics *TargetMetrics, rules []RenameRule)

+ type AddAttributesRule struct

+ Attributes map[string]interface{}

+ MetricPrefix string

+ type BoundedHarvesterCfg struct

+ DisablePeriodicReporting bool

+ HarvestPeriod time.Duration

+ MetricCap int

+ MinReportInterval time.Duration

+ type CopyAttributesRule struct

+ Attributes []string

+ FromMetric string

+ MatchBy []string

+ ToMetrics []string

+ type DecorateRule struct

+ Attributes labels.Set

+ Dest []string

+ Join labels.Set

+ Source string

+ type DecorationMap struct

+ Dests map[string][]DecorateRule

+ SourceLabels map[string][]labels.Set

+ func MatchingDecorate(targetMetrics *TargetMetrics, rules []DecorateRule) DecorationMap

+ type Emitter interface

+ Emit func([]Metric) error

+ Name func() string

+ type EntityDef struct

+ DisplayName string

+ Metrics []MetricDef

+ Name string

+ Properties PropertiesDef

+ type Fetcher interface

+ Fetch func(t []endpoints.Target) <-chan TargetMetrics

+ func NewFetcher(fetchDuration time.Duration, fetchTimeout time.Duration, workerThreads int, ...) Fetcher

+ type IgnoreRule struct

+ Except []string

+ Prefixes []string

+ type InfraSdkEmitter struct

+ func NewInfraSdkEmitter(specs Specs) *InfraSdkEmitter

+ func (e *InfraSdkEmitter) Emit(metrics []Metric) error

+ func (e *InfraSdkEmitter) Name() string

+ type Metric struct

+ func (m *Metric) MarshalJSON() ([]byte, error)

+ type MetricDef struct

+ Name string

+ type ProcessingRule struct

+ AddAttributes []AddAttributesRule

+ CopyAttributes []CopyAttributesRule

+ Description string

+ IgnoreMetrics []IgnoreRule

+ RenameAttributes []RenameRule

+ type Processor func(pairs <-chan TargetMetrics) <-chan TargetMetrics

+ func RuleProcessor(processingRules []ProcessingRule, queueLength int) Processor

+ type PropertiesDef struct

+ Labels []string

+ type RenameRule struct

+ Attributes map[string]interface{}

+ MetricPrefix string

+ type SpecDef struct

+ DefaultEntity string

+ Entities []EntityDef

+ Service string

+ type Specs struct

+ SpecsByName map[string]SpecDef

+ func LoadSpecFiles(filesPath string) (Specs, error)

+ type StdoutEmitter struct

+ func NewStdoutEmitter() *StdoutEmitter

+ func (se *StdoutEmitter) Emit(metrics []Metric) error

+ func (se *StdoutEmitter) Name() string

+ type TargetMetrics struct

+ Metrics []Metric

+ Target endpoints.Target

+ type TelemetryEmitter struct

+ func NewTelemetryEmitter(cfg TelemetryEmitterConfig) (*TelemetryEmitter, error)

+ func (te *TelemetryEmitter) Emit(metrics []Metric) error

+ func (te *TelemetryEmitter) Name() string

+ type TelemetryEmitterConfig struct

+ DeltaExpirationAge time.Duration

+ DeltaExpirationCheckInternval time.Duration

+ DisableBoundedHarvester bool

+ HarvesterOpts []TelemetryHarvesterOpt

+ type TelemetryHarvesterOpt = func(*telemetry.Config)

+ func TelemetryHarvesterWithLicenseKeyRoundTripper(licenseKey string) TelemetryHarvesterOpt

+ func TelemetryHarvesterWithMetricsURL(url string) TelemetryHarvesterOpt

+ func TelemetryHarvesterWithProxy(proxyURL *url.URL) TelemetryHarvesterOpt

+ func TelemetryHarvesterWithTLSConfig(tlsConfig *tls.Config) TelemetryHarvesterOpt

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