We have collection of more than 1 Million open source products ranging from Enterprise product to small libraries in all platforms. We aggregate information from all open source repositories. Search and find the best for your needs. Check out projects section.
workq - Job server in Go
Workq is a job scheduling server strictly focused on simplifying job processing and streamlining coordination. It can run jobs in blocking foreground or non-blocking background mode. Workq runs as a standalone TCP server and implements a simple, text based protocol. Clients interact with Workq over a TCP socket in a request/response model with text commands. Please refer to the full protocol doc for details.
queue queueing jobs jobqueue job job-scheduler worker workers scheduler schedulenats.js - Node.js client for NATS, the cloud native messaging system.
A Node.js client for the NATS messaging system. The json connect property makes it easier to exchange JSON data with other clients.
nats messaging pubsub publish subscribe queue distributed queueingnode-nats - Node.js client for NATS, the cloud native messaging system.
A Node.js client for the NATS messaging system.See examples and benchmarks for more information..
nats messaging pubsub publish subscribe queue distributed queueinghemera - 🔬 Writing reliable & fault-tolerant microservices with https://nats.io
Hemera (/ˈhɛmərə/; Ancient Greek: Ἡμέρα [hɛːméra] "day") is a small wrapper around the NATS driver. NATS is a simple, fast and reliable solution for the internal communication of a distributed system. It chooses simplicity and reliability over guaranteed delivery. We want to provide a toolkit to develop micro services in an easy and powerful way. We provide a pattern matching RPC style. You don't have to worry about the transport. NATS is powerful.Hemera has not been designed for high performance on a single process. It has been designed to create lots of microservices doesn't matter where they live. It choose simplicity and reliability as primary goals. It act together with NATS as central nervous system of your distributed system. Transport independency was not considered to be a relevant factor. In addition we use pattern matching which is very powerful. The fact that Hemera needs a broker is an argument which should be taken into consideration when you compare hemera with other frameworks. The relevant difference between microservice frameworks like senecajs, molecurer is not the performance or modularity its about the complexity you need to manage. Hemera is expert in providing an interface to work with lots of services in the network, NATS is the expert to deliver the message at the right place. Hemera is still a subscriber of NATS with some magic in routing and extensions. We don't have to worry about all different aspects in a distributed system like routing, load-balancing, service-discovery, clustering, health-checks ...
nodejs distributed-systems microservice nats pubsub rpc cloud-native micro service micro-service microservices micro-services services framework minimum viable product toolkit startup messaging publish subscribe queue distributed queueingkq - Kafka-based Job Queue for Python
KQ (Kafka Queue) is a lightweight Python library which lets you queue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood. You may need to use sudo depending on your environment.
kafka job-queue async kafka-client kafka-consumer kafka-producer python3 python2 python-library python-3 python-2 asynchronous queueing jobqueue apache-kafka worker-queue producer-consumer serialization python-3-5swarrot - A lib to consume message from any Broker
Swarrot is a PHP library to consume messages from any broker. Heavily inspired by stackphp/builder you can use Swarrot\Processor\Stack\Builder to stack your processors. Using the built in processors or by creating your own, you can extend the behavior of your base processor. In this example, your processor is decorated by 2 other processors. The ExceptionCatcherProcessor which decorates your own with a try/catch block and the MaxMessagesProcessor which stops your worker when some messages have been consumed.
swarrot rabbitmq rabbit sqs queue queueingnode-nats-streaming - Node.js client for NATS Streaming
Node NATS Streaming is an extremely performant, lightweight reliable streaming platform powered by NATS for Node.js.NATS Streaming subscriptions are similar to NATS subscriptions, but clients may start their subscription at an earlier point in the message stream, allowing them to receive messages that were published before this client registered interest.
nats streaming messaging pubsub publish subscribe queue distributed queueingost - Redis based queues and workers.
Redis based queues and workers.Ost makes it easy to enqueue object ids and process them with workers.
workers queueing lesscode job-queue task-queue queue worker background-tasksimple-sqs - A simple wrapper around the AWS SQS queue service
A simple wrapper around the AWS SQS queue service
sqs queue queueing awslibqueue - C library providing persistent, named data storage queues w/ CLI utils. Uses LevelDB.
libqueue is a C library that provides persistent, named data queues for programs. Arbitrarily many queues can co-exist, given they have distinct names. The data itself is stored using leveldb in a compressed hash tree.
database leveldb library queueingamqp-replay - :video_camera: Replay messages from (RabbitMQ) AMQP dead-letter queue
Add INFINITE=true to replay the queue message infinitely. See LICENSE.
amqp-replay amqp rabbitmq replay-messages dead-letter queue queueing replaytoro - Multithreaded message processing on Postgres
Multithreaded message processing on Postgres
message-queue queue queueing postgres postgresql background-jobs workersqure.js - Javascript library facilitating asynchronous programming
It is also possible to "fork" the timeline...which enables multiple queueing/chaining, independent of each other.
concurrency queueing recursion design-patternPSRabbitMq - PowerShell module to send and receive messages from a RabbitMq server
PowerShell module to send and receive messages from a RabbitMQ server. All credit to @gpduck, all blame for butchering to @ramblingcookiemonster.
powershell powershell-modules rabbitmq rabbitmq-server message-bus message queue queueing amqpts-nats - TypeScript Node.js client for NATS, the cloud native messaging system
A TypeScript Node.js client for the NATS messaging system. ts-nats is a typescript nats library for node that supports Promises and async/await patterns. Full documentation.
nats messaging pubsub publish subscribe queue distributed queueingRXBus - RX based bus with lifecycle based queuing support
RX based bus with lifecycle based queuing support
rxjava bus eventbus queueingRxBus2 - RxJava2 based bus with queuing (e.g. lifecycle based) support
This is an reactive implementation of an event bus, with a few convenient functions especially useful for handling events with activities, fragments and similar.
rxjava2 bus eventbus queueingnats.ts - TypeScript Node.js client for NATS, the cloud native messaging system
A TypeScript Node.js client for the NATS messaging system. ts-nats is a typescript nats library for node that supports Promises and async/await patterns. Full documentation.
nats messaging pubsub publish subscribe queue distributed queueingstan.js - Node.js client for NATS Streaming
NATS Streaming Server is an extremely performant, lightweight reliable streaming platform powered by NATS. NATS streaming subscriptions are similar to NATS subscriptions, but clients may start their subscription at an earlier point in the message stream, allowing them to receive messages that were published before this client registered interest.
nats streaming messaging pubsub publish subscribe queue distributed queueing
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.
