Package io.grpc.xds

Class XdsServerWrapper

java.lang.Object

io.grpc.Server

io.grpc.xds.XdsServerWrapper

final class XdsServerWrapper
extends io.grpc.Server

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	XdsServerWrapper.ConfigApplyingInterceptor
private final class	XdsServerWrapper.DiscoveryState
private final class	XdsServerWrapper.RestartTask
(package private) static class	XdsServerWrapper.ServerRoutingConfig	The HttpConnectionManager level configuration.

Field Summary

Fields

Modifier and Type	Field	Description
static final io.grpc.Attributes.Key<AtomicReference<XdsServerWrapper.ServerRoutingConfig>>	ATTR_SERVER_ROUTING_CONFIG
private io.grpc.Server	delegate
private final io.grpc.ServerBuilder<?>	delegateBuilder
private XdsServerWrapper.DiscoveryState	discoveryState
private final FilterChainSelectorManager	filterChainSelectorManager
private final FilterRegistry	filterRegistry
private boolean	initialStarted
private final com.google.common.util.concurrent.SettableFuture<Exception>	initialStartFuture
private final CountDownLatch	internalTerminationLatch
private boolean	isServing
private final XdsServerBuilder.XdsServingStatusListener	listener
private final String	listenerAddress
private static final Logger	logger
private final ThreadSafeRandom	random
private io.grpc.SynchronizationContext.ScheduledHandle	restartTimer
(package private) static final long	RETRY_DELAY_NANOS
private boolean	sharedTimeService
private final AtomicBoolean	shutdown
private final AtomicBoolean	started
private final io.grpc.SynchronizationContext	syncContext
private final ScheduledExecutorService	timeService
private XdsClient	xdsClient
private io.grpc.internal.ObjectPool<XdsClient>	xdsClientPool
private final XdsClientPoolFactory	xdsClientPoolFactory

Constructor Summary

Constructors

Constructor	Description
XdsServerWrapper(String listenerAddress, io.grpc.ServerBuilder<?> delegateBuilder, XdsServerBuilder.XdsServingStatusListener listener, FilterChainSelectorManager filterChainSelectorManager, XdsClientPoolFactory xdsClientPoolFactory, FilterRegistry filterRegistry)
XdsServerWrapper(String listenerAddress, io.grpc.ServerBuilder<?> delegateBuilder, XdsServerBuilder.XdsServingStatusListener listener, FilterChainSelectorManager filterChainSelectorManager, XdsClientPoolFactory xdsClientPoolFactory, FilterRegistry filterRegistry, ScheduledExecutorService timeService)

Method Summary

Modifier and Type	Method	Description
void	awaitTermination()
boolean	awaitTermination(long timeout, TimeUnit unit)
List<io.grpc.ServerServiceDefinition>	getImmutableServices()
List<? extends SocketAddress>	getListenSockets()
List<io.grpc.ServerServiceDefinition>	getMutableServices()
int	getPort()
List<io.grpc.ServerServiceDefinition>	getServices()
private void	internalShutdown()
private void	internalStart()
boolean	isShutdown()
boolean	isTerminated()
io.grpc.Server	shutdown()
io.grpc.Server	shutdownNow()
io.grpc.Server	start()
private void	startDelegateServer()

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final Logger logger

syncContext

private final io.grpc.SynchronizationContext syncContext

ATTR_SERVER_ROUTING_CONFIG

public static final io.grpc.Attributes.Key<AtomicReference<XdsServerWrapper.ServerRoutingConfig>> ATTR_SERVER_ROUTING_CONFIG

RETRY_DELAY_NANOS

static final long RETRY_DELAY_NANOS

listenerAddress

private final String listenerAddress

delegateBuilder

private final io.grpc.ServerBuilder<?> delegateBuilder

sharedTimeService

private boolean sharedTimeService

timeService

private final ScheduledExecutorService timeService

filterRegistry

private final FilterRegistry filterRegistry

random

private final ThreadSafeRandom random

xdsClientPoolFactory

private final XdsClientPoolFactory xdsClientPoolFactory

listener

private final XdsServerBuilder.XdsServingStatusListener listener

filterChainSelectorManager

private final FilterChainSelectorManager filterChainSelectorManager

started

private final AtomicBoolean started

shutdown

private final AtomicBoolean shutdown

isServing

private boolean isServing

internalTerminationLatch

private final CountDownLatch internalTerminationLatch

initialStartFuture

private final com.google.common.util.concurrent.SettableFuture<Exception> initialStartFuture

initialStarted

private boolean initialStarted

restartTimer

private io.grpc.SynchronizationContext.ScheduledHandle restartTimer

xdsClientPool

private io.grpc.internal.ObjectPool<XdsClient> xdsClientPool

xdsClient

private XdsClient xdsClient

discoveryState

private XdsServerWrapper.DiscoveryState discoveryState

delegate

private volatile io.grpc.Server delegate

Constructor Details

XdsServerWrapper

XdsServerWrapper(String listenerAddress,
 io.grpc.ServerBuilder<?> delegateBuilder,
 XdsServerBuilder.XdsServingStatusListener listener,
 FilterChainSelectorManager filterChainSelectorManager,
 XdsClientPoolFactory xdsClientPoolFactory,
 FilterRegistry filterRegistry)

XdsServerWrapper

XdsServerWrapper(String listenerAddress,
 io.grpc.ServerBuilder<?> delegateBuilder,
 XdsServerBuilder.XdsServingStatusListener listener,
 FilterChainSelectorManager filterChainSelectorManager,
 XdsClientPoolFactory xdsClientPoolFactory,
 FilterRegistry filterRegistry,
 ScheduledExecutorService timeService)

Method Details

start

public io.grpc.Server start()
                     throws IOException

Specified by:

start in class io.grpc.Server

Throws:

IOException

internalStart

private void internalStart()

shutdown

public io.grpc.Server shutdown()

Specified by:

shutdown in class io.grpc.Server

shutdownNow

public io.grpc.Server shutdownNow()

Specified by:

shutdownNow in class io.grpc.Server

internalShutdown

private void internalShutdown()

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in class io.grpc.Server

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in class io.grpc.Server

awaitTermination

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

Specified by:

awaitTermination in class io.grpc.Server

Throws:

InterruptedException

awaitTermination

public void awaitTermination()
                      throws InterruptedException

Specified by:

awaitTermination in class io.grpc.Server

Throws:

InterruptedException

getPort

public int getPort()

Overrides:

getPort in class io.grpc.Server

getListenSockets

public List<? extends SocketAddress> getListenSockets()

Overrides:

getListenSockets in class io.grpc.Server

getServices

public List<io.grpc.ServerServiceDefinition> getServices()

Overrides:

getServices in class io.grpc.Server

getImmutableServices

public List<io.grpc.ServerServiceDefinition> getImmutableServices()

Overrides:

getImmutableServices in class io.grpc.Server

getMutableServices

public List<io.grpc.ServerServiceDefinition> getMutableServices()

Overrides:

getMutableServices in class io.grpc.Server

startDelegateServer

private void startDelegateServer()