Versions in this module Expand all Collapse all v0 v0.1.0 May 20, 2026 Changes in this version + func AgentExecutor(eventLog EventLog, registry map[string]agent.Agent) agent.Executor + func AgentFunc(fn func(input []*proto.Message, tm agent.Executor, o agent.OutputHandler)) agent.Agent + func DefaultExecutor(eventLog EventLog, registry map[string]agent.Agent) agent.Executor + type EventLog interface + Append func(ctx context.Context, event *proto.ConversationEvent) (int32, error) + AppendExec func(ctx context.Context, event *proto.ExecutionEvent) error + Close func() error + DeleteEvents func(ctx context.Context, conversationID string) error + Events func(ctx context.Context, conversationID string) ([]*proto.ConversationEvent, error) + ExecEvents func(ctx context.Context, execID string) ([]*proto.ExecutionEvent, error) + type EventLogBuilder func() (EventLog, error) + type SQLiteEventLog struct + func OpenSQLiteEventLog(path string) (*SQLiteEventLog, error) + func (l *SQLiteEventLog) Append(ctx context.Context, event *proto.ConversationEvent) (int32, error) + func (l *SQLiteEventLog) AppendExec(ctx context.Context, event *proto.ExecutionEvent) error + func (l *SQLiteEventLog) Close() error + func (l *SQLiteEventLog) DeleteEvents(ctx context.Context, conversationID string) error + func (l *SQLiteEventLog) Events(ctx context.Context, conversationID string) ([]*proto.ConversationEvent, error) + func (l *SQLiteEventLog) ExecEvents(ctx context.Context, execID string) ([]*proto.ExecutionEvent, error)
Go to main page