Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 2019 Changes in this version + const ErrCouldNotCompileJMES + const ErrCouldNotCompileRegex + const ErrEmptyJSONStageConfig + const ErrEmptyJSONStageSource + const ErrEmptyLabelStageConfig + const ErrEmptyMatchStageConfig + const ErrEmptyMetricsStageConfig + const ErrEmptyOutputStageConfig + const ErrEmptyRegexStageConfig + const ErrEmptyRegexStageSource + const ErrEmptyTemplateStageConfig + const ErrEmptyTimestampStageConfig + const ErrExpressionRequired + const ErrExpressionsRequired + const ErrInvalidLabelName + const ErrInvalidLocation + const ErrMatchRequiresStages + const ErrMetricsStageInvalidType + const ErrOutputSourceRequired + const ErrPipelineNameRequired + const ErrSelectorRequired + const ErrSelectorSyntax + const ErrTemplateSourceRequired + const ErrTimestampContainsYear + 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 StageTypePipeline + const StageTypeRegex + const StageTypeTemplate + const StageTypeTimestamp + const Unix + const UnixMs + const UnixNs + type JSONConfig struct + Expressions map[string]string + Source *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) Name() string + 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 + Source *string + type Stage interface + Name func() string + 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 TemplateConfig struct + Source string + Template string + type TimestampConfig struct + Format string + Location *string + Source string
Go to main page