tree

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2024 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DefaultSampleTypeMapping = map[string]*SampleTypeConfig{

	"samples": {
		DisplayName: "cpu",
		Units:       metadata.SamplesUnits,
		Sampled:     true,
	},
	"inuse_objects": {
		Units:       metadata.ObjectsUnits,
		Aggregation: metadata.AverageAggregationType,
	},
	"alloc_objects": {
		Units:      metadata.ObjectsUnits,
		Cumulative: true,
	},
	"inuse_space": {
		Units:       metadata.BytesUnits,
		Aggregation: metadata.AverageAggregationType,
	},
	"alloc_space": {
		Units:      metadata.BytesUnits,
		Cumulative: true,
	},
	"goroutine": {
		DisplayName: "goroutines",
		Units:       metadata.GoroutinesUnits,
		Aggregation: metadata.AverageAggregationType,
	},
	"contentions": {

		DisplayName: "mutex_count",
		Units:       metadata.LockSamplesUnits,
		Cumulative:  true,
	},
	"delay": {

		DisplayName: "mutex_duration",
		Units:       metadata.LockNanosecondsUnits,
		Cumulative:  true,
	},
}

DefaultSampleTypeMapping contains default settings for every supported pprof sample type. These settings are required to build a proper storage.PutInput payload.

TODO(kolesnikovae): We should find a way to eliminate collisions. 

For example, both Go 'block' and 'mutex' profiles have
'contentions' and 'delay' sample types - this means we can't
override display name of the profile types and they would
be indistinguishable for the server.

The keys should have the following structure:
	{origin}.{profile_type}.{sample_type}

Example names (can be a reserved label, e.g __type__):
  * go.cpu.samples
  * go.block.delay
  * go.mutex.delay
  * nodejs.heap.objects

Another problem is that in pull mode we don't have spy-name, therefore we should solve this problem first.

View Source 
var File_og_storage_tree_profile_proto protoreflect.FileDescriptor

Functions

func CombineTree 

func CombineTree(leftTree, rightTree *Tree) (*Tree, *Tree)

CombineTree aligns 2 trees by making them having the same structure with the same number of nodes TODO: create a new struct?

func FindFunctionName 

func FindFunctionName(x *Profile, locID uint64) (string, bool)

Types

type Finder 

type Finder interface {
	FunctionFinder
	LocationFinder
}

func NewFinder 

func NewFinder(p *Profile) Finder

NewFinder creates an efficient finder for functions or locations in a profile.

It exists to abstract the details of how functions and locations exist in a pprof profile, and make it easy to provide an efficient implementation depending on the actual profile format, as location and function finding is a recurrent operation while processing pprof profiles.

