This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from c2c7038a8 col.isEmpty() (#2817)
add fc324981a Apache EventMesh Dashboard - Client Management (#907)
add d5236405a Add sourceCompatibility field to build.gradle
add b86662175 Implement the configuration in Dashboard
add 8d2da91aa Implement the configuration for protocols
add 0d224924a Merge pull request #1046 from apache/dashboard-configuration
add 54a1a5cf0 [Issue #700] Dashboard: Display Eventmesh Metrics (#1135)
add 0c6fcd002 Implement the EventMesh connector admin API
add 075259975 Implement the Topic Management for Standalone
add 3d57cb3c3 Implement the Event Management for Standalone
add 7c413ac96 Update
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
add 86bad8c6d Update
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
add cca5c8fe5 Update
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
add b04b5a9b1 Update
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
add 0e499499d Update
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
add ba3a6843f Update
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
add 03ce56c39 Update
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
add 868cd2138 Update
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
add e09138c2a Update
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQAdminWrapper.java
add ade1e21f1 Improve the client management
add 8ce044b4b Update
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java
add 30f58bf71 Update
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
add 86f963d37 [Dashboard] Implement Topic and Event Management (#1146)
add 042a5e696 implemented registry handler
add 08fbd8b81 Implemented registry page
add ef326a71a minor UI improvements
add 49f5bfd46 more minor UI fixes
add 43886c788 linted typescript files
add bcf57b4d2 fixed dynamic table update
add ca55d942c fixed checkstyle errors
add a5a82a082 checkstyle fix
add 370f9b60b fixed endpoint persistence
add 52e74fa4c Merge pull request #1168 from RSTdefg/dashboard-registry
add e5ba5c8d5 Merge branch 'dashboard' into dashboard-event
add b7d003311 Merge pull request #2750 from apache/dashboard-event
add 3e4c7b2a5 [Dashboard] Feature - Changed Change the style of navigation
menu - Added Workflow, Event Catalog menu items - Ignored vscode settings
add f39f72996 [Dashboard] Feature - Added Workflows
add f7a64fd4c [Dashboard] Feature - Added event catalogs
add a5292ff36 Merge pull request #2809 from SLSJL/dashboard
add 0f6e2a35e Merge branch 'apache:dashboard' into dashboard
add 900c6c15a Merge pull request #2810 from SLSJL/dashboard
add 6494f36f2 Fix master branch conflicts
new 14e14d283 Merge pull request #2821 from apache/dashboard
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 7 +-
.../java/org/apache/eventmesh/api/admin/Admin.java | 69 ++++
.../eventmesh/api/admin/TopicProperties.java | 32 +-
.../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} | 6 +-
.../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} | 6 +-
.../standalone/broker/StandaloneBrokerTest.java | 16 +-
.../.eslintrc.js | 55 +--
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 +++++
.../context/reducer.ts | 34 +-
.../context/type.ts | 36 +-
.../next.config.js | 25 +-
eventmesh-dashboard/package.json | 44 +++
.../pages/_app.tsx | 42 ++-
.../pages/_document.tsx | 36 +-
.../pages/event.tsx | 31 +-
.../pages/eventCatalogs/EventCatalogs.tsx | 123 +++++++
.../pages/eventCatalogs/SchemaView.tsx | 134 ++++++++
eventmesh-dashboard/pages/eventCatalogs/index.ts | 3 +
eventmesh-dashboard/pages/eventCatalogs/types.ts | 5 +
.../pages/grpc.tsx | 31 +-
.../pages/http.tsx | 31 +-
.../pages/index.tsx | 33 +-
.../pages/metrics.tsx | 31 +-
.../pages/registry.tsx | 31 +-
.../pages/tcp.tsx | 31 +-
.../pages/topic.tsx | 31 +-
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
.../static}/images/logo.png | Bin
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 +++++++++++
.../request/CreateTopicRequest.java} | 29 +-
.../request/DeleteGrpcClientRequest.java} | 29 +-
.../request/DeleteHTTPClientRequest.java} | 29 +-
.../request/DeleteTCPClientRequest.java} | 32 +-
.../request/DeleteTopicRequest.java} | 29 +-
.../eventmesh/runtime/admin/response/Error.java | 43 +--
.../runtime/admin/response/GetClientResponse.java | 63 ++++
.../admin/response/GetConfigurationResponse.java | 104 ++++++
.../runtime/admin/response/GetMetricsResponse.java | 160 +++++++++
.../admin/response/GetRegistryResponse.java | 39 ++-
.../utils/HttpExchangeUtils.java} | 35 +-
.../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, 6422 insertions(+), 697 deletions(-)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
(63%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/CreateTopicCommand.java
copy eventmesh-connector-plugin/{eventmesh-connector-kafka/gradle.properties
=>
eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin}
(91%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
copy eventmesh-connector-plugin/{eventmesh-connector-kafka/gradle.properties
=>
eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin}
(90%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/.eslintrc.js (56%)
create mode 100644 eventmesh-dashboard/.gitignore
create mode 100644 eventmesh-dashboard/README.md
create mode 100644 eventmesh-dashboard/components/client/GrpcClientTable.tsx
create mode 100644 eventmesh-dashboard/components/client/HTTPClientTable.tsx
create mode 100644 eventmesh-dashboard/components/client/TCPClientTable.tsx
create mode 100644 eventmesh-dashboard/components/event/EventTable.tsx
create mode 100755 eventmesh-dashboard/components/index/Configuration.tsx
create mode 100755 eventmesh-dashboard/components/index/Endpoint.tsx
create mode 100755 eventmesh-dashboard/components/metrics/MetricsTable.tsx
create mode 100644 eventmesh-dashboard/components/navigation/MenuItem.tsx
create mode 100644 eventmesh-dashboard/components/navigation/Menus.tsx
create mode 100644 eventmesh-dashboard/components/navigation/MenusMobile.tsx
create mode 100644 eventmesh-dashboard/components/navigation/Sidebar.tsx
create mode 100644 eventmesh-dashboard/components/registry/RegistryTable.tsx
create mode 100644 eventmesh-dashboard/components/topic/TopicTable.tsx
create mode 100644 eventmesh-dashboard/context/context.tsx
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/context/reducer.ts (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/context/type.ts (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/next.config.js (64%)
create mode 100644 eventmesh-dashboard/package.json
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/_app.tsx (53%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/_document.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/event.tsx (64%)
create mode 100644 eventmesh-dashboard/pages/eventCatalogs/EventCatalogs.tsx
create mode 100644 eventmesh-dashboard/pages/eventCatalogs/SchemaView.tsx
create mode 100644 eventmesh-dashboard/pages/eventCatalogs/index.ts
create mode 100644 eventmesh-dashboard/pages/eventCatalogs/types.ts
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/grpc.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/http.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/index.tsx (64%)
mode change 100644 => 100755
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/metrics.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/registry.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/tcp.tsx (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventHttpHandler.java
=> eventmesh-dashboard/pages/topic.tsx (64%)
create mode 100644 eventmesh-dashboard/pages/workflows/create.tsx
create mode 100644 eventmesh-dashboard/pages/workflows/details.tsx
create mode 100644 eventmesh-dashboard/pages/workflows/index.ts
create mode 100644 eventmesh-dashboard/pages/workflows/workflows.tsx
create mode 100644 eventmesh-dashboard/public/favicon.ico
copy {docs => eventmesh-dashboard/static}/images/logo.png (100%)
create mode 100644 eventmesh-dashboard/tsconfig.json
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/controller/EventMeshAdminController.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ConfigurationHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/EventHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/GrpcClientHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/HTTPClientHandler.java
create mode 100755
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/MetricsHandler.java
create mode 100755
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RegistryHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TCPClientHandler.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TopicHandler.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/request/CreateTopicRequest.java} (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/request/DeleteGrpcClientRequest.java} (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/request/DeleteHTTPClientRequest.java} (64%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/request/DeleteTCPClientRequest.java} (63%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/request/DeleteTopicRequest.java} (64%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/Error.java
(62%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetClientResponse.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetConfigurationResponse.java
create mode 100755
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetMetricsResponse.java
copy
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/request/TopicCreateRequest.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetRegistryResponse.java
(53%)
mode change 100644 => 100755
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{common/EventHttpHandler.java
=> admin/utils/HttpExchangeUtils.java} (52%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/utils/JsonUtils.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQAdminWrapper.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
