later - Utilities for Scheduling Functions to Execute Later with Event Loops
Executes arbitrary R or C functions some time after the current time, after the R execution stack has emptied. The functions are scheduled in an event loop.
Last updated
event-loopcpp
16.56 score 151 stars 3.1k dependents 399 scripts 581k downloads
mirai - Minimalist Async Evaluation Framework for R
Evaluates R expressions asynchronously and in parallel, locally or distributed across networks. An official parallel cluster type for R. Built on 'nanonext' and 'NNG', its non-polling, event-driven architecture scales from a laptop to thousands of processes across high-performance computing clusters and cloud platforms. Features FIFO scheduling with task cancellation and bounded queues, promises for reactive programming, 'OpenTelemetry' distributed tracing, and custom serialization for cross-language data types.
Last updated
asyncasynchronous-tasksconcurrencydistributed-computinghigh-performance-computingparallel-computing
15.93 score 345 stars 148 dependents 802 scripts 43k downloads
nanonext - Lightweight Toolkit for Messaging, Concurrency and the Web
R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. A toolkit for messaging, concurrency and the web. High-performance socket 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 survey. A threaded concurrency framework with intuitive 'aio' objects that resolve automatically upon completion of asynchronous operations, and synchronisation primitives that allow R to wait on events signalled by concurrent threads. A unified HTTP server hosting REST endpoints, WebSocket connections and streaming on a single port, with a built-in HTTP client.
Last updated
concurrencyhttp-clienthttp-serveripc-messagemessaging-libraryrpcsocket-communicationsynchronization-primitivestcp-protocoltlswebsocketmbedtls
13.77 score 84 stars 159 dependents 99 scripts 48k downloadssecretbase - Cryptographic Hash Functions and Data Encoding
Fast and memory-efficient streaming hash functions, binary/text encoding and serialization. Hashes strings and raw vectors directly. Stream hashes files which can be larger than memory, as well as in-memory objects through R's serialization mechanism. Implements the SHA-256, SHA-3 and 'Keccak' cryptographic hash functions, SHAKE256 extendable-output function (XOF), 'SipHash' pseudo-random function, base64 (including the URL-safe variant) and base58 encoding, 'CBOR' and 'JSON' serialization.
Last updated
base58checkbase64cborcryptographic-hash-functionsextendable-output-functionskeccaksha256sha3shake256siphash
8.71 score 19 stars 42 dependents 18 scripts 15k downloadswatcher - Watch the File System for Changes
R binding for 'libfswatch', a file system monitoring library. Watch files, or directories recursively, for changes in the background. Log activity, or call an R function, upon every change event.
Last updated
filesystem-eventscpp
7.99 score 40 stars 16 dependents 13 scripts 7.1k downloads
mori - Shared Memory for R Objects
Share R objects across processes on the same machine via a single copy in 'POSIX' shared memory (Linux, macOS) or a 'Win32' file mapping (Windows). Every process reads from the same physical pages through the R Alternative Representation ('ALTREP') framework, giving lazy, zero-copy access. Shared objects serialize compactly as their shared memory name rather than their full contents.
Last updated
shared-memory
7.35 score 148 stars 2 dependents 16 scripts 1.8k downloads
ichimoku - Visualization and Tools for Ichimoku Kinko Hyo Strategies
An implementation of 'Ichimoku Kinko Hyo', also commonly known as cloud charts. Static and interactive visualizations with tools for creating, backtesting and development of quantitative ichimoku strategies. As described in Sasaki (1996, ISBN:4925152009), the technique is a refinement on candlestick charting, originating from Japan and now in widespread use in technical analysis worldwide. Translating as one-glance equilibrium chart, it allows the price action and market structure of financial securities to be determined at-a-glance. Incorporates an interface with the 'OANDA fxTrade' API <https://developer.oanda.com/> for retrieving historical and live streaming price data for major currencies, metals, commodities, government bonds and stock indices.
Last updated
ichimokuichimoku-cloudoandaquantitative-finance
7.13 score 37 stars 46 scripts 665 downloadsmori - Shared Memory for R Objects
Share R objects across processes on the same machine via a single copy in 'POSIX' shared memory (Linux, macOS) or a 'Win32' file mapping (Windows). Every process reads from the same physical pages through the R Alternative Representation ('ALTREP') framework, giving lazy, zero-copy access. Shared objects serialize compactly as their shared memory name rather than their full contents.
Last updated
shared-memory
6.35 score 148 stars 2 dependents 16 scripts 1.8k downloadssakura - Extension to R Serialization
Extends the functionality of R serialization by augmenting the built-in reference hook system. This enhanced implementation allows an integrated single-pass operation that combines R serialization with third-party serialization methods. Facilitates the serialization of even complex R objects, which contain non-system reference objects, such as those accessed via external pointers, to enable their use in parallel and distributed computing.
Last updated
marshallingserialization
4.04 score 22 stars 3 scripts 203 downloads