Class BetaSelfHostedWorkQueueStats
-
- All Implemented Interfaces:
public final class BetaSelfHostedWorkQueueStatsStatistics about the work queue for an environment.
Uses Redis Stream consumer group metrics for O(1) queries.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public final classBetaSelfHostedWorkQueueStats.BuilderA builder for BetaSelfHostedWorkQueueStats.
-
Method Summary
Modifier and Type Method Description final Longdepth()Number of work items waiting to be picked up (lag from consumer group) final Optional<String>oldestQueuedAt()RFC 3339 timestamp of oldest item in the work stream (includes both queued and pending items), null if stream empty final Longpending()Number of work items being processed (polled but not acknowledged) final JsonValue_type()The type of objectExpected to always return the following:
However, this method can be useful for debugging and logging (e.g.JsonValue.from("work_queue_stats")final Optional<Long>workersPolling()Number of workers that have polled for work in the last 30 seconds. final JsonField<Long>_depth()Returns the raw JSON value of depth. final JsonField<String>_oldestQueuedAt()Returns the raw JSON value of oldestQueuedAt. final JsonField<Long>_pending()Returns the raw JSON value of pending. final JsonField<Long>_workersPolling()Returns the raw JSON value of workersPolling. final Map<String, JsonValue>_additionalProperties()final BetaSelfHostedWorkQueueStats.BuildertoBuilder()final BetaSelfHostedWorkQueueStatsvalidate()Validates that the types of all values in this object match their expected types recursively. final BooleanisValid()Booleanequals(Object other)IntegerhashCode()StringtoString()final static BetaSelfHostedWorkQueueStats.Builderbuilder()Returns a mutable builder for constructing an instance of BetaSelfHostedWorkQueueStats. -
-
Method Detail
-
oldestQueuedAt
final Optional<String> oldestQueuedAt()
RFC 3339 timestamp of oldest item in the work stream (includes both queued and pending items), null if stream empty
-
_type
final JsonValue _type()
The type of object
Expected to always return the following:
JsonValue.from("work_queue_stats")However, this method can be useful for debugging and logging (e.g. if the server responded with an unexpected value).
-
workersPolling
final Optional<Long> workersPolling()
Number of workers that have polled for work in the last 30 seconds. Requires worker_id to be sent with poll requests.
-
_depth
final JsonField<Long> _depth()
Returns the raw JSON value of depth.
Unlike depth, this method doesn't throw if the JSON field has an unexpected type.
-
_oldestQueuedAt
final JsonField<String> _oldestQueuedAt()
Returns the raw JSON value of oldestQueuedAt.
Unlike oldestQueuedAt, this method doesn't throw if the JSON field has an unexpected type.
-
_pending
final JsonField<Long> _pending()
Returns the raw JSON value of pending.
Unlike pending, this method doesn't throw if the JSON field has an unexpected type.
-
_workersPolling
final JsonField<Long> _workersPolling()
Returns the raw JSON value of workersPolling.
Unlike workersPolling, this method doesn't throw if the JSON field has an unexpected type.
-
_additionalProperties
final Map<String, JsonValue> _additionalProperties()
-
toBuilder
final BetaSelfHostedWorkQueueStats.Builder toBuilder()
-
validate
final BetaSelfHostedWorkQueueStats validate()
Validates that the types of all values in this object match their expected types recursively.
This method is not forwards compatible with new types from the API for existing fields.
-
builder
final static BetaSelfHostedWorkQueueStats.Builder builder()
Returns a mutable builder for constructing an instance of BetaSelfHostedWorkQueueStats.
The following fields are required:
.depth() .oldestQueuedAt() .pending() .workersPolling()
-
-
-
-