-
Notifications
You must be signed in to change notification settings - Fork 641
Closed
Labels
Description
Search before asking
- I had searched in the issues and found no similar issues.
Feature Request
Provide visual support for eventmesh subscription information management on the dashboard.
Components Interaction Diagram
Management Interface in EventMesh
- create topic
http://127.0.0.1:10105/eventmesh/topic/create
Request Method:Post
Params:application/json
{
"topic":"topic1;topic2"
}
Result:
{
"retMessage":"success",
"retCode":0
}
- delete topic
http://127.0.0.1:10105/eventmesh/topic/delete
Request Method:Post
Params:application/json
{
"topic":"topic1;topic2"
}
Result:
{
"retMessage":"success",
"retCode":0
}
- query subscription
http://127.0.0.1:10105/eventmesh/subscrition/query
Request Method:Get
Result:
{
"localTopicSet": ["topic1"],
"subsrciption": [{
"consumerGroup": "consumer-group-1111-AB0",
"topic": "topic1",
"subscriptionItem": {
"topic": "topic1",
"mode": "CLUSTERING",
"type": "ASYNC"
},
"idcUrls": {
"idc": ["http://127.0.0.1:8088/sub/test"]
},
"urls": ["http://127.0.0.1:8088/sub/test"],
"httpAuthTypeMap": {
}
}]
}
- subscribe
http://127.0.0.1:10105/eventmesh/subscribe/local
Request Method:Post
Params:application/json
{
"url":"http://127.0.0.1:8088/sub/test",
"consumerGroup":"group1",
"topic":[{
"mode":"CLUSTERING",
"topic":"topic1",
"type":"ASYNC"
}]
}
Result:
{
"retMessage": "success",
"retCode": 0
}
- unsubscribe
http://127.0.0.1:10105/eventmesh/unsubscribe/local
Request Method:Post
Params:application/json
{
"url":"http://127.0.0.1:8088",
"consumerGroup":"group1",
"topic":["topic1"]
}
Result:
{
"retMessage": "success",
"retCode": 0
}
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct *
Pil0tXia and mxsm
