This is an automated email from the ASF dual-hosted git repository.
apkhmv pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 38af0512c3 IGNITE-21855 Fix ItIndexAndIndexStorageDestructionTest
(#3503)
add ded415d544 IGNITE-21529 Implement log sink for EventLog (#3485)
No new revisions were added by this update.
Summary of changes:
gradle/libs.versions.toml | 2 +
.../src/testFixtures/resources/log4j2-test.xml | 17 +++-
modules/eventlog/build.gradle | 21 ++++
.../ItLogSinkConfigurationValidationTest.java | 89 +++++++++++++++++
.../ignite/internal/eventlog/api/EventFactory.java | 9 ++
.../config/EventLogConfigurationModule.java} | 17 ++--
.../schema/EventLogConfigurationSchema.java} | 13 ++-
.../config/schema/LogSinkConfigurationSchema.java} | 37 ++++---
.../config/schema/SinkConfigurationSchema.java} | 15 +--
.../ignite/internal/eventlog/event/EventImpl.java | 3 +
.../internal/eventlog/event/IgniteEvents.java | 5 +
.../internal/eventlog/ser/EventSerializer.java} | 13 ++-
.../internal/eventlog/ser/JsonEventSerializer.java | 110 +++++++++++++++++++++
.../ignite/internal/eventlog/sink/LogSink.java | 44 +++++++++
.../ignite/internal/eventlog/sink/Sink.java} | 34 ++++---
.../internal/eventlog/sink/SinkFactory.java} | 22 ++++-
.../internal/eventlog/event/EventBuilderTest.java | 1 -
.../eventlog/ser/JsonEventSerializerTest.java | 92 +++++++++++++++++
.../ignite/internal/eventlog/sink/LogSinkTest.java | 103 +++++++++++++++++++
19 files changed, 582 insertions(+), 65 deletions(-)
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/ItLogSinkConfigurationValidationTest.java
copy
modules/{metrics/src/main/java/org/apache/ignite/internal/metrics/configuration/MetricConfigurationModule.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/EventLogConfigurationModule.java}
(75%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/configuration/NodeAttributesConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/EventLogConfigurationSchema.java}
(76%)
copy
modules/{storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/configuration/schema/RocksDbDataStorageConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/LogSinkConfigurationSchema.java}
(52%)
copy
modules/{configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/injectedname/PolyConfigurationSchema.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/config/schema/SinkConfigurationSchema.java}
(74%)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/event/EventListener.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/EventSerializer.java}
(80%)
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/JsonEventSerializer.java
create mode 100644
modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/sink/LogSink.java
copy
modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/sample/ClusterWideConfigurationSchema.java
=> eventlog/src/main/java/org/apache/ignite/internal/eventlog/sink/Sink.java}
(50%)
copy
modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/ComponentNotStartedException.java
=>
eventlog/src/main/java/org/apache/ignite/internal/eventlog/sink/SinkFactory.java}
(58%)
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/JsonEventSerializerTest.java
create mode 100644
modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/sink/LogSinkTest.java