The [pprof format description](https://github.com/google/pprof/tree/master/proto#general-structure-of-a-profile) describes that both locations and functions have unique nonzero ids. A [comment in the proto file](https://github.com/google/pprof/blob/master/proto/profile.proto#L164-L166) goes further: _A profile could use instruction addresses or any integer sequence as ids_.

Based on this, any uint64 value (except 0) can appear as ids, and a map based cache can be used in that case. In practice, [go runtime](https://github.com/golang/go/blob/master/src/runtime/pprof/proto.go#L537) generates profiles where locations and functions use consecutive IDs starting from 1, making optimized access possible.

Taking advantage of this, the finder will try to:

  • Use direct access to functions and locations indexed by IDs when possible (sorting location and function sequences if needed).
  • Use a map based cache otherwise.

type Flamebearer 

type Flamebearer struct {
	Names    []string `json:"names"`
	Levels   [][]int  `json:"levels"`
	NumTicks int      `json:"numTicks"`
	MaxSelf  int      `json:"maxSelf"`
	// TODO: see note in render.go
	SpyName    string `json:"spyName"`
	SampleRate uint32 `json:"sampleRate"`
	Units      string `json:"units"`
	Format     Format `json:"format"`
}

func CombineToFlamebearerStruct 

func CombineToFlamebearerStruct(leftTree, rightTree *Tree, maxNodes int) *Flamebearer

CombineToFlamebearerStruct generates the Flamebearer struct from 2 trees. They must be the response trees from CombineTree (i.e. all children nodes must be the same length). The Flamebearer struct returned from this function is different to the one returned from Tree.FlamebearerStruct(). It has the following structure: 

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

type Format 

type Format string
const (
	FormatSingle Format = "single"
	FormatDouble Format = "double"
)

type Function 

type Function struct {

	// Unique nonzero id for the function.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the function, in human-readable form if available.
	Name int64 `protobuf:"varint,2,opt,name=name,proto3" json:"name,omitempty"` // Index into string table
	// Name of the function, as identified by the system.
	// For instance, it can be a C++ mangled name.
	SystemName int64 `protobuf:"varint,3,opt,name=system_name,json=systemName,proto3" json:"system_name,omitempty"` // Index into string table
	// Source file containing the function.
	Filename int64 `protobuf:"varint,4,opt,name=filename,proto3" json:"filename,omitempty"` // Index into string table
	// Line number in source file.
	StartLine int64 `protobuf:"varint,5,opt,name=start_line,json=startLine,proto3" json:"start_line,omitempty"`
	// contains filtered or unexported fields
}

func FindFunction 

func FindFunction(x *Profile, fid uint64) (*Function, bool)

func (*Function) Descriptor deprecated 

func (*Function) Descriptor() ([]byte, []int)

Deprecated: Use Function.ProtoReflect.Descriptor instead.

func (*Function) GetFilename 

func (x *Function) GetFilename() int64

func (*Function) GetId 

func (x *Function) GetId() uint64

func (*Function) GetName 

func (x *Function) GetName() int64

func (*Function) GetStartLine 

func (x *Function) GetStartLine() int64

func (*Function) GetSystemName 

func (x *Function) GetSystemName() int64

func (*Function) MarshalToSizedBufferVT 

func (m *Function) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Function) MarshalToVT 

func (m *Function) MarshalToVT(dAtA []byte) (int, error)

func (*Function) MarshalVT 

func (m *Function) MarshalVT() (dAtA []byte, err error)

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) ProtoReflect 

func (x *Function) ProtoReflect() protoreflect.Message

func (*Function) Reset 

func (x *Function) Reset()

func (*Function) SizeVT 

func (m *Function) SizeVT() (n int)

func (*Function) String 

func (x *Function) String() string

func (*Function) UnmarshalVT 

func (m *Function) UnmarshalVT(dAtA []byte) error

type FunctionFinder 

type FunctionFinder interface {
	FindFunction(id uint64) (*Function, bool)
}

Find function in a profile based on its ID

type Label 

type Label struct {
	Key int64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"` // Index into string table
	// At most one of the following must be present
	Str int64 `protobuf:"varint,2,opt,name=str,proto3" json:"str,omitempty"` // Index into string table
	Num int64 `protobuf:"varint,3,opt,name=num,proto3" json:"num,omitempty"`
	// Should only be present when num is present.
	// Specifies the units of num.
	// Use arbitrary string (for example, "requests") as a custom count unit.
	// If no unit is specified, consumer may apply heuristic to deduce the unit.
	// Consumers may also  interpret units like "bytes" and "kilobytes" as memory
	// units and units like "seconds" and "nanoseconds" as time units,
	// and apply appropriate unit conversions to these.
	NumUnit int64 `protobuf:"varint,4,opt,name=num_unit,json=numUnit,proto3" json:"num_unit,omitempty"` // Index into string table
	// contains filtered or unexported fields
}

func CopyLabel 

func CopyLabel(label *Label) *Label

func (*Label) Descriptor deprecated 

func (*Label) Descriptor() ([]byte, []int)

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetKey 

func (x *Label) GetKey() int64

func (*Label) GetNum 

