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) class	XdsServerWrapper.ConfigApplyingInterceptor
private class	XdsServerWrapper.DiscoveryState
private class	XdsServerWrapper.RestartTask
(package private) static class	XdsServerWrapper.ServerRoutingConfig	The HttpConnectionManager level configuration.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	awaitTermination()
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
java.util.List<io.grpc.ServerServiceDefinition>	getImmutableServices()
java.util.List<? extends java.net.SocketAddress>	getListenSockets()
java.util.List<io.grpc.ServerServiceDefinition>	getMutableServices()
int	getPort()
java.util.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 Detail

logger

private static final java.util.logging.Logger logger

syncContext

private final io.grpc.SynchronizationContext syncContext

ATTR_SERVER_ROUTING_CONFIG

public static final io.grpc.Attributes.Key<java.util.concurrent.atomic.AtomicReference<XdsServerWrapper.ServerRoutingConfig>> ATTR_SERVER_ROUTING_CONFIG

RETRY_DELAY_NANOS

static final long RETRY_DELAY_NANOS

listenerAddress

private final java.lang.String listenerAddress

delegateBuilder

private final io.grpc.ServerBuilder<?> delegateBuilder

sharedTimeService

private boolean sharedTimeService

timeService

private final java.util.concurrent.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 java.util.concurrent.atomic.AtomicBoolean started

shutdown

private final java.util.concurrent.atomic.AtomicBoolean shutdown

isServing

private boolean isServing

internalTerminationLatch

private final java.util.concurrent.CountDownLatch internalTerminationLatch

initialStartFuture

private final com.google.common.util.concurrent.SettableFuture<java.lang.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 Detail

XdsServerWrapper

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

XdsServerWrapper

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

Method Detail

start

public io.grpc.Server start()
                     throws java.io.IOException

Specified by:

start in class io.grpc.Server

Throws:

java.io.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,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Specified by:

awaitTermination in class io.grpc.Server

Throws:

java.lang.InterruptedException

awaitTermination

public void awaitTermination()
                      throws java.lang.InterruptedException

Specified by:

awaitTermination in class io.grpc.Server

Throws:

java.lang.InterruptedException

getPort

public int getPort()

Overrides:

getPort in class io.grpc.Server

getListenSockets

public java.util.List<? extends java.net.SocketAddress> getListenSockets()

Overrides:

getListenSockets in class io.grpc.Server

getServices

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

Overrides:

getServices in class io.grpc.Server

getImmutableServices

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

Overrides:

getImmutableServices in class io.grpc.Server

getMutableServices

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

Overrides:

getMutableServices in class io.grpc.Server

startDelegateServer

private void startDelegateServer()