Skip to content
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

feat: implemented multi-cluster NATS client #804

Merged
merged 18 commits into from
Jun 24, 2024

Conversation

bhavanakarwade
Copy link
Contributor

@bhavanakarwade bhavanakarwade commented Jun 22, 2024

What?

  • Implement Multi-Cluster NATS Client
  • Provide support for reconnect NATS Client
  • Implement NATS queue

Why?

  • Supporting multiple clusters in the NATS client enhances scalability and fault tolerance by allowing communication across different clusters, ensuring system robustness even if one cluster goes down.
  • Reconnect support in the NATS client ensures reliability by automatically re-establishing connections after a disruption, reducing downtime and maintaining consistent data flow.
  • Implementing a NATS queue allows for efficient task distribution and load balancing

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: bhavanakarwade <[email protected]>
@bhavanakarwade bhavanakarwade self-assigned this Jun 22, 2024
@bhavanakarwade bhavanakarwade added the enhancement New feature or request label Jun 22, 2024
@bhavanakarwade bhavanakarwade linked an issue Jun 22, 2024 that may be closed by this pull request
3 tasks
Copy link
Contributor

@tipusinghaw tipusinghaw left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@bhavanakarwade bhavanakarwade merged commit 65e6c45 into develop Jun 24, 2024
1 check passed
Copy link

sonarcloud bot commented Jun 24, 2024

@bhavanakarwade bhavanakarwade changed the title feat: implement multi-cluster NATS client feat: implemented multi-cluster NATS client Jun 24, 2024
KulkarniShashank pushed a commit that referenced this pull request Sep 6, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 11, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 11, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 11, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 11, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 12, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>
KulkarniShashank pushed a commit that referenced this pull request Sep 12, 2024
* wip: nats configuration

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: nats config function

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: implemented nats queue functionality

Signed-off-by: bhavanakarwade <[email protected]>

* wip: nats queue configurations

Signed-off-by: bhavanakarwade <[email protected]>

* feat: support nats queue

Signed-off-by: bhavanakarwade <[email protected]>

* fix: add logger

Signed-off-by: bhavanakarwade <[email protected]>

* refactor: added logger

Signed-off-by: bhavanakarwade <[email protected]>

* fix: remove unnecessary logs

Signed-off-by: bhavanakarwade <[email protected]>

* fix: added optional parameter

Signed-off-by: bhavanakarwade <[email protected]>

* feat: implement nats queue

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

feat: Implement multi-cluster NATS Client
2 participants