func (x *Label) GetNum() int64

func (*Label) GetNumUnit 

func (x *Label) GetNumUnit() int64

func (*Label) GetStr 

func (x *Label) GetStr() int64

func (*Label) MarshalToSizedBufferVT 

func (m *Label) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Label) MarshalToVT 

func (m *Label) MarshalToVT(dAtA []byte) (int, error)

func (*Label) MarshalVT 

func (m *Label) MarshalVT() (dAtA []byte, err error)

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

func (x *Label) ProtoReflect() protoreflect.Message

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) SizeVT 

func (m *Label) SizeVT() (n int)

func (*Label) String 

func (x *Label) String() string

func (*Label) UnmarshalVT 

func (m *Label) UnmarshalVT(dAtA []byte) error

type Labels 

type Labels []*Label

func CopyLabels 

func CopyLabels(labels Labels) Labels

func CutLabel 

func CutLabel(labels Labels, i int) Labels

CutLabel creates a copy of labels without label i.

func (Labels) Hash 

func (l Labels) Hash() uint64

func (Labels) Len 

func (l Labels) Len() int

func (Labels) Less 

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

func (Labels) Swap 

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

type LabelsCache 

type LabelsCache[T any] struct {
	Map     map[int64]map[uint64]*LabelsCacheEntry[T]
	Factory func() *T
}

sample type -> labels hash -> entry

func NewLabelsCache added in v1.1.0 

func NewLabelsCache[T any](factory func() *T) LabelsCache[T]

func (*LabelsCache[T]) Get 

func (c *LabelsCache[T]) Get(sampleType int64, h uint64) (*LabelsCacheEntry[T], bool)

func (*LabelsCache[T]) GetOrCreateTree 

func (c *LabelsCache[T]) GetOrCreateTree(sampleType int64, l Labels) *LabelsCacheEntry[T]

func (*LabelsCache[T]) GetOrCreateTreeByHash 

func (c *LabelsCache[T]) GetOrCreateTreeByHash(sampleType int64, l Labels, h uint64) *LabelsCacheEntry[T]

func (*LabelsCache[T]) NewCacheEntry added in v1.1.0 

func (c *LabelsCache[T]) NewCacheEntry(l Labels) *LabelsCacheEntry[T]

func (*LabelsCache[T]) Put 

func (c *LabelsCache[T]) Put(sampleType int64, e *LabelsCacheEntry[T])

func (*LabelsCache[T]) Remove 

func (c *LabelsCache[T]) Remove(sampleType int64, h uint64)

type LabelsCacheEntry 

type LabelsCacheEntry[T any] struct {
	Labels
	Value *T
}

type Line 

type Line struct {

	// The id of the corresponding profile.Function for this line.
	FunctionId uint64 `protobuf:"varint,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Line number in source code.
	Line int64 `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*Line) Descriptor deprecated 

func (*Line) Descriptor() ([]byte, []int)

Deprecated: Use Line.ProtoReflect.Descriptor instead.

func (*Line) GetFunctionId 

func (x *Line) GetFunctionId() uint64

func (*Line) GetLine 

func (x *Line) GetLine() int64

func (*Line) MarshalToSizedBufferVT 

func (m *Line) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Line) MarshalToVT 

func (m *Line) MarshalToVT(dAtA []byte) (int, error)

func (*Line) MarshalVT 

func (m *Line) MarshalVT() (dAtA []byte, err error)

func (*Line) ProtoMessage 

func (*Line) ProtoMessage()

func (*Line) ProtoReflect 

func (x *Line) ProtoReflect() protoreflect.Message

func (*Line) Reset 

func (x *Line) Reset()

func (*Line) SizeVT 

func (m *Line) SizeVT() (n int)

func (*Line) String 

func (x *Line) String() string

func (*Line) UnmarshalVT 

func (m *Line) UnmarshalVT(dAtA []byte) error

type Location 

