Struct Control
pub struct Control(/* private fields */);Available on crate features
http and inspect and std only.Implementations§
§impl Control
impl Control
pub fn new(recording: InspectionState) -> Control
pub fn is_active(&self) -> bool
pub fn subscribe(&self) -> impl Stream<Item = Snapshot> + Send + 'static
pub fn subscribe(&self) -> impl Stream<Item = Snapshot> + Send + 'static
Subscribe to initial and updated control content from a native UI or API.
pub fn subscribe_changes(&self) -> Receiver<u64>
pub fn pending_summaries(&self) -> Vec<PendingSummary>
pub fn snapshot(&self) -> Snapshot
pub fn configure( &self, revision: u64, config: Config, ) -> Result<(), Box<dyn Error + Send + Sync>>
pub fn observe( &self, connection: &ControlConnection, host: &Host, inspected: bool, source: &str, reason: &str, )
pub fn stop_and_forward(&self)
pub fn apply_rule( &self, index: usize, revision: u64, ) -> Result<(), Box<dyn Error + Send + Sync>>
pub fn clear_hosts(&self)
pub fn resume_connection(&self, id: u64)
pub fn pending(&self, id: u64) -> Option<Arc<Message>>
pub fn resolve( &self, id: u64, decision: Decision, ) -> Result<(), Box<dyn Error + Send + Sync>>
pub async fn decide( &self, connection: &ControlConnection, message: Message, ) -> (Decision, Option<String>)
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Control
impl !UnwindSafe for Control
impl Freeze for Control
impl Send for Control
impl Sync for Control
impl Unpin for Control
impl UnsafeUnpin for Control
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more