model

package
v1.0.0-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 18, 2023 License: AGPL-3.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LabelNameProfileType    = "__profile_type__"
	LabelNameType           = "__type__"
	LabelNameUnit           = "__unit__"
	LabelNamePeriodType     = "__period_type__"
	LabelNamePeriodUnit     = "__period_unit__"
	LabelNameDelta          = "__delta__"
	LabelNameProfileName    = pmodel.MetricNameLabel
	LabelNameServiceName    = "service_name"
	LabelNameServiceNameK8s = "__meta_kubernetes_pod_annotation_pyroscope_io_service_name"
)
View Source 
const MaxNodes = 8192

Variables

This section is empty.

Functions

func CloneLabelPairs 

func CloneLabelPairs(lbs []*typesv1.LabelPair) []*typesv1.LabelPair

CloneLabelPairs clones the label pairs.

func CompareLabelPairs 

func CompareLabelPairs(a []*typesv1.LabelPair, b []*typesv1.LabelPair) int

Compare compares the two label sets. The result will be 0 if a==b, <0 if a < b, and >0 if a > b.

func CompareProfile 

func CompareProfile(a, b *ingestv1.Profile) int64

CompareProfile compares the two profiles.

func ExportDiffToFlamebearer 

func ExportDiffToFlamebearer(fg *querierv1.FlameGraphDiff, profileType *typesv1.ProfileType) *flamebearer.FlamebearerProfile

func ExportToFlamebearer 

func ExportToFlamebearer(fg *querierv1.FlameGraph, profileType *typesv1.ProfileType) *flamebearer.FlamebearerProfile

ExportToFlamebearer exports the flamegraph to a Flamebearer struct.

func LabelPairsString 

func LabelPairsString(lbs []*typesv1.LabelPair) string

LabelPairsString returns a string representation of the label pairs.

func MergeBatchMergeStacktraces 

func MergeBatchMergeStacktraces(responses ...*ingestv1.MergeProfilesStacktracesResult) *ingestv1.MergeProfilesStacktracesResult

func NewFlameGraph 

func NewFlameGraph(t *Tree, maxNodes int64) *querierv1.FlameGraph

func NewFlamegraphDiff 

func NewFlamegraphDiff(left, right *Tree, maxNodes int) (*querierv1.FlameGraphDiff, error)

NewFlamegraphDiff generates a FlameGraphDiff from 2 trees. It also prunes the final tree based on the maxNodes parameter Notice that the resulting FlameGraph can't be used interchangeably with a 'single' Flamegraph Due to many differences: * Nodes * It's structure is different 

i+0 = x offset, left  tree
i+1 = total   , left  tree
i+2 = self    , left  tree
i+3 = x offset, right tree
i+4 = total   , right tree
i+5 = self    , right tree
i+6 = index in the names array

func ParseProfileTypeSelector 

func ParseProfileTypeSelector(id string) (*typesv1.ProfileType, error)

ParseProfileTypeSelector parses the profile selector string.

func SelectorFromProfileType 

func SelectorFromProfileType(profileType *typesv1.ProfileType) *labels.Matcher

SelectorFromProfileType builds a *label.Matcher from an profile type struct

func SetProfileMetadata 

func SetProfileMetadata(p *profile.Profile, ty *typesv1.ProfileType)

SetProfileMetadata sets the metadata on the profile.

func StacktracePartitionFromProfile 

func StacktracePartitionFromProfile(lbls []Labels, p *profilev1.Profile) uint64

func StringToLabelsPairs 

func StringToLabelsPairs(s string) ([]*typesv1.LabelPair, error)

StringToLabelsPairs converts a string representation of label pairs to a slice of label pairs.

func SumSeries 

func SumSeries(series ...[]*typesv1.Series) []*typesv1.Series

Types

type FlameGraphMerger 

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

func NewFlameGraphMerger 

func NewFlameGraphMerger() *FlameGraphMerger

func (*FlameGraphMerger) FlameGraph 

func (m *FlameGraphMerger) FlameGraph(maxNodes int64) *querierv1.FlameGraph

func (*FlameGraphMerger) MergeFlameGraph 

func (m *FlameGraphMerger) MergeFlameGraph(src *querierv1.FlameGraph)

MergeFlameGraph adds the flame graph stack traces to the resulting flame graph. The call is thread-safe, but the resulting flame graph or tree should be only accessed after all the samples are merged.

func (*FlameGraphMerger) Tree 

func (m *FlameGraphMerger) Tree() *Tree

type Labels 

type Labels []*typesv1.LabelPair

Labels is a sorted set of labels. Order has to be guaranteed upon instantiation.

func LabelsFromStrings 

func LabelsFromStrings(ss ...string) Labels

LabelsFromStrings creates new labels from pairs of strings.

func (Labels) BytesWithLabels 

func (ls Labels) BytesWithLabels(buf []byte, names ...string) []byte

BytesWithLabels is just as Bytes(), but only for labels matching names. 'names' have to be sorted in ascending order. It uses an byte invalid character as a separator and so should not be used for printing.

func (Labels) Clone 

func (ls Labels) Clone() Labels

func (Labels) Get 

func (ls Labels) Get(name string) string

Get returns the value for the label with the given name. Returns an empty string if the label doesn't exist.

