internal

Documentation

Index

• func AddCheckResponseBasedLabels(attributes pcommon.Map, checkResponse *flowcontrolv1.CheckResponse, ...)
• func AddEnvoySpecificLabels(attributes pcommon.Map)
• func AddFlowLabels(attributes pcommon.Map, checkResponse *flowcontrolv1.CheckResponse)
• func AddSDKSpecificLabels(attributes pcommon.Map)
• func EnforceIncludeListHTTP(attributes pcommon.Map)
• func EnforceIncludeListSDK(attributes pcommon.Map)
• func ResponseStatusForTelemetry(statusCode, featureStatus string) string
• func StatusLabelsForMetrics(decisionType flowcontrolv1.CheckResponse_DecisionType, statusCode string, ...) map[string]string
• func StatusesFromAttributes(attributes pcommon.Map) (statusCode string, featureStatus string)

Functions

func AddCheckResponseBasedLabels

func AddCheckResponseBasedLabels(attributes pcommon.Map, checkResponse *flowcontrolv1.CheckResponse, sourceStr string)

AddCheckResponseBasedLabels adds the following labels: * otelcollector.ApertureProcessingDurationLabel * otelcollector.ApertureServicesLabel * otelcollector.ApertureControlPointLabel * otelcollector.ApertureRateLimitersLabel * otelcollector.ApertureDroppingRateLimitersLabel * otelcollector.ApertureConcurrencyLimitersLabel * otelcollector.ApertureDroppingConcurrencyLimitersLabel * otelcollector.ApertureWorkloadsLabel * otelcollector.ApertureDroppingWorkloadsLabel * otelcollector.ApertureFluxMetersLabel * otelcollector.ApertureFlowLabelKeysLabel * otelcollector.ApertureClassifiersLabel * otelcollector.ApertureClassifierErrorsLabel * otelcollector.ApertureDecisionTypeLabel * otelcollector.ApertureRejectReasonLabel * otelcollector.ApertureErrorLabel, * dynamic flow labels.

func AddEnvoySpecificLabels

func AddEnvoySpecificLabels(attributes pcommon.Map)

AddEnvoySpecificLabels adds labels specific to Envoy data source.

func AddFlowLabels

func AddFlowLabels(attributes pcommon.Map, checkResponse *flowcontrolv1.CheckResponse)

AddFlowLabels adds dynamic from labels.

func AddSDKSpecificLabels

func AddSDKSpecificLabels(attributes pcommon.Map)

AddSDKSpecificLabels adds labels specific to SDK data source.

func EnforceIncludeListHTTP

func EnforceIncludeListHTTP(attributes pcommon.Map)

EnforceIncludeListHTTP filters attributes for HTTP telemetry.

func EnforceIncludeListSDK

func EnforceIncludeListSDK(attributes pcommon.Map)

EnforceIncludeListSDK filters attributes for SDK telemetry.

func ResponseStatusForTelemetry

func ResponseStatusForTelemetry(statusCode, featureStatus string) string

ResponseStatusForTelemetry returns response status for telemetry based on HTTP status code and Feature status.

func StatusLabelsForMetrics

func StatusLabelsForMetrics(
	decisionType flowcontrolv1.CheckResponse_DecisionType,
	statusCode string,
	featureStatus string,
) map[string]string

StatusLabelsForMetrics returns labels maps used which describe Histogram.

func StatusesFromAttributes

func StatusesFromAttributes(attributes pcommon.Map) (statusCode string, featureStatus string)

StatusesFromAttributes gets HTTP status code and Feature status from attributes.