Crate tokio_nsq

source ·
Expand description

A Rust NSQ client built on Tokio. Tokio NSQ aims to be a feature complete NSQ client implementation.

A basic consumer example:

 use tokio_nsq::*;

 let topic   = NSQTopic::new("names").unwrap();
 let channel = NSQChannel::new("first").unwrap();

 let mut addresses = std::collections::HashSet::new();
 addresses.insert("http://127.0.0.1:4161".to_string());

 let mut consumer = NSQConsumerConfig::new(topic, channel)
    .set_max_in_flight(15)
    .set_sources(
        NSQConsumerConfigSources::Lookup(
            NSQConsumerLookupConfig::new().set_addresses(addresses)
        )
    )
    .build();

 let mut message = consumer.consume_filtered().await.unwrap();

 let message_body_str = std::str::from_utf8(&message.body).unwrap();
 println!("message body = {}", message_body_str);

 message.finish();

Logging

Logging for Tokio NSQ is done via the common log facade. If you desire logs from Tokio NSQ you must integrate an additional crate implementing the log API such as env_logger, or simple-logging.

Structs

  • NSQChannel
    A smart constructor validating an NSQ channel name
  • NSQConfigShared
    Configuration options shared by both produces and consumers
  • NSQConfigSharedTLS
    NSQD TLS encryption options
  • NSQConsumer
    An NSQD consumer corresponding to multiple NSQD instances.
  • NSQConsumerConfig
    Configuration object for an NSQ consumer.
  • NSQConsumerLookupConfig
    Configuration object for NSQLookup nodes
  • NSQDeflateLevel
    A smart constructor validating a deflate compression level
  • NSQMessage
    An NSQ message. If this message is dropped with being finished and the respective NSQ daemon connection still exists the message will automatically by requeued.
  • NSQProducer
    An NSQD producer corresponding to a single instance.
  • NSQProducerConfig
    Configuration object for an NSQ consumer
  • NSQSampleRate
    A smart constructor validating an NSQ sample rate
  • NSQTopic
    A smart constructor validating an NSQ topic name

Enums