Summary

Adds binding for MetricsCollector in Projections.Store so that it is properly initialised and fix the NullReferenceException.

Summary

Implements the storage of copies of Projection readmodels in MongoDB (and prepared for others) whenever the Projection EventProcessor persists a state. The conversions are not yet used - just a simple JSON->BSON parsing using BsonDocument.Parse.

Summary

Introduces Runtime and MongoDB representations of the read model copy specification for Projection registration arguments. Provides default (no copy to MongoDB) values when not set, and DefinitionComparer also reports that definition has changed if the copy to MongoDB changes.

Summary

Manually released new Docker Images that sets the ASPNETCORE_URLS environment variable to serve the Web endpoint on port 8001 by default, instead of 80. This caused issues when running the Runtime in our platform.

Fixed

• Sets the ASPNETCORE_URLS environment variable to to "http://+:8001" so that it binds the Web endpoint to port 8001 instead of 80

Summary

Implements the new method introduced in the projection store that retrieves all projection states in batches to allow large and a high number of projection states to be retrieved by a client. The implementation also streams states directly from the underlying MongoDB storage to avoid having to read all into memory before passing along to a client. This provides a fix for the issues of fetching a large number of projections crashing the SDKs.

Added

• A new GetAllInBatches method on the ProjectionStore service that streams the responses back to the client in dynamically sized batches of approximately 2MB. Singular projection states that are larger than 2MB are sent in their own batch, as the client might still accept larger gRPC messages.

Summary

Simplify the batch building logic so we are all happy.

Attempt to make the projection batching logic look cleaner

Summary

Adds a new MongoDB project with an extension method to create IAsyncEnumerable from a MongoDB query. Then uses this in the Projections Store interfaces so that we can pass along results to the new batching method without caching all the results in memory while we iterate.

Summary

Implement the GetAllInBatches method so that it splits the retrieved states into batches of ~2MB. It does protect against the case where a single state is bigger than that, as there is really nothing we can do at that point (we could throw an exception in the Runtime, but we could be lucky and the client accepts it). Also added some specs that check that it splits as expected, they do not verify the content of the messages right now.

Summary

Manually released new Docker Images that sets the ASPNETCORE_URLS environment variable to serve the Web endpoint on port 8001 by default, instead of 80. This caused issues when running the Runtime in our platform.

Fixed

• Sets the ASPNETCORE_URLS environment variable to to "http://+:8001" so that it binds the Web endpoint to port 8001 instead of 80