bitcapybara/budmq

Issues

• Use zerocopy for serialize and deserialize

  #105 opened a year ago
  1

• Use FuturesUnorderd to manage broker tasks

  #104 opened a year ago
  0

• Client actively obtain messages after a specified period of idle time

  #103 opened a year ago
  0

• use s2n-mtls

  #102 opened a year ago
  0

• consumer weightlight

  #100 opened a year ago
  0

• add permits field in subscription packet

  #99 opened a year ago
  0

• wrap all raw errors from third party crates

  #98 opened a year ago
  0

• topic conv fix

  #87 opened a year ago
  0

• impl Stream trait for consumer

  #85 opened a year ago
  1

• cursor persistent

  #66 opened 2 years ago
  0

• storage features

  #64 opened 2 years ago
  1

• MetaStorage and MessageStorage trait

  #58 opened 2 years ago
  1

• produce/consume on multiple topic

  #56 opened 2 years ago
  0

• use queue in pipeline for resp order

  #55 opened 2 years ago
  1

• time in message

  #54 opened 2 years ago
  0

• impl protocol::Codec for custom types

  #45 opened 2 years ago
  0

• producer mode

  #44 opened 2 years ago
  0

• producer/consumer listen on connection close event

  #43 opened 2 years ago
  0

• add cache for published messages

  #42 opened 2 years ago
  1

• error design

  #41 opened 2 years ago
  5

• consumer unsubscribe/close_consumer

  #39 opened 2 years ago
  0

• channel(1) or unbounded_channel()?

  #38 opened a year ago
  0

• producer ordered/unordered send

  #35 opened 2 years ago
  3

• use JoinSet to manage all spawned tokio tasks

  #34 opened 2 years ago
  1

• producer batch send

  #33 opened a year ago
  0

• ordering of publish messages

  #32 opened 2 years ago
  0

• reconnect backoff

  #30 opened 2 years ago
  1

• global id generator

  #27 opened 2 years ago
  1

• protocol derive to generate decoder/encoder impl

  #26 opened 2 years ago
  1

• select on cancel token in cursor sending loop

  #24 opened 2 years ago
  1

• common reader and writer io/pool

  #22 opened 2 years ago
  10

• CreateProducer/CreateProducerReceipt Packet

  #20 opened 2 years ago
  3

• producer sync/async send

  #18 opened 2 years ago
  1

• use raft kv storage to support cluster

  #16 opened a year ago
  3

• add persist message storage support

  #15 opened 2 years ago
  0

• Client connection reconnect

  #9 opened 2 years ago
  2

• 使用 CancellationToken 等待线程结束

  #6 opened 2 years ago
  1

• Move `Storage` trait to `libbud-common`

  #5 opened 2 years ago
  0

• Client impl

  #4 opened 2 years ago
  3

• backgroud spawn task don't return error

  #3 opened 2 years ago
  0

• Features for storage

  #2 opened 2 years ago
  0

• Remove remote_handle()

  #1 opened 2 years ago
  1