Control plane
LocalControlPlane
In-process control plane with the exact semantics of the SpacetimeDB module (see Module~/Lib.cs), for single-process runs and tests.
generated from the sources
Class in namespace
Nebula · Packages/com.1by3.nebula/Runtime/ControlPlane/LocalControlPlane.cspublic sealed class LocalControlPlane : IControlPlaneIn-process control plane with the exact semantics of the SpacetimeDB module (see Module~/Lib.cs), for single-process runs and tests. Changes are applied synchronously and Changed fires on the next Tick, mirroring the subscription push of the real thing.
Properties
IsConnected
public bool IsConnected { get; }Now
public DateTime Now { get; }Workers
public IReadOnlyList<WorkerInfo> Workers { get; }Leases
public IReadOnlyList<LeaseInfo> Leases { get; }Gateways
public IReadOnlyList<GatewayInfo> Gateways { get; }Settings
public IReadOnlyDictionary<string, string> Settings { get; }Events
Changed
public event Action Changed;Methods
Connect
public void Connect();Tick
public void Tick();Dispose
public void Dispose();RegisterWorker
public void RegisterWorker(string workerId, uint workerIndex, string address, ushort port);HeartbeatWorker
public void HeartbeatWorker(string workerId, string status, in WorkerStats stats);UnregisterWorker
public void UnregisterWorker(string workerId);RegisterGateway
public void RegisterGateway(string gatewayId, string address, ushort port);HeartbeatGateway
public void HeartbeatGateway(string gatewayId);UnregisterGateway
public void UnregisterGateway(string gatewayId);HeartbeatOrchestrator
public void HeartbeatOrchestrator(string orchestratorId, uint desiredWorkers);SetSetting
public void SetSetting(string key, string value);EnsureContainer
public void EnsureContainer(string containerId);AssignContainer
public void AssignContainer(string containerId, string workerId);SetLeaseState
public void SetLeaseState(string containerId, string state);ReleaseContainer
public void ReleaseContainer(string containerId);ResetControlPlane
public void ResetControlPlane();