Tags: gammazero/nexus
Tags
Event History (#290) * Enabled event history feature * Extended router config with topic event history parameters * Implemented storing event history if configured for a topic Added function placeholders for event history meta RPCs * Implemented event history meta RPCs + filter events to save * Refactored/optimized event history processsing * Another bunch of refactored/optimized event history processsing points * A bit of refactoring and improvements, return err from broker initialization * Event history meta RPCs now return also isLimitReached flag * Typos and test renames * Added tests for broker's event history processing * Fixed issues in event history meta RPCs * Refactored/optimized event history meta RPCs into one with parameters + covered with tests * Added filtering based on topic URI to event history metaRPC * Enabled event history in README * Updated event history meta RPC with new params, refactored after review and covered with tests * Added readme about nexusd
Progressive calls (#3) (#289) * Implemented progressive calls on caller side: added new public API method * Added initial progressive call processing to dealer * Keep information about invocation for ongoing progressive calls * Repopulate invocationID for existing calls * Added test for progressive call * Added tests for progressive call and progressive result at the same time + fixed bugs * Refactored progressive calls to pull model * Some code improvements + comparing sequence of payload for progressive calls * Fixed sequential processing of progressive call input data chunks alongside progressive call results * Code style fixes * Added examples of progressive calls * Updating ctx for progressive calls if the timeout is specified * examples cleanup * Some code improvements
Fix/local client modifies msg (#237) Fix problem with local clients modifying contents of message If local clients modified contents of a message, this could affect the message contents received by another client. Local clients must never receive the same message instance or messages with shared contents.
PreviousNext