Package org.apache.druid.server.http

Class BrokerDynamicConfigSyncer

java.lang.Object

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

org.apache.druid.server.http.BrokerDynamicConfigSyncer

public class BrokerDynamicConfigSyncer
extends BaseDynamicConfigSyncer<BrokerDynamicConfig>

Syncs broker dynamic configuration to all brokers.

Constructor Summary

Constructors

Constructor	Description
BrokerDynamicConfigSyncer(ServiceClientFactory clientFactory, JacksonConfigManager 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 BrokerDynamicConfig	getCurrentConfig()	Get the current configuration to broadcast to brokers.
protected boolean	pushConfigToBroker(BrokerClient brokerClient, BrokerDynamicConfig 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

BrokerDynamicConfigSyncer

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

Method Details

getCurrentConfig

protected BrokerDynamicConfig getCurrentConfig()

Description copied from class: BaseDynamicConfigSyncer

Get the current configuration to broadcast to brokers.

Specified by:

getCurrentConfig in class BaseDynamicConfigSyncer<BrokerDynamicConfig>

pushConfigToBroker

protected boolean pushConfigToBroker(BrokerClient brokerClient,
 BrokerDynamicConfig 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<BrokerDynamicConfig>

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<BrokerDynamicConfig>