thread

package module

Go to main page

Versions in this module

v0

v0.9.1

Oct 7, 2026

v0.9.0

Oct 1, 2026

Changes in this version

+ const PoolParked

+ const ReceiptAccepted

+ const StepSigned

+ var ErrAwaitingApproval = errors.New("thread: approval requests pending")

+ var ErrClosed = errors.New("thread: session is closed")

+ var ErrCompactCanceled = errors.New("thread: compaction canceled")

+ var ErrCompactConfig = errors.New("thread: invalid compaction configuration")

+ var ErrCreateOnly = errors.New("thread: option applies only when a session is created")

+ var ErrDelegated = errors.New("thread: call is delegated to a child session")

+ var ErrDropped = errors.New("thread: message dropped from the queue")

+ var ErrInvalidCompaction = errors.New("thread: invalid compaction")

+ var ErrInvalidDecision = errors.New("thread: invalid decision")

+ var ErrNoEntry = errors.New("thread: session holds no such entry")

+ var ErrNotPersisted = errors.New("thread: turn end not persisted")

+ var ErrNotPinnable = errors.New("thread: entry cannot be pinned")

+ var ErrNotRun = errors.New("thread: turn did not run")

+ var ErrNothingToCompact = errors.New("thread: nothing to compact")

+ var ErrReservedKey = errors.New("thread: metadata key is reserved")

+ var ErrStale = errors.New("thread: session changed since it was opened")

+ var ErrSummaryTruncated = errors.New("thread: summary truncated at the output cap")

+ var ErrTurnPanicked = errors.New("thread: turn panicked")

type ApprovalAuditEntry

+ Decisions []string

+ GrantID string

+ GrantShared bool

+ KeyID string

type ApprovalDecisionEntry

+ Always bool

+ RequestID string

type CompactOption

+ func SummaryInstructions(text string) CompactOption

type Compaction

+ Trim *TrimRecord

type CompactionEntry

+ Trim *TrimRecord

type CorruptError

+ Entry string

type Key

+ func (k Key) Sign(req Request, d Decision) (SignedDecision, error)

type Keyring

+ func (r *Keyring) Sign(req Request, d Decision) (SignedDecision, error)

+ type Leaser interface

+ Acquire func(ctx context.Context, session string, holder any) (entries int, created time.Time, err error)

+ Yield func(ctx context.Context, session string, holder any) error

type MessageEntry

+ RunID string

+ type MirroredRequest struct

+ Decided bool

+ Decisions []ApprovalDecisionEntry

+ Request Request

+ Wrapper string

type OpenOption

+ func NoLock() OpenOption

+ func OpenLogger(l *slog.Logger) OpenOption

+ type OpenReport struct

+ Orphaned []string

type Policy

+ func (p Policy) String() string

type Query

+ BeforeID string

type QueuedSteer

+ Policy Policy

type ReceiptEntry

+ Unanswered bool

+ type Releaser interface

+ Release func(ctx context.Context, session string) error

type Request

+ ID string

type Session

+ func (s *Session) CancelDelegated(ctx context.Context, reason string) error

+ func (s *Session) Close(ctx context.Context) error

+ func (s *Session) Continue(ctx context.Context) (*Turn, error)

+ func (s *Session) DenyMirrored(ctx context.Context, child, reason string) error

+ func (s *Session) LoadReport() *OpenReport

+ func (s *Session) MirroredRequests(ctx context.Context) ([]MirroredRequest, error)

+ func (s *Session) ReplayDecisions(ctx context.Context, ds ...ApprovalDecisionEntry) (*Turn, error)

+ func (s *Session) ResolveDelegation(ctx context.Context, callID, child, content string, isError bool) (*Turn, error)

+ func (s *Session) WaitIdle(ctx context.Context) error

+ func (s *Session) WatchMirrors(owner any, fn func(log *slog.Logger))

type SessionOption

+ func Clock(now func() time.Time) SessionOption

+ func InheritApprovals(parent *Session) SessionOption

+ func NoAutoCompact() SessionOption

type SignedDecision

+ RequestID string

+ RunID string

+ type TrimRecord struct

+ Stubs []TrimStub

+ type TrimStub struct

+ CallID string

+ Content string

+ Entry string

+ IsError bool

type Turn

+ func (t *Turn) Done() <-chan struct{}

+ func (t *Turn) Outcome() TurnOutcome

+ func (t *Turn) WaitContext(ctx context.Context) (*weft.RunResult, error)

type TurnEntry

+ LateSteps int

+ Policy string

+ ReRun string

+ type TurnOutcome int

+ const TurnAnswered

+ const TurnCanceled

+ const TurnDeferred

+ const TurnDelivered

+ const TurnDropped

+ const TurnFailed

+ const TurnParked

+ const TurnRunning

+ func (o TurnOutcome) String() string

v0.8.1

Oct 1, 2026

v0.8.0

Oct 1, 2026

Changes in this version

type SessionOption

+ func PublicID(id string) SessionOption

v0.7.1

Sep 30, 2026

v0.7.0

Sep 30, 2026

v0.5.0

Sep 29, 2026

Changes in this version

+ const PoolAccepted

+ const PoolCanceled

+ const PoolCapped

+ const PoolDone

+ const PoolFailed

+ const PoolRunning

type ApprovalRequestEntry

+ Child string

+ Wrapper string

type Header

+ Lineage *Lineage

+ type Lineage struct

+ Call string

+ Session string

+ type PoolReceiptEntry struct

+ Call string

+ Child string

+ Created time.Time

+ ID string

+ ParentID string

+ Prompt string

+ Receipt string

+ Status string

+ Stop string

+ Usage weft.Usage

+ func (e PoolReceiptEntry) MarshalJSON() ([]byte, error)

type Request

+ Child string

type Session

+ func SessionFromContext(ctx context.Context) *Session

+ func (s *Session) AppendApprovalRequests(ctx context.Context, reqs ...ApprovalRequestEntry) ([]ApprovalRequestEntry, error)

+ func (s *Session) AppendPoolReceipt(ctx context.Context, e PoolReceiptEntry) (PoolReceiptEntry, error)

+ func (s *Session) Lineage() Lineage

+ func (s *Session) Storage() Storage

type SessionOption

+ func WithLineage(parentSession, call string) SessionOption

+ func WithMeta(meta map[string]string) SessionOption

type Usage

+ Delegated weft.Usage

v0.4.0

Sep 29, 2026

Changes in this version

type Query

+ Meta map[string]string

+ TitleSearch string

v0.3.0

Sep 29, 2026

Changes in this version

+ const ReceiptDeferred

+ const ReceiptDelivered

+ const ReceiptDropped

+ const ReceiptQueued

type Policy

+ const Interrupt

+ const Rollback

+ const Steer

+ type QueuedSteer struct

+ Msg weft.Message

+ Receipt string

+ type ReceiptEntry struct

+ Created time.Time

+ ID string

+ Msg *weft.Message

+ ParentID string

+ Receipt string

+ RunID string

+ Status string

+ Turn string

+ func (e ReceiptEntry) MarshalJSON() ([]byte, error)

type SendOption

+ func As(p Policy) SendOption

type Session

+ func (s *Session) ClearQueue(ctx context.Context) (int, error)

+ func (s *Session) Queue() []QueuedSteer

type SessionOption

+ func ReRunOnOverflow(on bool) SessionOption

v0.2.0

Sep 29, 2026

Changes in this version

+ const FormatVersion

+ const StepApprover

+ const StepExpiry

+ const StepGrant

+ const StepPark

+ const StepResume

+ var Cancel = Verdict

+ var ErrArgsChanged = errors.New("thread: request arguments changed under the signature")

+ var ErrBadSignature = errors.New("thread: decision signature does not verify")

+ var ErrBusy = errors.New("thread: session is busy with another turn")

+ var ErrCorrupt = errors.New("thread: stored session data is corrupt")

+ var ErrExists = errors.New("thread: session already exists")

+ var ErrExpired = errors.New("thread: signing challenge expired")

+ var ErrLocked = errors.New("thread: session is locked by another writer")

+ var ErrNewerFormat = errors.New("thread: session format newer than this build")

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

+ var ErrNotImplemented = errors.New("thread: feature not implemented in this build")

+ var ErrNotPending = errors.New("thread: call is not pending")

+ var ErrReplay = errors.New("thread: decision signature replayed")

+ var ErrSignatureRequired = errors.New("thread: this session requires signed decisions")

+ var ErrUnknownKey = errors.New("thread: signing key not in the keyring")

+ var Proceed = Verdict

+ func Delete(ctx context.Context, st Storage, id string) error

+ func NewEntryID() string

+ func NewSessionID() string

+ func ValidID(id string) bool

+ type ApprovalAuditEntry struct

+ CallID string

+ Created time.Time

+ Detail string

+ ID string

+ Outcome string

+ ParentID string

+ RunID string

+ Step string

+ func (e ApprovalAuditEntry) MarshalJSON() ([]byte, error)

+ type ApprovalDecisionEntry struct

+ CallID string

+ Content string

+ Created time.Time

+ ID string

+ KeyID string

+ Nonce string

+ Outcome Outcome

+ ParentID string

+ Reason string

+ RunID string

+ Via string

+ Who string

+ func (e ApprovalDecisionEntry) MarshalJSON() ([]byte, error)

+ type ApprovalRequestEntry struct

+ Args json.RawMessage

+ ArgsSHA256 string

+ CallID string

+ Created time.Time

+ Expiry time.Time

+ ID string

+ ParentID string

+ Reason string

+ RunID string

+ Tool string

+ func (e ApprovalRequestEntry) MarshalJSON() ([]byte, error)

+ type Approver func(ctx context.Context, r Request) (Decision, bool)

+ type Arg struct

+ Equals json.RawMessage

+ Glob string

+ Pointer string

+ Prefix string

+ func ArgEquals(pointer string, value json.RawMessage) Arg

+ func ArgGlob(pointer, glob string) Arg

+ func ArgPrefix(pointer, prefix string) Arg

+ type BranchOption interface

+ func SummarizeLeft() BranchOption

+ type BranchSummaryEntry struct

+ Created time.Time

+ FromEntry string

+ ID string

+ ParentID string

+ Summary string

+ func (e BranchSummaryEntry) MarshalJSON() ([]byte, error)

+ type CompactOption interface

+ func Instructions(text string) CompactOption

+ type Compaction struct

+ FilesModified []string

+ FilesRead []string

+ FirstKept string

+ Pinned []string

+ RangeHash string

+ Reason Reason

+ SummarizerModel weft.ModelInfo

+ SummarizerUsage weft.Usage

+ Summary string

+ TokensBefore int64

+ type CompactionEntry struct

+ Created time.Time

+ FilesModified []string

+ FilesRead []string

+ FirstKept string

+ ID string

+ ParentID string

+ Pinned []string

+ RangeHash string

+ Reason Reason

+ SummarizerModel weft.ModelInfo

+ SummarizerUsage weft.Usage

+ Summary string

+ TokensBefore int64

+ func (e CompactionEntry) MarshalJSON() ([]byte, error)

+ type Compactor interface

+ Compact func(ctx context.Context, p Preparation) (*Compaction, error)

+ type CorruptError struct

+ Err error

+ Line int

+ Session string

+ func (e *CorruptError) Error() string

+ func (e *CorruptError) Unwrap() error

+ type CustomEntry struct

+ Created time.Time

+ Data json.RawMessage

+ ID string

+ Kind string

+ ParentID string

+ func (e CustomEntry) MarshalJSON() ([]byte, error)

+ type CustomMessageEntry struct

+ Created time.Time

+ ID string

+ Kind string

+ Message weft.Message

+ ParentID string

+ func (e CustomMessageEntry) MarshalJSON() ([]byte, error)

+ type Decision struct

+ Always bool

+ CallID string

+ Content string

+ Kind Outcome

+ Reason string

+ Via string

+ Who string

+ func Approve(callID string) Decision

+ func ApproveAlways(callID string) Decision

+ func Deny(callID, reason string) Decision

+ func Resolve(callID, content string) Decision

+ func ResolveError(callID, content string) Decision

+ type Entry interface

+ func UnmarshalEntry(b []byte) (Entry, error)

+ type Estimator interface

+ Estimate func(msgs []weft.Message) int

+ type Flusher interface

+ Flush func(ctx context.Context, session string) error

+ type Grant struct

+ Args []Arg

+ Deny bool

+ Expiry time.Time

+ MaxUses int

+ Reason string

+ Tool string

+ type GrantEntry struct

+ Created time.Time

+ ID string

+ ParentID string

+ func (e GrantEntry) MarshalJSON() ([]byte, error)

+ type GrantRevokedEntry struct

+ Created time.Time

+ GrantID string

+ ID string

+ ParentID string

+ func (e GrantRevokedEntry) MarshalJSON() ([]byte, error)

+ type GrantStore interface

+ Grants func(ctx context.Context) ([]SharedGrant, error)

+ type Header struct

+ Created time.Time

+ ID string

+ Meta map[string]string

+ Parent *ParentRef

+ Weft int

+ func (h *Header) UnmarshalJSON(b []byte) error

+ func (h Header) MarshalJSON() ([]byte, error)

+ type InfoEntry struct

+ Created time.Time

+ ID string

+ Meta map[string]string

+ ParentID string

+ Title string

+ func (e InfoEntry) MarshalJSON() ([]byte, error)

+ type Key struct

+ Active bool

+ ID string

+ Secret []byte

+ type Keyring struct

+ func NewKeyring(keys ...Key) (*Keyring, error)

+ type LabelEntry struct

+ Created time.Time

+ Entry string

+ ID string

+ Name string

+ ParentID string

+ func (e LabelEntry) MarshalJSON() ([]byte, error)

+ type LeafEntry struct

+ Created time.Time

+ Entry string

+ ID string

+ ParentID string

+ func (e LeafEntry) MarshalJSON() ([]byte, error)

+ type LoadReport struct

+ Skipped []int

+ Torn int

+ type MessageEntry struct

+ Created time.Time

+ ID string

+ Message weft.Message

+ ParentID string

+ func (e MessageEntry) MarshalJSON() ([]byte, error)

+ type NativeCompactor interface

+ CompactNative func(ctx context.Context, req weft.ModelRequest, instructions string) (weft.Message, weft.Usage, error)

+ type OpenConfig struct

+ Salvage bool

+ SyncEveryAppend bool

+ func ResolveOpen(opts ...OpenOption) OpenConfig

+ type OpenOption interface

+ func FsyncEveryAppend() OpenOption

+ func FsyncOnFlush() OpenOption

+ func Salvage() OpenOption

+ type Outcome string

+ const OutcomeApprove

+ const OutcomeDeny

+ const OutcomeResolve

+ const OutcomeResolveError

+ type Page struct

+ Sessions []Header

+ Total int

+ func List(ctx context.Context, st Storage, q Query) (Page, error)

+ type ParentRef struct

+ Entry string

+ Session string

+ type Policy int

+ const Queue

+ const Reject

+ type Preparation struct

+ Context []weft.Message

+ FirstKept string

+ Instructions string

+ Messages []weft.Message

+ Pinned []string

+ PrevSummary string

+ Reason Reason

+ SplitPrefix []weft.Message

+ TokensBefore int64

+ type Query struct

+ Before time.Time

+ Limit int

+ type Reason string

+ const ReasonFromHook

+ const ReasonManual

+ const ReasonOverflow

+ const ReasonThreshold

+ const ReasonTrim

+ type Request struct

+ Args json.RawMessage

+ ArgsSHA256 string

+ CallID string

+ Created time.Time

+ Expiry time.Time

+ KeyID string

+ Nonce string

+ Reason string

+ RunID string

+ Session string

+ Tool string

+ type SendOption interface

+ func RunOptions(opts ...weft.RunOption) SendOption

+ type Session struct

+ func Create(ctx context.Context, st Storage, agent *weft.Agent, opts ...SessionOption) (*Session, error)

+ func Open(ctx context.Context, st Storage, id string, agent *weft.Agent, ...) (*Session, error)

+ func (s *Session) ApplyCompaction(ctx context.Context, c *Compaction) error

+ func (s *Session) Audit() []Entry

+ func (s *Session) Branch(ctx context.Context, entryID string, opts ...BranchOption) error

+ func (s *Session) Compact(ctx context.Context, opts ...CompactOption) error

+ func (s *Session) Context() []weft.Message

+ func (s *Session) Custom(ctx context.Context, kind string, data json.RawMessage) error

+ func (s *Session) CustomMessage(ctx context.Context, kind string, msg weft.Message) error

+ func (s *Session) Decide(ctx context.Context, ds ...Decision) (*Turn, error)

+ func (s *Session) DecideSigned(ctx context.Context, sd SignedDecision) (*Turn, error)

+ func (s *Session) Entries() []Entry

+ func (s *Session) Fork(ctx context.Context, entryID string, opts ...SessionOption) (*Session, error)

+ func (s *Session) Grant(ctx context.Context, g Grant) error

+ func (s *Session) ID() string

+ func (s *Session) Label(ctx context.Context, entryID, name string) error

+ func (s *Session) Leaf() string

+ func (s *Session) Meta() map[string]string

+ func (s *Session) Path(entryID string) ([]Entry, error)

+ func (s *Session) Pending() []Request

+ func (s *Session) Pin(ctx context.Context, entryID string) error

+ func (s *Session) PreviewCompaction(ctx context.Context, opts ...CompactOption) (*Compaction, error)

+ func (s *Session) Request(callID string) (Request, error)

+ func (s *Session) Resume(ctx context.Context) (*Turn, error)

+ func (s *Session) Revoke(ctx context.Context, grantID string) error

+ func (s *Session) Send(ctx context.Context, msg weft.Message, opts ...SendOption) (*Turn, error)

+ func (s *Session) SetInfo(ctx context.Context, title string, meta map[string]string) error

+ func (s *Session) Title() string

+ func (s *Session) Uncompact(ctx context.Context) error

+ func (s *Session) Usage() Usage

+ type SessionOption interface

