Home
last modified time | relevance | path

Searched refs:serviceConfig (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServiceConfigInterceptorTest.java94 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig)); in withWaitForReady() local
96 interceptor.handleUpdate(serviceConfig); in withWaitForReady()
120 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig)); in withMaxRequestSize() local
122 interceptor.handleUpdate(serviceConfig); in withMaxRequestSize()
134 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig)); in withMaxRequestSize_pickSmallerExisting() local
136 interceptor.handleUpdate(serviceConfig); in withMaxRequestSize_pickSmallerExisting()
149 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig)); in withMaxRequestSize_pickSmallerNew() local
151 interceptor.handleUpdate(serviceConfig); in withMaxRequestSize_pickSmallerNew()
164 JsonObj serviceConfig = new JsonObj("methodConfig", new JsonList(methodConfig)); in withMaxResponseSize() local
166 interceptor.handleUpdate(serviceConfig); in withMaxResponseSize()
[all …]
DAutoConfiguredLoadBalancerFactoryTest.java141 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in handleResolvedAddressGroups_shutsDownOldBalancer() local
142 serviceConfig.put("loadBalancingPolicy", "round_robin"); in handleResolvedAddressGroups_shutsDownOldBalancer()
145 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in handleResolvedAddressGroups_shutsDownOldBalancer()
194 Map<String, Object> serviceConfig = null; in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst() local
199 AutoConfiguredLoadBalancer.decideLoadBalancerFactory(servers, serviceConfig); in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
206 Map<String, Object> serviceConfig = null; in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb() local
213 servers, serviceConfig); in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
220 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in decideLoadBalancerFactory_grpclbOverridesServiceConfig() local
221 serviceConfig.put("loadBalancingPolicy", "round_robin"); in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
228 servers, serviceConfig); in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
[all …]
DDnsNameResolverTest.java82 private final Map<String, Object> serviceConfig = new LinkedHashMap<String, Object>(); field in DnsNameResolverTest
384 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesJava()
395 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageDoesntMatchGo()
406 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageCaseInsensitive()
416 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesEmtpy()
428 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesMulti()
437 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageZeroAlwaysFails()
446 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageHundredAlwaysSucceeds()
455 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageAboveMatches50()
471 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageAtFails50()
[all …]
DRetryPolicyTest.java63 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj; in getRetryPolicies() local
68 serviceConfigInterceptor.handleUpdate(serviceConfig); in getRetryPolicies()
141 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj; in getRetryPolicies_retryDisabled() local
146 serviceConfigInterceptor.handleUpdate(serviceConfig); in getRetryPolicies_retryDisabled()
178 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj; in getThrottle() local
179 Throttle throttle = ServiceConfigUtil.getThrottlePolicy(serviceConfig); in getThrottle()
DHedgingPolicyTest.java60 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj; in getHedgingPolicies() local
65 serviceConfigInterceptor.handleUpdate(serviceConfig); in getHedgingPolicies()
132 Map<String, Object> serviceConfig = (Map<String, Object>) serviceConfigObj; in getRetryPolicies_hedgingDisabled() local
137 serviceConfigInterceptor.handleUpdate(serviceConfig); in getRetryPolicies_hedgingDisabled()
DManagedChannelImplTest.java2258 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in channelTracing_serviceConfigChange() local
2259 serviceConfig.put("methodConfig", new HashMap<String, Object>()); in channelTracing_serviceConfigChange()
2262 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in channelTracing_serviceConfigChange()
2613 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2614 serviceConfig.put("methodConfig", Arrays.<Object>asList(methodConfig)); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2616 .newBuilder().set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServiceConfigUtil.java66 static Throttle getThrottlePolicy(@Nullable Map<String, Object> serviceConfig) { in getThrottlePolicy() argument
68 if (serviceConfig == null || !serviceConfig.containsKey(retryThrottlingKey)) { in getThrottlePolicy()
91 Map<String, Object> throttling = getObject(serviceConfig, retryThrottlingKey); in getThrottlePolicy()
263 Map<String, Object> serviceConfig) { in getMethodConfigFromServiceConfig() argument
264 if (!serviceConfig.containsKey(SERVICE_CONFIG_METHOD_CONFIG_KEY)) { in getMethodConfigFromServiceConfig()
267 return checkObjectList(getList(serviceConfig, SERVICE_CONFIG_METHOD_CONFIG_KEY)); in getMethodConfigFromServiceConfig()
275 public static String getLoadBalancingPolicyFromServiceConfig(Map<String, Object> serviceConfig) { in getLoadBalancingPolicyFromServiceConfig() argument
276 if (!serviceConfig.containsKey(SERVICE_CONFIG_LOAD_BALANCING_POLICY_KEY)) { in getLoadBalancingPolicyFromServiceConfig()
279 return getString(serviceConfig, SERVICE_CONFIG_LOAD_BALANCING_POLICY_KEY); in getLoadBalancingPolicyFromServiceConfig()
287 Map<String, Object> serviceConfig) { in getStickinessMetadataKeyFromServiceConfig() argument
[all …]
DDnsNameResolver.java229 Map<String, Object> serviceConfig = null;
234 serviceConfig =
239 if (serviceConfig != null) {
246 if (serviceConfig != null) {
247 attrs.set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig);
DManagedChannelImpl.java1271 final Map<String, Object> serviceConfig = in onAddresses() local
1273 if (channelTracer != null && serviceConfig != null in onAddresses()
1274 && !serviceConfig.equals(lastServiceConfig)) { in onAddresses()
1280 lastServiceConfig = serviceConfig; in onAddresses()
1293 if (serviceConfig != null) { in onAddresses()
1295 serviceConfigInterceptor.handleUpdate(serviceConfig); in onAddresses()
DServiceConfigInterceptor.java76 void handleUpdate(@Nonnull Map<String, Object> serviceConfig) { in handleUpdate() argument
84 ServiceConfigUtil.getMethodConfigFromServiceConfig(serviceConfig); in handleUpdate()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java433 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in stickinessEnabled_withoutStickyHeader() local
434 serviceConfig.put("stickinessMetadataKey", "my-sticky-key"); in stickinessEnabled_withoutStickyHeader()
436 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withoutStickyHeader()
465 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in stickinessEnabled_withStickyHeader() local
466 serviceConfig.put("stickinessMetadataKey", "my-sticky-key"); in stickinessEnabled_withStickyHeader()
468 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withStickyHeader()
495 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in stickinessEnabled_withDifferentStickyHeaders() local
496 serviceConfig.put("stickinessMetadataKey", "my-sticky-key"); in stickinessEnabled_withDifferentStickyHeaders()
498 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withDifferentStickyHeaders()
540 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in stickiness_goToTransientFailure_pick_backToReady() local
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java136 Map<String, Object> serviceConfig = in handleResolvedAddressGroups() local
138 if (serviceConfig != null) { in handleResolvedAddressGroups()
140 ServiceConfigUtil.getStickinessMetadataKeyFromServiceConfig(serviceConfig); in handleResolvedAddressGroups()
/external/python/apitools/samples/servicemanagement_sample/servicemanagement_v1/
Dservicemanagement_v1_messages.py540 serviceConfig = _messages.MessageField('Service', 2) variable in ConvertConfigResponse
1258 serviceConfig = _messages.MessageField('Service', 6) variable in ManagedService