Struct Engine 

pub struct Engine<S> { /* private fields */ }

Durable admin service over one deployment-wide metadata partition.

Implementations

impl<S: NamespaceStore + 'static> Engine<S>

pub async fn handle_streamed( self: Arc<Self>, path: &str, headers: &Headers, wire: &BodyCapture, decoded: Option<Result<Vec<u8>, ServerError>>, now_ms: i64, ) -> Reply

Dispatch signed bytes and return a bounded verified stream for ReadPreserved. Adapters must send streaming responses with Cache-Control: no-store.

impl<S: NamespaceStore> Engine<S>

pub fn new(store: S, partition: Partition, config: Config) -> Self

Build the signed audit export framework.

pub fn with_purge(self, enabled: bool) -> Self

Enable manual acceptance only when a real purge interface is configured.

pub fn with_operations(self, operations: Arc<dyn AdminOperations>) -> Self

Attach the opt-in takedown catalog.

pub async fn handle( &self, path: &str, headers: &Headers, body: &BodyCapture, now_ms: i64, ) -> Response

Dispatch exact signed bytes. Adapters must reject decompression errors through decoded after authentication, preserving authenticated audit.

pub async fn handle_decoded( &self, path: &str, headers: &Headers, wire: &BodyCapture, decoded: Option<Result<Vec<u8>, ServerError>>, now_ms: i64, ) -> Response

Dispatch with separately decompressed request bytes; the signature always covers wire. An error is recorded only after identity verification.

Trait Implementations

impl<S> Debug for Engine<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.