Home
last modified time | relevance | path

Searched refs:serviceConfig (Results 1 – 15 of 15) 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.java137 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in handleResolvedAddressGroups_shutsDownOldBalancer() local
138 serviceConfig.put("loadBalancingPolicy", "round_robin"); in handleResolvedAddressGroups_shutsDownOldBalancer()
141 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in handleResolvedAddressGroups_shutsDownOldBalancer()
190 Map<String, Object> serviceConfig = null; in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst() local
195 AutoConfiguredLoadBalancer.decideLoadBalancerFactory(servers, serviceConfig); in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
202 Map<String, Object> serviceConfig = null; in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb() local
209 servers, serviceConfig); in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
216 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in decideLoadBalancerFactory_grpclbOverridesServiceConfig() local
217 serviceConfig.put("loadBalancingPolicy", "round_robin"); in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
224 servers, serviceConfig); in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
[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()
DDnsNameResolverTest.java85 private final Map<String, Object> serviceConfig = new LinkedHashMap<String, Object>(); field in DnsNameResolverTest
539 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesJava()
550 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageDoesntMatchGo()
561 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageCaseInsensitive()
571 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesEmtpy()
583 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_clientLanguageMatchesMulti()
592 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageZeroAlwaysFails()
601 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageHundredAlwaysSucceeds()
610 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageAboveMatches50()
626 choice.put("serviceConfig", serviceConfig); in maybeChooseServiceConfig_percentageAtFails50()
[all …]
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.java2257 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in channelTracing_serviceConfigChange() local
2258 serviceConfig.put("methodConfig", new HashMap<String, Object>()); in channelTracing_serviceConfigChange()
2261 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in channelTracing_serviceConfigChange()
2612 Map<String, Object> serviceConfig = new HashMap<String, Object>(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2613 serviceConfig.put("methodConfig", Arrays.<Object>asList(methodConfig)); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2615 .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.java255 Map<String, Object> serviceConfig = null;
260 serviceConfig =
265 if (serviceConfig != null) {
272 if (serviceConfig != null) {
273 attrs.set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig);
DManagedChannelImpl.java1272 final Map<String, Object> serviceConfig = in onAddresses() local
1274 if (channelTracer != null && serviceConfig != null in onAddresses()
1275 && !serviceConfig.equals(lastServiceConfig)) { in onAddresses()
1281 lastServiceConfig = serviceConfig; in onAddresses()
1294 if (serviceConfig != null) { in onAddresses()
1296 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/syzkaller/vendor/google.golang.org/grpc/resolver/
Dresolver.go111 NewServiceConfig(serviceConfig string)
/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.py382 request.serviceConfig = apitools_base.JsonToMessage(messages.Service, FLAGS.serviceConfig)
Dservicemanagement_v1_messages.py540 serviceConfig = _messages.MessageField('Service', 2) variable in ConvertConfigResponse
1258 serviceConfig = _messages.MessageField('Service', 6) variable in ManagedService