Class JoinHelper
- java.lang.Object
-
- org.elasticsearch.cluster.coordination.JoinHelper
-
public class JoinHelper extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
JoinHelper.JoinCallback
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
JOIN_ACTION_NAME
static Setting<TimeValue>
JOIN_TIMEOUT_SETTING
static java.lang.String
START_JOIN_ACTION_NAME
static java.lang.String
VALIDATE_JOIN_ACTION_NAME
-
Constructor Summary
Constructors Constructor Description JoinHelper(Settings settings, AllocationService allocationService, MasterService masterService, TransportService transportService, java.util.function.LongSupplier currentTermSupplier, java.util.function.Supplier<ClusterState> currentStateSupplier, java.util.function.BiConsumer<JoinRequest,JoinHelper.JoinCallback> joinHandler, java.util.function.Function<StartJoinRequest,Join> joinLeaderInTerm, java.util.Collection<java.util.function.BiConsumer<DiscoveryNode,ClusterState>> joinValidators)
-
Method Summary
Modifier and Type Method Description void
sendJoinRequest(DiscoveryNode destination, java.util.Optional<Join> optionalJoin)
void
sendJoinRequest(DiscoveryNode destination, java.util.Optional<Join> optionalJoin, java.lang.Runnable onCompletion)
void
sendStartJoinRequest(StartJoinRequest startJoinRequest, DiscoveryNode destination)
void
sendValidateJoinRequest(DiscoveryNode node, ClusterState state, ActionListener<TransportResponse.Empty> listener)
-
-
-
Field Detail
-
JOIN_ACTION_NAME
public static final java.lang.String JOIN_ACTION_NAME
- See Also:
- Constant Field Values
-
VALIDATE_JOIN_ACTION_NAME
public static final java.lang.String VALIDATE_JOIN_ACTION_NAME
- See Also:
- Constant Field Values
-
START_JOIN_ACTION_NAME
public static final java.lang.String START_JOIN_ACTION_NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
JoinHelper
public JoinHelper(Settings settings, AllocationService allocationService, MasterService masterService, TransportService transportService, java.util.function.LongSupplier currentTermSupplier, java.util.function.Supplier<ClusterState> currentStateSupplier, java.util.function.BiConsumer<JoinRequest,JoinHelper.JoinCallback> joinHandler, java.util.function.Function<StartJoinRequest,Join> joinLeaderInTerm, java.util.Collection<java.util.function.BiConsumer<DiscoveryNode,ClusterState>> joinValidators)
-
-
Method Detail
-
sendJoinRequest
public void sendJoinRequest(DiscoveryNode destination, java.util.Optional<Join> optionalJoin)
-
sendJoinRequest
public void sendJoinRequest(DiscoveryNode destination, java.util.Optional<Join> optionalJoin, java.lang.Runnable onCompletion)
-
sendStartJoinRequest
public void sendStartJoinRequest(StartJoinRequest startJoinRequest, DiscoveryNode destination)
-
sendValidateJoinRequest
public void sendValidateJoinRequest(DiscoveryNode node, ClusterState state, ActionListener<TransportResponse.Empty> listener)
-
-