traces

package
v0.0.0-...-b4d2799 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package traces provides utilities for managing and manipulating trace in Arrow format.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventBuilder 

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

func NewEventBuilder 

func NewEventBuilder(allocator memory.Allocator, ab *attributes.AttributeBuilder) *EventBuilder

func (*EventBuilder) Append 

func (b *EventBuilder) Append(event ptrace.SpanEvent) uint32

func (*EventBuilder) AppendAttributes 

func (b *EventBuilder) AppendAttributes(attributes pcommon.Map)

func (*EventBuilder) Build 

func (b *EventBuilder) Build() arrow.RecordBatch

func (*EventBuilder) Release 

func (b *EventBuilder) Release()

func (*EventBuilder) Schema 

func (b *EventBuilder) Schema() *arrow.Schema

type EventReader 

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

func NewEventReader 

func NewEventReader(events arrow.RecordBatch, attributes *attributes.Reader) *EventReader

func (*EventReader) Attributes 

func (r *EventReader) Attributes(row int, fn func(key, val string))

func (*EventReader) DroppedAttributesCount 

func (r *EventReader) DroppedAttributesCount(row int) uint16

func (*EventReader) Name 

func (r *EventReader) Name(row int) string

func (*EventReader) NumOfRows 

func (r *EventReader) NumOfRows() int

func (*EventReader) Reset 

func (r *EventReader) Reset(record arrow.RecordBatch)

func (*EventReader) Timestamp 

func (r *EventReader) Timestamp(row int) int64

type LinkBuilder 

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

func NewLinkBuilder 

func NewLinkBuilder(allocator memory.Allocator, ab *attributes.AttributeBuilder) *LinkBuilder

func (*LinkBuilder) Append 

func (b *LinkBuilder) Append(link ptrace.SpanLink) uint32

func (*LinkBuilder) AppendAttributes 

func (b *LinkBuilder) AppendAttributes(attributes pcommon.Map)

func (*LinkBuilder) Build 

func (b *LinkBuilder) Build() arrow.RecordBatch

func (*LinkBuilder) Release 

func (b *LinkBuilder) Release()

func (*LinkBuilder) Schema 

func (b *LinkBuilder) Schema() *arrow.Schema

type LinkReader 

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

func NewLinkReader 

func NewLinkReader(links arrow.RecordBatch, attributes *attributes.Reader) *LinkReader

func (*LinkReader) Attributes 

func (r *LinkReader) Attributes(row int, fn func(key, val string))

func (*LinkReader) DroppedAttributesCount 

func (r *LinkReader) DroppedAttributesCount(row int) uint16

func (*LinkReader) Flags 

func (r *LinkReader) Flags(row int) uint32

func (*LinkReader) Reset 

func (r *LinkReader) Reset(links arrow.RecordBatch)

func (*LinkReader) SpanID 

func (r *LinkReader) SpanID(row int) []byte

func (*LinkReader) TraceID 

func (r *LinkReader) TraceID(row int) []byte

func (*LinkReader) TraceState 

func (r *LinkReader) TraceState(row int) string

type ResourceBuilder 

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

func ResourceBuilderNew 

func ResourceBuilderNew(allocator memory.Allocator, ab *attributes.AttributeBuilder) *ResourceBuilder

func (*ResourceBuilder) Append 

func (b *ResourceBuilder) Append(resourceScope ptrace.ResourceSpans) uint16

func (*ResourceBuilder) AppendAttributes 

func (b *ResourceBuilder) AppendAttributes(attributes pcommon.Map)

func (*ResourceBuilder) Build 

func (b *ResourceBuilder) Build() arrow.RecordBatch

func (*ResourceBuilder) Release 

func (b *ResourceBuilder) Release()

func (*ResourceBuilder) Schema 

func (b *ResourceBuilder) Schema() *arrow.Schema

type ResourceReader 

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

func NewResourceReader 

func NewResourceReader(resources arrow.RecordBatch, attributes *attributes.Reader) *ResourceReader

func (*ResourceReader) Attributes 

func (r *ResourceReader) Attributes(row int, fn func(key, val string))

func (*ResourceReader) DroppedAttributesCount 

func (r *ResourceReader) DroppedAttributesCount(row int) uint16

func (*ResourceReader) Reset 

func (r *ResourceReader) Reset(resources arrow.RecordBatch)

func (*ResourceReader) SchemaURL 

func (r *ResourceReader) SchemaURL(row int) string

type ScopeBuilder 

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

func NewScopeBuilder 

func NewScopeBuilder(allocator memory.Allocator, ab *attributes.AttributeBuilder) *ScopeBuilder

func (*ScopeBuilder) Append 

func (b *ScopeBuilder) Append(scopeSpans ptrace.ScopeSpans) uint16

Append appends a ScopeSpans to the builder and returns the primary key for the appended record.

func (*ScopeBuilder) AppendAttributes 

func (b *ScopeBuilder) AppendAttributes(attributes pcommon.Map)

func (*ScopeBuilder) Build 

func (b *ScopeBuilder) Build() arrow.RecordBatch

