io.druid.server.coordinator

Class ReplicationThrottler

java.lang.Object

io.druid.server.coordinator.ReplicationThrottler

public class ReplicationThrottler
extends Object

The ReplicationThrottler is used to throttle the number of replicants that are created and destroyed.

Constructor Summary

Constructors

Constructor and Description
ReplicationThrottler(int maxReplicants, int maxLifetime)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canCreateReplicant(String tier)
boolean	canDestroyReplicant(String tier)
void	registerReplicantCreation(String tier, String segmentId, String serverId)
void	registerReplicantTermination(String tier, String segmentId, String serverId)
void	unregisterReplicantCreation(String tier, String segmentId, String serverId)
void	unregisterReplicantTermination(String tier, String segmentId, String serverId)
void	updateParams(int maxReplicants, int maxLifetime)
void	updateReplicationState(String tier)
void	updateTerminationState(String tier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicationThrottler

public ReplicationThrottler(int maxReplicants,
                    int maxLifetime)

Method Detail

updateParams

public void updateParams(int maxReplicants,
                int maxLifetime)

updateReplicationState

public void updateReplicationState(String tier)

updateTerminationState

public void updateTerminationState(String tier)

canCreateReplicant

public boolean canCreateReplicant(String tier)

canDestroyReplicant

public boolean canDestroyReplicant(String tier)

registerReplicantCreation

public void registerReplicantCreation(String tier,
                             String segmentId,
                             String serverId)

unregisterReplicantCreation

public void unregisterReplicantCreation(String tier,
                               String segmentId,
                               String serverId)

registerReplicantTermination

public void registerReplicantTermination(String tier,
                                String segmentId,
                                String serverId)

unregisterReplicantTermination

public void unregisterReplicantTermination(String tier,
                                  String segmentId,
                                  String serverId)