You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@eventmesh.apache.org by GitBox <gi...@apache.org> on 2021/08/08 11:03:36 UTC
[GitHub] [incubator-eventmesh] lrhkobe opened a new issue #488: Support rebalance among clients with same group and Eventmesh recommendation when connect
lrhkobe opened a new issue #488:
URL: https://github.com/apache/incubator-eventmesh/issues/488
## Feature Request
### Is your feature request related to a problem? Please describe
The client randomly selects eventmesh from the address list to establish a connection. As to the client with same group , they may connect the same eventmesh, or the distribution of clients will be hugely uneven.Therefore, it may lead unbalanced flow on eventmesh.
### Describe the solution you'd like
1. Add `eventmesh-registry-plugin` module refers to `eventmesh-connector-plugin`, `eventmesh-registry-plugin` contains registry api design module and concrete registry plugin implementation module;
2. I will provide a simple API interface design in `eventmesh-registry-api` module , support rebalance among clients with same group, and recommend eventmesh before connecting in the `eventmesh-runtime` by calling the API interface.
3. In order to avoid eventmesh running error , I provide a plugin(`eventmesh-registry-namesrv`) of the default empty implementation of the `eventmesh-registry-api`, as to this plugin implemention, you can consider your own requirements.If you are interested in this issue, welcome to participate and suggestions.
Firstly, Every eventmesh will report the distribution data of clients to registry periodly;
Then registry can know the distribution data of clients with same group in different eventmesh.
At last, Eventmesh can do rebalance by the distribution data from registry and recommend eventmesh to client when connect.
### API interface design in eventmesh-registry-api
```
@EventMeshSPI(isSingleton = true)
public interface RegistryService {
void init() throws RegistryException;
void start() throws RegistryException;
void shutdown() throws RegistryException;
List<EventMeshDataInfo> findEventMeshInfoByCluster(String clusterName) throws RegistryException;
Map<String/*eventMeshName*/, Map<String/*purpose*/, Integer/*num*/>> findEventMeshClientDistributionData(String clusterName, String group, String purpose) throws RegistryException;
boolean register(EventMeshRegisterInfo eventMeshRegisterInfo) throws RegistryException;
boolean unRegister(EventMeshUnRegisterInfo eventMeshUnRegisterInfo) throws RegistryException;
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] lrhkobe commented on issue #488: Support registry adaptor plugin
Posted by GitBox <gi...@apache.org>.
lrhkobe commented on issue #488:
URL: https://github.com/apache/incubator-eventmesh/issues/488#issuecomment-898238782
EventmeshRuntime reports the data to every registry of the same cluster. Notification mechanism maybe exist the problem of repeated notification.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] ruanwenjun commented on issue #488: Support registry adaptor plugin
Posted by GitBox <gi...@apache.org>.
ruanwenjun commented on issue #488:
URL: https://github.com/apache/incubator-eventmesh/issues/488#issuecomment-894919449
I think we may need to add a notify method in RegistryService interface.
Then we needn't query by time polling.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] xwm1992 closed issue #488: Support registry adaptor plugin
Posted by GitBox <gi...@apache.org>.
xwm1992 closed issue #488:
URL: https://github.com/apache/incubator-eventmesh/issues/488
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] ruanwenjun edited a comment on issue #488: Support registry adaptor plugin
Posted by GitBox <gi...@apache.org>.
ruanwenjun edited a comment on issue #488:
URL: https://github.com/apache/incubator-eventmesh/issues/488#issuecomment-894919449
I think we may need to add a notify method in RegistryService interface.
```java
void notify(Listener listener) throws RegistryException;
```
Then we needn't query by time polling.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org