Module database

Source
Available on crate feature database only.
Expand description

Message store database functionality.

See MessageStore.

Structs§

CategoryStream
A category stream for consuming messages and storing the position.
GetCategoryMessagesOpts
Options for MessageStore::get_category_messages.
GetStreamMessagesOpts
Options for MessageStore::get_stream_messages.
MessageStore
Message DB client containing a postgres connection pool.
SubscribeToCategoryOpts
Options for MessageStore::subscribe_to_category.
WriteMessageOpts
Options for MessageStore::write_message.

Type Aliases§

MessageStoreTransaction
Type alias for a MessageStore transaction.