EntglDb.Sync 2.3.0

EntglDb.Sync

Synchronization engine for EntglDb — provides oplog, vector clocks, anti-entropy gossip, snapshots, and the P2P service mesh.

What's Included

• Oplog: Append-only, SHA-256 hash-chained journal of local changes
• Vector Clock: Causal ordering and divergence detection across nodes
• Anti-Entropy Gossip: Periodic exchange of vector clocks with peers to detect and reconcile differences
• Snapshot Sync: Fast full-state catch-up for nodes that have been offline or missed too many changes
• Interest-Aware Sync: Nodes advertise which collections they care about; only relevant changes are exchanged
• P2P Service Mesh: The shared TCP connections can be used for custom application-level protocols (message type ≥ 32)

Installation

dotnet add package EntglDb.Core
dotnet add package EntglDb.Network
dotnet add package EntglDb.Sync
dotnet add package EntglDb.Persistence.BLite   # or EntglDb.Persistence.EntityFramework

Quick Start

builder.Services
    .AddEntglDbCore()
    .AddEntglDbBLite<MyDbContext, MyDocumentStore>(sp => new MyDbContext("data.blite"))
    .AddEntglDbNetwork<StaticPeerNodeConfigurationProvider>()
    .AddEntglDbSync();          // registers sync handlers + SyncOrchestrator + EntglDbNode

Custom P2P Services

Implement INetworkMessageHandler for server-side handling and inject IPeerMessenger for outbound calls. Message types ≥ 32 are reserved for user services.

// Server side — handle incoming requests
public class PingHandler : INetworkMessageHandler
{
    public int MessageType => 100;  // pick any value in the 32–999 custom range

    public Task<(IMessage? Response, int ResponseType)> HandleAsync(IMessageHandlerContext context)
    {
        var req = PingRequest.Parser.ParseFrom(context.Payload);
        return Task.FromResult<(IMessage?, int)>(
            (new PingResponse { Echo = req.Message }, 33));
    }
}

// Register after AddEntglDbNetwork / AddEntglDbSync
services.AddSingleton<INetworkMessageHandler, PingHandler>();

// Client side — send a request
var (_, payload) = await messenger.SendAndReceiveAsync(
    "192.168.1.10:7000", 100, new PingRequest { Message = "hello" }, ct);
var response = PingResponse.Parser.ParseFrom(payload);

Documentation

• Full README
• Architecture
• Custom P2P Services
• Conflict Resolution