Class BinaryLogProviderImpl

java.lang.Object

io.grpc.BinaryLog

io.grpc.protobuf.services.BinaryLogProvider

io.grpc.protobuf.services.BinaryLogProviderImpl

All Implemented Interfaces:

Closeable, AutoCloseable

class BinaryLogProviderImpl
extends BinaryLogProvider

The default implementation of a BinaryLogProvider.

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicLong	counter
private final BinlogHelper.Factory	factory
private final BinaryLogSink	sink

Fields inherited from class BinaryLogProvider

BYTEARRAY_MARSHALLER

Constructor Summary

Constructors

Constructor	Description
BinaryLogProviderImpl()
BinaryLogProviderImpl(BinaryLogSink sink)	Deprecated.
BinaryLogProviderImpl(BinaryLogSink sink, String configStr)	Creates an instance.

Method Summary

Modifier and Type	Method	Description
void	close()
ClientInterceptor	getClientInterceptor(String fullMethodName, CallOptions callOptions)	Returns a ClientInterceptor for binary logging.
ServerInterceptor	getServerInterceptor(String fullMethodName)	Returns a ServerInterceptor for binary logging.

Methods inherited from class BinaryLogProvider

wrapChannel, wrapMethodDefinition

Methods inherited from class Object

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

Field Details

counter

private static final AtomicLong counter

factory

private final BinlogHelper.Factory factory

sink

private final BinaryLogSink sink

Constructor Details

BinaryLogProviderImpl

public BinaryLogProviderImpl()
                      throws IOException

Throws:

IOException

BinaryLogProviderImpl

@Deprecated
public BinaryLogProviderImpl(BinaryLogSink sink)
                      throws IOException

Deprecated.

Deprecated and will be removed in a future version of gRPC.

Throws:

IOException

BinaryLogProviderImpl

public BinaryLogProviderImpl(BinaryLogSink sink,
 String configStr)
                      throws IOException

Creates an instance.

Parameters:

sink - ownership is transferred to this class.

configStr - config string to parse to determine logged methods and msg size limits.

Throws:

IOException - if initialization failed.

Method Details

getServerInterceptor

@Nullable
public ServerInterceptor getServerInterceptor(String fullMethodName)

Description copied from class: BinaryLogProvider

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.

Specified by:

getServerInterceptor in class BinaryLogProvider

getClientInterceptor

@Nullable
public ClientInterceptor getClientInterceptor(String fullMethodName,
 CallOptions callOptions)

Description copied from class: BinaryLogProvider

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.

Specified by:

getClientInterceptor in class BinaryLogProvider

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class BinaryLogProvider

Throws:

IOException