reddb_server/application/
ports_impls_admin.rs

1use super::*;
2impl RuntimeAdminPort for RedDBRuntime {
3    fn set_index_enabled(&self, name: &str, enabled: bool) -> RedDBResult<PhysicalIndexState> {
4        RedDBRuntime::set_index_enabled(self, name, enabled)
5    }
6
7    fn mark_index_building(&self, name: &str) -> RedDBResult<PhysicalIndexState> {
8        RedDBRuntime::mark_index_building(self, name)
9    }
10
11    fn fail_index(&self, name: &str) -> RedDBResult<PhysicalIndexState> {
12        RedDBRuntime::fail_index(self, name)
13    }
14
15    fn mark_index_stale(&self, name: &str) -> RedDBResult<PhysicalIndexState> {
16        RedDBRuntime::mark_index_stale(self, name)
17    }
18
19    fn mark_index_ready(&self, name: &str) -> RedDBResult<PhysicalIndexState> {
20        RedDBRuntime::mark_index_ready(self, name)
21    }
22
23    fn warmup_index_with_lifecycle(&self, name: &str) -> RedDBResult<PhysicalIndexState> {
24        RedDBRuntime::warmup_index_with_lifecycle(self, name)
25    }
26
27    fn rebuild_indexes_with_lifecycle(
28        &self,
29        collection: Option<&str>,
30    ) -> RedDBResult<Vec<PhysicalIndexState>> {
31        RedDBRuntime::rebuild_indexes_with_lifecycle(self, collection)
32    }
33
34    fn save_graph_projection(
35        &self,
36        name: impl Into<String>,
37        projection: RuntimeGraphProjection,
38        source: Option<String>,
39    ) -> RedDBResult<PhysicalGraphProjection> {
40        RedDBRuntime::save_graph_projection(self, name, projection, source)
41    }
42
43    fn mark_graph_projection_materializing(
44        &self,
45        name: &str,
46    ) -> RedDBResult<PhysicalGraphProjection> {
47        RedDBRuntime::mark_graph_projection_materializing(self, name)
48    }
49
50    fn materialize_graph_projection(&self, name: &str) -> RedDBResult<PhysicalGraphProjection> {
51        RedDBRuntime::materialize_graph_projection(self, name)
52    }
53
54    fn fail_graph_projection(&self, name: &str) -> RedDBResult<PhysicalGraphProjection> {
55        RedDBRuntime::fail_graph_projection(self, name)
56    }
57
58    fn mark_graph_projection_stale(&self, name: &str) -> RedDBResult<PhysicalGraphProjection> {
59        RedDBRuntime::mark_graph_projection_stale(self, name)
60    }
61
62    fn save_analytics_job(
63        &self,
64        kind: impl Into<String>,
65        projection_name: Option<String>,
66        metadata: BTreeMap<String, String>,
67    ) -> RedDBResult<PhysicalAnalyticsJob> {
68        RedDBRuntime::save_analytics_job(self, kind, projection_name, metadata)
69    }
70
71    fn start_analytics_job(
72        &self,
73        kind: impl Into<String>,
74        projection_name: Option<String>,
75        metadata: BTreeMap<String, String>,
76    ) -> RedDBResult<PhysicalAnalyticsJob> {
77        RedDBRuntime::start_analytics_job(self, kind, projection_name, metadata)
78    }
79
80    fn queue_analytics_job(
81        &self,
82        kind: impl Into<String>,
83        projection_name: Option<String>,
84        metadata: BTreeMap<String, String>,
85    ) -> RedDBResult<PhysicalAnalyticsJob> {
86        RedDBRuntime::queue_analytics_job(self, kind, projection_name, metadata)
87    }
88
89    fn fail_analytics_job(
90        &self,
91        kind: impl Into<String>,
92        projection_name: Option<String>,
93        metadata: BTreeMap<String, String>,
94    ) -> RedDBResult<PhysicalAnalyticsJob> {
95        RedDBRuntime::fail_analytics_job(self, kind, projection_name, metadata)
96    }
97
98    fn mark_analytics_job_stale(
99        &self,
100        kind: impl Into<String>,
101        projection_name: Option<String>,
102        metadata: BTreeMap<String, String>,
103    ) -> RedDBResult<PhysicalAnalyticsJob> {
104        RedDBRuntime::mark_analytics_job_stale(self, kind, projection_name, metadata)
105    }
106
107    fn complete_analytics_job(
108        &self,
109        kind: impl Into<String>,
110        projection_name: Option<String>,
111        metadata: BTreeMap<String, String>,
112    ) -> RedDBResult<PhysicalAnalyticsJob> {
113        RedDBRuntime::complete_analytics_job(self, kind, projection_name, metadata)
114    }
115}
reddb_server/application/ports_impls_admin.rs

reddb_server/application/
ports_impls_admin.rs
