Versions in this module Expand all Collapse all v1 v1.4.0 Oct 20, 2026 Changes in this version + const CheckpointSchema + const ProviderName + const RuntimeABI + var ErrNoActiveAttempt = errors.New("no active attempt context") + type ArtifactStore interface + Open func(context.Context, string, store.ArtifactReference) (io.ReadCloser, error) + Put func(context.Context, string, string, io.Reader) (store.ArtifactReference, error) + type GrpcToolInvoker struct + func NewGrpcToolInvoker(client gatewayv1.ToolGatewayServiceClient) *GrpcToolInvoker + func (g *GrpcToolInvoker) InvokeTool(ctx context.Context, in tool.InvokeInput) (tool.InvokeResult, error) + func (g *GrpcToolInvoker) ListTools(ctx context.Context, tenantID string) ([]store.ToolDescriptor, error) + func (g *GrpcToolInvoker) ListToolsForAgent(ctx context.Context, tenantID, agentVersionRef string) ([]store.ToolDescriptor, error) + type IdentitySlot struct + func NewIdentitySlot() *IdentitySlot + func (s *IdentitySlot) Clear() + func (s *IdentitySlot) Resolve(context.Context) (mcp.AttemptContext, error) + func (s *IdentitySlot) Set(ctx mcp.AttemptContext) + type Worker struct + func NewWorker(client runtimev1.RuntimeControlServiceClient, artifacts ArtifactStore, ...) *Worker + func (w *Worker) RunOnce(ctx context.Context) (bool, error) + func (w *Worker) WithIdentitySlot(slot *IdentitySlot) *Worker + func (w *Worker) WithModelGateway(gateway modelv1.ModelGatewayServiceClient) *Worker + func (w *Worker) WithToolGateway(gateway gatewayv1.ToolGatewayServiceClient) *Worker
Go to main page