func (Labels) Hash 

func (ls Labels) Hash() uint64

Hash returns a hash value for the label set.

func (Labels) HashForLabels 

func (ls Labels) HashForLabels(b []byte, names ...string) (uint64, []byte)

HashForLabels returns a hash value for the labels matching the provided names. 'names' have to be sorted in ascending order.

func (Labels) HashWithoutLabels 

func (ls Labels) HashWithoutLabels(b []byte, names ...string) (uint64, []byte)

HashWithoutLabels returns a hash value for all labels except those matching the provided names. 'names' have to be sorted in ascending order.

func (Labels) Len 

func (ls Labels) Len() int

func (Labels) Less 

func (ls Labels) Less(i, j int) bool

func (Labels) Swap 

func (ls Labels) Swap(i, j int)

func (Labels) ToPrometheusLabels 

func (ls Labels) ToPrometheusLabels() labels.Labels

func (Labels) WithLabels 

func (ls Labels) WithLabels(names ...string) Labels

WithLabels returns a subset of Labels that matches match with the provided label names.

func (Labels) WithoutPrivateLabels 

func (ls Labels) WithoutPrivateLabels() Labels

type LabelsBuilder 

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

LabelsBuilder allows modifying Labels.

func NewLabelsBuilder 

func NewLabelsBuilder(base Labels) *LabelsBuilder

NewLabelsBuilder returns a new LabelsBuilder.

func (*LabelsBuilder) Del 

func (b *LabelsBuilder) Del(ns ...string) *LabelsBuilder

Del deletes the label of the given name.

func (*LabelsBuilder) Labels 

func (b *LabelsBuilder) Labels() Labels

Labels returns the labels from the builder. If no modifications were made, the original labels are returned.

func (*LabelsBuilder) Reset 

func (b *LabelsBuilder) Reset(base Labels)

Reset clears all current state for the builder.

func (*LabelsBuilder) Set 

func (b *LabelsBuilder) Set(n, v string) *LabelsBuilder

Set the name/value pair as a label.

type SeriesMerger 

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

func NewSeriesMerger 

func NewSeriesMerger(sum bool) *SeriesMerger

NewSeriesMerger creates a new series merger. If sum is set, samples with matching timestamps are summed, otherwise duplicates are discarded.

func (*SeriesMerger) MergeSeries 

func (m *SeriesMerger) MergeSeries(s []*typesv1.Series)

func (*SeriesMerger) Series 

func (m *SeriesMerger) Series() []*typesv1.Series

type Stack 

type Stack[T any] struct {
	// contains filtered or unexported fields
}

Stack is a stack of values. Pushing and popping values is O(1).

func NewStack 

func NewStack[T any]() *Stack[T]

func (*Stack[T]) Pop 

func (s *Stack[T]) Pop() (result T, ok bool)

Pop removes and returns the top value from the stack.

func (*Stack[T]) Push 

func (s *Stack[T]) Push(v T)

Push adds a value to the top of the stack.

func (*Stack[T]) Reset 

func (s *Stack[T]) Reset()

Reset releases the stack's resources.

func (*Stack[T]) Slice 

func (s *Stack[T]) Slice() []T

Slice returns a slice of the values in the stack. The top value of the stack is at the beginning of the slice.

type StacktraceMerger 

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

func NewStackTraceMerger 

func NewStackTraceMerger() *StacktraceMerger

NewStackTraceMerger merges collections of StacktraceSamples. The result is a byte tree representation of the merged samples.

func (*StacktraceMerger) MergeStackTraces 

func (m *StacktraceMerger) MergeStackTraces(stacks []*ingestv1.StacktraceSample, names []string)

MergeStackTraces adds the stack traces to the resulting tree. The call is thread-safe, but the resulting tree bytes should be only build after all the samples are merged. Note that the function may reuse the capacity of the names slice.

func (*StacktraceMerger) Size 

func (m *StacktraceMerger) Size() int

func (*StacktraceMerger) TreeBytes 

func (m *StacktraceMerger) TreeBytes(maxNodes int64) []byte

type StacktracesHasher 

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

func (StacktracesHasher) Hashes 

func (h StacktracesHasher) Hashes(fnIds []int32) uint64

todo we might want to reuse the results to avoid allocations

type Tree 

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

func UnmarshalTree 

func UnmarshalTree(b []byte) (*Tree, error)

func (*Tree) InsertStack 

func (t *Tree) InsertStack(v int64, stack ...string)

func (*Tree) MarshalTruncate 

func (t *Tree) MarshalTruncate(w io.Writer, maxNodes int64) (err error)

MarshalTruncate writes tree byte representation to the writer provider, the number of nodes is limited to maxNodes. The function modifies the tree: truncated nodes are removed from the tree.

func (*Tree) Merge 

func (t *Tree) Merge(src *Tree)

func (*Tree) String 

func (t *Tree) String() string

func (*Tree) Total 

func (t *Tree) Total() (v int64)

type TreeMerger 

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

func NewTreeMerger 

func NewTreeMerger() *TreeMerger

func (*TreeMerger) MergeTreeBytes 

func (m *TreeMerger) MergeTreeBytes(b []byte) error

func (*TreeMerger) Tree 

func (m *TreeMerger) Tree() *Tree

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.