Searched refs:ClientConfiguration (Results 1 – 11 of 11) sorted by relevance
41 public class ClientConfiguration implements Configuration { class42 private static final ClientConfiguration DEFAULT = new ClientConfiguration();65 private ClientConfiguration() { in ClientConfiguration() method in ClientConfiguration85 static final class Builder extends AbstractConfigurationBuilder<ClientConfiguration> {93 protected ClientConfiguration newConfiguration() { in newConfiguration()94 return new ClientConfiguration(); in newConfiguration()103 protected ClientConfiguration build0(ClientConfiguration config) { in build0()138 protected void setClientValue(ClientConfiguration config, String value) { in setClientValue()144 protected void setClientValue(ClientConfiguration config, String value) { in setClientValue()151 protected void setClientValue(ClientConfiguration config, String value) { in setClientValue()[all …]
23 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.ADDRESS;24 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CLIENT_PAYLOAD;25 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DURATION;26 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.FLOW_CONTROL_WINDOW;27 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SAVE_HISTOGRAM;28 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SERVER_PAYLOAD;29 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TARGET_QPS;30 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TESTCA;31 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TLS;32 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.TRANSPORT;[all …]
22 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.ADDRESS;23 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CHANNELS;24 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.CLIENT_PAYLOAD;25 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DIRECTEXECUTOR;26 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.DURATION;27 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.FLOW_CONTROL_WINDOW;28 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.OUTSTANDING_RPCS;29 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SAVE_HISTOGRAM;30 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.SERVER_PAYLOAD;31 import static io.grpc.benchmarks.qps.ClientConfiguration.ClientParam.STREAMING_RPCS;[all …]
88 ClientConfiguration client_config,94 ClientConfiguration client_config_for_testing() { return client_config_; } in client_config_for_testing()107 ClientConfiguration client_config_;
152 ClientConfiguration client_config;191 ClientConfiguration client_config;
170 ClientConfiguration client_config; in CreateAndHandshake()218 ClientConfiguration client_config, in Client()
42 struct ClientConfiguration { struct
180 ClientConfiguration client_configuration;
50 ClientConfiguration MakeClientConfiguration(const DataSourceConfig& cfg) { in MakeClientConfiguration()51 ClientConfiguration client_config; in MakeClientConfiguration()
31 Aws::Client::ClientConfiguration* InitializeDefaultClientConfig() { in InitializeDefaultClientConfig()32 static Aws::Client::ClientConfiguration config; in InitializeDefaultClientConfig()108 Aws::Client::ClientConfiguration& GetDefaultClientConfig() { in GetDefaultClientConfig()109 static Aws::Client::ClientConfiguration* config = in GetDefaultClientConfig()
48 Aws::Client::ClientConfiguration& GetDefaultClientConfig() { in GetDefaultClientConfig()51 static Aws::Client::ClientConfiguration cfg; in GetDefaultClientConfig()