Enum TopicName

pub enum TopicName {
    NodeMessage {
        namespace: TopicNamespace,
        group_id: String,
        node_message_type: NodeMessageType,
        edge_node_id: String,
    },
    DeviceMessage {
        namespace: TopicNamespace,
        group_id: String,
        device_message_type: DeviceMessageType,
        edge_node_id: String,
        device_id: String,
    },
    StateMessage {
        scada_host_id: String,
    },
}

Rust representation of a sparkplug™ MQTT topic-name.

The TopicName can be one of three possible types:

• TopicName::NodeMessage for Edge Nodes
• TopicName::DeviceMessage for devices
• TopicName::StateMessage for SCADA applications

Examples

let node = TopicName::new_node_message(TopicNamespace::SPBV1_0,
                                       "my_group".to_string(),
                                       NodeMessageType::NBIRTH,
                                       "nodeId".to_string());
assert_eq!(node.to_string(), "spBv1.0/my_group/NBIRTH/nodeId");

let topic: TopicName = TopicName::from_str("spBv1.0/my_group/NBIRTH/nodeId").unwrap();
assert_eq!(topic, node);

let device = TopicName::new_device_message(TopicNamespace::SPBV1_0,
                                           "my_group".to_string(),
                                           DeviceMessageType::DBIRTH,
                                           "nodeId".to_string(),
                                           "deviceId".to_string());
assert_eq!(device.to_string(), "spBv1.0/my_group/DBIRTH/nodeId/deviceId");

let topic: TopicName = TopicName::from_str("spBv1.0/my_group/DBIRTH/nodeId/deviceId").unwrap();
assert_eq!(topic, device);

let state = TopicName::new_state_message("scada_host_id".to_string());
assert_eq!(state.to_string(), "STATE/scada_host_id");

let topic: TopicName = TopicName::from_str("STATE/scada_host_id").unwrap();
assert_eq!(state, topic);

Variants

NodeMessage

A message for edge-nodes

Fields

namespace: TopicNamespace

The namespace element of the Topic Namespace is the root element that will define both the structure of the remaining namespace elements as well as the encoding used for the associated payload data.

group_id: String

The group_id element of the Topic Namespace provides for a logical grouping of MQTT EoN nodes into the MQTT Server and back out to the consuming MQTT Clients.

node_message_type: NodeMessageType

The message_type element of the Topic Namespace provides an indication as to how to handle the MQTT payload of the message.

edge_node_id: String

The edge_node_id element of the Sparkplug (TM) Topic Namespace uniquely identifies the MQTT EoN node within the infrastructure.

DeviceMessage

A message for devices

Fields

namespace: TopicNamespace

The namespace element of the Topic Namespace is the root element that will define both the structure of the remaining namespace elements as well as the encoding used for the associated payload data.

group_id: String

The group_id element of the Topic Namespace provides for a logical grouping of MQTT EoN nodes into the MQTT Server and back out to the consuming MQTT Clients.

device_message_type: DeviceMessageType

The message_type element of the Topic Namespace provides an indication as to how to handle the MQTT payload of the message.

edge_node_id: String

The edge_node_id element of the Sparkplug (TM) Topic Namespace uniquely identifies the MQTT EoN node within the infrastructure.

device_id: String

The device_id element of the Sparkplug (TM) Topic Namespace identifies a device attached (physically or logically) to the MQTT EoN node.

StateMessage

A state message for scada systems

Fields

scada_host_id: String

The id of the SCADA application

Implementations

impl TopicName

pub const fn new_node_message( namespace: TopicNamespace, group_id: String, node_message_type: NodeMessageType, edge_node_id: String, ) -> Self

Constructs a new TopicName of type TopicName::NodeMessage

pub const fn new_device_message( namespace: TopicNamespace, group_id: String, device_message_type: DeviceMessageType, edge_node_id: String, device_id: String, ) -> Self

Constructs a new TopicName of type TopicName::DeviceMessage

pub const fn new_state_message(scada_host_id: String) -> Self

Constructs a new TopicName of type TopicName::StateMessage

Trait Implementations

impl Clone for TopicName

fn clone(&self) -> TopicName

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TopicName

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

Formats the value using the given formatter.

impl FromStr for TopicName

type Err = Box<dyn Error + Send + Sync>

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl PartialEq for TopicName

fn eq(&self, other: &TopicName) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl ToString for TopicName

fn to_string(&self) -> String

Converts the given value to a String.

impl StructuralPartialEq for TopicName