node_redis - redis client for node

•    Javascript

---

Redis client library

database redis transaction pipelining performance queue nodejs pubsub backpressure redis-client redis-driver redis-library

tubes - A series of tubes.

•    Python

---

"Tubes" is a data-processing and flow-control engine for event-driven programs. Presently based primarily on Twisted, its core data structures are fairly framework-agnostic and could be repurposed to work with any event-driven container.

twisted async backpressure network networking

kanaloa - Make your service more resilient by providing protection against traffic oversaturation

•    Scala

---

Make your service more resilient by providing protection against traffic oversaturation.

backpressure traffic

scalecube-services - ScaleCube Services is a reactive-microservices-mesh that features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features

•    Java

---

The example provisions 2 cluster nodes and making a remote interaction. A service is nothing but an interface declaring what methods we wish to provision at our cluster.

microservices swim rpc netty reactive-streams reactive distributed-systems service-mesh reactive-microservices reactor3 rsocket-rpc ipc bi-directional streams low-latency performance backpressure swim-protocol cluster-membership

reactive-gremlin - akka http gremlin 3 websocket connector

•    Scala

---

High throughput akka http gremlin 3 websocket connector with backpressure. reactive-gremlin is a streaming websocket client that connects to a gremlin server to execute gremlin scripts. Current client including the Java client provided by datastax have the capability to crash your gremlin server by overflowing the server with asyn requests. Your gremlin server will buffer incoming requests and service them when it has finished the ones in the queue. For fast consumers (bulk loaders) it is possible to cause Out of memory Exceptions and crash the server.

backpressure bulk-loader akka-streams titan graph-database