|0.0.1-alpha.1||Jul 14, 2021|
#93 in WebSocket
22 downloads per month
Note: At the moment, this project is intended for me to learn and implement stuff I'm interested in. It's not really of any practical use to anyone.
Infotainer contains building blocks for simple pubsub services based on actix/-web, cbor and websockets.
- websocket interface: handles client-server interaction
- pubsub service: manages subscriptions and handles publication of client submissions
- datalog service: maintains log indices for and handles filesystem interactions
The websocket interface is an actor whose handlers are largely built around the
ClientCommand consists of struct variants holding data sent from client to server. These are translated into actix
Messages by the
ServerResponse type is used to wrap data sent from server to client and can contain
HashSet<Uuid>, representing a subscriptions log index,
Publication, representing data published by some client, or
DataLogEntry, containing one or more
Publications previously submitted to the data log.
The pubsub service actor handles the
ManageSubscription messages. When data is submitted for publication, the actor looks up the addressed
Subscription, generates a
Publication, sends it, wrapped in a
DataLogPut message, to the
DataLogger and proceeds to distribute it to connected clients subscribed to the
ManageSubscription has two variants,
Remove, and is used by clients to un-/subscribe from/to
DatalogService enables persisting the server state as well as published data.
DataLogPut messages represent write requests for
SubscriptionMeta, subscriber lists and
DataLogFetch messages are used to retrieve persisted data. Additionally, it maintains a log of subscriptions and their publications.
- websocket interface/ client message types
- Subscription/Subscription table
- Broadcast-type subscriptions
- Queue-type subscriptions
- publishing messages
- session management
- data log service
- persisting/retrieval of publication data
- persisting/retrieval of subscription metadata
- recreating server state from persisted data