v1development

package
v1.21.0 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProfiles        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProfiles          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProfiles = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AggregationTemporality_name = map[int32]string{
	0: "AGGREGATION_TEMPORALITY_UNSPECIFIED",
	1: "AGGREGATION_TEMPORALITY_DELTA",
	2: "AGGREGATION_TEMPORALITY_CUMULATIVE",
}
View Source 
var AggregationTemporality_value = map[string]int32{
	"AGGREGATION_TEMPORALITY_UNSPECIFIED": 0,
	"AGGREGATION_TEMPORALITY_DELTA":       1,
	"AGGREGATION_TEMPORALITY_CUMULATIVE":  2,
}

Functions

This section is empty.

Types

type AggregationTemporality 

type AggregationTemporality int32

Specifies the method of aggregating metric values, either DELTA (change since last report) or CUMULATIVE (total since a fixed start time). 

const (
	// UNSPECIFIED is the default AggregationTemporality, it MUST not be used.
	AggregationTemporality_AGGREGATION_TEMPORALITY_UNSPECIFIED AggregationTemporality = 0
	//* DELTA is an AggregationTemporality for a profiler which reports
	//changes since last report time. Successive metrics contain aggregation of
	//values from continuous and non-overlapping intervals.
	//
	//The values for a DELTA metric are based only on the time interval
	//associated with one measurement cycle. There is no dependency on
	//previous measurements like is the case for CUMULATIVE metrics.
	//
	//For example, consider a system measuring the number of requests that
	//it receives and reports the sum of these requests every second as a
	//DELTA metric:
	//
	//1. The system starts receiving at time=t_0.
	//2. A request is received, the system measures 1 request.
	//3. A request is received, the system measures 1 request.
	//4. A request is received, the system measures 1 request.
	//5. The 1 second collection cycle ends. A metric is exported for the
	//number of requests received over the interval of time t_0 to
	//t_0+1 with a value of 3.
	//6. A request is received, the system measures 1 request.
	//7. A request is received, the system measures 1 request.
	//8. The 1 second collection cycle ends. A metric is exported for the
	//number of requests received over the interval of time t_0+1 to
	//t_0+2 with a value of 2.
	AggregationTemporality_AGGREGATION_TEMPORALITY_DELTA AggregationTemporality = 1
	//* CUMULATIVE is an AggregationTemporality for a profiler which
	//reports changes since a fixed start time. This means that current values
	//of a CUMULATIVE metric depend on all previous measurements since the
	//start time. Because of this, the sender is required to retain this state
	//in some form. If this state is lost or invalidated, the CUMULATIVE metric
	//values MUST be reset and a new fixed start time following the last
	//reported measurement time sent MUST be used.
	//
	//For example, consider a system measuring the number of requests that
	//it receives and reports the sum of these requests every second as a
	//CUMULATIVE metric:
	//
	//1. The system starts receiving at time=t_0.
	//2. A request is received, the system measures 1 request.
	//3. A request is received, the system measures 1 request.
	//4. A request is received, the system measures 1 request.
	//5. The 1 second collection cycle ends. A metric is exported for the
	//number of requests received over the interval of time t_0 to
	//t_0+1 with a value of 3.
	//6. A request is received, the system measures 1 request.
	//7. A request is received, the system measures 1 request.
	//8. The 1 second collection cycle ends. A metric is exported for the
	//number of requests received over the interval of time t_0 to
	//t_0+2 with a value of 5.
	//9. The system experiences a fault and loses state.
	//10. The system recovers and resumes receiving at time=t_1.
	//11. A request is received, the system measures 1 request.
	//12. The 1 second collection cycle ends. A metric is exported for the
	//number of requests received over the interval of time t_1 to
	//t_1+1 with a value of 1.
	//
	//Note: Even though, when reporting changes since last report time, using
	//CUMULATIVE is valid, it is not recommended.
	AggregationTemporality_AGGREGATION_TEMPORALITY_CUMULATIVE AggregationTemporality = 2
)

func (AggregationTemporality) EnumDescriptor 

func (AggregationTemporality) EnumDescriptor() ([]byte, []int)

func (AggregationTemporality) String 

func (x AggregationTemporality) String() string

type AttributeUnit 

type AttributeUnit struct {
	// Index into string table.
	AttributeKeyStrindex int32 `protobuf:"varint,1,opt,name=attribute_key_strindex,json=attributeKeyStrindex,proto3" json:"attribute_key_strindex,omitempty"`
	// Index into string table.
	UnitStrindex int32 `protobuf:"varint,2,opt,name=unit_strindex,json=unitStrindex,proto3" json:"unit_strindex,omitempty"`
}

Represents a mapping between Attribute Keys and Units.

func (*AttributeUnit) Descriptor 

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

func (*AttributeUnit) GetAttributeKeyStrindex 

