Set di strumenti

Learn about toolset types, execution models, validation, retry hints, and tool catalogs in Goa-AI.

I set di strumenti sono raccolte di strumenti che gli agenti possono utilizzare. Goa-AI supporta diversi tipi di set di strumenti, ciascuno con diversi modelli di esecuzione e casi d’uso.

Tipi di set di strumenti

Set di strumenti di proprietà del servizio (supportati da metodi)

Dichiarati tramite Toolset("name", func() { ... }); gli strumenti possono BindTo metodi del servizio Goa o essere implementati da esecutori personalizzati.

  • Codegen emette specifiche/tipi/codici per gli strumenti sotto gen/<service>/tools/<toolset>/
  • Gli agenti che Use questi set di strumenti importano le specifiche del provider e ottengono costruttori di chiamate tipizzate e fabbriche di esecutori
  • Le applicazioni registrano gli esecutori che decodificano gli argomenti tipizzati (tramite i codec forniti dal runtime), usano facoltativamente le trasformazioni, chiamano i client di servizio e restituiscono ToolResult

Set di strumenti implementati dagli agenti (Agent-as-Tool)

Definiti nel blocco Export di un agente e facoltativamente Usedagli altri agenti.

  • La proprietà è ancora del servizio; l’agente è l’implementazione
  • Codegen emette aiutanti lato fornitore agenttools/<toolset> con NewRegistration e costruttori di chiamate digitate
  • Gli helper lato consumatore negli agenti che Use il toolset esportato delegano agli helper del fornitore mantenendo i metadati di routing centralizzati
  • L’esecuzione avviene in linea; i payload sono passati come JSON canonico e decodificati solo al limite, se necessario per i prompt

Set di strumenti MCP

Dichiarati tramite MCPToolset(service, suite) e referenziati tramite Use(MCPToolset(...)).

  • La registrazione generata imposta DecodeInExecutor=true in modo che il JSON grezzo sia passato all’esecutore MCP
  • L’esecutore MCP decodifica utilizzando i propri codec
  • I wrapper generati gestiscono schemi/encoder JSON e trasporti (HTTP/SSE/stdio) con tentativi e tracciamento

Quando utilizzare BindTo rispetto alle implementazioni in linea

Usare BindTo quando:

  • Lo strumento deve chiamare un metodo di servizio Goa esistente
  • Si desidera generare trasformazioni tra i tipi di strumento e metodo
  • Il metodo del servizio ha già la logica di business di cui si ha bisogno
  • Si vuole riutilizzare la convalida e la gestione degli errori dal livello di servizio
// Tool bound to existing service method
Tool("search", "Search documents", func() {
    Args(SearchPayload)
    Return(SearchResult)
    BindTo("Search")  // Calls the Search method on the same service
})

Usare le implementazioni inline quando:

  • Lo strumento ha una logica personalizzata non legata a un metodo del servizio
  • È necessario orchestrare più chiamate al servizio
  • Lo strumento è puramente computazionale (nessuna chiamata esterna)
  • Si desidera il pieno controllo del flusso di esecuzione
// Tool with custom executor implementation
Tool("summarize", "Summarize multiple documents", func() {
    Args(func() {
        Attribute("doc_ids", ArrayOf(String), "Document IDs to summarize")
        Required("doc_ids")
    })
    Return(func() {
        Attribute("summary", String, "Combined summary")
        Required("summary")
    })
    // No BindTo - implement in executor
})

Per le implementazioni inline, si scrive direttamente la logica dell’esecutore:

func (e *Executor) Execute(ctx context.Context, meta *runtime.ToolCallMeta, call *planner.ToolRequest) (*planner.ToolResult, error) {
    switch call.Name {
    case specs.Summarize:
        args, _ := specs.UnmarshalSummarizePayload(call.Payload)
        // Custom logic: fetch multiple docs, combine, summarize
        summary := e.summarizeDocuments(ctx, args.DocIDs)
        return &planner.ToolResult{
            Name:   call.Name,
            Result: &specs.SummarizeResult{Summary: summary},
        }, nil
    }
    return nil, fmt.Errorf("unknown tool: %s", call.Name)
}

