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 LogConsumer

    type LogConsumer interface {
    	// ConsumeLogs receives data.Logs for processing.
    	ConsumeLogs(ctx context.Context, ld data.Logs) error
    }

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

      type MetricsConsumer

      type MetricsConsumer interface {
      	MetricsConsumerBase
      	ConsumeMetrics(ctx context.Context, md pdata.Metrics) error
      }

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

        type MetricsConsumerBase

        type MetricsConsumerBase interface{}

          MetricsConsumerBase defines a common interface for MetricsConsumerOld and MetricsConsumer.

          type MetricsConsumerOld

          type MetricsConsumerOld interface {
          	MetricsConsumerBase
          	ConsumeMetricsData(ctx context.Context, md consumerdata.MetricsData) error
          }

            MetricsConsumerOld is an interface that receives consumerdata.MetricsData, process it as needed, and sends it to the next processing node if any or to the destination.

            ConsumeMetricsData receives consumerdata.MetricsData for processing by the MetricsConsumer.

            type TraceConsumer

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

              TraceConsumer 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.

              type TraceConsumerBase

              type TraceConsumerBase interface{}

                TraceConsumerBase defines a common interface for TraceConsumerOld and TraceConsumer.

                type TraceConsumerOld

                type TraceConsumerOld interface {
                	TraceConsumerBase
                	ConsumeTraceData(ctx context.Context, td consumerdata.TraceData) error
                }

                  TraceConsumerOld is an interface that receives consumerdata.TraceData, process it as needed, and sends it to the next processing node if any or to the destination.

                  ConsumeTraceData receives consumerdata.TraceData for processing by the TraceConsumer.

                  Source Files

                  Directories

                  Path Synopsis
                  Package consumerdata contains data structures that holds proto metrics/spans, node and resource.
                  Package consumerdata contains data structures that holds proto metrics/spans, node and resource.
                  Package consumererror provides wrappers to easily classify errors.
                  Package consumererror provides wrappers to easily classify errors.
                  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.
                  Package pdatautil is a temporary package to allow components to transition to the new API.
                  Package pdatautil is a temporary package to allow components to transition to the new API.