rabbitmq-stream-go-client
rabbitmq-stream-go-client copied to clipboard
rabbitmq
A client library for RabbitMQ streams
Bumps [github.com/klauspost/compress](https://github.com/klauspost/compress) from 1.15.10 to 1.15.11. Release notes Sourced from github.com/klauspost/compress's releases. v1.15.11 What's Changed flate: Improve level 1-3 compression by @klauspost in klauspost/compress#678 zstd: Improve "best" compression by @nightwolfz...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Implement the Single-Active Consumer Feature https://www.rabbitmq.com/blog/2022/07/05/rabbitmq-3-11-feature-preview-single-active-consumer-for-streams
### Is your feature request related to a problem? Please describe. Based on the experience we gained with the DotNet stream client, I'd like to report some best practices we...
### Ideal Features - Consumer Context can contain chunk position + offset - Multiple Codec options, does not have to be external to the client - Message Handling must not...
https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/80ec3cc3d49b88fb3f11393daa403055cba269c5/pkg/raw/client.go#L684-L697 Setting the channel to `nil` comes at a risk of blocking infinitely if any receiver attempts to receive. > Receiving from a nil channel blocks forever. > > https://go.dev/ref/spec#Receive_operator...
https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/b7086877761337310b475db1a1809edbad2cdb30/pkg/raw/client.go#L1289-L1296 These functions could check that the client is not closed, nor closing. We could change the signature to return a channel and an error, and return a specific error...
@Zerpet I put in a basic graceful close mechanism for the Heartbeat done channel. I might still be susceptible to a race condition. The test passes without panicking at least!...
### Is your feature request related to a problem? Please describe. Based on our experience with the other clients in production I will report some features that we should have:...
### Is your feature request related to a problem? Please describe. See this TODO: https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/a6cced8d34031d77343331bf667e866e21004bea/pkg/stream/locator_test.go#L74 ### Describe the solution you'd like - [Setup](https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/a6cced8d34031d77343331bf667e866e21004bea/pkg/stream/locator.go#L30) - [shutdownHandler](https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/a6cced8d34031d77343331bf667e866e21004bea/pkg/stream/locator.go#L85) - [locatorOperation](https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/a6cced8d34031d77343331bf667e866e21004bea/pkg/stream/locator.go#L151)
### Is your feature request related to a problem? Please describe. The idea is to use Github Pages, write the essential documentation for the client, and use rabbitmq.com for details....