Struct ConfigLoader

pub struct ConfigLoader { /* private fields */ }

Implementations

impl ConfigLoader

pub fn new() -> Self

Trait Implementations

impl Agent for ConfigLoader

type Context = AgentSession<ConfigLoader>

fn begin(&mut self) -> Next<Self>

fn interrupt(&mut self, ctx: &mut Context<Self>)

fn initialize(&mut self, _ctx: &mut Context<Self>) -> Next<Self>

fn event<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

fn failed(&mut self, err: &Error, _ctx: &mut Context<Self>)

impl ManageSubscription<ConfigUpdates> for ConfigLoader

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 mut self, sub_id: UniqueId<ConfigUpdates>, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 mut self, sub_id: UniqueId<ConfigUpdates>, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Subscribe<S>, ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

impl OnEvent<()> for ConfigLoader

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, __arg1: (), _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fallback<'life0, 'life1, 'async_trait>( &'life0 mut self, err: Error, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

impl OnEvent<StoreTemplate> for ConfigLoader

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: StoreTemplate, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fallback<'life0, 'life1, 'async_trait>( &'life0 mut self, err: Error, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,