Struct StateMachineBuilder 

pub struct StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH>
where
    PE: PolicyEngine,
    HR: HttpRequest,
    IN: Installer,
    TM: Timer,
    MR: MetricsReporter,
    ST: Storage,
    AS: AppSet,
    CH: Cupv2Handler,
{ /* private fields */ }

Helper type to build/start a StateMachine.

Implementations

impl<PE, HR, IN, TM, MR, ST, AS, CH> StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH>

where PE: PolicyEngine, HR: HttpRequest, IN: Installer, TM: Timer, MR: MetricsReporter, ST: Storage, AS: AppSet, CH: Cupv2Handler,

pub fn new( policy_engine: PE, http: HR, installer: IN, timer: TM, metrics_reporter: MR, storage: Rc<Mutex<ST>>, config: Config, app_set: Rc<Mutex<AS>>, cup_handler: Option<CH>, ) -> Self

Creates a new StateMachineBuilder using the given trait implementations.

impl<PE, HR, IN, TM, MR, ST, AS, CH> StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH>

where PE: PolicyEngine, HR: HttpRequest, IN: Installer, TM: Timer, MR: MetricsReporter, ST: Storage, AS: AppSet, CH: Cupv2Handler,

pub fn policy_engine<PE2: PolicyEngine>( self, policy_engine: PE2, ) -> StateMachineBuilder<PE2, HR, IN, TM, MR, ST, AS, CH>

Configures the state machine to use the provided policy_engine implementation.

pub fn http<HR2: HttpRequest>( self, http: HR2, ) -> StateMachineBuilder<PE, HR2, IN, TM, MR, ST, AS, CH>

Configures the state machine to use the provided http implementation.

pub fn installer<IN2: Installer>( self, installer: IN2, ) -> StateMachineBuilder<PE, HR, IN2, TM, MR, ST, AS, CH>

Configures the state machine to use the provided installer implementation.

pub fn timer<TM2: Timer>( self, timer: TM2, ) -> StateMachineBuilder<PE, HR, IN, TM2, MR, ST, AS, CH>

Configures the state machine to use the provided timer implementation.

pub fn metrics_reporter<MR2: MetricsReporter>( self, metrics_reporter: MR2, ) -> StateMachineBuilder<PE, HR, IN, TM, MR2, ST, AS, CH>

Configures the state machine to use the provided metrics_reporter implementation.

pub fn storage<ST2: Storage>( self, storage: Rc<Mutex<ST2>>, ) -> StateMachineBuilder<PE, HR, IN, TM, MR, ST2, AS, CH>

Configures the state machine to use the provided storage implementation.

pub fn config(self, config: Config) -> Self

Configures the state machine to use the provided config.

pub fn app_set<AS2: AppSet>( self, app_set: Rc<Mutex<AS2>>, ) -> StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS2, CH>

Configures the state machine to use the provided app_set implementation.

pub fn cup_handler<CH2: Cupv2Handler>( self, cup_handler: Option<CH2>, ) -> StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH2>

impl<'a, PE, HR, IN, TM, MR, ST, AS, CH, IR, PL> StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH>

where PE: 'a + PolicyEngine<InstallResult = IR, InstallPlan = PL>, HR: 'a + HttpRequest, IN: 'a + Installer<InstallResult = IR, InstallPlan = PL>, TM: 'a + Timer, MR: 'a + MetricsReporter, ST: 'a + Storage, AS: 'a + AppSet, CH: 'a + Cupv2Handler, IR: 'static + Send, PL: 'a + Plan,

pub async fn build(self) -> StateMachine<PE, HR, IN, TM, MR, ST, AS, CH>

pub async fn start( self, ) -> (ControlHandle, impl Stream<Item = StateMachineEvent> + 'a)

Start the StateMachine to do periodic update checks in the background or when requested through the returned control handle. The returned stream must be polled to make forward progress.

pub async fn oneshot_check(self) -> impl Stream<Item = StateMachineEvent> + 'a

Run start_upate_check once, returning a stream of the states it produces.

Trait Implementations

impl<PE, HR, IN, TM, MR, ST, AS, CH> Debug for StateMachineBuilder<PE, HR, IN, TM, MR, ST, AS, CH>

where PE: PolicyEngine + Debug, HR: HttpRequest + Debug, IN: Installer + Debug, TM: Timer + Debug, MR: MetricsReporter + Debug, ST: Storage + Debug, AS: AppSet + Debug, CH: Cupv2Handler + Debug,

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

Formats the value using the given formatter.