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

storage

package

Go to main page

Versions in this module

v0

v0.4.0-beta.1

Jun 19, 2026

v0.3.1

Jun 18, 2026

v0.3.1-beta.1

Jun 18, 2026

v0.3.0

Jun 17, 2026

Changes in this version

+ const DefaultTenantID

+ const MaxTenantIDLength

+ const PartitioningModeDaily

+ var ErrLogNotFoundOrWrongTenant = errors.New("log not found or not accessible by current tenant")

+ func AutoMigrateModels(db *gorm.DB, driver string) error

+ func AutoMigrateModelsWithOptions(db *gorm.DB, driver string, opts MigrateOptions) error

+ func ClampSearchWindowTo24h(start, end, now time.Time) (time.Time, time.Time, error)

+ func DropExpiredLogsPartitions(ctx context.Context, db *gorm.DB, cutoff time.Time) (int, error)

+ func EnsureLogsLookahead(db *gorm.DB, lookaheadDays int) (int, error)

+ func EnsureLogsPartitionForDay(db *gorm.DB, day time.Time) error

+ func HasTenantContext(ctx context.Context) bool

+ func NewDatabase(driver, dsn string) (*gorm.DB, error)

+ func SanitizeTenantID(s string) string

+ func TenantFromContext(ctx context.Context) string

+ func WithTenantContext(ctx context.Context, tenant string) context.Context

+ type CompressedText string

+ func (CompressedText) GormDBDataType(db *gorm.DB, _ *schema.Field) string

+ func (ct *CompressedText) Scan(value any) error

+ func (ct CompressedText) Value() (driver.Value, error)

+ type DashboardStats struct

+ ActiveServices int64

+ AvgLatencyMs float64

+ ErrorRate float64

+ P99Latency int64

+ TopFailingServices []ServiceError

+ TotalErrors int64

+ TotalLogs int64

+ TotalTraces int64

+ type LatencyPoint struct

+ Duration int64

+ Timestamp time.Time

+ type Log struct

+ AIInsight CompressedText

+ AttributesJSON CompressedText

+ Body string

+ ID uint

+ ServiceName string

+ Severity string

+ SpanID string

+ TenantID string

+ Timestamp time.Time

+ TraceID string

+ type LogFilter struct

+ EndTime time.Time

+ Limit int

+ Offset int

+ Search string

+ ServiceName string

+ Severity string

+ StartTime time.Time

+ TraceID string

+ type MetricBucket struct

+ AttributesJSON CompressedText

+ Count int64

+ ID uint

+ Max float64

+ Min float64

+ Name string

+ ServiceName string

+ Sum float64

+ TenantID string

+ TimeBucket time.Time

+ type MigrateOptions struct

+ PartitionLookaheadDays int

+ PostgresPartitioning string

+ Timeout time.Duration

+ type PartitionScheduler struct

+ func NewPartitionScheduler(repo *Repository, retentionDays, lookaheadDays int) *PartitionScheduler

+ func (s *PartitionScheduler) SetMetrics(onDrop, onKeep func(int))

+ func (s *PartitionScheduler) Start(parent context.Context)

+ func (s *PartitionScheduler) Stop()

+ type Repository struct

+ func NewRepository(metrics *telemetry.Metrics) (*Repository, error)

+ func NewRepositoryFromDB(db *gorm.DB, driver string) *Repository

+ func (r *Repository) BatchCreateAll(traces []Trace, spans []Span, logs []Log) error

+ func (r *Repository) BatchCreateLogs(logs []Log) error

+ func (r *Repository) BatchCreateMetrics(buckets []MetricBucket) error

+ func (r *Repository) BatchCreateSpans(spans []Span) error

+ func (r *Repository) BatchCreateTraces(traces []Trace) error

+ func (r *Repository) Close() error

+ func (r *Repository) CreateTrace(trace Trace) error

+ func (r *Repository) DB() *gorm.DB

+ func (r *Repository) DropLogsFTS(ctx context.Context) error

+ func (r *Repository) GetDashboardStats(ctx context.Context, start, end time.Time, serviceNames []string) (*DashboardStats, error)

+ func (r *Repository) GetLatencyHeatmap(ctx context.Context, start, end time.Time, serviceNames []string) ([]LatencyPoint, error)

+ func (r *Repository) GetLog(ctx context.Context, id uint) (*Log, error)

+ func (r *Repository) GetLogContext(ctx context.Context, targetTime time.Time) ([]Log, error)

+ func (r *Repository) GetLogsV2(ctx context.Context, filter LogFilter) ([]Log, int64, error)