func (m *AttributeUnit) GetAttributeKeyStrindex() int32

func (*AttributeUnit) GetUnitStrindex 

func (m *AttributeUnit) GetUnitStrindex() int32

func (*AttributeUnit) Marshal 

func (m *AttributeUnit) Marshal() (dAtA []byte, err error)

func (*AttributeUnit) MarshalTo 

func (m *AttributeUnit) MarshalTo(dAtA []byte) (int, error)

func (*AttributeUnit) MarshalToSizedBuffer 

func (m *AttributeUnit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AttributeUnit) ProtoMessage 

func (*AttributeUnit) ProtoMessage()

func (*AttributeUnit) Reset 

func (m *AttributeUnit) Reset()

func (*AttributeUnit) Size 

func (m *AttributeUnit) Size() (n int)

func (*AttributeUnit) String 

func (m *AttributeUnit) String() string

func (*AttributeUnit) Unmarshal 

func (m *AttributeUnit) Unmarshal(dAtA []byte) error

func (*AttributeUnit) XXX_DiscardUnknown 

func (m *AttributeUnit) XXX_DiscardUnknown()

func (*AttributeUnit) XXX_Marshal 

func (m *AttributeUnit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttributeUnit) XXX_Merge 

func (m *AttributeUnit) XXX_Merge(src proto.Message)

func (*AttributeUnit) XXX_Size 

func (m *AttributeUnit) XXX_Size() int

func (*AttributeUnit) XXX_Unmarshal 

func (m *AttributeUnit) XXX_Unmarshal(b []byte) error

type Function 

type Function struct {
	// Name of the function, in human-readable form if available.
	NameStrindex int32 `protobuf:"varint,1,opt,name=name_strindex,json=nameStrindex,proto3" json:"name_strindex,omitempty"`
	// Name of the function, as identified by the system.
	// For instance, it can be a C++ mangled name.
	SystemNameStrindex int32 `protobuf:"varint,2,opt,name=system_name_strindex,json=systemNameStrindex,proto3" json:"system_name_strindex,omitempty"`
	// Source file containing the function.
	FilenameStrindex int32 `protobuf:"varint,3,opt,name=filename_strindex,json=filenameStrindex,proto3" json:"filename_strindex,omitempty"`
	// Line number in source file.
	StartLine int64 `protobuf:"varint,4,opt,name=start_line,json=startLine,proto3" json:"start_line,omitempty"`
}

Describes a function, including its human-readable name, system name, source file, and starting line number in the source.

func (*Function) Descriptor 

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

func (*Function) GetFilenameStrindex 

func (m *Function) GetFilenameStrindex() int32

func (*Function) GetNameStrindex 

func (m *Function) GetNameStrindex() int32

func (*Function) GetStartLine 

func (m *Function) GetStartLine() int64

func (*Function) GetSystemNameStrindex 

func (m *Function) GetSystemNameStrindex() int32

func (*Function) Marshal 

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

func (*Function) MarshalTo 

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

func (*Function) MarshalToSizedBuffer 

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

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) Reset 

func (m *Function) Reset()

func (*Function) Size 

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

func (*Function) String 

func (m *Function) String() string

func (*Function) Unmarshal 

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

func (*Function) XXX_DiscardUnknown 

func (m *Function) XXX_DiscardUnknown()

func (*Function) XXX_Marshal 

func (m *Function) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Function) XXX_Merge 

func (m *Function) XXX_Merge(src proto.Message)

func (*Function) XXX_Size 

func (m *Function) XXX_Size() int

func (*Function) XXX_Unmarshal 

func (m *Function) XXX_Unmarshal(b []byte) error

type Label 

type Label struct {
	KeyStrindex int32 `protobuf:"varint,1,opt,name=key_strindex,json=keyStrindex,proto3" json:"key_strindex,omitempty"`
	// At most one of the following must be present
	StrStrindex int32 `protobuf:"varint,2,opt,name=str_strindex,json=strStrindex,proto3" json:"str_strindex,omitempty"`
	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.
	NumUnitStrindex int32 `protobuf:"varint,4,opt,name=num_unit_strindex,json=numUnitStrindex,proto3" json:"num_unit_strindex,omitempty"`
}

Provides additional context for a sample, such as thread ID or allocation size, with optional units. [deprecated]

func (*Label) Descriptor 

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

func (*Label) GetKeyStrindex 

func (m *Label) GetKeyStrindex() int32

func (*Label) GetNum 

func (m *Label) GetNum() int64

func (*Label) GetNumUnitStrindex 

func (m *Label) GetNumUnitStrindex() int32

func (*Label) GetStrStrindex 

func (m *Label) GetStrStrindex() int32

func (*Label) Marshal 

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

func (*Label) MarshalTo 

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

func (*Label) MarshalToSizedBuffer 

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

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

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

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Label) XXX_Merge 

