Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Cleanup leftovers for WAN replication SPI (#16052)
Cleanup leftovers for WAN replication SPI - removed Node parameter from WanReplicationConsumer. Node is private API and implementations may implement HazelcastInstanceAware to get something like configuration. - changed type of AbstractWanPublisherConfig.implementation to WanReplicationPublisher and WanConsumerConfig.implementation to WanReplicationConsumer. - moved republishReplicationEvent, publishAntiEntropyEvent, pause/stop/resume, getStats and removeWanEvents methods from public API. These methods are all related to our WAN implementation (WAN event republication, anti-entropy, lifecycle methods, statistics and clearing the WAN data) and the user need not implement these methods to have the simplest functioning WAN replication. Some of these are still exposed as REST URIs (clear, pause/stop/resume, sync...) but the REST handlers will be no-op in the case the user provides a custom publisher implementation. It may be possible we expose these methods as public SPI in the future so users may try to implement it and integrate with the REST handlers and other subsystems. - copied most migration and replication-related code from EE WanReplicationService to OS. This now allows the user to fully implement all methods on WAN publisher SPI, regardless if they are using OS or EE. - moved all migration and replication-related methods to a MigrationAwareWanReplicationPublisher interface. Now, if the user wants the publisher to participate in migrations and replication, they will need to implement this interface in addition to the WanReplicationPublisher. Because of this, WanReplicationPublisher is even simpler to implement. - Move WanSyncStats and ConsistencyCheckResult to private API Leftovers: - code duplication between OS and EE migration and replication related code. This can be addressed in a minor release. - exposing event data as public methods on WAN replication events
- Loading branch information
Showing
30 changed files
with
1,015 additions
and
284 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
102 changes: 102 additions & 0 deletions
102
hazelcast/src/main/java/com/hazelcast/wan/MigrationAwareWanReplicationPublisher.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,102 @@ | ||
| /* | ||
| * Copyright (c) 2008-2019, Hazelcast, Inc. All Rights Reserved. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package com.hazelcast.wan; | ||
|
|
||
| import com.hazelcast.internal.partition.PartitionMigrationEvent; | ||
| import com.hazelcast.internal.partition.PartitionReplicationEvent; | ||
| import com.hazelcast.internal.services.ServiceNamespace; | ||
|
|
||
| import java.util.Collection; | ||
| import java.util.Set; | ||
|
|
||
| /** | ||
| * Interface for WAN publisher migration related events. Can be implemented | ||
| * by WAN publishers to listen to migration events, for example to maintain | ||
| * the WAN event counters. | ||
| * <p> | ||
| * None of the methods of this interface is expected to block or fail. | ||
| * | ||
| * @param <T> WAN event container type (used for replication and migration inside the | ||
| * cluster) | ||
| * @see PartitionMigrationEvent | ||
| * @see com.hazelcast.internal.partition.MigrationAwareService | ||
| */ | ||
| public interface MigrationAwareWanReplicationPublisher<T> { | ||
| /** | ||
| * Indicates that migration started for a given partition | ||
| * | ||
| * @param event the migration event | ||
| */ | ||
| void onMigrationStart(PartitionMigrationEvent event); | ||
|
|
||
| /** | ||
| * Indicates that migration is committing for a given partition | ||
| * | ||
| * @param event the migration event | ||
| */ | ||
| void onMigrationCommit(PartitionMigrationEvent event); | ||
|
|
||
| /** | ||
| * Indicates that migration is rolling back for a given partition | ||
| * | ||
| * @param event the migration event | ||
| */ | ||
| void onMigrationRollback(PartitionMigrationEvent event); | ||
|
|
||
| /** | ||
| * Returns a container containing the WAN events for the given replication | ||
| * {@code event} and {@code namespaces} to be replicated. The replication | ||
| * here refers to the intra-cluster replication between members in a single | ||
| * cluster and does not refer to WAN replication, e.g. between two clusters. | ||
| * Invoked when migrating WAN replication data between members in a cluster. | ||
| * | ||
| * @param event the replication event | ||
| * @param namespaces namespaces which will be replicated | ||
| * @return the WAN event container | ||
| * @see #processEventContainerReplicationData(int, Object) | ||
| */ | ||
| default T prepareEventContainerReplicationData(PartitionReplicationEvent event, | ||
| Collection<ServiceNamespace> namespaces) { | ||
| return null; | ||
| } | ||
|
|
||
| /** | ||
| * Processes the WAN event container received through intra-cluster replication | ||
| * or migration. This method may completely remove existing WAN events for | ||
| * the given {@code partitionId} or it may append the given | ||
| * {@code eventContainer} to the existing events. | ||
| * Invoked when migrating WAN replication data between members in a cluster. | ||
| * | ||
| * @param partitionId partition ID which is being replicated or migrated | ||
| * @param eventContainer the WAN event container | ||
| * @see #prepareEventContainerReplicationData(PartitionReplicationEvent, Collection) | ||
| */ | ||
| default void processEventContainerReplicationData(int partitionId, T eventContainer) { | ||
| } | ||
|
|
||
| /** | ||
| * Collect the namespaces of all WAN event containers that should be replicated | ||
| * by the replication event. | ||
| * Invoked when migrating WAN replication data between members in a cluster. | ||
| * | ||
| * @param event the replication event | ||
| * @param namespaces the set in which namespaces should be added | ||
| */ | ||
| default void collectAllServiceNamespaces(PartitionReplicationEvent event, | ||
| Set<ServiceNamespace> namespaces) { | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.