io.druid.curator.inventory

Class CuratorInventoryManager<ContainerClass,InventoryClass>

java.lang.Object

io.druid.curator.inventory.CuratorInventoryManager<ContainerClass,InventoryClass>

public class CuratorInventoryManager<ContainerClass,InventoryClass>
extends Object

An InventoryManager watches updates to inventory on Zookeeper (or some other discovery-like service publishing system). It is built up on two object types: containers and inventory objects.

The logic of the InventoryManager just maintains a local cache of the containers and inventory it sees on ZK. It provides methods for getting at the container objects, which house the actual individual pieces of inventory.

A Strategy is provided to the constructor of an Inventory manager, this strategy provides all of the object-specific logic to serialize, deserialize, compose and alter the container and inventory objects.

Constructor Summary

Constructors

Constructor and Description
CuratorInventoryManager(org.apache.curator.framework.CuratorFramework curatorFramework, InventoryManagerConfig config, ExecutorService exec, CuratorInventoryManagerStrategy<ContainerClass,InventoryClass> strategy)

Method Summary

Methods

Modifier and Type	Method and Description
InventoryManagerConfig	getConfig()
Iterable<ContainerClass>	getInventory()
ContainerClass	getInventoryValue(String containerKey)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

CuratorInventoryManager

public CuratorInventoryManager(org.apache.curator.framework.CuratorFramework curatorFramework,
                       InventoryManagerConfig config,
                       ExecutorService exec,
                       CuratorInventoryManagerStrategy<ContainerClass,InventoryClass> strategy)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws IOException

Throws:

IOException

getConfig

public InventoryManagerConfig getConfig()

getInventoryValue

public ContainerClass getInventoryValue(String containerKey)

getInventory

public Iterable<ContainerClass> getInventory()