type Location struct {

	// Unique nonzero id for the location.  A profile could use
	// instruction addresses or any integer sequence as ids.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The id of the corresponding profile.Mapping for this location.
	// It can be unset if the mapping is unknown or not applicable for
	// this profile type.
	MappingId uint64 `protobuf:"varint,2,opt,name=mapping_id,json=mappingId,proto3" json:"mapping_id,omitempty"`
	// The instruction address for this location, if available.  It
	// should be within [Mapping.memory_start...Mapping.memory_limit]
	// for the corresponding mapping. A non-leaf address may be in the
	// middle of a call instruction. It is up to display tools to find
	// the beginning of the instruction if necessary.
	Address uint64 `protobuf:"varint,3,opt,name=address,proto3" json:"address,omitempty"`
	// Multiple line indicates this location has inlined functions,
	// where the last entry represents the caller into which the
	// preceding entries were inlined.
	//
	// E.g., if memcpy() is inlined into printf:
	//
	//	line[0].function_name == "memcpy"
	//	line[1].function_name == "printf"
	Line []*Line `protobuf:"bytes,4,rep,name=line,proto3" json:"line,omitempty"`
	// Provides an indication that multiple symbols map to this location's
	// address, for example due to identical code folding by the linker. In that
	// case the line information above represents one of the multiple
	// symbols. This field must be recomputed when the symbolization state of the
	// profile changes.
	IsFolded bool `protobuf:"varint,5,opt,name=is_folded,json=isFolded,proto3" json:"is_folded,omitempty"`
	// contains filtered or unexported fields
}

Describes function and line table debug information.

func FindLocation 

func FindLocation(x *Profile, lid uint64) (*Location, bool)

func (*Location) Descriptor deprecated 

func (*Location) Descriptor() ([]byte, []int)

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetAddress 

func (x *Location) GetAddress() uint64

func (*Location) GetId 

func (x *Location) GetId() uint64

func (*Location) GetIsFolded 

func (x *Location) GetIsFolded() bool

func (*Location) GetLine 

func (x *Location) GetLine() []*Line

func (*Location) GetMappingId 

func (x *Location) GetMappingId() uint64

func (*Location) MarshalToSizedBufferVT 

func (m *Location) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Location) MarshalToVT 

func (m *Location) MarshalToVT(dAtA []byte) (int, error)

func (*Location) MarshalVT 

func (m *Location) MarshalVT() (dAtA []byte, err error)

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

func (x *Location) ProtoReflect() protoreflect.Message

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) SizeVT 

func (m *Location) SizeVT() (n int)

func (*Location) String 

func (x *Location) String() string

func (*Location) UnmarshalVT 

func (m *Location) UnmarshalVT(dAtA []byte) error

type LocationFinder 

type LocationFinder interface {
	FindLocation(id uint64) (*Location, bool)
}

Find location in a profile based on its ID

type Mapping 

type Mapping struct {

	// Unique nonzero id for the mapping.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Address at which the binary (or DLL) is loaded into memory.
	MemoryStart uint64 `protobuf:"varint,2,opt,name=memory_start,json=memoryStart,proto3" json:"memory_start,omitempty"`
	// The limit of the address range occupied by this mapping.
	MemoryLimit uint64 `protobuf:"varint,3,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
	// Offset in the binary that corresponds to the first mapped address.
	FileOffset uint64 `protobuf:"varint,4,opt,name=file_offset,json=fileOffset,proto3" json:"file_offset,omitempty"`
	// The object this entry is loaded from.  This can be a filename on
	// disk for the main binary and shared libraries, or virtual
	// abstractions like "[vdso]".
	Filename int64 `protobuf:"varint,5,opt,name=filename,proto3" json:"filename,omitempty"` // Index into string table
	// A string that uniquely identifies a particular program version
	// with high probability. E.g., for binaries generated by GNU tools,
	// it could be the contents of the .note.gnu.build-id field.
	BuildId int64 `protobuf:"varint,6,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` // Index into string table
	// The following fields indicate the resolution of symbolic info.
	HasFunctions    bool `protobuf:"varint,7,opt,name=has_functions,json=hasFunctions,proto3" json:"has_functions,omitempty"`
	HasFilenames    bool `protobuf:"varint,8,opt,name=has_filenames,json=hasFilenames,proto3" json:"has_filenames,omitempty"`
	HasLineNumbers  bool `protobuf:"varint,9,opt,name=has_line_numbers,json=hasLineNumbers,proto3" json:"has_line_numbers,omitempty"`
	HasInlineFrames bool `protobuf:"varint,10,opt,name=has_inline_frames,json=hasInlineFrames,proto3" json:"has_inline_frames,omitempty"`
	// contains filtered or unexported fields
}

func (*Mapping) Descriptor deprecated 

func (*Mapping) Descriptor() ([]byte, []int)

Deprecated: Use Mapping.ProtoReflect.Descriptor instead.

func (*Mapping) GetBuildId 

func (x *Mapping) GetBuildId() int64

func (*Mapping) GetFileOffset 

func (x *Mapping) GetFileOffset() uint64

func (*Mapping) GetFilename 

func (x *Mapping) GetFilename() int64

func (*Mapping) GetHasFilenames 

func (x *Mapping) GetHasFilenames() bool

func (*Mapping) GetHasFunctions 

func (x *Mapping) GetHasFunctions() bool

func (*Mapping) GetHasInlineFrames 

func (x *Mapping) GetHasInlineFrames() bool

func (*Mapping) GetHasLineNumbers 

func (x *Mapping) GetHasLineNumbers() bool

func (*Mapping) GetId 

func (x *Mapping) GetId() uint64

func (*Mapping) GetMemoryLimit 

func (x *Mapping) GetMemoryLimit() uint64

func (*Mapping) GetMemoryStart 

func (x *Mapping) GetMemoryStart() uint64

func (*Mapping) MarshalToSizedBufferVT 

func (m *Mapping) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mapping) MarshalToVT 

func (m *Mapping) MarshalToVT(dAtA []byte) (int, error)

func (*Mapping) MarshalVT 

func (m *Mapping) MarshalVT() (dAtA []byte, err error)

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) ProtoReflect 

func (x *Mapping) ProtoReflect() protoreflect.Message

func (*Mapping) Reset 

func (x *Mapping) Reset()

func (*Mapping) SizeVT 

func (m *Mapping) SizeVT() (n int)

func (*Mapping) String 

func (x *Mapping) String() string

func (*Mapping) UnmarshalVT 

func (m *Mapping) UnmarshalVT(dAtA []byte) error

type PprofMetadata 

type PprofMetadata struct {
	Type       string
	Unit       string
	PeriodType string
	PeriodUnit string
	Period     int64
	StartTime  time.Time
	Duration   time.Duration
}

type Profile 

