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 AddLuaSpecificLabels(attributes pcommon.Map)
• func AddSDKSpecificLabels(attributes pcommon.Map)
• func EnforceIncludeListHTTP(attributes pcommon.Map)
• func EnforceIncludeListSDK(attributes pcommon.Map)
• func FlowStatusForTelemetry(statusCode, flowStatusStr string) string
• func StatusLabelsForMetrics(decisionType flowcontrolv1.CheckResponse_DecisionType, statusCode string, ...) map[string]string
• func StatusesFromAttributes(attributes pcommon.Map) (statusCode string, flowStatus string)

Functions

func AddCheckResponseBasedLabels

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

AddCheckResponseBasedLabels adds the following labels: * otelconsts.ApertureProcessingDurationLabel * otelconsts.ApertureServicesLabel * otelconsts.ApertureControlPointLabel * otelconsts.ApertureRateLimitersLabel * otelconsts.ApertureDroppingRateLimitersLabel * otelconsts.ApertureLoadSchedulersLabel * otelconsts.ApertureQuotaSchedulersLabel * otelconsts.ApertureDroppingQuotaSchedulersLabel * otelconsts.ApertureDroppingLoadSchedulersLabel * otelconsts.ApertureWorkloadsLabel * otelconsts.ApertureDroppingWorkloadsLabel * otelconsts.ApertureFluxMetersLabel * otelconsts.ApertureFlowLabelKeysLabel * otelconsts.ApertureClassifiersLabel * otelconsts.ApertureClassifierErrorsLabel * otelconsts.ApertureDecisionTypeLabel * otelconsts.ApertureRejectReasonLabel * otelconsts.ApertureResultCacheLookupStatusLabel * otelconsts.ApertureResultCacheOperationStatusLabel * otelconsts.ApertureGlobalCacheLookupStatusesLabel * otelconsts.ApertureGlobalCacheOperationStatusesLabel * 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 AddLuaSpecificLabels

func AddLuaSpecificLabels(attributes pcommon.Map)

AddLuaSpecificLabels adds labels specific to data source.

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 FlowStatusForTelemetry

func FlowStatusForTelemetry(statusCode, flowStatusStr string) string

FlowStatusForTelemetry returns protocol independent Flow status for telemetry based on HTTP status code and Flow status.

func StatusLabelsForMetrics

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

StatusLabelsForMetrics returns labels maps used which describe Histogram.

func StatusesFromAttributes

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

StatusesFromAttributes gets HTTP status code and Flow status from attributes.