"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 networkingMake your service more resilient by providing protection against traffic oversaturation.
backpressure trafficThe 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-membershipHigh 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
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.