type Profile struct {

	// A description of the samples associated with each Sample.value.
	// For a cpu profile this might be:
	//
	//	[["cpu","nanoseconds"]] or [["wall","seconds"]] or [["syscall","count"]]
	//
	// For a heap profile, this might be:
	//
	//	[["allocations","count"], ["space","bytes"]],
	//
	// If one of the values represents the number of events represented
	// by the sample, by convention it should be at index 0 and use
	// sample_type.unit == "count".
	SampleType []*ValueType `protobuf:"bytes,1,rep,name=sample_type,json=sampleType,proto3" json:"sample_type,omitempty"`
	// The set of samples recorded in this profile.
	Sample []*Sample `protobuf:"bytes,2,rep,name=sample,proto3" json:"sample,omitempty"`
	// Mapping from address ranges to the image/binary/library mapped
	// into that address range.  mapping[0] will be the main binary.
	Mapping []*Mapping `protobuf:"bytes,3,rep,name=mapping,proto3" json:"mapping,omitempty"`
	// Useful program location
	Location []*Location `protobuf:"bytes,4,rep,name=location,proto3" json:"location,omitempty"`
	// Functions referenced by locations
	Function []*Function `protobuf:"bytes,5,rep,name=function,proto3" json:"function,omitempty"`
	// A common table for strings referenced by various messages.
	// string_table[0] must always be "".
	StringTable []string `protobuf:"bytes,6,rep,name=string_table,json=stringTable,proto3" json:"string_table,omitempty"`
	// frames with Function.function_name fully matching the following
	// regexp will be dropped from the samples, along with their successors.
	DropFrames int64 `protobuf:"varint,7,opt,name=drop_frames,json=dropFrames,proto3" json:"drop_frames,omitempty"` // Index into string table.
	// frames with Function.function_name fully matching the following
	// regexp will be kept, even if it matches drop_functions.
	KeepFrames int64 `protobuf:"varint,8,opt,name=keep_frames,json=keepFrames,proto3" json:"keep_frames,omitempty"` // Index into string table.
	// Time of collection (UTC) represented as nanoseconds past the epoch.
	TimeNanos int64 `protobuf:"varint,9,opt,name=time_nanos,json=timeNanos,proto3" json:"time_nanos,omitempty"`
	// Duration of the profile, if a duration makes sense.
	DurationNanos int64 `protobuf:"varint,10,opt,name=duration_nanos,json=durationNanos,proto3" json:"duration_nanos,omitempty"`
	// The kind of events between sampled ocurrences.
	// e.g [ "cpu","cycles" ] or [ "heap","bytes" ]
	PeriodType *ValueType `protobuf:"bytes,11,opt,name=period_type,json=periodType,proto3" json:"period_type,omitempty"`
	// The number of events between sampled occurrences.
	Period int64 `protobuf:"varint,12,opt,name=period,proto3" json:"period,omitempty"`
	// Freeform text associated to the profile.
	Comment []int64 `protobuf:"varint,13,rep,packed,name=comment,proto3" json:"comment,omitempty"` // Indices into string table.
	// Index into the string table of the type of the preferred sample
	// value. If unset, clients should default to the last sample value.
	DefaultSampleType int64 `protobuf:"varint,14,opt,name=default_sample_type,json=defaultSampleType,proto3" json:"default_sample_type,omitempty"`
	// contains filtered or unexported fields
}

func ProfileFromVTPool 

func ProfileFromVTPool() *Profile

func (*Profile) Descriptor deprecated 

func (*Profile) Descriptor() ([]byte, []int)

Deprecated: Use Profile.ProtoReflect.Descriptor instead.

func (*Profile) Get 

func (x *Profile) Get(sampleType string, cb func(labels *spy.Labels, name []byte, val int) error) error

func (*Profile) GetComment 

func (x *Profile) GetComment() []int64

func (*Profile) GetDefaultSampleType 

func (x *Profile) GetDefaultSampleType() int64

func (*Profile) GetDropFrames 

func (x *Profile) GetDropFrames() int64

func (*Profile) GetDurationNanos 

func (x *Profile) GetDurationNanos() int64

func (*Profile) GetFunction 

func (x *Profile) GetFunction() []*Function

func (*Profile) GetKeepFrames 

func (x *Profile) GetKeepFrames() int64

func (*Profile) GetLocation 

func (x *Profile) GetLocation() []*Location

func (*Profile) GetMapping 

func (x *Profile) GetMapping() []*Mapping

func (*Profile) GetPeriod 

func (x *Profile) GetPeriod() int64

func (*Profile) GetPeriodType 

func (x *Profile) GetPeriodType() *ValueType

func (*Profile) GetSample 

func (x *Profile) GetSample() []*Sample

func (*Profile) GetSampleType 

func (x *Profile) GetSampleType() []*ValueType

func (*Profile) GetStringTable 

func (x *Profile) GetStringTable() []string

