Lib.rs

› Keywords #redis #ring-buffer #lock-free #lock-free-queue #mpmc #supplier

#consumer

  1. crossbeam-queue

    Concurrent queues

    v0.3.12 13.0M #lock-free-queue #mpmc #lock-free #queue #consumer

  2. prism3-function

    Common functional programming type aliases for Rust, providing Java-style functional interfaces

    v0.5.0 #consumer #supplier #predicate-function #functional

  3. redsumer

    Lightweight implementation of Redis Streams for Rust

    v0.5.4 500 #redis #consumer #redis-streams

  4. mecha10-messaging

    Redis Streams messaging layer for Mecha10

    v0.1.46 200 #redis #messaging #mecha10 #retry #consumer #pub-sub-messaging #backoff

  5. onering

    High throughput synchronous queue

    v1.4.0 110 #synchronous-queue #ring-buffer #consumer #receiver #high #try-recv-error

  6. shm_ring

    A single producer, single consumer lockless ring buffer for message passing between shared memory

    v0.3.4 750 #ring-buffer #shared-memory #lockless #consumer #directional

  7. rocketman

    A modular(ish) jetstream consumer

    v0.3.0 #collection #jetstream #ish #modular #consumer #ingestor #nsid #lexicon #tungstenite

  8. async-promise

    Async promise which resolves once and may be read by multiple consumers

    v0.1.1 2.9K #async #promise #consumer #resolve #read #oneshot-channel #once-cell

  9. conveyor-etl-registry

    Service registry and consumer group coordination for Conveyor ETL

    v0.1.0 #service-registry #load-balancing #etl #consumer #service-health #conveyor #data-pipeline

  10. rustbridge-consumer

    Rust consumer for rustbridge plugins

    v0.10.0 #dynamic-loading #plugin #consumer #api-bindings

  11. market

    Infrastructure for producers and consumers

    v0.30.1 100 #goods #consumer #producer

  12. dynamic_services

    A dynamic services injection framework

    v0.1.4 300 #service #framework #service-reference #inject #consumer

  13. openc2_consumer

    Rust types for OpenC2 consumers

    v0.2.0 #open-c2 #consumer #response #message #command #command-and-control

  14. supermon

    A set of utilities for coordinating watchers, middleware, and consumers via channels

    v0.1.0 #middleware #watcher #channel #consumer #action #feeding #coordinating

  15. tap-consooomer

    Parse Test Anything Protocol (TAP) files

    v0.1.0 #tap #consumer #test-anything #parser

  16. redis-stream-reactor

    Redis consumer group reactor

    v0.0.1-beta.33 1.1K #reactor #redis #group #consumer #stream

    17. Try searching with DuckDuckGo.

  17. invoke_impl

    Proc macro to generate functions that can invoke all identical functions or methods inside impl blocks

    v0.1.1 #impl-block #proc-macro #macro-attributes #fn-mut #consumer #methods-signature #automate #producing

  18. oyashio

    spmc streams

    v0.0.4 #stream #spmc #consumer #arc #iterator

  19. simple_ecs

    A super-simple entity-component system in Rust

    v0.3.2 #ecs #set-component #avoiding #consumer #object #super-simple #render-component #scale-component #real-world #insane

  20. sqs-service-helper

    facilitate SQS based consumer services

    v0.1.5 #amazon-sqs #service #consumer #sqs

  21. ecs-rs

    A super-simple entity-component system in Rust

    v0.1.2 #set-component #avoiding #consumer #entity-component-system #object #super-simple #render-component #scale-component #real-world #insane

  22. cooplan-amqp-api-consumer

    consuming Cooplan's AMQP APIs

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

  23. pac-man

    AWS Lambda streaming API consumer

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

  24. cooplan-amqp-api-shared

    Shared code for the Cooplan API providers & consumers

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

  25. wasm-reader

    Streaming, very fast webassembly parsing library that lets the consumer maintain ownership of the data stream (NIGHTLY ONLY)

    v0.2.0 #parser #streaming-parser #stream-data #nightly #consumer #wasm-parser

  26. stream-consumer-task

    Start asynchronous task in background to consume stream

    v0.1.0 #async-stream #task #consumer

  27. jetsky

    Skylight's jetstream consumer

    v0.1.0 #jetstream #github #tree #consumer #skylight #taken

  28. csfdapi

    Unofficial wrapper for mobile csfd api

    v0.1.0 #api #csfd #mobile #requests #consumer #encryption-key

  29. pallet-idn-consumer

    FRAME pallet for interfacing with IDN as a consumer

    v0.0.1 #subscription #consumer #pallet #idn #quote #xcm #pallet-frame #blockchain #reactivate

  30. tokio-by-hand

    futures

    v0.0.0 #future #standard #stream-sink #produce-consume #consumer #cryptocurrency #task-handle #sleeper #not-ready #notifying

  31. market_derive

    Derive macros for market

    v0.1.0 #define #goods #stock #consumer #hold

  32. builder_derive

    proc macro that allows the user to auto generate a simple builder pattern

    v0.0.1 #builder-pattern #proc-macro #user #auto-generate #consumer #macro-derive