public abstract class AbstractCuratorServerInventoryView<InventoryType> extends Object implements ServerInventoryView
ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerRemovedCallback
Constructor and Description |
---|
AbstractCuratorServerInventoryView(EmittingLogger log,
String announcementsPath,
String inventoryPath,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.fasterxml.jackson.core.type.TypeReference<InventoryType> typeReference) |
public AbstractCuratorServerInventoryView(EmittingLogger log, String announcementsPath, String inventoryPath, org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.core.type.TypeReference<InventoryType> typeReference)
public void stop() throws IOException
IOException
public boolean isStarted()
isStarted
in interface InventoryView
public DruidServer getInventoryValue(String containerKey)
getInventoryValue
in interface InventoryView
public Collection<DruidServer> getInventory()
getInventory
in interface InventoryView
public void registerServerRemovedCallback(Executor exec, ServerView.ServerRemovedCallback callback)
registerServerRemovedCallback
in interface ServerView
public void registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
registerSegmentCallback
in interface ServerView
public InventoryManagerConfig getInventoryManagerConfig()
protected void runSegmentCallbacks(com.google.common.base.Function<ServerView.SegmentCallback,ServerView.CallbackAction> fn)
protected void addSingleInventory(DruidServer container, DataSegment inventory)
protected void removeSingleInventory(DruidServer container, String inventoryKey)
public boolean isSegmentLoadedByServer(String serverKey, DataSegment segment)
isSegmentLoadedByServer
in interface InventoryView
protected abstract DruidServer addInnerInventory(DruidServer container, String inventoryKey, InventoryType inventory)
protected abstract DruidServer updateInnerInventory(DruidServer container, String inventoryKey, InventoryType inventory)
protected abstract DruidServer removeInnerInventory(DruidServer container, String inventoryKey)
protected abstract void segmentCallbackRemoved(ServerView.SegmentCallback callback)
Copyright © 2011–2018. All rights reserved.