Struct replicator::config::Config

pub struct Config {
    pub clusters: Vec<Cluster>,
    pub clients: Vec<Client>,
    pub routes: Vec<Route>,
    pub observers: Vec<ObserverConfig>,
    pub prometheus: Option<PrometheusConfig>,
}

Fields

clusters: Vec<Cluster>

clients: Vec<Client>

routes: Vec<Route>

observers: Vec<ObserverConfig>

prometheus: Option<PrometheusConfig>

Implementations

impl Config

pub fn get_cluster(&self, name: &str) -> Result<&Cluster, String>

pub fn get_client(&self, name: &str) -> Result<&Client, String>

pub fn create_client_config(
    &self,
    name: &str,
    group_id: Option<&str>
) -> ClientConfig

pub fn check_partitions(
    &self,
    upstream_config: &ClientConfig,
    downstream_config: &ClientConfig,
    upstream_topics: HashSet<String>,
    downstream_topic: String
) -> Result<(), String>

pub fn get_pipeline(
    &self,
    index: usize,
    metrics: Arc<Mutex<PipelineMetrics>>,
    is_running: Arc<AtomicBool>
) -> Pipeline

pub fn get_pipelines(
    &self,
    metrics: Arc<Mutex<PipelineMetrics>>,
    is_running: Arc<AtomicBool>
) -> Vec<Pipeline>

pub fn get_observers(
    &self,
    metrics: Arc<Mutex<ObserverMetrics>>
) -> Vec<Observer>

Trait Implementations

impl Clone for Config

pub fn clone(&self) -> Config

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

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

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

Deserialize this value from the given Serde deserializer.

impl Serialize for Config

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

Serialize this value into the given Serde serializer.