events

package

Go to main page

Versions in this module

v1

v1.2.0

Feb 15, 2026

v1.1.11

Feb 15, 2026

v1.1.10

Jan 27, 2026

v1.1.9

Jan 24, 2026

Changes in this version

type MessageCreatedData

+ Parts []types.ContentPart

v1.1.8

Jan 15, 2026

v1.1.7

Jan 10, 2026

v1.1.6

Dec 23, 2025

Changes in this version

+ func ExportSession(ctx context.Context, session *AnnotatedSession, outputPath string, ...) error

+ type AnnotatedSession struct

+ Annotations []*annotations.Annotation

+ Events []*Event

+ Metadata SessionMetadata

+ SessionID string

+ Timeline *MediaTimeline

+ func (s *AnnotatedSession) BuildTimelineView() *TimelineView

+ func (s *AnnotatedSession) GetAnnotationsByType(annotType annotations.AnnotationType) []*annotations.Annotation

+ func (s *AnnotatedSession) GetAnnotationsForEvent(eventIndex int) []*annotations.Annotation

+ func (s *AnnotatedSession) GetAnnotationsInTimeRange(start, end time.Duration) []*annotations.Annotation

+ func (s *AnnotatedSession) GetConversationMessages() []*Event

+ func (s *AnnotatedSession) GetEventsByType(eventType EventType) []*Event

+ func (s *AnnotatedSession) GetTranscriptions() []*Event

+ func (s *AnnotatedSession) NewSyncPlayer(config *SyncPlayerConfig) *SyncPlayer

+ func (s *AnnotatedSession) Summary() string

+ type AnnotatedSessionLoader struct

+ func NewAnnotatedSessionLoader(eventStore EventStore, blobStore BlobStore, annotStore annotations.Store) *AnnotatedSessionLoader

+ func (l *AnnotatedSessionLoader) Load(ctx context.Context, sessionID string) (*AnnotatedSession, error)

+ func (l *AnnotatedSessionLoader) WithMetadata(compute bool) *AnnotatedSessionLoader

+ type AnnotationHandler func(annotation *annotations.Annotation, position time.Duration)

+ type AudioHandler func(data []byte, track TrackType, position time.Duration) bool

+ type AudioInputData struct

+ Actor string

+ ChunkIndex int

+ IsFinal bool

+ Metadata AudioMetadata

+ Payload BinaryPayload

+ TurnID string

+ type AudioMetadata struct

+ BitsPerSample int

+ Channels int

+ DurationMs int64

+ Encoding string

+ SampleRate int

+ type AudioOutputData struct

+ ChunkIndex int

+ GeneratedFrom string

+ IsFinal bool

+ Metadata AudioMetadata

+ Payload BinaryPayload

+ TurnID string

+ type AudioTranscriptionData struct

+ AudioEventID string

+ Confidence float64

+ IsFinal bool

+ Language string

+ Provider string

+ Text string

+ TurnID string

+ type BinaryPayload struct

+ Checksum string

+ InlineData []byte

+ MIMEType string

+ Size int64

+ StorageRef string

+ type BlobStore interface

+ Close func() error

+ Delete func(ctx context.Context, ref string) error

+ Load func(ctx context.Context, ref string) ([]byte, error)

+ LoadReader func(ctx context.Context, ref string) (io.ReadCloser, error)

+ Store func(ctx context.Context, sessionID string, data []byte, mimeType string) (*BinaryPayload, error)

+ StoreReader func(ctx context.Context, sessionID string, r io.Reader, mimeType string) (*BinaryPayload, error)

type Emitter

+ func (e *Emitter) AudioInput(data *AudioInputData)

+ func (e *Emitter) AudioOutput(data *AudioOutputData)

+ func (e *Emitter) StageCompleted(name string, index int, duration time.Duration)

+ func (e *Emitter) StageFailed(name string, index int, err error, duration time.Duration)

+ func (e *Emitter) StageStarted(name string, index int, stageType interface{})

type EventBus

+ func (eb *EventBus) Store() EventStore

+ func (eb *EventBus) WithStore(store EventStore) *EventBus

+ type EventFilter struct

+ ConversationID string

+ Limit int

+ RunID string

+ SessionID string

+ Since time.Time

+ Types []EventType

+ Until time.Time

+ type EventStore interface

+ Append func(ctx context.Context, event *Event) error

+ Close func() error

+ Query func(ctx context.Context, filter *EventFilter) ([]*Event, error)

+ QueryRaw func(ctx context.Context, filter *EventFilter) ([]*StoredEvent, error)

+ Stream func(ctx context.Context, sessionID string) (<-chan *Event, error)

+ type EventStoreWithBlobs struct

+ func NewEventStoreWithBlobs(dir string) (*EventStoreWithBlobs, error)

+ func (s *EventStoreWithBlobs) Close() error

type EventType

+ const EventAudioInput

+ const EventAudioOutput

+ const EventAudioTranscription

+ const EventImageInput

+ const EventImageOutput

+ const EventScreenshot

+ const EventStageCompleted

+ const EventStageFailed

+ const EventStageStarted

+ const EventVideoFrame

+ type ExportConfig struct

+ AudioMix string

+ EndTime time.Duration

+ FFmpegPath string

+ FontSize int

+ Format ExportFormat

+ IncludeAnnotations bool

+ IncludeEvents bool

+ IncludeTranscriptions bool

+ OnProgress func(progress float64)

+ OutputPath string

+ StartTime time.Duration

+ VideoHeight int

+ VideoWidth int

+ func DefaultExportConfig(outputPath string) *ExportConfig

+ type ExportFormat string

+ const ExportFormatJSON

+ const ExportFormatMP3

+ const ExportFormatMP4

+ const ExportFormatWAV

+ const ExportFormatWebM

+ type FileBlobStore struct

+ func NewFileBlobStore(dir string) (*FileBlobStore, error)

+ func (s *FileBlobStore) Close() error

+ func (s *FileBlobStore) Delete(ctx context.Context, ref string) error

+ func (s *FileBlobStore) Load(ctx context.Context, ref string) ([]byte, error)

+ func (s *FileBlobStore) LoadReader(ctx context.Context, ref string) (io.ReadCloser, error)

+ func (s *FileBlobStore) Store(ctx context.Context, sessionID string, data []byte, mimeType string) (*BinaryPayload, error)

+ func (s *FileBlobStore) StoreReader(ctx context.Context, sessionID string, r io.Reader, mimeType string) (*BinaryPayload, error)

+ type FileEventStore struct

+ func NewFileEventStore(dir string) (*FileEventStore, error)

+ func (s *FileEventStore) Append(ctx context.Context, event *Event) error

+ func (s *FileEventStore) Close() error

+ func (s *FileEventStore) Query(ctx context.Context, filter *EventFilter) ([]*Event, error)

+ func (s *FileEventStore) QueryRaw(ctx context.Context, filter *EventFilter) ([]*StoredEvent, error)

+ func (s *FileEventStore) Stream(ctx context.Context, sessionID string) (<-chan *Event, error)

+ func (s *FileEventStore) Sync() error

+ type ImageInputData struct

+ Actor string

+ Description string

+ Metadata VideoMetadata

+ Payload BinaryPayload

+ type ImageOutputData struct

+ GeneratedFrom string

+ Metadata VideoMetadata

+ Payload BinaryPayload

+ Prompt string

+ type JSONSegment struct

+ Duration float64

+ Size int64

+ StartTime float64

+ StorageRef string

+ type JSONTimeline struct

+ Duration float64

+ Events []JSONTimelineItem

+ Metadata SessionMetadata

+ SessionID string

+ Tracks []JSONTrack

+ type JSONTimelineItem struct

+ Data map[string]interface{}

+ Duration float64

+ Time float64

+ Type string

+ type JSONTrack struct

+ Duration float64

+ Segments []JSONSegment

+ Type string

+ type MediaSegment struct

+ ChunkIndex int

+ Duration time.Duration

+ EventIndex int

+ Metadata interface{}

+ Payload *BinaryPayload

+ StartTime time.Duration

+ type MediaTimeline struct

+ Events []*Event

+ SessionEnd time.Time

+ SessionID string

+ SessionStart time.Time

+ Tracks map[TrackType]*MediaTrack

+ func LoadMediaTimeline(ctx context.Context, store EventStore, blobStore BlobStore, sessionID string) (*MediaTimeline, error)

+ func NewMediaTimeline(sessionID string, events []*Event, blobStore BlobStore) *MediaTimeline

+ func (mt *MediaTimeline) Duration() time.Duration

+ func (mt *MediaTimeline) ExportAudioToWAV(trackType TrackType, path string) error

+ func (mt *MediaTimeline) GetTrack(trackType TrackType) *MediaTrack

+ func (mt *MediaTimeline) HasTrack(trackType TrackType) bool

+ func (mt *MediaTimeline) NewMixedAudioReader() (*MixedAudioReader, error)

+ func (mt *MediaTimeline) NewTrackReader(trackType TrackType) (*TrackReader, error)

+ type MediaTrack struct

+ Format interface{}

+ Segments []*MediaSegment

+ TotalDuration time.Duration

+ Type TrackType

+ func (t *MediaTrack) ExportToWAV(path string, blobStore BlobStore) error

+ func (t *MediaTrack) OffsetInSegment(offset time.Duration) (*MediaSegment, time.Duration)

+ type MixedAudioReader struct

+ func (r *MixedAudioReader) Channels() int

+ func (r *MixedAudioReader) Close() error

+ func (r *MixedAudioReader) Position() time.Duration

+ func (r *MixedAudioReader) SampleRate() int

+ func (r *MixedAudioReader) Seek(offset time.Duration) error

+ type PlayerCallback func(event *Event, position time.Duration) bool

+ type PlayerConfig struct

+ OnComplete func()

+ OnError func(err error)

+ OnEvent PlayerCallback

+ OnStateChange func(state PlayerState)

+ SkipTiming bool

+ Speed float64

+ func DefaultPlayerConfig() *PlayerConfig

+ type PlayerState int

+ const PlayerStatePaused

+ const PlayerStatePlaying

+ const PlayerStateStopped

+ type Rect struct

+ Height int

+ Width int

+ X int

+ Y int

+ type ScreenshotData struct

+ Metadata VideoMetadata

+ Payload BinaryPayload

+ Reason string

+ WindowBounds *Rect

+ WindowTitle string

+ type SerializableEvent struct

+ ConversationID string

+ Data json.RawMessage

+ DataType string

+ RunID string

+ SessionID string

+ Timestamp time.Time

+ Type EventType

+ func (se *SerializableEvent) RawData() json.RawMessage

+ type SessionExporter struct

+ func NewSessionExporter(session *AnnotatedSession, config *ExportConfig) *SessionExporter

+ func (e *SessionExporter) Export(ctx context.Context) error

+ type SessionMetadata struct

+ AnnotationCounts map[annotations.AnnotationType]int

+ ConversationTurns int

+ Duration time.Duration

+ EndTime time.Time

+ EventCounts map[EventType]int

+ HasAudioInput bool

+ HasAudioOutput bool

+ HasVideo bool

+ ProviderCalls int

+ StartTime time.Time

+ ToolCalls int

+ TotalAudioInputDuration time.Duration

+ TotalAudioOutputDuration time.Duration

+ type SessionPlayer struct

+ func NewSessionPlayer(store EventStore, sessionID string, config *PlayerConfig) *SessionPlayer

+ func (p *SessionPlayer) CurrentTime() time.Duration

+ func (p *SessionPlayer) Duration() time.Duration

+ func (p *SessionPlayer) EventCount() int

+ func (p *SessionPlayer) Events() []*Event

+ func (p *SessionPlayer) Load(ctx context.Context) error

+ func (p *SessionPlayer) Pause()

+ func (p *SessionPlayer) Play(ctx context.Context)

+ func (p *SessionPlayer) Position() int

+ func (p *SessionPlayer) Seek(position time.Duration)

+ func (p *SessionPlayer) SeekToEvent(index int)

+ func (p *SessionPlayer) SetSpeed(speed float64)

+ func (p *SessionPlayer) State() PlayerState

+ func (p *SessionPlayer) Stop()

+ func (p *SessionPlayer) Wait()

+ type StageCompletedData struct

+ Duration time.Duration

+ Index int

+ Name string

+ StageType string

+ type StageFailedData struct

+ Duration time.Duration

+ Error error

+ Index int

+ Name string

+ StageType string

+ type StageStartedData struct

+ Index int

+ Name string

+ StageType string

+ type StoredEvent struct

+ Event *SerializableEvent

+ ParentID int64

+ Sequence int64

+ type SyncPlayer struct

+ func NewSyncPlayer(timeline *MediaTimeline, annots []*annotations.Annotation, ...) *SyncPlayer

+ func (p *SyncPlayer) AnnotationCount() int

+ func (p *SyncPlayer) Annotations() []*annotations.Annotation

+ func (p *SyncPlayer) Duration() time.Duration

+ func (p *SyncPlayer) EventCount() int

+ func (p *SyncPlayer) GetAnnotationsInRange(start, end time.Duration) []*annotations.Annotation

+ func (p *SyncPlayer) GetEventsInRange(start, end time.Duration) []*Event

+ func (p *SyncPlayer) Pause()

+ func (p *SyncPlayer) Play(ctx context.Context) error

+ func (p *SyncPlayer) Position() time.Duration

+ func (p *SyncPlayer) Seek(position time.Duration) error

+ func (p *SyncPlayer) SetSpeed(speed float64)

+ func (p *SyncPlayer) State() PlayerState

+ func (p *SyncPlayer) Stop()

+ func (p *SyncPlayer) Timeline() *MediaTimeline

+ func (p *SyncPlayer) Wait()

+ type SyncPlayerConfig struct

+ AudioBufferSize int

+ OnAnnotation AnnotationHandler

+ OnAudio AudioHandler

+ OnComplete func()

+ OnError func(err error)

+ OnEvent PlayerCallback

+ OnStateChange func(state PlayerState)

+ SkipTiming bool

+ Speed float64

+ func DefaultSyncPlayerConfig() *SyncPlayerConfig

+ type TimelineBuilder struct

+ func NewTimelineBuilder(sessionID string, blobStore BlobStore) *TimelineBuilder

+ func (b *TimelineBuilder) AddEvent(event *Event)

+ func (b *TimelineBuilder) Build() *MediaTimeline

+ type TimelineItem struct

+ Annotation *annotations.Annotation

+ Duration time.Duration

+ Event *Event

+ Segment *MediaSegment

+ Time time.Duration

+ Track TrackType

+ Type TimelineItemType

+ type TimelineItemType int

+ const TimelineItemAnnotation

+ const TimelineItemEvent

+ const TimelineItemMedia

+ type TimelineView struct

+ Items []TimelineItem

+ type TrackReader struct

+ func (r *TrackReader) Close() error

+ func (r *TrackReader) Position() time.Duration

+ func (r *TrackReader) Read(p []byte) (n int, err error)

+ func (r *TrackReader) Seek(offset time.Duration) error

+ type TrackType string

+ const TrackAudioInput

+ const TrackAudioOutput

+ const TrackVideo

+ type VideoFrameData struct

+ FrameIndex int64

+ IsKeyframe bool

+ Metadata VideoMetadata

+ Payload BinaryPayload

+ TimestampMs int64

+ type VideoMetadata struct

+ DurationMs int64

+ Encoding string

+ FrameRate float64

+ Height int

+ Width int

v1.1.5

Dec 9, 2025

Changes in this version

+ type ConversationStartedData struct

+ SystemPrompt string

type Emitter

+ func (e *Emitter) ConversationStarted(systemPrompt string)

+ func (e *Emitter) MessageCreated(role, content string, index int, toolCalls []MessageToolCall, ...)

+ func (e *Emitter) MessageUpdated(index int, latencyMs int64, inputTokens, outputTokens int, totalCost float64)

type EventType

+ const EventConversationStarted

+ const EventMessageCreated

+ const EventMessageUpdated

+ type MessageCreatedData struct

+ Content string

+ Index int

+ Role string

+ ToolCalls []MessageToolCall

+ ToolResult *MessageToolResult

+ type MessageToolCall struct

+ Args string

+ ID string

+ Name string

+ type MessageToolResult struct

+ Content string

+ Error string

+ ID string

+ LatencyMs int64

+ Name string

+ type MessageUpdatedData struct

+ Index int

+ InputTokens int

+ LatencyMs int64

+ OutputTokens int

+ TotalCost float64

v1.1.4

Dec 5, 2025

Changes in this version

+ type ContextBuiltData struct

+ MessageCount int

+ TokenBudget int

+ TokenCount int

+ Truncated bool

+ type CustomEventData struct

+ Data map[string]interface{}

+ EventName string

+ Message string

+ MiddlewareName string

+ type Emitter struct

+ func NewEmitter(bus *EventBus, runID, sessionID, conversationID string) *Emitter

+ func (e *Emitter) ContextBuilt(messageCount, tokenCount, tokenBudget int, truncated bool)

+ func (e *Emitter) EmitCustom(eventType EventType, middlewareName, eventName string, ...)

+ func (e *Emitter) MiddlewareCompleted(name string, index int, duration time.Duration)

+ func (e *Emitter) MiddlewareFailed(name string, index int, err error, duration time.Duration)

+ func (e *Emitter) MiddlewareStarted(name string, index int)

+ func (e *Emitter) PipelineCompleted(duration time.Duration, totalCost float64, ...)

+ func (e *Emitter) PipelineFailed(err error, duration time.Duration)

+ func (e *Emitter) PipelineStarted(middlewareCount int)

+ func (e *Emitter) ProviderCallCompleted(data *ProviderCallCompletedData)

+ func (e *Emitter) ProviderCallFailed(provider, model string, err error, duration time.Duration)

+ func (e *Emitter) ProviderCallStarted(provider, model string, messageCount, toolCount int)

+ func (e *Emitter) StateLoaded(conversationID string, messageCount int)

+ func (e *Emitter) StateSaved(conversationID string, messageCount int)

+ func (e *Emitter) StreamInterrupted(reason string)

+ func (e *Emitter) TokenBudgetExceeded(required, budget, excess int)

+ func (e *Emitter) ToolCallCompleted(toolName, callID string, duration time.Duration, status string)

+ func (e *Emitter) ToolCallFailed(toolName, callID string, err error, duration time.Duration)

+ func (e *Emitter) ToolCallStarted(toolName, callID string, args map[string]interface{})

+ func (e *Emitter) ValidationFailed(validatorName, validatorType string, err error, duration time.Duration, ...)

+ func (e *Emitter) ValidationPassed(validatorName, validatorType string, duration time.Duration)

+ func (e *Emitter) ValidationStarted(validatorName, validatorType string)

+ type Event struct

+ ConversationID string

+ Data EventData

+ RunID string

+ SessionID string

+ Timestamp time.Time

+ Type EventType

+ type EventBus struct

+ func NewEventBus() *EventBus

+ func (eb *EventBus) Clear()

+ func (eb *EventBus) Publish(event *Event)

+ func (eb *EventBus) Subscribe(eventType EventType, listener Listener)

+ func (eb *EventBus) SubscribeAll(listener Listener)

+ type EventData interface

+ type EventType string

+ const EventContextBuilt

+ const EventMiddlewareCompleted

+ const EventMiddlewareFailed

+ const EventMiddlewareStarted

+ const EventPipelineCompleted

+ const EventPipelineFailed

+ const EventPipelineStarted

+ const EventProviderCallCompleted

+ const EventProviderCallFailed

+ const EventProviderCallStarted

+ const EventStateLoaded

+ const EventStateSaved

+ const EventStreamInterrupted

+ const EventTokenBudgetExceeded

+ const EventToolCallCompleted

+ const EventToolCallFailed

+ const EventToolCallStarted

+ const EventValidationFailed

+ const EventValidationPassed

+ const EventValidationStarted

+ type Listener func(*Event)

+ type MiddlewareCompletedData struct

+ Duration time.Duration

+ Index int

+ Name string

+ type MiddlewareFailedData struct

+ Duration time.Duration

+ Error error

+ Index int

+ Name string

+ type MiddlewareStartedData struct

+ Index int

+ Name string

+ type PipelineCompletedData struct

+ Duration time.Duration

+ InputTokens int

+ MessageCount int

+ OutputTokens int

+ TotalCost float64

+ type PipelineFailedData struct

+ Duration time.Duration

+ Error error

+ type PipelineStartedData struct

+ MiddlewareCount int

+ type ProviderCallCompletedData struct

+ CachedTokens int

+ Cost float64

+ Duration time.Duration

+ FinishReason string

+ InputTokens int

+ Model string

+ OutputTokens int

+ Provider string

+ ToolCallCount int

+ type ProviderCallFailedData struct

+ Duration time.Duration

+ Error error

+ Model string

+ Provider string

+ type ProviderCallStartedData struct

+ MessageCount int

+ Model string

+ Provider string

+ ToolCount int

+ type StateLoadedData struct

+ ConversationID string

+ MessageCount int

+ type StateSavedData struct

+ ConversationID string

+ MessageCount int

+ type StreamInterruptedData struct

+ Reason string

+ type TokenBudgetExceededData struct

+ Budget int

+ Excess int

+ RequiredTokens int

+ type ToolCallCompletedData struct

+ CallID string

+ Duration time.Duration

+ Status string

+ ToolName string

+ type ToolCallFailedData struct

+ CallID string

+ Duration time.Duration

+ Error error

+ ToolName string

+ type ToolCallStartedData struct

+ Args map[string]interface{}

+ CallID string

+ ToolName string

+ type ValidationFailedData struct

+ Duration time.Duration

+ Error error

+ ValidatorName string

+ ValidatorType string

+ Violations []string

+ type ValidationPassedData struct

+ Duration time.Duration

+ ValidatorName string

+ ValidatorType string

+ type ValidationStartedData struct

+ ValidatorName string

+ ValidatorType string

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