Struct SensorTopicBus 

pub struct SensorTopicBus {
    pub router: Arc<TopicRouter>,
    pub chain: SensorFrameChainIndex,
    /* private fields */
}

Kernel-side publisher: TopicRouter registration + local fan-out + ExoChain.

Subscribers attach via TopicRouter::subscribe on cluster-suffixed topic names, and/or via SensorTopicBus::subscribe_local for in-process tests.

Fields

router: Arc<TopicRouter>

Topic router for subscriber registration.

chain: SensorFrameChainIndex

ExoChain stand-in index.

Implementations

impl SensorTopicBus

pub fn new() -> Self

Construct a bus with a fresh process table for the topic router.

pub fn with_router(router: Arc<TopicRouter>) -> Self

Construct around an existing topic router (kernel boot path).

pub fn register_well_known_topics(&self)

Register the three base topics on the router for discovery.

TopicRouter is lazy (entries appear on subscribe). We touch each base topic with a sentinel subscribe/unsubscribe so list_topics can see them once real subscribers attach; the constants remain the source of truth either way.

pub fn well_known_topics(&self) -> &'static [&'static str]

Well-known topic names (always three).

pub fn subscribe_pid( &self, pid: Pid, topic: MeshSensorTopic, cluster: Option<&str>, )

Subscribe a process to a sensor topic (with optional cluster suffix).

pub fn subscribe_local(&mut self, topic: &str)

Local test subscriber: buffers published payloads for a topic.

pub fn drain_local(&mut self, topic: &str) -> Vec<Vec<u8>>

Drain local subscriber buffer for a topic.

pub fn publish( &mut self, env: SensorMeshEnvelope, ) -> Result<SensorPublishResult, String>

Publish a sensor envelope: mesh frame encode check, local fan-out, TopicRouter subscriber count, ExoChain index.

pub fn last_payload(&self, topic: &str) -> Option<&[u8]>

Last payload for a topic (if any).

Trait Implementations

impl Default for SensorTopicBus

fn default() -> Self

Returns the “default value” for a type.