org.apache.solr.cloud.autoscaling.sim

Class SimDistributedQueueFactory.SimDistributedQueue

java.lang.Object

org.apache.solr.cloud.autoscaling.sim.SimDistributedQueueFactory.SimDistributedQueue

All Implemented Interfaces:

DistributedQueue

Enclosing class:

SimDistributedQueueFactory

public static class SimDistributedQueueFactory.SimDistributedQueue
extends Object
implements DistributedQueue

Constructor Summary

Constructors

Constructor and Description
SimDistributedQueue(String dir)

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getStats()
Stats	getZkStats()
void	offer(byte[] data)
byte[]	peek()
byte[]	peek(boolean block)
byte[]	peek(long wait)
Collection<Pair<String,byte[]>>	peekElements(int max, long waitMillis, Predicate<String> acceptFilter)
byte[]	poll()
byte[]	remove()
byte[]	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimDistributedQueue

public SimDistributedQueue(String dir)

Method Detail

peek

public byte[] peek()
            throws Exception

Specified by:

peek in interface DistributedQueue

Throws:

Exception

peek

public byte[] peek(boolean block)
            throws Exception

Specified by:

peek in interface DistributedQueue

Throws:

Exception

peek

public byte[] peek(long wait)
            throws Exception

Specified by:

peek in interface DistributedQueue

Throws:

Exception

poll

public byte[] poll()
            throws Exception

Specified by:

poll in interface DistributedQueue

Throws:

Exception

remove

public byte[] remove()
              throws Exception

Specified by:

remove in interface DistributedQueue

Throws:

Exception

take

public byte[] take()
            throws Exception

Specified by:

take in interface DistributedQueue

Throws:

Exception

offer

public void offer(byte[] data)
           throws Exception

Specified by:

offer in interface DistributedQueue

Throws:

Exception

peekElements

public Collection<Pair<String,byte[]>> peekElements(int max,
                                                    long waitMillis,
                                                    Predicate<String> acceptFilter)
                                             throws Exception

Specified by:

peekElements in interface DistributedQueue

Throws:

Exception

getZkStats

public Stats getZkStats()

getStats

public Map<String,Object> getStats()

Specified by:

getStats in interface DistributedQueue