Package com.google.cloud.grpc.fallback

Class GcpFallbackChannel

java.lang.Object

io.grpc.Channel

io.grpc.ManagedChannel

com.google.cloud.grpc.fallback.GcpFallbackChannel

public class GcpFallbackChannel
extends io.grpc.ManagedChannel

Constructor Summary

Constructors

Constructor	Description
GcpFallbackChannel(GcpFallbackChannelOptions options, io.grpc.ManagedChannelBuilder<?> primaryChannelBuilder, io.grpc.ManagedChannelBuilder<?> fallbackChannelBuilder)
GcpFallbackChannel(GcpFallbackChannelOptions options, io.grpc.ManagedChannel primaryChannel, io.grpc.ManagedChannel fallbackChannel)

Method Summary

Modifier and Type	Method	Description
String	authority()
boolean	awaitTermination(long timeout, TimeUnit unit)
boolean	isInFallbackMode()
boolean	isShutdown()
boolean	isTerminated()
<RequestT, ResponseT> io.grpc.ClientCall<RequestT,ResponseT>	newCall(io.grpc.MethodDescriptor<RequestT,ResponseT> methodDescriptor, io.grpc.CallOptions callOptions)
io.grpc.ManagedChannel	shutdown()
io.grpc.ManagedChannel	shutdownNow()

Methods inherited from class io.grpc.ManagedChannel

enterIdle, getState, notifyWhenStateChanged, resetConnectBackoff

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GcpFallbackChannel

public GcpFallbackChannel(GcpFallbackChannelOptions options,
 io.grpc.ManagedChannel primaryChannel,
 io.grpc.ManagedChannel fallbackChannel)

GcpFallbackChannel

public GcpFallbackChannel(GcpFallbackChannelOptions options,
 io.grpc.ManagedChannelBuilder<?> primaryChannelBuilder,
 io.grpc.ManagedChannelBuilder<?> fallbackChannelBuilder)

Method Details

isInFallbackMode

public boolean isInFallbackMode()

newCall

public <RequestT,
ResponseT>
io.grpc.ClientCall<RequestT,ResponseT> newCall(io.grpc.MethodDescriptor<RequestT,ResponseT> methodDescriptor,
 io.grpc.CallOptions callOptions)

Specified by:

newCall in class io.grpc.Channel

authority

public String authority()

Specified by:

authority in class io.grpc.Channel

shutdown

public io.grpc.ManagedChannel shutdown()

Specified by:

shutdown in class io.grpc.ManagedChannel

shutdownNow

public io.grpc.ManagedChannel shutdownNow()

Specified by:

shutdownNow in class io.grpc.ManagedChannel

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in class io.grpc.ManagedChannel

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in class io.grpc.ManagedChannel

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in class io.grpc.ManagedChannel

Throws:

InterruptedException