Interface TaskQueueStatsOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
TaskQueueStats, TaskQueueStats.Builder
@Generated(value="protoc", comments="annotations:TaskQueueStatsOrBuilder.java.pb.meta") public interface TaskQueueStatsOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.protobuf.Duration
    getApproximateBacklogAge()
    Approximate age of the oldest task in the backlog based on the creation time of the task at the head of the queue.
    com.google.protobuf.DurationOrBuilder
    getApproximateBacklogAgeOrBuilder()
    Approximate age of the oldest task in the backlog based on the creation time of the task at the head of the queue.
    long
    getApproximateBacklogCount()
    The approximate number of tasks backlogged in this task queue.
    boolean
    getRateLimitingActive()
    Whether rate limiting blocked any dispatches within the recent observation window (approximately 30 seconds).
    float
    getTasksAddRate()
    The approximate tasks per second added to the task queue, averaging the last 30 seconds.
    float
    getTasksDispatchRate()
    The approximate tasks per second dispatched from the task queue, averaging the last 30 seconds.
    boolean
    hasApproximateBacklogAge()
    Approximate age of the oldest task in the backlog based on the creation time of the task at the head of the queue.

    Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

    isInitialized

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

    findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

  • Method Details

    • getApproximateBacklogCount

      long getApproximateBacklogCount()
       The approximate number of tasks backlogged in this task queue. May count expired tasks but eventually
 converges to the right value. Can be relied upon for scaling decisions.

 Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because
 those tasks only remain valid for a few seconds, the inaccuracy becomes less significant as the backlog size
 grows.
      int64 approximate_backlog_count = 1;
      Returns:
      The approximateBacklogCount.

    • hasApproximateBacklogAge

      boolean hasApproximateBacklogAge()
       Approximate age of the oldest task in the backlog based on the creation time of the task at the head of
 the queue. Can be relied upon for scaling decisions.

 Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because
 those tasks only remain valid for a few seconds, they should not affect the result when backlog is older than
 few seconds.
      .google.protobuf.Duration approximate_backlog_age = 2;
      Returns:
      Whether the approximateBacklogAge field is set.

    • getApproximateBacklogAge

      com.google.protobuf.Duration getApproximateBacklogAge()
       Approximate age of the oldest task in the backlog based on the creation time of the task at the head of
 the queue. Can be relied upon for scaling decisions.

 Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because
 those tasks only remain valid for a few seconds, they should not affect the result when backlog is older than
 few seconds.
      .google.protobuf.Duration approximate_backlog_age = 2;
      Returns:
      The approximateBacklogAge.

    • getApproximateBacklogAgeOrBuilder

      com.google.protobuf.DurationOrBuilder getApproximateBacklogAgeOrBuilder()
       Approximate age of the oldest task in the backlog based on the creation time of the task at the head of
 the queue. Can be relied upon for scaling decisions.

 Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because
 those tasks only remain valid for a few seconds, they should not affect the result when backlog is older than
 few seconds.
      .google.protobuf.Duration approximate_backlog_age = 2;

    • getTasksAddRate

      float getTasksAddRate()
       The approximate tasks per second added to the task queue, averaging the last 30 seconds. These includes tasks
 whether or not they were added to/dispatched from the backlog or they were dispatched immediately without going
 to the backlog (sync-matched).

 The difference between `tasks_add_rate` and `tasks_dispatch_rate` is a reliable metric for the rate at which
 backlog grows/shrinks.

 Note: the actual tasks delivered to the workers may significantly be higher than the numbers reported by
 tasks_add_rate, because:
 - Tasks can be sent to workers without going to the task queue. This is called Eager dispatch. Eager dispatch is
   enable for activities by default in the latest SDKs.
 - Tasks going to Sticky queue are not accounted for. Note that, typically, only the first workflow task of each
   workflow goes to a normal queue, and the rest workflow tasks go to the Sticky queue associated with a specific
   worker instance.
      float tasks_add_rate = 3;
      Returns:
      The tasksAddRate.

    • getTasksDispatchRate

      float getTasksDispatchRate()
       The approximate tasks per second dispatched from the task queue, averaging the last 30 seconds. These includes
 tasks whether or not they were added to/dispatched from the backlog or they were dispatched immediately without
 going to the backlog (sync-matched).

 The difference between `tasks_add_rate` and `tasks_dispatch_rate` is a reliable metric for the rate at which
 backlog grows/shrinks.

 Note: the actual tasks delivered to the workers may significantly be higher than the numbers reported by
 tasks_dispatch_rate, because:
 - Tasks can be sent to workers without going to the task queue. This is called Eager dispatch. Eager dispatch is
   enable for activities by default in the latest SDKs.
 - Tasks going to Sticky queue are not accounted for. Note that, typically, only the first workflow task of each
   workflow goes to a normal queue, and the rest workflow tasks go to the Sticky queue associated with a specific
   worker instance.
      float tasks_dispatch_rate = 4;
      Returns:
      The tasksDispatchRate.

    • getRateLimitingActive

      boolean getRateLimitingActive()
       Whether rate limiting blocked any dispatches within the recent observation window (approximately
 30 seconds). When true, adding more workers will not increase throughput — the bottleneck is the
 rate limit, not worker count. This field is useful for auto-scaling systems to avoid unnecessary
 scale-up.
      bool rate_limiting_active = 5;
      Returns:
      The rateLimitingActive.