Showing 4 of total 4 results (show query)
ropensci
rzmq:R Bindings for 'ZeroMQ'
Interface to the 'ZeroMQ' lightweight messaging kernel (see <https://zeromq.org/> for more information).
Maintained by Jeroen Ooms. Last updated 3 months ago.
15.2 match 84 stars 7.08 score 81 scripts
snoweye
pbdZMQ:Programming with Big Data -- Interface to 'ZeroMQ'
'ZeroMQ' is a well-known library for high-performance asynchronous messaging in scalable, distributed applications. This package provides high level R wrapper functions to easily utilize 'ZeroMQ'. We mainly focus on interactive client/server programming frameworks. For convenience, a minimal 'ZeroMQ' library (4.2.2) is shipped with 'pbdZMQ', which can be used if no system installation of 'ZeroMQ' is available. A few wrapper functions compatible with 'rzmq' are also provided.
Maintained by Wei-Chen Chen. Last updated 6 months ago.
9.2 match 17 stars 9.92 score 46 scripts 26 dependents
mschubert
clustermq:Evaluate Function Calls on HPC Schedulers (LSF, SGE, SLURM, PBS/Torque)
Evaluate arbitrary function calls using workers on HPC schedulers in single line of code. All processing is done on the network without accessing the file system. Remote schedulers are supported via SSH.
Maintained by Michael Schubert. Last updated 25 days ago.
clusterhigh-performance-computinglsfsgeslurmsshzeromq3cpp
2.9 match 149 stars 10.23 score 253 scripts
shikokuchuo
nanonext:NNG (Nanomsg Next Gen) Lightweight Messaging Library
R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a socket library for reliable, high-performance messaging over in-process, IPC, TCP, WebSocket and secure TLS transports. Implements 'Scalability Protocols', a standard for common communications patterns including publish/subscribe, request/reply and service discovery. As its own threaded concurrency framework, provides a toolkit for asynchronous programming and distributed computing. Intuitive 'aio' objects resolve automatically when asynchronous operations complete, and synchronisation primitives allow R to wait upon events signalled by concurrent threads.
Maintained by Charlie Gao. Last updated 2 days ago.
concurrencyhttpsipc-messagemessaging-librarynngrpcsocket-communicationsynchronization-primitivestcp-protocolwebsocketmbedtls
0.5 match 60 stars 9.81 score 28 scripts 9 dependents