func (*Profile) GetTimeNanos 

func (x *Profile) GetTimeNanos() int64

func (*Profile) MarshalToSizedBufferVT 

func (m *Profile) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Profile) MarshalToVT 

func (m *Profile) MarshalToVT(dAtA []byte) (int, error)

func (*Profile) MarshalVT 

func (m *Profile) MarshalVT() (dAtA []byte, err error)

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) ProtoReflect 

func (x *Profile) ProtoReflect() protoreflect.Message

func (*Profile) Reset 

func (x *Profile) Reset()

func (*Profile) ResetVT 

func (m *Profile) ResetVT()

func (*Profile) ResolveLabelName 

func (x *Profile) ResolveLabelName(l *Label) (string, bool)

func (*Profile) ResolveLabels 

func (x *Profile) ResolveLabels(l Labels) map[string]string

func (*Profile) ResolveSampleType 

func (x *Profile) ResolveSampleType(v int64) (*ValueType, bool)

func (*Profile) ReturnToVTPool 

func (m *Profile) ReturnToVTPool()

func (*Profile) SampleTypes 

func (x *Profile) SampleTypes() []string

func (*Profile) SizeVT 

func (m *Profile) SizeVT() (n int)

func (*Profile) String 

func (x *Profile) String() string

func (*Profile) UnmarshalVT 

func (m *Profile) UnmarshalVT(dAtA []byte) error

type Sample 

type Sample struct {

	// The ids recorded here correspond to a Profile.location.id.
	// The leaf is at location_id[0].
	LocationId []uint64 `protobuf:"varint,1,rep,packed,name=location_id,json=locationId,proto3" json:"location_id,omitempty"`
	// The type and unit of each value is defined by the corresponding
	// entry in Profile.sample_type. All samples must have the same
	// number of values, the same as the length of Profile.sample_type.
	// When aggregating multiple samples into a single sample, the
	// result has a list of values that is the element-wise sum of the
	// lists of the originals.
	Value []int64 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	// label includes additional context for this sample. It can include
	// things like a thread id, allocation size, etc
	Label []*Label `protobuf:"bytes,3,rep,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

Each Sample records values encountered in some program context. The program context is typically a stack trace, perhaps augmented with auxiliary information like the thread-id, some indicator of a higher level request being handled etc.

func (*Sample) Descriptor deprecated 

func (*Sample) Descriptor() ([]byte, []int)

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) GetLabel 

func (x *Sample) GetLabel() []*Label

func (*Sample) GetLocationId 

func (x *Sample) GetLocationId() []uint64

func (*Sample) GetValue 

func (x *Sample) GetValue() []int64

func (*Sample) MarshalToSizedBufferVT 

func (m *Sample) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Sample) MarshalToVT 

func (m *Sample) MarshalToVT(dAtA []byte) (int, error)

func (*Sample) MarshalVT 

func (m *Sample) MarshalVT() (dAtA []byte, err error)

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect 

func (x *Sample) ProtoReflect() protoreflect.Message

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) SizeVT 

func (m *Sample) SizeVT() (n int)

func (*Sample) String 

func (x *Sample) String() string

func (*Sample) UnmarshalVT 

func (m *Sample) UnmarshalVT(dAtA []byte) error

type SampleTypeConfig 

type SampleTypeConfig struct {
	Units       metadata.Units           `json:"units,omitempty" yaml:"units,omitempty"`
	DisplayName string                   `json:"display-name,omitempty" yaml:"display-name,omitempty"`
	Aggregation metadata.AggregationType `json:"aggregation,omitempty" yaml:"aggregation,omitempty"`
	Cumulative  bool                     `json:"cumulative,omitempty" yaml:"cumulative,omitempty"`
	Sampled     bool                     `json:"sampled,omitempty" yaml:"sampled,omitempty"`
}

type StackBuilder 

type StackBuilder interface {
	Push(frame []byte)
	Pop() // bool
	Build() (stackID uint64)
	Reset()
}

type Tree 

type Tree struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Deserialize 

func Deserialize(d *dict.Dict, r io.Reader) (*Tree, error)

func DeserializeNoDict 

func DeserializeNoDict(r io.Reader) (*Tree, error)

used in the cloud

func New 

func New() *Tree

func (*Tree) Clone 

func (t *Tree) Clone(r *big.Rat) *Tree

func (*Tree) Collapsed 

func (t *Tree) Collapsed() string

func (*Tree) Diff 

func (t *Tree) Diff(x *Tree) *Tree

func (*Tree) FlamebearerStruct 

func (t *Tree) FlamebearerStruct(maxNodes int) *Flamebearer

func (*Tree) Insert 

func (t *Tree) Insert(key []byte, value uint64)

func (*Tree) InsertInt 

func (t *Tree) InsertInt(key []byte, value int)

func (*Tree) InsertStack 

func (t *Tree) InsertStack(stack [][]byte, v uint64)

func (*Tree) InsertStackA 

func (t *Tree) InsertStackA(stack [][]byte, v uint64)

func (*Tree) InsertStackString 

func (t *Tree) InsertStackString(stack []string, v uint64)

func (*Tree) Iterate 

func (t *Tree) Iterate(cb func(key []byte, val uint64))

func (*Tree) IterateStacks 

func (t *Tree) IterateStacks(cb func(name string, self uint64, stack []string))

func (*Tree) IterateWithStackBuilder 

func (t *Tree) IterateWithStackBuilder(sb StackBuilder, cb func(stackID uint64, val uint64))

func (*Tree) MarshalJSON 

func (t *Tree) MarshalJSON() ([]byte, error)

func (*Tree) Merge 

func (t *Tree) Merge(srcTrieI merge.Merger)

func (*Tree) Pprof 

func (t *Tree) Pprof(mdata *PprofMetadata) *Profile

func (*Tree) Samples 

func (t *Tree) Samples() uint64

func (*Tree) Scale 

func (t *Tree) Scale(s uint64)

func (*Tree) SerializeTruncate 

func (t *Tree) SerializeTruncate(d *dict.Dict, maxNodes int, w io.Writer) error

warning: this function modifies the tree

func (*Tree) SerializeTruncateNoDict 

func (t *Tree) SerializeTruncateNoDict(maxNodes int, w io.Writer) error

used in the cloud warning: this function modifies the tree

func (*Tree) String 

func (t *Tree) String() string

type ValueType 

type ValueType struct {
	Type int64 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` // Index into string table.
	Unit int64 `protobuf:"varint,2,opt,name=unit,proto3" json:"unit,omitempty"` // Index into string table.
	// contains filtered or unexported fields
}

ValueType describes the semantics and measurement units of a value.

func (*ValueType) Descriptor deprecated 

func (*ValueType) Descriptor() ([]byte, []int)

Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

func (*ValueType) GetType 

func (x *ValueType) GetType() int64

func (*ValueType) GetUnit 

func (x *ValueType) GetUnit() int64

func (*ValueType) MarshalToSizedBufferVT 

func (m *ValueType) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValueType) MarshalToVT 

func (m *ValueType) MarshalToVT(dAtA []byte) (int, error)

func (*ValueType) MarshalVT 

func (m *ValueType) MarshalVT() (dAtA []byte, err error)

func (*ValueType) ProtoMessage 

func (*ValueType) ProtoMessage()

func (*ValueType) ProtoReflect 

func (x *ValueType) ProtoReflect() protoreflect.Message

func (*ValueType) Reset 

func (x *ValueType) Reset()

func (*ValueType) SizeVT 

func (m *ValueType) SizeVT() (n int)

func (*ValueType) String 

func (x *ValueType) String() string

func (*ValueType) UnmarshalVT 

func (m *ValueType) UnmarshalVT(dAtA []byte) error

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.