interaction

package

Go to main page

Versions in this module

v0

v0.62.0

Nov 14, 2026

Changes in this version

+ var ErrInvalidCompletionDecision = errors.New("interaction: invalid completion decision")

+ var ErrInvalidConfig = errors.New("interaction: invalid configuration")

type CompletionDecision

+ func AcceptCompletion() CompletionDecision

+ func RejectCompletion(feedback string) (CompletionDecision, error)

type ToolSetConfig

+ MaxConcurrentCalls int

+ RequiredCapabilities run.CapabilitySet

v0.61.0

Nov 10, 2026

Changes in this version

+ type HistoryProjection struct

+ func NewHistoryProjection[I, O any](program run.Program[I, O]) (*HistoryProjection, error)

+ func (h *HistoryProjection) DelegateAttributions(log run.Log) ([]DelegateAttribution, error)

+ func (h *HistoryProjection) SettledResults(log run.Log) ([]RoundResults, error)

+ type ModelCallIntent struct

+ Request *chat.Request

+ Sequence uint64

+ func ModelCallFromEffect(effect run.Effect) (ModelCallIntent, bool, error)

type ModelSettlement

+ func ModelSettlementFromRecord(record run.EffectSettled) (ModelSettlement, error)

type ToolSettlement

+ func ToolSettlementFromRecord(call chat.ToolCall, record run.EffectSettled) (ToolSettlement, error)

v0.60.0

Nov 4, 2026

Changes in this version

+ const DefaultMaxStreamDeltaBytes

+ const ToolOutcomeDispatchFailed

+ const ToolOutcomeFailed

+ const ToolOutcomeInputRequired

+ const ToolOutcomeInvalid

+ const ToolOutcomeRejected

+ const ToolOutcomeSucceeded

+ const ToolOutcomeUnknown

+ var ErrInvalidModelResponse = run.NewClassifiedError(run.FailureKindExternal, "interaction.model.invalid_response", ...)

+ var ErrInvalidModelSettlement = errors.New("interaction: invalid model settlement")

+ var ErrInvalidProtocol = run.NewClassifiedError(run.FailureKindContract, "interaction.protocol.invalid", ...)

+ var ErrInvalidResult = errors.New("interaction: invalid result")

+ var ErrModelResponseTooLarge = errors.New("interaction: model response exceeds byte limit")

+ var ErrModelStreamTooLarge = errors.New("interaction: encoded model response deltas exceed stream byte limit")

+ func Compile(compiler *run.Compiler, cfg Config) (run.Program[Input, Output], error)

+ func ModelRequestFromEffect(effect run.Effect) (*chat.Request, bool, error)

+ func ParseToolProgress(payload json.RawMessage) (tool.Progress, error)

+ func SettleModelResult[I, O any](program run.Program[I, O], request run.EffectRequest, response *chat.Response) (run.Settlement, error)

+ func SettlePreparedContext[I, O any](program run.Program[I, O], request run.EffectRequest, messages []chat.Message) (run.Settlement, error)

+ func SettleToolResult(program run.Program[Input, Output], request run.EffectRequest, ...) (run.Settlement, error)

+ type AdvertisingTool interface

+ AdvertiseDeferred func(ctx context.Context, invocation tool.Invocation, result tool.Result) ([]string, error)

type Artifact

+ func (a Artifact) ModelCallSequence() uint64

+ func (a Artifact) ToolCallID() string

type ConcurrentTool

+ ConcurrencyPolicy func() func(tool.Invocation) (key string, concurrent bool)

+ type Config struct

+ CompletionValidator CompletionValidator

+ ContextPolicy ContextPolicy

+ ContextProcessor ContextProcessor

+ Delegates []Delegate

+ Description string

+ MaxConcurrentToolCalls int

+ MaxModelCalls run.Quota

+ MaxResponseBytes int

+ Model ModelSource

+ Name string

+ RequiredToolCapabilities run.CapabilitySet

+ Revision string

+ Tools ToolSet

+ type ContextFailure struct

+ Cause error

+ func (c *ContextFailure) Error() string

+ func (c *ContextFailure) Unwrap() error

+ type ContextInvocation struct

+ Effect run.EffectRequest

+ Sequence uint64

+ type ContextPolicy func(ctx context.Context, input Input) ([]chat.Message, error)

+ type ContextProcessor interface

+ PrepareContext func(ctx context.Context, invocation ContextInvocation, request *chat.Request) ([]chat.Message, error)

+ type DelegateAttribution struct

+ func DelegateAttributions(program run.Program[Input, Output], log run.Log) ([]DelegateAttribution, error)

+ func (d DelegateAttribution) ChildKey() run.ChildKey

+ func (d DelegateAttribution) ModelCallSequence() uint64

+ func (d DelegateAttribution) ProcessID() run.ProcessID

+ func (d DelegateAttribution) Reference() (run.EffectID, bool)

+ func (d DelegateAttribution) ToolCall() chat.ToolCall

+ func (d DelegateAttribution) ToolCallIndex() uint32

+ func (d DelegateAttribution) Valid() bool

type DelegateConfig

+ Child run.ChildBinding

+ type ModelOutcome string

+ const ModelOutcomeFailed

+ const ModelOutcomeInvalid

+ const ModelOutcomeNotExecuted

+ const ModelOutcomeSucceeded

+ const ModelOutcomeUnknown

+ func (m ModelOutcome) Valid() bool

+ type ModelSettlement struct

+ Failure string

+ Outcome ModelOutcome

+ Response *chat.Response

+ func ModelSettlementFromOutcome(outcome run.Settlement) (ModelSettlement, error)

+ func (m ModelSettlement) Validate() error

+ type ModelSource interface

+ func CallModel(model chat.Model) ModelSource

+ func StreamModel(config StreamModelConfig) ModelSource

type PendingToolInput

+ func (p PendingToolInput) WaitKey() run.WaitKey

+ type ResultDisposition string

+ const ResultFailed

+ const ResultInvalid

+ const ResultRejected

+ const ResultSucceeded

+ func (r ResultDisposition) String() string

+ func (r ResultDisposition) Valid() bool

+ type ResultEntry struct

+ Call chat.ToolCall

+ Disposition ResultDisposition

+ Reference run.EffectID

+ Result chat.ToolResult

+ ToolCallIndex uint32

+ type RoundResults struct

+ func SettledResults(program run.Program[Input, Output], log run.Log) ([]RoundResults, error)

+ func (r RoundResults) CallCount() uint32

+ func (r RoundResults) Complete() bool

+ func (r RoundResults) Digest() run.Digest

+ func (r RoundResults) Entries() []ResultEntry

+ func (r RoundResults) JSON() json.RawMessage

+ func (r RoundResults) ModelCallSequence() uint64

+ func (r RoundResults) ModelEffectID() run.EffectID

+ func (r RoundResults) ProcessID() run.ProcessID

+ func (r RoundResults) Reference(index uint32) (run.EffectID, bool)

+ type StreamModelConfig struct

+ MaxDeltaBytes int

+ Streamer chat.Streamer

+ type ToolCallIntent struct

+ Call chat.ToolCall

+ ContinuationOf run.EffectID

+ func ToolCallFromEffect(effect run.Effect) (ToolCallIntent, bool, error)

type ToolInvocation

+ func ToolInvocationFromRequest(request run.EffectRequest) (ToolInvocation, error)

+ func (t ToolInvocation) Epoch() run.Epoch

+ func (t ToolInvocation) IdempotencyKey() tool.IdempotencyKey

+ func (t ToolInvocation) ProcessID() run.ProcessID

+ func (t ToolInvocation) ProgramRef() run.ProgramRef

+ func (t ToolInvocation) Reference() run.EffectID

+ type ToolOutcome string

+ func (t ToolOutcome) Valid() bool

type ToolSet

+ func (t ToolSet) Configured() bool

type ToolSetConfig

+ Middlewares []tool.CallMiddleware

+ Revision string

type ToolSettlement

+ Evidence *tool.Output

+ Outcome ToolOutcome

+ func ToolSettlementFromOutcome(call chat.ToolCall, outcome run.Settlement) (ToolSettlement, error)

v0.17.0

Sep 10, 2026

Changes in this version

type DispatcherConfig

+ Model chat.Model

+ Streamer chat.Streamer

v0.16.0

Sep 9, 2026

Changes in this version

+ var ErrInvalidToolSet = errors.New("interaction: invalid tool set")

type DefinitionConfig

+ MaxConcurrentToolCalls int

+ ToolBudget agent.Budget

+ ToolCapabilities agent.CapabilitySet

+ Tools ToolSet

+ type ModelObserver interface

+ OnModelResponse func(ctx context.Context, invocation ModelInvocation, response *chat.Response)

type PendingToolInput

+ func PendingToolInputs(snapshot agent.TreeSnapshot) ([]PendingToolInput, error)

+ func (p PendingToolInput) ProcessID() agent.ProcessID

+ type ToolObserver interface

+ OnToolSettled func(ctx context.Context, invocation ToolInvocation, settlement ToolSettlement)

+ OnToolStarted func(ctx context.Context, invocation ToolInvocation)

+ type ToolSet struct

+ func NewToolSet(config ToolSetConfig) (ToolSet, error)

+ func (t ToolSet) Deployment() agent.Deployment

+ func (t ToolSet) ObservationFailures() ObservationFailureCounts

+ func (t ToolSet) Valid() bool

+ type ToolSetConfig struct

+ ConfigurationDigest agent.Digest

+ DeferredTools []tool.Tool

+ Description string

+ ImplementationDigest agent.Digest

+ Name string

+ Observer ToolObserver

+ Tools []tool.Tool

v0.15.0

Sep 7, 2026

v0.14.0

Sep 1, 2026

v0.13.0

Aug 31, 2026

Changes in this version

type DispatcherConfig

+ ResponseMode ModelResponseMode

type ModelResponseDelta

+ func (m ModelResponseDelta) ResponseDelta() *chat.ResponseDelta

+ type ModelResponseMode string

+ const ModelResponseComplete

+ const ModelResponseStream

+ func (m ModelResponseMode) Valid() bool

v0.12.0

Aug 30, 2026

v0.11.0

Aug 30, 2026

v0.10.0

Aug 30, 2026

v0.2.1

Aug 30, 2026

Changes in this version

+ var ErrHostFailure = errors.New("interaction: host failure")

+ var ErrInvalidArtifact = errors.New("interaction: invalid artifact")

+ var ErrInvalidDefinitionConfig = errors.New("interaction: invalid definition configuration")

+ var ErrInvalidDelegate = errors.New("interaction: invalid delegate")

+ var ErrInvalidDispatcherConfig = errors.New("interaction: invalid dispatcher configuration")

+ var ErrInvalidExecutionState = errors.New("interaction: invalid execution state")

+ var ErrInvalidInput = errors.New("interaction: invalid input")

+ var ErrInvalidPendingToolInput = errors.New("interaction: invalid pending tool input")

+ var ErrInvalidSteer = errors.New("interaction: invalid steer")

+ var ErrInvalidToolAdvertisement = errors.New("interaction: invalid tool advertisement")

+ var ErrInvalidToolInputRequest = errors.New("interaction: invalid tool input request")

+ var ErrToolAdvertisementUnavailable = errors.New("interaction: tool advertisement unavailable")

+ var ErrToolInputRequired = errors.New("interaction: tool input required")

+ func AdvertiseTools(ctx context.Context, names ...string) error

+ func DelegateChildKey(modelCallSequence uint32, toolCall chat.ToolCall) (agent.ChildKey, error)

+ func HostFailure(cause error) error

+ func NewSteerSignal(id agent.SignalID, messages ...chat.Message) (agent.SignalRequest, error)

+ func NewToolInputResponseSignal(id agent.SignalID, waitID agent.WaitID, response json.RawMessage) (agent.SignalRequest, error)

+ func RequireToolInput(prompt json.RawMessage, responseSchema json.RawMessage, ...) error

+ type ActiveDelegateChild struct

+ func ActiveDelegateChildrenFromSnapshot(snapshot agent.ProcessSnapshot) (children []ActiveDelegateChild, found bool, err error)

+ func (a ActiveDelegateChild) ChildKey() agent.ChildKey

+ func (a ActiveDelegateChild) ModelCallSequence() uint32

+ func (a ActiveDelegateChild) ProcessID() agent.ProcessID

+ func (a ActiveDelegateChild) ToolCall() chat.ToolCall

+ func (a ActiveDelegateChild) ToolCallIndex() uint32

+ func (a ActiveDelegateChild) Valid() bool

+ type Artifact struct

+ func (a Artifact) Decode[T any]() (T, error)

+ func (a Artifact) DelegateName() string

+ func (a Artifact) Output() agent.Output

+ type Artifacts struct

+ func (a Artifacts) All() []Artifact

+ func (a Artifacts) Len() int

+ type CompletionCandidate struct

+ func (c CompletionCandidate) Artifacts() Artifacts

+ func (c CompletionCandidate) Output() Output

+ func (c CompletionCandidate) WorkingContext() *chat.Request

+ type CompletionDecision struct

+ Accepted bool

+ Feedback string

+ func (c CompletionDecision) Valid() bool

+ type CompletionSource string

+ const CompletionSourceDirectToolResults

+ const CompletionSourceModelResponse

+ func (c CompletionSource) Valid() bool

+ type CompletionValidator func(candidate CompletionCandidate) (CompletionDecision, error)

+ type ConcurrentTool interface

+ ConcurrencyKey func(invocation tool.Invocation) (key string, concurrent bool)

+ type Definition struct

+ func NewDefinition(config DefinitionConfig) (*Definition, error)

+ func (d *Definition) Descriptor() agent.Descriptor

+ func (d *Definition) Restore(state agent.ExecutionState) (agent.Execution, error)

+ func (d *Definition) Start(input agent.Input) (agent.Execution, error)

+ type DefinitionConfig struct

+ CompletionValidator CompletionValidator

+ Delegates []Delegate

+ Description string

+ MaxModelCalls uint32

+ Name string

+ type Delegate struct

+ func NewDelegate(config DelegateConfig) (Delegate, error)

+ func (d Delegate) Valid() bool

+ type DelegateConfig struct

+ Budget agent.Budget

+ Capabilities agent.CapabilitySet

+ Deployment agent.Deployment

+ Description string

+ Name string

+ type DirectResultTool interface

+ ReturnsDirectResult func() bool

+ type Dispatcher struct

+ func NewDispatcher(definition *Definition, config DispatcherConfig) (*Dispatcher, error)

+ func (*Dispatcher) ReplayPolicy(effect agent.Effect) agent.ReplayPolicy

+ func (d *Dispatcher) Dispatch(ctx context.Context, request agent.EffectRequest, emit agent.DeltaEmitter) (agent.Settlement, error)

+ func (d *Dispatcher) ObservationFailures() ObservationFailureCounts

+ type DispatcherConfig struct

+ Client ModelClient

+ DeferredTools []tool.Tool

+ MaxConcurrentToolCalls int

+ ModelContextReducer ModelContextReducer

+ Observer ExecutionObserver

+ StreamModelResponses bool

+ Tools []tool.Tool

+ type ExecutionObserver interface

+ OnModelResponse func(ctx context.Context, invocation ModelInvocation, response *chat.Response)

+ OnToolSettled func(ctx context.Context, invocation ToolInvocation, settlement ToolSettlement)

+ OnToolStarted func(ctx context.Context, invocation ToolInvocation)

+ type Input struct

+ Messages []chat.Message

+ Options chat.Options

+ func (i Input) Validate() error

+ type ModelClient interface

+ Call func(ctx context.Context, request *chat.Request) (*chat.Response, error)

+ Stream func(ctx context.Context, request *chat.Request) iter.Seq2[*chat.Response, error]

+ type ModelContextReducer interface

+ ReduceModelContext func(ctx context.Context, invocation ModelInvocation, request *chat.Request) ([]chat.Message, error)

+ type ModelInvocation struct

+ func ModelInvocationFromContext(ctx context.Context) (ModelInvocation, bool)

+ func (m ModelInvocation) AppliedSteerSignalIDs() []agent.SignalID

+ func (m ModelInvocation) DeploymentRef() agent.DeploymentRef

+ func (m ModelInvocation) EffectID() agent.EffectID

+ func (m ModelInvocation) ModelCallSequence() uint32

+ func (m ModelInvocation) Relation() agent.ProcessRelation

+ func (m ModelInvocation) StepSequence() uint64

+ func (m ModelInvocation) Valid() bool

+ type ModelResponseDelta struct

+ func ParseModelResponseDelta(payload json.RawMessage) (ModelResponseDelta, error)

+ func (m ModelResponseDelta) Response() *chat.Response

+ type ObservationFailureCounts struct

+ func (c ObservationFailureCounts) ModelResponsePanics() uint64

+ func (c ObservationFailureCounts) ToolSettledPanics() uint64

+ func (c ObservationFailureCounts) ToolStartedPanics() uint64

+ type Output struct

+ DirectToolResults []chat.ToolResult

+ ModelCalls uint32

+ ModelResponse *chat.Response

+ Source CompletionSource

+ func (o Output) Validate() error

+ type PendingToolInput struct

+ func PendingToolInputFromProcess(ctx context.Context, process *agent.Process) (PendingToolInput, bool, error)

+ func PendingToolInputFromSnapshot(snapshot agent.ProcessSnapshot) (PendingToolInput, bool, error)

+ func (p PendingToolInput) Prompt() json.RawMessage

+ func (p PendingToolInput) ResponseSchema() json.RawMessage

+ func (p PendingToolInput) ResponseSignal(id agent.SignalID, response json.RawMessage) (agent.SignalRequest, error)

+ func (p PendingToolInput) Valid() bool

+ func (p PendingToolInput) WaitID() agent.WaitID

+ type ToolInputContinuation struct

+ func ToolInputContinuationFromContext(ctx context.Context) (ToolInputContinuation, bool)

+ func (t ToolInputContinuation) Response() json.RawMessage

+ func (t ToolInputContinuation) State() json.RawMessage

+ type ToolInputRequest struct

+ func NewToolInputRequest(prompt json.RawMessage, responseSchema json.RawMessage, ...) (ToolInputRequest, error)

+ func (t ToolInputRequest) ContinuationState() json.RawMessage

+ func (t ToolInputRequest) Prompt() json.RawMessage

+ func (t ToolInputRequest) ResponseSchema() json.RawMessage

+ func (t ToolInputRequest) Valid() bool

+ type ToolInputRequiredError struct

+ func (*ToolInputRequiredError) Unwrap() error

+ func (t *ToolInputRequiredError) Error() string

+ type ToolInvocation struct

+ func ToolInvocationFromContext(ctx context.Context) (ToolInvocation, bool)

+ func (t ToolInvocation) DeploymentRef() agent.DeploymentRef

+ func (t ToolInvocation) EffectID() agent.EffectID

+ func (t ToolInvocation) ModelCallSequence() uint32

+ func (t ToolInvocation) ModelResult(output chat.ToolOutput, cause error) (result chat.ToolResult, present bool)

+ func (t ToolInvocation) Relation() agent.ProcessRelation

+ func (t ToolInvocation) StepSequence() uint64

+ func (t ToolInvocation) ToolCall() chat.ToolCall

+ func (t ToolInvocation) ToolCallIndex() uint32

+ func (t ToolInvocation) Valid() bool

+ type ToolSettlement struct

+ Failure string

+ InputRequired bool

+ Result *chat.ToolResult

+ Unknown bool

v0.2.0

Aug 27, 2026

v0.1.0

Aug 27, 2026

v0.0.1

Aug 27, 2026

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