net.lag.kestrel.thrift

Interface Kestrel.Iface

All Known Implementing Classes:

Kestrel.Client, KestrelThriftClient

Enclosing class:

Kestrel

public static interface Kestrel.Iface

Method Summary

Modifier and Type	Method and Description
int	abort(String queue_name, Set<Long> ids)
int	confirm(String queue_name, Set<Long> ids)
void	delete_queue(String queue_name)
void	flush_all_queues()
void	flush_queue(String queue_name)
String	get_version()
List<Item>	get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
QueueInfo	peek(String queue_name)
int	put(String queue_name, List<ByteBuffer> items, int expiration_msec)

Method Detail

put

int put(String queue_name,
        List<ByteBuffer> items,
        int expiration_msec)
 throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get

List<Item> get(String queue_name,
               int max_items,
               int timeout_msec,
               int auto_abort_msec)
        throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

confirm

int confirm(String queue_name,
            Set<Long> ids)
     throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

abort

int abort(String queue_name,
          Set<Long> ids)
   throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

peek

QueueInfo peek(String queue_name)
        throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_queue

void flush_queue(String queue_name)
          throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_all_queues

void flush_all_queues()
               throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

delete_queue

void delete_queue(String queue_name)
           throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get_version

String get_version()
            throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException