pub struct JobRegistryHandle { /* private fields */ }Expand description
Cloneable in-process handle to the registry actor.
Implementations§
Source§impl JobRegistryHandle
impl JobRegistryHandle
pub fn submit(&self, spec: JobSpec) -> AgentResult<JobStatus>
pub fn start(&self, name: impl Into<String>) -> AgentResult<JobStatus>
pub fn restart(&self, name: impl Into<String>) -> AgentResult<JobStatus>
pub fn drain(&self, name: impl Into<String>) -> AgentResult<JobStatus>
pub fn stop(&self, name: impl Into<String>) -> AgentResult<JobStatus>
pub fn status(&self, name: impl Into<String>) -> AgentResult<JobStatus>
pub fn list(&self) -> AgentResult<Vec<JobStatus>>
pub fn events(&self) -> Source<JobEvent>
pub fn shutdown(&self) -> AgentResult<()>
Trait Implementations§
Source§impl Clone for JobRegistryHandle
impl Clone for JobRegistryHandle
Source§fn clone(&self) -> JobRegistryHandle
fn clone(&self) -> JobRegistryHandle
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for JobRegistryHandle
impl RefUnwindSafe for JobRegistryHandle
impl Send for JobRegistryHandle
impl Sync for JobRegistryHandle
impl Unpin for JobRegistryHandle
impl UnsafeUnpin for JobRegistryHandle
impl UnwindSafe for JobRegistryHandle
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
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,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
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>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage