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

    Constants

    This section is empty.

    Variables

    This section is empty.

    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.

                Types

                This section is empty.