Trait subspace_farmer::cluster::nats_client::GenericBroadcast

pub trait GenericBroadcast:
    Encode
    + Decode
    + Debug
    + Send
    + Sync
    + 'static {
    const SUBJECT: &'static str;

    // Provided method
    fn deterministic_message_id(&self) -> Option<HeaderValue> { ... }
}

Generic broadcast message.

Broadcast messages are sent by an instance to (potentially) an instance-specific subject that any other app can subscribe to. The same broadcast message can also originate from multiple places and be de-duplicated using Self::deterministic_message_id.

Required Associated Constants

const SUBJECT: &'static str

Broadcast subject with optional * in place of application instance sending broadcast

Provided Methods

fn deterministic_message_id(&self) -> Option<HeaderValue>

Deterministic message ID that is used for de-duplicating messages broadcast by different instances

Object Safety

This trait is not object safe.

Implementors

impl GenericBroadcast for ClusterCacheIdentifyBroadcast

const SUBJECT: &'static str = "subspace.cache.*.identify"

impl GenericBroadcast for ClusterControllerCacheIdentifyBroadcast

const SUBJECT: &'static str = "subspace.controller.*.cache-identify"

impl GenericBroadcast for ClusterControllerFarmerIdentifyBroadcast

const SUBJECT: &'static str = "subspace.controller.farmer-identify"

impl GenericBroadcast for ClusterFarmerIdentifyFarmBroadcast

const SUBJECT: &'static str = "subspace.farmer.*.identify"