obsdb

Oct 27, 2026

Changes in this version

+ func StockHasMessages(attrs map[string]any) bool

+ func StockNotRun(spans []Span) (reason, fix string)

+ func StockRunPrefix(traceID string) string

+ func StockToolContent(attrs map[string]any) (args json.RawMessage, result string, hasArgs, hasResult bool)

+ type BreakpointProvenanceStore interface

+ BreakpointSet func(ctx context.Context, runtimeID string) (BreakpointSet, bool, error)

+ PutBreakpointSet func(ctx context.Context, runtimeID string, set BreakpointSet) error

+ type BreakpointSet struct

+ SetAt time.Time

+ SetBy string

+ Tools []string

type RequestBody

+ Parallelism int

+ Wire *RequestWire

+ type RequestWire struct

+ Dropped int

+ ExtraBodyKeys []string

+ ExtraHeaders []string

+ ServerAddress string

type RunRow

+ Removed bool

+ func StockFoldedRuns(spans []Span) []RunRow

type SessionQuery

+ IDPrefix string

+ type SkippedTool struct

+ Name string

+ Reason string

+ Source string

+ type SourceDetail struct

+ Prefix string

+ RemoteName string

+ Server string

+ Transport string

type ToolEntry

+ SourceDetail *SourceDetail

type ToolsRecord

+ Skipped []SkippedTool

+ SkippedMore int

type TraceQuery

+ IDPrefix string

+ Meta map[string]string

+ NotRun bool

+ ScopeMeta map[string]string

type TreeQuery

+ Meta map[string]string

+ func (q TreeQuery) Scoped() bool

type TreeRun

+ Meta map[string]string

Oct 26, 2026

Changes in this version

+ const MaxErrorClassBytes

+ const MaxErrorTexts

+ const MaxStatsBuckets

+ const MaxStatsGroups

+ const MaxStatsYear

+ const MinStatsYear

+ const StatsBuckets

+ var ErrInvalidStats = errors.New("obsdb: invalid stats query")

+ func AttemptIndex(attrs map[string]any) (int64, bool)

+ func CheckStats(q StatsQuery) (buckets int, width time.Duration, err error)

+ func ErrorClass(err string) string

+ func ErrorClassTexts(counts []ErrorCount, class string) []string

+ func PercentileRank(p, n int64) int64

+ type Aggregator interface

+ ErrorCounts func(ctx context.Context, q SearchQuery) (counts []ErrorCount, capped bool, err error)

+ Stats func(ctx context.Context, q StatsQuery) (StatsPage, error)

type CommandStore

+ DeleteRuntime func(ctx context.Context, runtimeID string) error

+ type ErrorClassCount struct

+ Class string

+ Count int64

+ func ErrorClasses(counts []ErrorCount, limit int) []ErrorClassCount

+ type ErrorCount struct

+ Count int64

+ Err string

type Experiment

+ PassPredicate string

type ExperimentInput

+ FromStep *int

+ type Percentiles struct

+ N int64

+ P50 float64

+ P95 float64

type RunQuery

+ Errs []string

+ type StatsBucket struct

+ Calls int64

+ Failed int64

+ FailedCalls int64

+ InputTokens int64

+ OutputTokens int64

+ Runs int64

+ type StatsBy string

+ const StatsByAgent

+ const StatsByErrorType

+ const StatsByModel

+ const StatsByStep

+ const StatsByTool

+ func (by StatsBy) RunLevel() bool

+ type StatsCell struct

+ Bucket int

+ CacheWriteTokens int64

+ CachedInputTokens int64

+ Calls int64

+ DelegatedRuns int64

+ Denials int64

+ Failed int64

+ FailedCalls int64

+ InputTokens int64

+ Key string

+ OutputTokens int64

+ ReasoningTokens int64

+ Retried int64

+ Runs int64

+ type StatsGroup struct

+ Calls int64

+ Delegated core.Usage

+ DelegatedModels []ModelUsage

+ DelegatedRuns int64

+ Denials int64

+ Duration Percentiles

+ Failed int64

+ FailedCalls int64

+ Key string

+ Models []ModelUsage

+ Retried int64

+ Runs int64

+ Series []StatsBucket

+ TTFT Percentiles

+ Usage core.Usage

+ type StatsModelPart struct

+ Delegated bool

+ Key string

+ type StatsPage struct

+ Bucket time.Duration

+ Buckets int

+ By StatsBy

+ Groups []StatsGroup

+ GroupsCut int

+ Since time.Time

+ Until time.Time

+ func BuildStats(q StatsQuery, cells []StatsCell, models []StatsModelPart, ...) StatsPage

+ type StatsPercentiles struct

+ Duration Percentiles

+ Key string

+ TTFT Percentiles

+ type StatsQuery struct

+ Buckets int

+ By StatsBy

+ Since time.Time

+ Until time.Time

Oct 20, 2026

Changes in this version

+ const AttrChatRole

+ const BusyCancelCause

+ const ChatRoleSummarizer

+ const LineageChild

+ const LineageFork

+ const MaxOutcomes

+ const MaxSessionEventLimit

+ const RecordThread

+ const SessionForkedFromKey

+ const TreeCutParent

+ func AttrTrue(m map[string]any, k string) bool

+ func IsSessionEventKind(kind string) bool

+ func SessionEventKind(e SessionEvent) string

+ func SessionEventName(kind, eventName string, body []byte) string

+ func SessionTurnFacts(row *SessionRow, turns []RunRow)

+ type ModelUsage struct

+ Model string

+ Provider string

+ Usage core.Usage

+ func SumModelUsage(parts []ModelUsage) (core.Usage, []ModelUsage)

type RunQuery

+ CallerRunID string

+ Oldest bool

+ SessionIDs []string

+ TurnAbove int

+ TurnBelow int

type RunRow

+ CallerCallID string

+ CallerRunID string

+ type SessionEvent struct

+ Body json.RawMessage

+ Content string

+ Kind string

+ Name string

+ PublicID string

+ RunID string

+ SessionID string

+ Time time.Time

+ type SessionEventPage struct

+ Events []SessionEvent

+ Total int

+ type SessionEventQuery struct

+ Kinds []string

+ Limit int

+ Offset int

+ PublicID string

+ RunIDs []string

+ SessionID string

+ func (q SessionEventQuery) PageLimit() int

+ type SessionEventReader interface

+ SessionEvents func(ctx context.Context, q SessionEventQuery) (SessionEventPage, error)

type SessionQuery

+ Awaiting bool

+ Compacted bool

+ Failed bool

+ IDs []string

+ Lineage string

+ Meta map[string]string

+ Parents []string

+ Since time.Time

+ Status Status

type SessionRow

+ CancelledTurns int

+ EndedTurns int

+ FailedTurns int

+ ForkedFrom string

+ Outcomes []TurnOutcome

+ ParentCall string

+ ParentRun string

+ ParentSession string

+ Pending int

+ Resumes int

+ SummarizerModels []ModelUsage

+ SummarizerUsage core.Usage

+ type TurnOutcome string

+ const OutcomeCancelled

+ const OutcomeEnded

+ const OutcomeFailed

+ const OutcomeInterrupted

+ const OutcomeParked

+ const OutcomeResumed

+ const OutcomeRunning

+ const OutcomeSucceeded

+ func OutcomeOf(r RunRow) TurnOutcome

type Weft

+ CallerCallID string

+ CallerRunID string

Oct 17, 2026

Changes in this version

+ const ChildRunsCap

+ const FrameAttempt

+ const TreeMissingCap

+ const TreeRowCap

+ const TreeSpanCap

+ const TreeTraceCap

+ var ErrChildRunsCapped = errors.New("obsdb: more child runs than ChildRunsCap")

+ var ErrInvalidStatus = errors.New("status must be running, succeeded, failed, interrupted, parked or cancelled")

+ var StatusWords = []Status

+ func TreeChildID(parent, id string) bool

+ func TreeIDRule(runID, id string, known func(string) bool) (parent string, ok bool)

+ func TreeMemberIDs(runID string, parents map[string]string) []string

+ func TreeMembers(runID string, parents map[string]string) map[string]string

+ func TreeReadIDs(q TreeQuery, parents map[string]string, rows []TreeRun) []string

type Frame

+ Span *Span

+ func AttemptFrame(s Span) (Frame, bool)

type LogPage

+ NoBridge bool

type RequestBody

+ Prepared []string

type RequestThinking

+ Wire string

type RunQuery

+ IDPrefix string

+ type RunTree struct

+ Hidden bool

+ HiddenCount int

+ Missing []TreeRun

+ MissingCount int

+ Spans []TreeSpan

+ TraceTruncated bool

+ Truncated bool

+ func CapTree(read []Span, more bool, q TreeQuery, parents map[string]string, rows []TreeRun) RunTree

type Status

+ const StatusCancelled

+ const StatusParked

+ func ParseStatus(s string) (Status, error)

+ func (s Status) Stored() Status

type ToolEntry

+ Output bool

+ type TreeQuery struct

+ PublicID string

+ RunID string

+ type TreeReader interface

+ ChildRuns func(ctx context.Context, parentIDs []string) (map[string][]RunRow, error)

+ RunTreeSpans func(ctx context.Context, q TreeQuery) (RunTree, error)

+ type TreeRun struct

+ ID string

+ ParentRunID string

+ PublicID string

+ Started time.Time

+ Status Status

+ type TreeSpan struct

+ ParentRunID string

+ RunID string

+ func CutRunTree(spans []Span, runID string, parents map[string]string) []TreeSpan

Oct 14, 2026

Changes in this version

+ const ErrorTypeCancelled

+ const ManifestSourceFile

+ const ManifestSourceRuntime

+ const SessionTitleKey

+ var ErrInvalidManifest = errors.New("obsdb: invalid manifest")

+ func CheckStoredManifest(m StoredManifest) error

+ func DeriveSettling(rootEnded, finishRecorded bool, lastSeen, now time.Time) bool

+ func EventsLostHole(r RunRow) (Hole, HoleCause)

+ func EventsLostReason(r RunRow, below int) string

+ func LostRecordsHole(r RunRow, hasSpans bool) (Hole, HoleCause)

+ func ManifestHash(body []byte) string

+ func MessagesLostHole(r RunRow) (Hole, HoleCause)

+ func MessagesLostReason(r RunRow) string

+ func MetadataCapReason(n int64) string

+ func NonMetaKeys() []string

+ func RunErrorType(errorType string) string

+ func SessionContentOff(first RunRow) bool

+ func SpanProblems(s Span) []string

+ func TailLostHole(r RunRow) (Hole, HoleCause)

type DB

+ CountLogs func(ctx context.Context, runID string, minSeverity int) (LogCounts, error)

type HoleCause

+ const CauseEventsLost

+ const CauseMessagesLost

+ const CauseMetadataCap

+ const CauseNoLogger

+ const CauseTailLost

+ type LogCounts struct

+ Capped bool

+ Error int64

+ Total int64

+ Warn int64

+ func CountOtherLogs(ctx context.Context, db DB, runID string, minSeverity int, ...) (LogCounts, error)

+ type ManifestStore interface

+ Manifest func(ctx context.Context, hash string) (StoredManifest, bool, error)

+ PutManifest func(ctx context.Context, m StoredManifest) error

+ type Problems struct

+ AttemptsRetried int64

+ Denied int64

+ Fallbacks int64

+ LogError int64

+ LogWarn int64

+ MetadataDropped int64

+ Repaired int64

+ TapPanics int64

+ ToolErrors int64

+ Truncated int64

+ func CountProblems(tokens []string) Problems

+ func (p Problems) Any() bool

type PromptRecord

+ Segments []PromptSegment

+ type PromptSegment struct

+ Source string

+ Text string

type RunQuery

+ ErrorType string

+ StoppedBy string

type RunRow

+ CancelCause string

