radicle_ci_broker::broker

Struct Broker

Source
pub struct Broker { /* private fields */ }
Expand description

A CI broker.

The broker gets repository change events from the local Radicle node, and executes the appropriate adapter to run CI on the repository.

Implementations§

Source§

impl Broker

Source

pub fn new( db_filename: &Path, max_run_time: Duration, ) -> Result<Self, BrokerError>

Source

pub fn all_runs(&mut self) -> Result<Vec<Run>, BrokerError>

Source

pub fn set_default_adapter(&mut self, adapter: &Adapter)

Source

pub fn default_adapter(&self) -> Option<&Adapter>

Source

pub fn set_repository_adapter(&mut self, rid: &RepoId, adapter: &Adapter)

Source

pub fn adapter(&self, rid: &RepoId) -> Option<&Adapter>

Source

pub fn execute_ci( &mut self, trigger: &Request, run_notification: &NotificationSender, ) -> Result<Run, BrokerError>

Auto Trait Implementations§

§

impl Freeze for Broker

§

impl !RefUnwindSafe for Broker

§

impl Send for Broker

§

impl !Sync for Broker

§

impl Unpin for Broker

§

impl !UnwindSafe for Broker

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T