summary refs log tree commit diff
path: root/extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs
diff options
context:
space:
mode:
authorRory& <root@rory.gay>2026-03-13 06:10:31 +0100
committerRory& <root@rory.gay>2026-03-13 06:10:31 +0100
commitad4b34220027b91f259d4a214dba44a6f8633014 (patch)
tree5bb3f948a7573bb6486a2bf30c34eeb42f738d7e /extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs
parentgateway: util function to do gateway offload stuff (diff)
downloadserver-ts-ad4b34220027b91f259d4a214dba44a6f8633014.tar.xz
CS: make replication messages typed, some offload work
Diffstat (limited to 'extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs')
-rw-r--r--extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs4
1 files changed, 3 insertions, 1 deletions
diff --git a/extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs b/extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs

index 2959c71b..1c23c1c4 100644 --- a/extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs +++ b/extra/admin-api/Interop/Spacebar.Interop.Replication.UnixSocket/UnixSocketSpacebarReplication.cs
@@ -20,7 +20,7 @@ public class UnixSocketSpacebarReplication(UnixSocketConfiguration conf) : ISpac }; } - public async Task SendAsync(ReplicationMessage message) { + public async Task SendAsync(ContentlessReplicationMessage message) { // message format: [uint32be length][payload] var payload = JsonSerializer.SerializeToUtf8Bytes(message); byte[] formattedPayload = [..BitConverter.GetBytes(System.Net.IPAddress.HostToNetworkOrder(payload.Length)), ..payload]; @@ -30,6 +30,8 @@ public class UnixSocketSpacebarReplication(UnixSocketConfiguration conf) : ISpac skv.Value.SendAsync(formattedPayload); }); } + + async Task ISpacebarReplication.SendAsync<TPayload>(ReplicationMessage<TPayload> message) => await SendAsync(message); } public class UnixSocketConfiguration {