runtimeclient

package

Go to main page

Versions in this module

v0

v0.5.1

Jul 19, 2026

v0.5.0

Jul 19, 2026

Changes in this version

+ const RuntimeLeaseKind

+ const RuntimeModuleCacheEntriesMax

+ const RuntimeModuleCacheEntriesMin

+ const RuntimeModuleCacheSourceBytesMax

+ const RuntimeModuleCacheSourceBytesMin

+ const RuntimePerPluginConcurrencyMax

+ const RuntimePerPluginConcurrencyMin

+ const RuntimeQueueCapacityMax

+ const RuntimeQueueCapacityMin

+ const RuntimeWorkerCountMax

+ const RuntimeWorkerCountMin

+ var ErrManagerLifecycleOutcomeUnknown = errors.New("runtime manager lifecycle outcome is unknown")

+ var ErrRuntimeArtifactDigest = errors.New("runtime artifact digest mismatch")

+ var ErrRuntimeBindingInvalid = errors.New("runtime binding is invalid")

+ var ErrRuntimeDescriptorInvalid = errors.New("runtime descriptor is invalid")

+ var ErrRuntimeDescriptorMismatch = errors.New("runtime descriptor does not match")

+ var ErrRuntimeHostServicesBound = errors.New("runtime host services are already bound")

+ var ErrRuntimeHostServicesInvalid = errors.New("runtime host services are invalid")

+ var ErrRuntimeHostServicesRequired = errors.New("runtime host services are not bound")

+ var ErrRuntimeLimitsInvalid = errors.New("runtime limits are invalid")

+ var ErrRuntimeShardCount = errors.New("runtime shard count must be between 1 and 16")

+ var ErrRuntimeTimingInvalid = errors.New("runtime timing is invalid")

+ func ValidateRuntimeLimits(limits RuntimeLimits) error

type HandleGrantValidationRequest

+ OwnerEnvHash string

+ OwnerSessionHash string

+ OwnerUserHash string

+ ResourceScope sessionctx.ResourceScope

+ SessionChannelIDHash string

type HandleGrantValidationResult

+ ResourceScope sessionctx.ResourceScope

type Health

+ ActiveInvocations int

+ Descriptor RuntimeDescriptor

+ Limits RuntimeLimits

+ ModuleCache ModuleCacheMetrics

+ QueuedInvocations int

type HeartbeatResult

+ ActiveInvocations int

+ Limits RuntimeLimits

+ ModuleCache ModuleCacheMetrics

+ QueuedInvocations int

type Lease

+ ExpiresAtUnixMillis int64

+ OwnerEnvHash string

+ type Manager interface

+ BindHostServices func(services RuntimeHostServices) error

+ BindPlugin func(ctx context.Context, pluginInstanceID string) (RuntimeBinding, error)

+ Health func(ctx context.Context) (ManagerHealth, error)

+ InvokeWorker func(ctx context.Context, binding RuntimeBinding, lease Lease, method string, ...) ([]byte, error)

+ Preflight func(ctx context.Context, target runtimetarget.Target) (RuntimeDescriptor, error)

+ Revoke func(ctx context.Context, req RevokeRequest) (RevokeResult, error)

+ Start func(ctx context.Context, target runtimetarget.Target) (ManagerHealth, error)

+ Stop func(ctx context.Context) error

+ type ManagerHealth struct

+ Descriptor RuntimeDescriptor

+ Ready bool

+ Shards []ShardHealth

+ type ModuleCacheMetrics struct

+ Compiles uint64

+ Entries int

+ Hits uint64

+ Misses uint64

+ SourceBytes int64

+ type ProcessManager struct

+ func NewProcessManager(options ProcessManagerOptions) (*ProcessManager, error)

+ func (m *ProcessManager) BindHostServices(services RuntimeHostServices) error

+ func (m *ProcessManager) BindPlugin(ctx context.Context, pluginInstanceID string) (RuntimeBinding, error)

+ func (m *ProcessManager) Health(ctx context.Context) (ManagerHealth, error)

+ func (m *ProcessManager) InvokeWorker(ctx context.Context, binding RuntimeBinding, lease Lease, method string, ...) ([]byte, error)

+ func (m *ProcessManager) Preflight(ctx context.Context, target runtimetarget.Target) (RuntimeDescriptor, error)

+ func (m *ProcessManager) Revoke(ctx context.Context, req RevokeRequest) (RevokeResult, error)

+ func (m *ProcessManager) Start(ctx context.Context, target runtimetarget.Target) (ManagerHealth, error)

+ func (m *ProcessManager) Stop(ctx context.Context) error

+ type ProcessManagerOptions struct

+ ShardCount int

+ Supervisor ProcessSupervisorOptions

type ProcessSupervisor

+ func (s *ProcessSupervisor) Preflight(ctx context.Context, target runtimetarget.Target) (RuntimeDescriptor, error)

type ProcessSupervisorOptions

+ Descriptor RuntimeDescriptor

+ Limits RuntimeLimits

+ type RevokeRequest struct

+ PluginInstanceID string

+ ResourceScope sessionctx.ResourceScope

+ RevokeEpoch uint64

type RevokeResult

+ ResourceScope sessionctx.ResourceScope

+ RuntimeStopped bool

+ type RuntimeBinding struct

+ ConnectionNonce string

+ Descriptor RuntimeDescriptor

+ IPCChannelID string

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeShardID string

+ type RuntimeDescriptor struct

+ func NewRuntimeDescriptor(runtimeVersion platformversion.SemVer, target runtimetarget.Target, ...) (RuntimeDescriptor, error)

+ func (d *RuntimeDescriptor) UnmarshalJSON(raw []byte) error

+ func (d RuntimeDescriptor) ArtifactSHA256() string

+ func (d RuntimeDescriptor) CompatibleWithPlatform() error

+ func (d RuntimeDescriptor) IPCVersion() string

+ func (d RuntimeDescriptor) MarshalJSON() ([]byte, error)

+ func (d RuntimeDescriptor) Target() runtimetarget.Target

+ func (d RuntimeDescriptor) Version() platformversion.SemVer

+ func (d RuntimeDescriptor) WASMABIVersion() string

+ type RuntimeHostServices struct

+ StreamSink RuntimeStreamSink

+ type RuntimeLimits struct

+ ModuleCacheEntries int

+ ModuleCacheSourceBytes int64

+ PerPluginConcurrency int

+ QueueCapacity int

+ WorkerCount int

+ func DefaultRuntimeLimits() RuntimeLimits

+ type RuntimeProcessExitFailure struct

+ Code observability.RuntimeProcessFailureCode

+ ExitCode int

+ func RuntimeProcessExitFailures() []RuntimeProcessExitFailure

+ type ShardHealth struct

+ RuntimeShardID string

v0.4.3

Jul 15, 2026

v0.4.2

Jul 15, 2026

v0.4.1

Jul 15, 2026

v0.4.0

Jul 15, 2026

Changes in this version

+ type WorkerErrorOrigin string

+ const WorkerErrorOriginHostcall

+ const WorkerErrorOriginPlugin

+ const WorkerErrorOriginRuntime

+ type WorkerExecutionError struct

+ Code string

+ Message string

+ Origin WorkerErrorOrigin

+ func (e *WorkerExecutionError) Error() string

+ func (e *WorkerExecutionError) Unwrap() error

v0.3.2

Jul 14, 2026

v0.3.1

Jul 14, 2026

v0.3.0

Jul 14, 2026

Changes in this version

type Lease

+ AuditCorrelationID string

+ OperationID string

+ StreamID string

type ProcessSupervisorOptions

+ StreamSink RuntimeStreamSink

+ type RuntimeStreamSink interface

+ AppendRuntimeStream func(ctx context.Context, streamID, kind string, data []byte) error

+ CloseRuntimeStream func(ctx context.Context, streamID string) error

+ FailRuntimeStream func(ctx context.Context, streamID, reason string) error

v0.2.2

Jul 12, 2026

v0.2.1

Jul 12, 2026

v0.2.0

Jul 12, 2026

Changes in this version

+ const RuntimeLeaseSignatureAlgorithm

+ const RuntimeLeaseSignatureSchemaVersion

+ const RuntimeLeaseTokenKind

+ var ErrRuntimeHandshake = errors.New("runtime ipc handshake failed")

+ var ErrRuntimeIPCUnavailable = errors.New("runtime ipc transport is unavailable")

+ var ErrRuntimeLeaseInvalid = errors.New("runtime execution lease is invalid")

+ var ErrRuntimeLeasePublicKeyInvalid = errors.New("runtime lease signing public key is invalid")

+ var ErrRuntimeLeaseReplay = errors.New("runtime execution lease has already been consumed")

+ var ErrRuntimeLeaseSignatureInvalid = errors.New("runtime execution lease signature is invalid")

+ var ErrRuntimeLeaseSignatureKeyringRequired = errors.New("runtime lease signing keyring is required")

+ var ErrRuntimeLeaseSignatureRequired = errors.New("runtime execution lease signature is required")

+ var ErrRuntimeLeaseSigningKeyNotFound = errors.New("runtime lease signing key not found")

+ var ErrRuntimeLeaseSigningKeyRevoked = errors.New("runtime lease signing key is revoked")

+ var ErrRuntimeNotReady = errors.New("runtime is not ready")

+ var ErrRuntimePathRequired = errors.New("runtime path is required")

+ var ErrRuntimeRequestFailed = errors.New("runtime ipc request failed")

+ func CanonicalRuntimeLeaseSignaturePayload(lease Lease, method string) ([]byte, error)

+ type ArtifactProvider interface

+ ReadArtifact func(ctx context.Context, req ArtifactRequest) (ArtifactResult, error)

+ type ArtifactRequest struct

+ Artifact string

+ ArtifactSHA256 string

+ PackageHash string

+ type ArtifactResult struct

+ Content []byte

+ SHA256 string

+ type Ed25519RuntimeLeaseVerifier struct

+ Keyring RuntimeLeaseSigningKeyring

+ Now func() time.Time

+ func (v Ed25519RuntimeLeaseVerifier) VerifyRuntimeLease(ctx context.Context, req RuntimeLeaseVerificationRequest) error

+ type HandleGrantValidationRequest struct

+ ActiveFingerprint string

+ HandleGrantToken string

+ HandleID string

+ ManagementRevision uint64

+ Method string

+ PluginInstanceID string

+ PolicyRevision uint64

+ RevokeEpoch uint64

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeShardID string

+ type HandleGrantValidationResult struct

+ HandleGrantID string

+ HandleID string

+ MaxBytesPerSecond int64

+ MaxTotalBytes int64

+ Method string

+ RuntimeGenerationID string

+ type HandleGrantValidator interface

+ ValidateHandleGrant func(ctx context.Context, req HandleGrantValidationRequest) (HandleGrantValidationResult, error)

+ type Health struct

+ ConnectionNonce string

+ IPCChannelID string

+ Ready bool

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeVersion string

+ RustIPCVersion string

+ WASMABIVersion string

+ type HeartbeatResult struct

+ HostSentUnixNanoEcho int64

+ MaxStalenessMillis int64

+ RuntimeGenerationID string

+ RuntimeUnixNano int64

+ type Lease struct

+ ActiveFingerprint string

+ BridgeChannelID string

+ ConnectionNonce string

+ Effect string

+ Execution string

+ ExpiresAt time.Time

+ IPCChannelID string

+ IssuedAt time.Time

+ IssuedAtUnixMillis int64

+ KeyID string

