trace

type HTTPLogEntry struct {
	Timestamp   time.Time
	Method      string
	Path        string
	StatusCode  int
	ServiceName string
	ClientIP    string
	Duration    time.Duration
}

type HealthState string

type IngestResult struct {
	Created int
	Updated int
}

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

type OTLPReceiver struct {
	coltracepb.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

type RouteMapping struct {
	ServiceName  string
	RoutePattern string
	NodeHash     types.Hash
	MappingType  string // "http_route", "grpc_method", "queue_topic"
}

type RuntimeStats struct {
	TotalEdges   int
	BySourceType map[string]int
	ActiveCount  int // edges with observations in last 7 days
	StaleCount   int // edges with no observations in last 30 days
	GCEligible   int // edges with no observations in last 90 days
}

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

type TraceIngestConfig struct {
	Enabled                 bool
	OTLPEndpoint            string
	BatchSize               int
	BatchInterval           time.Duration
	ConfidenceDecayInterval time.Duration
	GCThresholdDays         int
	ServiceMap              map[string]string // OTel name -> knowing repo name
}

type TraceIngestor interface {
	IngestSpans(ctx context.Context, spans []TraceSpan) (IngestResult, error)
	IngestHTTPLogs(ctx context.Context, entries []HTTPLogEntry) (IngestResult, error)
	RuntimeEdgeStats(ctx context.Context, snapshot types.Hash) (*RuntimeStats, error)
	DecayConfidence(ctx context.Context) (updated int, err error)
}

type TraceSpan struct {
	TraceID       string
	SpanID        string
	ParentSpanID  string
	ServiceName   string
	OperationName string
	PeerService   string
	Attributes    map[string]string
	StartTime     time.Time
	Duration      time.Duration
}