pipelines

Documentation

Index

• type Pipelines
  • func Build(ctx context.Context, settings component.TelemetrySettings, ...) (*Pipelines, error)
  • func (bps *Pipelines) GetExporters() map[config.DataType]map[config.ComponentID]component.Exporter
  • func (bps *Pipelines) HandleZPages(w http.ResponseWriter, r *http.Request)
  • func (bps *Pipelines) ShutdownAll(ctx context.Context) error
  • func (bps *Pipelines) StartAll(ctx context.Context, host component.Host) error

Types

type Pipelines

type Pipelines struct {
	// contains filtered or unexported fields
}

Pipelines is set of all pipelines created from exporter configs.

func Build

func Build(ctx context.Context, settings component.TelemetrySettings, buildInfo component.BuildInfo, cfg *config.Config, factories component.Factories) (*Pipelines, error)

Build builds all pipelines from config.

func (*Pipelines) GetExporters

func (bps *Pipelines) GetExporters() map[config.DataType]map[config.ComponentID]component.Exporter

func (*Pipelines) HandleZPages

func (bps *Pipelines) HandleZPages(w http.ResponseWriter, r *http.Request)

func (*Pipelines) ShutdownAll

func (bps *Pipelines) ShutdownAll(ctx context.Context) error

ShutdownAll stops all pipelines.

Shutdown order is the reverse of starting: receivers, processors, then exporters. This gives senders a chance to send all their data to a not "shutdown" component.

func (*Pipelines) StartAll

func (bps *Pipelines) StartAll(ctx context.Context, host component.Host) error

StartAll starts all pipelines.

Start with exporters, processors (in revers configured order), then receivers. This is important so that components that are earlier in the pipeline and reference components that are later in the pipeline do not start sending data to later components which are not yet started.