Struct NotificationChannel

pub struct NotificationChannel { /* private fields */ }

Notification channel.

The notification channel allows one thread to notify another that the other thread has some work to do. The notification carries no other information: the receiver is supposed to know where it can get whatever data it needs to what it needs to do.

The point of this is to make sure threads in the CI broker exchange data only via the database, where it is persistent.

Implementations

impl NotificationChannel

pub fn new_event() -> Self

Construct a channel for notifying about new events.

pub fn new_run() -> Self

Construct a channel for notifying about new CI runs.

impl NotificationChannel

pub fn tx(&mut self) -> Result<NotificationSender, NotificationError>

Return the transmit endpoint of the notification channel. This can only be called once.

pub fn rx(&mut self) -> Result<NotificationReceiver, NotificationError>

Return the receive endpoint of the notification channel. This can only be called once.