Skip to content

[Feature] Support subscription info management on Dashboard #4400

@lrhkobe

Description

@lrhkobe

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

dashboard(1)

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions