You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2023/01/05 02:28:58 UTC

[incubator-eventmesh] 01/01: Merge pull request #2821 from apache/dashboard

This is an automated email from the ASF dual-hosted git repository.

chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git

commit 14e14d2830ae8ba217402b1a83d90a49d36cdb63
Merge: c2c7038a8 6494f36f2
Author: Eason Chen <qq...@gmail.com>
AuthorDate: Thu Jan 5 10:28:51 2023 +0800

    Merge pull request #2821 from apache/dashboard
    
    [ISSUE #2827] Merge Dashboard branch to master

 build.gradle                                       |   7 +-
 .../java/org/apache/eventmesh/api/admin/Admin.java |  69 ++++
 .../eventmesh/api/admin/TopicProperties.java       |  38 +++
 .../api/factory/ConnectorPluginFactory.java        |  12 +-
 .../eventmesh-connector-rocketmq/build.gradle      |  26 +-
 .../eventmesh-connector-rocketmq/gradle.properties |   2 -
 .../connector/rocketmq/admin/RocketMQAdmin.java    | 171 ++++++++++
 .../rocketmq/admin/RocketMQAdminAdaptor.java       |  86 +++++
 .../connector/rocketmq/admin/command/Command.java  |  52 ---
 .../rocketmq/admin/command/CreateTopicCommand.java |  84 -----
 .../cloudevent/RocketMQMessageFactory.java         |  10 +-
 .../impl/RocketMQBinaryMessageReader.java          |   4 +-
 .../rocketmq/cloudevent/impl/RocketMQHeaders.java  |   4 +-
 .../cloudevent/impl/RocketMQMessageWriter.java     |   6 +-
 .../rocketmq/config/ClientConfiguration.java       |  62 ++--
 .../rocketmq/producer/AbstractProducer.java        |  38 +--
 .../org.apache.eventmesh.api.admin.Admin}          |   4 +-
 .../rocketmq/consumer/PushConsumerImplTest.java    |   4 +-
 .../eventmesh-connector-standalone/build.gradle    |   2 +-
 .../gradle.properties                              |   1 -
 .../standalone/admin/StandaloneAdmin.java          | 121 +++++++
 .../standalone/admin/StandaloneAdminAdaptor.java   |  86 +++++
 .../connector/standalone/broker/MessageQueue.java  |   8 +
 .../standalone/broker/StandaloneBroker.java        |  23 +-
 .../standalone/broker/model/TopicMetadata.java     |  11 +-
 .../standalone/broker/task/SubScribeTask.java      |   8 +-
 .../standalone/producer/StandaloneProducer.java    |  18 +-
 .../org.apache.eventmesh.api.admin.Admin}          |   4 +-
 .../standalone/broker/StandaloneBrokerTest.java    |  16 +-
 eventmesh-dashboard/.eslintrc.js                   |  53 +++
 eventmesh-dashboard/.gitignore                     | 132 ++++++++
 eventmesh-dashboard/README.md                      |  34 ++
 .../components/client/GrpcClientTable.tsx          | 217 ++++++++++++
 .../components/client/HTTPClientTable.tsx          | 217 ++++++++++++
 .../components/client/TCPClientTable.tsx           | 223 +++++++++++++
 .../components/event/EventTable.tsx                | 371 +++++++++++++++++++++
 .../components/index/Configuration.tsx             | 259 ++++++++++++++
 eventmesh-dashboard/components/index/Endpoint.tsx  | 105 ++++++
 .../components/metrics/MetricsTable.tsx            | 313 +++++++++++++++++
 .../components/navigation/MenuItem.tsx             |  98 ++++++
 .../components/navigation/Menus.tsx                | 160 +++++++++
 .../components/navigation/MenusMobile.tsx          |  39 +++
 .../components/navigation/Sidebar.tsx              |  63 ++++
 .../components/registry/RegistryTable.tsx          | 170 ++++++++++
 .../components/topic/TopicTable.tsx                | 275 +++++++++++++++
 eventmesh-dashboard/context/context.tsx            |  87 +++++
 eventmesh-dashboard/context/reducer.ts             |  40 +++
 eventmesh-dashboard/context/type.ts                |  40 +++
 eventmesh-dashboard/next.config.js                 |  25 ++
 eventmesh-dashboard/package.json                   |  44 +++
 eventmesh-dashboard/pages/_app.tsx                 |  46 +++
 eventmesh-dashboard/pages/_document.tsx            |  38 +++
 eventmesh-dashboard/pages/event.tsx                |  33 ++
 .../pages/eventCatalogs/EventCatalogs.tsx          | 123 +++++++
 .../pages/eventCatalogs/SchemaView.tsx             | 134 ++++++++
 eventmesh-dashboard/pages/eventCatalogs/index.ts   |   3 +
 eventmesh-dashboard/pages/eventCatalogs/types.ts   |   5 +
 eventmesh-dashboard/pages/grpc.tsx                 |  33 ++
 eventmesh-dashboard/pages/http.tsx                 |  33 ++
 eventmesh-dashboard/pages/index.tsx                |  35 ++
 eventmesh-dashboard/pages/metrics.tsx              |  33 ++
 eventmesh-dashboard/pages/registry.tsx             |  33 ++
 eventmesh-dashboard/pages/tcp.tsx                  |  33 ++
 eventmesh-dashboard/pages/topic.tsx                |  33 ++
 eventmesh-dashboard/pages/workflows/create.tsx     |  93 ++++++
 eventmesh-dashboard/pages/workflows/details.tsx    |  93 ++++++
 eventmesh-dashboard/pages/workflows/index.ts       |   3 +
 eventmesh-dashboard/pages/workflows/workflows.tsx  | 115 +++++++
 eventmesh-dashboard/public/favicon.ico             | Bin 0 -> 25931 bytes
 eventmesh-dashboard/static/images/logo.png         | Bin 0 -> 58522 bytes
 eventmesh-dashboard/tsconfig.json                  |  20 ++
 eventmesh-runtime/build.gradle                     |   1 +
 .../admin/controller/EventMeshAdminController.java |  81 +++++
 .../admin/handler/ConfigurationHandler.java        | 140 ++++++++
 .../runtime/admin/handler/EventHandler.java        | 200 +++++++++++
 .../runtime/admin/handler/GrpcClientHandler.java   | 194 +++++++++++
 .../runtime/admin/handler/HTTPClientHandler.java   | 184 ++++++++++
 .../runtime/admin/handler/MetricsHandler.java      | 152 +++++++++
 .../runtime/admin/handler/RegistryHandler.java     | 124 +++++++
 .../runtime/admin/handler/TCPClientHandler.java    | 200 +++++++++++
 .../runtime/admin/handler/TopicHandler.java        | 197 +++++++++++
 .../runtime/admin/request/CreateTopicRequest.java  |  35 ++
 .../admin/request/DeleteGrpcClientRequest.java     |  35 ++
 .../admin/request/DeleteHTTPClientRequest.java     |  35 ++
 .../admin/request/DeleteTCPClientRequest.java      |  38 +++
 .../runtime/admin/request/DeleteTopicRequest.java  |  35 ++
 .../eventmesh/runtime/admin/response/Error.java    |  23 +-
 .../runtime/admin/response/GetClientResponse.java  |  63 ++++
 .../admin/response/GetConfigurationResponse.java   | 104 ++++++
 .../runtime/admin/response/GetMetricsResponse.java | 160 +++++++++
 .../admin/response/GetRegistryResponse.java        |  46 +++
 .../runtime/admin/utils/HttpExchangeUtils.java     |  43 +++
 .../eventmesh/runtime/admin/utils/JsonUtils.java   |  71 ++++
 .../runtime/core/plugin/MQAdminWrapper.java        | 105 ++++++
 .../protocol/grpc/consumer/ConsumerManager.java    |   4 +
 .../consumergroup/ConsumerGroupClient.java         |  20 +-
 .../protocol/http/consumer/ConsumerManager.java    |   4 +
 .../eventmesh/spi/EventMeshExtensionFactory.java   |   1 -
 98 files changed, 6908 insertions(+), 268 deletions(-)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org