rocketmq-common-0.2.0
- rocketmq-common 0.2.0
- Docs.rs crate page
- MIT OR Apache-2.0
- Links
- Homepage
- Repository
- crates.io
- Source
- Owners
- mxsm
- Dependencies
- anyhow ^1.0 normal
  byteorder ^1.5.0 normal
  bytes ^1.5.0 normal
  chrono ^0.4.38 normal
  config ^0.14 normal
  crc32fast ^1.3.2 normal
  dirs ^5.0 normal
  flate2 ^1.0.17 normal
  futures ^0.3 normal
  futures-core ^0.3 normal
  futures-executor ^0.3 normal
  futures-task ^0.3 normal
  futures-util ^0.3 normal
  lazy_static ^1.4.0 normal
  local-ip-address ^0.6.1 normal
  log ^0.4.20 normal
  lz4_flex ^0.11 normal
  num_cpus ^1.16 normal
  once_cell ^1.19.0 normal
  parking_lot ^0.12 normal
  serde ^1.0 normal
  serde_json ^1.0 normal
  tempfile ^3.10.1 normal
  tokio ^1.35 normal
  tracing ^0.1 normal
  tracing-subscriber ^0.3 normal
  trait-variant ^0.1.2 normal
  zstd ^0.13 normal
  mockall ^0.12.1 dev
- Versions
- 1.63% of the crate is documented
Go to latest version
Platform
- i686-unknown-linux-gnu
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

rocketmq_common0.2.0

In rocketmq_common::utils::message_utils

Function rocketmq_common::utils::message_utils::get_sharding_key_indexes

pub fn get_sharding_key_indexes(
    msgs: &[MessageExt],
    index_size: usize
) -> HashSet<usize>