Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

graphrag

package

Go to main page

Versions in this module

v0

v0.4.0-beta.1

Jun 19, 2026

v0.3.1

Jun 18, 2026

Changes in this version

type GraphRAG

+ func (g *GraphRAG) ObserveSpanTopology(tenant, traceID, spanID, parentSpanID, service string)

type ServiceStore

+ func (s *ServiceStore) EnsureCallEdge(source, target string, ts time.Time) bool

+ func (s *ServiceStore) EnsureService(name string, ts time.Time) bool

v0.3.1-beta.1

Jun 18, 2026

v0.3.0

Jun 17, 2026

Changes in this version

+ const Wildcard

+ func AutoMigrateGraphRAG(db *gorm.DB) error

+ func Preprocess(line string) string

+ func SaveDrainTemplates(db *gorm.DB, tenant string, templates []Template) error

+ func SetPanicMetrics(m *telemetry.Metrics)

+ type AffectedEntry struct

+ CallCount int64

+ Depth int

+ ImpactScore float64

+ Service string

+ type AnomalyNode struct

+ Evidence string

+ ID string

+ Service string

+ Severity AnomalySeverity

+ Timestamp time.Time

+ Type AnomalyType

+ type AnomalySeverity string

+ const SeverityCritical

+ const SeverityInfo

+ const SeverityWarning

+ type AnomalyStore struct

+ Anomalies map[string]*AnomalyNode

+ Edges map[string]*Edge

+ func (as *AnomalyStore) AddAnomaly(anomaly AnomalyNode)

+ func (as *AnomalyStore) AddPrecededByEdge(anomalyID, precedingID string, ts time.Time)

+ func (as *AnomalyStore) AnomaliesForService(service string, since time.Time) []*AnomalyNode

+ func (as *AnomalyStore) AnomaliesSince(since time.Time) []*AnomalyNode

+ func (as *AnomalyStore) AnomaliesSinceLimit(since time.Time, n int) []*AnomalyNode

+ type AnomalyType string

+ const AnomalyErrorSpike

+ const AnomalyLatencySpike

+ const AnomalyMetricZScore

+ type Config struct

+ AnomalyEvery time.Duration

+ ChannelSize int

+ MaxSpansPerTenant int

+ RefreshEvery time.Duration

+ SnapshotEvery time.Duration

+ TenantIdleTTL time.Duration

+ TraceTTL time.Duration

+ WorkerCount int

+ func DefaultConfig() Config

+ type CorrelatedSignalsResult struct

+ Anomalies []AnomalyNode

+ ErrorChains []ErrorChainResult

+ ErrorLogs []LogClusterNode

+ Metrics []MetricNode

+ Service string

+ type Drain struct

+ func NewDrain(opts ...DrainOption) *Drain

+ func (d *Drain) Len() int

+ func (d *Drain) LoadTemplates(tpls []Template)

+ func (d *Drain) Match(logLine string, ts time.Time) *Template

+ func (d *Drain) TemplateCount() int

+ func (d *Drain) Templates() []Template

+ type DrainOption func(*Drain)

+ func WithDepth(depth int) DrainOption

+ func WithMaxChildren(n int) DrainOption

+ func WithMaxTemplates(n int) DrainOption

+ func WithSimilarityThreshold(st float64) DrainOption

+ type DrainTemplateRow struct

+ Count int

+ FirstSeen time.Time

+ ID int64

+ LastSeen time.Time

+ Sample string

+ TenantID string

+ Tokens string

+ func (DrainTemplateRow) TableName() string

+ type Edge struct

+ AvgMs float64

+ CallCount int64

+ ErrorCount int64

+ ErrorRate float64

+ FromID string

+ ToID string

+ TotalMs float64

+ Type EdgeType

+ UpdatedAt time.Time

+ Weight float64

+ type EdgeType string

+ const EdgeCalls

+ const EdgeChildOf

+ const EdgeContains

+ const EdgeEmittedBy

+ const EdgeExposes

+ const EdgeLoggedDuring

+ const EdgeMeasuredBy

+ const EdgePrecededBy

+ const EdgeTriggeredBy

+ type ErrorChainResult struct

+ AnomalousMetrics []MetricNode

+ CorrelatedLogs []LogClusterNode

+ RootCause *RootCauseInfo

+ SpanChain []SpanNode

+ TraceID string

+ type GraphRAG struct

+ func New(repo *storage.Repository, tsdbAgg *tsdb.Aggregator, ringBuf *tsdb.RingBuffer, ...) *GraphRAG

+ func (g *GraphRAG) AllServiceEdges(ctx context.Context) []*Edge

+ func (g *GraphRAG) AnomaliesForService(ctx context.Context, service string, since time.Time) []*AnomalyNode

+ func (g *GraphRAG) AnomalyTimeline(ctx context.Context, since time.Time) []*AnomalyNode

+ func (g *GraphRAG) CorrelatedSignals(ctx context.Context, service string, since time.Time) *CorrelatedSignalsResult

+ func (g *GraphRAG) DependencyChain(ctx context.Context, traceID string) []SpanNode

+ func (g *GraphRAG) DrainTemplateCount() int

+ func (g *GraphRAG) DroppedLogsCount() int64

+ func (g *GraphRAG) DroppedMetricsCount() int64

+ func (g *GraphRAG) DroppedSpansCount() int64

+ func (g *GraphRAG) ErrorChain(ctx context.Context, service string, since time.Time, limit int) []ErrorChainResult

+ func (g *GraphRAG) EventBufferDepth() int

+ func (g *GraphRAG) GetInvestigation(ctx context.Context, id string) (*Investigation, error)

+ func (g *GraphRAG) GetInvestigations(ctx context.Context, service, severity, status string, limit int) ([]Investigation, error)

+ func (g *GraphRAG) ImpactAnalysis(ctx context.Context, service string, maxDepth int) *ImpactResult

+ func (g *GraphRAG) InvestigationInsertCount() int64

+ func (g *GraphRAG) IsRunning() bool

+ func (g *GraphRAG) OnLogIngested(log storage.Log)

+ func (g *GraphRAG) OnMetricIngested(metric tsdb.RawMetric)

+ func (g *GraphRAG) OnSpanIngested(span storage.Span)

+ func (g *GraphRAG) PersistInvestigation(tenant, triggerService string, chains []ErrorChainResult, ...)

+ func (g *GraphRAG) RegisterAnomaly(tenant string, anomaly AnomalyNode)

+ func (g *GraphRAG) RootCauseAnalysis(ctx context.Context, service string, since time.Time) []RankedCause

+ func (g *GraphRAG) ServiceMap(ctx context.Context, depth int) []ServiceMapEntry

+ func (g *GraphRAG) ServiceNames(ctx context.Context) []string

+ func (g *GraphRAG) SetMetrics(m *telemetry.Metrics)

+ func (g *GraphRAG) ShortestPath(ctx context.Context, from, to string) []string

+ func (g *GraphRAG) SpanCapacityDropsCount() int64

+ func (g *GraphRAG) Start(ctx context.Context)

+ func (g *GraphRAG) Stop()

+ func (g *GraphRAG) StoreCounts() StoreCounts

+ func (g *GraphRAG) TenantsEvictedCount() int64

+ type ImpactResult struct

+ AffectedServices []AffectedEntry

+ Service string

+ TotalDownstream int

+ type Investigation struct

+ AffectedServices json.RawMessage

+ AnomalousMetrics json.RawMessage

+ CausalChain json.RawMessage

+ CreatedAt time.Time

+ ErrorLogs json.RawMessage

+ ErrorMessage string

+ ID string

+ RootOperation string

+ RootService string

+ Severity string

+ SpanChain json.RawMessage

+ Status string

+ TenantID string

+ TraceIDs json.RawMessage

+ TriggerOperation string

+ TriggerService string

+ func (Investigation) TableName() string

+ type LogClusterNode struct

+ Count int64

+ FirstSeen time.Time

+ ID string

+ LastSeen time.Time

+ SampleLog string

+ SeverityDist map[string]int64

+ Template string

+ TemplateID uint64

+ TemplateTokens []string

+ type MetricNode struct

+ ID string

+ LastSeen time.Time

+ MetricName string

+ RollingAvg float64

+ RollingMax float64

+ RollingMin float64

+ SampleCount int64

+ Service string

+ type NodeType string

+ const NodeAnomaly

+ const NodeLogCluster

+ const NodeMetric

+ const NodeOperation

+ const NodeService

+ const NodeSpan

+ const NodeTrace

+ type OperationNode struct

+ AvgLatency float64

+ CallCount int64

+ ErrorCount int64

+ ErrorRate float64

+ FirstSeen time.Time

+ HealthScore float64

+ ID string

+ LastSeen time.Time

+ Operation string

+ P50Latency float64

+ P95Latency float64

+ P99Latency float64

+ Service string

+ TotalMs float64

+ type RankedCause struct

+ Anomalies []AnomalyNode

+ ErrorChain []SpanNode

+ Evidence []string

+ Operation string

+ Score float64

+ Service string

+ type RootCauseInfo struct

