traces

Documentation

Index

• Constants
• func ConvertNanoSecondsIntoProperTimeUnit(value int) string
• func ConvertTimeFieldIntoNanoSeconds(value string) int
• func CreateTraceID(id []byte) trace.TraceID
• func DecodeTraceID(id string) trace.TraceID
• type Attributes
  • func (a Attributes) Get(key string) string
  • func (a Attributes) SetPointerValue(key string, value *string)
• type ConversionConfig
  • func NewConversionConfig() ConversionConfig
  • func (c ConversionConfig) AddTimeFields(fields ...string)
  • func (c ConversionConfig) IsTimeField(field string) bool
• type HttpResourceSpans
• type Span
  • func AugmentRootSpan(span Span, result trigger.TriggerResult) Span
  • func ConvertOtelSpanIntoSpan(span *v1.Span) *Span
  • func (s Span) IsZero() bool
  • func (s Span) MarshalJSON() ([]byte, error)
  • func (s *Span) UnmarshalJSON(data []byte) error
• type SpanEvent
• type SpanKind
• type SpanStatus
• type Spans
  • func (s Spans) ForEach(fn func(ix int, _ Span) bool) Spans
  • func (s Spans) OrEmpty(fn func()) Spans
• type Trace
  • func FromHttpOtelResourceSpans(resourceSpans []*HttpResourceSpans) Trace
  • func FromOtel(input *v1.TracesData) Trace
  • func FromOtelResourceSpans(resourceSpans []*v1.ResourceSpans) Trace
  • func FromSpanList(input []*v1.Span) Trace
  • func MergeTraces(traces ...*Trace) *Trace
  • func NewTrace(traceID string, spans []Span) Trace
  • func (t *Trace) HasRootSpan() bool
  • func (t *Trace) InsertRootSpan(newRoot Span) *Trace
  • func (t Trace) MarshalJSON() ([]byte, error)
  • func (t *Trace) Sort() Trace
  • func (t *Trace) Spans() []Span
  • func (t *Trace) UnmarshalJSON(data []byte) error
• type TraceRepository
  • func NewTraceRepository(db *sql.DB) *TraceRepository
  • func (r *TraceRepository) Get(ctx context.Context, id trace.TraceID) (Trace, error)
  • func (r *TraceRepository) UpdateTraceSpans(ctx context.Context, trace *Trace) error

Constants

const (
	TracetestMetadataFieldStartTime         string = "tracetest.span.start_time"
	TracetestMetadataFieldEndTime           string = "tracetest.span.end_time"
	TracetestMetadataFieldDuration          string = "tracetest.span.duration"
	TracetestMetadataFieldType              string = "tracetest.span.type"
	TracetestMetadataFieldName              string = "tracetest.span.name"
	TracetestMetadataFieldParentID          string = "tracetest.span.parent_id"
	TracetestMetadataFieldKind              string = "tracetest.span.kind"
	TracetestMetadataFieldStatusCode        string = "tracetest.span.status_code"
	TracetestMetadataFieldStatusDescription string = "tracetest.span.status_description"
)

const (
	NANOSECOND_SCALE  = 0
	MICROSECOND_SCALE = 1
	MILLISECOND_SCALE = 2
	SECOND_SCALE      = 3
	MINUTE_SCALE      = 4
	HOUR_SCALE        = 5
)

const TemporaryRootSpanName = "Temporary Tracetest root span"

const TriggerSpanName = "Tracetest trigger"

Functions

func ConvertNanoSecondsIntoProperTimeUnit

func ConvertNanoSecondsIntoProperTimeUnit(value int) string

func ConvertTimeFieldIntoNanoSeconds

func ConvertTimeFieldIntoNanoSeconds(value string) int

func CreateTraceID

func CreateTraceID(id []byte) trace.TraceID

func DecodeTraceID

func DecodeTraceID(id string) trace.TraceID

Types

type Attributes

type Attributes map[string]string

func (Attributes) Get

func (a Attributes) Get(key string) string

func (Attributes) SetPointerValue

