CLAUDE.md was corrected in34227991but the component docs were not, so the same understatements — plus several outright wrong statements — survived where a reader is most likely to meet them. ClusterInfrastructure.md carried the worst of it. It described active/standby as cluster leadership and showed an IsActiveNode snippet doing `cluster.State.Leader == self.Address`. No such code exists: ActiveNodeGate returns ClusterActivityEvaluator.SelfIsOldest, and ActiveNodeEvaluator's own doc comment says "never cluster.State.Leader". A second snippet (siteCallAuditShutdown .AddTask) described a hand-rolled drain that has since been folded into SingletonRegistrar.Start. Both snippets are replaced with what the code does. The central singleton table listed 3 of the 7 registered singletons. The downing section still described keep-oldest as the strategy and omitted downing-provider-class entirely; it now shows the branching blockcf3bd52fintroduced, with the accepted dual-active trade stated rather than the old "impossible to boot" framing. Note the requirements-side spec, docs/requirements/Component-ClusterInfrastructure.md, was already rewritten bycf3bd52f— this is the components-side doc, which was untouched. Communication.md described two transports; there are three — the deployment config fetch over HTTP was missing. Each row now names which side dials, because the gRPC entry gave a data direction (site to central) without saying who hosts the server, which reads as the opposite of the truth: the only MapGrpcService in the tree is in Program.cs's Site branch, and central dials in. The SiteEnvelope snippet called DeployInstanceAsync, which is not a member of CommunicationService; the heartbeat bullet claimed a cluster-leadership check; the proto summary listed 4 of 6 RPCs. DeploymentManager.md still said the pipeline sends DeployInstanceCommand carrying FlattenedConfigurationJson. It stages a PendingDeployment and sends a RefreshDeploymentCommand; the config travels over the HTTP fetch. That is the change the 128 KB frame-size issue forced, and the doc predated it. Two of the five briefed drifts turned out not to be errors: nothing claimed the transports were authenticated, and nothing asserted per-site ActorSystem names — both were simply unstated. They are now stated, since silence about an unauthenticated boundary is its own problem. Docs only; no code changed. Claude-Session: https://claude.ai/code/session_01GASWkNEi68FSCtvr6rLoEW
30 KiB
Central–Site Communication
The Central–Site Communication component is the transport layer that connects the central cluster to every site cluster. It provides three independent transports — Akka.NET ClusterClient for command/control, gRPC server-streaming for real-time data, and plain token-gated HTTP for the deployment-config fetch — anchored by a pair of actors that each cluster registers with the ClusterClientReceptionist.
Overview
Communication (#5) runs on every node in every cluster. The component code lives in src/ZB.MOM.WW.ScadaBridge.Communication/, organised as follows:
Actors/—CentralCommunicationActor,SiteCommunicationActor,DebugStreamBridgeActor,StreamRelayActor.Grpc/—SiteStreamGrpcServer,SiteStreamGrpcClient,SiteStreamGrpcClientFactory,ISiteStreamSubscriber, and the proto DTO mappers.Protos/—sitestream.proto(proto source; generated C# is vendored inSiteStreamGrpc/).CommunicationService.cs— typed Ask-pattern façade used by callers on the central side.DebugStreamService.cs— session manager for debug stream bridge actors.CommunicationOptions.cs— configuration options class.ServiceCollectionExtensions.cs— DI registration (AddCommunication).
DI registration is called from the Host composition root via AddCommunication. The actors themselves are created inside AkkaHostedService.RegisterCentralActors / RegisterSiteActors because they must be created within the actor system, not by the DI container.
Key Concepts
Three transports, three concerns
| Transport | Who dials | Data direction | Purpose |
|---|---|---|---|
Akka.NET ClusterClient |
both (central → site per site; site → central) | bidirectional | Deploy notifies, lifecycle, subscribe/unsubscribe handshake, snapshots, heartbeats, health reports, telemetry, notifications |
gRPC (SiteStreamService) |
central dials the site | mostly site → central | Real-time attribute value and alarm state changes (server-streaming), plus the audit ingest/pull unary RPCs |
HTTP GET (/api/internal/deployments/{id}/config) |
site dials central | central → site | The flattened deployment config itself (notify-and-fetch), gated by a per-deployment X-Deployment-Token |
The transports are independent. A gRPC stream interruption does not affect in-flight ClusterClient commands, and vice versa.
The gRPC dial direction is inverted from its data direction. Values flow site → central, but each site node hosts the gRPC server and central is the client. MapGrpcService<SiteStreamGrpcServer>() appears exactly once in the tree, inside the Site branch of Program.cs (Host/Program.cs:542); there is no gRPC server on a central node at all. That is why the two Ingest* unary RPCs — nominally a central-side ingest surface — are dead in the shipped topology (acknowledged in AkkaHostedService.cs:505-508: "when the gRPC server is not registered (current central topology)"); sites push audit telemetry to central over ClusterClient instead, and central pulls with PullAuditEvents / PullSiteCalls by dialling the site.
None of the three transports carries a mutual-auth or transport-encryption story. BuildHocon emits no Akka enable-ssl, no secure cookie and no trusted-selection-paths, so remoting and ClusterClient are plaintext and unauthenticated. The site gRPC listener is h2c — ListenAnyIP(grpcPort, o => o.Protocols = HttpProtocols.Http2) with no UseHttps (Host/Program.cs:501-506) — and SiteStreamGrpcClient opens a bare GrpcChannel.ForAddress(endpoint, …) with no credentials. LocalDbSyncAuthInterceptor shares that listener but gates only methods under /localdb_sync.v1.LocalDbSync/, explicitly letting every SiteStreamService call through untouched, so the whole surface — including the PullAuditEvents / PullSiteCalls RPCs that return audit rows — is callable by anything that can reach the site's gRPC port. The one authenticated piece is the HTTP config fetch, and its per-deployment token is the entire security boundary (the endpoint is AllowAnonymous). The design assumes a trusted network between central and sites.
Notify-and-fetch: the deployment-config HTTP path
An instance deployment does not carry its flattened configuration inside the Akka message. Central stages a PendingDeployment row (config JSON + a freshly generated DeploymentFetchToken + a TTL) and sends only a small RefreshDeploymentCommand over ClusterClient, carrying the deployment id, revision hash, CentralFetchBaseUrl and the fetch token. The site's Deployment Manager singleton then calls back to central over plain HTTP:
// SiteRuntime/Deployment/HttpDeploymentConfigFetcher.cs
var url = $"{centralFetchBaseUrl.TrimEnd('/')}/api/internal/deployments/{Uri.EscapeDataString(deploymentId)}/config";
using var req = new HttpRequestMessage(HttpMethod.Get, url);
req.Headers.Add("X-Deployment-Token", token);
DeploymentConfigEndpoints.Resolve (ManagementService/DeploymentConfigEndpoints.cs:101) checks existence and TTL before the token, so unknown, superseded and expired deployments are all indistinguishable 404s; a live row with a wrong or missing token is 401. The token comparison is constant-time. This exists because a flattened config can exceed the default 128 KB Akka frame size, which drops the single oversized message without tearing down the association — heartbeats keep flowing, the site still reports healthy, and the deploy just hangs to its Ask timeout. See docs/known-issues/2026-06-26-deploy-config-exceeds-akka-frame-size.md. DeployArtifactsCommand was not moved to this path and still carries its payload inline.
Hub-and-spoke topology
Sites do not communicate with each other. All inter-cluster traffic flows through central. Central maintains one ClusterClient per site; each site maintains a single ClusterClient pointed at both central nodes.
SiteEnvelope routing
Central-side callers wrap outbound messages in a SiteEnvelope(SiteId, Message). CentralCommunicationActor resolves the site's ClusterClient by SiteId and forwards the inner message to /user/site-communication on the site:
// CommunicationService.cs — deployment pattern (notify-and-fetch)
public async Task<DeploymentStatusResponse> RefreshDeploymentAsync(
string siteId, RefreshDeploymentCommand command, CancellationToken cancellationToken = default)
{
var envelope = new SiteEnvelope(siteId, command);
return await GetActor().Ask<DeploymentStatusResponse>(
envelope, _options.DeploymentTimeout, cancellationToken);
}
CentralCommunicationActor.HandleSiteEnvelope extracts the inner message and routes it via the cached ClusterClient:
private void HandleSiteEnvelope(SiteEnvelope envelope)
{
if (!_siteClients.TryGetValue(envelope.SiteId, out var entry))
{
_log.Warning("No ClusterClient for site {0}, cannot route message {1}",
envelope.SiteId, envelope.Message.GetType().Name);
return; // caller's Ask times out — no central buffering
}
entry.Client.Tell(
new ClusterClient.Send("/user/site-communication", envelope.Message),
Sender);
}
No central buffering
If a site is unreachable when a command arrives, the caller's Ask times out. Central never queues command/control messages on behalf of a site. This is deliberate: it keeps the central coordinator stateless with respect to site availability and pushes retry responsibility to the operator or to the Store-and-Forward Engine for messages that tolerate it.
Architecture
Central-side: CentralCommunicationActor
CentralCommunicationActor is a ReceiveActor created at /user/central-communication and registered with ClusterClientReceptionist so the site's ClusterClient can locate it. It owns:
- A
Dictionary<string, (IActorRef Client, ImmutableHashSet<string> ContactAddresses)>keyed by site identifier — oneClusterClientper site. - A
RefreshSiteAddressesperiodic timer (60-second cadence, starting immediately). Each tick firesLoadSiteAddressesFromDb, which reads everySiterow from the database, parsesNodeAAddressandNodeBAddressinto Akka receptionist paths ({addr}/system/receptionist), and pipes aSiteAddressCacheLoadedmessage back to Self.HandleSiteAddressCacheLoadedcreates, updates, or stopsClusterClientactors based on the diff. - Proxy references to
NotificationOutboxActorandAuditLogIngestActorcluster singletons, injected post-construction viaRegisterNotificationOutbox/RegisterAuditIngestmessages from the Host. Messages that arrive before the proxy is registered are answered with a non-accepted ack (notifications) or an empty reply (audit), so the site retries without data loss. - Fanout of
SiteHealthReportto the peer central node viaDistributedPubSub, keyed on thesite-health-replicatopic, so both central nodes' aggregators stay in sync regardless of which central node the site'sClusterClientload-balanced the report to.
ISiteClientFactory / DefaultSiteClientFactory abstract ClusterClient construction for testability.
Site-side: SiteCommunicationActor
SiteCommunicationActor is a ReceiveActor created at /user/site-communication and registered with ClusterClientReceptionist. It owns:
- An
IActorRef? _centralClient— the site's outboundClusterClientto central. Injected post-construction viaRegisterCentralClient. - A
Timers-based heartbeat onCommunicationOptions.ApplicationHeartbeatInterval(default 5 s; deliberately distinct from the Akka.RemoteTransportHeartbeatInterval, so retuning the transport failure detector cannot silently retune the health heartbeat). Each tick sends aHeartbeatMessagewhoseIsActiveis stamped fromActiveNodeEvaluator.SelfIsOldestUp— the node is active when it is the oldestUpmember, not when it holds cluster leadership (SiteCommunicationActor.cs:517-518). A throwing active-check is caught and reported asIsActive = false. - Dispatch to local handlers for every inbound command pattern. Handlers for event-log, parked-message, integration, and artifact patterns are registered post-construction via
RegisterLocalHandler; unregistered patterns receive an inline error reply so the central Ask does not stall.
Site-to-central messages (health reports, audit batches, notification submissions) are sent via:
_centralClient.Tell(
new ClusterClient.Send("/user/central-communication", msg), Sender);
For request/response messages, the original Sender is forwarded as the ClusterClient.Send sender so any reply from central routes straight back to the waiting Ask on the site, not through SiteCommunicationActor. For fire-and-forget messages (e.g. SiteHealthReport), Self is used as the sender instead, because no reply is expected.
Address loading and the 60-second refresh
CentralCommunicationActor calls ISiteRepository.GetAllSitesAsync inside a background Task.Run (to avoid blocking the actor thread on a database round-trip) and pipes the result as SiteAddressCacheLoaded. The actor-lifecycle CancellationTokenSource is threaded into the repository call so a slow MS SQL query is cancelled when the actor stops.
A malformed address for one site does not abort the refresh loop — the actor catches the parse failure, logs a warning, skips that site, and processes the rest. The refresh also runs immediately on startup (TimeSpan.Zero initial delay) so the cache is populated before the first command arrives.
CommunicationService.RefreshSiteAddresses() triggers an on-demand refresh when a site record is added, edited, or deleted from the Central UI or CLI.
gRPC real-time data transport
Real-time attribute value and alarm state changes are delivered over SiteStreamService, defined in sitestream.proto. The server runs on every site node and the client runs on central — central dials in to receive the stream (see the transport table above).
Site-side — SiteStreamGrpcServer (Kestrel h2c, HTTP/2 only, port 8083):
- Implements
SiteStreamService.SiteStreamServiceBase. - For each
SubscribeInstancecall, creates aStreamRelayActor(namedstream-relay-{correlationId}-{seq}) and subscribes it toISiteStreamSubscriber(implemented bySiteStreamManagerin the Site Runtime project —SiteStreamGrpcServerholds only the interface so it does not referenceSiteRuntimedirectly). - Bridges events via a
BoundedChannel<SiteStreamEvent>(capacity 1000,DropOldest) from the actor thread to the async gRPC write loop. - Enforces a
GrpcMaxConcurrentStreamslimit (default 100) and aGrpcMaxStreamLifetimesession timeout (default 4 hours) to evict zombie streams. - Validates
correlation_idagainstActorPath.IsValidPathElementbefore use in an actor name, rejecting invalid values withStatusCode.InvalidArgument. - During
CoordinatedShutdown,CancelAllStreams()flips_shuttingDown, refuses new subscriptions withStatusCode.Unavailable, and cancels all activeCancellationTokenSources.
StreamRelayActor is a lightweight ReceiveActor that converts AttributeValueChanged and AlarmStateChanged domain events to proto SiteStreamEvent messages and writes them to the channel writer:
// StreamRelayActor.cs
private void HandleAttributeValueChanged(AttributeValueChanged msg)
{
var protoEvent = new SiteStreamEvent
{
CorrelationId = _correlationId,
AttributeChanged = new AttributeValueUpdate
{
InstanceUniqueName = msg.InstanceUniqueName,
AttributePath = msg.AttributePath,
AttributeName = msg.AttributeName,
Value = ValueFormatter.FormatDisplayValue(msg.Value),
Quality = MapQuality(msg.Quality),
Timestamp = Timestamp.FromDateTimeOffset(msg.Timestamp)
}
};
WriteToChannel(protoEvent);
}
Central-side — SiteStreamGrpcClient / SiteStreamGrpcClientFactory:
SiteStreamGrpcClientFactory(singleton) caches oneSiteStreamGrpcClientper(site, endpoint)pair — aConcurrentDictionary<(string Site, string Endpoint), SiteStreamGrpcClient>. The key was widened from site-only to fix an arch-review High: with a site-only key, one debug session's NodeA→NodeB failover flip disposed a channel another session was still using.GetOrCreatetherefore no longer disposes on endpoint mismatch; both of a site's node channels coexist, and site removal (RemoveSiteAsync) is the only shared-disposal path. The trade-off is that an edited gRPC address leaves the old endpoint's idle channel cached until site removal or process shutdown — bounded at a handful of entries per site.SiteStreamGrpcClientopens aGrpcChannelwith HTTP/2 keepalive (KeepAlivePingDelaydefault 15 s,KeepAlivePingTimeoutdefault 10 s,KeepAlivePingPolicy.Always).SubscribeAsyncis a plainasync Taskthat callsSubscribeInstanceand reads the response stream withawait foreach, invokingonEventfor each received event andonErroron any non-cancellation exception. The caller (DebugStreamBridgeActor.OpenGrpcStream) launches it inside aTask.Runso the long-running stream loop runs off the actor thread.
Debug stream session lifecycle
DebugStreamService manages one DebugStreamBridgeActor per active debug session. On StartStreamAsync, it resolves the instance's site and gRPC addresses, creates the bridge actor, and holds the session in a ConcurrentDictionary.
DebugStreamBridgeActor (one per session, short-lived, no persistence):
- In
PreStart, sendsSubscribeDebugViewRequesttoCentralCommunicationActor(ClusterClient, for the initial snapshot). - On receiving
DebugViewSnapshot, firesonEvent(snapshot)and callsOpenGrpcStream. OpenGrpcStreamcalls_grpcFactory.GetOrCreate(siteId, endpoint)and launchesclient.SubscribeAsync(...)as a background task. Domain events are marshalled back to the actor viaSelf.Tellfor thread safety.- On a gRPC error, flips to the other node endpoint and retries (first retry immediate, subsequent retries with
ReconnectDelaydefault 5 s). The retry budget (MaxRetries = 3) is recovered only afterStabilityWindow(default 60 s) of uninterrupted connection — a stream that delivers one event then immediately fails does not count as stable. - On
StopDebugStream, cancels the gRPC subscription and sendsUnsubscribeDebugViewRequestto the site via ClusterClient.
Proto definition summary
// Protos/sitestream.proto — six RPCs, all served by the SITE
service SiteStreamService {
rpc SubscribeInstance(InstanceStreamRequest) returns (stream SiteStreamEvent);
rpc SubscribeSite(SiteStreamRequest) returns (stream SiteStreamEvent);
rpc IngestAuditEvents(AuditEventBatch) returns (IngestAck);
rpc IngestCachedTelemetry(CachedTelemetryBatch) returns (IngestAck);
rpc PullAuditEvents(PullAuditEventsRequest) returns (PullAuditEventsResponse);
rpc PullSiteCalls(PullSiteCallsRequest) returns (PullSiteCallsResponse);
}
Two are server-streaming: SubscribeInstance carries the per-instance real-time stream; SubscribeSite is the site-wide, alarm-only stream (no instance filter, attribute updates never carried) that feeds the aggregated central live alarm cache. The four unary RPCs serve the Audit Log and Site Call Audit push/pull paths — SiteStreamGrpcServer hosts them on the same port because sites already listen there. As noted above, the two Ingest* RPCs are dead in the shipped topology (no central gRPC server exists for a site to dial); the two Pull* RPCs are live, with central as the caller.
SiteStreamEvent uses a oneof event { AttributeValueUpdate, AlarmStateUpdate } discriminator. AlarmStateUpdate carries the full native alarm condition (fields 8–23) alongside the base computed-alarm fields (1–7), added additively so old clients ignoring unknown fields continue to work. Field numbers are never reused and evolution is additive only.
The generated C# is vendored under Communication/SiteStreamGrpc/ with the <Protobuf> include commented out, so editing sitestream.proto does not regenerate on build — regeneration is a manual toggle-build-copy-untoggle.
Usage
Central callers interact through CommunicationService, which wraps each command pattern in a typed Ask with a per-pattern timeout:
| Pattern | Method | Timeout |
|---|---|---|
| Instance deployment (notify-and-fetch) | RefreshDeploymentAsync |
120 s |
| Instance lifecycle | DisableInstanceAsync, EnableInstanceAsync, DeleteInstanceAsync |
30 s |
| Artifact deployment | DeployArtifactsAsync |
60 s |
| Integration routing | RouteIntegrationCallAsync |
30 s |
| Debug snapshot | RequestDebugSnapshotAsync |
30 s |
| Remote queries | QueryEventLogsAsync, QueryParkedMessagesAsync, etc. |
30 s |
| OPC UA tag browse | BrowseNodeAsync |
30 s |
| Notification outbox (central-local) | QueryNotificationOutboxAsync, RetryNotificationAsync, etc. |
30 s |
| Site Call Audit (central-local) | QuerySiteCallsAsync, RetrySiteCallAsync, etc. |
30 s |
Notification Outbox and Site Call Audit actors are central-local singletons — their CommunicationService methods Ask the proxy directly without wrapping in SiteEnvelope.
For real-time streaming, callers use DebugStreamService.StartStreamAsync, which creates a DebugStreamBridgeActor and returns a session handle. Ongoing events arrive via the onEvent callback; session teardown is via StopStreamAsync.
Configuration
All options are bound from the ScadaBridge:Communication section via CommunicationOptions:
| Key | Default | Description |
|---|---|---|
DeploymentTimeout |
00:02:00 |
Ask timeout for the RefreshDeploymentCommand round-trip (covers the site's HTTP config fetch and apply). |
LifecycleTimeout |
00:00:30 |
Ask timeout for lifecycle commands (disable, enable, delete). |
ArtifactDeploymentTimeout |
00:01:00 |
Ask timeout for system-wide artifact deployment. |
QueryTimeout |
00:00:30 |
Ask timeout for remote queries and management commands. |
IntegrationTimeout |
00:00:30 |
Ask timeout for integration routing and Inbound API routing. |
DebugViewTimeout |
00:00:10 |
Ask timeout for debug subscribe/unsubscribe handshake. |
NotificationForwardTimeout |
00:00:30 |
Ask timeout for notification submission forwarding. |
CentralContactPoints |
[] |
Site-side: Akka addresses of central nodes, e.g. akka.tcp://scadabridge@central-a:8081. |
GrpcKeepAlivePingDelay |
00:00:15 |
HTTP/2 keepalive PING interval on SiteStreamGrpcClient. |
GrpcKeepAlivePingTimeout |
00:00:10 |
HTTP/2 keepalive PING timeout. |
GrpcMaxStreamLifetime |
04:00:00 |
Per-stream session timeout; forces reconnect of zombie streams. |
GrpcMaxConcurrentStreams |
100 |
Max concurrent SubscribeInstance streams per site node. |
ApplicationHeartbeatInterval |
00:00:05 |
SiteCommunicationActor site→central heartbeat cadence. |
TransportHeartbeatInterval |
00:00:05 |
Akka.Remote transport failure-detector heartbeat interval (emitted into the HOCON by the Host). Distinct from the application heartbeat above. |
TransportFailureThreshold |
00:00:15 |
Akka remoting failure-detection threshold. |
CentralFetchBaseUrl |
"" |
Base URL (Traefik/LB) the site uses to fetch deploy configs from central. Carried in RefreshDeploymentCommand so sites need no standing config; empty makes a deploy impossible — DeploymentService fails fast. |
PendingDeploymentTtl |
00:05:00 |
How long a staged PendingDeployment row and its fetch token stay valid. Must comfortably cover both site nodes' fetches within one deploy window. |
PendingDeploymentPurgeInterval |
01:00:00 |
Cadence of the central pending-deployment-purge singleton that sweeps TTL-expired staging rows. Hygiene only — the fetch endpoint already enforces the TTL. |
Three layers of dead-client detection protect the gRPC stream path:
| Layer | Detects | Timeline |
|---|---|---|
| TCP RST | Clean process death, connection close | ~1–5 s |
| gRPC keepalive PING | Network partition, silent crash | ~25 s |
Session timeout (GrpcMaxStreamLifetime) |
Zombie streams with misconfigured keepalive | 4 h |
Dependencies & Interactions
- Commons (#16) — owns all message contracts used by this component:
DeployInstanceCommand,SiteEnvelope,HeartbeatMessage,SiteHealthReport,SiteHealthReportReplica,RegisterNotificationOutbox,RegisterAuditIngest,IngestAuditEventsCommand,IngestCachedTelemetryCommand, and all other request/response records. Commons does not hold an Akka package reference, soRegisterAuditIngest(which carries anIActorRef) lives in this project. - Cluster Infrastructure (#13) — provides
ClusterClientReceptionistregistration and the oldest-Upactive/standby model thatSiteCommunicationActor'sIsActivestamp depends on, plus the single"scadabridge"ActorSystemname that makes cross-clusterClusterClientaddressing possible at all.CentralCommunicationActor'sDistributedPubSubfanout keeps both central nodes in sync regardless of which one a site's report landed on. - Configuration Database (#17) — provides
ISiteRepository.GetAllSitesAsyncfor address loading; site records carryNodeAAddress,NodeBAddress,GrpcNodeAAddress,GrpcNodeBAddress. - Deployment Manager (#2) — the primary consumer of command/control patterns 1–3.
CommunicationServiceis injected into the Deployment Manager actor to send deploy notifies, lifecycle commands, and artifact deployments to sites. It also owns the staging half of the notify-and-fetch HTTP path (PendingDeploymentrows + fetch tokens); the endpoint itself is served by the Management Service. - Site Runtime (#3) —
SiteCommunicationActorforwards inbound commands to theDeploymentManagersingleton proxy.SiteStreamManager(in Site Runtime) implementsISiteStreamSubscribersoSiteStreamGrpcServercan subscribe relay actors to instance event feeds without referencing Site Runtime directly. - Health Monitoring (#11) —
CentralCommunicationActorcallsICentralHealthAggregator.MarkHeartbeatandProcessReportfor every inbound heartbeat and health report.DistributedPubSubfanout keeps both central nodes' aggregators in sync. - Audit Log (#23) —
SiteStreamGrpcServerhosts theIngestAuditEvents,IngestCachedTelemetry,PullAuditEventsandPullSiteCallsRPCs. Because there is no central gRPC server, theIngest*pair is unused in the shipped topology: sites push audit telemetry over ClusterClient, andCentralCommunicationActorroutesIngestAuditEventsCommand/IngestCachedTelemetryCommandto theAuditLogIngestActorproxy. ThePull*reconciliation RPCs run the other way, with the centralsite-audit-reconciliationsingleton dialling each site. - Notification Outbox (#21) —
CentralCommunicationActorroutesNotificationSubmit/NotificationStatusQuerymessages from sites to theNotificationOutboxActorproxy.CommunicationServiceAsks the proxy directly for central-UI outbox management calls. - Site Call Audit (#22) —
CommunicationServiceAsks theSiteCallAuditActorproxy directly for query and relay operations.SiteCallAuditActorissuesRetryParkedOperation/DiscardParkedOperationrelay commands to sites viaSiteEnvelope;SiteCommunicationActordispatches them to_parkedMessageHandler. - Store-and-Forward Engine (#6) — the site S&F Engine drives
NotificationSubmitforwarding and cached-call telemetry emission throughSiteCommunicationActor. Parked-message queries and retry/discard relay commands flow back the other way. - Management Service (#18) —
ManagementActoris registered withClusterClientReceptionistat/user/managementon central; the CLI connects via its own separateClusterClient. This is a distinctClusterClientusage from the inter-cluster hub-and-spoke connections managed by this component. Management Service also hostsDeploymentConfigEndpoints— theGET /api/internal/deployments/{id}/configroute that terminates the third (HTTP) transport, mapped in the central-role block alongside/api/audit/*and/management. - Design spec: Component-Communication.md.
Troubleshooting
A site's commands fail immediately
Check that NodeAAddress and NodeBAddress are populated in the site configuration — if both are empty, CentralCommunicationActor logs a warning and skips that site on every refresh, so no ClusterClient is created and all commands timeout. CommunicationService.RefreshSiteAddresses() triggers an on-demand refresh after an address is added.
Commands are timing out but the site is reachable
A single malformed address string for one site can silently prevent ClusterClient creation for that site while other sites are unaffected. Check the logs for a Warning line from HandleSiteAddressCacheLoaded naming the offending site. The actor parse-guard catches the ActorPath.Parse exception per-site so the rest of the refresh proceeds.
A Warning at the Status.Failure handler in CentralCommunicationActor means LoadSiteAddressesFromDb itself threw (typically a SQL connection error); the cache is left stale until the next successful refresh.
gRPC debug stream drops immediately after opening
SiteStreamGrpcServer rejects correlation_id values that contain characters invalid in Akka actor names (/, whitespace, etc.) with StatusCode.InvalidArgument. Verify that the calling DebugStreamBridgeActor generates a safe correlation ID.
After a site node failover, the DebugStreamBridgeActor attempts to reconnect to the other node endpoint (_useNodeA flips on each error). If both nodes are unreachable, the actor exhausts its 3-retry budget and calls onTerminated. The engineer must restart the debug session.
Deployments fail immediately with a config-fetch error
The site received the RefreshDeploymentCommand over ClusterClient but could not complete the HTTP leg. Check CentralFetchBaseUrl first — it must be reachable from the site, so a value that only resolves inside the central network fails every deploy. A 404 from the fetch means the staged row was unknown, superseded, or past PendingDeploymentTtl; a 401 means the row is live but the token did not match. Because the endpoint hides existence, a 404 cannot distinguish "wrong id" from "expired".
Heartbeats arrive but health reports do not
SiteCommunicationActor sends heartbeats and health reports via separate paths. Health reports are sent only when the site's HealthReportSender publishes them (every 30 s by default). If heartbeats arrive but reports do not, the health-report sender on the site may have faulted — check site-side logs for errors in HealthReportSender.