Package me.ahoo.cosid.zookeeper

Class ZookeeperIdSegmentDistributor

java.lang.Object

me.ahoo.cosid.segment.AbstractIdSegmentDistributor

me.ahoo.cosid.zookeeper.ZookeeperIdSegmentDistributor

All Implemented Interfaces:

Grouped, IdSegmentDistributor

public class ZookeeperIdSegmentDistributor
extends AbstractIdSegmentDistributor

Zookeeper IdSegment Distributor.

Field Summary

Fields inherited from interface me.ahoo.cosid.segment.IdSegmentDistributor

DEFAULT_OFFSET, DEFAULT_SEGMENTS, DEFAULT_STEP

Constructor Summary

Constructors

Constructor	Description
ZookeeperIdSegmentDistributor(String namespace, String name, long offset, long step, org.apache.curator.framework.CuratorFramework curatorFramework, org.apache.curator.RetryPolicy retryPolicy)
ZookeeperIdSegmentDistributor(String namespace, String name, long offset, long step, org.apache.curator.framework.CuratorFramework curatorFramework, org.apache.curator.RetryPolicy retryPolicy, CallTimeout callTimeout)	Create a ZooKeeper segment distributor whose AbstractIdSegmentDistributor.nextMaxId(long) gives up after callTimeout.

Method Summary

Modifier and Type	Method	Description
protected long	doNextMaxId(long step)	Ask the store for the next max id, step after the previous one.

Methods inherited from class me.ahoo.cosid.segment.AbstractIdSegmentDistributor

getLastMaxId, getName, getNamespace, getStep, nextMaxId

Methods inherited from class java.lang.Object

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

Methods inherited from interface me.ahoo.cosid.segment.grouped.Grouped

group

Methods inherited from interface me.ahoo.cosid.segment.IdSegmentDistributor

allowReset, getNamespacedName, getStep, nextIdSegment, nextIdSegment, nextIdSegment, nextIdSegmentChain, nextIdSegmentChain, nextMaxId

Constructor Details

ZookeeperIdSegmentDistributor

public ZookeeperIdSegmentDistributor(String namespace,
 String name,
 long offset,
 long step,
 org.apache.curator.framework.CuratorFramework curatorFramework,
 org.apache.curator.RetryPolicy retryPolicy)

ZookeeperIdSegmentDistributor

public ZookeeperIdSegmentDistributor(String namespace,
 String name,
 long offset,
 long step,
 org.apache.curator.framework.CuratorFramework curatorFramework,
 org.apache.curator.RetryPolicy retryPolicy,
 CallTimeout callTimeout)

Create a ZooKeeper segment distributor whose AbstractIdSegmentDistributor.nextMaxId(long) gives up after callTimeout. ensureOffset() at startup is not bounded.

Method Details

doNextMaxId

protected long doNextMaxId(long step)

Description copied from class: AbstractIdSegmentDistributor

Ask the store for the next max id, step after the previous one.

Specified by:

doNextMaxId in class AbstractIdSegmentDistributor

Parameters:

step - the step, already validated

Returns:

the new max id