Displaying 1 to 5 from 5 results

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.

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

  •    Scala

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




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.