substrate
substrate copied to clipboard
uw-labs
A message broker abstraction for Go
This would allow using simplified version of sink creation with ability to modify config with FuncKeys and other options not available in current flow.
Hello (from a UW newcomer), I do like substrate but there's something I really puzzled with. Let's say I have the following use case (for integration testing or whatever): *...
This gives the user more control on how often the sink will flush. Using ticker instead of timer makes the implementation simpler and makes sure messages gets flushed periodically.
Add experimental version of synchronous sink adapter that automatically reconnects on failures using the provided backoff strategy. It also periodically checks the status of the underlying async sink and reconnects...
Connection to Nats streaming are always done using durable groups. This is problematic in cases where the client ID of the subscriber is not the same on reconnection (new pod...
https://github.com/uw-labs/substrate/blob/67626b38e3a2382235b2307e2b82d50f297cec6b/natsstreaming/nats_streaming.go#L173 This type of convenience can introduce unwanted behaviour upon re-connections and should not be silently ignored. It is preferable for the client to generate its own random id when...
Bumps [github.com/docker/distribution](https://github.com/docker/distribution) from 2.8.1+incompatible to 2.8.2+incompatible. Release notes Sourced from github.com/docker/distribution's releases. v2.8.2 What's Changed Revert registry/client: set Accept: identity header when getting layers by @ndeloof in distribution/distribution#3783 Parse http...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [github.com/opencontainers/runc](https://github.com/opencontainers/runc) from 1.1.3 to 1.1.5. Release notes Sourced from github.com/opencontainers/runc's releases. runc 1.1.5 -- "囚われた屈辱は 反撃の嚆矢だ" This is the fifth patch release in the 1.1.z series of runc, which...