forwardconnector

README

Forward Connector

Status
Distributions	core, contrib
Issues

Supported Pipeline Types

Exporter Pipeline Type	Receiver Pipeline Type	Stability Level
traces	traces	beta
metrics	metrics	beta
logs	logs	beta

The forward connector can merge or fork pipelines of the same type.

Configuration

If you are not already familiar with connectors, you may find it helpful to first visit the Connectors README.

The forward connector does not have any configuration settings.

receivers:
  foo:
exporters:
  bar:
connectors:
  forward:

Example Usage

Annotate distinct log streams, then merge them together, batch, and export.

receivers:
  foo/blue:
  foo/green:
processors:
  attributes/blue:
  attributes/green:
  batch:
exporters:
  bar:
connectors:
  forward:
service:
  pipelines:
    logs/blue:
      receivers: [foo/blue]
      processors: [attributes/blue]
      exporters: [forward]
    logs/green:
      receivers: [foo/green]
      processors: [attributes/green]
      exporters: [forward]
    logs:
      receivers: [forward]
      processors: [batch]
      exporters: [bar]

Preprocess data, then replicate and handle in distinct ways.

receivers:
  foo:
processors:
  resourcedetection:
  sample:
  attributes:
  batch:
exporters:
  bar/hot:
  bar/cold:
connectors:
  forward:
service:
  pipelines:
    traces:
      receivers: [foo]
      processors: [resourcedetection]
      exporters: [forward]
    traces/hot:
      receivers: [forward]
      processors: [sample, batch]
      exporters: [bar/hot]
    traces/cold:
      receivers: [forward]
      processors: [attributes]
      exporters: [bar/cold]

Add a temporary debugging exporter. (Uncomment to enable.)

receivers:
  foo:
processors:
  filter:
  batch:
exporters:
  bar:
# connectors:
#   forward:
service:
  pipelines:
    traces:
      receivers:
        - foo
      processors:
        - filter
        - batch
      exporters:
        - bar
      # - forward
  # traces/log:
  #   receivers: [forward]
  #   exporters: [logging]

Documentation

Overview

Package forwardconnector passes signals from one pipeline to another.

Index

• func NewFactory() connector.Factory
• type Config

Functions

func NewFactory

func NewFactory() connector.Factory

NewFactory returns a connector.Factory.

Types

type Config

type Config struct{}