Package io.grpc.protobuf.services

Class BinaryLogProvider

java.lang.Object

io.grpc.BinaryLog

io.grpc.protobuf.services.BinaryLogProvider

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

BinaryLogProviderImpl

@Internal
public abstract class BinaryLogProvider
extends BinaryLog

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	BinaryLogProvider.BinaryLogShim	The pipeline of interceptors is hard coded when the ManagedChannel is created.
private static final class	BinaryLogProvider.ByteArrayMarshaller
private static final class	BinaryLogProvider.IoUtils

Field Summary

Fields

Modifier and Type	Field	Description
private final ClientInterceptor	binaryLogShim
static final MethodDescriptor.Marshaller<byte[]>	BYTEARRAY_MARSHALLER

Constructor Summary

Constructors

Constructor	Description
BinaryLogProvider()

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract ClientInterceptor	getClientInterceptor(String fullMethodName, CallOptions callOptions)	Returns a ClientInterceptor for binary logging.
protected abstract ServerInterceptor	getServerInterceptor(String fullMethodName)	Returns a ServerInterceptor for binary logging.
private static MethodDescriptor<byte[],byte[]>	toByteBufferMethod(MethodDescriptor<?,?> method)
final Channel	wrapChannel(Channel channel)	Wraps a channel to provide binary logging on ClientCalls as needed.
final <ReqT, RespT> ServerMethodDefinition<?,?>	wrapMethodDefinition(ServerMethodDefinition<ReqT,RespT> oMethodDef)	Wraps a ServerMethodDefinition such that it performs binary logging if needed.

Methods inherited from class java.lang.Object

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

Field Details

BYTEARRAY_MARSHALLER

public static final MethodDescriptor.Marshaller<byte[]> BYTEARRAY_MARSHALLER

binaryLogShim

private final ClientInterceptor binaryLogShim

Constructor Details

BinaryLogProvider

public BinaryLogProvider()

Method Details

wrapChannel

public final Channel wrapChannel(Channel channel)

Wraps a channel to provide binary logging on ClientCalls as needed.

Specified by:

wrapChannel in class BinaryLog

toByteBufferMethod

private static MethodDescriptor<byte[],byte[]> toByteBufferMethod(MethodDescriptor<?,?> method)

wrapMethodDefinition

public final <ReqT,
RespT>
ServerMethodDefinition<?,?> wrapMethodDefinition(ServerMethodDefinition<ReqT,RespT> oMethodDef)

Wraps a ServerMethodDefinition such that it performs binary logging if needed.

Specified by:

wrapMethodDefinition in class BinaryLog

getServerInterceptor

@Nullable
protected abstract ServerInterceptor getServerInterceptor(String fullMethodName)

Returns a ServerInterceptor for binary logging. gRPC is free to cache the interceptor, so the interceptor must be reusable across calls. At runtime, the request and response marshallers are always Marshaller<InputStream>. Returns null if this method is not binary logged.

getClientInterceptor

@Nullable
protected abstract ClientInterceptor getClientInterceptor(String fullMethodName,
 CallOptions callOptions)

Returns a ClientInterceptor for binary logging. gRPC is free to cache the interceptor, so the interceptor must be reusable across calls. At runtime, the request and response marshallers are always Marshaller<InputStream>. Returns null if this method is not binary logged.

close

public void close()
           throws IOException

Throws:

IOException