Struct CapabilityServices

Source

pub struct CapabilityServices {
    pub tenant: Option<String>,
    pub kv: Option<Arc<dyn KvStore>>,
    pub http: Option<Arc<dyn OutboundHttp>>,
    pub db: Option<Arc<dyn PluginStore>>,
    pub jobs: Option<Arc<dyn JobSink>>,
    pub rate: Option<Arc<CapabilityRateLimiter>>,
}

Expand description

The backends a host will honour a capability against.

Deliberately not #[non_exhaustive], unlike the types in this module that the host produces and a caller only reads: this one is built by the embedder, and CapabilityServices { kv: …, ..CapabilityServices::none() } is how. Marking it would make that spelling impossible outside this crate, which is the only spelling there is.

Every field is optional, and a missing one is not a hole: a call whose backend is absent is denied DenialReason::Unavailable and recorded, the same as any other refusal. That is what lets SandboxHost::run — which has no application state at all — keep working unchanged, and what lets a test exercise one capability without standing up the other four.

Fields§

§tenant: Option<String>

The tenant every scoped capability binds to.

None is the single-tenant application: keys and rows land in a namespace of their own rather than in some other tenant’s.

§kv: Option<Arc<dyn KvStore>>

Backing store for kv.

§http: Option<Arc<dyn OutboundHttp>>

Client for http-outbound.

§db: Option<Arc<dyn PluginStore>>

Store for db.

§jobs: Option<Arc<dyn JobSink>>

Queue for jobs.

§rate: Option<Arc<CapabilityRateLimiter>>

The plugin’s own calls-per-second ceiling, shared across its requests.

None leaves only the per-request counters, which is the right default for a direct SandboxHost::run caller: a rate ceiling with no shared state is a ceiling that resets every call, which is worse than saying it is not there. SandboxedPlugin builds one per plugin.

Struct CapabilityServices Copy item path

Fields§

Implementations§

impl CapabilityServices

pub fn none() -> Self

pub fn for_tenant(self, tenant: impl Into<String>) -> Self

Trait Implementations§

impl Clone for CapabilityServices

fn clone(&self) -> Self

fn clone_from(&mut self, source: &Self)

impl Debug for CapabilityServices

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

impl Default for CapabilityServices

fn default() -> Self

Auto Trait Implementations§

impl !RefUnwindSafe for CapabilityServices

impl !UnwindSafe for CapabilityServices

impl Freeze for CapabilityServices

impl Send for CapabilityServices

impl Sync for CapabilityServices

impl Unpin for CapabilityServices

impl UnsafeUnpin for CapabilityServices

Blanket Implementations§

impl<T> AggregateExpressionMethods for T

fn aggregate_distinct(self) -> Self::Outputwhere Self: DistinctDsl,

fn aggregate_all(self) -> Self::Outputwhere Self: AllDsl,

fn aggregate_filter<P>(self, f: P) -> Self::Outputwhere P: AsExpression<Bool>, Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,

fn aggregate_order<O>(self, o: O) -> Self::Outputwhere Self: OrderAggregateDsl<O>,

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> AutumnCounterCaches for Twhere T: 'static,

const HAS_COUNTER_CACHES: bool = false

fn counter_caches() -> &'static [CounterCacheSpec<Self>]

impl<T> AutumnDependents for Twhere T: ?Sized,

fn dependents() -> &'static [RuntimeDependentSpec]

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> Downcast for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> Downcast for Twhere T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> DowncastSend for Twhere T: Any + Send,

fn into_any_send(self: Box<T>) -> Box<dyn Any + Send>

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

fn into_any_sync(self: Box<T>) -> Box<dyn Any + Send + Sync>

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync> ⓘ

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoSql for T

fn into_sql<T>(self) -> Self::Expressionwhere Self: Sized + AsExpression<T>, T: SqlType + TypedExpressionType,

fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expressionwhere &'a Self: AsExpression<T>, T: SqlType + TypedExpressionType,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

Struct CapabilityServices

fn aggregate_distinct(self) -> Self::Output
where Self: DistinctDsl,

fn aggregate_all(self) -> Self::Output
where Self: AllDsl,

fn aggregate_filter<P>(self, f: P) -> Self::Output
where P: AsExpression<Bool>, Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,

fn aggregate_order<O>(self, o: O) -> Self::Output
where Self: OrderAggregateDsl<O>,

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> AutumnCounterCaches for T
where T: 'static,

impl<T> AutumnDependents for T
where T: ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> Downcast for T
where T: Any,

impl<T> Downcast for T
where T: Any,

impl<T> DowncastSend for T
where T: Any + Send,

impl<T> DowncastSync for T
where T: Any + Send + Sync,

impl<T> DowncastSync for T
where T: Any + Send + Sync,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_sql<T>(self) -> Self::Expression
where Self: Sized + AsExpression<T>, T: SqlType + TypedExpressionType,

fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression
where &'a Self: AsExpression<T>, T: SqlType + TypedExpressionType,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> RepositoryHooksClone for T
where T: Clone,

impl<T> RepositoryHooksDefault for T
where T: Default,

fn execute<'conn, 'query>( self, conn: &'conn mut Conn, ) -> <Conn as AsyncConnectionCore>::ExecuteFuture<'conn, 'query>
where Conn: AsyncConnectionCore + Send, Self: ExecuteDsl<Conn> + 'query,

fn load<'query, 'conn, U>( self, conn: &'conn mut Conn, ) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>>
where U: Send, Conn: AsyncConnectionCore, Self: LoadQuery<'query, Conn, U> + 'query,

fn load_stream<'conn, 'query, U>( self, conn: &'conn mut Conn, ) -> Self::LoadFuture<'conn>
where Conn: AsyncConnectionCore, U: 'conn, Self: LoadQuery<'query, Conn, U> + 'query,

fn get_result<'query, 'conn, U>( self, conn: &'conn mut Conn, ) -> AndThen<Self::LoadFuture<'conn>, LoadNext<Pin<Box<Self::Stream<'conn>>>>>
where U: Send + 'conn, Conn: AsyncConnectionCore, Self: LoadQuery<'query, Conn, U> + 'query,

fn get_results<'query, 'conn, U>( self, conn: &'conn mut Conn, ) -> AndThen<Self::LoadFuture<'conn>, TryCollect<Self::Stream<'conn>, Vec<U>>>
where U: Send, Conn: AsyncConnectionCore, Self: LoadQuery<'query, Conn, U> + 'query,

impl<T> Scoped for T
where T: Send + Sync + 'static,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn over(self) -> Self::Output
where Self: OverDsl,

fn window_filter<P>(self, f: P) -> Self::Output
where P: AsExpression<Bool>, Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,

fn partition_by<E>(self, expr: E) -> Self::Output
where Self: PartitionByDsl<E>,

fn window_order<E>(self, expr: E) -> Self::Output
where Self: OrderWindowDsl<E>,

fn frame_by<E>(self, expr: E) -> Self::Output
where Self: FrameDsl<E>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,