Versions in this module Expand all Collapse all v2 v2.0.1 Apr 22, 2026 v2.0.0 Apr 22, 2026 Changes in this version + const AttrDBSystem + const AttrExceptionMessage + const AttrExceptionStacktrace + const AttrExceptionType + const AttrMessagingSystem + const AttrRPCSystem + const AttrServiceName + const ContentTypeAltProtobuf + const ContentTypeJSON + const ContentTypeProtobuf + const DefaultCollectorSourceTag + const DefaultFingerprintTag + const DefaultHostTag + const DefaultLogService + const DefaultLogSource + const DefaultMaxMessageLength + const DefaultMessageField + const DefaultMetricMeasurement + const DefaultMetricTemporality + const DefaultParentSpanID + const DefaultSchemaURLKey + const DefaultScopeNameKey + const DefaultServiceTag + const DefaultSourceTag + const DefaultSpanIDField + const DefaultStatusTag + const DefaultTraceBaseServiceTag + const DefaultTraceDBHostTag + const DefaultTraceDurationField + const DefaultTraceFingerprintTag + const DefaultTraceIDField + const DefaultTraceMessageField + const DefaultTraceParentIDField + const DefaultTracePointName + const DefaultTraceResourceField + const DefaultTraceRuntimeIDField + const DefaultTraceServiceTag + const DefaultTraceSource + const DefaultTraceSourceTag + const DefaultTraceSourceTypeTag + const DefaultTraceSpanIDField + const DefaultTraceSpanKindTag + const DefaultTraceSpanTypeTag + const DefaultTraceStartField + const DefaultTraceStatusTag + const DefaultTraceTraceIDField + const DefaultUnknownService + const EventException + const MetricSuffixAvg + const MetricSuffixBucket + const MetricSuffixCount + const MetricSuffixInf + const MetricSuffixMax + const MetricSuffixMin + const MetricSuffixSum + const MetricTagLE + const MetricTagUnit + const SpanStatusError + const SpanStatusInfo + const SpanStatusOK + const TraceSourceTypeCustomer + const TraceSourceTypeDB + const TraceSourceTypeMessage + const TraceSourceTypeWeb + var ErrUnsupportedContentType = errors.New("unsupported OTLP content type") + var PublicAttributeAliases = map[string]string + var SpanKindNames = map[int32]string + func AnyValueToInterface(value *common.AnyValue) (any, bool) + func AnyValueToString(value *common.AnyValue) (string, bool) + func AttributesToStringMap(attrs []*common.KeyValue, opts StringMapOptions) map[string]string + func AttributesToTagMap(attrs []*common.KeyValue, opts StringMapOptions) map[string]string + func Base64RawID(id []byte) string + func ChunkStringByRuneLength(s string, size int) []string + func DBHostFromAttributes(resourceAttrs, spanAttrs map[string]string) string + func DecimalIDFromLast8Bytes(id []byte) (string, bool) + func DefaultHostName(attrs []*common.KeyValue) string + func DefaultLogServiceAndSource(attrs []*common.KeyValue) (service string, source string) + func FindAttribute(attrs []*common.KeyValue, key string) (*common.KeyValue, int, bool) + func HexID(id []byte) string + func IsZeroID(id []byte) bool + func LogStatusFromSeverityNumber(severityNumber int32, fallback string) string + func MergeStringMapsAsFields(maps ...map[string]string) point.KVs + func MergeStringMapsAsTags(maps ...map[string]string) point.KVs + func MetricMeasurementFromAttribute(pointAttrs map[string]string, fallback string) string + func MetricNameFromAttribute(pointAttrs map[string]string, fallback string) string + func NormalizeContentType(contentType string) string + func NumberDataPointToPoint(measurement, field string, kvs point.KVs, pt *metrics.NumberDataPoint, ...) *point.Point + func NumberDataPointValue(pt *metrics.NumberDataPoint) (any, bool) + func ParseLogRequest(resourceLogs []*logs.ResourceLogs, opts LogsParserOptions) []*point.Point + func ParseResourceMetricsV2(resmcs []*metrics.ResourceMetrics, opts MetricsParserOptions) []*point.Point + func PublicAttributeAlias(key string) (string, bool) + func SelectPublicTraceAttributes(attrs []*common.KeyValue) (point.KVs, []*common.KeyValue) + func ShouldDropMetricAttribute(key string) bool + func SpanKindName(kind int32) string + func SummaryDataPointToPoint(measurement, field string, kvs point.KVs, summary *metrics.SummaryDataPoint, ...) *point.Point + func SystemNameForService(attrs map[string]string) string + func TraceSourceTypeFromTags(tags point.KVs) string + func TraceStatusFromCode(code int32) string + func Unmarshal(body []byte, contentType string, msg proto.Message) error + type LogsParserOptions struct + CollectorSourceIP string + CollectorSourceIPTag string + DKFingerprint string + DKFingerprintTag string + GlobalFields map[string]any + GlobalTags map[string]string + HostName func([]*common.KeyValue) string + HostTag string + IDConverter func([]byte) string + MaxMessageLen int + MessageField string + PointOptions func(ts time.Time) []point.Option + RecordStringOptions StringMapOptions + ResourceStringOptions StringMapOptions + SchemaURLKey string + ScopeNameKey string + ScopeStringOptions StringMapOptions + ServiceAndSource func([]*common.KeyValue) (service, source string) + ServiceTag string + SeverityMapper func(logs.SeverityNumber, string) string + SourceTag string + SpanIDField string + StatusTag string + TraceIDField string + type MetricsParserOptions struct + CollectorSourceIP string + CollectorSourceIPTag string + ExponentialHistogramAvg func(sum float64, count uint64) any + FieldName func(metric *metrics.Metric, pointAttrs map[string]string) string + KVOptions func(metric *metrics.Metric) []point.KVOption + Measurement string + MeasurementFromPointAttr func(metric *metrics.Metric, pointAttrs map[string]string) string + PointOptions func(ts time.Time) []point.Option + PointStringOptions StringMapOptions + ResourceStringOptions StringMapOptions + ScopeNameKey string + ScopeStringOptions StringMapOptions + TemporalityTagKey string + type StringMapOptions struct + DropKeys map[string]struct{} + KeyNormalizer func(string) string + MaxValueLen int + func DefaultMetricStringMapOptions() StringMapOptions + type TraceBatch []*point.Point + func ParseResourceSpans(resourceSpans []*trace.ResourceSpans, opts TracesParserOptions) []TraceBatch + type TracesParserOptions struct + BaseService func(map[string]string) string + BaseServiceTag string + CleanSpan func(*trace.Span) *trace.Span + CollectorSourceIP string + CollectorSourceIPTag string + DBHostTag string + DKFingerprint string + DKFingerprintTag string + DecorateKVs func(point.KVs, *trace.ResourceSpans, *trace.ScopeSpans, *trace.Span) point.KVs + DurationField string + GlobalTags map[string]string + IDConverter func([]byte) string + MessageEncoder func(*trace.Span) (string, error) + MessageField string + ParentIDField string + PointName string + ResourceField string + RuntimeIDField string + ScopeKVs func(*trace.ScopeSpans) point.KVs + SelectAttrs func([]*common.KeyValue) (point.KVs, []*common.KeyValue) + ServiceTag string + Source string + SourceTag string + SourceType func(point.KVs) string + SourceTypeTag string + SpanIDField string + SpanKind func(int32) string + SpanKindTag string + SpanStatus func(*trace.Status) string + SpanStatusTag string + SpanType func(spanID, parentID string, spanIDs, parentIDs map[string]bool) string + SpanTypeTag string + StartField string + TraceIDField string + UnknownService string
Go to main page