io.druid.server.router

Class TieredBrokerHostSelector<T>

java.lang.Object

io.druid.server.router.TieredBrokerHostSelector<T>

All Implemented Interfaces:

HostSelector<T>

public class TieredBrokerHostSelector<T>
extends Object
implements HostSelector<T>

Constructor Summary

Constructors

Constructor and Description
TieredBrokerHostSelector(CoordinatorRuleManager ruleManager, TieredBrokerConfig tierConfig, ServerDiscoveryFactory serverDiscoveryFactory, List<TieredBrokerSelectorStrategy> strategies)

Method Summary

Modifier and Type	Method and Description
Map<String,ServerDiscoverySelector>	getAllBrokers()
Pair<String,ServerDiscoverySelector>	getDefaultLookup()
String	getDefaultServiceName()
Pair<String,ServerDiscoverySelector>	select(Query<T> query)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TieredBrokerHostSelector

@Inject
public TieredBrokerHostSelector(CoordinatorRuleManager ruleManager,
                                        TieredBrokerConfig tierConfig,
                                        ServerDiscoveryFactory serverDiscoveryFactory,
                                        List<TieredBrokerSelectorStrategy> strategies)

Method Detail

start

public void start()

stop

public void stop()

getDefaultServiceName

public String getDefaultServiceName()

Specified by:

getDefaultServiceName in interface HostSelector<T>

select

public Pair<String,ServerDiscoverySelector> select(Query<T> query)

Specified by:

select in interface HostSelector<T>

getDefaultLookup

public Pair<String,ServerDiscoverySelector> getDefaultLookup()

getAllBrokers

public Map<String,ServerDiscoverySelector> getAllBrokers()