net.lag.kestrel.thrift

Interface Kestrel.AsyncIface

All Known Implementing Classes:

Kestrel.AsyncClient

Enclosing class:

Kestrel

public static interface Kestrel.AsyncIface

Method Summary

Methods

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