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

[Dashboard] Implement Topic and Event Management #1146

Merged
merged 15 commits into from
Aug 23, 2022

Conversation

xiaoyang-sde
Copy link
Member

@xiaoyang-sde xiaoyang-sde commented Aug 11, 2022

  • Created a new Admin interface for EventMesh Connector API.
  • Implement the API for Standalone and RocketMQ Connector plugin.
@EventMeshSPI(isSingleton = false, eventMeshExtensionType = EventMeshExtensionType.CONNECTOR)
public interface Admin extends LifeCycle {
    void init(Properties keyValue) throws Exception;

    List<TopicProperties> getTopic() throws Exception;

    void createTopic(String topicName) throws Exception;

    void deleteTopic(String topicName) throws Exception;

    List<CloudEvent> getEvent(String topicName, int offset, int length) throws Exception;

    void publish(CloudEvent cloudEvent) throws Exception;
}

Event Management

Screen Shot 2022-08-11 at 11 49 24 AM

Publish Event in Dashboard

Screen Shot 2022-08-11 at 11 49 48 AM

Topic Management

Screen Shot 2022-08-11 at 11 49 37 AM

Xiaoyang Liu added 3 commits August 10, 2022 10:21
Signed-off-by: Xiaoyang Liu <siujoeng.lau@gmail.com>
Signed-off-by: Xiaoyang Liu <siujoeng.lau@gmail.com>
Signed-off-by: Xiaoyang Liu <siujoeng.lau@gmail.com>
@xiaoyang-sde xiaoyang-sde self-assigned this Aug 11, 2022
Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

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

license-eye has totally checked 1141 files.

Valid Invalid Ignored Fixed
820 9 312 0
Click to see the invalid file list
  • eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
  • eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
  • eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
  • eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
  • eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
  • eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
  • eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
  • eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
  • eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQAdminWrapper.java

Xiaoyang Liu and others added 10 commits August 11, 2022 11:57
…va/org/apache/eventmesh/api/admin/Admin.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…va/org/apache/eventmesh/api/admin/TopicProperties.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…in/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…in/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…dmin/request/CreateTopicRequest.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…dmin/request/DeleteTopicRequest.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…ore/plugin/MQAdminWrapper.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Signed-off-by: Xiaoyang Liu <siujoeng.lau@gmail.com>
Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

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

license-eye has totally checked 1149 files.

Valid Invalid Ignored Fixed
835 2 312 0
Click to see the invalid file list
  • eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
  • eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java

Xiaoyang Liu and others added 2 commits August 11, 2022 11:06
…dmin/request/DeleteHTTPClientRequest.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
…dmin/request/DeleteGrpcClientRequest.java

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
@qqeasonchen
Copy link
Contributor

@xiaoyang-sde please pay attention to the CI check fail tasks.

@xiaoyang-sde xiaoyang-sde merged commit 670ab03 into dashboard Aug 23, 2022
xwm1992 pushed a commit to xwm1992/EventMesh that referenced this pull request Jan 4, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants