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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 classio.grpc.Server
- Throws:
java.io.IOException
-
internalStart
private void internalStart()
-
shutdown
public io.grpc.Server shutdown()
- Specified by:
shutdown
in classio.grpc.Server
-
shutdownNow
public io.grpc.Server shutdownNow()
- Specified by:
shutdownNow
in classio.grpc.Server
-
internalShutdown
private void internalShutdown()
-
isShutdown
public boolean isShutdown()
- Specified by:
isShutdown
in classio.grpc.Server
-
isTerminated
public boolean isTerminated()
- Specified by:
isTerminated
in classio.grpc.Server
-
awaitTermination
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
- Specified by:
awaitTermination
in classio.grpc.Server
- Throws:
java.lang.InterruptedException
-
awaitTermination
public void awaitTermination() throws java.lang.InterruptedException
- Specified by:
awaitTermination
in classio.grpc.Server
- Throws:
java.lang.InterruptedException
-
getPort
public int getPort()
- Overrides:
getPort
in classio.grpc.Server
-
getListenSockets
public java.util.List<? extends java.net.SocketAddress> getListenSockets()
- Overrides:
getListenSockets
in classio.grpc.Server
-
getServices
public java.util.List<io.grpc.ServerServiceDefinition> getServices()
- Overrides:
getServices
in classio.grpc.Server
-
getImmutableServices
public java.util.List<io.grpc.ServerServiceDefinition> getImmutableServices()
- Overrides:
getImmutableServices
in classio.grpc.Server
-
getMutableServices
public java.util.List<io.grpc.ServerServiceDefinition> getMutableServices()
- Overrides:
getMutableServices
in classio.grpc.Server
-
startDelegateServer
private void startDelegateServer()
-
-