Versions in this module Expand all Collapse all v0 v0.1.0 Aug 9, 2026 Changes in this version + func IsReservedRuntimeStateKey(key string) bool + func StripPlanKeys(state map[string]any) + type AppliedCheckpoint struct + InterruptToRequester map[string]string + PendingToolCalls map[string]stores.PendingToolCall + Window []*streaming.Message + type Checkpointer struct + func NewCheckpointer() Checkpointer + func (Checkpointer) Apply(cp stores.SessionCheckpoint, sm *SessionManager) (AppliedCheckpoint, error) + func (Checkpointer) Capture(window []*streaming.Message, sm *SessionManager, ...) (*stores.SessionCheckpoint, error) + type PlanStore struct + func NewPlanStore() *PlanStore + func (p *PlanStore) ConsumeDocumentUpdated() bool + func (p *PlanStore) Document() string + func (p *PlanStore) ExportInto(state map[string]any) + func (p *PlanStore) Get() []Todo + func (p *PlanStore) HasActive() bool + func (p *PlanStore) LoadFromState(state map[string]any) + func (p *PlanStore) Set(todos []Todo) + func (p *PlanStore) SetDocument(plan string) + type Runtime struct + CurrentToolCallID string + Store stores.BaseStore + func NewRuntime(ch chan streaming.StreamEvent, store stores.BaseStore, sm *SessionManager) Runtime + func (rt Runtime) AdoptInterrupt(intr interrupt.Interrupt) (interrupt.Interrupt, error) + func (rt Runtime) EmitPlanUpdate(plan []Todo) + func (rt Runtime) EmitUpdate(message string) + func (rt Runtime) HasPendingInterrupt() bool + func (rt Runtime) PendingInterrupt(id string) (interrupt.Interrupt, bool) + func (rt Runtime) RaiseInterrupt(kind string, payload []byte) (interrupt.Interrupt, error) + func (rt Runtime) ReturnInterrupt(id string, result []byte) (interrupt.Interrupt, error) + func (rt Runtime) StateDelete(key string) + func (rt Runtime) StateGet(key string) (any, bool) + func (rt Runtime) StateSet(key string, value any) + func (rt Runtime) TakeResolvedInterrupt(id string) (interrupt.Interrupt, bool) + type SessionManager struct + func NewSessionManager() *SessionManager + func (s *SessionManager) ClearInterrupts() + func (s *SessionManager) HasActivePlan() bool + func (s *SessionManager) HasPendingInterrupt() bool + func (s *SessionManager) LoadInterruptsJSON(pendingJSON, resolvedJSON []byte) error + func (s *SessionManager) LoadUserAndPlanState(state map[string]any) + func (s *SessionManager) PendingInterrupt(id string) (interrupt.Interrupt, bool) + func (s *SessionManager) Plan() *PlanStore + func (s *SessionManager) ReturnInterrupt(id string, result []byte) (interrupt.Interrupt, error) + func (s *SessionManager) SnapshotDurable() (runtimeState map[string]any, pending, resolved interruptMap) + func (s *SessionManager) StateDelete(key string) + func (s *SessionManager) StateGet(key string) (any, bool) + func (s *SessionManager) StateSet(key string, value any) + type Todo = streaming.Todo
Go to main page