v2.3.0

This release brings improvements to the message streaming capabilities. Before, it was only possible to send a single message and receive either a single response or a stream of responses. Now we support sending streams as well.

Messenger now has 4 different methods:

• send for sending a single message and receiving a single response
• sendStream for sending a stream of messages without receiving any response (breaking change: this method was previously used for receiving a stream, you should use sendAndReceiveStream instead for that purpose)
• sendAndReceiveStream for sending a single message and receiving a stream of responses
• sendStreamAndReceiveStream for sending a stream of messages and receiving a stream of responses

With this release also come the following dependency upgrades:

• zio to 2.1.1
• sttp to 3.9.6
• caliban to 2.6.0
• zio-http to 3.0.0-RC6
• zio-grpc to 0.6.2
• grpc-netty to 1.63.0

What's Changed

• Bump Caliban to 2.6.0 by @frekw in #125
• Add terminology diagram to documentation by @calvinlfer in #126
• Upgrace grpc lib by @ghostdogpr in #127
• Allow sending streams and not just receiving them by @ghostdogpr in #121

New Contributors

• @calvinlfer made their first contribution in #126

Full Changelog: v2.2.7...v2.3.0

v2.2.7

This release contains the following changes:

• Fixed the assignedShards metric (missed it in 2.2.6) #124 by @ghostdogpr

v2.2.6

This release contains the following changes:

• Fixed the unassignedShards metric and renamed singletons metric tag from name to singleton_name #123 by @ghostdogpr

v2.2.5

This release contains the following changes:

• Allow setting a custom labelSelector in the k8s health api to filter pods. This is useful if you have several deployments in the same cluster and a given IP address might be reused by another service/environment. #119 by @ghostdogpr

v2.2.4

This release contains the following changes:

• Made the grpc server shutdown timeout configurable. By default, zio-grpc was using shutdown then awaitTermination without any timeout, which prevents new connections and wait for existing connections to end. The problem is that if those connections are grpc streams, we are waiting forever. Instead, we use awaitTermination with a timeout, then call shutdownNow to force the grpc server to shutdown and interrupt the grpc streams. #117 by @ghostdogpr

v2.2.3

This release contains the following changes:

• Added zio metrics for useful values and events. That lets you track easily rebalances, registered pods and shard assignments using the metrics backend of your choice. #116 by @ghostdogpr

v2.2.2

This release contains the following changes:

• Prevented spurious logs and double timeout in broadcastDiscard #115 by @ghostdogpr

v2.2.1

This release contains the following changes:

• Made the grpc executor configurable #113 by @ghostdogpr

v2.2.0

This release contains the following changes:

• Upgraded library dependencies, in particular Caliban to 2.5.3 which transitively depends on zio-http 3.0.0-RC4 #110 by @jgulotta
• Added the ability to set no timeout in Messenger. This changes the sendTimeout parameter from Option[Duration] to a small ADT that allows no timeout, a specific timeout or just using the global config timeout #112 by @ghostdogpr

v2.1.6

This release contains a bug fix:

• Fixed a bug introduced in 2.1.2, making the reply stream not being interrupted properly #111 by @ghostdogpr