weft

package module

Go to main page

Versions in this module

v0

v0.14.1

Oct 11, 2026

v0.14.0

Oct 11, 2026

Changes in this version

+ const ContentRaw

+ func WithMetadata(ctx context.Context, kv map[string]string) context.Context

v0.13.0

Oct 10, 2026

v0.12.0

Oct 9, 2026

v0.11.0

Oct 8, 2026

v0.10.1

Oct 8, 2026

v0.10.0

Oct 8, 2026

Changes in this version

+ const ContentPrompt

+ const ContentStop

+ type AttemptInfo = core.AttemptInfo

+ type RawPair = core.RawPair

+ type Reporter = core.Reporter

+ func ReportFromContext(ctx context.Context) Reporter

type ToolOption

+ func Origin(name string) ToolOption

v0.9.0

Oct 7, 2026

v0.8.0

Oct 7, 2026

Changes in this version

type RunOption

+ func ParkAllExcept(names ...string) RunOption

v0.7.0

Oct 1, 2026

Changes in this version

+ type ReplayPolicy string

+ const ReplayNever

+ const ReplaySafe

type ToolDef

+ func (t *ToolDef) ReplayPolicy() ReplayPolicy

type ToolOption

+ func Replay(p ReplayPolicy) ToolOption

v0.6.0

Sep 30, 2026

Changes in this version

+ var ErrInvalidRunOption = errors.New("weft: invalid run option")

+ func MetadataFromContext(ctx context.Context) map[string]string

+ type ContentKind string

+ const ContentArgs

+ const ContentMessages

+ const ContentReasoning

+ const ContentResult

+ const ContentText

type Event

+ func StripContent(ev Event) Event

+ type InstructionsOption interface

+ type MaxStepsOption interface

type Option

+ func Content(capture bool) Option

+ func LoggerProvider(lp log.LoggerProvider) Option

+ type ParallelismOption interface

type RunOption

+ func Metadata(kv map[string]string) RunOption

+ func OnlyTools(names ...string) RunOption

+ func ParkOn(tools ...string) RunOption

+ func UseModel(m Model) RunOption

v0.5.0

Sep 29, 2026

Changes in this version

type RunOption

+ func OnMessages(fn func(ctx context.Context, step int, msgs []Message)) RunOption

v0.4.0

Sep 29, 2026

Changes in this version

+ var ErrContextOverflow = errors.New("weft: request exceeds the model's context window")

+ var ErrInvalidSteer = errors.New("weft: steering delivered a message with a role other than user")

type RunOption

+ func Steering(fn SteerFunc) RunOption

+ type SteerFunc func(ctx context.Context, at SteerPoint) []Message

+ type SteerPoint struct

+ Final bool

+ RunID string

+ Step int

+ type Steered struct

+ Messages []Message

+ RunID string

+ Seq int64

+ Step int

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

v0.3.7

Sep 29, 2026

Changes in this version

type Agent

+ func (a *Agent) Model() Model

type Model

+ func Unwrap(m Model) Model

v0.3.6

Sep 26, 2026

Changes in this version

type Agent

+ func AgentFromContext(ctx context.Context) *Agent

+ func (a *Agent) Logger() *slog.Logger

v0.3.5

Sep 26, 2026

Changes in this version

type Option

+ func OnRunEnd(fn func(ctx context.Context, res *RunResult, err error)) Option

v0.3.4

Sep 26, 2026

v0.3.3

Sep 26, 2026

v0.3.2

Sep 26, 2026

v0.3.1

Sep 26, 2026

v0.3.0

Sep 22, 2026

Changes in this version

type ModelRequest

+ Params RequestParams

+ ToolChoice ToolChoiceConfig

+ type OutputDecoder struct

+ func NewOutputDecoder[Out any]() *OutputDecoder[Out]

+ func (d *OutputDecoder[Out]) Feed(ev Event) (partial Out, ok bool)

+ func (d *OutputDecoder[Out]) Result() (Out, error)

+ type ParamsOption interface

+ func Params(p RequestParams) ParamsOption

+ type RequestParams struct

+ MaxTokens *int

+ Seed *int64

+ Stop []string

+ Temperature *float64

+ TopP *float64

type RunOption

+ func Resolve(callID, content string) RunOption

+ func ResolveError(callID, content string) RunOption

+ type ToolChoiceConfig struct

+ Mode ToolChoiceMode

+ Name string

+ type ToolChoiceMode string

+ const ToolChoiceAny

+ const ToolChoiceAuto

+ const ToolChoiceNamed

+ const ToolChoiceNone

+ type ToolChoiceOption interface

+ func ToolChoice(cfg ToolChoiceConfig) ToolChoiceOption

type Usage

+ CacheWriteTokens int64

+ CachedInputTokens int64

+ ReasoningTokens int64

v0.2.0

Sep 19, 2026

Changes in this version

+ const CodeDenied

+ const CodeInvalidInput

+ const CodeNoSuchTool

+ const CodeRetry

+ const CodeSubagentCycle

+ const CodeSubagentFailed

+ const CodeSubagentPending

+ var ErrApprovalDenied = errors.New("weft: tool call denied")

+ var ErrApprovalRequired = errors.New("weft: tool call requires approval")

+ var ErrDuplicateTool = errors.New("weft: duplicate tool name from tool source")

+ var ErrLoopDetected = errors.New("weft: the model repeated the same tool calls too many times")

+ var ErrModelRetriesExceeded = errors.New("weft: a tool asked the model to retry too many times")

+ var ErrNilTool = errors.New("weft: nil tool in tool source snapshot")

+ var ErrNoOutput = errors.New("weft: run ended without a structured output")

+ var ErrUsageLimit = errors.New("weft: run exceeded its usage limit")

+ func ModelRetry(hint string) error

+ func OutputOf[Out any](res *RunResult) (Out, error)

type Agent

+ func (a *Agent) Name() string

+ func (a *Agent) TapPanics() int64

type Call

+ Approved bool

type ModelInfo

+ func InfoOf(m Model) ModelInfo

+ type ModelMiddleware func(next Model) Model

type ModelRequest

+ Thinking ThinkingConfig

+ type ModelToolCallDelta struct

+ Args string

+ Index int

+ Name string

+ type Nested struct

+ CallID string

+ Event Event

+ RunID string

+ Seq int64

+ func (e *Nested) UnmarshalJSON(b []byte) error

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

type Option

+ func DetectLoops(repeats int) Option

+ func Logger(l *slog.Logger) Option

+ func MaxModelRetries(n int) Option

+ func Options(opts ...Option) Option

+ func Output[Out any]() Option

+ func PrepareStep(fn func(ctx context.Context, step int, req ModelRequest) (ModelRequest, error)) Option

+ func TracerProvider(tp trace.TracerProvider) Option

+ func UsageLimit(max Usage) Option

+ func WrapModel(mw ...ModelMiddleware) Option

+ type PolicyOption interface

+ func StrictInput() PolicyOption

+ func Timeout(d time.Duration) PolicyOption

+ func WrapTools(mw ...ToolMiddleware) PolicyOption

type ReasoningDelta

+ RunID string

type Run

+ func (r *Run) Close()

type RunFinish

+ Pending []ToolCallPart

+ RunID string

type RunOption

+ func Approve(callID string) RunOption

+ func Deny(callID, reason string) RunOption

type RunResult

+ Pending []ToolCallPart

+ func GenerateAs[Out any](ctx context.Context, a *Agent, opts ...RunOption) (Out, *RunResult, error)

type Schema

+ AdditionalProperties *Schema

+ func ParseSchema(b json.RawMessage) (*Schema, error)

+ func (s *Schema) MarshalJSON() ([]byte, error)

type StepFinish

+ RunID string

type StepRecord

+ SubagentUsage map[string]Usage

type StepStart

+ RunID string

