Documentation
¶
Overview ¶
Package executor provides registry-backed tool execution. It routes tool invocations through the registry gateway and awaits results on Pulse streams.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
CallTool(
ctx context.Context,
toolset string,
tool tools.Ident,
payload []byte,
meta toolregistry.ToolCallMeta,
) (toolregistry.ToolCallRef, error)
RetryTool(
ctx context.Context,
toolset string,
tool tools.Ident,
payload []byte,
meta toolregistry.ToolCallMeta,
expectedRegistrationToken string,
) (toolregistry.ToolCallRef, error)
}
Client initiates tool calls and returns both transport identity and the exact admission-generation token stamped on the routed request.
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func (*Executor) Execute ¶
func (e *Executor) Execute(ctx context.Context, meta *runtime.ToolCallMeta, call *planner.ToolRequest) (*runtime.ToolExecutionResult, error)
type Option ¶
type Option func(*Executor)
func WithLogger ¶
WithLogger configures the executor logger. When nil, the executor uses a noop logger.
func WithStreamSink ¶
WithStreamSink configures the executor to forward best-effort tool output delta frames into the provided stream sink while it waits for the canonical tool result message. This does not affect tool execution semantics: the final tool result remains authoritative.
func WithTracer ¶
WithTracer configures the executor tracer. When nil, the executor uses a noop tracer.
Source Files