net.lag.kestrel.thrift

Interface Kestrel.AsyncIface

All Known Implementing Classes:

Kestrel.AsyncClient

Enclosing class:

Kestrel

public static interface Kestrel.AsyncIface

Method Summary

Modifier and Type	Method and Description
void	abort(String queue_name, Set<Long> ids, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.abort_call> resultHandler)
void	confirm(String queue_name, Set<Long> ids, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.confirm_call> resultHandler)
void	delete_queue(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.delete_queue_call> resultHandler)
void	flush_all_queues(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_all_queues_call> resultHandler)
void	flush_queue(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_queue_call> resultHandler)
void	get_version(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_version_call> resultHandler)
void	get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_call> resultHandler)
void	peek(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.peek_call> resultHandler)
void	put(String queue_name, List<ByteBuffer> items, int expiration_msec, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.put_call> resultHandler)

Method Detail

put

void put(String queue_name,
         List<ByteBuffer> items,
         int expiration_msec,
         org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.put_call> resultHandler)
  throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get

void get(String queue_name,
         int max_items,
         int timeout_msec,
         int auto_abort_msec,
         org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_call> resultHandler)
  throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

confirm

void confirm(String queue_name,
             Set<Long> ids,
             org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.confirm_call> resultHandler)
      throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

abort

void abort(String queue_name,
           Set<Long> ids,
           org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.abort_call> resultHandler)
    throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

peek

void peek(String queue_name,
          org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.peek_call> resultHandler)
   throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_queue

void flush_queue(String queue_name,
                 org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_queue_call> resultHandler)
          throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

flush_all_queues

void flush_all_queues(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_all_queues_call> resultHandler)
               throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

delete_queue

void delete_queue(String queue_name,
                  org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.delete_queue_call> resultHandler)
           throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get_version

void get_version(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_version_call> resultHandler)
          throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException