Class StatsTraceContext

java.lang.Object

io.grpc.internal.StatsTraceContext

@ThreadSafe
public final class StatsTraceContext
extends Object

The stats and tracing information for a stream.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	closed
static final StatsTraceContext	NOOP
private final StreamTracer[]	tracers

Constructor Summary

Constructors

Constructor	Description
StatsTraceContext(StreamTracer[] tracers)

Method Summary

Modifier and Type	Method	Description
void	clientInboundHeaders(Metadata headers)	See ClientStreamTracer.inboundHeaders().
void	clientInboundTrailers(Metadata trailers)	See ClientStreamTracer.inboundTrailers(Metadata).
void	clientOutboundHeaders()	See ClientStreamTracer.outboundHeaders().
List<StreamTracer>	getTracersForTest()	Returns a copy of the tracer list.
void	inboundMessage(int seqNo)	See StreamTracer.inboundMessage(int).
void	inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize)	See StreamTracer.inboundMessageRead(int, long, long).
void	inboundUncompressedSize(long bytes)	See StreamTracer.inboundUncompressedSize(long).
void	inboundWireSize(long bytes)	See StreamTracer.inboundWireSize(long).
static StatsTraceContext	newClientContext(ClientStreamTracer[] tracers, Attributes transportAtts, Metadata headers)	Factory method for the client-side.
static StatsTraceContext	newServerContext(List<? extends ServerStreamTracer.Factory> factories, String fullMethodName, Metadata headers)	Factory method for the server-side.
void	outboundMessage(int seqNo)	See StreamTracer.outboundMessage(int).
void	outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize)	See StreamTracer.outboundMessageSent(int, long, long).
void	outboundUncompressedSize(long bytes)	See StreamTracer.outboundUncompressedSize(long).
void	outboundWireSize(long bytes)	See StreamTracer.outboundWireSize(long).
void	serverCallStarted(ServerStreamTracer.ServerCallInfo<?,?> callInfo)	See ServerStreamTracer.serverCallStarted(ServerStreamTracer.ServerCallInfo).
<ReqT,RespT> Context	serverFilterContext(Context context)	See ServerStreamTracer.filterContext(Context).
void	streamClosed(Status status)	See StreamTracer.streamClosed(Status).

Methods inherited from class Object

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

Field Details

NOOP

public static final StatsTraceContext NOOP

tracers

private final StreamTracer[] tracers

closed

private final AtomicBoolean closed

Constructor Details

StatsTraceContext

StatsTraceContext(StreamTracer[] tracers)

Method Details

newClientContext

public static StatsTraceContext newClientContext(ClientStreamTracer[] tracers,
 Attributes transportAtts,
 Metadata headers)

Factory method for the client-side.

newServerContext

public static StatsTraceContext newServerContext(List<? extends ServerStreamTracer.Factory> factories,
 String fullMethodName,
 Metadata headers)

Factory method for the server-side.

getTracersForTest

public List<StreamTracer> getTracersForTest()

Returns a copy of the tracer list.

clientOutboundHeaders

public void clientOutboundHeaders()

See ClientStreamTracer.outboundHeaders(). For client-side only.

Transport-specific, thus should be called by transport implementations.

clientInboundHeaders

public void clientInboundHeaders(Metadata headers)

See ClientStreamTracer.inboundHeaders(). For client-side only.

Called from abstract stream implementations.

clientInboundTrailers

public void clientInboundTrailers(Metadata trailers)

See ClientStreamTracer.inboundTrailers(Metadata). For client-side only.

Called from abstract stream implementations.

serverFilterContext

public <ReqT,RespT> Context serverFilterContext(Context context)

See ServerStreamTracer.filterContext(Context). For server-side only.

Called from ServerImpl.

serverCallStarted

public void serverCallStarted(ServerStreamTracer.ServerCallInfo<?,?> callInfo)

See ServerStreamTracer.serverCallStarted(ServerStreamTracer.ServerCallInfo). For server-side only.

Called from ServerImpl.

streamClosed

public void streamClosed(Status status)

See StreamTracer.streamClosed(Status). This may be called multiple times, and only the first value will be taken.

Called from abstract stream implementations.

outboundMessage

public void outboundMessage(int seqNo)

See StreamTracer.outboundMessage(int).

Called from Framer.

inboundMessage

public void inboundMessage(int seqNo)

See StreamTracer.inboundMessage(int).

Called from MessageDeframer.

outboundMessageSent

public void outboundMessageSent(int seqNo,
 long optionalWireSize,
 long optionalUncompressedSize)

See StreamTracer.outboundMessageSent(int, long, long).

Called from Framer.

inboundMessageRead

public void inboundMessageRead(int seqNo,
 long optionalWireSize,
 long optionalUncompressedSize)

See StreamTracer.inboundMessageRead(int, long, long).

Called from MessageDeframer.

outboundUncompressedSize

public void outboundUncompressedSize(long bytes)

See StreamTracer.outboundUncompressedSize(long).

Called from Framer.

outboundWireSize

public void outboundWireSize(long bytes)

See StreamTracer.outboundWireSize(long).

Called from Framer.

inboundUncompressedSize

public void inboundUncompressedSize(long bytes)

See StreamTracer.inboundUncompressedSize(long).

Called from MessageDeframer.

inboundWireSize

public void inboundWireSize(long bytes)

See StreamTracer.inboundWireSize(long).

Called from MessageDeframer.