com.netflix.dyno.queues.redis

Class DynoShardSupplier

java.lang.Object

com.netflix.dyno.queues.redis.DynoShardSupplier

All Implemented Interfaces:

ShardSupplier

public class DynoShardSupplier
extends java.lang.Object
implements ShardSupplier

Constructor Summary

Constructors

Constructor and Description
DynoShardSupplier(com.netflix.dyno.connectionpool.HostSupplier hs, java.lang.String region, java.lang.String localDC)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCurrentShard()
java.util.Set<java.lang.String>	getQueueShards()

Methods inherited from class java.lang.Object

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

Constructor Detail

DynoShardSupplier

public DynoShardSupplier(com.netflix.dyno.connectionpool.HostSupplier hs,
                         java.lang.String region,
                         java.lang.String localDC)

Method Detail

getCurrentShard

public java.lang.String getCurrentShard()

Specified by:

getCurrentShard in interface ShardSupplier

Returns:

Name of the current shard. Used when popping elements out of the queue

getQueueShards

public java.util.Set<java.lang.String> getQueueShards()

Specified by:

getQueueShards in interface ShardSupplier

Returns:

Provides the set of all the available queue shards. The elements are evenly distributed amongst these shards