文件名称:tokio-nsq:基于Tokio的Rust NSQ客户端
文件大小:28KB
文件格式:ZIP
更新时间:2024-04-20 02:18:11
Rust
东京NSQ 基于Rust 客户端。 Tokio NSQ旨在成为功能完善的NSQ客户端实现。 Tokio NSQ可作为,API文档可在上。 版本控制 该项目遵循严格的语义版本控制。 在1.0.0之前的版本中,重大更改只有次要版本。 基本消费者示例 let topic = NSQTopic :: new ( "names" ). unwrap (); let channel = NSQChannel :: new ( "first" ). unwrap (); let mut addresses = HashSet :: new (); addresses. insert ( "http://127.0.0.1:4161" . to_string ()); let mut consumer = NSQConsumerConfig :: new (topic, channel)
【文件预览】:
tokio-nsq-master
----rustfmt.toml(40B)
----Cargo.toml(1KB)
----.github()
--------workflows()
----auth.js(593B)
----src()
--------consumer.rs(14KB)
--------producer.rs(3KB)
--------connection.rs(35KB)
--------connection_config.rs(8KB)
--------lib.rs(2KB)
--------snappy.rs(9KB)
--------with_stopper.rs(365B)
----keys()
--------README.md(37B)
--------key.pem(3KB)
--------cert.pem(2KB)
----build.rs(95B)
----LICENSE(1KB)
----README.md(2KB)
----docker-compose.yml(861B)
----tests()
--------test_live.rs(10KB)
----.gitignore(19B)