1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57
#![allow(dead_code)] extern crate hyper; extern crate serde; extern crate serde_json; extern crate tokio; extern crate byteorder; extern crate log; extern crate tokio_rustls; extern crate rustls; extern crate regex; #[macro_use] extern crate lazy_static; extern crate backoff; extern crate miniz_oxide; use std::collections::HashMap; use std::collections::HashSet; use std::sync::Arc; use std::sync::atomic::{AtomicBool, Ordering}; use log::*; use crate::tokio::io::AsyncWrite; use crate::tokio::io::AsyncRead; use crate::tokio::io::AsyncWriteExt; use crate::tokio::io::AsyncReadExt; use std::convert::TryFrom; use failure::{Error}; mod connection; mod producer; mod consumer; mod compression; mod connection_config; pub use connection:: { NSQTopic , NSQChannel }; pub use producer:: { NSQProducerConfig , NSQProducer }; pub use consumer:: { NSQConsumerConfig , NSQConsumerConfigSources , NSQConsumerLookupConfig , NSQConsumer }; pub use connection_config:: { NSQConfigSharedTLS , NSQConfigSharedCompression , NSQConfigShared };