Docs.rs
  • sea-streamer-redis-0.5.2
    • sea-streamer-redis 0.5.2
    • Permalink
    • Docs.rs crate page
    • MIT OR Apache-2.0
    • Links
    • Repository
    • crates.io
    • Source
    • Owners
    • tyt2y3
    • Dependencies
      • anyhow ^1 normal optional
      • async-std ^1 normal optional
      • clap ^4.5 normal optional
      • env_logger ^0.9 normal optional
      • flume ^0.11 normal
      • lazy_static ^1.4 normal
      • log ^0.4 normal
      • mac_address ^1 normal
      • redis ^0.25 normal
      • sea-streamer-runtime ^0.5 normal
      • sea-streamer-types ^0.5 normal
      • thiserror ^1 normal
      • tokio ^1.10.0 normal optional
    • Versions
    • 55.84% of the crate is documented
  • Platform
    • i686-pc-windows-msvc
    • i686-unknown-linux-gnu
    • x86_64-apple-darwin
    • x86_64-pc-windows-msvc
    • x86_64-unknown-linux-gnu
  • Feature flags
  • docs.rs
    • About docs.rs
    • Privacy policy
  • Rust
    • Rust website
    • The Book
    • Standard Library API Reference
    • Rust by Example
    • The Cargo Guide
    • Clippy Documentation
logo

sea_streamer_redis0.5.2

Crate Items

  • Structs
  • Enums
  • Constants
  • Traits
  • Functions
  • Type Aliases

List of all items

Structs

  • Connection
  • NextFuture
  • PseudoRandomSharder
  • RedisCluster
  • RedisConnectOptions
  • RedisConsumer
  • RedisConsumerOptions
  • RedisMessageStream
  • RedisProducer
  • RedisProducerOptions
  • RedisStreamer
  • RoundRobinSharder
  • SendFuture

Enums

  • AutoCommit
  • AutoStreamReset
  • RedisErr
  • ShardOwnership
  • TimestampFormat

Traits

  • RedisMessageId
  • Sharder
  • SharderConfig

Functions

  • consumer_id
  • group_id
  • host_id
  • parse_message_id

Type Aliases

  • MessageId
  • NodeId
  • RedisMessage
  • RedisResult

Constants

  • DEFAULT_TIMEOUT
  • MAX_MSG_ID
  • MSG
  • REDIS_PORT
  • ZERO
  • constants::DEFAULT_AUTO_CLAIM_IDLE
  • constants::DEFAULT_AUTO_CLAIM_INTERVAL
  • constants::DEFAULT_AUTO_COMMIT_DELAY
  • constants::DEFAULT_AUTO_COMMIT_INTERVAL
  • constants::DEFAULT_BATCH_SIZE
  • constants::DEFAULT_LOAD_BALANCED_BATCH_SIZE
  • constants::HEARTBEAT