reddb_server/application/
ports_impls_native.rs

1use super::*;
2use crate::RedDBError;
3impl RuntimeNativePort for RedDBRuntime {
4    fn health_report(&self) -> crate::health::HealthReport {
5        self.health()
6    }
7
8    fn collection_roots(&self) -> RedDBResult<BTreeMap<String, u64>> {
9        RedDBRuntime::collection_roots(self)
10    }
11
12    fn snapshots(&self) -> RedDBResult<Vec<SnapshotDescriptor>> {
13        RedDBRuntime::snapshots(self)
14    }
15
16    fn exports(&self) -> RedDBResult<Vec<ExportDescriptor>> {
17        RedDBRuntime::exports(self)
18    }
19
20    fn physical_metadata(&self) -> RedDBResult<PhysicalMetadataFile> {
21        self.db()
22            .physical_metadata()
23            .ok_or_else(|| crate::RedDBError::NotFound("physical metadata".to_string()))
24    }
25
26    fn manifest_events_filtered(
27        &self,
28        collection: Option<&str>,
29        kind: Option<&str>,
30        since_snapshot: Option<u64>,
31    ) -> RedDBResult<Vec<ManifestEvent>> {
32        RedDBRuntime::manifest_events_filtered(self, collection, kind, since_snapshot)
33    }
34
35    fn create_snapshot(&self) -> RedDBResult<SnapshotDescriptor> {
36        RedDBRuntime::create_snapshot(self)
37    }
38
39    fn create_export(&self, name: String) -> RedDBResult<ExportDescriptor> {
40        RedDBRuntime::create_export(self, name)
41    }
42
43    fn checkpoint(&self) -> RedDBResult<()> {
44        RedDBRuntime::checkpoint(self)
45    }
46
47    fn apply_retention_policy(&self) -> RedDBResult<()> {
48        RedDBRuntime::apply_retention_policy(self)
49    }
50
51    fn run_maintenance(&self) -> RedDBResult<()> {
52        RedDBRuntime::run_maintenance(self)
53    }
54
55    fn native_header(&self) -> RedDBResult<PhysicalFileHeader> {
56        RedDBRuntime::native_header(self)
57    }
58
59    fn native_collection_roots(&self) -> RedDBResult<BTreeMap<String, u64>> {
60        RedDBRuntime::native_collection_roots(self)
61    }
62
63    fn native_manifest_summary(&self) -> RedDBResult<NativeManifestSummary> {
64        RedDBRuntime::native_manifest_summary(self)
65    }
66
67    fn native_registry_summary(&self) -> RedDBResult<NativeRegistrySummary> {
68        RedDBRuntime::native_registry_summary(self)
69    }
70
71    fn native_recovery_summary(&self) -> RedDBResult<NativeRecoverySummary> {
72        RedDBRuntime::native_recovery_summary(self)
73    }
74
75    fn native_catalog_summary(&self) -> RedDBResult<NativeCatalogSummary> {
76        RedDBRuntime::native_catalog_summary(self)
77    }
78
79    fn native_physical_state(&self) -> RedDBResult<NativePhysicalState> {
80        RedDBRuntime::native_physical_state(self)
81    }
82
83    fn native_vector_artifact_pages(&self) -> RedDBResult<Vec<NativeVectorArtifactPageSummary>> {
84        RedDBRuntime::native_vector_artifact_pages(self)
85    }
86
87    fn inspect_native_vector_artifact(
88        &self,
89        collection: &str,
90        artifact_kind: Option<&str>,
91    ) -> RedDBResult<NativeVectorArtifactInspection> {
92        RedDBRuntime::inspect_native_vector_artifact(self, collection, artifact_kind)
93    }
94
95    fn warmup_native_vector_artifact(
96        &self,
97        collection: &str,
98        artifact_kind: Option<&str>,
99    ) -> RedDBResult<NativeVectorArtifactInspection> {
100        RedDBRuntime::warmup_native_vector_artifact(self, collection, artifact_kind)
101    }
102
103    fn inspect_native_vector_artifacts(&self) -> RedDBResult<NativeVectorArtifactBatchInspection> {
104        RedDBRuntime::inspect_native_vector_artifacts(self)
105    }
106
107    fn warmup_native_vector_artifacts(&self) -> RedDBResult<NativeVectorArtifactBatchInspection> {
108        RedDBRuntime::warmup_native_vector_artifacts(self)
109    }
110
111    fn native_header_repair_policy(&self) -> RedDBResult<String> {
112        RedDBRuntime::native_header_repair_policy(self)
113    }
114
115    fn repair_native_header_from_metadata(&self) -> RedDBResult<String> {
116        RedDBRuntime::repair_native_header_from_metadata(self)
117    }
118
119    fn rebuild_physical_metadata_from_native_state(&self) -> RedDBResult<bool> {
120        RedDBRuntime::rebuild_physical_metadata_from_native_state(self)
121    }
122
123    fn repair_native_physical_state_from_metadata(&self) -> RedDBResult<bool> {
124        RedDBRuntime::repair_native_physical_state_from_metadata(self)
125    }
126
127    fn native_metadata_state_summary(&self) -> RedDBResult<NativeMetadataStateSummary> {
128        RedDBRuntime::native_metadata_state_summary(self)
129    }
130
131    fn physical_authority_status(&self) -> PhysicalAuthorityStatus {
132        RedDBRuntime::physical_authority_status(self)
133    }
134
135    fn readiness_for_query(&self) -> bool {
136        RedDBRuntime::readiness_for_query(self)
137    }
138
139    fn readiness_for_query_serverless(&self) -> bool {
140        RedDBRuntime::readiness_for_query_serverless(self)
141    }
142
143    fn readiness_for_write(&self) -> bool {
144        RedDBRuntime::readiness_for_write(self)
145    }
146
147    fn readiness_for_write_serverless(&self) -> bool {
148        RedDBRuntime::readiness_for_write_serverless(self)
149    }
150
151    fn readiness_for_repair(&self) -> bool {
152        RedDBRuntime::readiness_for_repair(self)
153    }
154
155    fn readiness_for_repair_serverless(&self) -> bool {
156        RedDBRuntime::readiness_for_repair_serverless(self)
157    }
158}
reddb_server/application/ports_impls_native.rs

reddb_server/application/
ports_impls_native.rs
