[−][src]Struct arcon::streaming::task::manager::Manager
The Manager handles metrics from
each StreamTask. It is supposed to send
off the metrics to Arcon's operational plane
,but it may also on instruction alter the
current running StreamTasks
Methods
impl Manager[src]
Trait Implementations
impl ComponentDefinition for Manager[src]
fn setup(&mut self, self_component: Arc<Component<Self>>)[src]
fn execute(&mut self, max_events: usize, skip: usize) -> ExecuteResult[src]
fn ctx_mut(&mut self) -> &mut ComponentContext<Self>[src]
fn ctx(&self) -> &ComponentContext<Self>[src]
fn type_name() -> &'static str[src]
impl Provide<ControlPort> for Manager[src]
fn handle(&mut self, event: ControlEvent)[src]
impl Provide<MetricPort> for Manager[src]
impl Actor for Manager[src]
fn receive_local(&mut self, _sender: ActorRef, _msg: &dyn Any)[src]
fn receive_message(
&mut self,
_sender: ActorPath,
_ser_id: u64,
_buf: &mut dyn Buf
)[src]
&mut self,
_sender: ActorPath,
_ser_id: u64,
_buf: &mut dyn Buf
)
Auto Trait Implementations
impl Send for Manager
impl Unpin for Manager
impl !Sync for Manager
impl !UnwindSafe for Manager
impl !RefUnwindSafe for Manager
Blanket Implementations
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Erased for T
impl<T> Deserialisable<T> for T[src]
impl<A> ExecuteSend for A where
A: ActorRaw, [src]
A: ActorRaw,
fn execute_send(&mut self, env: DispatchEnvelope)[src]
impl<D> ExecuteSend for D where
D: ActorRaw + Dispatcher, [src]
D: ActorRaw + Dispatcher,
fn execute_send(&mut self, env: DispatchEnvelope)[src]
impl<CD> ActorRaw for CD where
CD: Actor, [src]
CD: Actor,
fn receive(&mut self, env: ReceiveEnvelope)[src]
impl<CD> ActorRefFactory for CD where
CD: ComponentDefinition + 'static, [src]
CD: ComponentDefinition + 'static,
impl<CD> Dispatching for CD where
CD: ComponentDefinition + 'static, [src]
CD: ComponentDefinition + 'static,
fn dispatcher_ref(&self) -> ActorRef[src]
impl<CD> ActorSource for CD where
CD: ComponentDefinition + 'static, [src]
CD: ComponentDefinition + 'static,
fn path_resolvable(&self) -> PathResolvable[src]
impl<CD> Timer<CD> for CD where
CD: ComponentDefinition + 'static, [src]
CD: ComponentDefinition + 'static,
fn schedule_once<F>(&mut self, timeout: Duration, action: F) -> ScheduledTimer where
F: FnOnce(&mut CD, Uuid) + Send + 'static, [src]
F: FnOnce(&mut CD, Uuid) + Send + 'static,
fn schedule_periodic<F>(
&mut self,
delay: Duration,
period: Duration,
action: F
) -> ScheduledTimer where
F: Fn(&mut CD, Uuid) + Send + 'static, [src]
&mut self,
delay: Duration,
period: Duration,
action: F
) -> ScheduledTimer where
F: Fn(&mut CD, Uuid) + Send + 'static,