Struct FleetSource 

pub struct FleetSource {
    agents: Box<dyn Fn() -> Vec<(String, String)> + Send + Sync>,
    kind_of_block: Box<dyn Fn(&str) -> Option<&'static str> + Send + Sync>,
    state_of_block: Box<dyn Fn(&str) -> Option<AgentState> + Send + Sync>,
    line_of_block: Box<dyn Fn(&str) -> Option<String> + Send + Sync>,
    since: &'static SinceTracker,
    shared_registry: Box<dyn Fn() -> Vec<AgentEntry> + Send + Sync>,
    own_channel: String,
    own_url: String,
    kinds: Mutex<HashMap<String, &'static str>>,
    channels: Mutex<Option<(Instant, u32)>>,
}

The fleet feed’s view of this instance.

Fields

agents: Box<dyn Fn() -> Vec<(String, String)> + Send + Sync>

(agent name, block id) of every reachable agent.

kind_of_block: Box<dyn Fn(&str) -> Option<&'static str> + Send + Sync>

state_of_block: Box<dyn Fn(&str) -> Option<AgentState> + Send + Sync>

The block’s state now (agent_state::current_state); read on every look, unlike the kind.

line_of_block: Box<dyn Fn(&str) -> Option<String> + Send + Sync>

The block’s summary line now (agent_line), None while sharing is off; read on every look.

since: &'static SinceTracker

When each state began; a block no longer listed is forgotten.

shared_registry: Box<dyn Fn() -> Vec<AgentEntry> + Send + Sync>

own_channel: String

own_url: String

kinds: Mutex<HashMap<String, &'static str>>

Kinds already read, by block id. A block’s agentMode is fixed when the agent is created, so each block is read once while it is listed.

channels: Mutex<Option<(Instant, u32)>>

Implementations

impl FleetSource

pub fn live( handler: &'static ReactiveHandler, mstore: Arc<Store>, config: Arc<ConfigState>, own_url: String, ) -> Self

The live source: the reactive registry, the object store, the settings and the host-global shared registry.

fn new( agents: Box<dyn Fn() -> Vec<(String, String)> + Send + Sync>, kind_of_block: Box<dyn Fn(&str) -> Option<&'static str> + Send + Sync>, state_of_block: Box<dyn Fn(&str) -> Option<AgentState> + Send + Sync>, line_of_block: Box<dyn Fn(&str) -> Option<String> + Send + Sync>, since: &'static SinceTracker, shared_registry: Box<dyn Fn() -> Vec<AgentEntry> + Send + Sync>, own_channel: String, own_url: String, ) -> Self

pub fn observe(&self) -> FleetObservation

One look. Blocking: reads the store and the registry directory.

fn channels_running(&self) -> u32