fanoutconsumer

Documentation

Overview

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

Cloning connectors create clones of data before fanning out, which ensures each consumer gets their own copy of data and is free to modify it.

Index

• func NewLogs(lcs []consumer.Logs) consumer.Logs
• func NewLogsCloning(lcs []consumer.Logs) consumer.Logs
• func NewMetrics(mcs []consumer.Metrics) consumer.Metrics
• func NewMetricsCloning(mcs []consumer.Metrics) consumer.Metrics
• func NewTraces(tcs []consumer.Traces) consumer.Traces
• func NewTracesCloning(tcs []consumer.Traces) consumer.Traces

Functions

func NewLogs

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

NewLogs wraps multiple log consumers in a single one.

func NewLogsCloning

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

NewLogsCloning wraps multiple trace consumers in a single one and clones the data before fanning out.

func NewMetrics

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

NewMetrics wraps multiple metrics consumers in a single one.

func NewMetricsCloning

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

NewMetricsCloning wraps multiple metrics consumers in a single one and clones the data before fanning out.

func NewTraces

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

NewTraces wraps multiple trace consumers in a single one.

func NewTracesCloning

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

NewTracesCloning wraps multiple traces consumers in a single one and clones the data before fanning out.