@Test public void makeTargetStringForDirectAddress_scopedIpv6() throws Exception { InetSocketAddress address = new InetSocketAddress("0:0:0:0:0:0:0:0%0", 10005); assertEquals("/0:0:0:0:0:0:0:0%0:10005", address.toString()); String target = AbstractManagedChannelImplBuilder.makeTargetStringForDirectAddress(address); URI uri = new URI(target); assertEquals("directaddress: assertEquals(target, uri.toString()); }
@VisibleForTesting static String makeTargetStringForDirectAddress(SocketAddress address) { try { return new URI(DIRECT_ADDRESS_SCHEME, "", "/" + address, null).toString(); } catch (URISyntaxException e) { throw new RuntimeException(e); } }
AbstractManagedChannelImplBuilder extends ManagedChannelBuilder<T> { @VisibleForTesting static String makeTargetStringForDirectAddress(SocketAddress address) { try { return new URI(DIRECT_ADDRESS_SCHEME, "", "/" + address, null).toString(); } catch (URISyntaxException e) { throw new RuntimeException(e); } } }
AbstractManagedChannelImplBuilder extends ManagedChannelBuilder<T> { @VisibleForTesting static String makeTargetStringForDirectAddress(SocketAddress address) { try { return new URI(DIRECT_ADDRESS_SCHEME, "", "/" + address, null).toString(); } catch (URISyntaxException e) { throw new RuntimeException(e); } } protected  AbstractManagedChannelImplBuilder(String target); protected  AbstractManagedChannelImplBuilder(SocketAddress directServerAddress, String authority); }
AbstractManagedChannelImplBuilder extends ManagedChannelBuilder<T> { @VisibleForTesting static String makeTargetStringForDirectAddress(SocketAddress address) { try { return new URI(DIRECT_ADDRESS_SCHEME, "", "/" + address, null).toString(); } catch (URISyntaxException e) { throw new RuntimeException(e); } } protected  AbstractManagedChannelImplBuilder(String target); protected  AbstractManagedChannelImplBuilder(SocketAddress directServerAddress, String authority); static ManagedChannelBuilder<?> forAddress(String name, int port); static ManagedChannelBuilder<?> forTarget(String target); @Override T maxInboundMessageSize(int max); @Override final T directExecutor(); @Override final T executor(Executor executor); @Override final T intercept(List<ClientInterceptor> interceptors); @Override final T intercept(ClientInterceptor... interceptors); @Override final T nameResolverFactory(NameResolver.Factory resolverFactory); @Override final T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory); @Override final T enableFullStreamDecompression(); @Override final T decompressorRegistry(DecompressorRegistry registry); @Override final T compressorRegistry(CompressorRegistry registry); @Override final T userAgent(@Nullable String userAgent); @Override final T overrideAuthority(String authority); @Override final T idleTimeout(long value, TimeUnit unit); @Override final T maxRetryAttempts(int maxRetryAttempts); @Override final T maxHedgedAttempts(int maxHedgedAttempts); @Override final T retryBufferSize(long bytes); @Override final T perRpcBufferLimit(long bytes); @Override final T disableRetry(); @Override final T enableRetry(); @Override final T setBinaryLog(BinaryLog binlog); @Override T maxTraceEvents(int maxTraceEvents); @Override ManagedChannel build(); }
AbstractManagedChannelImplBuilder extends ManagedChannelBuilder<T> { @VisibleForTesting static String makeTargetStringForDirectAddress(SocketAddress address) { try { return new URI(DIRECT_ADDRESS_SCHEME, "", "/" + address, null).toString(); } catch (URISyntaxException e) { throw new RuntimeException(e); } } protected  AbstractManagedChannelImplBuilder(String target); protected  AbstractManagedChannelImplBuilder(SocketAddress directServerAddress, String authority); static ManagedChannelBuilder<?> forAddress(String name, int port); static ManagedChannelBuilder<?> forTarget(String target); @Override T maxInboundMessageSize(int max); @Override final T directExecutor(); @Override final T executor(Executor executor); @Override final T intercept(List<ClientInterceptor> interceptors); @Override final T intercept(ClientInterceptor... interceptors); @Override final T nameResolverFactory(NameResolver.Factory resolverFactory); @Override final T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory); @Override final T enableFullStreamDecompression(); @Override final T decompressorRegistry(DecompressorRegistry registry); @Override final T compressorRegistry(CompressorRegistry registry); @Override final T userAgent(@Nullable String userAgent); @Override final T overrideAuthority(String authority); @Override final T idleTimeout(long value, TimeUnit unit); @Override final T maxRetryAttempts(int maxRetryAttempts); @Override final T maxHedgedAttempts(int maxHedgedAttempts); @Override final T retryBufferSize(long bytes); @Override final T perRpcBufferLimit(long bytes); @Override final T disableRetry(); @Override final T enableRetry(); @Override final T setBinaryLog(BinaryLog binlog); @Override T maxTraceEvents(int maxTraceEvents); @Override ManagedChannel build();  }