Struct ViewerService 

pub struct ViewerService {
    data_dir: Option<PathBuf>,
    tls: Mutex<Option<Arc<ViewerTls>>>,
    pub pairing: Pairing,
    pub hub: Arc<FeedHub>,
    feeds: Arc<Mutex<FeedRegistry>>,
    max_per_device: usize,
    max_total: usize,
    advertised_port: Arc<AtomicU16>,
    bound: Mutex<Vec<IpAddr>>,
    reservation: Mutex<Option<(u16, Socket)>>,
    last_seen_written: Mutex<HashMap<String, i64>>,
}

Fields

data_dir: Option<PathBuf>

Where the certificate is kept; None keeps it in memory only.

tls: Mutex<Option<Arc<ViewerTls>>>

pairing: Pairing

hub: Arc<FeedHub>

feeds: Arc<Mutex<FeedRegistry>>

max_per_device: usize

max_total: usize

advertised_port: Arc<AtomicU16>

0 while no viewer listener is bound.

bound: Mutex<Vec<IpAddr>>

The addresses viewer listeners are bound on, for the QR’s host.

reservation: Mutex<Option<(u16, Socket)>>

The viewer port, held on loopback (bound, never listening) from the first time the listener comes up until exit, so another instance on this host never takes it from the range and the port a device saw stays ours across LAN off/on.

last_seen_written: Mutex<HashMap<String, i64>>

When each device’s last_seen_ms was last written.

Implementations

impl ViewerService

pub fn new(data_dir: Option<PathBuf>, broker: &Broker) -> Arc<Self>

A viewer whose feeds watch broker.

pub fn with_limits( data_dir: Option<PathBuf>, broker: &Broker, hub: Arc<FeedHub>, max_per_device: usize, max_total: usize, ) -> Arc<Self>

pub fn install_global(&self)

Make this the process’s advertised viewer port (advertised_viewer_port).

pub fn advertised_port_handle(&self) -> Arc<AtomicU16>

The handle the fleet feed reads viewer_port from.

pub fn advertised_port(&self) -> Option<u16>

pub fn tls(&self) -> Result<Arc<ViewerTls>, String>

The certificate, made and kept on first need.

pub fn reserve_port( &self, candidates: impl IntoIterator<Item = u16>, ) -> Option<u16>

The viewer port: the one already held, else the first port of candidates free on loopback, now held. None when none is free.

pub fn set_bound(&self, addrs: Vec<IpAddr>, port: u16)

Record which addresses viewer listeners are bound on, and advertise the port while there is at least one.

pub fn pair_host(&self) -> Option<IpAddr>

The IPv4 address the QR names: the primary outbound one when a viewer listener is bound there, else the first bound IPv4 address.

pub fn open_feed(&self, device_id: &str) -> Result<FeedLease, FeedRefused>

Take a place for one more feed of device_id, or say why not.

pub fn close_device_feeds(&self, device_id: &str) -> usize

Close every open feed of device_id (it was revoked). Returns how many.

pub fn last_seen_due(&self, device_id: &str, now_ms: i64) -> bool

Whether device_id’s last_seen_ms is due to be written at now_ms; records it when it is.

pub fn forget_device(&self, device_id: &str)

Forget a revoked device’s throttle entry.