func (m *Label) XXX_Merge(src proto.Message)

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

func (m *Label) XXX_Unmarshal(b []byte) error

type Line 

type Line struct {
	// Reference to function in Profile.function_table.
	FunctionIndex int32 `protobuf:"varint,1,opt,name=function_index,json=functionIndex,proto3" json:"function_index,omitempty"`
	// Line number in source code.
	Line int64 `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"`
	// Column number in source code.
	Column int64 `protobuf:"varint,3,opt,name=column,proto3" json:"column,omitempty"`
}

Details a specific line in a source code, linked to a function.

func (*Line) Descriptor 

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

func (*Line) GetColumn 

func (m *Line) GetColumn() int64

func (*Line) GetFunctionIndex 

func (m *Line) GetFunctionIndex() int32

func (*Line) GetLine 

func (m *Line) GetLine() int64

func (*Line) Marshal 

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

func (*Line) MarshalTo 

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

func (*Line) MarshalToSizedBuffer 

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

func (*Line) ProtoMessage 

func (*Line) ProtoMessage()

func (*Line) Reset 

func (m *Line) Reset()

func (*Line) Size 

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

func (*Line) String 

func (m *Line) String() string

func (*Line) Unmarshal 

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

func (*Line) XXX_DiscardUnknown 

func (m *Line) XXX_DiscardUnknown()

func (*Line) XXX_Marshal 

func (m *Line) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Line) XXX_Merge 

func (m *Line) XXX_Merge(src proto.Message)

func (*Line) XXX_Size 

func (m *Line) XXX_Size() int

func (*Line) XXX_Unmarshal 

func (m *Line) XXX_Unmarshal(b []byte) error
type Link struct {
	// A unique identifier of a trace that this linked span is part of. The ID is a
	// 16-byte array.
	TraceId go_opentelemetry_io_collector_pdata_internal_data.TraceID `` /* 141-byte string literal not displayed */
	// A unique identifier for the linked span. The ID is an 8-byte array.
	SpanId go_opentelemetry_io_collector_pdata_internal_data.SpanID `` /* 137-byte string literal not displayed */
}

A pointer from a profile Sample to a trace Span. Connects a profile sample to a trace span, identified by unique trace and span IDs.

func (*Link) Descriptor 

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

func (*Link) Marshal 

func (m *Link) Marshal() (dAtA []byte, err error)

func (*Link) MarshalTo 

func (m *Link) MarshalTo(dAtA []byte) (int, error)

func (*Link) MarshalToSizedBuffer 

func (m *Link) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) Reset 

func (m *Link) Reset()

func (*Link) Size 

func (m *Link) Size() (n int)

func (*Link) String 

func (m *Link) String() string

func (*Link) Unmarshal 

func (m *Link) Unmarshal(dAtA []byte) error

func (*Link) XXX_DiscardUnknown 

func (m *Link) XXX_DiscardUnknown()

func (*Link) XXX_Marshal 

func (m *Link) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Link) XXX_Merge 

func (m *Link) XXX_Merge(src proto.Message)

func (*Link) XXX_Size 

func (m *Link) XXX_Size() int

func (*Link) XXX_Unmarshal 

func (m *Link) XXX_Unmarshal(b []byte) error

type Location 

type Location struct {
	// Reference to mapping in Profile.mapping_table.
	// It can be unset if the mapping is unknown or not applicable for
	// this profile type.
	//
	// Types that are valid to be assigned to MappingIndex_:
	//	*Location_MappingIndex
	MappingIndex_ isLocation_MappingIndex_ `protobuf_oneof:"mapping_index_"`
	// 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,2,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,3,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,4,opt,name=is_folded,json=isFolded,proto3" json:"is_folded,omitempty"`
	// References to attributes in Profile.attribute_table. [optional]
	AttributeIndices []int32 `protobuf:"varint,5,rep,packed,name=attribute_indices,json=attributeIndices,proto3" json:"attribute_indices,omitempty"`
}

Describes function and line table debug information.

func (*Location) Descriptor 

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

func (*Location) GetAddress 

func (m *Location) GetAddress() uint64

func (*Location) GetAttributeIndices 

func (m *Location) GetAttributeIndices() []int32

func (*Location) GetIsFolded 

func (m *Location) GetIsFolded() bool

func (*Location) GetLine 

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

func (*Location) GetMappingIndex 

func (m *Location) GetMappingIndex() int32

func (*Location) GetMappingIndex_ 

func (m *Location) GetMappingIndex_() isLocation_MappingIndex_

func (*Location) Marshal 

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

func (*Location) MarshalTo 

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

func (*Location) MarshalToSizedBuffer 

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

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) Size 

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

func (*Location) String 

func (m *Location) String() string

func (*Location) Unmarshal 

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

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_OneofWrappers 

