stages

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 24, 2020

v1.6.0

Aug 13, 2020

Changes in this version

+ const ErrDropStageEmptyConfig

+ const ErrDropStageInvalidByteSize

+ const ErrDropStageInvalidConfig

+ const ErrDropStageInvalidDuration

+ const ErrDropStageInvalidRegex

+ const ErrEmptyReplaceStageConfig

+ const ErrEmptyReplaceStageSource

+ const StageTypeDrop

+ const StageTypeReplace

+ type DropConfig struct

+ DropReason *string

+ Expression *string

+ LongerThan *string

+ OlderThan *string

+ Source *string

+ Value *string

type MatcherConfig

+ DropReason *string

+ type ReplaceConfig struct

+ Expression string

+ Replace string

+ Source *string

v1.5.0

May 20, 2020

v1.4.1

Apr 6, 2020

v1.4.0

Apr 1, 2020

Changes in this version

+ const ErrInvalidIdleDur

+ const ErrSubSecIdleDur

type MetricConfig

+ IdleDuration *string

+ Prefix string

v1.3.0

Jan 22, 2020

Changes in this version

+ const UnixUs

v1.2.0

Dec 9, 2019

v1.1.0

Dec 4, 2019

v1.0.2

Jul 26, 2019

v1.0.1

Jul 25, 2019

v1.0.0

Nov 20, 2019

Changes in this version

+ const ErrTenantStageConflictingSourceAndValue

+ const ErrTenantStageEmptySourceOrValue

+ const StageTypeTenant

+ type TenantConfig struct

+ Source string

+ Value string

v0

v0.4.0

Oct 24, 2019

Changes in this version

+ const ErrInvalidActionOnFailure

+ const ErrStagesWithDropLine

+ const ErrTimestampConversionFailed

+ const ErrTimestampParsingFailed

+ const ErrTimestampSourceMissing

+ const ErrUnknownMatchAction

+ const MatchActionDrop

+ const MatchActionKeep

+ const TimestampActionOnFailureDefault

+ const TimestampActionOnFailureFudge

+ const TimestampActionOnFailureSkip

+ var Debug = false

+ var TimestampActionOnFailureOptions = []string

type MatcherConfig

+ Action string

type TimestampConfig

+ ActionOnFailure *string

v0.3.0

Aug 18, 2019

v0.2.0

Aug 2, 2019

Changes in this version

+ const ErrEmptyJSONStageSource

+ const ErrEmptyRegexStageSource

+ const ErrEmptyTemplateStageConfig

+ const ErrInvalidLocation

+ const ErrTemplateSourceRequired

+ const ErrTimestampContainsYear

+ const StageTypePipeline

+ const StageTypeTemplate

+ const Unix

+ const UnixMs

+ const UnixNs

type JSONConfig

+ Source *string

type Pipeline

+ func (p *Pipeline) Name() string

type RegexConfig

+ Source *string

type Stage

+ Name func() string

+ type TemplateConfig struct

+ Source string

+ Template string

type TimestampConfig

+ Location *string

v0.1.0

Jun 3, 2019

Changes in this version

+ const ErrCouldNotCompileJMES

+ const ErrCouldNotCompileRegex

+ const ErrEmptyJSONStageConfig

+ const ErrEmptyLabelStageConfig

+ const ErrEmptyMatchStageConfig

+ const ErrEmptyMetricsStageConfig

+ const ErrEmptyOutputStageConfig

+ const ErrEmptyRegexStageConfig

+ const ErrEmptyTimestampStageConfig

+ const ErrExpressionRequired

+ const ErrExpressionsRequired

+ const ErrInvalidLabelName

+ const ErrMatchRequiresStages

+ const ErrMetricsStageInvalidType

+ const ErrOutputSourceRequired

+ const ErrPipelineNameRequired

+ const ErrSelectorRequired

+ const ErrSelectorSyntax

+ const ErrTimestampFormatRequired

+ const ErrTimestampSourceRequired

+ const MetricTypeCounter

+ const MetricTypeGauge

+ const MetricTypeHistogram

+ const RFC3339Nano

+ const StageTypeCRI

+ const StageTypeDocker

+ const StageTypeJSON

+ const StageTypeLabel

+ const StageTypeMatch

+ const StageTypeMetric

+ const StageTypeOutput

+ const StageTypeRegex

+ const StageTypeTimestamp

+ type JSONConfig struct

+ Expressions map[string]string

+ type LabelsConfig map[string]*string

+ type MatcherConfig struct

+ PipelineName *string

+ Selector string

+ Stages PipelineStages

+ type MetricConfig struct

+ Config interface{}

+ Description string

+ MetricType string

+ Source *string

+ type MetricsConfig map[string]MetricConfig

+ type OutputConfig struct

+ Source string

+ type Pipeline struct

+ func NewPipeline(logger log.Logger, stgs PipelineStages, jobName *string, ...) (*Pipeline, error)

+ func (p *Pipeline) AddStage(stage Stage)

+ func (p *Pipeline) Process(labels model.LabelSet, extracted map[string]interface{}, ts *time.Time, ...)

+ func (p *Pipeline) Size() int

+ func (p *Pipeline) Wrap(next api.EntryHandler) api.EntryHandler

+ type PipelineStage = map[interface{}]interface

+ type PipelineStages = []interface

+ type RegexConfig struct

+ Expression string

+ type Stage interface

+ Process func(labels model.LabelSet, extracted map[string]interface{}, time *time.Time, ...)

+ func New(logger log.Logger, jobName *string, stageType string, cfg interface{}, ...) (Stage, error)

+ func NewCRI(logger log.Logger, registerer prometheus.Registerer) (Stage, error)

+ func NewDocker(logger log.Logger, registerer prometheus.Registerer) (Stage, error)

+ type StageFunc func(labels model.LabelSet, extracted map[string]interface{}, time *time.Time, ...)

+ func (s StageFunc) Process(labels model.LabelSet, extracted map[string]interface{}, time *time.Time, ...)

+ type TimestampConfig struct

+ Format string

+ Source string

Incompatible versions in this module

v6.7.8+incompatible

Aug 1, 2019

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