Struct ChannelSource 

pub struct ChannelSource { /* private fields */ }

A data source that receives monitor snapshots via a channel.

This source is designed for integration with message bus systems. The producer (e.g., a message bus subscriber) sends snapshots through the channel, and this source provides them to the TUI.

Example

use buswatch_tui::ChannelSource;

// Create a channel pair
let (tx, source) = ChannelSource::create("rabbitmq://localhost");

Implementations

impl ChannelSource

pub fn new(receiver: Receiver<Snapshot>, source_description: &str) -> Self

Create a new channel source.

Arguments

• receiver - The receiving end of a watch channel
• source_description - A description of where snapshots come from (e.g., “rabbitmq://localhost”, “nats://broker:4222”)

pub fn create(source_description: &str) -> (Sender<Snapshot>, Self)

Create a channel pair for sending snapshots to a ChannelSource.

Returns (sender, source) where the sender can be used to push snapshots and the source can be used with the Doctor TUI.

Trait Implementations

impl DataSource for ChannelSource

fn poll(&mut self) -> Option<Snapshot>

Poll for the latest snapshot.

fn description(&self) -> &str

Returns a human-readable description of the source.

fn error(&self) -> Option<&str>

Check if the source has encountered an error.

impl Debug for ChannelSource

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

Formats the value using the given formatter.