+ ErrorType string

+ EventsEmitted int64

+ FinishRecorded bool

+ MessagesEmitted int64

+ Problems Problems

+ ResumedBy string

+ ResumedFrom string

+ RootEnded bool

+ Settling bool

+ StoppedBy string

+ func (r RunRow) RequestsHoleCause() (Hole, HoleCause)

type SessionQuery

+ Q string

type SessionRow

+ ContentOff bool

+ FirstPrompt string

+ Title string

+ type StoredManifest struct

+ Body json.RawMessage

+ FirstSeen time.Time

+ Hash string

+ Source string

type Weft

+ ResumedFrom string

Oct 12, 2026

Changes in this version

+ const CommandAccepted

+ const CommandFinished

+ const CommandLost

+ const CommandQueued

+ const CommandRejected

+ const StockErrNoDescription

+ var ErrInvalidCommand = errors.New("obsdb: invalid command store row")

+ func CheckStoredCommand(c StoredCommand) error

+ func CommandTerminal(state string) bool

+ func IsStockRoot(s Span) bool

+ func ParseStockRunID(id string) (traceID, spanID string, ok bool)

+ func StockCandidate(s Span) bool

+ func StockRunID(traceID, spanID string) string

+ func StockRunsOf(all []SpanLink, keys []SpanKey, deleted map[string]bool) []string

+ func StockTraces(ids []string) []string

+ type CommandQuery struct

+ ID string

+ Limit int

+ RunID string

+ RuntimeID string

+ States []string

+ type CommandStore interface

+ Breakpoints func(ctx context.Context, runtimeID string) ([]string, bool, error)

+ Commands func(ctx context.Context, q CommandQuery) ([]StoredCommand, error)

+ PruneCommands func(ctx context.Context, before time.Time, keep int) (int, error)

+ PutBreakpoints func(ctx context.Context, runtimeID string, tools []string) error

+ PutCommand func(ctx context.Context, c StoredCommand) error

+ PutRoute func(ctx context.Context, r RunRoute) error

+ PutRuntime func(ctx context.Context, r StoredRuntime) error

+ Route func(ctx context.Context, runID string) (RunRoute, bool, error)

+ Runtimes func(ctx context.Context) ([]StoredRuntime, error)

type HoleCause

+ const CauseStockSpans

+ type RunRoute struct

+ CommandID string

+ Fork bool

+ PublicID string

+ RunID string

+ RuntimeID string

+ Seen time.Time

type RunRow

+ Derived bool

type Span

+ func StockRunSpans(spans []Span, id string) []Span

+ type StockRun struct

+ Row RunRow

+ Spans []Span

+ func DeriveStockRuns(spans []Span) []StockRun

+ type StoredCommand struct

+ AcceptedAt time.Time

+ Ack json.RawMessage

+ Agent string

+ Body json.RawMessage

+ Created time.Time

+ Error string

+ ExperimentID string

+ Fork bool

+ ID string

+ Kind string

+ LastBeat time.Time

+ PublicID string

+ RunID string

+ RuntimeID string

+ SourceRunID string

+ State string

+ Status string

+ Updated time.Time

+ func CommandByRun(ctx context.Context, s CommandStore, runID string) (StoredCommand, bool, error)

+ type StoredRuntime struct

+ Agents []string

+ Body json.RawMessage

+ Cwd string

+ Host string

+ ID string

+ LastSeen time.Time

+ Pid int

+ Registered time.Time

+ Service string

Oct 11, 2026

Changes in this version

+ const MaxSearchOffset

+ const MaxSearchTermBytes

+ const MaxSearchTerms

+ const PromptPreviewRunes

+ const RecordRaw

+ const SweepBatch

+ var ErrInvalidSearch = errors.New("obsdb: invalid search")

+ func AttachRaw(reqs []RequestRecord, raws []StoredRecord)

+ func CheckSearch(q SearchQuery) ([]string, error)

+ func LastAssistantText(body []byte) (string, bool)

+ func ParseSearch(text string) ([]string, error)

+ func PromptPreview(s string) string

+ func PromptText(body []byte, input bool) (string, bool)

+ func StepRange(reqs []RequestRecord) (lo, hi int, ok bool)

+ func TurnPrompt(input, next []byte) (string, bool)

type DB

+ DeleteRun func(ctx context.Context, id string) error

+ DeleteSession func(ctx context.Context, id string) error

+ Sweep func(ctx context.Context, before time.Time) (int, error)

+ Traces func(ctx context.Context, q TraceQuery) (TracePage, error)

+ Vacuum func(ctx context.Context) error

+ type ExperimentCommand struct

+ Engine string

+ FromStep *int

+ SideEffects string

+ SourceRunID string

+ Thread string

+ TranscriptEdits json.RawMessage

type ExperimentVariant

+ Engine string

+ SideEffects string

+ Thread string

type HoleCause

+ const CauseRawOff

+ type MessageText struct

+ Role string

+ Text string

+ ToolCall bool

+ func MessagesText(body []byte) []MessageText

+ type RawRecord struct

+ Attempt int64

+ Content Hole

+ Index int64

+ RedactedHeaders []string

+ RedactedQuery []string

+ Request RawSide

+ Response *RawSide

+ Step int

+ Time time.Time

+ TruncatedBytes int64

+ func RawRecordOf(r StoredRecord) RawRecord

+ type RawSide struct

+ Body string

+ Bytes int64

+ Complete *bool

+ Encoding string

+ Headers map[string][]string

+ MediaType string

+ Method string

+ Status int

+ TruncatedBytes int64

+ URL string

type RequestRecord

+ Wire *RawRecord

type RunQuery

+ LastSeenAfter time.Time

type RunRow

+ PromptPreview string

+ type SearchQuery struct

+ Error string

+ MinTokens int64

+ Model string

+ Offset int

+ Since time.Time

+ Sort SearchSort

+ Text string

+ Tool string

+ Until time.Time

+ type SearchSort string

+ const SortDuration

+ const SortStarted

+ const SortTokens

+ type Searcher interface

+ Search func(ctx context.Context, q SearchQuery) (RunPage, error)

type Selector

+ All bool

+ type SpanKey struct

+ SpanID string

+ TraceID string

+ func DeletedSpans(all []SpanLink, deleted map[string]bool) []SpanKey

+ type SpanLink struct

+ ParentSpanID string

+ RunID string

+ SpanID string

+ TraceID string

+ type TracePage struct

+ NextBefore *time.Time

+ NextBeforeID string

+ Total int

+ Traces []TraceRow

+ type TraceQuery struct

+ Before time.Time

+ BeforeID string

+ Limit int

+ PublicID string

+ Service string

+ Since time.Time

+ Until time.Time

+ type TraceRoot struct

+ Name string

+ SpanID string

+ type TraceRow struct

+ End time.Time

+ Error bool

+ Root *TraceRoot

+ RunIDs []string

+ Service string

+ SpanCount int

+ Start time.Time

+ TraceID string

type Weft

+ Input bool

Oct 10, 2026

Changes in this version

+ var ErrStepMessages = errors.New("obsdb: the records do not rebuild the step's messages")

+ func ApplyView(transcript []core.Message, v Compaction) ([]core.Message, error)

+ func CheckToolArgs(tool string, schema, args json.RawMessage) error

+ type Assembler struct

+ func NewAssembler(batches []TranscriptBatch) *Assembler

+ func (a *Assembler) Step(requests []RequestRecord, compactions []Compaction, step int) (StepMessages, error)

type Compaction

+ func ViewOf(rec RequestRecord, compactions []Compaction) (Compaction, bool)

type HoleCause

+ const CauseResponseCap

+ type StepMessages struct

+ Derived bool

+ Messages []core.Message

+ Step int

+ View *Compaction

+ func AssembleStep(batches []TranscriptBatch, requests []RequestRecord, compactions []Compaction, ...) (StepMessages, error)

+ func MessagesAsOf(ctx context.Context, db DB, runID string, step int) (StepMessages, error)

+ type StepMessagesError struct

+ Hole Hole

+ Msg string

+ Step int

+ func (e *StepMessagesError) Error() string

+ func (e *StepMessagesError) Is(target error) bool

Oct 9, 2026

Changes in this version

type HoleCause

+ const CauseDevTokenOnly

+ const CauseNoPublicID

+ const CauseNotServed

Oct 8, 2026

Changes in this version

+ const CompactionRun

+ const CompactionSession

+ const LogSkew

+ const MaxLogCandidates

+ const ReasonCompacted

+ const RecordCompaction

+ func ExplainMissing(ctx context.Context, db DB, runID, kind, hash string) error

+ func HoleNote(h Hole) (reason, fix string)

+ func HoleNoteFor(h Hole, cause HoleCause) (reason, fix string)

+ func ParseSeverity(s string) (n int, ok bool)

+ func SeverityText(n int) string

+ func SortCompactions(cs []Compaction)

+ func TranscriptBodies(batches []TranscriptBatch) []json.RawMessage

+ type Compaction struct

+ Entries int

+ FromSeq int64

+ Hash string

+ Index int64

+ Messages json.RawMessage

+ Reason string

+ Replaced int

+ Scope string

+ Step int

+ ToSeq int64

+ TokensAfter int64

+ TokensBefore int64

+ func CompactionOf(kind string, index int64, step int, attrs map[string]any, body []byte) (c Compaction, ok bool, err error)

type DB

+ Catalogs func(ctx context.Context, runID string) ([]ToolsRecord, error)

+ Compactions func(ctx context.Context, runID string) ([]Compaction, error)

+ OtherLogs func(ctx context.Context, runID string, q LogQuery) (LogPage, error)

+ Prompt func(ctx context.Context, runID, hash string) (PromptRecord, error)

+ Requests func(ctx context.Context, runID string, q RequestQuery) ([]RequestRecord, error)

+ Tools func(ctx context.Context, runID, hash string) (ToolsRecord, error)

+ TranscriptBatches func(ctx context.Context, runID string) ([]TranscriptBatch, error)

+ type Hole string

+ const HoleCompacted

+ const HoleDerived

+ const HoleGap

+ const HoleHidden

+ const HoleInterrupted

+ const HoleMaxTokens

+ const HoleNotRecorded

+ const HoleRedacted

+ const HoleStripped

+ const HoleTruncated

+ func Holes() []Hole

+ type HoleCause string

+ const CauseDefault

+ const CauseLogCap

+ const CauseNoSpans

+ const CauseResultCap

+ func HoleCauses() []HoleCause

+ type HoleError struct

+ Hash string

+ Hole Hole

+ Kind string

+ func (e *HoleError) Error() string

+ func (e *HoleError) Is(target error) bool

+ type LogCandidates func(ctx context.Context, traceIDs []string, from, to time.Time, limit int) ([]OtherLog, error)

+ type LogPage struct

+ Gap int

+ Logs []OtherLog

+ Partial bool

+ Truncated bool

+ func ReadOtherLogs(ctx context.Context, db DB, runID string, q LogQuery, candidates LogCandidates) (LogPage, error)

+ type LogQuery struct

+ From int64

+ Limit int

+ MinSeverity int

+ func (q LogQuery) PageLimit() int

+ type OtherLog struct

+ Attrs map[string]any

+ Body string

+ EventName string

+ Index int64

+ Service string

+ Severity int

+ SpanID string

+ Time time.Time

+ TraceID string

type PosEvent

+ Content string

+ TruncatedBytes int64

+ type PromptRecord struct

+ Content Hole

+ Hash string

+ Index int64

+ Text string

+ Time time.Time

+ TruncatedBytes int64

+ func PromptRecordOf(r StoredRecord) PromptRecord

+ type RequestBody struct

+ Attempt int64

+ MessagesRef RequestMessagesRef

+ Model RequestModel

+ Params RequestParams

+ SequentialTools bool

+ Step int

+ Stream bool

+ SystemHash string

+ Thinking *RequestThinking

+ ToolChoice *RequestToolChoice

+ Tools RequestTools

+ type RequestMessagesRef struct

+ Count int

+ Index *int64

+ type RequestModel struct

+ Name string

+ Provider string

+ type RequestParams struct

+ MaxTokens *int

+ Seed *int64

+ Stop []string

+ Temperature *float64

+ TopP *float64

+ type RequestQuery struct

+ From int64

+ Limit int

+ Step *int

+ func (q RequestQuery) PageLimit() int

+ type RequestRecord struct

+ Attempt int64

+ Body RequestBody

+ CatalogHash string

+ Content Hole

+ Index int64

+ Raw json.RawMessage

+ Step int

+ SystemHash string

+ Time time.Time

+ TruncatedBytes int64

+ func RequestRecordOf(r StoredRecord) RequestRecord

+ type RequestThinking struct

+ Budget int64

+ Level string

+ type RequestToolChoice struct

+ Mode string

+ Name string

+ type RequestTools struct

+ CatalogHash string

+ Names []string

type RunRow

+ CatalogHash string

+ InstructionsHash string

+ RequestCount int64

+ func (r RunRow) RequestsHole() Hole

+ type StoredRecord struct

+ Body []byte

+ CatalogHash string

+ Content string

+ Index int64

+ Step int

+ SystemHash string

+ Time time.Time

+ TruncatedBytes int64

+ type ToolEntry struct

+ Approval bool

+ Description string

+ MaxResultBytes int

+ Name string

+ Replay string

+ Schema json.RawMessage

+ Sequential bool

+ Source string

+ TimeoutMS int64

+ type ToolsRecord struct

+ Content Hole

+ Hash string

+ Index int64

+ Time time.Time

+ Tools []ToolEntry

+ TruncatedBytes int64

+ func ToolsRecordOf(r StoredRecord) ToolsRecord

+ type TranscriptBatch struct

+ Index int64

+ Input bool

+ InputDerived bool

+ Messages json.RawMessage

+ Step int

+ func DedupBatches(batches []TranscriptBatch) []TranscriptBatch

type Weft

+ Reason string

Oct 7, 2026

Changes in this version

+ const FrameRecord

+ const FrameRun

+ const InterruptedAfter

+ const MaxGaps

+ const MaxTies

+ var ErrClosed = errors.New("obsdb: closed")

+ var ErrNotFound = errors.New("obsdb: not found")

+ func DedupTranscript(bodies []json.RawMessage) []json.RawMessage

+ func LimitOf(n int) int

+ func MetaOf(attrs map[string]any) map[string]string

+ type Batch struct

+ Records []Record

+ Spans []Span

+ type DB interface

+ Close func() error

+ Events func(ctx context.Context, runID string, after int64, limit int) (EventPage, error)

+ Experiment func(ctx context.Context, id string) (Experiment, error)

+ Experiments func(ctx context.Context) ([]Experiment, error)

+ ResolvePublicID func(ctx context.Context, publicID string) (sessionID string, err error)

+ Run func(ctx context.Context, id string) (RunDetail, error)

+ RunSpans func(ctx context.Context, runID string) ([]Span, error)

+ Runs func(ctx context.Context, q RunQuery) (RunPage, error)

+ SaveExperiment func(ctx context.Context, e Experiment) error

+ Session func(ctx context.Context, id string) (SessionDetail, error)

+ Sessions func(ctx context.Context, q SessionQuery) (SessionPage, error)

+ Trace func(ctx context.Context, traceID string) ([]Span, error)

+ Transcript func(ctx context.Context, runID string) ([]json.RawMessage, error)

+ Write func(ctx context.Context, b Batch) error

+ type EventPage struct

+ Done bool

+ Events []PosEvent

+ Gaps []int64

+ NextAfter *int64

+ type Experiment struct

+ Agent string

+ Created time.Time

+ ID string

+ Inputs []ExperimentInput

+ Name string

+ Updated time.Time

+ Variants []ExperimentVariant

+ type ExperimentInput struct

+ Key string

+ SourceRunID string

+ Text string

+ type ExperimentVariant struct

+ Key string

+ Overrides json.RawMessage

+ type Frame struct

+ Kind string

+ Record *Record

+ Run *RunRow

+ Seq uint64

+ Weft Weft

+ func RecordFrame(r Record) Frame

+ func RunFrame(r RunRow) Frame

+ type Hub interface

+ Publish func(ctx context.Context, f Frame)

+ Subscribe func(ctx context.Context, sel Selector, after uint64) (<-chan Frame, error)

+ func NewHub(opts ...HubOption) Hub

+ type HubOption interface

+ func QueueSize(n int) HubOption

+ type PosEvent struct

+ Event json.RawMessage

+ Pos int64

+ Time time.Time

+ type Record struct

+ Attrs map[string]any

+ Body string

+ EventName string

+ Observed time.Time

+ Resource map[string]any

+ Service string

+ Severity int

+ SpanID string

+ Time time.Time

+ TraceID string

+ func FromOTLPLogs(req *collogspb.ExportLogsServiceRequest) []Record

+ type RunDetail struct

+ Children []RunRow

+ type RunPage struct

+ NextBefore *time.Time

+ NextBeforeID string

+ Runs []RunRow

+ Total int

+ type RunQuery struct

+ Agent string

+ Before time.Time

+ BeforeID string

+ ExperimentID string

+ Limit int

+ Meta map[string]string

+ ParentRunID string

+ Playground *bool

+ PublicID string

+ SessionID string

+ Status Status

+ type RunRow struct

+ Agent string

+ DeltaCount int64

+ Err string

+ EventCount int64

+ ExperimentID string

+ Finished *time.Time

+ ForkedFrom string

+ ID string

+ LastSeen time.Time

+ ManifestHash string

+ MessageCount int64

+ Meta map[string]string

+ Model string

+ ParentCallID string

+ ParentRunID string

+ Pending int

+ Playground bool

+ Provider string

+ PublicID string

+ Service string

+ SessionID string

+ Started time.Time

+ Status Status

+ Steps int

+ StopReason string

+ TraceID string

+ Turn int

+ Usage core.Usage

+ WeftVersion string

+ type Selector struct

+ Agent string

+ PublicID string

+ RunID string

+ SessionID string

+ type SessionDetail struct

+ Runs []RunRow

+ type SessionPage struct

+ NextBefore *time.Time

+ NextBeforeID string

+ Sessions []SessionRow

+ Total int

+ type SessionQuery struct

+ Agent string

+ Before time.Time

+ BeforeID string

+ Limit int

+ PublicID string

+ type SessionRow struct

+ Agent string

+ FirstSeen time.Time

+ ID string

+ LastSeen time.Time

+ PublicID string

+ Status Status

+ Turns int

+ Usage core.Usage

+ type Span struct

+ Attrs map[string]any

+ End time.Time

+ Events []SpanEvent

+ Kind int

+ Name string

+ ParentSpanID string

+ Resource map[string]any

+ Service string

+ SpanID string

+ Start time.Time

+ StatusCode int

+ StatusMessage string

+ TraceID string

+ func FromOTLPTraces(req *coltracepb.ExportTraceServiceRequest) []Span

+ type SpanEvent struct

+ Attrs map[string]any

+ Name string

+ Time time.Time

+ type Status string

+ const StatusFailed

+ const StatusInterrupted

+ const StatusRunning

+ const StatusSucceeded

+ func DeriveStatus(spanFailed, runFinished bool, lastSeen, now time.Time) Status

+ type Weft struct

+ Agent string

+ EventType string

+ ExperimentID string

+ ForkedFrom string

+ ParentCallID string

+ ParentRunID string

+ Playground bool

+ Pos int64

+ PublicID string

+ Record string

+ RunID string

+ SessionID string

+ Step int

+ ToolSeq int64

+ Turn int

+ func DeriveRecord(r Record) Weft

+ func DeriveSpan(s Span) Weft