### Bounded Tool Results

Some tools naturally return large lists, graphs, or time-series windows. You can mark these as **bounded views** so that services remain responsible for trimming while the runtime enforces and surfaces the contract.

#### The agent.Bounds Contract

The `agent.Bounds` type is a small, provider-agnostic contract that describes how a tool result has been bounded relative to the full underlying data set:

```go
tipo Bounds struct {
    Returned int // Numero di elementi nella vista delimitata
    Total *int // Totale al meglio prima del troncamento (opzionale)
    Truncated bool // Se sono stati applicati dei tappi (lunghezza, finestra, profondità)
    RefinementHint string // Guida su come restringere la query quando è troncata
}
FieldDescription
ReturnedCount of items actually present in the result
TotalBest-effort count of total items before truncation (nil if unknown)
TruncatedTrue if any caps were applied (pagination, depth limits, size limits)
RefinementHintHuman-readable guidance for narrowing the query (e.g., “Add a date filter to reduce results”)

Service Responsibility for Trimming

The runtime does not compute subsets or truncation itself—services are responsible for:

  1. Applying truncation logic: Pagination, result limits, depth caps, time windows
  2. Populating bounds metadata: Setting Returned, Total, Truncated accurately
  3. Providing refinement hints: Guiding users/models on how to narrow queries when results are truncated

This design keeps truncation logic where domain knowledge lives (in services) while providing a uniform contract for the runtime, planners, and UIs to consume.

Declaring Bounded Tools

Use the DSL helper BoundedResult() inside a Tool definition:

Tool("list_devices", "Elenco dei dispositivi con paginazione", func() {
    Args(func() {
        Attributo("site_id", String, "Identificatore del sito")
        Attributo("stato", Stringa, "Filtrare per stato", func() {
            Enum("online", "offline", "sconosciuto")
        })
        Attributo("limite", Int, "Risultati massimi", func() {
            Predefinito(50)
            Massimo(500)
        })
        Required("site_id")
    })
    Return(func() {
        Attribute("devices", ArrayOf(Device), "Dispositivi corrispondenti")
        Attribute("returned", Int, "Conteggio dei dispositivi restituiti")
        Attributo("total", Int, "Totale dispositivi corrispondenti")
        Attributo("troncato", Booleano, "I risultati sono stati troncati")
        Attributo("refinement_hint", Stringa, "Come restringere i risultati")
        Richiesto("dispositivi", "restituiti")
    })
    BoundedResult()
    BindTo("DeviceService", "ListDevices")
})

Code Generation

When a tool is marked with BoundedResult():

  • The generated tool spec includes BoundedResult: true
  • The generated result alias type includes a Bounds *agent.Bounds field
  • Generated result types implement the agent.BoundedResult interface:
// Implementazione dell'interfaccia generata
tipo ListDevicesResult struct {
    Dispositivi []*Dispositivo
    Restituito int
    Totale *int
    Troncato bool
    RefinementHint string
}

func (r *ListDevicesResult) ResultBounds() *agent.Bounds {
    return &agent.Bounds{
        Restituito: r.Restituito,
        Totale: r.Total,
        Troncato: r.Troncato,
        RefinementHint: r.RefinementHint,
    }
}

Implementing Bounded Tools

Services implement truncation and populate bounds metadata:

func (s *DeviceService) ListDevices(ctx context.Context, p *ListDevicesPayload) (*ListDevicesResult, error) {
    // Interrogazione con limite + 1 per rilevare il troncamento
    devices, err := s.repo.QueryDevices(ctx, p.SiteID, p.Status, p.Limit+1)
    se err := nil {
        return nil, err
    }
    
    // Determinare se i risultati sono stati troncati
    troncato := len(dispositivi) > p.Limite
    if truncated {
        devices = devices[:p.Limit] // Taglia al limite richiesto
    }
    
    // Ottenere il conteggio totale (opzionale, può essere costoso)
    total, _ := s.repo.CountDevices(ctx, p.SiteID, p.Status)
    
    // Costruire un suggerimento di raffinatezza quando viene troncato
    var hint stringa
    se troncato {
        hint = "Aggiungere un filtro di stato o ridurre l'ambito del sito per vedere meno risultati"
    }
    
    return &ElencoDispositiviRisultato{
        Dispositivi: dispositivi,
        Restituito: len(dispositivi),
        Totale: &totale,
        Troncato: troncato,
        RefinementHint: hint,
    }, nil
}

Runtime Behavior

When a bounded tool executes:

  1. The runtime decodes the result and checks for agent.BoundedResult implementation
  2. If the result implements the interface, ResultBounds() extracts bounds metadata
  3. Bounds are attached to planner.ToolResult.Bounds
  4. Stream subscribers and finalizers can access bounds for UI display, logging, or policy decisions
// In un sottoscrittore di flusso
func handleToolEnd(event *stream.ToolEndEvent) {
    if event.Bounds != nil && event.Bounds.Truncated {
        log.Printf("Lo strumento %s ha restituito %d di %d risultati (troncati)",
            event.ToolName, event.Bounds.Returned, *event.Bounds.Total)
        se event.Bounds.RefinementHint != "" {
            log.Printf("Suggerimento: %s", event.Bounds.RefinementHint)
        }
    }
}

When to Use BoundedResult

Use BoundedResult() for tools that:

  • Return paginated lists (devices, users, records, logs)
  • Query large datasets with result limits
  • Apply depth or size caps to nested structures (graphs, trees)
  • Return time-windowed data (metrics, events)

The bounded contract helps:

  • Models understand that results may be incomplete and can request refinement
  • UIs display truncation indicators and pagination controls
  • Policies enforce size limits and detect runaway queries

Injected Fields

The Inject DSL function marks specific payload fields as “injected”—server-side infrastructure values that are hidden from the LLM but required by the service method. This is useful for session IDs, user context, authentication tokens, and other runtime-provided values.

How Inject Works

When you mark a field with Inject:

  1. Hidden from LLM: The field is excluded from the JSON schema sent to the model provider
  2. Generated setter: Codegen emits a setter method on the payload struct
  3. Runtime population: You populate the field via a ToolInterceptor before execution

DSL Declaration

Tool("get_user_data", "Ottieni dati per l'utente corrente", func() {
    Args(func() {
        Attribute("session_id", String, "ID della sessione corrente")
        Attributo("query", Stringa, "Domanda di dati")
        Required("session_id", "query")
    })
    Return(func() {
        Attributo("dati", ArrayOf(String), "Risultati della query")
        Richiesto("dati")
    })
    BindTo("UserService", "GetData")
    Inject("session_id") // Nascosto da LLM, popolato a runtime
})

Generated Code

Codegen produces a setter method for each injected field:

// Carico utile generato struct
type GetUserDataPayload struct {
    Stringa SessionID `json:"session_id"`
    Query string `json:"query"`
}

// Setter generato per il campo iniettato
func (p *GetUserDataPayload) SetSessionID(v string) {
    p.SessionID = v
}

Runtime Population via ToolInterceptor

Use a ToolInterceptor to populate injected fields before tool execution:

tipo SessionInterceptor struct{}

func (i *SessionInterceptor) InterceptToolCall(ctx context.Context, call *planner.ToolCall) error {
    // Estrae la sessione dal contesto (impostata dal middleware di autenticazione)
    sessionID, ok := ctx.Value(sessionKey).(string)
    if !ok {
        return fmt.Errorf("ID sessione non trovato nel contesto")
    }
    
    // Popola il campo iniettato usando il setter generato
    switch call.Name {
    case specs.GetUserData:
        payload, _ := specs.UnmarshalGetUserDataPayload(call.Payload)
        payload.SetSessionID(sessionID)
        call.Payload, _ = json.Marshal(payload)
    }
    return nil
}

// Registra l'intercettore con il runtime
rt := runtime.New(runtime.WithToolInterceptor(&SessionInterceptor{}))

When to Use Inject

Use Inject for fields that:

  • Are required by the service but shouldn’t be chosen by the LLM
  • Come from runtime context (session, user, tenant, request ID)
  • Contain sensitive values (auth tokens, API keys)
  • Are infrastructure concerns (tracing IDs, correlation IDs)

Execution Models

Activity-Based Execution (Default)

Service-backed toolsets execute via Temporal activities (or equivalent in other engines):

  1. Planner returns tool calls in PlanResult (payload is json.RawMessage)
  2. Runtime schedules ExecuteToolActivity for each tool call
  3. Activity decodes payload via generated codec for validation/hints
  4. Calls the toolset registration’s Execute(ctx, planner.ToolRequest) with canonical JSON
  5. Re-encodes the result with the generated result codec

Inline Execution (Agent-as-Tool)

Agent-as-tool toolsets execute inline from the planner’s perspective while the runtime runs the provider agent as a real child run:

  1. The runtime detects Inline=true on the toolset registration
  2. It injects the engine.WorkflowContext into ctx so the toolset’s Execute function can start the provider agent as a child workflow with its own RunID
  3. It calls the toolset’s Execute(ctx, call) with canonical JSON payload and tool metadata (including parent RunID and ToolCallID)
  4. The generated agent-tool executor builds nested agent messages (system + user) from the tool payload and runs the provider agent as a child run
  5. The nested agent executes a full plan/execute/resume loop in its own run; its RunOutput and tool events are aggregated into a parent planner.ToolResult that carries the result payload, aggregated telemetry, child ChildrenCount, and a RunLink pointing at the child run
  6. Stream subscribers emit both tool_start / tool_end for the parent tool call and an agent_run_started link event so UIs and debuggers can attach to the child run’s stream on demand

Executor-First Model

Generated service toolsets expose a single, generic constructor:

New<Agent><Toolset>ToolsetRegistration(exec runtime.ToolCallExecutor)

Applications register an executor implementation for each consumed toolset. The executor decides how to run the tool (service client, MCP, nested agent, etc.) and receives explicit per-call metadata via ToolCallMeta.

Executor Example:

func Execute(ctx context.Context, meta runtime.ToolCallMeta, call planner.ToolRequest) (planner.ToolResult, error) {
    switch call.Name {
    case "orchestrator.profiles.upsert":
        args, err := profilesspecs.UnmarshalUpsertPayload(call.Payload)
        if err := nil {
            return planner.ToolResult{
                Errore: planner.NewToolError("payload non valido"),
            }, nil
        }
        
        // Trasformazioni opzionali se emesse da codegen
        mp, _ := profilesspecs.ToMethodPayload_Upsert(args)
        methodRes, err := client.Upsert(ctx, mp)
        se err != nil {
            return planner.ToolResult{
                Errore: planner.ToolErrorFromError(err),
            }, nil
        }
        tr, _ := profilesspecs.ToToolReturn_Upsert(methodRes)
        return planner.ToolResult{Payload: tr}, nil
        
    predefinito:
        return planner.ToolResult{
            Errore: planner.NewToolError("strumento sconosciuto"),
        }, nil
    }
}

Tool Call Metadata

Tool executors receive explicit per-call metadata via ToolCallMeta rather than fishing values from context.Context. This provides direct access to run-scoped identifiers for correlation, telemetry, and parent/child relationships.

ToolCallMeta Fields

FieldDescription
RunIDDurable workflow execution identifier of the run that owns this tool call. Stable across retries; used to correlate runtime records and telemetry.
SessionIDLogically groups related runs (e.g., a chat conversation). Services typically index memory and search attributes by session.
TurnIDIdentifies the conversational turn that produced this tool call. Event streams use it to order and group events.
ToolCallIDUniquely identifies this tool invocation. Used to correlate start/update/end events and parent/child relationships.
ParentToolCallIDIdentifier of the parent tool call when this invocation is a child (e.g., a tool launched by an agent-tool). UIs and subscribers use it to reconstruct the call tree.

Executor Signature

All tool executors receive ToolCallMeta as an explicit parameter:

func Execute(ctx context.Context, meta *runtime.ToolCallMeta, call *planner.ToolRequest) (*planner.ToolResult, error) {
    // Accedere al contesto di esecuzione direttamente da meta
    log.Printf("Esecuzione dello strumento nella corsa %s, sessione %s, turno %s",
        meta.RunID, meta.SessionID, meta.TurnID)
    
    // Utilizza ToolCallID per la correlazione
    span := tracer.StartSpan("tool.execute", trace.WithAttributes(
        attribute.String("tool.call_id", meta.ToolCallID),
        attribute.String("tool.parent_call_id", meta.ParentToolCallID),
    ))
    rinviare span.End()
    
    // ... implementazione dello strumento
}

Why Explicit Metadata?

The explicit metadata pattern provides several benefits:

  • Type safety: Compile-time guarantees that required identifiers are available
  • Testability: Easy to construct test metadata without mocking context
  • Clarity: No hidden dependencies on context keys or middleware ordering
  • Correlation: Direct access to parent/child relationships for nested agent-tool calls
  • Traceability: Complete causal chain from user input to tool execution to final response

Async & Durable Execution

Goa-AI uses Temporal Activities for all service-backed tool executions. This “async-first” architecture is implicit and requires no special DSL.

Implicit Async

When a planner decides to call a tool, the runtime does not block the OS thread. Instead:

  1. The runtime schedules a Temporal Activity for the tool call.
  2. The agent workflow suspends execution (saving state).
  3. The activity executes (on a local worker, remote worker, or even a different cluster).
  4. When the activity completes, the workflow wakes up, restores state, and resumes with the result.

This means every tool call is automatically parallelizable, durable, and long-running. You do not need to configure InterruptsAllowed for this standard async behavior.

Pause & Resume (Agent-Level)

InterruptsAllowed(true) is distinct: it allows the Agent itself to pause and wait for an arbitrary external signal (like a user’s clarification) that is not tied to a currently running tool activity.

FeatureImplicit AsyncPause & Resume
ScopeSingle Tool ExecutionEntire Agent Workflow
TriggerCalling any service-backed toolMissing arguments or Planner request
Policy RequiredNone (Default)InterruptsAllowed(true)
Use CaseSlow API, Batch Job, processingHuman-in-the-loop, Clarification

Ensure you verify that your use case requires agent-level pausing before enabling the policy; often, standard tool async is sufficient.

Non-Blocking Planners

From the perspective of the planner (LLM), the interaction feels synchronous: the model requests a tool, “pauses”, and then “sees” the result in the next turn.

From the perspective of the infrastructure, it is fully asynchronous and non-blocking. This allows a single small agent worker to manage thousands of concurrent long-running agent executions without running out of threads or memory.

Survival Across Restarts

Because execution is durable, you can restart your entire backend—including the agent workers—while tools are mid-execution. When the systems come back up:

  • Pending tool activities will be picked up by workers.
  • Completed tools will report results to their parent workflows.
  • Agents will resume exactly where they left off.

This capability is essential for building robust, production-grade agentic systems that operate reliably in dynamic environments.


Transforms

When a tool is bound to a Goa method via BindTo, code generation analyzes the tool Arg/Return and the method Payload/Result. If the shapes are compatible, Goa emits type-safe transform helpers:

  • ToMethodPayload_<Tool>(in <ToolArgs>) (<MethodPayload>, error)
  • ToToolReturn_<Tool>(in <MethodResult>) (<ToolReturn>, error)

Transforms are emitted under gen/<service>/agents/<agent>/specs/<toolset>/transforms.go and use Goa’s GoTransform to safely map fields. If a transform isn’t emitted, write an explicit mapper in the executor.


Tool Identity

Each toolset defines typed tool identifiers (tools.Ident) for all generated tools—including non-exported toolsets. Prefer these constants over ad-hoc strings:

import chattools "example.com/assistant/gen/orchestrator/agents/chat/agenttools/search"

// Usare una costante generata invece di stringhe/cast ad hoc
spec, _ := rt.ToolSpec(chattools.Search)
schemas, _ := rt.ToolSchema(chattools.Search)

For exported toolsets (agent-as-tool), Goa-AI also generates agenttools packages with:

  • Typed tool IDs
  • Alias payload/result types
  • Codecs
  • Helper builders (e.g., New<Search>Call)

Tool Validation and Retry Hints

Goa-AI combines Goa’s design-time validations with a structured tool error model to give LLM planners a powerful way to repair invalid tool calls automatically.

Core Types: ToolError and RetryHint

ToolError (alias to runtime/agent/toolerrors.ToolError):

  • Message string – human-readable summary
  • Cause *ToolError – optional nested cause (preserves chains across retries and agent-as-tool hops)
  • Constructors: planner.NewToolError(msg), planner.NewToolErrorWithCause(msg, cause), planner.ToolErrorFromError(err), planner.ToolErrorf(format, args...)

RetryHint – planner-side hint used by the runtime and policy engine:

type RetryHint struct {
    Motivo RetryReason
    Strumento tools.Ident
    RestrictToTool bool
    Campi mancanti []stringa
    ExampleInput map[string]any
    PriorInput map[string]any
    Stringa ClarifyingQuestion
    Messaggio stringa
}

Common RetryReason values:

  • invalid_arguments – payload failed validation (schema/type)
  • missing_fields – required fields are missing
  • malformed_response – tool returned data that could not be decoded
  • timeout, rate_limited, tool_unavailable – execution/infra issues

ToolResult carries errors and hints:

tipo ToolResult struct {
    Nome tools.Ident
    Risultato qualsiasi
    Errore *ErroreStrumenti
    Suggerimento di riprova *RetryHint
    Telemetria *telemetria.ToolTelemetry
    ToolCallID stringa
    ChildrenCount int
    RunLink *run.Handle
}

Auto-Repairing Invalid Tool Calls

The recommended pattern:

  1. Design tools with strong payload schemas (Goa design)
  2. Let executors/tools surface validation failures as ToolError + RetryHint instead of panicking or hiding errors
  3. Teach your planner to inspect ToolResult.Error and ToolResult.RetryHint, repair the payload when possible, and retry the tool call if appropriate

Example Executor:

func Execute(ctx context.Context, meta runtime.ToolCallMeta, call planner.ToolRequest) (*planner.ToolResult, error) {
    args, err := spec.UnmarshalUpsertPayload(call.Payload)
    se err := nil {
        return &planner.ToolResult{
            Nome: call.Name,
            Errore: planner.NewToolError("payload non valido"),
            RetryHint: &planner.RetryHint{
                Motivo: planner.RetryReasonInvalidArguments,
                Strumento: call.Name,
                RestrictToTool: true,
                Messaggio:       "Il payload non corrisponde allo schema previsto",
            },
        }, nil
    }

    res, err := client.Upsert(ctx, args)
    se err != nil {
        restituisce &planner.ToolResult{
            Nome: call.Name,
            Errore: planner.ToolErrorFromError(err),
        }, nil
    }

    return &planner.ToolResult{Name: call.Name, Result: res}, nil
}

Example Planner Logic:

func (p *MyPlanner) PlanResume(ctx context.Context, in *planner.PlanResumeInput) (*planner.PlanResult, error) {
    if len(in.ToolResults) == 0 {
        return &planner.PlanResult{}, nil
    }

    last := in.ToolResults[len(in.ToolResults)-1]
    se last.Error := nil && last.RetryHint := nil {
        hint := last.RetryHint

        switch hint.Reason {
        case planner.RetryReasonMissingFields, planner.RetryReasonInvalidArguments:
            return &planner.PlanResult{
                Attesa: &planner.Await{
                    Chiarimento: &planner.AwaitClarification{
                        ID:               "fix-" + string(hint.Tool),
                        Domanda: hint.ClarifyingQuestion,
                        MissingFields: hint.MissingFields,
                        RestrictToTool: hint.Tool,
                        ExampleInput: hint.ExampleInput,
                        ClarifyingPrompt: hint.Message,
                    },
                },
            }, nil
        }
    }

    return &planner.PlanResult{/* FinalResponse, next ToolCalls, ... */}, nil
}

Tool Catalogs and Schemas

Goa-AI agents generate a single, authoritative catalog of tools from your Goa designs. This catalog powers:

  • Planner tool advertisement (which tools the model can call)
  • UI discovery (tool lists, categories, schemas)
  • External orchestrators (MCP, custom frontends) that need machine-readable specs

Generated Specs and tool_schemas.json

For each agent, Goa-AI emits a specs package and a JSON catalog:

Specs packages (gen/<service>/agents/<agent>/specs/...):

  • types.go – payload/result Go structs
  • codecs.go – JSON codecs (encode/decode typed payloads/results)
  • specs.go[]tools.ToolSpec entries with canonical tool ID, payload/result schemas, hints

JSON catalog (tool_schemas.json):

Location: gen/<service>/agents/<agent>/specs/tool_schemas.json

Contains one entry per tool with:

  • id – canonical tool ID ("<service>.<toolset>.<tool>")
  • service, toolset, title, description, tags
  • payload.schema and result.schema (JSON Schema)

This JSON file is ideal for feeding schemas to LLM providers, building UI forms/editors, and offline documentation tooling.

Runtime Introspection APIs

At runtime, you do not need to read tool_schemas.json from disk. The runtime exposes an introspection API:

agents := rt.ListAgents() // []agent.Ident
toolset := rt.ListToolsets() // []stringa

spec, ok := rt.ToolSpec(toolID) // singolo ToolSpec
schemas, ok := rt.ToolSchema(toolID) // schemi di payload/risultato
specs := rt.ToolSpecsForAgent(chat.AgentID) // []ToolSpec per un agente

Where toolID is a typed tools.Ident constant from a generated specs or agenttools package.

Typed Sidecars and Artifacts

Some tools need to return rich artifacts (full time series, topology graphs, large result sets) that are useful for UIs and audits but too heavy for model providers. Goa-AI models these as typed sidecars (also called artifacts):

Model-Facing vs Sidecar Data

The key distinction is what data flows where:

Data TypeSent to ModelStored/StreamedPurpose
Model-facing resultBounded summary the LLM reasons about
Sidecar/ArtifactFull-fidelity data for UIs, audits, downstream consumers

This separation lets you:

  • Keep model context windows bounded and focused
  • Provide rich visualizations (charts, graphs, tables) without bloating LLM prompts
  • Attach provenance and audit data that models don’t need to see
  • Stream large datasets to UIs while the model works with summaries

Declaring Artifacts in DSL

Use the Artifact(kind, schema) function inside a Tool definition:

Tool("get_time_series", "Ottieni i dati delle serie temporali", func() {
    Args(func() {
        Attributo("device_id", String, "Identificatore del dispositivo")
        Attributo("start_time", Stringa, "Timestamp iniziale (RFC3339)")
        Attributo("end_time", Stringa, "Timestamp di fine (RFC3339)")
        Required("device_id", "start_time", "end_time")
    })
    // Risultato rivolto al modello: riepilogo delimitato
    Return(func() {
        Attributo("summary", String, "Riepilogo del modello")
        Attributo("count", Int, "Numero di punti dati")
        Attributo("min_value", Float64, "Valore minimo nell'intervallo")
        Attributo("max_value", Float64, "Valore massimo nell'intervallo")
        Richiesto("summary", "count")
    })
    // Sidecar: dati a piena fedeltà per le UI
    Artefatto("time_series", func() {
        Attributo("data_points", ArrayOf(TimeSeriesPoint), "Dati completi della serie temporale")
        Attributo("metadata", MapOf(String, String), "Metadati aggiuntivi")
        Richiesto("data_points")
    })
})

The kind parameter (e.g., "time_series") identifies the artifact type so UIs can dispatch appropriate renderers.

Generated Specs and Helpers

In the specs packages, each tools.ToolSpec entry includes:

  • Payload tools.TypeSpec – tool input schema
  • Result tools.TypeSpec – model-facing output schema
  • Sidecar *tools.TypeSpec (optional) – artifact schema

Goa-AI generates typed helpers for working with sidecars:

// Ottenere un artefatto da uno strumento risultato
func GetGetTimeSeriesSidecar(res *planner.ToolResult) (*GetTimeSeriesSidecar, error)

// Associa l'artefatto al risultato di uno strumento
func SetGetTimeSeriesSidecar(res *planner.ToolResult, sc *GetTimeSeriesSidecar) errore

Runtime Usage Patterns

In tool executors, attach artifacts to results:

func (e *Executor) Execute(ctx context.Context, meta *runtime.ToolCallMeta, call *planner.ToolRequest) (*planner.ToolResult, error) {
    args, _ := specs.UnmarshalGetTimeSeriesPayload(call.Payload)
    
    // Recupera i dati completi
    fullData, err := e.dataService.GetTimeSeries(ctx, args.DeviceID, args.StartTime, args.EndTime)
    se err := nil {
        return &planner.ToolResult{Errore: planner.ToolErrorFromError(err)}, nil
    }
    
    // Costruire un risultato delimitato rivolto al modello
    risultato := &specs.GetTimeSeriesResult{
        Summary: fmt.Sprintf("Recuperati %d punti dati da %s a %s", len(fullData.Points), args.StartTime, args.EndTime),
        Count: len(fullData.Points),
        MinValue: fullData.Min,
        MaxValue: fullData.Max,
    }
    
    // Costruire l'artefatto a piena fedeltà per le UI
    artefatto := &specs.GetTimeSeriesSidecar{
        DataPoints: fullData.Points,
        Metadati: fullData.Metadata,
    }
    
    // Allega l'artefatto al risultato
    toolResult := &planner.ToolResult{
        Nome: call.Name,
        Risultato: risultato,
    }
    specs.SetGetTimeSeriesSidecar(toolResult, artefatto)
    
    restituisce toolResult, nil
}

In stream subscribers or UI handlers, access artifacts:

func handleToolEnd(event *stream.ToolEndEvent) {
    // Gli artefatti sono disponibili sull'evento
    for _, artifact := range event.Artifacts {
        switch artifact.Kind {
        case "time_series":
            // Renderizza il grafico delle serie temporali
            renderTimeSeriesChart(artifact.Data)
        case "topology":
            // Renderizza il grafico della rete
            renderTopologyGraph(artifact.Data)
        }
    }
}

Artifact Structure

The planner.Artifact type carries:

tipo Artefatto struct {
    Kind string // Tipo logico (ad esempio, "time_series", "chart_data")
    Data any // Carico utile serializzabile in JSON
    SourceTool tools.Ident // Strumento che ha prodotto questo artefatto
    RunLink *run.Handle // Collegamento all'esecuzione dell'agente nidificato (per agent-as-tool)
}

Quando usare gli artefatti

Utilizzare gli artefatti quando:

  • I risultati dello strumento includono dati troppo grandi per il contesto del modello (serie temporali, log, tabelle di grandi dimensioni)
  • Le interfacce utente hanno bisogno di dati strutturati per la visualizzazione (grafici, diagrammi, mappe)
  • Si vuole separare ciò che il modello ragiona da ciò che gli utenti vedono
  • I sistemi a valle hanno bisogno di dati a piena fedeltà, mentre il modello lavora con sintesi

Evitare gli artefatti quando:

  • Il risultato completo si inserisce comodamente nel contesto del modello
  • Non c’è un’interfaccia utente o un utente a valle che abbia bisogno dei dati completi
  • Il risultato delimitato contiene già tutto ciò che serve

Migliori pratiche

  • Inserire le convalide nella progettazione, non nei progettisti - Usare il DSL degli attributi di Goa (Required, MinLength, Enum, ecc.)
  • Restituire ToolError + RetryHint dagli esecutori - Preferire gli errori strutturati ai panici o ai semplici ritorni error
  • Mantenere i suggerimenti concisi ma perseguibili - Concentrarsi sui campi mancanti/invalidi, su una breve domanda chiarificatrice e su una piccola mappa ExampleInput
  • Insegnare ai pianificatori a leggere i suggerimenti - Rendere la gestione di RetryHint una parte di prima classe del vostro pianificatore
  • Evitare la riconvalida all’interno dei servizi - Goa-AI presume che la convalida avvenga al confine con lo strumento

Prossimi passi