public class CoordinatorRuleManager extends Object
Constructor and Description |
---|
CoordinatorRuleManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Supplier<TieredBrokerConfig> config,
DruidLeaderClient druidLeaderClient) |
Modifier and Type | Method and Description |
---|---|
List<Rule> |
getRulesWithDefault(String dataSource) |
boolean |
isStarted() |
void |
poll() |
void |
start() |
void |
stop() |
@Inject public CoordinatorRuleManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.google.common.base.Supplier<TieredBrokerConfig> config, DruidLeaderClient druidLeaderClient)
Copyright © 2011–2018. All rights reserved.