Versions in this module Expand all Collapse all v0 v0.0.2 Sep 9, 2026 Changes in this version + const DefaultMaxEvents + const DefaultQueryLimit + const MaxCursorBytes + const MaxQueryLimit + const SchemaVersion + var ErrCASRetryLimit = errors.New("executionledger: distributed update retry limit exceeded") + var ErrConflict = errors.New("executionledger: conflict") + var ErrCorrupt = errors.New("executionledger: corrupt store") + var ErrInvalid = errors.New("executionledger: invalid input") + type AppendRequest struct + BranchID string + Error string + Iteration int + MessageID string + Model string + Outcome string + ParentID string + Reference *Reference + TaskID string + Type EventType + type AppendResult struct + Event Event + Replayed bool + type AuditAuthorizer interface + AuthorizeExecutionLedger func(context.Context, protocol.MessageAddress, protocol.ChatMessage) error + type CASStore struct + func NewCASStore(config CASStoreConfig) (*CASStore, error) + func (s *CASStore) Append(ctx context.Context, ref Ref, operationID string, request AppendRequest) (AppendResult, error) + func (s *CASStore) PinnedModel(ctx context.Context, ref Ref) (string, error) + func (s *CASStore) Query(ctx context.Context, ref Ref, query Query) (Page, error) + type CASStoreConfig struct + Blobs casblob.Store + MaxEvents int + MaxRetries int + NewID func() (string, error) + Now func() time.Time + Prefix string + type Event struct + CreatedAt string + ID string + SchemaVersion int + Sequence uint64 + SessionID string + WorkspaceID string + type EventType string + const EventContextCompacted + const EventGoalReferenced + const EventModelCallFinished + const EventModelCallStarted + const EventModelPinned + const EventRecoveryMarker + const EventRefinementReferenced + const EventSkillReferenced + const EventTurnFinished + const EventTurnStarted + const EventUserPromptSubmitted + type FileStore struct + func NewFileStore(config FileStoreConfig) (*FileStore, error) + func (s *FileStore) Append(ctx context.Context, ref Ref, operationID string, request AppendRequest) (AppendResult, error) + func (s *FileStore) PinnedModel(ctx context.Context, ref Ref) (string, error) + func (s *FileStore) Query(ctx context.Context, ref Ref, query Query) (Page, error) + type FileStoreConfig struct + MaxEvents int + NewID func() (string, error) + Now func() time.Time + StateDir string + type MemoryStore struct + func NewMemoryStore(config MemoryStoreConfig) *MemoryStore + func (s *MemoryStore) Append(ctx context.Context, ref Ref, operationID string, request AppendRequest) (AppendResult, error) + func (s *MemoryStore) PinnedModel(ctx context.Context, ref Ref) (string, error) + func (s *MemoryStore) Query(ctx context.Context, ref Ref, query Query) (Page, error) + type MemoryStoreConfig struct + MaxEvents int + NewID func() (string, error) + Now func() time.Time + type Page struct + Events []Event + NextPageToken string + ScannedCount int + type Query struct + BranchID string + Limit int + PageToken string + ReferenceID string + TaskID string + Types []EventType + type Ref struct + SessionID string + WorkspaceID string + type Reference struct + ID string + Kind string + System string + type Service struct + AuditAuthorizer AuditAuthorizer + Authority string + Store Store + func (s *Service) ObserveTurn(ctx context.Context, observed hooks.TurnEvent) + func (s *Service) PinModel(ctx context.Context, addr protocol.MessageAddress, model string) error + func (s *Service) PinnedModel(ctx context.Context, addr protocol.MessageAddress) (string, error) + func (s *Service) RunExecutionLedgerCommand(ctx context.Context, addr protocol.MessageAddress, user protocol.ChatMessage, ...) (string, error) + func (s *Service) String() string + type Store interface + Append func(ctx context.Context, ref Ref, operationID string, request AppendRequest) (AppendResult, error) + PinnedModel func(ctx context.Context, ref Ref) (string, error) + Query func(ctx context.Context, ref Ref, query Query) (Page, error)
Go to main page