func (*Location) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

type Location_MappingIndex 

type Location_MappingIndex struct {
	MappingIndex int32 `protobuf:"varint,1,opt,name=mapping_index,json=mappingIndex,proto3,oneof" json:"mapping_index,omitempty"`
}

func (*Location_MappingIndex) MarshalTo 

func (m *Location_MappingIndex) MarshalTo(dAtA []byte) (int, error)

func (*Location_MappingIndex) MarshalToSizedBuffer 

func (m *Location_MappingIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Location_MappingIndex) Size 

func (m *Location_MappingIndex) Size() (n int)

type Mapping 

type Mapping struct {
	// Address at which the binary (or DLL) is loaded into memory.
	MemoryStart uint64 `protobuf:"varint,1,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,2,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,3,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]".
	FilenameStrindex int32 `protobuf:"varint,4,opt,name=filename_strindex,json=filenameStrindex,proto3" json:"filename_strindex,omitempty"`
	// References to attributes in Profile.attribute_table. [optional]
	AttributeIndices []int32 `protobuf:"varint,5,rep,packed,name=attribute_indices,json=attributeIndices,proto3" json:"attribute_indices,omitempty"`
	// The following fields indicate the resolution of symbolic info.
	HasFunctions    bool `protobuf:"varint,6,opt,name=has_functions,json=hasFunctions,proto3" json:"has_functions,omitempty"`
	HasFilenames    bool `protobuf:"varint,7,opt,name=has_filenames,json=hasFilenames,proto3" json:"has_filenames,omitempty"`
	HasLineNumbers  bool `protobuf:"varint,8,opt,name=has_line_numbers,json=hasLineNumbers,proto3" json:"has_line_numbers,omitempty"`
	HasInlineFrames bool `protobuf:"varint,9,opt,name=has_inline_frames,json=hasInlineFrames,proto3" json:"has_inline_frames,omitempty"`
}

Describes the mapping of a binary in memory, including its address range, file offset, and metadata like build ID

func (*Mapping) Descriptor 

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

func (*Mapping) GetAttributeIndices 

func (m *Mapping) GetAttributeIndices() []int32

func (*Mapping) GetFileOffset 

func (m *Mapping) GetFileOffset() uint64

func (*Mapping) GetFilenameStrindex 

func (m *Mapping) GetFilenameStrindex() int32

func (*Mapping) GetHasFilenames 

func (m *Mapping) GetHasFilenames() bool

func (*Mapping) GetHasFunctions 

func (m *Mapping) GetHasFunctions() bool

func (*Mapping) GetHasInlineFrames 

func (m *Mapping) GetHasInlineFrames() bool

func (*Mapping) GetHasLineNumbers 

func (m *Mapping) GetHasLineNumbers() bool

func (*Mapping) GetMemoryLimit 

func (m *Mapping) GetMemoryLimit() uint64

func (*Mapping) GetMemoryStart 

func (m *Mapping) GetMemoryStart() uint64

func (*Mapping) Marshal 

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

func (*Mapping) MarshalTo 

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

func (*Mapping) MarshalToSizedBuffer 

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

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) Reset 

func (m *Mapping) Reset()

func (*Mapping) Size 

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

func (*Mapping) String 

func (m *Mapping) String() string

func (*Mapping) Unmarshal 

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

func (*Mapping) XXX_DiscardUnknown 

func (m *Mapping) XXX_DiscardUnknown()

func (*Mapping) XXX_Marshal 

func (m *Mapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mapping) XXX_Merge 

func (m *Mapping) XXX_Merge(src proto.Message)

func (*Mapping) XXX_Size 

func (m *Mapping) XXX_Size() int

func (*Mapping) XXX_Unmarshal 

func (m *Mapping) XXX_Unmarshal(b []byte) error

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.
	// If multiple binaries contribute to the Profile and no main
	// binary can be identified, mapping[0] has no special meaning.
	MappingTable []*Mapping `protobuf:"bytes,3,rep,name=mapping_table,json=mappingTable,proto3" json:"mapping_table,omitempty"`
	// Locations referenced by samples via location_indices.
	LocationTable []*Location `protobuf:"bytes,4,rep,name=location_table,json=locationTable,proto3" json:"location_table,omitempty"`
	// Array of locations referenced by samples.
	LocationIndices []int32 `protobuf:"varint,5,rep,packed,name=location_indices,json=locationIndices,proto3" json:"location_indices,omitempty"`
	// Functions referenced by locations.
	FunctionTable []*Function `protobuf:"bytes,6,rep,name=function_table,json=functionTable,proto3" json:"function_table,omitempty"`
	// Lookup table for attributes.
	AttributeTable []v11.KeyValue `protobuf:"bytes,7,rep,name=attribute_table,json=attributeTable,proto3" json:"attribute_table"`
	// Represents a mapping between Attribute Keys and Units.
	AttributeUnits []*AttributeUnit `protobuf:"bytes,8,rep,name=attribute_units,json=attributeUnits,proto3" json:"attribute_units,omitempty"`
	// Lookup table for links.
	LinkTable []*Link `protobuf:"bytes,9,rep,name=link_table,json=linkTable,proto3" json:"link_table,omitempty"`
	// A common table for strings referenced by various messages.
	// string_table[0] must always be "".
	StringTable []string `protobuf:"bytes,10,rep,name=string_table,json=stringTable,proto3" json:"string_table,omitempty"`
	// Time of collection (UTC) represented as nanoseconds past the epoch.
	TimeNanos int64 `protobuf:"varint,11,opt,name=time_nanos,json=timeNanos,proto3" json:"time_nanos,omitempty"`
	// Duration of the profile, if a duration makes sense.
	DurationNanos int64 `protobuf:"varint,12,opt,name=duration_nanos,json=durationNanos,proto3" json:"duration_nanos,omitempty"`
	// The kind of events between sampled occurrences.
	// e.g [ "cpu","cycles" ] or [ "heap","bytes" ]
	PeriodType ValueType `protobuf:"bytes,13,opt,name=period_type,json=periodType,proto3" json:"period_type"`
	// The number of events between sampled occurrences.
	Period int64 `protobuf:"varint,14,opt,name=period,proto3" json:"period,omitempty"`
	// Free-form text associated with the profile. The text is displayed as is
	// to the user by the tools that read profiles (e.g. by pprof). This field
	// should not be used to store any machine-readable information, it is only
	// for human-friendly content. The profile must stay functional if this field
	// is cleaned.
	CommentStrindices []int32 `protobuf:"varint,15,rep,packed,name=comment_strindices,json=commentStrindices,proto3" json:"comment_strindices,omitempty"`
	// Index into the string table of the type of the preferred sample
	// value. If unset, clients should default to the last sample value.
	DefaultSampleTypeStrindex int32 `` /* 142-byte string literal not displayed */
	// A globally unique identifier for a profile. The ID is a 16-byte array. An ID with
	// all zeroes is considered invalid.
	//
	// This field is required.
	ProfileId go_opentelemetry_io_collector_pdata_internal_data.ProfileID `` /* 150-byte string literal not displayed */
	// attributes is a collection of key/value pairs. Note, global attributes
	// like server name can be set using the resource API. Examples of attributes:
	//
	//     "/http/user_agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36"
	//     "/http/server_latency": 300
	//     "abc.com/myattribute": true
	//     "abc.com/score": 10.239
	//
	// The OpenTelemetry API specification further restricts the allowed value types:
	// https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/common/README.md#attribute
	// Attribute keys MUST be unique (it is not allowed to have more than one
	// attribute with the same key).
	Attributes []v11.KeyValue `protobuf:"bytes,18,rep,name=attributes,proto3" json:"attributes"`
	// dropped_attributes_count is the number of attributes that were discarded. Attributes
	// can be discarded because their keys are too long or because there are too many
	// attributes. If this value is 0, then no attributes were dropped.
	DroppedAttributesCount uint32 `` /* 131-byte string literal not displayed */
	// Specifies format of the original payload. Common values are defined in semantic conventions. [required if original_payload is present]
	OriginalPayloadFormat string `` /* 127-byte string literal not displayed */
	// Original payload can be stored in this field. This can be useful for users who want to get the original payload.
	// Formats such as JFR are highly extensible and can contain more information than what is defined in this spec.
	// Inclusion of original payload should be configurable by the user. Default behavior should be to not include the original payload.
	// If the original payload is in pprof format, it SHOULD not be included in this field.
	// The field is optional, however if it is present then equivalent converted data should be populated in other fields
	// of this message as far as is practicable.
	OriginalPayload []byte `protobuf:"bytes,21,opt,name=original_payload,json=originalPayload,proto3" json:"original_payload,omitempty"`
}

Represents a complete profile, including sample types, samples, mappings to binaries, locations, functions, string table, and additional metadata. It modifies and annotates pprof Profile with OpenTelemetry specific fields.

Note that whilst fields in this message retain the name and field id from pprof in most cases for ease of understanding data migration, it is not intended that pprof:Profile and OpenTelemetry:Profile encoding be wire compatible.

func (*Profile) Descriptor 

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

func (*Profile) GetAttributeTable 

func (m *Profile) GetAttributeTable() []v11.KeyValue

func (*Profile) GetAttributeUnits 

func (m *Profile) GetAttributeUnits() []*AttributeUnit

func (*Profile) GetAttributes 

func (m *Profile) GetAttributes() []v11.KeyValue

func (*Profile) GetCommentStrindices 

func (m *Profile) GetCommentStrindices() []int32

func (*Profile) GetDefaultSampleTypeStrindex 

func (m *Profile) GetDefaultSampleTypeStrindex() int32

func (*Profile) GetDroppedAttributesCount 

func (m *Profile) GetDroppedAttributesCount() uint32

func (*Profile) GetDurationNanos 

func (m *Profile) GetDurationNanos() int64

func (*Profile) GetFunctionTable 

func (m *Profile) GetFunctionTable() []*Function

func (*Profile) GetLinkTable 

func (m *Profile) GetLinkTable() []*Link

func (*Profile) GetLocationIndices 

func (m *Profile) GetLocationIndices() []int32

func (*Profile) GetLocationTable 

func (m *Profile) GetLocationTable() []*Location

func (*Profile) GetMappingTable 

func (m *Profile) GetMappingTable() []*Mapping

func (*Profile) GetOriginalPayload 

func (m *Profile) GetOriginalPayload() []byte

func (*Profile) GetOriginalPayloadFormat 

func (m *Profile) GetOriginalPayloadFormat() string

func (*Profile) GetPeriod 

func (m *Profile) GetPeriod() int64

func (*Profile) GetPeriodType 

func (m *Profile) GetPeriodType() ValueType

func (*Profile) GetSample 

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

func (*Profile) GetSampleType 

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

func (*Profile) GetStringTable 

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

func (*Profile) GetTimeNanos 

func (m *Profile) GetTimeNanos() int64

func (*Profile) Marshal 

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

func (*Profile) MarshalTo 

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

func (*Profile) MarshalToSizedBuffer 

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

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) Reset 

func (m *Profile) Reset()

func (*Profile) Size 

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

func (*Profile) String 

func (m *Profile) String() string

func (*Profile) Unmarshal 

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

func (*Profile) XXX_DiscardUnknown 

func (m *Profile) XXX_DiscardUnknown()

func (*Profile) XXX_Marshal 

func (m *Profile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Profile) XXX_Merge 

func (m *Profile) XXX_Merge(src proto.Message)

func (*Profile) XXX_Size 

func (m *Profile) XXX_Size() int

func (*Profile) XXX_Unmarshal 

func (m *Profile) XXX_Unmarshal(b []byte) error

type ProfilesData 

type ProfilesData struct {
	// An array of ResourceProfiles.
	// For data coming from a single resource this array will typically contain
	// one element. Intermediary nodes that receive data from multiple origins
	// typically batch the data before forwarding further and in that case this
	// array will contain multiple elements.
	ResourceProfiles []*ResourceProfiles `protobuf:"bytes,1,rep,name=resource_profiles,json=resourceProfiles,proto3" json:"resource_profiles,omitempty"`
}

ProfilesData represents the profiles data that can be stored in persistent storage, OR can be embedded by other protocols that transfer OTLP profiles data but do not implement the OTLP protocol.

The main difference between this message and collector protocol is that in this message there will not be any "control" or "metadata" specific to OTLP protocol.

When new fields are added into this message, the OTLP request MUST be updated as well.

func (*ProfilesData) Descriptor 

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

func (*ProfilesData) GetResourceProfiles 

func (m *ProfilesData) GetResourceProfiles() []*ResourceProfiles

func (*ProfilesData) Marshal 

func (m *ProfilesData) Marshal() (dAtA []byte, err error)

func (*ProfilesData) MarshalTo 

func (m *ProfilesData) MarshalTo(dAtA []byte) (int, error)

func (*ProfilesData) MarshalToSizedBuffer 

func (m *ProfilesData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProfilesData) ProtoMessage 

func (*ProfilesData) ProtoMessage()

func (*ProfilesData) Reset 

func (m *ProfilesData) Reset()

func (*ProfilesData) Size 

func (m *ProfilesData) Size() (n int)

func (*ProfilesData) String 

func (m *ProfilesData) String() string

func (*ProfilesData) Unmarshal 

func (m *ProfilesData) Unmarshal(dAtA []byte) error

func (*ProfilesData) XXX_DiscardUnknown 

func (m *ProfilesData) XXX_DiscardUnknown()

func (*ProfilesData) XXX_Marshal 

func (m *ProfilesData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfilesData) XXX_Merge 

func (m *ProfilesData) XXX_Merge(src proto.Message)

func (*ProfilesData) XXX_Size 

func (m *ProfilesData) XXX_Size() int

func (*ProfilesData) XXX_Unmarshal 

func (m *ProfilesData) XXX_Unmarshal(b []byte) error

type ResourceProfiles 

type ResourceProfiles struct {
	// The resource for the profiles in this message.
	// If this field is not set then no resource info is known.
	Resource v1.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource"`
	// A list of ScopeProfiles that originate from a resource.
	ScopeProfiles []*ScopeProfiles `protobuf:"bytes,2,rep,name=scope_profiles,json=scopeProfiles,proto3" json:"scope_profiles,omitempty"`
	// The Schema URL, if known. This is the identifier of the Schema that the resource data
	// is recorded in. To learn more about Schema URL see
	// https://opentelemetry.io/docs/specs/otel/schemas/#schema-url
	// This schema_url applies to the data in the "resource" field. It does not apply
	// to the data in the "scope_profiles" field which have their own schema_url field.
	SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"`
}

A collection of ScopeProfiles from a Resource.

func (*ResourceProfiles) Descriptor 

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

func (*ResourceProfiles) GetResource 

func (m *ResourceProfiles) GetResource() v1.Resource

func (*ResourceProfiles) GetSchemaUrl 

func (m *ResourceProfiles) GetSchemaUrl() string

func (*ResourceProfiles) GetScopeProfiles 

func (m *ResourceProfiles) GetScopeProfiles() []*ScopeProfiles

func (*ResourceProfiles) Marshal 

func (m *ResourceProfiles) Marshal() (dAtA []byte, err error)

func (*ResourceProfiles) MarshalTo 

func (m *ResourceProfiles) MarshalTo(dAtA []byte) (int, error)

func (*ResourceProfiles) MarshalToSizedBuffer 

func (m *ResourceProfiles) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceProfiles) ProtoMessage 

func (*ResourceProfiles) ProtoMessage()

func (*ResourceProfiles) Reset 

func (m *ResourceProfiles) Reset()

func (*ResourceProfiles) Size 

func (m *ResourceProfiles) Size() (n int)

func (*ResourceProfiles) String 

func (m *ResourceProfiles) String() string

func (*ResourceProfiles) Unmarshal 

func (m *ResourceProfiles) Unmarshal(dAtA []byte) error

