Documentation
¶
Overview ¶
Package obase provides common classes for orchestration
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PipelineStarter ¶
type PipelineStarter func(parentLogger logger.Logger, metricCreator promreg.MetricCreator, input <-chan []*base.LogRecord, bufferID string, outputTag string, onStopped func())
PipelineStarter represents a function to launch workers for a top-level pipeline under Orchestrator
bufferID must be unique inside the parent orchestrator
Launched workers should start shutting down as soon as the input channel is closed and call onStopped at the end
func PrepareSequentialPipeline ¶
func PrepareSequentialPipeline(args bconfig.PipelineArgs) PipelineStarter
PrepareSequentialPipeline makes a starter for pipelines including transformer, serializer and output forwarder
type TagBuilder ¶
type TagBuilder struct {
// contains filtered or unexported fields
}
TagBuilder builds tags from key set fields
func NewTagBuilder ¶
func NewTagBuilder(tagTemplate string, keyNames []string) (*TagBuilder, error)
NewTagBuilder creates a TagBuilder
func (*TagBuilder) Build ¶
func (m *TagBuilder) Build(keyValues []string) string
Build constructs new tag from given label values, the length and order must match labelNames passed to NewTagBuilder
Source Files
Click to show internal directories.
Click to hide internal directories.