Creates a {@link ChannelCredentials} from the given jsonConfig, or {@code null} if the given config is invalid. The provider is free to ignore the con

Creates a new TsiHandshaker for use by the client.

Returns a {@link ClientInterceptor} with default stats implementation.

Returns a {@link ClientInterceptor} with default tracing implementation.

Creates a new configuration instance which will be used as the target for command-line arguments.

Creates a new ListenableFuture-style stub that supports unary calls on the service

Creates a new ListenableFuture-style stub that supports unary calls on the service

Creates an instance.

Creates an instance.

Creates a {@link LoadBalancer} that will be used inside a channel. @since 1.2.0

Obtain a new cache with a least-recently used eviction policy and the specified size limit. The backing caching implementation is provided by {@link L

Creates a new {@link Metadata} instance from serialized data, with some values pre-parsed. Metadata will mutate the passed in array. @param usedNames

Returns a new test-specific {@link NameResolver.Args} instance.

Creates a new resource resolver. The return value is {@code null} iff {@link #unavailabilityCause()} is not null;

Creates a new TsiHandshaker for use by the server.

Creates and starts a new {@link TestServiceImpl} server.

Returns a {@link ServerStreamTracer.Factory} with default stats implementation.

Returns a {@link ServerStreamTracer.Factory} with default tracing implementation.

Creates a new async stub that supports all call types for the service

Creates a new async stub that supports all call types for the service

Creates a new async stub that supports all call types for the service

Creates a new async stub that supports all call types for the service

Creates a new async stub that supports all call types for the service

Creates a new physical ClientStream that represents a retry/hedging attempt. The returned Client stream is not yet started.

Returns a test {@link SynchronizationContext}. <p>Exceptions will cause the test to fail with {@link AssertionError}.

Creates an interceptor that associates the {@link PeerUids#REMOTE_PEER} key in the request {@link Context} with a UID provided by the client in the {@

Utility method to call {@link StreamObserver#onNext(Object)} and {@link StreamObserver#onCompleted()} on the specified responseObserver.

Returns the next sequence number and atomically increases sequence with wraparound.

Notify all listeners that this context has been cancelled and immediately release any reference to them so that they may be garbage collected.

Helper for getting local address from {@link io.grpc.ClientCall#getAttributes()}.

Helper for getting local address from {@link io.grpc.ServerCall#getAttributes()}.

Helper for getting remote address from {@link io.grpc.ServerCall#getAttributes()}.

Helper for getting remote address from {@link io.grpc.ClientCall#getAttributes()}.

Handles updates on resolved addresses and attributes. @deprecated This will be removed in 1.22.0

We're now bound to the service. Only called once, and only if the binding succeeded.

Notifies the implementation that the binding has succeeded and we are now connected to the server's "endpoint" which can be reached at 'endpointBinder