+ LeaseID string

+ LeaseNonce string

+ LeaseToken string

+ Limits LeaseLimits

+ ManagementRevision uint64

+ Method string

+ OwnerSessionHash string

+ OwnerUserHash string

+ PluginID string

+ PluginInstanceID string

+ PluginVersion string

+ PolicyRevision uint64

+ RevokeEpoch uint64

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeShardID string

+ SessionChannelIDHash string

+ Signature string

+ SurfaceInstanceID string

+ TargetDescriptorHashes []string

+ TokenID string

+ func SignRuntimeLease(lease Lease, method string, keyID string, privateKey ed25519.PrivateKey) (Lease, error)

+ type LeaseLimits struct

+ MaxPayloadBytes int64

+ MaxStreamBytesPerSecond int64

+ MemoryBytes int64

+ TimeoutMillis int64

+ type MemoryRuntimeLeaseReplayStore struct

+ func NewMemoryRuntimeLeaseReplayStore() *MemoryRuntimeLeaseReplayStore

+ func (s *MemoryRuntimeLeaseReplayStore) ConsumeRuntimeLease(ctx context.Context, req RuntimeLeaseReplayConsumeRequest) (RuntimeLeaseReplayRecord, error)

+ func (s *MemoryRuntimeLeaseReplayStore) ListRuntimeLeaseReplays(ctx context.Context, req RuntimeLeaseReplayListRequest) ([]RuntimeLeaseReplayRecord, error)

+ type ProcessSupervisor struct

+ func NewProcessSupervisor(options ProcessSupervisorOptions) (*ProcessSupervisor, error)

+ func (s *ProcessSupervisor) Health(context.Context) (Health, error)

+ func (s *ProcessSupervisor) Heartbeat(ctx context.Context) (HeartbeatResult, error)

+ func (s *ProcessSupervisor) InvokeWorker(ctx context.Context, lease Lease, method string, payload []byte) ([]byte, error)

+ func (s *ProcessSupervisor) Revoke(ctx context.Context, pluginInstanceID string, revokeEpoch uint64) (RevokeResult, error)

+ func (s *ProcessSupervisor) Start(ctx context.Context, target Target) error

+ func (s *ProcessSupervisor) Stop(ctx context.Context) error

+ type ProcessSupervisorOptions struct

+ Args []string

+ Artifacts ArtifactProvider

+ Connectivity connectivity.Broker

+ Diagnostics observability.DiagnosticsSink

+ Dir string

+ Env []string

+ HandleGrants HandleGrantValidator

+ HandshakeTimeout time.Duration

+ HeartbeatInterval time.Duration

+ MaxHeartbeatStaleness time.Duration

+ NetworkExecutor connectivity.NetworkExecutor

+ Now func() time.Time

+ RuntimeLeasePublicKeys []RuntimeLeasePublicKey

+ RuntimeLeaseReplays RuntimeLeaseReplayStore

+ RuntimeLeaseVerifier RuntimeLeaseVerifier

+ RuntimePath string

+ StorageFiles storage.FilesBroker

+ StorageKV storage.KVBroker

+ StorageSQLite storage.SQLiteBroker

+ Streams stream.Store

+ type RevokeResult struct

+ ClosedActorCount int

+ ClosedSocketCount int

+ ClosedStorageHandleCount int

+ ClosedStreamCount int

+ PluginInstanceID string

+ RevokeEpoch uint64

+ type RuntimeLeasePublicKey struct

+ Algorithm string

+ KeyID string

+ PublicKeyBase64 string

+ func NormalizeRuntimeLeasePublicKeys(keys []RuntimeLeasePublicKey) ([]RuntimeLeasePublicKey, error)

+ func RuntimeLeasePublicKeyFromEd25519(keyID string, publicKey ed25519.PublicKey) (RuntimeLeasePublicKey, error)

+ type RuntimeLeaseReplayConsumeRequest struct

