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 NewMetrics(mcs []consumer.Metrics) consumer.Metrics
• func NewProfiles(tcs []consumerprofiles.Profiles) consumerprofiles.Profiles
• func NewTraces(tcs []consumer.Traces) consumer.Traces

Functions

func NewLogs

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

NewLogs wraps multiple log consumers in a single one. It fans out 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 mutable data.

func NewMetrics

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

NewMetrics wraps multiple metrics consumers in a single one. It fans out 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 mutable data.

func NewProfiles

func NewProfiles(tcs []consumerprofiles.Profiles) consumerprofiles.Profiles

NewProfiles wraps multiple profile consumers in a single one. It fans out 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 mutable data.

func NewTraces

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

NewTraces wraps multiple trace consumers in a single one. It fans out 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 mutable data.