type TextDelta

+ RunID string

+ type ThinkingConfig struct

+ Budget int64

+ Level ThinkingLevel

+ type ThinkingLevel int

+ const ThinkHigh

+ const ThinkLow

+ const ThinkMedium

+ const ThinkOff

+ const ThinkUnset

+ type ThinkingOption interface

+ func Thinking(cfg ThinkingConfig) ThinkingOption

+ type ToolArgsDelta struct

+ Args string

+ Name string

+ RunID string

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

+ type ToolCaller func(ctx context.Context, call ToolCallPart) (string, error)

type ToolDef

+ func Subagent(name, description string, child *Agent, opts ...ToolOption) *ToolDef

+ func (t *ToolDef) PromptSnippet() string

+ func (t *ToolDef) RequiresApproval() bool

+ type ToolError struct

+ Code string

+ Err error

+ Message string

+ func Errorf(code, format string, args ...any) *ToolError

+ func (e *ToolError) Error() string

+ func (e *ToolError) Unwrap() error

type ToolFinish

+ RunID string

+ type ToolMiddleware func(next ToolCaller) ToolCaller

+ type ToolOption interface

+ func PromptSnippet(text string) ToolOption

+ func RequireApproval() ToolOption

+ func ToolOptions(opts ...ToolOption) ToolOption

type ToolStart

+ RunID string

v0.1.0

Sep 11, 2026

Changes in this version

+ const SchemaVersion

+ var ErrInvalidToolInput = errors.New("weft: tool input is not valid for its schema")

+ var ErrMaxSteps = errors.New("weft: run exceeded the maximum number of steps")

+ var ErrModelContract = errors.New("weft: model violated the stream contract")

+ var ErrModelRequestsDenied = errors.New("weft: model requests denied by WEFT_MODEL_REQUESTS")

+ var ErrNoSuchTool = errors.New("weft: no tool with that name")

+ var ErrRunConsumed = errors.New("weft: run events already consumed")

+ var ErrStreamIdle = errors.New("weft: model stream idle timeout")

+ var ErrUnsupported = errors.New("weft: request uses a feature the model does not support")

+ func Manifest(agents ...*Agent) ([]byte, error)

+ func ModelRequestsAllowed() bool

+ type Agent struct

+ func New(m Model, opts ...Option) *Agent

+ func (a *Agent) CallTool(ctx context.Context, call ToolCallPart) (string, error)

+ func (a *Agent) Generate(ctx context.Context, opts ...RunOption) (*RunResult, error)

+ func (a *Agent) Stream(ctx context.Context, opts ...RunOption) *Run

+ func (a *Agent) Tools() []*ToolDef

+ type Call struct

+ CallID string

+ Name string

+ RunID string

+ Step int

+ func CallFromContext(ctx context.Context) (c Call, ok bool)

+ type Event interface

+ func UnmarshalEvent(b []byte) (Event, error)

+ type FilePart struct

+ Data []byte

+ MediaType string

+ URL string

+ func (p FilePart) MarshalJSON() ([]byte, error)

+ type Message struct

+ Content []Part

+ Role Role

+ func Assistant(text string) Message

+ func Repair(msgs []Message) []Message

+ func User(text string) Message

+ func UserParts(parts ...Part) Message

+ func (m *Message) UnmarshalJSON(b []byte) error

+ func (m Message) Text() string

+ type Model interface

+ Stream func(ctx context.Context, req ModelRequest) iter.Seq2[ModelEvent, error]

+ type ModelEvent interface

+ type ModelFinish struct

+ Raw string

+ Reason StopReason

+ Usage Usage

+ type ModelInfo struct

+ Name string

+ Provider string

+ type ModelReasoningDelta struct

+ Signature string

+ Text string

+ type ModelRequest struct

+ Messages []Message

+ SequentialTools bool

+ System string

+ Tools []*ToolDef

+ type ModelTextDelta struct

+ Text string

+ type ModelToolCall struct

+ Args json.RawMessage

+ ID string

+ Name string

+ Signature string

+ type Option interface

+ func Instructions(text string) Option

+ func MaxResultBytes(n int) Option

+ func MaxSteps(n int) Option

+ func Name(name string) Option

+ func Parallelism(n int) Option

+ func Sequential() Option

+ func StopWhen(conds ...StopCondition) Option

+ func Tap(fn func(ctx context.Context, ev Event)) Option

+ func ToolSource(fn func() []*ToolDef) Option

+ type Part interface

+ type ReasoningDelta struct

+ Text string

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

+ type ReasoningPart struct

+ Signature string

+ Text string

+ func (p ReasoningPart) MarshalJSON() ([]byte, error)

+ type Role string

+ const RoleAssistant

+ const RoleTool

+ const RoleUser

+ type Run struct

+ func (r *Run) Events() iter.Seq2[Event, error]

+ func (r *Run) ID() string

+ func (r *Run) Wait() (*RunResult, error)

+ type RunError struct

+ Err error

+ Result *RunResult

+ Step int

+ func (e *RunError) Error() string

+ func (e *RunError) Unwrap() error

+ type RunFinish struct

+ Steps int

+ Usage Usage

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

+ type RunOption interface

+ func Messages(msgs ...Message) RunOption

+ func Prompt(text string) RunOption

+ func RunID(id string) RunOption

+ type RunResult struct

+ ID string

+ Messages []Message

+ Steps []StepRecord

+ StopReason StopReason

+ Usage Usage

+ func (r *RunResult) NumSteps() int

+ func (r *RunResult) Text() string

+ type RunStart struct

+ Agent string

+ ID string

+ Model ModelInfo

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

+ type Schema struct

+ Description string

+ Format string

+ Items *Schema

+ Properties map[string]*Schema

+ Required []string

+ Type string

+ type StepFinish struct

+ Index int

+ Raw string

+ Reason StopReason

+ Usage Usage

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

+ type StepRecord struct

+ Index int

+ RawStopReason string

+ Results []ToolResultPart

+ StopReason StopReason

+ Text string

+ ToolCalls []ToolCallPart

+ Usage Usage

+ type StepStart struct

+ Index int

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

+ type StopCondition interface

+ Stop func(steps []StepRecord) bool

+ func HasToolCall(names ...string) StopCondition

+ func StepCountIs(n int) StopCondition

+ type StopFunc func(steps []StepRecord) bool

+ func (f StopFunc) Stop(steps []StepRecord) bool

+ type StopReason string

+ const StopEndTurn

+ const StopMaxTokens

+ const StopToolCalls

+ type TextDelta struct

+ Text string

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

+ type TextPart struct

+ Text string

+ func (p TextPart) MarshalJSON() ([]byte, error)

+ type ToolCallPart struct

+ Args json.RawMessage

+ ID string

+ Name string

+ Signature string

+ func (p ToolCallPart) MarshalJSON() ([]byte, error)

+ type ToolDef struct

+ Description string

+ InputSchema *Schema

+ Name string

+ OutputSchema *Schema

+ func RawTool(name, description string, schema *Schema, ...) *ToolDef

+ func Tool[In, Out any](name, description string, fn func(ctx context.Context, in In) (Out, error)) *ToolDef

+ func (t *ToolDef) Invoke(ctx context.Context, args json.RawMessage) (string, error)

+ type ToolFinish struct

+ CallID string

+ Content string

+ IsError bool

+ Name string

+ Seq int64

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

+ type ToolResultPart struct

+ CallID string

+ Content string

+ IsError bool

+ Name string

+ func (p ToolResultPart) MarshalJSON() ([]byte, error)

+ type ToolStart struct

+ Args json.RawMessage

+ CallID string

+ Name string

+ Seq int64

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

+ type Usage struct

+ InputTokens int64

+ OutputTokens int64

+ func (u Usage) Add(o Usage) Usage

+ func (u Usage) Total() int64

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