@Stability.Internal public class OrphanReporter extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ORPHAN_TREAD_PREFIX |
Constructor and Description |
---|
OrphanReporter(EventBus eventBus,
OrphanReporterConfig config)
Creates a new
OrphanReporter . |
Modifier and Type | Method and Description |
---|---|
OrphanReporterConfig |
config()
Returns the currently active configuration.
|
void |
report(Request<?> request)
Reports an orphaned
Request . |
Mono<Void> |
start()
Starts the orphan reporter.
|
Mono<Void> |
stop()
Stops the orphan reporter.
|
public static final String ORPHAN_TREAD_PREFIX
@Stability.Internal public OrphanReporter(EventBus eventBus, OrphanReporterConfig config)
OrphanReporter
.
Please do not instantiate this class directly, but rather let it be handled through the environment and
customize it through the OrphanReporterConfig
which can also be provided on the environment.
eventBus
- the event bus where the messages should be emitted on.config
- the configuration for this reporter.public OrphanReporterConfig config()
public Mono<Void> start()
public Mono<Void> stop()
public void report(Request<?> request)
Request
.
If the orphan could not be recorded because the buffer is full, a OrphanRecordDroppedEvent
will
be raised on the event bus.
If you wish to ignore certain requests as being considered in the orphan reporting, make sure they implement
the UnmonitoredRequest
marker interface.
request
- the request to report as orphan.Copyright © 2024 Couchbase, Inc.. All rights reserved.