imbhgo

package module

Go to main page

Versions in this module

v0

v0.8.0

Aug 9, 2026

Changes in this version

+ const IndexScaleAll

+ const PromoteCostly

+ const PromoteMarginal

+ const PromoteNo

+ const PromoteUnknown

+ const PromoteYes

+ const PromoteYesRare

+ type AttrScope string

+ const ScopeAttributes

+ const ScopeResource

+ const ScopeScope

+ type AttrStatsOptions struct

+ BatchSize uint64

+ EndNs int64

+ MaxKeys uint64

+ MaxValues uint64

+ Scopes []AttrScope

+ StartNs int64

+ Windows string

+ type AttrStatsReport struct

+ Dir string

+ Global UnitReport

+ Levels []LevelReport

+ MaxKeys int

+ MaxValues int

+ PendingWalFrames int

+ PromotionCandidates []PromotionCandidate

+ Range *[2]int64

+ Scopes []AttrScope

+ SegmentsSkipped []string

+ Tables []UnitReport

type CompactionReport

+ SegmentsConverged uint64

type DB

+ func (db *DB) AttributeStats(opts AttrStatsOptions) (AttrStatsReport, error)

+ func (db *DB) CommitPending() (PendingReport, error)

+ func (db *DB) CompactBounded(maxPartitions int) (CompactionReport, error)

+ func (db *DB) Promoted() ([]string, error)

+ func (db *DB) Retention() (RetentionPolicy, error)

+ func (db *DB) SetPromoted(keys []string) ([]string, error)

type DbOptions

+ ResetPromote bool

+ ResetRetention bool

+ type KeyReport struct

+ CSegment *float64

+ Curve []*float64

+ DistinctEst float64

+ EstBytesPerRow float64

+ Name string

+ PostingsEst float64

+ Repetition float64

+ RowsPresent uint64

+ RowsString uint64

+ Runs uint64

+ Scope AttrScope

+ SegmentsPresent uint32

+ Sigma *SigmaSummary

+ StrLenAvg float64

+ StrLenMax uint32

+ ValuesSampleRate float64

+ ValuesTracked int

+ func (k KeyReport) IsSampled() bool

+ type LevelReport struct

+ Label string

+ WidthNanos int64

+ Windows uint32

type MaintenanceReport

+ PendingApplied uint64

+ PendingDiscarded uint64

+ PendingSegmentsReplaced uint64

+ type PendingReport struct

+ Applied uint64

+ Discarded uint64

+ SegmentsReplaced uint64

+ type PromotionCandidate struct

+ EstBytesPerRow float64

+ IndexScale string

+ Name string

+ Promote string

+ RowsString uint64

+ type RetentionPolicy struct

+ MaxAgeNs *uint64

+ MaxDiskBytes *uint64

+ type SigmaSummary struct

+ Count int

+ FracLE25 float64

+ Histogram [10]uint32

+ Max float64

+ Mean float64

+ P50 float64

+ P90 float64

+ type UnitReport struct

+ Keys []KeyReport

+ KeysEst float64

+ KeysSampleRate float64

+ KeysTracked int

+ Label string

+ Rows uint64

+ Segments uint32

+ SpanNanos int64

+ Windows []uint32

+ func (u UnitReport) Key(name string) *KeyReport

+ func (u UnitReport) RowsPerSegment() float64

v0.7.0

Aug 9, 2026

Changes in this version

type DB

+ func (db *DB) MetricDimensions(ctx context.Context, metric string) ([]MetricDimension, error)

+ type MetricDimension struct

+ Name string

+ Values []string

v0.6.0

Aug 7, 2026

Changes in this version

type LogEntry

+ ObservedTime int64

+ type LogOrder string

+ const LogOrderObservedTime

+ const LogOrderTime

type LogQuery

+ ObservedAfter int64

+ OrderBy LogOrder

v0.5.1

Aug 7, 2026

v0.5.0

Aug 5, 2026

Changes in this version

type DbOptions

+ Duplicates string

type DbStats

+ IngestRejected uint64

v0.3.0

Aug 1, 2026

v0.2.0

Aug 1, 2026

Changes in this version

type DbOptions

+ Flush string

v0.1.1

Jul 28, 2026

v0.1.0

Jul 26, 2026

Changes in this version

+ const Version

+ var ErrBackpressure = sable.ErrBackpressure

+ func SetMaxInFlight(max uint64)

+ type CompactionReport struct

+ SegmentsCreated uint64

+ SegmentsMerged uint64

+ type Cursor []byte

+ func (c Cursor) HasMore() bool

+ type DB struct

+ func Open(path string) (*DB, error)

+ func OpenInMemory() (*DB, error)

+ func OpenReadOnly(path string) (*DB, error)

+ func OpenWith(opts DbOptions) (*DB, error)

+ func (db *DB) AttrNames(ctx context.Context) ([]string, error)

+ func (db *DB) AttrValues(ctx context.Context, key string) ([]string, error)

+ func (db *DB) Close()

+ func (db *DB) Compact() (CompactionReport, error)

+ func (db *DB) CountLogs(ctx context.Context, q LogQuery) (uint64, error)

+ func (db *DB) DurableThrough() (uint64, bool, error)

+ func (db *DB) Export(table Table, startNs, endNs int64) ([]byte, error)

+ func (db *DB) ExportRecords(table Table, startNs, endNs int64) ([]arrow.RecordBatch, error)

+ func (db *DB) Flush() error

+ func (db *DB) GetTrace(ctx context.Context, traceID string) (*Rows, error)

+ func (db *DB) GetTraceForest(ctx context.Context, traceID string) ([]*TraceNode, error)

+ func (db *DB) GetTraceSpans(ctx context.Context, traceID string) ([]Span, error)

+ func (db *DB) IngestOTLPLogs(otlp []byte) (Receipt, error)

+ func (db *DB) IngestOTLPMetrics(otlp []byte) (Receipt, error)

+ func (db *DB) IngestOTLPTraces(otlp []byte) (Receipt, error)

+ func (db *DB) LogVolume(ctx context.Context, q LogQuery, stepNs int64) ([]VolumeBucket, error)

+ func (db *DB) LogVolumeBy(ctx context.Context, q LogQuery, stepNs int64, groupBy []string) ([]VolumeBucket, error)

+ func (db *DB) Maintain() (MaintenanceReport, error)

+ func (db *DB) MetricCatalog(ctx context.Context) ([]MetricInfo, error)

+ func (db *DB) MetricExemplars(ctx context.Context, metric string) ([]Exemplar, error)

+ func (db *DB) MetricSeries(ctx context.Context, metric string) ([]string, error)

+ func (db *DB) Query(ctx context.Context, sql string) (*Rows, error)

+ func (db *DB) QueryLogPage(ctx context.Context, q LogQuery, after Cursor) (*LogPage, error)

+ func (db *DB) QueryLogQL(ctx context.Context, query string, start, end, step int64) (*Rows, error)

+ func (db *DB) QueryLogQLLines(ctx context.Context, query string, start, end int64, limit int) ([]LogEntry, error)

+ func (db *DB) QueryLogQLSeries(ctx context.Context, query string, start, end, step int64) ([]Series, error)

+ func (db *DB) QueryLogs(ctx context.Context, q LogQuery) (*Rows, error)

+ func (db *DB) QueryLogsTyped(ctx context.Context, q LogQuery) ([]LogEntry, error)

+ func (db *DB) QueryMetricInstant(ctx context.Context, q MetricQuery) ([]InstantSample, error)

+ func (db *DB) QueryMetricPoints(ctx context.Context, q MetricPointsQuery) (*Rows, error)

+ func (db *DB) QueryMetricPointsTyped(ctx context.Context, q MetricPointsQuery) ([]MetricPoint, error)

+ func (db *DB) QueryMetrics(ctx context.Context, q MetricQuery) (*Rows, error)

+ func (db *DB) QueryMetricsTyped(ctx context.Context, q MetricQuery) (Matrix, error)

+ func (db *DB) QueryPromQL(ctx context.Context, query string, start, end, step int64) (*Rows, error)

+ func (db *DB) QueryPromQLSeries(ctx context.Context, query string, start, end, step int64) ([]Series, error)

+ func (db *DB) QuerySpanMetrics(ctx context.Context, q SpanMetricsQuery) (*Rows, error)

+ func (db *DB) QuerySpanMetricsTyped(ctx context.Context, q SpanMetricsQuery) ([]SpanMetricPoint, error)

+ func (db *DB) QueryTraceQL(ctx context.Context, query string, start, end int64) (*Rows, error)

+ func (db *DB) QueryTraceQLMatches(ctx context.Context, query string, start, end int64) ([]TraceMatch, error)

+ func (db *DB) SearchTraces(ctx context.Context, q TraceQuery) ([]TraceSummary, error)

+ func (db *DB) SegmentFiles(table Table) ([]string, error)

+ func (db *DB) Segments() ([]SegmentRef, error)

+ func (db *DB) Snapshot(dir string) (SnapshotInfo, error)

+ func (db *DB) Stats() (DbStats, error)

+ func (db *DB) TryIngestOTLPLogs(otlp []byte) (Receipt, error)

+ func (db *DB) TryIngestOTLPMetrics(otlp []byte) (Receipt, error)

+ func (db *DB) TryIngestOTLPTraces(otlp []byte) (Receipt, error)

+ type DbOptions struct

+ AllowStaleReads bool

+ Compression string

+ MaintenanceBackgroundNs int64

+ MaxDiskBytes uint64

+ MemoryBudgetBytes uint64

+ Path string

+ PromoteKeys []string

+ ReadOnly bool

+ Refresh string

+ RefreshTtlNs int64

+ RetentionDays uint64

+ WalIntervalNs int64

+ WalMode string

+ ZstdLevel int32

+ type DbStats struct

+ BufferBytes uint64

+ DurableLSN *uint64

