Lib.rs

› 关键词 #producer #producer-consumer #queue #client #async #thread #multiple #api

消费者

  1. async-broadcast

    异步广播通道

    v0.7.1 1.0M #broadcast-channel #async #messages #clone #consumer #multi-producer #multi-consumer

  2. crossbeam-queue

    并发队列

    v0.3.11 3.2M #queue #lock-free-queue #mpmc #lock-free #producer-consumer #consumer #producer

  3. embassy-sync

    无标准库、无分配的异步支持同步原语

    v0.6.0 72K #async-channel #synchronization-primitive #consumer #mutex #multiple #producer-consumer #embassy

  4. pulsar

    Rust版本的Apache Pulsar客户端

    v6.3.0 15K #client #api-client #consumer #apache #api #tls-connection #topic

  5. kafka

    Rust版本的Apache Kafka客户端

    v0.10.0 16K #apache-kafka #queue #client #topic #producer #deprecated #consumer

  6. picokafka

    基于librdkafka的tarantool-module的Kafka库

    v0.3.0 320 #tarantool #kafka #distributed-systems #communication #thread #consumer #driver

  7. rabbit-auto

    lapin发布者和消费者包装器

    v0.4.1 #rabbitmq #publisher #consumer #connection #auto #automatic #lapin

  8. command-executor

    命令执行线程池

    v0.1.1 #thread-pool #producer-consumer #consumer #producer #mpmc #concurrency #execute-command

  9. sigq

    信号队列，用于通知等待的消费者关于节点可用性的信息

    v0.13.4 #queue #sync #thread #node #consumer #waiting #mutex

  10. fluvio-compression

    Fluvio压缩库

    v0.3.3 2.0K #compression #fluvio #consumer #streaming #side #producer #zstd

  11. pragma-consumer

    用于消费Pragma数据流的SDK

    v0.1.1 230 #consumer #feed #sdk #data #pragma #merkle-proof

  12. howudoin

    进度报告抽象

    v0.1.2 2.7K #progress #abstraction #tui #reporting #reports #consumer #producing

  13. rabbit_borough

    通过绕过模板、配置和复杂的弹性逻辑，以最小努力创建RabbitMQ消费者项目

    v0.1.7 #rabbitmq #consumer #amqp #lapin #configuration #abstraction #templating

  14. neutron

    Pulsar的客户端库

    v0.0.2 #pulsar #client #consumer #producer #send #json #tls

  15. tiny_kafka

    一个具有生产者和消费者功能的迷你Kafka客户端库

    v1.0.4 #producer-consumer #kafka #producer #consumer #streaming #rust-client

  16. unbounded-spsc

    由bounded_spsc_queue构建的无界spsc队列

    v0.1.9 #queue #unbounded #spsc #consumer #performance #buffer #size

  17. redsumer

    Rust中Redis Streams的轻量级实现

    v0.4.1 #redis #stream #redis-streams #consumer #producer #messages

  18. pragma-common

    Pragma SDKs的通用工具

    v0.1.0 120 #feed #sdk #consumer #pragma #data

  19. market

    生产者和消费者基础设施

    v0.30.1 200 #producer-consumer #consumer #producer #stock #agent #goods #infrastructure

  20. para

    数据流/管道并行化框架

    v0.2.0 #node #framework #scheduler #computation #parallelization #consumer #data

  21. async_message_dispatcher

    简化异步处理器的消息调度

    v7.0.0 #message #handlers #dispatching #dispatcher #async #consumer #states

    22. 尝试使用DuckDuckGo进行搜索。搜索.

  22. tap-consooomer

    解析Test Anything Protocol (TAP)文件

    v0.1.0 #tap #consumer #parser #test-anything #convert-json #input-file

  23. supermon

    通过通道协调监视器、中间件和消费者的实用工具集

    v0.1.0 #consumer #middleware #channel #watcher #communication-channel #messages #worker

  24. krs

    Kafka命令行工具

    v0.2.4 #kafka #producer #consumer #rdkafka #command-line-tool

  25. sling

    顺序锁定（SeqLock）环形缓冲区

    v0.2.0 #ring-buffer #queue #thread #message-queue #read #consumer #locking

  26. invoke_impl

    生成可以调用impl块中所有相同函数或方法的proc宏

    v0.1.1 #impl-block #invoke #proc-macro #consumer #functions #enums #attributes

  27. mp2c

    一个多生产者多轮询消费者库，允许多个生产者完全异步地向多个消费者发送消息

    v0.1.2 #send-message #consumer #producer-consumer #multi-consumer #multiple #polling #thread

  28. other-pocket

    Pocket API（https://getpocket.com）的异步绑定

    v0.1.0 #pocket #api-bindings #com #getpocket #oauth #token #consumer

  29. mpmc-ringbuf

    队列

    v0.1.4 #queue #mpmc #consumer #multiple #producer #ringbuf #block

  30. async_event_streams

    异步事件发布/订阅库

    v0.1.4 #event-stream #events #async #multiple #consumer #publishing #object

  31. xorc-notifications

    一个从Kafka发送推送通知的消费者

    v0.1.0 #consumer #kafka #web-push #fcm #apns

  32. centaurs

    一个实用crate

    v0.3.0 #centaurs #offset #consumer

  33. bbq-rs

    用于交换数据和性能分析的基于块的有限队列

    v0.1.1 #queue #bounded #profiling #exchanging #bbq #producer #consumer

  34. pyth-sdk

    Pyth价格预言机的数据结构和工具

    v0.8.0 7.9K #price #pyth #structures #oracle #product #consumer #methods

  35. cooplan-amqp-api-consumer

    消费Cooplan的AMQP API

    v0.2.0 #amqp #api #consumer #cooplan #consuming

  36. pac-man

    AWS Lambda流式API消费者

    v0.1.0 #aws-lambda #consumer #streaming #api

  37. oyashio

    spmc streams

    v0.0.4 #stream #consumer #spmc #producer-consumer #iterator #functions

  38. simple_ecs

    Rust中的超级简单实体-组件系统

    v0.3.2 #entity-component #consumer #macro #avoiding #system #entities #objects

  39. ecs-rs

    Rust中的超级简单实体-组件系统

    v0.1.2 #ecs #consumer #macro #avoiding #inlining #system #entities

  40. instapaper

    API包装器

    v0.1.2 #api-wrapper #api-access #consumer #client #secret #user-name #key

  41. promissory

    线程间的一次性值交换

    v0.1.3 #thread #value #producer #consumer #single #one-shot #exhange

  42. dropshot_endpoint

    dropshot消费者用于注册处理器的宏

    v0.11.0 4.6K #consumer #dropshot #handlers #macro #attributes #define #generate

  43. sqs-service-helper

    简化基于SQS的消费者服务

    v0.1.5 #sqs #consumer #message #services #visibility #helper #processing

  44. pants

    一个网页应用，用于将任何内容保存到Pocket

    v0.1.2 #pocket #save #rocket #anything #web-apps #consumer #post

  45. obstacle

    将object_store crate与基于mmap的消费者（如Polars）集成

    v0.0.2 #object-store #mmap #polars #download #integrate #cache #consumer

  46. stream-consumer-task

    在后台启动异步任务以消费流

    v0.1.0 #task #stream #consumer #async #asynchronous

  47. market_types

    市场的常见实现

    v0.1.0 #market #consumer #process #instance

  48. wot-consume

    物联网（WoT）事物消费者

    v0.1.0 #wot #consumer #web #consume #webof-things #thing

  49. cooplan-amqp-api-shared

    Cooplan API提供者与消费者的共享代码

    v0.1.2 #consumer #provider #api #shared #cooplan

  50. multi-consumer-stream

    处理到流的句柄，允许多个不同的任务从相同的底层流中读取

    v0.4.0 #stream #read-stream #multiple #different #allowing #tasks #consumer