Package io.grpc.internal
Class ManagedChannelImpl.UncommittedRetriableStreamsRegistry
java.lang.Object
io.grpc.internal.ManagedChannelImpl.UncommittedRetriableStreamsRegistry
- Enclosing class:
ManagedChannelImpl
A registry that prevents channel shutdown from killing existing retry attempts that are in
backoff.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Object
(package private) Status
(package private) Collection
<ClientStream> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) Status
add
(RetriableStream<?> retriableStream) Registers a RetriableStream and return null if not shutdown, otherwise just returns the shutdown Status.(package private) void
onShutdown
(Status reason) (package private) void
onShutdownNow
(Status reason) (package private) void
remove
(RetriableStream<?> retriableStream)
-
Field Details
-
lock
-
uncommittedRetriableStreams
Collection<ClientStream> uncommittedRetriableStreams -
shutdownStatus
Status shutdownStatus
-
-
Constructor Details
-
UncommittedRetriableStreamsRegistry
private UncommittedRetriableStreamsRegistry()
-
-
Method Details
-
onShutdown
-
onShutdownNow
-
add
Registers a RetriableStream and return null if not shutdown, otherwise just returns the shutdown Status. -
remove
-