pub struct Service<N> { /* private fields */ }Expand description
Factory-only operator extension. Production adapters remain disabled until PR2.
Implementations§
Source§impl<N: NamespaceStore + Clone> Service<N>
impl<N: NamespaceStore + Clone> Service<N>
Sourcepub fn new(store: N, root: Partition, shards: Arc<dyn ShardMap>) -> Self
pub fn new(store: N, root: Partition, shards: Arc<dyn ShardMap>) -> Self
Construct the inert intent extension over durable operator metadata.
Sourcepub fn with_purge(self, purge: Option<PurgeConfig>) -> Self
pub fn with_purge(self, purge: Option<PurgeConfig>) -> Self
Attach configured automatic cache invalidation for accepted actions.
Sourcepub async fn resume(
&self,
id: Hash,
now: u64,
request_budget: &SliceBudget,
) -> Result<(), ServerError>
pub async fn resume( &self, id: Hash, now: u64, request_budget: &SliceBudget, ) -> Result<(), ServerError>
Resume bounded denial activation; the preservation timer remains owned by PR2.
§Errors
Missing/corrupt accepted work, unavailable storage or exhausted call budget.
Trait Implementations§
Source§impl<N: NamespaceStore + Clone> AdminOperations for Service<N>
impl<N: NamespaceStore + Clone> AdminOperations for Service<N>
Source§fn plan<'a>(
&'a self,
path: &'a str,
input: &'a Json,
digest: &'a str,
now: u64,
request_budget: &'a SliceBudget,
) -> BoxFuture<'a, Result<Prepared, ServerError>>
fn plan<'a>( &'a self, path: &'a str, input: &'a Json, digest: &'a str, now: u64, request_budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<Prepared, ServerError>>
Prepare root effects after staging immutable action metadata; no denial is activated here.
Source§fn after_commit<'a>(
&'a self,
path: &'a str,
_input: &'a Json,
response: Response,
now: u64,
request_budget: &'a SliceBudget,
) -> BoxFuture<'a, Result<Response, ServerError>>
fn after_commit<'a>( &'a self, path: &'a str, _input: &'a Json, response: Response, now: u64, request_budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<Response, ServerError>>
Resume accepted denial activation from durable validated metadata.
Called on nonce and operation replay as well as first acceptance.
Source§fn preserved_now_ms(&self) -> Result<i64, ServerError>
fn preserved_now_ms(&self) -> Result<i64, ServerError>
Backend time for terminal preserved-stream failure audits.
Source§fn preserved_piece<'a>(
&'a self,
_descriptor: &'a Value,
) -> BoxFuture<'a, Result<PreservedPiece, ServerError>>
fn preserved_piece<'a>( &'a self, _descriptor: &'a Value, ) -> BoxFuture<'a, Result<PreservedPiece, ServerError>>
Read one bounded, freshly authorized and verified preservation piece.
The input is a byte-free descriptor; implementations recheck live retention.
Auto Trait Implementations§
impl<N> !RefUnwindSafe for Service<N>
impl<N> !UnwindSafe for Service<N>
impl<N> Freeze for Service<N>where
N: Freeze,
impl<N> Send for Service<N>where
N: Send,
impl<N> Sync for Service<N>where
N: Sync,
impl<N> Unpin for Service<N>where
N: Unpin,
impl<N> UnsafeUnpin for Service<N>where
N: UnsafeUnpin,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more