diff options
| author | Kun Zhang <zhangkun83@users.noreply.github.com> | 2017-09-19 09:22:11 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-09-19 09:22:11 -0700 |
| commit | 7e534ed704441cdef7f2af6c094148acf3dabd8b (patch) | |
| tree | 02a3828965cd52a558d6b4fd992befb93c574eae /grpclb | |
| parent | a3ff9cd784fce8a3a05054f0cd695954283e51f5 (diff) | |
| download | grpc-grpc-java-7e534ed704441cdef7f2af6c094148acf3dabd8b.tar.gz | |
core: record individual messages with sizes to Census/tracing (#3461)
Two methods, outboundMessageSent() and inboundMessageRead() are added to StreamTracer in order to associate individual messages with sizes. Both types of sizes are optional, as allowed by Census tracing.
Both methods accept a sequence number as the type ID as required by Census. The original outboundMesage() and inboundMessage() are also replaced by overrides that take the sequence number, to better match the new methods. The deprecation of the old overrides are tracked by #3460
Diffstat (limited to 'grpclb')
| -rw-r--r-- | grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java index 039c24e19..3115fa388 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java @@ -117,7 +117,7 @@ final class GrpclbClientLoadRecorder extends ClientStreamTracer.Factory { } @Override - public void inboundMessage() { + public void inboundMessage(int seqNo) { anythingReceived.set(true); } |