| /dports/net/krill/krill-0.9.4/src/commons/eventsourcing/ |
| H A D | kv.rs | 16 pub struct KeyStoreKey { struct
21 impl KeyStoreKey { argument
23 KeyStoreKey { scope, name } in new()
27 KeyStoreKey { scope: None, name } in simple()
31 KeyStoreKey { in scoped()
53 KeyStoreKey { in sub_scope()
73 impl fmt::Display for KeyStoreKey { implementation
145 pub fn move_key(&self, from: &KeyStoreKey, to: &KeyStoreKey) -> Result<(), KeyValueError> { in move_key() argument
363 pub fn move_key(&self, from: &KeyStoreKey, to: &KeyStoreKey) -> Result<(), KeyValueError> { in move_key() argument
485 UnknownKey(KeyStoreKey),
[all …]
|
| H A D | store.rs | 681 fn key_version() -> KeyStoreKey { in key_version()
682 KeyStoreKey::simple("version".to_string()) in key_version()
685 fn key_for_info(agg: &Handle) -> KeyStoreKey { in key_for_info() argument
686 KeyStoreKey::scoped(agg.to_string(), "info.json".to_string()) in key_for_info()
689 fn key_for_snapshot(agg: &Handle) -> KeyStoreKey { in key_for_snapshot() argument
690 KeyStoreKey::scoped(agg.to_string(), "snapshot.json".to_string()) in key_for_snapshot()
693 fn key_for_backup_snapshot(agg: &Handle) -> KeyStoreKey { in key_for_backup_snapshot() argument
697 fn key_for_new_snapshot(agg: &Handle) -> KeyStoreKey { in key_for_new_snapshot() argument
701 fn key_for_event(agg: &Handle, version: u64) -> KeyStoreKey { in key_for_event() argument
705 fn key_for_command(agg: &Handle, command: &CommandKey) -> KeyStoreKey { in key_for_command() argument
[all …]
|
| /dports/net/krill/krill-0.9.4/src/upgrades/ |
| H A D | mod.rs | 14 eventsourcing::{AggregateStoreError, CommandKey, KeyStoreKey, KeyValueError, KeyValueStore},
104 fn command_keys(&self, scope: &str) -> Result<Vec<KeyStoreKey>, UpgradeError> { in command_keys() argument
117 .map(|ck| KeyStoreKey::scoped(scope.to_string(), format!("{}.json", ck))) in command_keys()
123 fn get<V: DeserializeOwned>(&self, key: &KeyStoreKey) -> Result<V, UpgradeError> { in get()
129 fn event_key(scope: &str, nr: u64) -> KeyStoreKey { in event_key() argument
130 KeyStoreKey::scoped(scope.to_string(), format!("delta-{}.json", nr)) in event_key()
134 let snapshot_key = KeyStoreKey::scoped(scope.to_string(), "snapshot.json".to_string()); in archive_snapshots()
135 … let snapshot_bk_key = KeyStoreKey::scoped(scope.to_string(), "snapshot-bk.json".to_string()); in archive_snapshots()
148 fn archive_to_migration_scope(&self, key: &KeyStoreKey) -> Result<(), UpgradeError> { in archive_to_migration_scope()
|
| /dports/net/krill/krill-0.9.4/src/upgrades/v0_9_0/ |
| H A D | pubd_objects_migration.rs | 23 … Aggregate, AggregateStore, CommandKey, KeyStoreKey, KeyValueStore, StoredEvent, StoredValueInfo,
69 let info = KeyStoreKey::scoped("0".to_string(), "info.json".to_string()); in populate_repo_content()
89 let dflt_key = KeyStoreKey::simple(format!("{}.json", PUBSERVER_DFLT)); in populate_repo_content()
124 … let migration_info_key = KeyStoreKey::scoped(migration_scope.clone(), "info.json".to_string()); in migrate()
199 … let key = KeyStoreKey::scoped(scope.to_string(), format!("delta-{}.json", info.last_event)); in migrate()
219 let key = KeyStoreKey::scoped(scope.to_string(), format!("{}.json", cmd_key)); in migrate()
234 let info_key = KeyStoreKey::scoped(scope.to_string(), "info.json".to_string()); in migrate()
259 let key = KeyStoreKey::simple("version".to_string()); in version_before()
|
| H A D | ca_objects_migration.rs | 18 …eventsourcing::{Aggregate, AggregateStore, CommandKey, KeyStoreKey, KeyValueStore, StoredValueInfo…
84 let info_key = KeyStoreKey::scoped(c.to_string(), "info.json".to_string()); in populate_ca_objects_store()
164 … let migration_info_key = KeyStoreKey::scoped(migration_scope.clone(), "info.json".to_string()); in migrate()
189 … let old_init_key = KeyStoreKey::scoped(migration_scope.clone(), "delta-0.json".to_string()); in migrate()
190 let init_key = KeyStoreKey::scoped(scope.clone(), "delta-0.json".to_string()); in migrate()
230 let key = KeyStoreKey::scoped(scope.clone(), format!("{}.json", cmd_key)); in migrate()
294 … KeyStoreKey::scoped(scope.clone(), format!("delta-{}.json", info.last_event)); in migrate()
314 let key = KeyStoreKey::scoped(scope.clone(), format!("{}.json", cmd_key)); in migrate()
325 let info_key = KeyStoreKey::scoped(scope.clone(), "info.json".to_string()); in migrate()
|
| /dports/net/krill/krill-0.9.4/src/daemon/ca/ |
| H A D | status.rs | 11 eventsourcing::{KeyStoreKey, KeyValueStore},
78 fn status_key(ca: &Handle) -> KeyStoreKey { in status_key() argument
79 KeyStoreKey::scoped(ca.to_string(), "status.json".to_string()) in status_key()
|
| H A D | publishing.rs | 33 eventsourcing::{KeyStoreKey, KeyValueStore, PreSaveEventListener},
151 fn key(ca: &Handle) -> KeyStoreKey { in key() argument
152 KeyStoreKey::simple(format!("{}.json", ca)) in key()
|
| /dports/net/krill/krill-0.9.4/src/pubd/ |
| H A D | repository.rs | 28 eventsourcing::{Aggregate, AggregateStore, KeyStoreKey, KeyValueStore},
53 key: KeyStoreKey,
61 let key = KeyStoreKey::simple(format!("{}.json", PUBSERVER_DFLT)); in disk()
|
| /dports/net/krill/krill-0.9.4/doc/development/ |
| H A D | 05_repo_manager.md | 48 key: KeyStoreKey,
|
| H A D | 04_es_krill.md | 31 a `KeyStoreKey` and save or retrieve values. The key supports 'scopes' which can be useful
37 pub struct KeyStoreKey {
|