func (*ResourceProfiles) XXX_DiscardUnknown 

func (m *ResourceProfiles) XXX_DiscardUnknown()

func (*ResourceProfiles) XXX_Marshal 

func (m *ResourceProfiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceProfiles) XXX_Merge 

func (m *ResourceProfiles) XXX_Merge(src proto.Message)

func (*ResourceProfiles) XXX_Size 

func (m *ResourceProfiles) XXX_Size() int

func (*ResourceProfiles) XXX_Unmarshal 

func (m *ResourceProfiles) XXX_Unmarshal(b []byte) error

type Sample 

type Sample struct {
	// locations_start_index along with locations_length refers to to a slice of locations in Profile.location_indices.
	LocationsStartIndex int32 `protobuf:"varint,1,opt,name=locations_start_index,json=locationsStartIndex,proto3" json:"locations_start_index,omitempty"`
	// locations_length along with locations_start_index refers to a slice of locations in Profile.location_indices.
	// Supersedes location_index.
	LocationsLength int32 `protobuf:"varint,2,opt,name=locations_length,json=locationsLength,proto3" json:"locations_length,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,3,rep,packed,name=value,proto3" json:"value,omitempty"`
	// References to attributes in Profile.attribute_table. [optional]
	AttributeIndices []int32 `protobuf:"varint,4,rep,packed,name=attribute_indices,json=attributeIndices,proto3" json:"attribute_indices,omitempty"`
	// Reference to link in Profile.link_table. [optional]
	//
	// Types that are valid to be assigned to LinkIndex_:
	//	*Sample_LinkIndex
	LinkIndex_ isSample_LinkIndex_ `protobuf_oneof:"link_index_"`
	// Timestamps associated with Sample represented in nanoseconds. These timestamps are expected
	// to fall within the Profile's time range. [optional]
	TimestampsUnixNano []uint64 `protobuf:"varint,6,rep,packed,name=timestamps_unix_nano,json=timestampsUnixNano,proto3" json:"timestamps_unix_nano,omitempty"`
}

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 

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

func (*Sample) GetAttributeIndices 

func (m *Sample) GetAttributeIndices() []int32

func (*Sample) GetLinkIndex 

func (m *Sample) GetLinkIndex() int32

func (*Sample) GetLinkIndex_ 

func (m *Sample) GetLinkIndex_() isSample_LinkIndex_

func (*Sample) GetLocationsLength 

func (m *Sample) GetLocationsLength() int32

func (*Sample) GetLocationsStartIndex 

func (m *Sample) GetLocationsStartIndex() int32

func (*Sample) GetTimestampsUnixNano 

func (m *Sample) GetTimestampsUnixNano() []uint64

func (*Sample) GetValue 

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

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sample) XXX_Merge 

func (m *Sample) XXX_Merge(src proto.Message)

func (*Sample) XXX_OneofWrappers 

func (*Sample) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

func (m *Sample) XXX_Unmarshal(b []byte) error

type Sample_LinkIndex 

type Sample_LinkIndex struct {
	LinkIndex int32 `protobuf:"varint,5,opt,name=link_index,json=linkIndex,proto3,oneof" json:"link_index,omitempty"`
}

func (*Sample_LinkIndex) MarshalTo 

func (m *Sample_LinkIndex) MarshalTo(dAtA []byte) (int, error)

func (*Sample_LinkIndex) MarshalToSizedBuffer 

func (m *Sample_LinkIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sample_LinkIndex) Size 

func (m *Sample_LinkIndex) Size() (n int)

type ScopeProfiles 

type ScopeProfiles struct {
	// The instrumentation scope information for the profiles in this message.
	// Semantically when InstrumentationScope isn't set, it is equivalent with
	// an empty instrumentation scope name (unknown).
	Scope v11.InstrumentationScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope"`
	// A list of Profiles that originate from an instrumentation scope.
	Profiles []*Profile `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// The Schema URL, if known. This is the identifier of the Schema that the profile data
	// is recorded in. To learn more about Schema URL see
	// https://opentelemetry.io/docs/specs/otel/schemas/#schema-url
	// This schema_url applies to all profiles in the "profiles" field.
	SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"`
}

A collection of Profiles produced by an InstrumentationScope.

func (*ScopeProfiles) Descriptor 

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

func (*ScopeProfiles) GetProfiles 

func (m *ScopeProfiles) GetProfiles() []*Profile

func (*ScopeProfiles) GetSchemaUrl 

func (m *ScopeProfiles) GetSchemaUrl() string

func (*ScopeProfiles) GetScope 

func (m *ScopeProfiles) GetScope() v11.InstrumentationScope

func (*ScopeProfiles) Marshal 

func (m *ScopeProfiles) Marshal() (dAtA []byte, err error)

func (*ScopeProfiles) MarshalTo 

func (m *ScopeProfiles) MarshalTo(dAtA []byte) (int, error)

func (*ScopeProfiles) MarshalToSizedBuffer 

func (m *ScopeProfiles) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScopeProfiles) ProtoMessage 

func (*ScopeProfiles) ProtoMessage()

func (*ScopeProfiles) Reset 

func (m *ScopeProfiles) Reset()

func (*ScopeProfiles) Size 

func (m *ScopeProfiles) Size() (n int)

func (*ScopeProfiles) String 

func (m *ScopeProfiles) String() string

func (*ScopeProfiles) Unmarshal 

func (m *ScopeProfiles) Unmarshal(dAtA []byte) error

func (*ScopeProfiles) XXX_DiscardUnknown 

func (m *ScopeProfiles) XXX_DiscardUnknown()

func (*ScopeProfiles) XXX_Marshal 

func (m *ScopeProfiles) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScopeProfiles) XXX_Merge 

func (m *ScopeProfiles) XXX_Merge(src proto.Message)

func (*ScopeProfiles) XXX_Size 

func (m *ScopeProfiles) XXX_Size() int

func (*ScopeProfiles) XXX_Unmarshal 

func (m *ScopeProfiles) XXX_Unmarshal(b []byte) error

type ValueType 

type ValueType struct {
	TypeStrindex           int32                  `protobuf:"varint,1,opt,name=type_strindex,json=typeStrindex,proto3" json:"type_strindex,omitempty"`
	UnitStrindex           int32                  `protobuf:"varint,2,opt,name=unit_strindex,json=unitStrindex,proto3" json:"unit_strindex,omitempty"`
	AggregationTemporality AggregationTemporality `` /* 199-byte string literal not displayed */
}

ValueType describes the type and units of a value, with an optional aggregation temporality.

func (*ValueType) Descriptor 

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

func (*ValueType) GetAggregationTemporality 

func (m *ValueType) GetAggregationTemporality() AggregationTemporality

func (*ValueType) GetTypeStrindex 

func (m *ValueType) GetTypeStrindex() int32

func (*ValueType) GetUnitStrindex 

func (m *ValueType) GetUnitStrindex() int32

func (*ValueType) Marshal 

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

func (*ValueType) MarshalTo 

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

func (*ValueType) MarshalToSizedBuffer 

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

func (*ValueType) ProtoMessage 

func (*ValueType) ProtoMessage()

func (*ValueType) Reset 

func (m *ValueType) Reset()

func (*ValueType) Size 

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

func (*ValueType) String 

func (m *ValueType) String() string

func (*ValueType) Unmarshal 

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

func (*ValueType) XXX_DiscardUnknown 

func (m *ValueType) XXX_DiscardUnknown()

func (*ValueType) XXX_Marshal 

func (m *ValueType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueType) XXX_Merge 

func (m *ValueType) XXX_Merge(src proto.Message)

func (*ValueType) XXX_Size 

func (m *ValueType) XXX_Size() int

func (*ValueType) XXX_Unmarshal 

func (m *ValueType) XXX_Unmarshal(b []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.