Skip to main content

tycho_collator/storage/
db.rs

1use tycho_storage::kv::{NamedTables, TableContext};
2use weedb::WeeDb;
3
4use super::tables;
5
6pub type InternalQueueDB = WeeDb<InternalQueueTables>;
7
8impl NamedTables for InternalQueueTables {
9    const NAME: &'static str = "int_queue";
10}
11
12// TODO: Add migrations.
13
14weedb::tables! {
15    pub struct InternalQueueTables<TableContext> {
16        pub internal_message_var: tables::InternalMessageVar,
17        pub internal_message_diffs_tail: tables::InternalMessageDiffsTail,
18        pub internal_message_diff_info: tables::InternalMessageDiffInfo,
19        pub internal_message_commit_pointer: tables::InternalMessageCommitPointer,
20        pub internal_message_stats: tables::InternalMessageStatistics,
21        pub shard_internal_messages: tables::ShardInternalMessages,
22    }
23}