This is an automated email from the ASF dual-hosted git repository.
frankgh pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-sidecar.git
from a2c19e8c CASSSIDECAR-219: Add CHANGES.txt and update release version
(#202)
add a789bf7d CASSSIDECAR-211: Config APIs for storing CDC/Kafka configs
for CDC feature (#193)
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 1 +
.../cassandra/sidecar/common/ApiEndpointsV1.java | 6 +
...oRequest.java => AllServicesConfigRequest.java} | 17 +-
...equest.java => DeleteServiceConfigRequest.java} | 13 +-
.../{UploadableRequest.java => Service.java} | 25 +-
...equest.java => UpdateServiceConfigRequest.java} | 27 +-
.../request/data/AllServicesConfigPayload.java | 105 ++++++
...est.java => UpdateCdcServiceConfigPayload.java} | 46 +--
.../cassandra/sidecar/client/SidecarClient.java | 46 +++
.../sidecar/client/SidecarClientTest.java | 59 ++++
.../testing/SharedClusterIntegrationTestBase.java | 12 +-
.../sidecar/routes/CdcConfigIntegrationTest.java | 127 +++++++
.../apache/cassandra/sidecar/cdc/CdcConfig.java | 153 +++++++++
.../cassandra/sidecar/cdc/CdcConfigImpl.java | 363 +++++++++++++++++++++
.../cassandra/sidecar/config/CdcConfiguration.java | 13 +
.../sidecar/config/yaml/CdcConfigurationImpl.java | 44 ++-
.../cassandra/sidecar/db/CdcConfigAccessor.java} | 43 +--
.../cassandra/sidecar/db/ConfigAccessor.java | 55 ++++
.../ConfigAccessorFactory.java} | 35 +-
.../cassandra/sidecar/db/ConfigAccessorImpl.java | 108 ++++++
.../cassandra/sidecar/db/KafkaConfigAccessor.java} | 43 +--
.../apache/cassandra/sidecar/db/ServiceConfig.java | 40 ++-
.../cassandra/sidecar/db/schema/ConfigsSchema.java | 143 ++++++++
.../routes/cdc/AllServiceConfigHandler.java | 73 +++++
.../sidecar/routes/cdc/ConfigPayloadParams.java | 14 +-
.../routes/cdc/DeleteServiceConfigHandler.java | 79 +++++
.../sidecar/routes/cdc/ServiceConfigValidator.java | 74 +++++
.../routes/cdc/UpdateServiceConfigHandler.java | 77 +++++
.../cassandra/sidecar/server/MainModule.java | 26 ++
.../org/apache/cassandra/sidecar/TestModule.java | 2 +-
.../cassandra/sidecar/cdc/CdcConfigImplTest.java | 232 +++++++++++++
.../sidecar/config/SidecarConfigurationTest.java | 3 +
.../sidecar/db/ConfigAccessorImplTest.java | 139 ++++++++
.../cassandra/sidecar/db/SidecarSchemaTest.java | 12 +-
server/src/test/resources/config/sidecar_cdc.yaml | 2 +
35 files changed, 2096 insertions(+), 161 deletions(-)
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/{GossipInfoRequest.java
=> AllServicesConfigRequest.java} (69%)
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/{CleanSSTableUploadSessionRequest.java
=> DeleteServiceConfigRequest.java} (70%)
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/{UploadableRequest.java
=> Service.java} (64%)
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/{NodeDecommissionRequest.java
=> UpdateServiceConfigRequest.java} (61%)
create mode 100644
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/data/AllServicesConfigPayload.java
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/request/data/{MD5Digest.java
=> UpdateCdcServiceConfigPayload.java} (54%)
create mode 100644
integration-tests/src/integrationTest/org/apache/cassandra/sidecar/routes/CdcConfigIntegrationTest.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcConfig.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcConfigImpl.java
copy
server/src/{test/integration/org/apache/cassandra/sidecar/db/SidecarSchemaIntTest.java
=> main/java/org/apache/cassandra/sidecar/db/CdcConfigAccessor.java} (50%)
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/db/ConfigAccessor.java
copy
server/src/main/java/org/apache/cassandra/sidecar/{routes/TimeSkewHandler.java
=> db/ConfigAccessorFactory.java} (51%)
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/db/ConfigAccessorImpl.java
copy
server/src/{test/integration/org/apache/cassandra/sidecar/db/SidecarSchemaIntTest.java
=> main/java/org/apache/cassandra/sidecar/db/KafkaConfigAccessor.java} (50%)
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/utils/StringUtils.java
=> server/src/main/java/org/apache/cassandra/sidecar/db/ServiceConfig.java
(51%)
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/db/schema/ConfigsSchema.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/routes/cdc/AllServiceConfigHandler.java
copy
client-common/src/main/java/org/apache/cassandra/sidecar/common/exceptions/RangeException.java
=>
server/src/main/java/org/apache/cassandra/sidecar/routes/cdc/ConfigPayloadParams.java
(75%)
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/routes/cdc/DeleteServiceConfigHandler.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/routes/cdc/ServiceConfigValidator.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/routes/cdc/UpdateServiceConfigHandler.java
create mode 100644
server/src/test/java/org/apache/cassandra/sidecar/cdc/CdcConfigImplTest.java
create mode 100644
server/src/test/java/org/apache/cassandra/sidecar/db/ConfigAccessorImplTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
