Struct starchart::master::Master

pub struct Master {
    sites: BTreeMap<String, (Option<()>, Addr<Counter>)>,
    gc: u64,
}

This Actor manages the Counter actors. A service can have several Counter actors with varying [Defense][crate::defense::Defense] configurations so a “master” actor is needed to manage them all

Fields

sites: BTreeMap<String, (Option<()>, Addr<Counter>)>

gc: u64

Implementations

impl Master

pub fn add_site(&mut self, addr: Addr<Counter>, id: String)

add Counter actor to Master

pub fn new(gc: u64) -> Self

create new master accepts a u64 to configure garbage collection period

pub fn get_site(&mut self, id: &str) -> Option<Addr<Counter>>

get Counter actor from Master

pub fn rm_site(&mut self, id: &str) -> Option<(Option<()>, Addr<Counter>)>

remvoes Counter actor from Master

pub fn rename(&mut self, msg: Rename)

renames Counter actor

Trait Implementations

impl Actor for Master

type Context = Context<Master>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

fn start(self) -> Addr<Self>where
    Self: Actor<Context = Context<Self>>,

Start a new asynchronous actor, returning its address.

fn start_default() -> Addr<Self>where
    Self: Actor<Context = Context<Self>> + Default,

Construct and start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>where
    Self: Actor<Context = Context<Self>>,
    F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn create<F>(f: F) -> Addr<Self>where
    Self: Actor<Context = Context<Self>>,
    F: FnOnce(&mut Context<Self>) -> Self,

Start a new asynchronous actor given a Context.

impl Clone for Master

fn clone(&self) -> Master

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for Master

fn default() -> Master

Returns the “default value” for a type.

impl Handler<AddCounter> for Master

type Result = MessageResult<AddCounter>

The type of value that this handler will return.

fn handle(&mut self, m: AddCounter, _ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<AddSearchMaster> for Master

type Result = MessageResult<AddSearchMaster>

The type of value that this handler will return.

fn handle(&mut self, m: AddSearchMaster, ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<CleanUp> for Master

type Result = ()

The type of value that this handler will return.

fn handle(&mut self, _: CleanUp, ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetSite> for Master

type Result = MessageResult<GetSite>

The type of value that this handler will return.

fn handle(&mut self, m: GetSite, _ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<RemoveCounter> for Master

type Result = MessageResult<RemoveCounter>

The type of value that this handler will return.

fn handle(&mut self, m: RemoveCounter, ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

impl Handler<Rename> for Master

type Result = MessageResult<Rename>

The type of value that this handler will return.

fn handle(&mut self, m: Rename, _ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.