func (a Attributes) SetPointerValue(key string, value *string)

type ConversionConfig

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

func NewConversionConfig

func NewConversionConfig() ConversionConfig

func (ConversionConfig) AddTimeFields

func (c ConversionConfig) AddTimeFields(fields ...string)

func (ConversionConfig) IsTimeField

func (c ConversionConfig) IsTimeField(field string) bool

type HttpResourceSpans

type HttpResourceSpans struct {
	v1.ResourceSpans
	ScopeSpans                  []*httpScopeSpans `json:"scopeSpans"`
	InstrumentationLibrarySpans []*httpScopeSpans `json:"instrumentationLibrarySpans"`
}

type Span

type Span struct {
	ID         trace.SpanID
	Name       string
	StartTime  time.Time
	EndTime    time.Time
	Attributes Attributes
	Kind       SpanKind
	Events     []SpanEvent
	Status     *SpanStatus

	Parent   *Span   `json:"-"`
	Children []*Span `json:"-"`
}

func AugmentRootSpan

func AugmentRootSpan(span Span, result trigger.TriggerResult) Span

func ConvertOtelSpanIntoSpan

func ConvertOtelSpanIntoSpan(span *v1.Span) *Span

func (Span) IsZero

func (s Span) IsZero() bool

func (Span) MarshalJSON

func (s Span) MarshalJSON() ([]byte, error)

func (*Span) UnmarshalJSON

func (s *Span) UnmarshalJSON(data []byte) error

type SpanEvent

type SpanEvent struct {
	Name       string     `json:"name"`
	Timestamp  time.Time  `json:"timestamp"`
	Attributes Attributes `json:"attributes"`
}

type SpanKind

type SpanKind string

var (
	SpanKindClient       SpanKind = "client"
	SpanKindServer       SpanKind = "server"
	SpanKindConsumer     SpanKind = "consumer"
	SpanKindProducer     SpanKind = "producer"
	SpanKindInternal     SpanKind = "internal"
	SpanKindUnespecified SpanKind = "unespecified"
)

type SpanStatus

type SpanStatus struct {
	Code        string
	Description string
}

type Spans

type Spans []Span

func (Spans) ForEach

func (s Spans) ForEach(fn func(ix int, _ Span) bool) Spans

func (Spans) OrEmpty

func (s Spans) OrEmpty(fn func()) Spans

type Trace

type Trace struct {
	ID       trace.TraceID
	RootSpan Span
	Flat     map[trace.SpanID]*Span `json:"-"`
}

func FromHttpOtelResourceSpans

func FromHttpOtelResourceSpans(resourceSpans []*HttpResourceSpans) Trace

func FromOtel

func FromOtel(input *v1.TracesData) Trace

func FromOtelResourceSpans

func FromOtelResourceSpans(resourceSpans []*v1.ResourceSpans) Trace

func FromSpanList

func FromSpanList(input []*v1.Span) Trace

func MergeTraces

func MergeTraces(traces ...*Trace) *Trace

func NewTrace

func NewTrace(traceID string, spans []Span) Trace

func (*Trace) HasRootSpan

func (t *Trace) HasRootSpan() bool

func (*Trace) InsertRootSpan

func (t *Trace) InsertRootSpan(newRoot Span) *Trace

func (Trace) MarshalJSON

func (t Trace) MarshalJSON() ([]byte, error)

func (*Trace) Sort

func (t *Trace) Sort() Trace

func (*Trace) Spans

func (t *Trace) Spans() []Span

func (*Trace) UnmarshalJSON

func (t *Trace) UnmarshalJSON(data []byte) error

type TraceRepository

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

func NewTraceRepository

func NewTraceRepository(db *sql.DB) *TraceRepository

func (*TraceRepository) Get

func (r *TraceRepository) Get(ctx context.Context, id trace.TraceID) (Trace, error)

func (*TraceRepository) UpdateTraceSpans

func (r *TraceRepository) UpdateTraceSpans(ctx context.Context, trace *Trace) error