Skip to content

Latest commit

 

History

History
135 lines (117 loc) · 3.79 KB

File metadata and controls

135 lines (117 loc) · 3.79 KB

Forward Connector

Status
Distributions core, contrib, k8s
Issues Open issues Closed 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: [debug]