Changeset View
Changeset View
Standalone View
Standalone View
services/tunnelbroker/src/constants.rs
| use tokio::time::Duration; | use tokio::time::Duration; | ||||
| pub const GRPC_TX_QUEUE_SIZE: usize = 32; | pub const GRPC_TX_QUEUE_SIZE: usize = 32; | ||||
| pub const GRPC_SERVER_PORT: u16 = 50051; | pub const GRPC_SERVER_PORT: u16 = 50051; | ||||
| pub const GRPC_KEEP_ALIVE_PING_INTERVAL: Duration = Duration::from_secs(3); | pub const GRPC_KEEP_ALIVE_PING_INTERVAL: Duration = Duration::from_secs(3); | ||||
| pub const GRPC_KEEP_ALIVE_PING_TIMEOUT: Duration = Duration::from_secs(10); | pub const GRPC_KEEP_ALIVE_PING_TIMEOUT: Duration = Duration::from_secs(10); | ||||
| pub const LOG_LEVEL_ENV_VAR: &str = | pub const LOG_LEVEL_ENV_VAR: &str = | ||||
| tracing_subscriber::filter::EnvFilter::DEFAULT_ENV; | tracing_subscriber::filter::EnvFilter::DEFAULT_ENV; | ||||
| pub mod dynamodb { | |||||
| // This table holds messages which could not be immediately delivered to | |||||
| // a device. | |||||
| // | |||||
| // - (primary key) = (deviceID: Partition Key, createdAt: Sort Key) | |||||
| // - deviceID: The public key of a device's olm identity key | |||||
| // - payload: Message to be delivered. See shared/tunnelbroker_messages. | |||||
| // - createdAt: UNIX timestamp of when the item was inserted. | |||||
| // Timestamp is needed to order the messages correctly to the device. | |||||
| pub mod undelivered_messages { | |||||
| pub const TABLE_NAME: &str = "tunnelbroker-undelivered-messages"; | |||||
| pub const PARTITION_KEY: &str = "deviceID"; | |||||
| pub const DEVICE_ID: &str = "deviceID"; | |||||
| pub const PAYLOAD: &str = "payload"; | |||||
| pub const CREATED_AT: &str = "createdAt"; | |||||
| pub const SORT_KEY: &str = "createdAt"; | |||||
| } | |||||
| } | |||||