-
Notifications
You must be signed in to change notification settings - Fork 23
Add Sinks Factory, Batched mode #208
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
In porting some prod code, I found client side was:
The solution on the Propulsion side was to define a This PR actually removes the On the client side, it's frequently useful to define a local set of aliases near ones one's Domain/Event parsing logic a la: This lets one refer to NOTE In the above, there are also helpers associated with the encoding used with the system in question. Having a top level I'm still searching for a better way to name/structure things such that client code does not end up having to be littered with Alongside this Again, this allows one to refer to |
|
@nordfjord related to jet/equinox#375 I am strongly considering renaming one of two ... but I don't like |
Add EquinoxSystemTextJsonParser.tryEnumStreamEvents Update straggler tupled/async APIs
remove statsInterval
Introduces a
Propulsion.Sinksnamespace to replacePropulsion.Streams.Default. Within that, the structure remains the same.Eventtype alias, withStreamSpanbeing removed in favour of usage ofEvent[]Sinks.Eventshelpers:index,nextIndex, which compute the base and post versions given the events supplied to the handler.SpanResult.OverrideWritePositionbecomesStreamResult.OverrideNextIndexConfigtoFactory(various internal helpers have similar renames)statsIntervalarguments that can be inferred based on thestatsargumentChoice<'res,exn>withResultAlso tweaks some function signatures and type aliases based on upgrading a production system that uses Propulsion V2 and Equinox V2.
EquinoxSystemTextJsonParser.tryEnumStreamEventsto facilitate custom parsingFunc/Task