normalizer

package

Go to main page

Versions in this module

v0

v0.25.0

Nov 24, 2025

v0.24.2

Sep 10, 2025

v0.24.1

Sep 9, 2025

Changes in this version

+ func ValidateOtelDictionary(d *otelprofilingpb.ProfilesDictionary) error

v0.24.0

Jun 20, 2025

Changes in this version

type InternalRecordBuilderV1

+ TimeNanos *array.Int64

v0.23.1

Feb 24, 2025

v0.23.0

Feb 20, 2025

v0.22.0

Aug 9, 2024

Changes in this version

+ const MetadataSchemaVersion

+ const MetadataSchemaVersionV1

+ func MetaFromOtelProfile(p *pprofextended.Profile, name string, sampleIndex int, duration int64) profile.Meta

+ func MetaFromPprof(p *pprofpb.Profile, name string, sampleIndex int) profile.Meta

+ func NewArrowToInternalConverter(mem memory.Allocator, schema *dynparquet.Schema, metrics *Metrics) *arrowToInternalConverter

+ func OtlpRequestToArrowRecord(ctx context.Context, req *otelgrpcprofilingpb.ExportProfilesServiceRequest, ...) (arrow.Record, error)

+ func SampleToParquetRow(schema *dynparquet.Schema, row parquet.Row, ...) parquet.Row

+ func ValidateOtelExportProfilesServiceRequest(req *otelgrpcprofilingpb.ExportProfilesServiceRequest) error

+ func ValidateOtelProfile(p *otelprofilingpb.Profile) error

+ func WriteRawRequestToArrowRecord(ctx context.Context, mem memory.Allocator, req *profilestorepb.WriteRawRequest, ...) (arrow.Record, error)

+ type InternalRecordBuilderV1 struct

+ Duration *array.Int64

+ LabelFields []arrow.Field

+ Labels []arrow.Array

+ Locations *array.List

+ Period *array.Int64

+ PeriodType *array.Dictionary

+ PeriodUnit *array.Dictionary

+ Producer *array.Dictionary

+ SampleType *array.Dictionary

+ SampleUnit *array.Dictionary

+ StacktraceIDs *array.Dictionary

+ Timestamp *array.Int64

+ Value *array.Int64

+ func (r *InternalRecordBuilderV1) Release()

+ type Metrics struct

+ IncompleteLocations prometheus.Counter

+ func NewMetrics(reg prometheus.Registerer) *Metrics

+ type NormalizedProfile struct

+ Meta profile.Meta

+ Samples []*NormalizedSample

+ func NormalizePprof(ctx context.Context, name string, takenLabelNames map[string]string, ...) ([]*NormalizedProfile, error)

+ type NormalizedSample struct

+ DiffValue int64

+ Label map[string]string

+ Locations [][]byte

+ NumLabel map[string]int64

+ Value int64

type NormalizedWriteRawRequest

+ func NormalizeWriteRawRequest(ctx context.Context, req *profilestorepb.WriteRawRequest) (NormalizedWriteRawRequest, error)

v0.21.0

Feb 27, 2024

Changes in this version

+ const UnsymolizableLocationAddress

+ var ErrMissingNameLabel = errors.New("missing __name__ label")

+ func CalculateBase(ei *profilestorepb.ExecutableInfo, start, limit, offset uint64) (uint64, error)

+ func LabelNamesFromSamples(takenLabels map[string]string, stringTable []string, samples []*pprofpb.Sample, ...)

+ func LabelsFromSample(takenLabels map[string]string, stringTable []string, plabels []*pprofpb.Label) (map[string]string, map[string]int64)

+ func NormalizeAddress(addr uint64, ei *profilestorepb.ExecutableInfo, start, limit, offset uint64) (uint64, error)

+ func ValidatePprofProfile(p *pprofpb.Profile, ei []*profilestorepb.ExecutableInfo) error

+ type MetastoreNormalizer struct

+ func NewNormalizer(metastore pb.MetastoreServiceClient, enableAddressNormalization bool, ...) *MetastoreNormalizer

+ func (n *MetastoreNormalizer) NormalizeFunctions(ctx context.Context, functions []*pprofpb.Function, stringTable []string) ([]*pb.Function, error)

+ func (n *MetastoreNormalizer) NormalizeLocations(ctx context.Context, locations []*pprofpb.Location, ...) ([]*pb.Location, error)

+ func (n *MetastoreNormalizer) NormalizeMappings(ctx context.Context, mappings []*pprofpb.Mapping, stringTable []string) ([]mappingNormalizationInfo, error)

+ func (n *MetastoreNormalizer) NormalizePprof(ctx context.Context, name string, takenLabelNames map[string]string, ...) ([]*profile.NormalizedProfile, error)

+ func (n *MetastoreNormalizer) NormalizeStacktraces(ctx context.Context, samples []*pprofpb.Sample, locations []*pb.Location) ([]*pb.Stacktrace, error)

+ func (n *MetastoreNormalizer) NormalizeWriteRawRequest(ctx context.Context, req *profilestorepb.WriteRawRequest) (NormalizedWriteRawRequest, error)

+ type NormalizedWriteRawRequest struct

+ AllLabelNames []string

+ AllPprofLabelNames []string

+ AllPprofNumLabelNames []string

+ Series []Series

+ type Normalizer interface

+ NormalizePprof func(ctx context.Context, name string, takenLabelNames map[string]string, ...) ([]*profile.NormalizedProfile, error)

+ NormalizeWriteRawRequest func(ctx context.Context, req *profilestorepb.WriteRawRequest) (NormalizedWriteRawRequest, error)

+ type Series struct

+ Labels map[string]string

+ Samples [][]*profile.NormalizedProfile

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL