com.facebook.buck.slb

Class HybridThriftOverHttpServiceImpl<ThriftRequest extends org.apache.thrift.TBase<?,?>,ThriftResponse extends org.apache.thrift.TBase<?,?>>

java.lang.Object

com.facebook.buck.slb.HybridThriftOverHttpServiceImpl<ThriftRequest,ThriftResponse>

All Implemented Interfaces:

HybridThriftOverHttpService<ThriftRequest,ThriftResponse>, ThriftOverHttpService<ThriftRequest,ThriftResponse>, ThriftService<ThriftRequest,ThriftResponse>, Closeable, AutoCloseable

public class HybridThriftOverHttpServiceImpl<ThriftRequest extends org.apache.thrift.TBase<?,?>,ThriftResponse extends org.apache.thrift.TBase<?,?>>
extends Object
implements HybridThriftOverHttpService<ThriftRequest,ThriftResponse>

The HTTP body contains: - 4 bytes big endian byte size of the thrift serialised message. - N bytes of the thrift serialised message. - Remaining bytes correspond to the out-of-band payload(s).

Field Summary

Fields

Modifier and Type	Field and Description
static okhttp3.MediaType	HYBRID_THRIFT_STREAM_CONTENT_TYPE
static String	PROTOCOL_HEADER

Constructor Summary

Constructors

Constructor and Description
HybridThriftOverHttpServiceImpl(HybridThriftOverHttpServiceImplArgs args) New instances.

Method Summary

Modifier and Type	Method and Description
void	close()
com.google.common.util.concurrent.ListenableFuture<ThriftResponse>	makeRequest(HybridThriftRequestHandler<ThriftRequest> request, HybridThriftResponseHandler<ThriftResponse> responseHandler) Asynchronously make a request.
void	makeRequest(ThriftRequest thriftRequest, ThriftResponse thriftResponse)
ThriftResponse	makeRequestSync(HybridThriftRequestHandler<ThriftRequest> request, HybridThriftResponseHandler<ThriftResponse> responseHandler) Synchronously make a request.
static <ThriftResponse extends org.apache.thrift.TBase<?,?>> ThriftResponse	readFromStream(DataInputStream rawBodyStream, ThriftProtocol protocol, HybridThriftResponseHandler<ThriftResponse> responseHandler) Reads a HTTP body stream in Hybrid Thrift over HTTP format.
static <ThriftRequest extends org.apache.thrift.TBase<?,?>> void	writeToStream(DataOutputStream outputStream, byte[] serializedThriftData, HybridThriftRequestHandler<ThriftRequest> request) Writes the HTTP body into a stream in Hybrid Thrift over HTTP format.

Methods inherited from class java.lang.Object

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

Field Detail

HYBRID_THRIFT_STREAM_CONTENT_TYPE

public static final okhttp3.MediaType HYBRID_THRIFT_STREAM_CONTENT_TYPE

PROTOCOL_HEADER

public static final String PROTOCOL_HEADER

See Also:

Constant Field Values

Constructor Detail

HybridThriftOverHttpServiceImpl

public HybridThriftOverHttpServiceImpl(HybridThriftOverHttpServiceImplArgs args)

New instances.

Method Detail

makeRequest

public com.google.common.util.concurrent.ListenableFuture<ThriftResponse> makeRequest(HybridThriftRequestHandler<ThriftRequest> request,
                                                                                      HybridThriftResponseHandler<ThriftResponse> responseHandler)

Description copied from interface: HybridThriftOverHttpService

Asynchronously make a request.

Specified by:

makeRequest in interface HybridThriftOverHttpService<ThriftRequest extends org.apache.thrift.TBase<?,?>,ThriftResponse extends org.apache.thrift.TBase<?,?>>

makeRequestSync

public ThriftResponse makeRequestSync(HybridThriftRequestHandler<ThriftRequest> request,
                                      HybridThriftResponseHandler<ThriftResponse> responseHandler)
                               throws IOException

Description copied from interface: HybridThriftOverHttpService

Synchronously make a request.

Specified by:

makeRequestSync in interface HybridThriftOverHttpService<ThriftRequest extends org.apache.thrift.TBase<?,?>,ThriftResponse extends org.apache.thrift.TBase<?,?>>

Throws:

IOException

writeToStream

public static <ThriftRequest extends org.apache.thrift.TBase<?,?>> void writeToStream(DataOutputStream outputStream,
                                                                                      byte[] serializedThriftData,
                                                                                      HybridThriftRequestHandler<ThriftRequest> request)
                                                                               throws IOException

Writes the HTTP body into a stream in Hybrid Thrift over HTTP format.

Throws:

IOException

readFromStream

public static <ThriftResponse extends org.apache.thrift.TBase<?,?>> ThriftResponse readFromStream(DataInputStream rawBodyStream,
                                                                                                  ThriftProtocol protocol,
                                                                                                  HybridThriftResponseHandler<ThriftResponse> responseHandler)
                                                                                           throws IOException

Reads a HTTP body stream in Hybrid Thrift over HTTP format.

Throws:

IOException

makeRequest

public void makeRequest(ThriftRequest thriftRequest,
                        ThriftResponse thriftResponse)
                 throws IOException

Specified by:

makeRequest in interface ThriftService<ThriftRequest extends org.apache.thrift.TBase<?,?>,ThriftResponse extends org.apache.thrift.TBase<?,?>>

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable