Class: Anthropic::Models::Beta::Environments::BetaSelfHostedWorkQueueStats

Inherits:
Internal::Type::BaseModel show all
Defined in:
lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb

Overview

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Internal::Type::BaseModel

==, #==, #[], coerce, #deconstruct_keys, #deep_to_h, dump, fields, hash, #hash, inherited, inspect, #inspect, known_fields, optional, recursively_to_h, required, #to_h, #to_json, #to_s, to_sorbet_type, #to_yaml

Methods included from Internal::Type::Converter

#coerce, coerce, #dump, dump, #inspect, inspect, meta_info, new_coerce_state, type_info

Methods included from Internal::Util::SorbetRuntimeSupport

#const_missing, #define_sorbet_constant!, #sorbet_constant_defined?, #to_sorbet_type, to_sorbet_type

Constructor Details

#initialize(depth:, oldest_queued_at:, pending:, workers_polling:, type: :work_queue_stats) ⇒ Object

Some parameter documentations has been truncated, see Anthropic::Models::Beta::Environments::BetaSelfHostedWorkQueueStats for more details.

Statistics about the work queue for an environment.

Uses Redis Stream consumer group metrics for O(1) queries.

Parameters:

  • depth (Integer)

    Number of work items waiting to be picked up (lag from consumer group)

  • oldest_queued_at (String, nil)

    RFC 3339 timestamp of oldest item in the work stream (includes both queued and p

  • pending (Integer)

    Number of work items being processed (polled but not acknowledged)

  • workers_polling (Integer, nil)

    Number of workers that have polled for work in the last 30 seconds. Requires wor

  • type (Symbol, :work_queue_stats) (defaults to: :work_queue_stats)

    The type of object



# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 41

Instance Attribute Details

#depthInteger

Number of work items waiting to be picked up (lag from consumer group)

Returns:

  • (Integer)


13
# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 13

required :depth, Integer

#oldest_queued_atString?

RFC 3339 timestamp of oldest item in the work stream (includes both queued and pending items), null if stream empty

Returns:

  • (String, nil)


20
# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 20

required :oldest_queued_at, String, nil?: true

#pendingInteger

Number of work items being processed (polled but not acknowledged)

Returns:

  • (Integer)


26
# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 26

required :pending, Integer

#typeSymbol, :work_queue_stats

The type of object

Returns:

  • (Symbol, :work_queue_stats)


32
# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 32

required :type, const: :work_queue_stats

#workers_pollingInteger?

Number of workers that have polled for work in the last 30 seconds. Requires worker_id to be sent with poll requests.

Returns:

  • (Integer, nil)


39
# File 'lib/anthropic/models/beta/environments/beta_self_hosted_work_queue_stats.rb', line 39

required :workers_polling, Integer, nil?: true