traceimport

type CallStats ¶

type CallStats struct {
	Count       int
	Occurrences int
}

CallStats separates how often a call happens from how many times it happens.

Count is the number of parent invocations that made the call at least once — the probability numerator. Occurrences is the total number of call occurrences across those invocations, so the typical per-invocation repetition (the emitted count:) is round(Occurrences / Count). Keeping these apart prevents a call made several times within one invocation from being mistaken for a call made across several invocations.

type CallStyleVote ¶

type CallStyleVote struct {
	Parallel   int
	Sequential int
}

CallStyleVote tracks parallel vs sequential votes across traces.

type Format ¶

type Format string

Format identifies the input trace format.

const (
	FormatAuto        Format = "auto"         // Detects the format from the input.
	FormatStdouttrace Format = "stdouttrace"  // Line-delimited JSON from the OTel stdout exporter.
	FormatOTLP        Format = "otlp"         // OTLP protobuf JSON.
	FormatJaeger      Format = "jaeger"       // Jaeger JSON export format (also used by Grafana Tempo).
	FormatMetaSummary Format = "meta-summary" // Meta ATC 2023 parent-data.csv summary rows.
)

type OpStats ¶

type OpStats struct {
	DurationCount int
	DurationMean  float64
	DurationM2    float64
	ErrorCount    int
	TotalCount    int
	Calls         map[string]*CallStats // key: "targetService.targetOp"
}

OpStats accumulates statistics for a single (service, operation) pair.

func (o *OpStats) RecordDuration(d time.Duration, weight int)

type Options ¶

type Options struct {
	Format           Format
	MinTraces        int
	Warnings         io.Writer // defaults to os.Stderr
	MetaProfile      string
	MetaIncludeEmpty bool
	// RecordTo, when non-nil, receives a newline-delimited replay recording of
	// the source traces alongside the inferred topology. Not supported for
	// Meta summary imports, which carry no per-trace span data.
	RecordTo io.Writer
}

Options controls import behaviour.

type Result ¶ added in v0.9.2

type Result struct {
	// YAML is the inferred synth topology.
	YAML []byte
	// TraceCount is the number of source traces. For Meta summary imports it is
	// the total weighted parent-sample count rather than a literal trace count.
	TraceCount int
	// SpanCount is the number of source spans. For Meta summary imports it is an
	// estimate derived from the weighted call counts rather than a literal span
	// count.
	SpanCount int
}

Result contains the inferred topology and source counts from an import.

For span-based imports (OTLP, stdouttrace, auto) the counts are literal. For Meta summary imports they are weighted estimates rather than observed values; see the field comments.

func Import(r io.Reader, opts Options) (Result, error)

type ServiceStats ¶

type ServiceStats struct {
	Ops        map[string]*OpStats       // operation name -> stats
	CallStyles map[string]*CallStyleVote // operation name -> voting
}

ServiceStats holds per-operation stats and call style votes for one service.

type Span ¶

type Span struct {
	TraceID    string
	SpanID     string
	ParentID   string // empty for root spans
	Service    string
	Operation  string
	StartTime  time.Time
	EndTime    time.Time
	IsError    bool
	Attributes map[string]string
}

Span is the format-independent representation of a trace span.

func ParseSpans(r io.Reader, format Format) ([]Span, error)

type SpanNode ¶

type SpanNode struct {
	Span     Span
	Children []*SpanNode
}

SpanNode wraps a Span with its children in the trace tree.

type StatsCollector ¶

type StatsCollector struct {
	Services map[string]*ServiceStats // service name -> stats
}

StatsCollector accumulates statistics across all traces.

func NewStatsCollector() *StatsCollector

func (c *StatsCollector) CollectFromTrees(trees []*TraceTree)

type TraceTree ¶

type TraceTree struct {
	TraceID  string
	Roots    []*SpanNode
	AllNodes []*SpanNode
}

TraceTree holds spans grouped by trace with parent-child links.

func BuildTrees(spans []Span, w io.Writer) []*TraceTree