public class HttpServerInventoryView extends Object implements ServerInventoryView, FilteredServerInventoryView
ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerRemovedCallback
Constructor and Description |
---|
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter,
HttpServerInventoryViewConfig config) |
Modifier and Type | Method and Description |
---|---|
Collection<DruidServer> |
getInventory() |
DruidServer |
getInventoryValue(String containerKey) |
boolean |
isSegmentLoadedByServer(String serverKey,
DataSegment segment) |
boolean |
isStarted() |
void |
registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback) |
void |
registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) |
void |
registerServerRemovedCallback(Executor exec,
ServerView.ServerRemovedCallback callback) |
void |
start() |
void |
stop() |
@Inject public HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper, HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter, HttpServerInventoryViewConfig config)
public void stop() throws IOException
IOException
public void registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)
registerSegmentCallback
in interface FilteredServerInventoryView
public void registerServerRemovedCallback(Executor exec, ServerView.ServerRemovedCallback callback)
registerServerRemovedCallback
in interface FilteredServerInventoryView
registerServerRemovedCallback
in interface ServerView
public void registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
registerSegmentCallback
in interface ServerView
public DruidServer getInventoryValue(String containerKey)
getInventoryValue
in interface InventoryView
public Collection<DruidServer> getInventory()
getInventory
in interface InventoryView
public boolean isStarted()
isStarted
in interface InventoryView
public boolean isSegmentLoadedByServer(String serverKey, DataSegment segment)
isSegmentLoadedByServer
in interface InventoryView
Copyright © 2011–2018. All rights reserved.