events

package

Go to main page

Versions in this module

v0

v0.3.0

Aug 16, 2026

Changes in this version

+ const DenialResultText

+ func HasUnansweredMCPToolUse(ctx context.Context, q Querier, sessionID domain.ID, extraRefs []string) (bool, error)

type NewEvent

+ func DenialResults(ctx context.Context, q Querier, sessionID domain.ID, evs []NewEvent) ([]NewEvent, []string, error)

v0.2.0

Aug 7, 2026

Changes in this version

+ const InterruptResultText

+ const InterruptedExplanation

+ const MetricApprovalWait

+ const MetricCacheTokenUsage

+ const MetricSessionStatus

+ func ActiveOutcome(evals []domain.OutcomeEvaluation) (domain.OutcomeEvaluation, bool)

+ func FlipNonTerminalOutcomes(now time.Time) func([]domain.OutcomeEvaluation) ([]domain.OutcomeEvaluation, error)

+ func LatestOutcomeStartID(history []domain.Event, outcomeID domain.ID) domain.ID

+ func NewOutcomeEntry(d DefineOutcome) domain.OutcomeEvaluation

+ func NotifyWorkEnqueued(ctx context.Context, db Execer, envID domain.ID) error

+ func RecordApprovalWait(ctx context.Context, seconds float64)

+ func RecordSessionStatus(ctx context.Context, status domain.SessionStatus)

+ func RubricSnapshotKey(outcomeID domain.ID) string

+ func UnansweredPlatformToolNames(ctx context.Context, q Querier, sessionID domain.ID, extraRefs []string) ([]string, error)

+ func ValidateDefineOutcomes(ctx context.Context, tx pgx.Tx, sessionID domain.ID, evs []NewEvent, ...) error

type AppendOptions

+ MutateOutcomes func([]domain.OutcomeEvaluation) ([]domain.OutcomeEvaluation, error)

+ type Backend struct

+ Model string

+ Provider string

+ type DefineOutcome struct

+ Description string

+ MaxIterations int64

+ OutcomeID domain.ID

+ RubricContent string

+ RubricFileID string

+ RubricType string

+ func DefineOutcomes(evs []NewEvent) ([]DefineOutcome, error)

+ func FindDefineOutcome(history []domain.Event, outcomeID domain.ID) (DefineOutcome, bool)

+ func ParseDefineOutcome(payload json.RawMessage) (DefineOutcome, error)

+ type Execer interface

+ Exec func(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

type Log

+ func (l *Log) StartOutcomeEvaluation(ctx context.Context, sessionID domain.ID, outcomeID domain.ID, iteration int64, ...) (context.Context, *OutcomeEvaluation)

type ModelRequest

+ func (m *ModelRequest) ModelDone(usage *domain.ModelUsage)

+ func (m *ModelRequest) SetAttributes(attrs ...attribute.KeyValue)

type NewEvent

+ func InterruptOutcomes(ctx context.Context, tx pgx.Tx, sessionID domain.ID) ([]NewEvent, bool, error)

+ func InterruptResults(uses []ToolUseRef) ([]NewEvent, error)

+ func NewOutcomeStartEvent(outcomeID domain.ID, iteration int64) (NewEvent, error)

+ type OutcomeEvaluation struct

+ func (o *OutcomeEvaluation) EndEvent(result, explanation string, usage domain.ModelUsage) (NewEvent, error)

+ func (o *OutcomeEvaluation) Finish(result string, commitErr error)

+ func (o *OutcomeEvaluation) Heartbeat(ctx context.Context) error

+ type ToolUseRef struct

+ ID string

+ Type domain.EventType

+ func UnansweredToolUses(ctx context.Context, q Querier, sessionID domain.ID, extraRefs []string) ([]ToolUseRef, error)

v0.1.0

Jul 16, 2026

Changes in this version

+ var ErrSessionArchived = errors.New("session is archived")

+ var ErrSessionNotFound = errors.New("session not found")

+ func HasUnansweredPlatformToolUse(ctx context.Context, q Querier, sessionID domain.ID, extraRefs []string) (bool, error)

+ func HasUnansweredToolUse(ctx context.Context, q Querier, sessionID domain.ID, extraRefs []string) (bool, error)

+ func Previewable(t domain.EventType) bool

+ func ToolConfirmationRefs(evs []NewEvent) []string

+ func ToolResultRefs(evs []NewEvent) []string

+ func UnconfirmedAskEvents(ctx context.Context, q Querier, sessionID domain.ID, extraConfirmed []string) ([]string, error)

+ func ValidateToolConfirmations(ctx context.Context, q Querier, sessionID domain.ID, evs []NewEvent) error

+ func ValidateToolResults(ctx context.Context, q Querier, sessionID domain.ID, evs []NewEvent) error

+ type AppendOptions struct

+ AddUsage *domain.ModelUsage

+ MarkProcessedThrough int64

+ SetStatus *domain.SessionStatus

+ Then func(ctx context.Context, tx pgx.Tx) error

+ type Broker struct

+ func NewBroker(pool *pgxpool.Pool) *Broker

+ func (b *Broker) Ready(ctx context.Context) error

+ func (b *Broker) Subscribe(sessionID domain.ID) *Subscription

+ type ListQuery struct

+ AfterSeq *int64

+ CreatedGT *time.Time

+ CreatedGTE *time.Time

+ CreatedLT *time.Time

+ CreatedLTE *time.Time

+ Desc bool

+ Limit int

+ Types []string

+ type Log struct

+ func NewLog(pool *pgxpool.Pool) *Log

+ func (l *Log) Append(ctx context.Context, sessionID domain.ID, evs []NewEvent) ([]domain.Event, error)

+ func (l *Log) AppendInTx(ctx context.Context, tx pgx.Tx, sessionID domain.ID, evs []NewEvent, ...) ([]domain.Event, error)

+ func (l *Log) AppendWith(ctx context.Context, sessionID domain.ID, evs []NewEvent, opts AppendOptions) ([]domain.Event, error)

+ func (l *Log) List(ctx context.Context, sessionID domain.ID, q ListQuery) ([]domain.Event, error)

+ func (l *Log) PublishEventFrame(ctx context.Context, sessionID domain.ID, event map[string]any) error

+ func (l *Log) StartModelRequest(ctx context.Context, sessionID domain.ID) (context.Context, *ModelRequest, error)

+ func (l *Log) StartPreview(ctx context.Context, sessionID domain.ID, typ domain.EventType) (*Preview, error)

+ type ModelRequest struct

+ func (m *ModelRequest) EndEvent(isError bool, usage domain.ModelUsage) (NewEvent, error)

+ func (m *ModelRequest) Finish(isError bool, commitErr error)

+ func (m *ModelRequest) StartEventID() domain.ID

+ type NewEvent struct

+ ID domain.ID

+ Payload json.RawMessage

+ ProcessedAt *time.Time

+ Type domain.EventType

+ func NormalizeInbound(envKind string, raws []json.RawMessage) ([]NewEvent, error)

+ type Preview struct

+ func (p *Preview) Delta(ctx context.Context, index int64, text string) error

+ func (p *Preview) EventID() domain.ID

+ type Querier interface

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

+ type Subscription struct

+ func (s *Subscription) Close()

+ func (s *Subscription) Frames() <-chan json.RawMessage

+ func (s *Subscription) Wake() <-chan struct{}

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