util library

Classes

AdditionalData
AdditionalDataEvent
AsyncEventEmitter: Implementation of a typed async event emitter. This event emitter maintains a queue of events, the events are processed in order and the next is not started until all (async) event listeners for the previous event have finished. Event listers for a single event are processed concurrently, events are processed sequentially. Typings are inspired by the 'typed-emitter' package.
AuthResponse
BaseTransaction<ChangeT>
Change
ConnectivityState
DataChange
ElectricEnumCodec<T extends Enum>
EventWithAck<T>
GoneBatch
GoneBatchEvent
InboundReplication
QualifiedTablename
Relation
RelationColumn
ReplicatedRowTransformer<RowType>
Replication<TransactionType>
RunResult
SchemaChange
SeenAdditionalDataInfo
ServerTransaction
SocketCloseReason
StartReplicationResponse
Statement
StopReplicationResponse
TransactionEvent
TypeConverters

createConnectivityStateSubscribeFunction(Notifier notifier) → ConnectivityStateSubscribeFunction
escDoubleQ(String str) → String
genUUID() → String
unescDoubleQ(String str) → String

AdditionalDataCallback = Future<void> Function(AdditionalData)
ConnectivityStateSubscribeFunction = void Function() Function(void handler(ConnectivityState))
DataTransaction = BaseTransaction<DataChange>
DbName = String
DbRecord = Map<String, Object?>
EmitterAdditionalDataCallback = EventCallbackCall<AdditionalDataEvent>
EmitterGoneBatchCallback = EventCallbackCall<GoneBatchEvent>
EmitterTransactionCallback = EventCallbackCall<TransactionEvent>
ErrorAndStackTrace = ({Object error, StackTrace st})
ErrorCallback = EventCallbackCall<(SatelliteException, StackTrace)>
GoneBatchCallback = Future<void> Function(GoneBatch)
LSN = List<int>
MigrationTable = SatOpMigrate_Table
OutboundStartedCallback = EventCallbackCall<void>
RelationCallback = EventCallbackCall<Relation>
RelationsCache = Map<String, Relation>
RowId = int
SqlValue = Object?
Tag = String
Transaction = BaseTransaction<Change>
TransactionCallback = Future<void> Function(ServerTransaction)