@Test public void checkAuthority_failsOnInvalidHost() { thrown.expect(IllegalArgumentException.class); thrown.expectMessage("No host in authority"); GrpcUtil.checkAuthority("bad_host"); }
public static String checkAuthority(String authority) { URI uri = authorityToUri(authority); checkArgument(uri.getHost() != null, "No host in authority '%s'", authority); checkArgument(uri.getUserInfo() == null, "Userinfo must not be present on authority: '%s'", authority); return authority; }
GrpcUtil { public static String checkAuthority(String authority) { URI uri = authorityToUri(authority); checkArgument(uri.getHost() != null, "No host in authority '%s'", authority); checkArgument(uri.getUserInfo() == null, "Userinfo must not be present on authority: '%s'", authority); return authority; } }
GrpcUtil { public static String checkAuthority(String authority) { URI uri = authorityToUri(authority); checkArgument(uri.getHost() != null, "No host in authority '%s'", authority); checkArgument(uri.getUserInfo() == null, "Userinfo must not be present on authority: '%s'", authority); return authority; } private  GrpcUtil(); }
GrpcUtil { public static String checkAuthority(String authority) { URI uri = authorityToUri(authority); checkArgument(uri.getHost() != null, "No host in authority '%s'", authority); checkArgument(uri.getUserInfo() == null, "Userinfo must not be present on authority: '%s'", authority); return authority; } private  GrpcUtil(); static boolean shouldBeCountedForInUse(CallOptions callOptions); static ProxyDetector getDefaultProxyDetector(); static Status httpStatusToGrpcStatus(int httpStatusCode); static boolean isGrpcContentType(String contentType); static String getGrpcUserAgent(
      String transportName, @Nullable String applicationUserAgent); static URI authorityToUri(String authority); static String checkAuthority(String authority); static String authorityFromHostAndPort(String host, int port); static ThreadFactory getThreadFactory(String nameFormat, boolean daemon); static String getHost(InetSocketAddress addr); static void closeQuietly(@Nullable InputStream message); static EquivalentAddressGroup getAddressGroupFromTransport(ClientTransport transport); }
GrpcUtil { public static String checkAuthority(String authority) { URI uri = authorityToUri(authority); checkArgument(uri.getHost() != null, "No host in authority '%s'", authority); checkArgument(uri.getUserInfo() == null, "Userinfo must not be present on authority: '%s'", authority); return authority; } private  GrpcUtil(); static boolean shouldBeCountedForInUse(CallOptions callOptions); static ProxyDetector getDefaultProxyDetector(); static Status httpStatusToGrpcStatus(int httpStatusCode); static boolean isGrpcContentType(String contentType); static String getGrpcUserAgent(
      String transportName, @Nullable String applicationUserAgent); static URI authorityToUri(String authority); static String checkAuthority(String authority); static String authorityFromHostAndPort(String host, int port); static ThreadFactory getThreadFactory(String nameFormat, boolean daemon); static String getHost(InetSocketAddress addr); static void closeQuietly(@Nullable InputStream message); static EquivalentAddressGroup getAddressGroupFromTransport(ClientTransport transport); static final Charset US_ASCII; static final boolean IS_RESTRICTED_APPENGINE; static final Metadata.Key<Long> TIMEOUT_KEY; static final Metadata.Key<String> MESSAGE_ENCODING_KEY; static final Metadata.Key<byte[]> MESSAGE_ACCEPT_ENCODING_KEY; static final Metadata.Key<String> CONTENT_ENCODING_KEY; static final Metadata.Key<byte[]> CONTENT_ACCEPT_ENCODING_KEY; static final Metadata.Key<String> CONTENT_TYPE_KEY; static final Metadata.Key<String> TE_HEADER; static final Metadata.Key<String> USER_AGENT_KEY; static final int DEFAULT_PORT_PLAINTEXT; static final int DEFAULT_PORT_SSL; static final String CONTENT_TYPE_GRPC; static final String HTTP_METHOD; static final String TE_TRAILERS; static final String TIMEOUT; static final String MESSAGE_ENCODING; static final String MESSAGE_ACCEPT_ENCODING; static final String CONTENT_ENCODING; static final String CONTENT_ACCEPT_ENCODING; static final int DEFAULT_MAX_MESSAGE_SIZE; static final int DEFAULT_MAX_HEADER_LIST_SIZE; static final Splitter ACCEPT_ENCODING_SPLITTER; static final long DEFAULT_KEEPALIVE_TIME_NANOS; static final long DEFAULT_KEEPALIVE_TIMEOUT_NANOS; static final long KEEPALIVE_TIME_NANOS_DISABLED; static final long DEFAULT_SERVER_KEEPALIVE_TIME_NANOS; static final long DEFAULT_SERVER_KEEPALIVE_TIMEOUT_NANOS; static final long SERVER_KEEPALIVE_TIME_NANOS_DISABLED; static final ProxyDetector DEFAULT_PROXY_DETECTOR; static final ProxyDetector NOOP_PROXY_DETECTOR; static final CallOptions.Key<Boolean> CALL_OPTIONS_RPC_OWNED_BY_BALANCER; static final Resource<Executor> SHARED_CHANNEL_EXECUTOR; static final Resource<ScheduledExecutorService> TIMER_SERVICE; static final Supplier<Stopwatch> STOPWATCH_SUPPLIER; }