Back to godoc.org
go.opentelemetry.io/collector/processor

package processor

v0.4.0
Latest Go to latest
Published: Jun 16, 2020 | License: Apache-2.0 | Module: go.opentelemetry.io/collector

Index

Variables

var (
	TagServiceNameKey, _   = tag.NewKey("service")
	TagProcessorNameKey, _ = tag.NewKey(obsreport.ProcessorKey)

	StatReceivedSpanCount = stats.Int64(
		"spans_received",
		"counts the number of spans received",
		stats.UnitDimensionless)
	StatDroppedSpanCount = stats.Int64(
		"spans_dropped",
		"counts the number of spans dropped",
		stats.UnitDimensionless)
	StatBadBatchDroppedSpanCount = stats.Int64(
		"bad_batch_spans_dropped",
		"counts the number of spans dropped due to being in bad batches",
		stats.UnitDimensionless)

	StatTraceBatchesDroppedCount = stats.Int64(
		"trace_batches_dropped",
		"counts the number of trace batches dropped",
		stats.UnitDimensionless)

	StatDroppedMetricCount = stats.Int64(
		"metrics_dropped",
		"counts the number of metrics dropped",
		stats.UnitDimensionless)

	StatMetricBatchesDroppedCount = stats.Int64(
		"metric_batches_dropped",
		"counts the number of metric batches dropped",
		stats.UnitDimensionless)
)

Keys and stats for telemetry.

func CreateMetricsCloningFanOutConnector

func CreateMetricsCloningFanOutConnector(mcs []consumer.MetricsConsumerBase) consumer.MetricsConsumerBase

CreateMetricsCloningFanOutConnector is a placeholder function for now. It supposed to create an old type connector or a new type connector based on type of provided metrics consumer.

func CreateMetricsFanOutConnector

func CreateMetricsFanOutConnector(mcs []consumer.MetricsConsumerBase) consumer.MetricsConsumerBase

CreateMetricsFanOutConnector creates a connector based on provided type of trace consumer. If any of the wrapped metrics consumers are of the new type, use metricsFanOutConnector, otherwise use the old type connector.

func CreateTraceCloningFanOutConnector

func CreateTraceCloningFanOutConnector(tcs []consumer.TraceConsumerBase) consumer.TraceConsumerBase

CreateTraceCloningFanOutConnector is a placeholder function for now. It supposed to create an old type connector or a new type connector based on type of provided trace consumer.

func CreateTraceFanOutConnector

func CreateTraceFanOutConnector(tcs []consumer.TraceConsumerBase) consumer.TraceConsumerBase

CreateTraceFanOutConnector wraps multiple trace consumers in a single one. If any of the wrapped trace consumers are of the new type, use traceFanOutConnector, otherwise use the old type connector

func MetricTagKeys

func MetricTagKeys(level telemetry.Level) []tag.Key

MetricTagKeys returns the metric tag keys according to the given telemetry level.

func MetricViews

func MetricViews(level telemetry.Level) []*view.View

MetricViews return the metrics views according to given telemetry level.

func NewLogCloningFanOutConnector

func NewLogCloningFanOutConnector(lcs []consumer.LogConsumer) consumer.LogConsumer

NewLogCloningFanOutConnector wraps multiple trace consumers in a single one.

func NewLogFanOutConnector

func NewLogFanOutConnector(lcs []consumer.LogConsumer) consumer.LogConsumer

NewLogFanOutConnector wraps multiple new type consumers in a single one.

func NewMetricsFanOutConnector

func NewMetricsFanOutConnector(mcs []consumer.MetricsConsumer) consumer.MetricsConsumer

NewMetricsFanOutConnector wraps multiple new type metrics consumers in a single one.

func NewMetricsFanOutConnectorOld

func NewMetricsFanOutConnectorOld(mcs []consumer.MetricsConsumerOld) consumer.MetricsConsumerOld

NewMetricsFanOutConnectorOld wraps multiple metrics consumers in a single one.

func NewTraceFanOutConnector

func NewTraceFanOutConnector(tcs []consumer.TraceConsumer) consumer.TraceConsumer

NewTraceFanOutConnector wraps multiple new type trace consumers in a single one.

func NewTraceFanOutConnectorOld

func NewTraceFanOutConnectorOld(tcs []consumer.TraceConsumerOld) consumer.TraceConsumerOld

NewTraceFanOutConnectorOld wraps multiple trace consumers in a single one.

func RecordsSpanCountMetrics

func RecordsSpanCountMetrics(ctx context.Context, scm *SpanCountStats, measure *stats.Int64Measure)

RecordsSpanCountMetrics reports span count metrics for specified measure.

func ServiceNameForNode

func ServiceNameForNode(node *commonpb.Node) string

ServiceNameForNode gets the service name for a specified node.

func ServiceNameForResource

func ServiceNameForResource(resource pdata.Resource) string

ServiceNameForResource gets the service name for a specified Resource. TODO: Find a better package for this function.

type LogCloningFanOutConnector

type LogCloningFanOutConnector []consumer.LogConsumer

func (LogCloningFanOutConnector) ConsumeLogs

func (lfc LogCloningFanOutConnector) ConsumeLogs(ctx context.Context, ld data.Logs) error

ConsumeLogs exports the span data to all consumers wrapped by the current one.

type LogFanOutConnector

type LogFanOutConnector []consumer.LogConsumer

func (LogFanOutConnector) ConsumeLogs

func (fc LogFanOutConnector) ConsumeLogs(ctx context.Context, ld data.Logs) error

Consume exports the span data to all consumers wrapped by the current one.

type SpanCountStats

type SpanCountStats struct {
	// contains filtered or unexported fields
}

SpanCountStats represents span count stats grouped by service if DETAILED telemetry level is set, otherwise only overall span count is stored in serviceSpansCounts.

func NewSpanCountStats

func NewSpanCountStats(td pdata.Traces, processorName string) *SpanCountStats

func (*SpanCountStats) GetAllSpansCount

func (scm *SpanCountStats) GetAllSpansCount() int
Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
f or F : Jump to identifier