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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