func (*ScopeBuilder) Release 

func (b *ScopeBuilder) Release()

func (*ScopeBuilder) Schema 

func (b *ScopeBuilder) Schema() *arrow.Schema

type ScopeReader 

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

func NewScopeReader 

func NewScopeReader(scopes arrow.RecordBatch, attributes *attributes.Reader) *ScopeReader

func (*ScopeReader) Attributes 

func (r *ScopeReader) Attributes(row int, fn func(key, val string))

func (*ScopeReader) DroppedAttributesCount 

func (r *ScopeReader) DroppedAttributesCount(row int) uint16

func (*ScopeReader) Name 

func (r *ScopeReader) Name(row int) string

func (*ScopeReader) Reset 

func (r *ScopeReader) Reset(scopes arrow.RecordBatch)

func (*ScopeReader) SchemaURL 

func (r *ScopeReader) SchemaURL(row int) string

func (*ScopeReader) Version 

func (r *ScopeReader) Version(row int) string

type SpanBuilder 

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

func NewSpanBuilder 

func NewSpanBuilder(allocator memory.Allocator) *SpanBuilder

func (*SpanBuilder) Append 

func (b *SpanBuilder) Append(span *model.Span)

func (*SpanBuilder) AppendAttributes 

func (b *SpanBuilder) AppendAttributes(attributes pcommon.Map)

func (*SpanBuilder) Build 

func (b *SpanBuilder) Build() []arrow.RecordBatch

func (*SpanBuilder) Bytes 

func (b *SpanBuilder) Bytes() ([]byte, error)

func (*SpanBuilder) NumOfRows 

func (b *SpanBuilder) NumOfRows() int

func (*SpanBuilder) Release 

func (b *SpanBuilder) Release() error

func (*SpanBuilder) Schemas 

func (b *SpanBuilder) Schemas() []*arrow.Schema

type TraceIDReader 

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

TraceIDReader provides efficient access to trace IDs from the spans record batch without fully initializing the TraceReader. It is optimized for scenarios where only trace IDs are needed, such as indexing or filtering, and avoids the overhead of initializing all span fields and related record batches.

func NewTraceIDReader 

func NewTraceIDReader(data []byte) (*TraceIDReader, error)

func (*TraceIDReader) NumOfRows 

func (tr *TraceIDReader) NumOfRows() int

func (*TraceIDReader) Release 

func (tr *TraceIDReader) Release()

func (*TraceIDReader) Reset 

func (tr *TraceIDReader) Reset(data []byte) error

func (*TraceIDReader) TraceID 

func (tr *TraceIDReader) TraceID(row int) []byte

type TraceReader 

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

func NewTraceReader 

func NewTraceReader(data []byte) (*TraceReader, error)

func (*TraceReader) Attributes 

func (tr *TraceReader) Attributes(row int, fn func(k, v string))

func (*TraceReader) DroppedAttributesCount 

func (tr *TraceReader) DroppedAttributesCount(row int) uint16

func (*TraceReader) DroppedEventsCount 

func (tr *TraceReader) DroppedEventsCount(row int) uint16

func (*TraceReader) DroppedLinksCount 

func (tr *TraceReader) DroppedLinksCount(row int) uint16

func (*TraceReader) EndTime 

func (tr *TraceReader) EndTime(row int) int64

func (*TraceReader) Events 

func (tr *TraceReader) Events(row int, fn func(reader *EventReader, rowOfEvent int))

func (*TraceReader) Kind 

func (tr *TraceReader) Kind(row int) string
func (tr *TraceReader) Links(row int, fn func(reader *LinkReader, rowOfLink int))

func (*TraceReader) Name 

func (tr *TraceReader) Name(row int) string

func (*TraceReader) NumOfRows 

func (tr *TraceReader) NumOfRows() int

func (*TraceReader) ParentSpanID 

func (tr *TraceReader) ParentSpanID(row int) []byte

func (*TraceReader) Release 

func (tr *TraceReader) Release()

func (*TraceReader) Reset 

func (tr *TraceReader) Reset(data []byte) error

func (*TraceReader) Resource 

func (tr *TraceReader) Resource(row int, fn func(reader *ResourceReader, rowOfResource int))

func (*TraceReader) Scope 

func (tr *TraceReader) Scope(row int, fn func(reader *ScopeReader, rowOfScope int))

func (*TraceReader) SpanID 

func (tr *TraceReader) SpanID(row int) []byte

func (*TraceReader) StartTime 

func (tr *TraceReader) StartTime(row int) int64

func (*TraceReader) Status 

func (tr *TraceReader) Status(row int) string

func (*TraceReader) StatusMessage 

func (tr *TraceReader) StatusMessage(row int) string

func (*TraceReader) TraceID 

func (tr *TraceReader) TraceID(row int) []byte

Source Files

View all Source files

Directories

Path Synopsis
Package v1 provides the Arrow schema definition for version 1 of the attributes data structure.
 Package v1 provides the Arrow schema definition for version 1 of the attributes data structure.

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.