public class BrokerServerView extends Object implements TimelineServerView
TimelineServerView.TimelineCallback
ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerRemovedCallback
Constructor and Description |
---|
BrokerServerView(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
FilteredServerInventoryView baseView,
TierSelectorStrategy tierSelectorStrategy,
ServiceEmitter emitter,
BrokerSegmentWatcherConfig segmentWatcherConfig) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
<T> QueryRunner<T> |
getQueryRunner(DruidServer server) |
VersionedIntervalTimeline<String,ServerSelector> |
getTimeline(DataSource dataSource) |
boolean |
isInitialized() |
void |
registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback) |
void |
registerServerRemovedCallback(Executor exec,
ServerView.ServerRemovedCallback callback) |
void |
registerTimelineCallback(Executor exec,
TimelineServerView.TimelineCallback callback)
Register a callback for state changes in the timeline managed by this TimelineServerView.
|
@Inject public BrokerServerView(QueryToolChestWarehouse warehouse, QueryWatcher queryWatcher, com.fasterxml.jackson.databind.ObjectMapper smileMapper, HttpClient httpClient, FilteredServerInventoryView baseView, TierSelectorStrategy tierSelectorStrategy, ServiceEmitter emitter, BrokerSegmentWatcherConfig segmentWatcherConfig)
public boolean isInitialized()
public void clear()
@Nullable public VersionedIntervalTimeline<String,ServerSelector> getTimeline(DataSource dataSource)
getTimeline
in interface TimelineServerView
public void registerTimelineCallback(Executor exec, TimelineServerView.TimelineCallback callback)
TimelineServerView
registerTimelineCallback
in interface TimelineServerView
exec
- executor in which to run the callbackcallback
- the callbackpublic <T> QueryRunner<T> getQueryRunner(DruidServer server)
getQueryRunner
in interface TimelineServerView
public void registerServerRemovedCallback(Executor exec, ServerView.ServerRemovedCallback callback)
registerServerRemovedCallback
in interface ServerView
public void registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
registerSegmentCallback
in interface ServerView
Copyright © 2011–2018. All rights reserved.