Documentation

Overview

    Package consumer contains interfaces that receive and process consumerdata.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    Types

    type Logs

    type Logs interface {
    	// ConsumeLogs receives pdata.Logs for consumption.
    	ConsumeLogs(ctx context.Context, ld pdata.Logs) error
    }

      Logs is an interface that receives pdata.Logs, processes it as needed, and sends it to the next processing node if any or to the destination.

      type Metrics

      type Metrics interface {
      	// ConsumeMetrics receives pdata.Metrics for consumption.
      	ConsumeMetrics(ctx context.Context, md pdata.Metrics) error
      }

        Metrics is the new metrics consumer interface that receives pdata.Metrics, processes it as needed, and sends it to the next processing node if any or to the destination.

        type Traces

        type Traces interface {
        	// ConsumeTraces receives pdata.Traces for consumption.
        	ConsumeTraces(ctx context.Context, td pdata.Traces) error
        }

          Traces is an interface that receives pdata.Traces, processes it as needed, and sends it to the next processing node if any or to the destination.

          Source Files

          Directories

          Path Synopsis
          Package consumererror provides wrappers to easily classify errors.
          Package consumererror provides wrappers to easily classify errors.
          Package fanoutconsumer contains implementations of Traces/Metrics/Logs consumers that fan out the data to multiple other consumers.
          Package fanoutconsumer contains implementations of Traces/Metrics/Logs consumers that fan out the data to multiple other consumers.
          Package pdata (pipeline data) implements data structures that represent telemetry data in-memory.
          Package pdata (pipeline data) implements data structures that represent telemetry data in-memory.