+ IngestDropped uint64

+ IngestErrors uint64

+ IngestQueueDepth uint64

+ Tables []TableStats

+ WalBytes uint64

+ type Exemplar struct

+ Attributes string

+ SpanID string

+ Time int64

+ TraceID string

+ Value float64

+ type InstantSample struct

+ Labels string

+ Time int64

+ Value float64

+ type LogEntry struct

+ Attributes string

+ Body string

+ Service string

+ Severity uint8

+ SeverityText string

+ SpanID []byte

+ Time int64

+ TraceID []byte

+ type LogPage struct

+ Entries []LogEntry

+ Next Cursor

+ Stats QueryStats

+ type LogQuery struct

+ AttrEq map[string]string

+ AttrExists []string

+ AttrGe map[string]float64

+ AttrGt map[string]float64

+ AttrIn map[string][]string

+ AttrLe map[string]float64

+ AttrLt map[string]float64

+ AttrMatches map[string]string

+ AttrNotIn map[string][]string

+ AttrRegex map[string]string

+ Backward bool

+ End int64

+ Limit int

+ Match string

+ Service string

+ SeverityAtLeast int

+ SpanID string

+ Start int64

+ TraceID string

+ type MaintenanceReport struct

+ BytesFreed uint64

+ Sealed bool

+ SegmentsDropped uint64

+ type Matrix struct

+ Series []Series

+ type MetricInfo struct

+ Kind string

+ Metric string

+ Temporality string

+ Unit string

+ type MetricPoint struct

+ Attributes string

+ Metric string

+ Service string

+ Time int64

+ Value float64

+ type MetricPointsQuery struct

+ End int64

+ Filters map[string]string

+ Kind string

+ Limit int

+ Metric string

+ Start int64

+ type MetricQuery struct

+ End int64

+ GroupBy []string

+ Metric string

+ Start int64

+ Step int64

+ Sum bool

+ type Point struct

+ T int64

+ V float64

+ type QueryStats struct

+ BytesScanned uint64

+ ElapsedNs uint64

+ RowsReturned uint64

+ RowsScanned uint64

+ SegmentsPruned uint64

+ SegmentsScanned uint64

+ UsedIndex bool

+ type Receipt struct

+ Accepted uint64

+ Durable bool

+ LSN uint64

+ Queued bool

+ Rejected uint64

+ type Rows struct

+ func (r *Rows) Close()

+ func (r *Rows) Err() error

+ func (r *Rows) Next() (rec arrow.RecordBatch, ok bool, err error)

+ type SegmentRef struct

+ MaxTimeUnixNano int64

+ MinTimeUnixNano int64

+ RelativePath string

+ Rows uint64

+ type Series struct

+ Labels map[string]string

+ Points []Point

+ type SnapshotInfo struct

+ Dir string

+ Segments uint64

+ type Span struct

+ Attributes string

+ DurationNs int64

+ Kind string

+ Name string

+ ParentSpanID []byte

+ Service string

+ SpanID []byte

+ StartTime int64

+ StatusCode string

+ StatusMessage string

+ TraceID []byte

+ type SpanMetricPoint struct

+ Bucket int64

+ Calls uint64

+ Errors uint64

+ Labels map[string]string

+ P50 float64

+ P95 float64

+ P99 float64

+ type SpanMetricsQuery struct

+ End int64

+ GroupBy []string

+ Kind string

+ Name string

+ Service string

+ Start int64

+ Status string

+ Step int64

+ type Stats = sable.Stats

+ func RuntimeStats() Stats

+ type Table string

+ const TableLogs

+ const TableMetricsExpHistogram

+ const TableMetricsGauge

+ const TableMetricsHistogram

+ const TableMetricsSum

+ const TableMetricsSummary

+ const TableSpans

+ type TableStats struct

+ BufferRows uint64

+ MaxTimeUnixNano *int64

+ MinTimeUnixNano *int64

+ SegmentCount uint64

+ SegmentRows uint64

+ Table string

+ type TraceMatch struct

+ SpanIDs []string

+ TraceID string

+ type TraceNode struct

+ Children []*TraceNode

+ func AssembleTrace(spans []Span) []*TraceNode

+ type TraceQuery struct

+ AttrEq map[string]string

+ AttrExists []string

+ AttrGe map[string]float64

+ AttrGt map[string]float64

+ AttrIn map[string][]string

+ AttrLe map[string]float64

+ AttrLt map[string]float64

+ AttrMatches map[string]string

+ AttrNotIn map[string][]string

+ AttrRegex map[string]string

+ End int64

+ Kind string

+ Limit int64

+ MaxDurationNs int64

+ MinDurationNs int64

+ Name string

+ Service string

+ Start int64

+ Status string

+ type TraceSummary struct

+ DurationNs int64

+ Error bool

+ RootName string

+ RootService string

+ SpanCount int64

+ StartTime int64

+ TraceID string

+ type VolumeBucket struct

+ Count int64

+ Labels string

+ Time int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL