Struct station::config::Config

pub struct Config { /* fields omitted */ }

RPC and PubSub configuration.

Implementations

impl Config

pub fn new() -> Config

Create a new config.

pub fn add_rpc(
    &mut self,
    name: &str,
    addr: SocketAddr
) -> Result<(), ConfigError>

Add an RPC config entry based on TCP port usage.

Args:

• name: The name to associate the config with.
• addr: The TCP socket address to use for the RPC listener.

pub fn get_rpc(&self, name: &str) -> Option<SocketAddr>

Get the TCP port number for an RPC listener.

Args:

• name: The name in the config entries.

pub fn add_pubsub(
    &mut self,
    topic: &str,
    endpoint: &PubSubEndpoint
) -> Result<(), ConfigError>

Add a PubSub endpoint to the config.

Args:

• topic: The PubSub topic to add the endpoint to.
• endpoint: An endpoint for a publisher to publish to.

pub fn get_pubsub_endpoint(
    &self,
    topic: &str,
    endpoint: &str
) -> Option<PubSubEndpoint>

Get the config for a PubSub endpoint for a topic.

Args:

• topic: The PubSub topic to fetch endpoint configs for.
• endpoint: The name of the PubSub endpoint to query.

pub fn get_pubsub_topic(&self, topic: &str) -> Option<HashSet<PubSubEndpoint>>

Get the set of endpoint configs for a PubSub topic.

Args:

• topic: The PubSub topic to fetch endpoint configs for.

pub fn has_pubsub(&self, topic: &str) -> bool

Check if a config exists for a PubSub topic.

pub fn read_yaml(path: &Path) -> Result<Config, IoError>

Read a config from a YAML file.

Args:

• path: Path to the file to read.

pub fn write_yaml(&self, path: &Path) -> Result<(), IoError>

Write the config as a YAML file.

Args:

• path: Path to the file to write.

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Config

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<Config> for Config

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Serialize for Config

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Config