+ ErrorMessage string

+ Operation string

+ Service string

+ SpanID string

+ TraceID string

+ type ServiceMapEntry struct

+ CalledBy []*Edge

+ CallsTo []*Edge

+ Operations []*OperationNode

+ Service *ServiceNode

+ type ServiceNode struct

+ AvgLatency float64

+ CallCount int64

+ ErrorCount int64

+ ErrorRate float64

+ FirstSeen time.Time

+ HealthScore float64

+ ID string

+ LastSeen time.Time

+ Name string

+ TotalMs float64

+ type ServiceStore struct

+ Edges map[string]*Edge

+ Operations map[string]*OperationNode

+ Services map[string]*ServiceNode

+ func (s *ServiceStore) AllEdges() []*Edge

+ func (s *ServiceStore) AllServices() []*ServiceNode

+ func (s *ServiceStore) CallEdgesFrom(service string) []*Edge

+ func (s *ServiceStore) CallEdgesTo(service string) []*Edge

+ func (s *ServiceStore) GetService(name string) (*ServiceNode, bool)

+ func (s *ServiceStore) UpsertCallEdge(source, target string, durationMs float64, isError bool, ts time.Time)

+ func (s *ServiceStore) UpsertOperation(service, operation string, durationMs float64, isError bool, ts time.Time)

+ func (s *ServiceStore) UpsertService(name string, durationMs float64, isError bool, ts time.Time)

+ type SignalStore struct

+ Edges map[string]*Edge

+ LogClusters map[string]*LogClusterNode

+ Metrics map[string]*MetricNode

+ func (ss *SignalStore) AddLoggedDuringEdge(clusterID, spanID string, ts time.Time)

+ func (ss *SignalStore) LogClustersForService(service string) []*LogClusterNode

+ func (ss *SignalStore) MetricsForService(service string) []*MetricNode

+ func (ss *SignalStore) Prune(cutoff time.Time, maxMetrics int) int

+ func (ss *SignalStore) UpsertLogCluster(id, template, severity, service string, ts time.Time)

+ func (ss *SignalStore) UpsertLogClusterWithTemplate(id, template, severity, service string, templateID uint64, tokens []string, ...)

+ func (ss *SignalStore) UpsertMetric(metricName, service string, value float64, ts time.Time)

+ type SpanNode struct

+ Duration float64

+ ID string

+ IsError bool

+ Operation string

+ ParentSpanID string

+ Service string

+ StatusCode string

+ Timestamp time.Time

+ TraceID string

+ type StoreCounts struct

+ Anomalies int

+ AnomalyEdges int

+ LogClusters int

+ Metrics int

+ Operations int

+ ServiceEdges int

+ Services int

+ SignalEdges int

+ Spans int

+ Tenants int

+ TraceEdges int

+ Traces int

+ type Template struct

+ Count int

+ FirstSeen time.Time

+ ID uint64

+ LastSeen time.Time

+ Sample string

+ Tokens []string

+ func LoadDrainTemplates(db *gorm.DB, tenant string) ([]Template, error)

+ func (t *Template) TemplateString() string

+ type TraceNode struct

+ Duration float64

+ ID string

+ RootService string

+ SpanCount int

+ Status string

+ Timestamp time.Time

+ type TraceStore struct

+ Edges map[string]*Edge

+ MaxSpans int

+ Spans map[string]*SpanNode

+ TTL time.Duration

+ Traces map[string]*TraceNode

+ func (ts *TraceStore) ErrorSpans(service string, since time.Time) []*SpanNode

+ func (ts *TraceStore) GetSpan(spanID string) (*SpanNode, bool)

+ func (ts *TraceStore) GetTrace(traceID string) (*TraceNode, bool)

+ func (ts *TraceStore) Prune() int

+ func (ts *TraceStore) SpansForTrace(traceID string) []*SpanNode

+ func (ts *TraceStore) UpsertSpan(span SpanNode) bool

+ func (ts *TraceStore) UpsertTrace(traceID, rootService, status string, durationMs float64, timestamp time.Time)

v0.3.0-beta.1

Jun 12, 2026

v0.2.0-beta.6

Jun 5, 2026

v0.2.0-beta.5

Jun 5, 2026

v0.2.0-beta.4

May 3, 2026

v0.2.0-beta.3

May 3, 2026

v0.2.0-beta.2

May 3, 2026

v0.2.0-beta.1

Mar 22, 2026

v0.0.11-beta.15

Mar 23, 2026

v0.0.11-beta.14

Mar 22, 2026

v0.0.11-beta.13

Mar 20, 2026