V3/feature/105 - #170
Merged
Merged
Conversation
Add async support to data store interfaces and refactor Refactor `IDataStore` into its own file for better modularity. Introduce `IAsyncDataStore` with async methods like `GetAsync`, `PutAsync`, and `RemoveAsync`, including `IAsyncEnumerable` support for .NET Standard 2.1+ and .NET Core 3.0+. Update `InMemoryStateStore` to implement `IAsyncDataStore`, adding async methods for key-value operations. Improve input validation in the constructor. Reorganize namespaces and add conditional compilation for framework-specific features. These changes enhance scalability, modernize the API, and improve maintainability.
v2/feature/ #158: Add Async/Await support
…idation-to-be-used Feature/164 allow fluentvalidation to be used
Removed the IConfiguration parameter from AddCortexMediator and made the configure parameter non-nullable. This streamlines service registration and eliminates the need to provide a configuration object.
v2.2/bug/161: Refactor AddCortexMediator method signature
V2.2/release
Remove windowed stream processing (window operators) All code related to windowed stream processing—including tumbling, sliding, and session windows—has been removed. This includes the deletion of TumblingWindowOperator, SlidingWindowOperator, SessionWindowOperator, and their supporting types (WindowKey, WindowState, SessionKey, SessionState). All related methods have been removed from IStreamBuilder and StreamBuilder, and references to windowing types have been eliminated. Other stream builder features remain unaffected.
Introduce TumblingWindow, SlidingWindow, and SessionWindow operators with state persistence, thread safety, and telemetry support. Extend stream builder interfaces for fluent windowing. Add WindowResult type and comprehensive unit tests. Refactor and replace old windowing logic for consistency and extensibility.
eneshoxha
added
enhancement
Added ITelemetryEnabled to Branch, Fork, and SinkOperatorAdapter for metrics and tracing. Updated StreamBuilder for telemetry propagation and refactored windowing methods. Introduced TelemetryTests with a mock provider to verify metrics, tracing, and thread safety. Cortex.Tests.csproj now references Cortex.Telemetry. All telemetry features remain optional.
This was
linked to
issues
Jan 24, 2026
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
This PR contains the re-write of Window Operators