Dapr.EventStore
Dapr.EventStore copied to clipboard
perokvist
Demo implementation of an naive EventStore with DaprClient (as feedback)
Add surface api to read the all stream for OffAndSharedAll mode.
StateTransactionRequest stores value byte serialized, even if meta is set to json. `var headReq = new StateTransactionRequest(streamHeadKey, JsonSerializer.SerializeToUtf8Bytes(head), Client.StateOperationType.Upsert, metadata: meta,`
The Cosmos REST api is limited when using Query Api sort.
Replace "long" with explicit version; FromStart FromVersion(inclusive)
Add an option to read the "current" slice to check for duplicate events, when appending.