in continuous_load_testing/src/main/java/com/google/net/grpc/testing/directpath/continuous_load_testing/Client.java [77:115]
public static void main(String[] args) {
logger.info("DirectPath Continuous Load Testing Client Started.");
initializeLogManager();
parseArgs(args);
GrpcOpenTelemetry grpcOpenTelemetry = initializeOpenTelemetry();
ChannelCredentials credentials = GoogleDefaultChannelCredentials.create();
String backend = disable_directpath ? CLOUDPATH_BACKEND : DIRECTPATH_BACKEND;
ManagedChannelBuilder<?> builder = Grpc.newChannelBuilder(backend, credentials);
grpcOpenTelemetry.configureChannelBuilder(builder);
TestServiceStub stub = TestServiceGrpc.newStub(builder.build());
if (methods.contains(Method.EmptyCall)) {
ExecuteEmptyCalls(stub);
}
if (methods.contains(Method.UnaryCall)) {
ExecuteUnaryCalls(stub);
}
if (methods.contains(Method.StreamingInputCall)) {
ExecuteStreamingInputCalls(stub);
}
if (methods.contains(Method.StreamingOutputCall)) {
ExecuteStreamingOutputCalls(stub);
}
if (methods.contains(Method.FullDuplexCall)) {
ExecuteFullDuplexCalls(stub);
}
if (methods.contains(Method.HalfDuplexCall)) {
ExecuteHalfDuplexCalls(stub);
}
try {
synchronized (Client.class) {
Client.class.wait();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}