net.lag.kestrel.thrift

Interface Kestrel.Iface

All Known Implementing Classes:

Kestrel.Client, KestrelThriftClient

Enclosing class:

Kestrel

public static interface Kestrel.Iface

Method Summary

Methods

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