core

package module

Go to main page

Versions in this module

v0

v0.20.3

Oct 31, 2026

v0.20.2

Oct 27, 2026

v0.20.1

Oct 27, 2026

v0.20.0

Oct 27, 2026

Changes in this version

+ const AttemptGiveUpBudget

+ const AttemptGiveUpNotRetryable

+ const AttemptGiveUpRetryAfter

+ const AttemptLayerRetry

+ func WithCaller(ctx context.Context, c Caller) context.Context

type AttemptInfo

+ GiveUp string

+ type Caller struct

+ CallID string

+ RunID string

+ Span trace.SpanContext

+ type MiddlewareInfo struct

+ Name string

+ Opaque bool

+ Params map[string]string

+ Source string

type Option

+ func SkippedImports(source string, skipped ...SkippedImport) Option

+ type RepairInfo struct

+ CallID string

+ Kind string

+ Original []byte

+ Repaired []byte

type Reporter

+ func (r Reporter) Repair(ri RepairInfo)

type RunOption

+ func DenyBy(callID, reason, by, grantID string) RunOption

+ type SkippedImport struct

+ Name string

+ Reason string

+ type SourceDetail struct

+ Prefix string

+ RemoteName string

+ Server string

+ Skipped []SkippedImport

+ Transport string

type ToolMiddleware

+ func NameToolMiddleware(name string, mw ToolMiddleware) ToolMiddleware

type ToolOption

+ func OriginDetail(d SourceDetail) ToolOption

+ type ToolReporter struct

+ func ToolReportFromContext(ctx context.Context) ToolReporter

+ func (r ToolReporter) Denied(by string)

+ func (r ToolReporter) Masked(original error)

v0.19.0

Oct 26, 2026

Changes in this version

type RunOption

+ func KeptSteps(n int) RunOption

v0.18.3

Oct 21, 2026

v0.18.2

Oct 21, 2026

v0.18.1

Oct 21, 2026

v0.18.0

Oct 20, 2026

Changes in this version

type Agent

+ func (a *Agent) ContentCapture() (capture, set bool)

+ func (a *Agent) TracerProvider() trace.TracerProvider

type RunOption

+ func ApproveBy(callID, by, grantID string) RunOption

v0.17.0

Oct 17, 2026

Changes in this version

type AttemptInfo

+ HTTPStatus int

+ Wait time.Duration

v0.16.0

Oct 13, 2026

Changes in this version

+ const AttemptLayerFallback

type AttemptInfo

+ Layer string

+ type CancelCause string

+ func (c CancelCause) Error() string

+ func (c CancelCause) Is(target error) bool

+ func (c CancelCause) Kind() string

type RunFinish

+ StoppedBy string

type RunOption

+ func ResumeOf(runID string) RunOption

v0.15.1

Oct 12, 2026

v0.15.0

Oct 12, 2026

Changes in this version

type Agent

+ func (a *Agent) ParkSources() []func(ctx context.Context) []string

type Option

+ func ParkSource(fn func(ctx context.Context) []string) Option

v0.14.2

Oct 11, 2026

v0.14.1

Oct 11, 2026

v0.14.0

Oct 11, 2026

Changes in this version

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

type ContentKind

+ const ContentRaw

type RawPair

+ Method string

+ RedactedHeaders []string

+ RequestHeaders map[string][]string

+ RequestTruncated int64

+ ResponseHeaders map[string][]string

+ ResponseIncomplete bool

+ ResponseMediaType string

+ ResponseTruncated int64

+ Status int

+ URL string

type Reporter

+ func (r Reporter) WantsRaw() bool

v0.13.0

Oct 10, 2026

Changes in this version

type Agent

+ func (a *Agent) Params() RequestParams

+ func (a *Agent) Thinking() ThinkingConfig

+ func (a *Agent) ToolChoice() ToolChoiceConfig

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

type Agent

+ func (a *Agent) LoggerProvider() log.LoggerProvider

+ type AttemptInfo struct

+ End time.Time

+ Err error

+ Model string

+ Provider string

+ RetryAfter time.Duration

+ Start time.Time

type ContentKind

+ const ContentPrompt

+ const ContentStop

+ type RawPair struct

+ MediaType string

+ Request []byte

+ Response []byte

+ type Reporter struct

+ func ReportFromContext(ctx context.Context) Reporter

+ func (r Reporter) Attempt(a AttemptInfo)

+ func (r Reporter) Raw(p RawPair)

type RunStart

+ InstructionsHash string

type StepFinish

+ LatencyMS int64

+ TTFTMS int64

type ToolOption

+ func Origin(name string) ToolOption

v0.9.0

Oct 7, 2026

Changes in this version

+ const CodeDenied

+ const CodeInvalidInput

+ const CodeNoSuchTool

+ const CodeRetry

+ const CodeSubagentCycle

+ const CodeSubagentFailed

+ const CodeSubagentPending

+ const SchemaVersion

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

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

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

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

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

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

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

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

+ 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 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 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")

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

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

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

+ func ModelRequestsAllowed() bool

+ func ModelRetry(hint string) error

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

+ type Agent struct

+ func AgentFromContext(ctx context.Context) *Agent

+ 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) Logger() *slog.Logger

+ func (a *Agent) Model() Model

+ func (a *Agent) Name() string

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

+ func (a *Agent) TapPanics() int64

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

+ type Call struct

+ Approved bool

+ CallID string

+ Name string

+ RunID string

+ Step int

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

+ type ContentKind string

+ const ContentArgs

+ const ContentMessages

+ const ContentReasoning

+ const ContentResult

+ const ContentText

+ type Event interface

+ func StripContent(ev Event) Event

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

+ type FilePart struct

+ Data []byte

+ MediaType string

+ URL string

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

+ type InstructionsOption interface

+ func Instructions(text string) InstructionsOption

+ type MaxStepsOption interface

+ func MaxSteps(n int) MaxStepsOption

+ 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]

+ func Unwrap(m Model) Model

+ type ModelEvent interface

+ type ModelFinish struct

+ Raw string

+ Reason StopReason

+ Usage Usage

+ type ModelInfo struct

+ Name string

+ Provider string

+ func InfoOf(m Model) ModelInfo

+ type ModelMiddleware func(next Model) Model

+ type ModelReasoningDelta struct

+ Signature string

+ Text string

+ type ModelRequest struct

+ Messages []Message

+ Params RequestParams

+ SequentialTools bool

+ System string

+ Thinking ThinkingConfig

+ ToolChoice ToolChoiceConfig

+ Tools []*ToolDef

+ type ModelTextDelta struct

+ Text string

+ type ModelToolCall struct

+ Args json.RawMessage

+ ID string

+ Name string

+ Signature string

+ 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 interface

+ func Content(capture bool) Option

+ func DetectLoops(repeats int) Option

+ func Logger(l *slog.Logger) Option

+ func LoggerProvider(lp log.LoggerProvider) Option

+ func MaxModelRetries(n int) Option

+ func Name(name string) Option

+ func OnRunEnd(fn func(ctx context.Context, res *RunResult, err error)) 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 StopWhen(conds ...StopCondition) Option

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

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

+ func TracerProvider(tp trace.TracerProvider) Option

+ func UsageLimit(max Usage) Option

+ func WrapModel(mw ...ModelMiddleware) Option

+ 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 ParallelismOption interface

+ func Parallelism(n int) ParallelismOption

+ type ParamsOption interface

+ func Params(p RequestParams) ParamsOption

+ type Part interface

+ type PolicyOption interface

+ func MaxResultBytes(n int) PolicyOption

+ func Sequential() PolicyOption

+ func StrictInput() PolicyOption

+ func Timeout(d time.Duration) PolicyOption

+ func WrapTools(mw ...ToolMiddleware) PolicyOption

+ type ReasoningDelta struct

+ RunID string

+ Text string

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

+ type ReasoningPart struct

+ Signature string

+ Text string

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

+ type ReplayPolicy string

+ const ReplayNever

+ const ReplaySafe

+ type RequestParams struct

+ MaxTokens *int

+ Seed *int64

+ Stop []string

+ Temperature *float64

+ TopP *float64

+ type Role string

+ const RoleAssistant

+ const RoleTool

+ const RoleUser

+ type Run struct

+ func (r *Run) Close()

+ 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

+ Pending []ToolCallPart

+ RunID string

+ Steps int

+ Usage Usage

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

+ type RunOption interface

+ func Approve(callID string) RunOption

+ func Deny(callID, reason string) RunOption

+ func Messages(msgs ...Message) RunOption

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

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

+ func OnlyTools(names ...string) RunOption

+ func ParkAllExcept(names ...string) RunOption

+ func ParkOn(tools ...string) RunOption

+ func Prompt(text string) RunOption

+ func Resolve(callID, content string) RunOption

+ func ResolveError(callID, content string) RunOption

+ func RunID(id string) RunOption

+ func Steering(fn SteerFunc) RunOption

+ func UseModel(m Model) RunOption

+ type RunResult struct

+ ID string

+ Messages []Message

+ Pending []ToolCallPart

+ Steps []StepRecord

+ StopReason StopReason

+ Usage Usage

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

+ 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

+ AdditionalProperties *Schema

+ Description string

+ Format string

+ Items *Schema

+ Properties map[string]*Schema

+ Required []string

+ Type string

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

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

+ 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)

+ type StepFinish struct

+ Index int

+ Raw string

+ Reason StopReason

+ RunID string

+ Usage Usage

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

+ type StepRecord struct

+ Index int

+ RawStopReason string

+ Results []ToolResultPart

+ StopReason StopReason

+ SubagentUsage map[string]Usage

+ Text string

+ ToolCalls []ToolCallPart

+ Usage Usage

+ type StepStart struct

+ Index int

+ RunID string

+ 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

+ RunID string

+ Text string

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

+ type TextPart struct

+ Text string

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

+ 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 ToolCallPart struct

+ Args json.RawMessage

+ ID string

+ Name string

+ Signature string

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

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

+ 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 ToolDef struct

+ Description string

+ InputSchema *Schema

+ Name string

+ OutputSchema *Schema

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

+ func Subagent(name, description string, child *Agent, opts ...ToolOption) *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)

+ func (t *ToolDef) PromptSnippet() string

+ func (t *ToolDef) ReplayPolicy() ReplayPolicy

+ 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 struct

+ CallID string

+ Content string

+ IsError bool

+ Name string

+ RunID string

+ Seq int64

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

+ type ToolMiddleware func(next ToolCaller) ToolCaller

+ type ToolOption interface

+ func PromptSnippet(text string) ToolOption

+ func Replay(p ReplayPolicy) ToolOption

+ func RequireApproval() ToolOption

+ func ToolOptions(opts ...ToolOption) ToolOption

+ 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

+ RunID string

+ Seq int64

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

+ type Usage struct

+ CacheWriteTokens int64

+ CachedInputTokens int64

+ InputTokens int64

+ OutputTokens int64

+ ReasoningTokens 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