| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | GoogleDefaultProtocolNegotiator.java | 20 import io.grpc.internal.GrpcAttributes;
45 if (grpcHandler.getEagAttributes().get(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY) != null in newHandler()
46 || grpcHandler.getEagAttributes().get(GrpcAttributes.ATTR_LB_PROVIDED_BACKEND) != null) { in newHandler()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | GrpcAttributes.java | 25 public final class GrpcAttributes { class
46 private GrpcAttributes() {} in GrpcAttributes() method in GrpcAttributes
|
| D | AutoConfiguredLoadBalancerFactory.java | 85 Map<String, Object> configMap = attributes.get(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG); in handleResolvedAddressGroups()
161 if (s.getAttributes().get(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY) != null) { in decideLoadBalancerFactory()
|
| D | JndiResourceResolverFactory.java | 154 .set(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY, record.host) in resolveSrv()
|
| D | ManagedChannelImpl.java | 1273 config.get(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG); in onAddresses()
1369 config.get(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG)); in getThrottle()
|
| D | DnsNameResolver.java | 273 attrs.set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig);
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | GoogleDefaultProtocolNegotiatorTest.java | 26 import io.grpc.internal.GrpcAttributes;
52 Attributes.newBuilder().set(GrpcAttributes.ATTR_LB_PROVIDED_BACKEND, true).build(); in altsHandler()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 62 import io.grpc.internal.GrpcAttributes;
436 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withoutStickyHeader()
468 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withStickyHeader()
498 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickinessEnabled_withDifferentStickyHeaders()
543 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickiness_goToTransientFailure_pick_backToReady()
591 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickiness_goToTransientFailure_backToReady_pick()
644 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in stickiness_oneSubchannelShutdown()
700 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig1).build(); in stickiness_resolveTwice_metadataKeyChanged()
707 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig2).build(); in stickiness_resolveTwice_metadataKeyChanged()
719 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig1).build(); in stickiness_resolveTwice_metadataKeyUnChanged()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancer.java | 30 import io.grpc.internal.GrpcAttributes;
93 String lbAddrAuthority = server.getAttributes().get(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY); in handleResolvedAddressGroups()
|
| D | GrpclbState.java | 46 import io.grpc.internal.GrpcAttributes;
89 Attributes.newBuilder().set(GrpcAttributes.ATTR_LB_PROVIDED_BACKEND, true).build();
751 .set(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY, authority) in flattenLbAddressGroups()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 141 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in handleResolvedAddressGroups_shutsDownOldBalancer()
207 Attributes.newBuilder().set(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY, "ok").build())); in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
222 Attributes.newBuilder().set(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY, "ok").build())); in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
|
| D | ManagedChannelImplTest.java | 2235 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, new HashMap<String, Object>()) in channelTracing_serviceConfigChange()
2261 .set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig) in channelTracing_serviceConfigChange()
2615 .newBuilder().set(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, serviceConfig).build(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2723 GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, in badServiceConfigIsRecoverable()
2782 GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG, in badServiceConfigIsRecoverable()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 44 import io.grpc.internal.GrpcAttributes;
137 attributes.get(GrpcAttributes.NAME_RESOLVER_SERVICE_CONFIG); in handleResolvedAddressGroups()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 73 import io.grpc.internal.GrpcAttributes;
138 Attributes.newBuilder().set(GrpcAttributes.ATTR_LB_PROVIDED_BACKEND, true).build();
1543 .set(GrpcAttributes.ATTR_LB_ADDR_AUTHORITY, authority) in lbAttributes()
|