transcript

package

Go to main page

Versions in this module

v0

v0.4.0

Aug 17, 2026

Changes in this version

+ const RedactionApproverDigest

+ const RedactionNone

+ type ExportMeta struct

+ ExportedAt time.Time

+ Records int

+ Redaction string

+ Schema string

+ Session string

+ Since *time.Time

+ Source string

+ Tool string

+ Until *time.Time

+ Version string

+ Warning string

+ Workload string

+ type ExportOptions struct

+ IncludeApprover bool

+ Now func() time.Time

+ SessionID string

+ Since time.Time

+ Source string

+ Until time.Time

+ UserID string

+ Workload string

+ type ScheduleRecord struct

+ Anchor time.Time

+ Fires int

+ Interval string

+ LastFire time.Time

+ LastTick time.Time

+ Workload string

type Store

+ func (s *Store) Decisions(ctx context.Context, userID, sessionID string) ([]approval.Decision, error)

+ func (s *Store) ExportDecisions(ctx context.Context, w io.Writer, opts ExportOptions) (int, error)

+ func (s *Store) SaveSchedule(ctx context.Context, userID string, rec ScheduleRecord) error

+ func (s *Store) Schedule(ctx context.Context, userID, workload string) *ScheduleRecord

v0.3.0

Aug 14, 2026

Changes in this version

type Detail

+ AppliedEdits []approval.AppliedEdit

v0.2.0

Aug 10, 2026

Changes in this version

+ const DefaultTokenTTL

+ const PlaneGate

+ const PlaneInterrupt

+ var ErrAlreadyResumed = errors.New("pause already resumed")

+ var ErrTokenExpired = errors.New("resume token expired (the pause remains; extend-token is the recovery)")

+ var ErrTokenNotFound = fmt.Errorf("resume token not found: %w", ErrNotFound)

+ func ValidReasons() []string

type Detail

+ GatePause *PauseRecord

+ type InterruptedCandidate struct

+ EventCount int

+ Events adksession.Events

+ InterruptReason string

+ InterruptedAt time.Time

+ LastEventTime time.Time

+ SessionID string

+ UserID string

+ type PauseHandle struct

+ ExpiresAt time.Time

+ SessionID string

+ Token string

+ type PauseRecord struct

+ App string

+ ConsumedAt time.Time

+ ConsumedBy string

+ ExpiresAt time.Time

+ InterruptID string

+ Message string

+ Metadata map[string]any

+ MintedAt time.Time

+ Plane string

+ Reason Reason

+ ResumeAt time.Time

+ SessionID string

+ Token string

+ User string

+ func (r *PauseRecord) Active() bool

+ func (r *PauseRecord) Expired(now time.Time) bool

+ type PauseSpec struct

+ Interrupt bool

+ Message string

+ Metadata map[string]any

+ Reason Reason

+ ResumeAt time.Time

+ TokenTTL time.Duration

type PendingInput

+ LongRunning bool

+ ToolName string

+ type Reason string

+ const ReasonA2ATaskPending

+ const ReasonAmbiguity

+ const ReasonBudgetExhaustion

+ const ReasonCostCoolDown

+ const ReasonMaintenanceWindow

+ const ReasonOperator

+ const ReasonOther

+ const ReasonRateLimitBackoff

+ const ReasonWatchdogAnomaly

type Store

+ func (s *Store) AckEffects(ctx context.Context, userID, sessionID, reason string) error

+ func (s *Store) AutoResumeAttempts(ctx context.Context, userID, sessionID string) (int, time.Time)

+ func (s *Store) ClearAutoResumeAttempts(ctx context.Context, userID, sessionID string) error

+ func (s *Store) ConsumeScheduled(ctx context.Context, token, by string) (*PauseRecord, error)

+ func (s *Store) ConsumeToken(ctx context.Context, token, by string) (*PauseRecord, error)

+ func (s *Store) EffectsAckedAt(ctx context.Context, userID, sessionID string) (time.Time, bool)

+ func (s *Store) ExtendToken(ctx context.Context, token string, ttl time.Duration) (*PauseRecord, error)

+ func (s *Store) FindToken(ctx context.Context, token string) (*PauseRecord, error)

+ func (s *Store) GatePause(ctx context.Context, userID, sessionID string) *PauseRecord

+ func (s *Store) PauseGate(ctx context.Context, userID, sessionID string, spec PauseSpec) (PauseHandle, bool, error)

+ func (s *Store) PauseInterrupt(ctx context.Context, userID, sessionID, interruptID string, spec PauseSpec) (PauseHandle, error)

+ func (s *Store) PauseRecords(ctx context.Context, userID, sessionID string) (map[string]*PauseRecord, error)

+ func (s *Store) RecordAutoResumeAttempt(ctx context.Context, userID, sessionID string) (int, error)

+ func (s *Store) ScanInterrupted(ctx context.Context) ([]InterruptedCandidate, error)

+ func (s *Store) ScanPauses(ctx context.Context) ([]*PauseRecord, error)

type Summary

+ InterruptedAt time.Time

+ PauseMessage string

+ PauseReason string

v0.1.2

Jul 31, 2026

Changes in this version

+ func IsReservedSessionID(sessionID string) bool

v0.1.1

Jul 31, 2026

Changes in this version

+ const StateInterrupted

type Store

+ func (s *Store) ClearInterrupted(ctx context.Context, userID, sessionID string) error

+ func (s *Store) MarkInterrupted(ctx context.Context, userID, sessionID, reason string) error

type Summary

+ InterruptReason string

v0.1.0

Jul 30, 2026

Changes in this version

+ const StateAborted

+ const StateIdle

+ const StatePaused

+ var ErrAlreadyAborted = errors.New("session already aborted")

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

+ type Detail struct

+ EventCount int

+ Pending []PendingInput

+ type PendingInput struct

+ Author string

+ InterruptID string

+ Message string

+ Payload any

+ RaisedAt time.Time

+ ResponseSchema *jsonschema.Schema

+ type Store struct

+ func NewStore(svc adksession.Service, appName string) *Store

+ func Open(path, appName string) (*Store, error)

+ func (s *Store) Abort(ctx context.Context, userID, sessionID, reason string) error

+ func (s *Store) Get(ctx context.Context, userID, sessionID string) (*Detail, error)

+ func (s *Store) List(ctx context.Context, userID string) ([]Summary, error)

+ type Summary struct

+ AbortReason string

+ AppName string

+ ID string

+ LastEventTime time.Time

+ PendingInterruptIDs []string

+ State string

+ UserID string

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