contextdb_server/subjects.rs
1pub fn push_subject(tenant_id: &str) -> String {
2 format!("sync.{tenant_id}.push")
3}
4
5pub fn pull_subject(tenant_id: &str) -> String {
6 format!("sync.{tenant_id}.pull")
7}
8
9pub fn command_subject(tenant_id: &str, command: &str) -> String {
10 format!("sync.{tenant_id}.command.{command}")
11}