+ func (r *Repository) GetMetricBuckets(ctx context.Context, start, end time.Time, serviceName string, ...) ([]MetricBucket, error)

+ func (r *Repository) GetMetricNames(ctx context.Context, serviceName string) ([]string, error)

+ func (r *Repository) GetRecentLogs(ctx context.Context, limit int) ([]Log, error)

+ func (r *Repository) GetServiceMapMetrics(ctx context.Context, start, end time.Time) (*ServiceMapMetrics, error)

+ func (r *Repository) GetServices(ctx context.Context) ([]string, error)

+ func (r *Repository) GetSpansForGraph(since time.Time) ([]SpanGraphRow, error)

+ func (r *Repository) GetStats(ctx context.Context) (map[string]any, error)

+ func (r *Repository) GetTrace(ctx context.Context, traceID string) (*Trace, error)

+ func (r *Repository) GetTracesFiltered(ctx context.Context, start, end time.Time, serviceNames []string, ...) (*TracesResponse, error)

+ func (r *Repository) GetTrafficMetrics(ctx context.Context, start, end time.Time, serviceNames []string) ([]TrafficPoint, error)

+ func (r *Repository) HotDBSizeBytes() int64

+ func (r *Repository) LogsPartitioned() bool

+ func (r *Repository) MarkLogsPartitioned()

+ func (r *Repository) PurgeLogs(olderThan time.Time) (int64, error)

+ func (r *Repository) PurgeLogsBatched(ctx context.Context, olderThan time.Time, batchSize int, sleep time.Duration) (int64, error)

+ func (r *Repository) PurgeMetricBucketsBatched(ctx context.Context, olderThan time.Time, batchSize int, sleep time.Duration) (int64, error)

+ func (r *Repository) PurgeTraces(olderThan time.Time) (int64, error)

+ func (r *Repository) PurgeTracesBatched(ctx context.Context, olderThan time.Time, batchSize int, sleep time.Duration) (int64, error)

+ func (r *Repository) RecentLogs(ctx context.Context, limit int) ([]Log, error)

+ func (r *Repository) RecentTraces(ctx context.Context, limit int) ([]Trace, error)

+ func (r *Repository) SearchLogs(ctx context.Context, query string, limit int) ([]Log, error)

+ func (r *Repository) UpdateLogInsight(ctx context.Context, logID uint, insight string) error

+ func (r *Repository) VacuumDB() error

+ type RetentionScheduler struct

+ func NewRetentionScheduler(repo *Repository, retentionDays, batchSize int, batchSleep time.Duration) *RetentionScheduler

+ func (r *RetentionScheduler) SetFullVacuum(enabled bool)

+ func (r *RetentionScheduler) SkippedRuns() int64

+ func (r *RetentionScheduler) Start(parent context.Context)

+ func (r *RetentionScheduler) Stop()

+ type ServiceError struct

+ ErrorCount int64

+ ErrorRate float64

+ ServiceName string

+ TotalCount int64

+ type ServiceMapEdge struct

+ AvgLatencyMs float64

+ CallCount int64

+ ErrorRate float64

+ Source string

+ Target string

+ type ServiceMapMetrics struct

+ Edges []ServiceMapEdge

+ Nodes []ServiceMapNode

+ type ServiceMapNode struct

+ AvgLatencyMs float64

+ ErrorCount int64

+ Name string

+ TotalTraces int64

+ type Span struct

+ AttributesJSON CompressedText

+ Duration int64

+ EndTime time.Time

+ ID uint

+ OperationName string

+ ParentSpanID string

+ ServiceName string

+ SpanID string

+ StartTime time.Time

+ Status string

+ TenantID string

+ TraceID string

+ type SpanGraphRow struct

+ DurationMs float64

+ IsError bool

+ OperationName string

+ ParentSpanID string

+ ServiceName string

+ SpanID string

+ Timestamp time.Time

+ type Trace struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Duration int64

+ DurationMs float64

+ ID uint

+ Logs []Log

+ Operation string

+ ServiceName string

+ SpanCount int

+ Spans []Span

+ Status string

+ TenantID string

+ Timestamp time.Time

+ TraceID string

+ UpdatedAt time.Time

+ type TracesResponse struct

+ Limit int

+ Offset int

+ Total int64

+ Traces []Trace

+ type TrafficPoint struct

+ Count int64

+ ErrorCount int64

+ 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

v0.0.11-beta.12

Mar 20, 2026

v0.0.11-beta.11

Mar 18, 2026

v0.0.11-beta.10

Mar 17, 2026

v0.0.11-beta.9

Mar 17, 2026

v0.0.11-beta.8

Mar 17, 2026

v0.0.11-beta.7

Mar 17, 2026