fanoutconsumer

Documentation

Overview

Package fanoutconsumer contains implementations of Traces/Metrics/Logs consumers that fan out the data to multiple other consumers.

Index

• func NewLogs(lcs []consumer.Logs) consumer.Logs
• func NewLogsRouter(cm map[component.ID]consumer.Logs) consumer.Logs
• func NewMetrics(mcs []consumer.Metrics) consumer.Metrics
• func NewMetricsRouter(cm map[component.ID]consumer.Metrics) consumer.Metrics
• func NewTraces(tcs []consumer.Traces) consumer.Traces
• func NewTracesRouter(cm map[component.ID]consumer.Traces) consumer.Traces

Functions

func NewLogs

func NewLogs(lcs []consumer.Logs) consumer.Logs

NewLogs wraps multiple log consumers in a single one. It fanouts the incoming data to all the consumers, and does smart routing:

• Clones only to the consumer that needs to mutate the data.
• If all consumers needs to mutate the data one will get the original data.

func NewLogsRouter

func NewLogsRouter(cm map[component.ID]consumer.Logs) consumer.Logs

func NewMetrics

func NewMetrics(mcs []consumer.Metrics) consumer.Metrics

NewMetrics wraps multiple metrics consumers in a single one. It fanouts the incoming data to all the consumers, and does smart routing:

• Clones only to the consumer that needs to mutate the data.
• If all consumers needs to mutate the data one will get the original data.

func NewMetricsRouter

func NewMetricsRouter(cm map[component.ID]consumer.Metrics) consumer.Metrics

func NewTraces

func NewTraces(tcs []consumer.Traces) consumer.Traces

NewTraces wraps multiple trace consumers in a single one. It fanouts the incoming data to all the consumers, and does smart routing:

• Clones only to the consumer that needs to mutate the data.
• If all consumers needs to mutate the data one will get the original data.

func NewTracesRouter

func NewTracesRouter(cm map[component.ID]consumer.Traces) consumer.Traces