crdt_sync_server library

Classes

CrdtSync

Constants

defaultPingInterval → const Duration

Functions

listen(SqlCrdt crdt, int port, {Duration? pingInterval = defaultPingInterval, ServerHandshakeDataBuilder? handshakeDataBuilder, Map<String, Query>? changesetQueries, RecordValidator? validateRecord, void onConnecting(HttpRequest request)?, ServerOnConnect? onConnect, OnDisconnect? onDisconnect, OnChangeset? onChangesetReceived, OnChangeset? onChangesetSent, bool verbose = false}) → Future<void>

Opens an HTTP socket and starts listening for incoming connections on the specified port.

upgrade(SqlCrdt crdt, HttpRequest request, {Duration? pingInterval = defaultPingInterval, ServerHandshakeDataBuilder? handshakeDataBuilder, Map<String, Query>? changesetQueries, RecordValidator? validateRecord, ServerOnConnect? onConnect, OnDisconnect? onDisconnect, OnChangeset? onChangesetReceived, OnChangeset? onChangesetSent, bool verbose = false}) → Future<void>

Typedefs

ClientHandshakeDataBuilder = FutureOr<Object>? Function()

OnChangeset = void Function(String nodeId, Map<String, int> recordCounts)

OnConnect = void Function(String peerId, Object? customData)

OnDisconnect = void Function(String peerId, int? code, String? reason)

Query = (String, List<Object?>)

RecordValidator = FutureOr<bool> Function(String table, Map<String, dynamic> record)

ServerHandshakeDataBuilder = FutureOr<Object>? Function(String peerId, Object? peerData)

ServerOnConnect = void Function(CrdtSync crdtSync, Object? customData)