You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently our NATS streaming client does multiple things. On requester node side. it is used as a consumer of log messages coming via NATS and on compute node it acts as write, where it reads logs from appropriate execution engines and puts them as messages on NATS subject.
With this change we go with single responsibility per client and split the client into ConsumerClient and ProducerClient. This makes it easy and each client has single responsibility.
With this change we also add the logic of producer client sending heart beats to consumer client on a heart beat request subject, when a connection is made.
The text was updated successfully, but these errors were encountered:
What is this change about ?
Currently our NATS streaming client does multiple things. On requester node side. it is used as a consumer of log messages coming via NATS and on compute node it acts as write, where it reads logs from appropriate execution engines and puts them as messages on NATS subject.
With this change we go with single responsibility per client and split the client into
ConsumerClient
andProducerClient
. This makes it easy and each client has single responsibility.With this change we also add the logic of producer client sending heart beats to consumer client on a heart beat request subject, when a connection is made.
The text was updated successfully, but these errors were encountered: