Skip to main content

WorkerProperties

autoagents_core::ractor::factory

Struct WorkerProperties 

Source 
pub struct WorkerProperties<TKey, TMsg>
where
    TKey: JobKey,
    TMsg: Message,
{ /* private fields */ }
Expand description

Properties of a worker

Implementations§

Source§

impl<TKey, TMsg> WorkerProperties<TKey, TMsg>
where TKey: JobKey, TMsg: Message,

Source

pub fn is_processing_key(&self, key: &TKey) -> bool

Identifies if a worker is processing a specific job key

Returns true if the worker is currently processing the given key

Source

pub fn is_available(&self) -> bool

Identify if the worker is available for enqueueing work

Source

pub fn is_working(&self) -> bool

Identify if the worker is currently processing any requests

Source

pub fn enqueue_job( &mut self, job: Job<TKey, TMsg>, ) -> Result<(), Box<MessagingErr<WorkerMessage<TKey, TMsg>>>>

Enqueue a new job to this worker. If the discard threshold has been exceeded it will discard the oldest or newest elements from the message queue (based on discard semantics)

Trait Implementations§

Source§

impl<TKey, TMsg> Debug for WorkerProperties<TKey, TMsg>
where TKey: JobKey, TMsg: Message,

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<TKey, TMsg> Freeze for WorkerProperties<TKey, TMsg>

§

impl<TKey, TMsg> !RefUnwindSafe for WorkerProperties<TKey, TMsg>

§

impl<TKey, TMsg> Send for WorkerProperties<TKey, TMsg>

§

impl<TKey, TMsg> Sync for WorkerProperties<TKey, TMsg>
where TMsg: Sync,

§

impl<TKey, TMsg> Unpin for WorkerProperties<TKey, TMsg>
where TKey: Unpin, TMsg: Unpin,

§

impl<TKey, TMsg> UnsafeUnpin for WorkerProperties<TKey, TMsg>

§

impl<TKey, TMsg> !UnwindSafe for WorkerProperties<TKey, TMsg>

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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 more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

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
Source§

impl<T> Message for T
where T: Any + Send + 'static,

Source§

fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>

Convert a BoxedMessage to this concrete type
Source§

fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>

Convert this message to a BoxedMessage
Source§

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

Source§

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

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

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

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

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

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> State for T
where T: Any + Send + 'static,