Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stages

package

Go to main page

Versions in this module

v0

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