Versions in this module Expand all Collapse all v1 v1.4.0 Oct 20, 2026 Changes in this version + const SyscallABIMajor + const SyscallABIMinor + const SyscallABIPatch + const SyscallABIVersion + type AttemptIdentity struct + AttemptID uuid.UUID + FencingToken int64 + TenantID string + type DispatcherOption func(*SyscallDispatcher) + func WithAllowedTenant(tenant string) DispatcherOption + func WithMetrics(m Metrics) DispatcherOption + func WithNamespaceEnforcer(enforcer *namespace.Enforcer) DispatcherOption + func WithRuntimeFence(fences RuntimeFence) DispatcherOption + func WithTracer(t trace.Tracer) DispatcherOption + type EffectExecutePayload struct + AgentID string + Deadline *time.Time + IdempotencyKey string + Operation string + Payload json.RawMessage + Provider string + RunID string + TraceID string + type EffectGetPayload struct + AgentID string + EffectID string + IdempotencyKey string + type EffectInvoker interface + ExecuteEffect func(ctx context.Context, req *effect.EffectRequest) (*effect.EffectReceipt, error) + GetEffect func(ctx context.Context, tenantID, effectID string) (*effect.EffectRecord, error) + GetEffectByIdempotencyKey func(ctx context.Context, tenantID, agentID, idempotencyKey string) (*effect.EffectRecord, error) + type EffectSyscallHandler struct + func NewEffectSyscallHandler(invoker EffectInvoker, caps *capability.Authorizer) *EffectSyscallHandler + func (h *EffectSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type HandlerFunc func(ctx *SyscallContext) (json.RawMessage, int64, error) + func (f HandlerFunc) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type IPCAckPayload struct + AgentVersionRef string + MessageIDs []string + type IPCAckResult struct + AcknowledgedIDs []string + type IPCKernelService interface + Ack func(ctx context.Context, addr ipc.AgentAddress, messageIDs []string) error + Receive func(ctx context.Context, addr ipc.AgentAddress, maxMessages int) ([]*ipc.AgentMessage, error) + Send func(ctx context.Context, msg *ipc.AgentMessage) error + type IPCReceivePayload struct + AgentVersionRef string + MaxMessages int + WaitMillis int + type IPCReceiveResult struct + Messages []*ipc.AgentMessage + type IPCSendPayload struct + AgentVersionRef string + CorrelationID string + Deadline *time.Time + Kind string + PayloadJSON json.RawMessage + ReplyToMessageID string + RunID uuid.UUID + TaskID uuid.UUID + To ipc.AgentAddress + type IPCSendResult struct + AcceptedAt time.Time + MessageID string + Replayed bool + type IPCSyscallHandler struct + func NewIPCSyscallHandler(service IPCKernelService) *IPCSyscallHandler + func (h *IPCSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type MemoryInvoker interface + Put func(context.Context, memory.PutInput) (store.MemoryRecord, bool, error) + Search func(context.Context, memory.SearchInput) ([]store.MemoryRecord, error) + type MemoryPutPayload struct + AgentVersionRef string + Content string + ContentType string + Key string + Namespace string + ProvenanceJSON json.RawMessage + Sensitivity string + type MemoryPutResult struct + Record store.MemoryRecord + Replayed bool + type MemorySearchPayload struct + AgentVersionRef string + Limit int + Namespace string + Query string + Sensitivity string + type MemorySearchResult struct + Records []store.MemoryRecord + type MemorySyscallHandler struct + func NewMemorySyscallHandler(invoker MemoryInvoker, caps *capability.Authorizer) *MemorySyscallHandler + func (h *MemorySyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type Metrics interface + ErrorCount func() int64 + RecordSyscall func(ctx context.Context, syscall SyscallNumber, code SyscallErrorCode, ...) + SuccessCount func() int64 + TotalCount func() int64 + type ModelBeginPayload struct + AgentVersionRef string + ModelRef string + RunID uuid.UUID + TaskID uuid.UUID + type ModelBeginResult struct + CallID uuid.UUID + ModelRef string + PolicyRevision string + PriceRevision string + ResourceVersion int64 + Status string + type ModelChatMessage struct + Content string + Role string + ToolCallID string + ToolCalls []ModelChatToolCall + type ModelChatToolCall struct + Arguments string + ID string + Name string + type ModelFinishPayload struct + CallID uuid.UUID + ExpectedVersion int64 + FinishReason string + InputTokens int64 + OutputTokens int64 + ProviderRequestID string + Status string + type ModelFinishResult struct + CallID uuid.UUID + CostUSD float64 + FinishReason string + InputTokens int64 + ModelRef string + OutputTokens int64 + PriceRevision string + Status string + type ModelInvokePayload struct + AgentVersionRef string + MaxOutputTokens int32 + Messages []ModelChatMessage + ModelRef string + RunID uuid.UUID + Stream bool + TaskID uuid.UUID + Temperature *float64 + Tools []ModelToolDef + type ModelInvokeResult struct + CallID uuid.UUID + Content string + CostUSD float64 + FinishReason string + InputTokens int64 + ModelRef string + OutputTokens int64 + PriceRevision string + ProviderRequestID string + Status string + ToolCalls []ModelChatToolCall + type ModelInvoker interface + Begin func(context.Context, model.BeginInput) (model.BeginResult, error) + Finish func(context.Context, store.ModelCall, model.FinishInput) (store.ModelCall, error) + GetModelCall func(context.Context, string, uuid.UUID) (store.ModelCall, error) + Settle func(context.Context, store.ModelCall, int64, model.Usage) error + type ModelRunner interface + InvokeStream func(context.Context, model.InvokeInput, func(string)) (model.InvokeOutput, error) + type ModelSettlePayload struct + CallID uuid.UUID + InputTokens int64 + OutputTokens int64 + Sequence int64 + type ModelSettleResult struct + CallID uuid.UUID + type ModelSyscallHandler struct + func NewModelSyscallHandler(runner ModelRunner, invoker ModelInvoker, caps *capability.Authorizer) *ModelSyscallHandler + func (h *ModelSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type ModelToolDef struct + Description string + Name string + Parameters json.RawMessage + type NamespaceGetPayload struct + Namespace string + type NamespaceInfo struct + CreatedAt time.Time + Description string + DisplayName string + Labels map[string]string + Name string + Phase namespace.NamespacePhase + Quota namespace.ResourceQuota + TenantID string + UpdatedAt time.Time + type ResourceQuotaInfo struct + Namespace string + Quota namespace.ResourceQuota + TenantID string + type ResourceQuotaPayload struct + Namespace string + type ResourceSyscallHandler struct + func NewResourceSyscallHandler(store namespace.Store) *ResourceSyscallHandler + func (h *ResourceSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type ResourceUsageInfo struct + Usage namespace.ResourceUsage + type ResourceUsagePayload struct + Namespace string + type RuntimeCheckpointPayload struct + CheckpointID string + ConfirmedReceiptIDs []string + ExpectedAttemptVersion int64 + State store.ArtifactReference + type RuntimeCheckpointResult struct + AttemptVersion int64 + Checkpoint store.Checkpoint + type RuntimeCompletePayload struct + ExpectedAttemptVersion int64 + Result store.ArtifactReference + type RuntimeCompleteResult struct + AttemptVersion int64 + ResultRef string + type RuntimeFence interface + GetRuntimeAssignment func(ctx context.Context, tenantID string, attemptID uuid.UUID, fencingToken int64) (store.RuntimeAssignment, error) + type RuntimeLifecycleInvoker interface + CommitCheckpoint func(context.Context, store.CommitCheckpointInput) (store.Checkpoint, store.Attempt, error) + CompleteAttempt func(context.Context, store.CompleteAttemptInput) (store.CompleteAttemptResult, error) + type RuntimeSyscallHandler struct + func NewRuntimeSyscallHandler(invoker RuntimeLifecycleInvoker) *RuntimeSyscallHandler + func (h *RuntimeSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type RuntimeYieldPayload struct + Reason string + type RuntimeYieldResult struct + Yielded bool + type ServiceHeartbeatPayload struct + InstanceID string + LoadScore float64 + ServiceID uuid.UUID + Status string + type ServiceHeartbeatResult struct + Acknowledged bool + RebalanceRequested bool + type ServiceQueryPayload struct + Name string + Namespace string + type ServiceQueryResult struct + Services []*supervisor.Service + type ServiceSyscallHandler struct + func NewServiceSyscallHandler(store supervisor.Store) *ServiceSyscallHandler + func (h *ServiceSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error) + type StandardMetrics struct + func NewStandardMetrics() *StandardMetrics + func (m *StandardMetrics) ErrorCount() int64 + func (m *StandardMetrics) RecordSyscall(ctx context.Context, syscall SyscallNumber, code SyscallErrorCode, ...) + func (m *StandardMetrics) SuccessCount() int64 + func (m *StandardMetrics) TotalCount() int64 + type SyscallClient struct + func NewClient(invoker SyscallInvoker) *SyscallClient + func (c *SyscallClient) ABIVersion() string + func (c *SyscallClient) AckIPC(ctx context.Context, id AttemptIdentity, payload IPCAckPayload) (IPCAckResult, error) + func (c *SyscallClient) BeginModel(ctx context.Context, id AttemptIdentity, payload ModelBeginPayload) (ModelBeginResult, int64, error) + func (c *SyscallClient) Call(ctx context.Context, syscall SyscallNumber, identity AttemptIdentity, ...) (json.RawMessage, int64, error) + func (c *SyscallClient) Checkpoint(ctx context.Context, id AttemptIdentity, payload RuntimeCheckpointPayload) (RuntimeCheckpointResult, int64, error) + func (c *SyscallClient) Complete(ctx context.Context, id AttemptIdentity, payload RuntimeCompletePayload) (RuntimeCompleteResult, int64, error) + func (c *SyscallClient) ExecuteEffect(ctx context.Context, id AttemptIdentity, payload EffectExecutePayload) (effect.EffectReceipt, int64, error) + func (c *SyscallClient) FinishModel(ctx context.Context, id AttemptIdentity, payload ModelFinishPayload) (ModelFinishResult, int64, error) + func (c *SyscallClient) GetEffect(ctx context.Context, id AttemptIdentity, payload EffectGetPayload) (effect.EffectRecord, int64, error) + func (c *SyscallClient) GetNamespace(ctx context.Context, id AttemptIdentity, payload NamespaceGetPayload) (NamespaceInfo, error) + func (c *SyscallClient) GetResourceQuota(ctx context.Context, id AttemptIdentity, payload ResourceQuotaPayload) (ResourceQuotaInfo, error) + func (c *SyscallClient) GetResourceUsage(ctx context.Context, id AttemptIdentity, payload ResourceUsagePayload) (ResourceUsageInfo, error) + func (c *SyscallClient) HeartbeatService(ctx context.Context, id AttemptIdentity, payload ServiceHeartbeatPayload) (ServiceHeartbeatResult, error) + func (c *SyscallClient) InvokeModel(ctx context.Context, id AttemptIdentity, payload ModelInvokePayload) (ModelInvokeResult, error) + func (c *SyscallClient) InvokeTool(ctx context.Context, id AttemptIdentity, payload ToolInvokePayload) (ToolInvokeResult, error) + func (c *SyscallClient) ListTools(ctx context.Context, id AttemptIdentity, payload ToolListPayload) (ToolListResult, error) + func (c *SyscallClient) PutMemory(ctx context.Context, id AttemptIdentity, payload MemoryPutPayload) (MemoryPutResult, int64, error) + func (c *SyscallClient) QueryServices(ctx context.Context, id AttemptIdentity, payload ServiceQueryPayload) (ServiceQueryResult, error) + func (c *SyscallClient) ReceiveIPC(ctx context.Context, id AttemptIdentity, payload IPCReceivePayload) (IPCReceiveResult, error) + func (c *SyscallClient) SearchMemory(ctx context.Context, id AttemptIdentity, payload MemorySearchPayload) (MemorySearchResult, error) + func (c *SyscallClient) SendIPC(ctx context.Context, id AttemptIdentity, payload IPCSendPayload) (IPCSendResult, error) + func (c *SyscallClient) SettleModel(ctx context.Context, id AttemptIdentity, payload ModelSettlePayload) (ModelSettleResult, error) + func (c *SyscallClient) Yield(ctx context.Context, id AttemptIdentity, payload RuntimeYieldPayload) (RuntimeYieldResult, error) + type SyscallContext struct + Assignment store.RuntimeAssignment + Request SyscallRequest + type SyscallDescriptor struct + Category string + Description string + IsReadOnly bool + Name string + Number SyscallNumber + SinceVersion string + func AllDescriptors() []SyscallDescriptor + type SyscallDispatcher struct + func NewDispatcher(opts ...DispatcherOption) *SyscallDispatcher + func (d *SyscallDispatcher) Dispatch(ctx context.Context, req SyscallRequest) SyscallResponse + func (d *SyscallDispatcher) GetHandler(number SyscallNumber) (SyscallHandler, bool) + func (d *SyscallDispatcher) Register(number SyscallNumber, handler SyscallHandler) + func (d *SyscallDispatcher) RegisterFunc(number SyscallNumber, ...) + type SyscallError struct + Cause error + Code SyscallErrorCode + Message string + func NewSyscallError(code SyscallErrorCode, msg string) *SyscallError + func WrapError(code SyscallErrorCode, msg string, cause error) *SyscallError + func (e *SyscallError) Error() string + func (e *SyscallError) Unwrap() error + type SyscallErrorCode int32 + const SyscallEBUSY + const SyscallEFENCE + const SyscallEINTERNAL + const SyscallEINVAL + const SyscallENOENT + const SyscallENOMEM + const SyscallENOSYS + const SyscallEPERM + const SyscallETIMEDOUT + const SyscallEUNKNOWN + const SyscallOK + func ErrorToCode(err error) (SyscallErrorCode, string) + func (c SyscallErrorCode) StandardName() string + func (c SyscallErrorCode) String() string + type SyscallHandler interface + Handle func(ctx *SyscallContext) (json.RawMessage, int64, error) + type SyscallInvoker interface + Dispatch func(ctx context.Context, req SyscallRequest) SyscallResponse + type SyscallNumber uint32 + const SysEffectExecute + const SysEffectGet + const SysIPCAck + const SysIPCReceive + const SysIPCSend + const SysMemoryPut + const SysMemorySearch + const SysModelBegin + const SysModelFinish + const SysModelInvoke + const SysModelSettle + const SysNamespaceGet + const SysResourceQuotaGet + const SysResourceUsageGet + const SysRuntimeCheckpoint + const SysRuntimeComplete + const SysRuntimeYield + const SysServiceHeartbeat + const SysServiceQuery + const SysToolInvoke + const SysToolList + const SyscallNone + func ParseSyscallNumber(str string) (SyscallNumber, error) + func (s SyscallNumber) Category() string + func (s SyscallNumber) Descriptor() (SyscallDescriptor, bool) + func (s SyscallNumber) IsReadOnly() bool + func (s SyscallNumber) Name() string + func (s SyscallNumber) String() string + type SyscallRequest struct + IdempotencyKey string + Identity AttemptIdentity + Metadata map[string]string + PayloadJSON json.RawMessage + Syscall SyscallNumber + type SyscallResponse struct + DurationUS int64 + ErrorCode SyscallErrorCode + ErrorMessage string + ResourceVersion int64 + ResultJSON json.RawMessage + Syscall SyscallNumber + func (r SyscallResponse) IsSuccess() bool + type ToolInvokePayload struct + Action string + AgentVersionRef string + ApprovalID string + ArgsJSON json.RawMessage + Resource string + RunID uuid.UUID + SecretRef string + TaskID uuid.UUID + ToolName string + ToolVersion string + type ToolInvokeResult struct + ApprovalID string + DenyReasons []string + Outcome string + PolicyRevision string + ReceiptOperation string + ResultJSON json.RawMessage + ToolCallID string + type ToolInvoker interface + GetToolDescriptor func(ctx context.Context, tenantID, name, version string) (store.ToolDescriptor, error) + InvokeTool func(context.Context, tool.InvokeInput) (tool.InvokeResult, error) + ListTools func(context.Context, string) ([]store.ToolDescriptor, error) + type ToolListPayload struct + AgentVersionRef string + type ToolListResult struct + Tools []store.ToolDescriptor + type ToolSyscallHandler struct + func NewToolSyscallHandler(invoker ToolInvoker, caps *capability.Authorizer) *ToolSyscallHandler + func (h *ToolSyscallHandler) Handle(ctx *SyscallContext) (json.RawMessage, int64, error)
Go to main page