| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| ServiceConfigInterceptorTest.java | 94 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig));
96 interceptor.handleUpdate(serviceConfig);
120 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig));
122 interceptor.handleUpdate(serviceConfig);
134 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig));
136 interceptor.handleUpdate(serviceConfig);
149 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig));
151 interceptor.handleUpdate(serviceConfig);
164 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig));
166 interceptor.handleUpdate(serviceConfig);
[all...] |
| AutoConfiguredLoadBalancerFactoryTest.java | 137 Map<String, Object> serviceConfig = new HashMap<String, Object>();
138 serviceConfig.put("loadBalancingPolicy", "round_robin");
141 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig)
190 Map<String, Object> serviceConfig = null;
195 AutoConfiguredLoadBalancer.decideLoadBalancerFactory(servers, serviceConfig);
202 Map<String, Object> serviceConfig = null;
209 servers, serviceConfig);
216 Map<String, Object> serviceConfig = new HashMap<String, Object>();
217 serviceConfig.put("loadBalancingPolicy", "round_robin");
224 servers, serviceConfig);
[all...] |
| HedgingPolicyTest.java | 60 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj;
65 serviceConfigInterceptor.handleUpdate(serviceConfig);
132 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj;
137 serviceConfigInterceptor.handleUpdate(serviceConfig);
|
| RetryPolicyTest.java | 63 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj;
68 serviceConfigInterceptor.handleUpdate(serviceConfig);
141 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj;
146 serviceConfigInterceptor.handleUpdate(serviceConfig);
178 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj;
179 Throttle throttle = ServiceConfigUtil.getThrottlePolicy(serviceConfig);
|
| DnsNameResolverTest.java | 85 private final Map<String, Object> serviceConfig = new LinkedHashMap<String, Object>();
539 choice.put("serviceConfig", serviceConfig);
550 choice.put("serviceConfig", serviceConfig);
561 choice.put("serviceConfig", serviceConfig);
571 choice.put("serviceConfig", serviceConfig);
583 choice.put("serviceConfig", serviceConfig)
[all...] |
| ManagedChannelImplTest.java | [all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| ServiceConfigUtil.java | 66 static Throttle getThrottlePolicy(@Nullable Map<String, Object> serviceConfig) {
68 if (serviceConfig == null || !serviceConfig.containsKey(retryThrottlingKey)) {
91 Map<String, Object> throttling = getObject(serviceConfig, retryThrottlingKey);
263 Map<String, Object> serviceConfig) {
264 if (!serviceConfig.containsKey(SERVICE_CONFIG_METHOD_CONFIG_KEY)) {
267 return checkObjectList(getList(serviceConfig, SERVICE_CONFIG_METHOD_CONFIG_KEY));
275 public static String getLoadBalancingPolicyFromServiceConfig(Map<String, Object> serviceConfig) {
276 if (!serviceConfig.containsKey(SERVICE_CONFIG_LOAD_BALANCING_POLICY_KEY)) {
279 return getString(serviceConfig, SERVICE_CONFIG_LOAD_BALANCING_POLICY_KEY)
[all...] |
| DnsNameResolver.java | 68 private static final String SERVICE_CONFIG_CHOICE_SERVICE_CONFIG_KEY = "serviceConfig";
255 Map<String, Object> serviceConfig = null;
260 serviceConfig =
265 if (serviceConfig != null) {
272 if (serviceConfig != null) {
273 attrs.set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig);
382 logger.log(Level.FINE, "ServiceConfig resolution failure", txtRecordsException);
|
| ManagedChannelImpl.java | [all...] |
| ServiceConfigInterceptor.java | 76 void handleUpdate(@Nonnull Map<String, Object> serviceConfig) {
84 ServiceConfigUtil.getMethodConfigFromServiceConfig(serviceConfig);
128 * Equivalent of MethodConfig from a ServiceConfig with restrictions from Channel setting.
|
| /external/syzkaller/vendor/google.golang.org/grpc/resolver/ |
| resolver.go | 111 NewServiceConfig(serviceConfig string)
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| RoundRobinLoadBalancerTest.java | 433 Map<String, Object> serviceConfig = new HashMap<String, Object>();
434 serviceConfig.put("stickinessMetadataKey", "my-sticky-key");
436 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build();
465 Map<String, Object> serviceConfig = new HashMap<String, Object>();
466 serviceConfig.put("stickinessMetadataKey", "my-sticky-key");
468 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build();
495 Map<String, Object> serviceConfig = new HashMap<String, Object>();
496 serviceConfig.put("stickinessMetadataKey", "my-sticky-key");
498 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build();
540 Map<String, Object> serviceConfig = new HashMap<String, Object>()
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| RoundRobinLoadBalancerFactory.java | 136 Map<String, Object> serviceConfig =
138 if (serviceConfig != null) {
140 ServiceConfigUtil.getStickinessMetadataKeyFromServiceConfig(serviceConfig);
|
| /external/python/apitools/samples/servicemanagement_sample/servicemanagement_v1/ |
| servicemanagement_v1.py | 331 'serviceConfig',
362 serviceConfig: The service's generated configuration.
381 if FLAGS['serviceConfig'].present:
382 request.serviceConfig = apitools_base.JsonToMessage(messages.Service, FLAGS.serviceConfig)
[all...] |
| servicemanagement_v1_messages.py | 535 serviceConfig: The service configuration. Not set if errors occured during
540 serviceConfig = _messages.MessageField('Service', 2)
[all...] |
| /external/grpc-grpc-java/core/ |
| grpc-core-1.14.0.jar | |