+ func AfterCompact(fn func(ctx context.Context, e CompactionEntry)) SessionOption

+ func ApproverTimeout(d time.Duration) SessionOption

+ func AutoResume(on bool) SessionOption

+ func BeforeCompact(fn func(ctx context.Context, p *Preparation) (Verdict, error)) SessionOption

+ func BusyPolicy(p Policy) SessionOption

+ func CheckSummary(fn func(Summary) error) SessionOption

+ func ClearOldToolResults(keepLast int) SessionOption

+ func CompactFailed(fn func(ctx context.Context, r Reason, err error)) SessionOption

+ func ContextWindow(n int64) SessionOption

+ func Disabled() SessionOption

+ func IDs(id func() string) SessionOption

+ func KeepRecent(n int64) SessionOption

+ func MaxPerSession(n int) SessionOption

+ func MinTurnsBetween(n int) SessionOption

+ func ModelReserves(reserves map[weft.ModelInfo]int64) SessionOption

+ func ModelWindows(windows map[weft.ModelInfo]int64) SessionOption

+ func OnRequest(fn func(Request)) SessionOption

+ func PreferNative() SessionOption

+ func Quorum(n int) SessionOption

+ func RequestExpiry(d time.Duration) SessionOption

+ func RequireSigned() SessionOption

+ func Reserve(n int64) SessionOption

+ func SummaryFocus(focus string) SessionOption

+ func SummaryMaxTokens(n int) SessionOption

+ func SummaryModel(m weft.Model) SessionOption

+ func SummaryPrompt(tmpl string) SessionOption

+ func TriggerFunc(fn func(TriggerInput) bool) SessionOption

+ func WithApprover(a Approver) SessionOption

+ func WithCompactor(c Compactor) SessionOption

+ func WithEstimator(est Estimator) SessionOption

+ func WithGrantStore(gs GrantStore) SessionOption

+ func WithKeyring(r *Keyring) SessionOption

+ func WithSummarizer(s Summarizer) SessionOption

+ func WithTrimmer(t Trimmer) SessionOption

+ type SharedGrant struct

+ ID string

+ type SignedDecision struct

+ Always bool

+ ArgsSHA256 string

+ CallID string

+ Content string

+ Expiry time.Time

+ KeyID string

+ Kind Outcome

+ MAC []byte

+ Nonce string

+ Reason string

+ Session string

+ Tool string

+ Who string

+ func SignDecision(key []byte, r Request, d Decision) SignedDecision

+ type Storage interface

+ Append func(ctx context.Context, session string, entries ...Entry) error

+ Create func(ctx context.Context, h Header) error

+ Delete func(ctx context.Context, session string) error

+ List func(ctx context.Context, q Query) (Page, error)

+ Load func(ctx context.Context, session string) (Header, []Entry, *LoadReport, error)

+ func Memory() Storage

+ type Summarizer interface

+ Summarize func(ctx context.Context, in SummaryInput) (Summary, error)

+ type Summary struct

+ Model weft.ModelInfo

+ Reason Reason

+ Text string

+ Usage weft.Usage

+ type SummaryInput struct

+ Instructions string

+ MaxTokens int

+ Messages []weft.Message

+ PrevSummary string

+ Reason Reason

+ SummaryModel weft.Model

+ SystemPrompt string

+ type TriggerInput struct

+ Estimated int64

+ LastInput int64

+ Reserve int64

+ Window int64

+ type TrimReport struct

+ Cleared int

+ EstimatedSave int64

+ type Trimmer interface

+ Trim func(ctx context.Context, msgs []weft.Message) ([]weft.Message, TrimReport)

+ type Turn struct

+ func (t *Turn) Events() iter.Seq2[weft.Event, error]

+ func (t *Turn) ID() string

+ func (t *Turn) Next() *Turn

+ func (t *Turn) RunID() string

+ func (t *Turn) Wait() (*weft.RunResult, error)

+ type TurnEntry struct

+ Canceled bool

+ Created time.Time

+ Err string

+ ID string

+ LastInput int64

+ ParentID string

+ Pending []weft.ToolCallPart

+ RunID string

+ Steps int

+ StopReason weft.StopReason

+ Usage weft.Usage

+ func (e TurnEntry) MarshalJSON() ([]byte, error)

+ type Usage struct

+ Summaries weft.Usage

+ Turns weft.Usage

+ type Verdict struct

+ func Replace(c *Compaction) Verdict

+ type Watcher interface

+ Watch func(ctx context.Context, session string, after string) (iter.Seq2[Entry, error], error)

Other modules containing this package

github.com/weftgo/weft

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