io.druid.client

Class ServerInventoryView<InventoryType>

java.lang.Object

io.druid.client.ServerInventoryView<InventoryType>

All Implemented Interfaces:

InventoryView, ServerView

Direct Known Subclasses:

BatchServerInventoryView, SingleServerInventoryView

public abstract class ServerInventoryView<InventoryType>
extends Object
implements ServerView, InventoryView

Nested Class Summary

Nested classes/interfaces inherited from interface io.druid.client.ServerView

ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerCallback

Constructor Summary

Constructors

Constructor and Description
ServerInventoryView(com.metamx.emitter.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)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract DruidServer	addInnerInventory(DruidServer container, String inventoryKey, InventoryType inventory)
protected void	addSingleInventory(DruidServer container, io.druid.timeline.DataSegment inventory)
Iterable<DruidServer>	getInventory()
InventoryManagerConfig	getInventoryManagerConfig()
DruidServer	getInventoryValue(String containerKey)
boolean	isStarted()
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
void	registerServerCallback(Executor exec, ServerView.ServerCallback callback)
protected abstract DruidServer	removeInnerInventory(DruidServer container, String inventoryKey)
protected void	removeSingleInventory(DruidServer container, String inventoryKey)
protected void	runSegmentCallbacks(com.google.common.base.Function<ServerView.SegmentCallback,ServerView.CallbackAction> fn)
protected void	runServerCallbacks(DruidServer server)
void	start()
void	stop()
protected abstract DruidServer	updateInnerInventory(DruidServer container, String inventoryKey, InventoryType inventory)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerInventoryView

public ServerInventoryView(com.metamx.emitter.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)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws IOException

Throws:

IOException

isStarted

public boolean isStarted()

getInventoryValue

public DruidServer getInventoryValue(String containerKey)

Specified by:

getInventoryValue in interface InventoryView

getInventory

public Iterable<DruidServer> getInventory()

Specified by:

getInventory in interface InventoryView

registerServerCallback

public void registerServerCallback(Executor exec,
                          ServerView.ServerCallback callback)

Specified by:

registerServerCallback in interface ServerView

registerSegmentCallback

public void registerSegmentCallback(Executor exec,
                           ServerView.SegmentCallback callback)

Specified by:

registerSegmentCallback in interface ServerView

getInventoryManagerConfig

public InventoryManagerConfig getInventoryManagerConfig()

runSegmentCallbacks

protected void runSegmentCallbacks(com.google.common.base.Function<ServerView.SegmentCallback,ServerView.CallbackAction> fn)

runServerCallbacks

protected void runServerCallbacks(DruidServer server)

addSingleInventory

protected void addSingleInventory(DruidServer container,
                      io.druid.timeline.DataSegment inventory)

removeSingleInventory

protected void removeSingleInventory(DruidServer container,
                         String inventoryKey)

addInnerInventory

protected abstract DruidServer addInnerInventory(DruidServer container,
                            String inventoryKey,
                            InventoryType inventory)

updateInnerInventory

protected abstract DruidServer updateInnerInventory(DruidServer container,
                               String inventoryKey,
                               InventoryType inventory)

removeInnerInventory

protected abstract DruidServer removeInnerInventory(DruidServer container,
                               String inventoryKey)