Package org.apache.druid.server.http

Class CoordinatorDynamicConfigSyncer

java.lang.Object

org.apache.druid.server.http.BaseDynamicConfigSyncer<CoordinatorDynamicConfig>

org.apache.druid.server.http.CoordinatorDynamicConfigSyncer

public class CoordinatorDynamicConfigSyncer
extends BaseDynamicConfigSyncer<CoordinatorDynamicConfig>

Updates all brokers with the latest coordinator dynamic config.

Constructor Summary

Constructors

Constructor	Description
CoordinatorDynamicConfigSyncer(ServiceClientFactory clientFactory, CoordinatorConfigManager configManager, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, ServiceEmitter emitter)

Method Summary

Modifier and Type	Method	Description
protected String	getConfigTypeName()	Get the name of this config type for logging (e.g., "coordinator dynamic configuration", "broker dynamic configuration").
protected CoordinatorDynamicConfig	getCurrentConfig()	Get the current configuration to broadcast to brokers.
protected boolean	pushConfigToBroker(BrokerClient brokerClient, CoordinatorDynamicConfig config)	Push the config to a broker using the appropriate BrokerClient method.

Methods inherited from class org.apache.druid.server.http.BaseDynamicConfigSyncer

broadcastConfigToBrokers, getInSyncBrokers, onLeaderStart, onLeaderStop, queueBroadcastConfigToBrokers, stop

Methods inherited from class java.lang.Object

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

Constructor Details

CoordinatorDynamicConfigSyncer

@Inject
public CoordinatorDynamicConfigSyncer(ServiceClientFactory clientFactory,
 CoordinatorConfigManager configManager,
 com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
 DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
 ServiceEmitter emitter)

Method Details

getCurrentConfig

protected CoordinatorDynamicConfig getCurrentConfig()

Description copied from class: BaseDynamicConfigSyncer

Get the current configuration to broadcast to brokers.

Specified by:

getCurrentConfig in class BaseDynamicConfigSyncer<CoordinatorDynamicConfig>

pushConfigToBroker

protected boolean pushConfigToBroker(BrokerClient brokerClient,
 CoordinatorDynamicConfig config)
                              throws Exception

Description copied from class: BaseDynamicConfigSyncer

Push the config to a broker using the appropriate BrokerClient method.

Specified by:

pushConfigToBroker in class BaseDynamicConfigSyncer<CoordinatorDynamicConfig>

Returns:

true if the push was successful

Throws:

Exception

getConfigTypeName

protected String getConfigTypeName()

Description copied from class: BaseDynamicConfigSyncer

Get the name of this config type for logging (e.g., "coordinator dynamic configuration", "broker dynamic configuration").

Specified by:

getConfigTypeName in class BaseDynamicConfigSyncer<CoordinatorDynamicConfig>