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 ClassesModifier and TypeClassDescription(package private) final class
private final class
private final class
(package private) static class
The HttpConnectionManager level configuration. -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final io.grpc.Attributes.Key
<AtomicReference<XdsServerWrapper.ServerRoutingConfig>> private io.grpc.Server
private final io.grpc.ServerBuilder
<?> private XdsServerWrapper.DiscoveryState
private final FilterChainSelectorManager
private final FilterRegistry
private boolean
private final com.google.common.util.concurrent.SettableFuture
<Exception> private final CountDownLatch
private boolean
private final XdsServerBuilder.XdsServingStatusListener
private final String
private static final Logger
private final ThreadSafeRandom
private io.grpc.SynchronizationContext.ScheduledHandle
(package private) static final long
private boolean
private final AtomicBoolean
private final AtomicBoolean
private final io.grpc.SynchronizationContext
private final ScheduledExecutorService
private XdsClient
private io.grpc.internal.ObjectPool
<XdsClient> private final XdsClientPoolFactory
-
Constructor Summary
ConstructorsConstructorDescriptionXdsServerWrapper
(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 TypeMethodDescriptionvoid
boolean
awaitTermination
(long timeout, TimeUnit unit) List
<io.grpc.ServerServiceDefinition> List
<? extends SocketAddress> List
<io.grpc.ServerServiceDefinition> int
getPort()
List
<io.grpc.ServerServiceDefinition> private void
private void
boolean
boolean
io.grpc.Server
shutdown()
io.grpc.Server
io.grpc.Server
start()
private void
-
Field Details
-
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
-
delegateBuilder
private final io.grpc.ServerBuilder<?> delegateBuilder -
timeService
-
filterRegistry
-
random
-
xdsClientPoolFactory
-
listener
-
filterChainSelectorManager
-
started
-
shutdown
-
isServing
private boolean isServing -
internalTerminationLatch
-
initialStartFuture
-
initialStarted
private boolean initialStarted -
restartTimer
private io.grpc.SynchronizationContext.ScheduledHandle restartTimer -
xdsClientPool
-
xdsClient
-
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
- Specified by:
start
in classio.grpc.Server
- Throws:
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
- Specified by:
awaitTermination
in classio.grpc.Server
- Throws:
InterruptedException
-
awaitTermination
- Specified by:
awaitTermination
in classio.grpc.Server
- Throws:
InterruptedException
-
getPort
public int getPort()- Overrides:
getPort
in classio.grpc.Server
-
getListenSockets
- Overrides:
getListenSockets
in classio.grpc.Server
-
getServices
- Overrides:
getServices
in classio.grpc.Server
-
getImmutableServices
- Overrides:
getImmutableServices
in classio.grpc.Server
-
getMutableServices
- Overrides:
getMutableServices
in classio.grpc.Server
-
startDelegateServer
private void startDelegateServer()
-