Start background sync tasks
(&self)
| 156 | |
| 157 | /// Start background sync tasks |
| 158 | pub async fn start_sync_tasks(&self) { |
| 159 | let persistent = self.persistent_manager.clone(); |
| 160 | let ephemeral = self.ephemeral_manager.clone(); |
| 161 | |
| 162 | tokio::join!(persistent.start_sync_tasks(), ephemeral.start_sync_tasks(),); |
| 163 | |
| 164 | info!("WaveKV sync tasks started"); |
| 165 | } |
| 166 | |
| 167 | /// Handle incoming sync request for persistent store |
| 168 | pub fn handle_persistent_sync(&self, msg: SyncMessage) -> Result<SyncResponse> { |
no test coverage detected