Documentation ¶
Overview ¶
Package builder contains the logic on parsing configs and building receivers, exporters, pipeplines and tail sampling.
Package builder handles the options to build the OpenTelemetry collector pipeline.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Flags ¶
Flags adds flags related to basic building of the collector application to the given flagset.
func GetConfigFile ¶
GetConfigFile gets the config file from the config file flag.
func MemBallastSize ¶
MemBallastSize returns the size of memory ballast to use in MBs
Types ¶
type Exporters ¶
type Exporters map[configmodels.Exporter]*builtExporter
Exporters is a map of exporters created from exporter configs.
func (Exporters) ShutdownAll ¶ added in v0.0.2
func (exps Exporters) ShutdownAll()
ShutdownAll stops all exporters.
type ExportersBuilder ¶
type ExportersBuilder struct {
// contains filtered or unexported fields
}
ExportersBuilder builds exporters from config.
func NewExportersBuilder ¶
func NewExportersBuilder( logger *zap.Logger, config *configmodels.Config, factories map[string]exporter.Factory, ) *ExportersBuilder
NewExportersBuilder creates a new ExportersBuilder. Call Build() on the returned value.
func (*ExportersBuilder) Build ¶
func (eb *ExportersBuilder) Build() (Exporters, error)
Build exporters from config.
type PipelineProcessors ¶
type PipelineProcessors map[*configmodels.Pipeline]*builtProcessor
PipelineProcessors is a map of entry-point processors created from pipeline configs. Each element of the map points to the first processor of the pipeline.
type PipelinesBuilder ¶
type PipelinesBuilder struct {
// contains filtered or unexported fields
}
PipelinesBuilder builds pipelines from config.
func NewPipelinesBuilder ¶
func NewPipelinesBuilder( logger *zap.Logger, config *configmodels.Config, exporters Exporters, factories map[string]processor.Factory, ) *PipelinesBuilder
NewPipelinesBuilder creates a new PipelinesBuilder. Requires exporters to be already built via ExportersBuilder. Call Build() on the returned value.
func (*PipelinesBuilder) Build ¶
func (pb *PipelinesBuilder) Build() (PipelineProcessors, error)
Build pipeline processors from config.
type Receivers ¶
type Receivers map[configmodels.Receiver]*builtReceiver
Receivers is a map of receivers created from receiver configs.
type ReceiversBuilder ¶
type ReceiversBuilder struct {
// contains filtered or unexported fields
}
ReceiversBuilder builds receivers from config.
func NewReceiversBuilder ¶
func NewReceiversBuilder( logger *zap.Logger, config *configmodels.Config, pipelineProcessors PipelineProcessors, factories map[string]receiver.Factory, ) *ReceiversBuilder
NewReceiversBuilder creates a new ReceiversBuilder. Call Build() on the returned value.
func (*ReceiversBuilder) Build ¶
func (rb *ReceiversBuilder) Build() (Receivers, error)
Build receivers from config.