+ Lease Lease

+ Method string

+ Now time.Time

+ type RuntimeLeaseReplayListRequest struct

+ PluginInstanceID string

+ type RuntimeLeaseReplayLister interface

+ ListRuntimeLeaseReplays func(ctx context.Context, req RuntimeLeaseReplayListRequest) ([]RuntimeLeaseReplayRecord, error)

+ type RuntimeLeaseReplayRecord struct

+ ConsumedAt time.Time

+ ExpiresAt time.Time

+ LeaseID string

+ LeaseNonceHash string

+ ManagementRevision uint64

+ Method string

+ PluginInstanceID string

+ PolicyRevision uint64

+ RevokeEpoch uint64

+ RuntimeGenerationID string

+ type RuntimeLeaseReplayStore interface

+ ConsumeRuntimeLease func(ctx context.Context, req RuntimeLeaseReplayConsumeRequest) (RuntimeLeaseReplayRecord, error)

+ type RuntimeLeaseSigningKey struct

+ ConnectionNonce string

+ IPCChannelID string

+ KeyID string

+ Metadata map[string]string

+ PublicKey ed25519.PublicKey

+ Revoked bool

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeShardID string

+ type RuntimeLeaseSigningKeyLookupRequest struct

+ ConnectionNonce string

+ IPCChannelID string

+ KeyID string

+ Method string

+ PluginInstanceID string

+ RuntimeGenerationID string

+ RuntimeInstanceID string

+ RuntimeShardID string

+ type RuntimeLeaseSigningKeyring interface

+ LookupRuntimeLeaseSigningKey func(ctx context.Context, req RuntimeLeaseSigningKeyLookupRequest) (RuntimeLeaseSigningKey, error)

+ type RuntimeLeaseVerificationRequest struct

+ Lease Lease

+ Method string

+ Now time.Time

+ type RuntimeLeaseVerifier interface

+ VerifyRuntimeLease func(ctx context.Context, req RuntimeLeaseVerificationRequest) error

+ type SQLiteRuntimeLeaseReplayStore struct

+ func NewSQLiteRuntimeLeaseReplayStore(ctx context.Context, path string) (*SQLiteRuntimeLeaseReplayStore, error)

+ func (s *SQLiteRuntimeLeaseReplayStore) Close() error

+ func (s *SQLiteRuntimeLeaseReplayStore) ConsumeRuntimeLease(ctx context.Context, req RuntimeLeaseReplayConsumeRequest) (RuntimeLeaseReplayRecord, error)

+ func (s *SQLiteRuntimeLeaseReplayStore) ListRuntimeLeaseReplays(ctx context.Context, req RuntimeLeaseReplayListRequest) ([]RuntimeLeaseReplayRecord, error)

+ type StaticRuntimeLeaseSigningKeyring struct

+ Keys []RuntimeLeaseSigningKey

+ func (k StaticRuntimeLeaseSigningKeyring) LookupRuntimeLeaseSigningKey(ctx context.Context, req RuntimeLeaseSigningKeyLookupRequest) (RuntimeLeaseSigningKey, error)

+ type Supervisor interface

+ Health func(ctx context.Context) (Health, error)

+ Heartbeat func(ctx context.Context) (HeartbeatResult, error)

+ InvokeWorker func(ctx context.Context, lease Lease, method string, payload []byte) ([]byte, error)

+ Revoke func(ctx context.Context, pluginInstanceID string, revokeEpoch uint64) (RevokeResult, error)

+ Start func(ctx context.Context, target Target) error

+ Stop func(ctx context.Context) error

+ type Target struct

+ Arch string

+ OS string

v0.1.6

Jul 12, 2026

v0.1.5

Jul 6, 2026

v0.1.4

Jul 6, 2026

v0.1.3

Jul 6, 2026

v0.1.2

Jul 6, 2026

v0.1.1

Jul 4, 2026

v0.1.0

Jul 4, 2026

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