(&self, def: ScheduleDef)
| 23 | } |
| 24 | |
| 25 | pub fn register(&self, def: ScheduleDef) { |
| 26 | let key = (def.tenant_id, def.name.clone()); |
| 27 | let mut map = self.by_name.write().unwrap_or_else(|p| p.into_inner()); |
| 28 | map.insert(key, def); |
| 29 | } |
| 30 | |
| 31 | pub fn unregister(&self, tenant_id: u64, name: &str) -> bool { |
| 32 | let key = (tenant_id, name.to_string()); |