transcript

Aug 18, 2026

Changes in this version

type AzureBlobSyncerConfig

+ MaxBytesPerSecond int64

+ Sleep func(context.Context, time.Duration) error

Aug 18, 2026

Changes in this version

type AzureBlobSyncerConfig

+ Backoff func(attempt int) time.Duration

Aug 18, 2026

Changes in this version

+ type AzureBlobSyncer struct

+ func NewAzureBlobSyncer(config AzureBlobSyncerConfig) *AzureBlobSyncer

+ func (s *AzureBlobSyncer) Destination() string

+ func (s *AzureBlobSyncer) Enabled() bool

+ func (s *AzureBlobSyncer) Run(ctx context.Context)

+ func (s *AzureBlobSyncer) SyncOnce(ctx context.Context) error

+ type AzureBlobSyncerConfig struct

+ AccountKey string

+ Client *http.Client

+ Destination string

+ Interval time.Duration

+ LocalRetention time.Duration

+ Logger *slog.Logger

+ MaxLocalBytes int64

+ Now func() time.Time

+ SASToken string

+ SourceDir string

+ Timeout time.Duration

Jun 15, 2026

Changes in this version

type GCSSyncerConfig

+ LocalRetention time.Duration

+ MaxLocalBytes int64

type Recorder

+ func (r *Recorder) RecordPayloadChunk(agentType, sessionID, eventType, direction, streamID string, chunkIndex int, ...)

+ func (r *Recorder) RecordPayloadSummary(agentType, sessionID, eventType, direction, streamID string, bytesRead int64, ...)

May 4, 2026

Changes in this version

+ func BaseSessionID(sessionID string) string

+ func RedactedHeaders(headers http.Header) map[string][]string

+ func SessionPath(dir, agentType, sessionID string) string

+ type Analytics struct

+ ByAccount []UsageGroup

+ ByModel []UsageGroup

+ ByUser []UsageGroup

+ MaxAccountTokens int64

+ MaxTimelineTokens int64

+ MaxUserTokens int64

+ Timeline []UsageBucket

+ Totals Usage

+ func Analyze(dir string) (Analytics, error)

+ type Event struct

+ Payload map[string]any

+ Timestamp string

+ Type string

+ type GCSSyncer struct

+ func NewGCSSyncer(config GCSSyncerConfig) *GCSSyncer

+ func (s *GCSSyncer) Enabled() bool

+ func (s *GCSSyncer) Run(ctx context.Context)

+ func (s *GCSSyncer) SyncOnce(ctx context.Context) error

+ type GCSSyncerConfig struct

+ Command string

+ Destination string

+ Interval time.Duration

+ Logger *slog.Logger

+ SourceDir string

+ Timeout time.Duration

+ type RawEvent struct

+ BodyBase64 string

+ BodyText string

+ Payload map[string]any

+ Timestamp string

+ Type string

+ func ReadRawSession(dir, agentType, sessionID string) ([]RawEvent, error)

+ type Recorder struct

+ func NewRecorder(dir string) *Recorder

+ func (r *Recorder) Dir() string

+ func (r *Recorder) Enabled() bool

+ func (r *Recorder) PathForSession(agentType, sessionID string) string

+ func (r *Recorder) RecordMeta(agentType, sessionID string, payload map[string]any)

+ func (r *Recorder) RecordPayload(agentType, sessionID, eventType, direction string, body []byte, ...)

+ type SanitizedEvent struct

+ Payload map[string]any

+ Timestamp string

+ Type string

+ func ReadSanitizedSession(dir, agentType, sessionID string) ([]SanitizedEvent, error)

+ type Summary struct

+ Account string

+ AgentType string

+ EventCount int

+ FirstEventAt string

+ HasBodies bool

+ LastEventAt string

+ SessionID string

+ SizeBytes int64

+ TotalBytes int64

+ Usage Usage

+ User string

+ func ListSummaries(dir string) ([]Summary, error)

+ type Usage struct

+ CachedInputTokens int64

+ InputTokens int64

+ OutputTokens int64

+ PayloadBytes int64

+ ReasoningTokens int64

+ Requests int64

+ TotalTokens int64

+ type UsageBucket struct

+ Label string

+ Start string

+ Usage Usage

+ type UsageGroup struct

+ Key string

+ Usage Usage