- 2.70.0 (latest)
- 2.69.0
- 2.68.2
- 2.67.0
- 2.66.0
- 2.65.0
- 2.63.1
- 2.62.0
- 2.61.0
- 2.60.0
- 2.59.1
- 2.58.0
- 2.57.0
- 2.55.0
- 2.54.1
- 2.53.0
- 2.52.0
- 2.51.0
- 2.50.0
- 2.49.0
- 2.48.1
- 2.47.0
- 2.46.1
- 2.45.0
- 2.43.0
- 2.42.0
- 2.41.0
- 2.39.0
- 2.38.0
- 2.37.0
- 2.36.0
- 2.35.0
- 2.34.1
- 2.33.0
- 2.32.1
- 2.31.1
- 2.30.1
- 2.24.0
- 2.23.3
- 2.22.0
- 2.21.0
- 2.20.1
- 2.19.6
- 2.18.7
- 2.17.0
- 2.16.0
- 2.15.0
- 2.14.0
- 2.13.0
- 2.12.2
- 2.11.0
- 2.10.0
- 2.9.0
- 2.8.1
- 2.7.1
public
final
class
Watchdog
implements
Runnable
,
BackgroundResource
Prevents the streams from hanging indefinitely. This middleware garbage collects idle streams in case the user forgot to close a ServerStream or if a connection is reset and GRPC does not get notified.
For every checkInterval
, this class checks two thresholds:
- waitingTimeout: the amount of time to wait for a response (after the caller signaled demand) before forcefully closing the stream. Duration.ZERO disables the timeout.
- idleTimeout: the amount of time to wait before assuming that the caller forgot to close the stream and forcefully closing the stream. This is measured from the last time the caller had no outstanding demand. Duration.ZERO disables the timeout.
Static Methods
create(ApiClock clock, Duration scheduleInterval, ScheduledExecutorService executor)
public
static
Watchdog
create
(
ApiClock
clock
,
Duration
scheduleInterval
,
ScheduledExecutorService
executor
)
returns a Watchdog which is scheduled at the provided interval.
clock
scheduleInterval
org.threeten.bp.Duration
executor
Methods
<ResponseT>watch(ResponseObserver<ResponseT> innerObserver, Duration waitTimeout, Duration idleTimeout)
public
ResponseObserver<ResponseT>
< ResponseT>watch
(
ResponseObserver<ResponseT>
innerObserver
,
Duration
waitTimeout
,
Duration
idleTimeout
)
Wraps the target observer with timing constraints.
innerObserver
ResponseObserver
< ResponseT
>
waitTimeout
org.threeten.bp.Duration
idleTimeout
org.threeten.bp.Duration
awaitTermination(long duration, TimeUnit unit)
public
boolean
awaitTermination
(
long
duration
,
TimeUnit
unit
)
Blocks until all work has completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
close()
public
void
close
()
isShutdown()
public
boolean
isShutdown
()
Returns true if this background resource has been shut down.
isTerminated()
public
boolean
isTerminated
()
Returns true if all work has completed following shut down. Note that isTerminated is never true unless either shutdown or shutdownNow was called first.
run()
public
void
run
()
shutdown()
public
void
shutdown
()
Initiates an orderly shutdown in which previously submitted work is finished, but no new work will be accepted. Invocation has no additional effect if already shut down.
This method does not wait for previously submitted work to complete execution. Use awaitTermination to do that.
shutdownNow()
public
void
shutdownNow
()
Attempts to stop all actively executing work and halts the processing of waiting work.
This method does not wait for actively executing work to terminate. Use awaitTermination to do that.
There are no guarantees beyond best-effort attempts to stop processing actively executing work. For example, typical implementations will cancel via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate.
