mirror of https://github.com/grpc/grpc-java.git
ea70de601c
* Implement LRS client with backoff. No load data is invovled yet, only for load reporting interval updates. Unit test with load report interval update and streamClosed retry. * use a separate stopwatch to manage actual load report interval * refactor XdsLrsClientTest * LRS response will only receive exactly one cluster name for grpc use case * add more XdsLrsClientTest * change class modifier * fixed class comment * renamed TRAFFICDIRECTOR_HOSTNAME_FIELD * removed self-implemented Duration util methods, instead use methods in com.google.protobuf.util.Durations * starting LrsStream's stopwatch inside LrsStream's start method * fixed bug of using the wrong stopwatch for XdsLrsClient retrying * removed try-catch around request StreamObserver * polished code by eliminating unnecessary operations * log an error instead of crash the thread when receiving LRS response for different cluster name * created a XdsLoadStatsManager interface, XdsLrsClient implements it * added XdsLoadStatsStore component in XdsLrsClient * specify thread safety in XdsLoadStatsManager * fixed style and convention issues * added test case for verifying recorded load data by manually crafting load data * added thread-safety in interface specification * minor polish with adding debug logs to LRS client |
||
|---|---|---|
| .. | ||
| src | ||
| third_party | ||
| build.gradle | ||