net.lag.kestrel.thrift

Class Kestrel.Client

java.lang.Object

org.apache.thrift7.TServiceClient

net.lag.kestrel.thrift.Kestrel.Client

All Implemented Interfaces:

Kestrel.Iface

Enclosing class:

Kestrel

public static class Kestrel.Client
extends org.apache.thrift7.TServiceClient
implements Kestrel.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Kestrel.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift7.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
Client(org.apache.thrift7.protocol.TProtocol prot)
Client(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot)

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)
int	recv_abort()
int	recv_confirm()
void	recv_delete_queue()
void	recv_flush_all_queues()
void	recv_flush_queue()
String	recv_get_version()
List<Item>	recv_get()
QueueInfo	recv_peek()
int	recv_put()
void	send_abort(String queue_name, Set<Long> ids)
void	send_confirm(String queue_name, Set<Long> ids)
void	send_delete_queue(String queue_name)
void	send_flush_all_queues()
void	send_flush_queue(String queue_name)
void	send_get_version()
void	send_get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
void	send_peek(String queue_name)
void	send_put(String queue_name, List<ByteBuffer> items, int expiration_msec)

Methods inherited from class org.apache.thrift7.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase

Methods inherited from class java.lang.Object

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

Constructor Detail

Client

public Client(org.apache.thrift7.protocol.TProtocol prot)

Client

public Client(org.apache.thrift7.protocol.TProtocol iprot,
              org.apache.thrift7.protocol.TProtocol oprot)

Method Detail

put

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

Specified by:

put in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_put

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

Throws:

org.apache.thrift7.TException

recv_put

public int recv_put()
             throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get

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

Specified by:

get in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_get

public void send_get(String queue_name,
                     int max_items,
                     int timeout_msec,
                     int auto_abort_msec)
              throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_get

public List<Item> recv_get()
                    throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

confirm

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

Specified by:

confirm in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_confirm

public void send_confirm(String queue_name,
                         Set<Long> ids)
                  throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_confirm

public int recv_confirm()
                 throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

abort

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

Specified by:

abort in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_abort

public void send_abort(String queue_name,
                       Set<Long> ids)
                throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_abort

public int recv_abort()
               throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

peek

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

Specified by:

peek in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_peek

public void send_peek(String queue_name)
               throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_peek

public QueueInfo recv_peek()
                    throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_queue

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

Specified by:

flush_queue in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_flush_queue

public void send_flush_queue(String queue_name)
                      throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_flush_queue

public void recv_flush_queue()
                      throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_all_queues

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

Specified by:

flush_all_queues in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_flush_all_queues

public void send_flush_all_queues()
                           throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_flush_all_queues

public void recv_flush_all_queues()
                           throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

delete_queue

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

Specified by:

delete_queue in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_delete_queue

public void send_delete_queue(String queue_name)
                       throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_delete_queue

public void recv_delete_queue()
                       throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get_version

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

Specified by:

get_version in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

send_get_version

public void send_get_version()
                      throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

recv_get_version

public String recv_get_version()
                        throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException