This is an automated email from the ASF dual-hosted git repository.
kezhenxu94 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
from 547f5f1 Add some defensive codes for NPE and bump up Kubernetes
client version to expose exception stack trace (#6327)
add b92eac2 Add a new concept "Event" and its implementations to collect
events (#6183)
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci-it.yaml | 5 +-
.github/workflows/e2e.event.yaml | 53 +++++
CHANGES.md | 1 +
README.md | 2 +-
docs/en/concepts-and-designs/README.md | 2 +
docs/en/concepts-and-designs/event.md | 56 +++++
docs/en/protocols/README.md | 3 +
docs/en/setup/backend/backend-receivers.md | 8 +-
docs/en/setup/backend/configuration-vocabulary.md | 1 +
oap-server/analyzer/{ => event-analyzer}/pom.xml | 26 +--
.../oap/server/analyzer/event/EventAnalyzer.java | 60 ++++++
.../analyzer/event/EventAnalyzerModule.java} | 21 +-
.../analyzer/event/EventAnalyzerModuleConfig.java} | 13 +-
.../event/EventAnalyzerModuleProvider.java | 70 +++++++
.../analyzer/event/EventAnalyzerService.java} | 15 +-
.../analyzer/event/EventAnalyzerServiceImpl.java | 50 +++++
.../event/listener/EventAnalyzerListener.java} | 26 ++-
.../EventAnalyzerListenerFactoryManager.java} | 16 +-
.../listener/EventRecordAnalyzerListener.java | 87 ++++++++
...ywalking.oap.server.library.module.ModuleDefine | 19 ++
...alking.oap.server.library.module.ModuleProvider | 19 ++
oap-server/analyzer/pom.xml | 3 +-
oap-server/server-bootstrap/pom.xml | 5 +
.../src/main/resources/application.yml | 8 +
.../server-bootstrap/src/main/resources/log4j2.xml | 1 +
.../skywalking/oap/server/core/CoreModule.java | 2 +
.../oap/server/core/CoreModuleProvider.java | 2 +
.../skywalking/oap/server/core/event/Event.java | 231 +++++++++++++++++++++
.../oap/server/core/query/EventQueryService.java | 59 ++++++
.../oap/server/core/query/type/event/Event.java | 62 ++++++
.../query/type/event/EventQueryCondition.java} | 32 ++-
.../server/core/query/type/event/EventType.java} | 20 +-
.../oap/server/core/query/type/event/Events.java} | 17 +-
.../oap/server/core/query/type/event/Source.java} | 21 +-
.../oap/server/core/source/DefaultScopeDefine.java | 4 +-
.../oap/server/core/storage/StorageModule.java | 4 +-
.../server/core/storage/query/IEventQueryDAO.java} | 17 +-
.../skywalking/oap/server/core/CoreModuleTest.java | 2 +-
oap-server/server-library/library-server/pom.xml | 2 +-
.../oap/query/graphql/GraphQLQueryProvider.java | 3 +
.../oap/query/graphql/resolver/EventQuery.java | 51 +++++
.../src/main/resources/query-protocol | 2 +-
oap-server/server-receiver-plugin/pom.xml | 3 +-
.../skywalking-event-receiver-plugin}/pom.xml | 23 +-
.../oap/server/receiver/event/EventModule.java} | 19 +-
.../server/receiver/event/EventModuleConfig.java} | 13 +-
.../server/receiver/event/EventModuleProvider.java | 75 +++++++
.../event/grpc/EventGrpcServiceHandler.java | 89 ++++++++
...ywalking.oap.server.library.module.ModuleDefine | 19 ++
...alking.oap.server.library.module.ModuleProvider | 19 ++
.../StorageModuleElasticsearchProvider.java | 4 +
.../elasticsearch/query/ESEventQueryDAO.java | 140 +++++++++++++
.../StorageModuleElasticsearch7Provider.java | 4 +
.../elasticsearch7/query/ES7EventQueryDAO.java | 50 +++++
.../plugin/influxdb/InfluxStorageProvider.java | 4 +
.../plugin/influxdb/query/EventQueryDAO.java | 164 +++++++++++++++
.../storage/plugin/jdbc/h2/H2StorageProvider.java | 4 +
.../plugin/jdbc/h2/dao/H2EventQueryDAO.java | 142 +++++++++++++
.../plugin/jdbc/mysql/MySQLStorageProvider.java | 4 +
.../plugin/jdbc/tidb/TiDBStorageProvider.java | 4 +
.../tool/profile/core/MockCoreModuleProvider.java | 3 +
.../apache/skywalking/e2e/SimpleQueryClient.java | 21 ++
.../skywalking/e2e/common/KeyValueMatcher.java | 2 +-
.../KeyValueMatcher.java => event/Event.java} | 61 +++---
.../org/apache/skywalking/e2e/event/EventData.java | 24 ++-
.../apache/skywalking/e2e/event/EventMatcher.java | 112 ++++++++++
.../apache/skywalking/e2e/event/EventsMatcher.java | 51 +++++
.../apache/skywalking/e2e/event/EventsQuery.java | 23 +-
test/e2e/e2e-data/src/main/resources/events.gql | 39 ++++
test/e2e/e2e-test/docker/Dockerfile.cli | 33 +++
.../{storage => event}/docker-compose.es6.yml | 0
.../{storage => event}/docker-compose.es7.0.yml | 0
.../{browser => event}/docker-compose.h2.yml | 0
.../{storage => event}/docker-compose.influxdb.yml | 0
.../{storage => event}/docker-compose.mysql.yml | 0
test/e2e/e2e-test/docker/event/docker-compose.yml | 56 +++++
.../org/apache/skywalking/e2e/event/EventE2E.java | 66 ++++++
.../src/test/resources/expected/event/events.yml | 30 +++
78 files changed, 2196 insertions(+), 206 deletions(-)
create mode 100644 .github/workflows/e2e.event.yaml
create mode 100644 docs/en/concepts-and-designs/event.md
copy oap-server/analyzer/{ => event-analyzer}/pom.xml (66%)
create mode 100644
oap-server/analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzer.java
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzerModule.java}
(65%)
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzerModuleConfig.java}
(73%)
create mode 100644
oap-server/analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzerModuleProvider.java
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzerService.java}
(73%)
create mode 100644
oap-server/analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/EventAnalyzerServiceImpl.java
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/listener/EventAnalyzerListener.java}
(53%)
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/listener/EventAnalyzerListenerFactoryManager.java}
(71%)
create mode 100644
oap-server/analyzer/event-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/event/listener/EventRecordAnalyzerListener.java
create mode 100644
oap-server/analyzer/event-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine
create mode 100644
oap-server/analyzer/event-analyzer/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider
create mode 100644
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/event/Event.java
create mode 100644
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/EventQueryService.java
create mode 100644
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/type/event/Event.java
copy
oap-server/server-core/src/{test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
main/java/org/apache/skywalking/oap/server/core/query/type/event/EventQueryCondition.java}
(52%)
copy
oap-server/server-core/src/{test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
main/java/org/apache/skywalking/oap/server/core/query/type/event/EventType.java}
(63%)
copy
oap-server/server-core/src/{test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
main/java/org/apache/skywalking/oap/server/core/query/type/event/Events.java}
(73%)
copy
oap-server/server-core/src/{test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
main/java/org/apache/skywalking/oap/server/core/query/type/event/Source.java}
(72%)
copy
oap-server/server-core/src/{test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
main/java/org/apache/skywalking/oap/server/core/storage/query/IEventQueryDAO.java}
(64%)
create mode 100644
oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/resolver/EventQuery.java
copy oap-server/{analyzer =>
server-receiver-plugin/skywalking-event-receiver-plugin}/pom.xml (73%)
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
server-receiver-plugin/skywalking-event-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/event/EventModule.java}
(69%)
copy
oap-server/{server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
server-receiver-plugin/skywalking-event-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/event/EventModuleConfig.java}
(73%)
create mode 100755
oap-server/server-receiver-plugin/skywalking-event-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/event/EventModuleProvider.java
create mode 100644
oap-server/server-receiver-plugin/skywalking-event-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/event/grpc/EventGrpcServiceHandler.java
create mode 100644
oap-server/server-receiver-plugin/skywalking-event-receiver-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleDefine
create mode 100644
oap-server/server-receiver-plugin/skywalking-event-receiver-plugin/src/main/resources/META-INF/services/org.apache.skywalking.oap.server.library.module.ModuleProvider
create mode 100644
oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/ESEventQueryDAO.java
create mode 100644
oap-server/server-storage-plugin/storage-elasticsearch7-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch7/query/ES7EventQueryDAO.java
create mode 100644
oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/query/EventQueryDAO.java
create mode 100644
oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2EventQueryDAO.java
copy
test/e2e/e2e-data/src/main/java/org/apache/skywalking/e2e/{common/KeyValueMatcher.java
=> event/Event.java} (53%)
copy
oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
test/e2e/e2e-data/src/main/java/org/apache/skywalking/e2e/event/EventData.java
(69%)
create mode 100644
test/e2e/e2e-data/src/main/java/org/apache/skywalking/e2e/event/EventMatcher.java
create mode 100644
test/e2e/e2e-data/src/main/java/org/apache/skywalking/e2e/event/EventsMatcher.java
copy
oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/CoreModuleTest.java
=>
test/e2e/e2e-data/src/main/java/org/apache/skywalking/e2e/event/EventsQuery.java
(68%)
create mode 100644 test/e2e/e2e-data/src/main/resources/events.gql
create mode 100644 test/e2e/e2e-test/docker/Dockerfile.cli
copy test/e2e/e2e-test/docker/{storage => event}/docker-compose.es6.yml (100%)
copy test/e2e/e2e-test/docker/{storage => event}/docker-compose.es7.0.yml
(100%)
copy test/e2e/e2e-test/docker/{browser => event}/docker-compose.h2.yml (100%)
copy test/e2e/e2e-test/docker/{storage => event}/docker-compose.influxdb.yml
(100%)
copy test/e2e/e2e-test/docker/{storage => event}/docker-compose.mysql.yml
(100%)
create mode 100644 test/e2e/e2e-test/docker/event/docker-compose.yml
create mode 100644
test/e2e/e2e-test/src/test/java/org/apache/skywalking/e2e/event/EventE2E.java
create mode 100644
test/e2e/e2e-test/src/test/resources/expected/event/events.yml
