#sink #conf #config #rlink

rlink-sink-conf

sink config for rlink

8 releases (4 breaking)

0.6.0 Aug 12, 2021
0.5.0 Jun 17, 2021
0.3.1 May 28, 2021
0.2.0 Apr 23, 2021
0.1.2 Apr 14, 2021

#13 in #conf

MIT/Apache

10KB
201 lines

rlink-sink-conf

Crates.io Released API docs MIT licensed License

Sink config for rlink. Upgrade tasks smoothly.

Example

[dependencies]
rlink-sink-conf = "0.1"
        let sin_conf_url = "http://web.rlink.17usoft.com/upgrade/config/name";
        let application_name = "tlb_base_qa";
        let timestamp = 123 as u64;

        init_sink_config(sin_conf_url.to_string(), application_name.to_string());

        let mut expression_param = HashMap::new();
        expression_param.insert("timestamp".to_string(), timestamp.to_string());
        let sink_topic = get_sink_topic(expression_param);

lib.rs:

rlink-sink-conf

A library to upgrade rlink task smoothly.

Example

use rlink_sink_conf::sink_config::{init_sink_config, get_sink_topic};
use std::collections::HashMap;

let sin_conf_url = "testUrl";
let application_name = "tlb_base_qa";
let timestamp = 123 as u64;

init_sink_config(sin_conf_url.to_string(), application_name.to_string());

let mut expression_param = HashMap::new();
expression_param.insert("timestamp".to_string(), timestamp.to_string());
let sink_topic = get_sink_topic(expression_param);

Dependencies

~28–43MB
~718K SLoC