grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add more interop client logging

This commit is contained in:
Michael Lumish 2020-08-28 11:17:52 -07:00
parent 60bc11285b
commit b9962feff0
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
packages/grpc-js/interop/xds-interop-client.ts
View File

@ -52,20 +52,18 @@ class CallSubscriber {
constructor(private callGoal: number, private onFinished: () => void) {} constructor(private callGoal: number, private onFinished: () => void) {}
addCallStarted(): void { addCallStarted(): void {
console.log('Call started');
this.callsStarted += 1; this.callsStarted += 1;
} }
private maybeOnFinished() { private maybeOnFinished() {
if (this.callsFinished == this.callGoal) { if (this.callsFinished == this.callGoal) {
console.log(`Out of a total of ${this.callsFinished} calls, ${this.callsSucceeded} succeeded`);
for (const [message, count] of this.failureMessageCount) {
console.log(`${count} failed with the message ${message}`);
}
this.onFinished(); this.onFinished();
} }
} }
addCallSucceeded(peerName: string): void { addCallSucceeded(peerName: string): void {
console.log(`Call to ${peerName} succeeded`);
if (peerName in this.callsSucceededByPeer) { if (peerName in this.callsSucceededByPeer) {
this.callsSucceededByPeer[peerName] += 1; this.callsSucceededByPeer[peerName] += 1;
} else { } else {
@ -76,6 +74,7 @@ class CallSubscriber {
this.maybeOnFinished(); this.maybeOnFinished();
} }
addCallFailed(message: string): void { addCallFailed(message: string): void {
console.log(`Call failed with message ${message}`);
this.callsFinished += 1; this.callsFinished += 1;
this.failureMessageCount.set(message, (this.failureMessageCount.get(message) ?? 0) + 1); this.failureMessageCount.set(message, (this.failureMessageCount.get(message) ?? 0) + 1);
this.maybeOnFinished(); this.maybeOnFinished();
@ -86,6 +85,10 @@ class CallSubscriber {
} }
getFinalStats(): LoadBalancerStatsResponse { getFinalStats(): LoadBalancerStatsResponse {
console.log(`Out of a total of ${this.callGoal} calls requested, ${this.callsFinished} finished. ${this.callsSucceeded} succeeded`);
for (const [message, count] of this.failureMessageCount) {
console.log(`${count} failed with the message ${message}`);
}
return { return {
rpcs_by_peer: this.callsSucceededByPeer, rpcs_by_peer: this.callsSucceededByPeer,
num_failures: this.callsStarted - this.callsSucceeded num_failures: this.callsStarted - this.callsSucceeded