Interface WorkerSlotsInfoOrBuilder

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

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getCurrentAvailableSlots()
    Number of slots available for the worker to specific tasks.
    int
    getCurrentUsedSlots()
    Number of slots used by the worker for specific tasks.
    int
    getLastIntervalFailureTasks()
    Number of failed tasks processed since the last heartbeat from the worker.
    int
    getLastIntervalProcessedTasks()
    Number of tasks processed in since the last heartbeat from the worker.
    String
    getSlotSupplierKind()
    Kind of the slot supplier, which is used to determine how the slots are allocated.
    com.google.protobuf.ByteString
    getSlotSupplierKindBytes()
    Kind of the slot supplier, which is used to determine how the slots are allocated.
    int
    getTotalFailedTasks()
    Total number of failed tasks processed by the worker so far.
    int
    getTotalProcessedTasks()
    Total number of tasks processed (completed both successfully and unsuccesfully, or any other way) by the worker since the worker started.

    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

    • getCurrentAvailableSlots

      int getCurrentAvailableSlots()
       Number of slots available for the worker to specific tasks.
 May be -1 if the upper bound is not known.
      int32 current_available_slots = 1;
      Returns:
      The currentAvailableSlots.

    • getCurrentUsedSlots

      int getCurrentUsedSlots()
       Number of slots used by the worker for specific tasks.
      int32 current_used_slots = 2;
      Returns:
      The currentUsedSlots.

    • getSlotSupplierKind

      String getSlotSupplierKind()
       Kind of the slot supplier, which is used to determine how the slots are allocated.
 Possible values: "Fixed | ResourceBased | Custom String"
      string slot_supplier_kind = 3;
      Returns:
      The slotSupplierKind.

    • getSlotSupplierKindBytes

      com.google.protobuf.ByteString getSlotSupplierKindBytes()
       Kind of the slot supplier, which is used to determine how the slots are allocated.
 Possible values: "Fixed | ResourceBased | Custom String"
      string slot_supplier_kind = 3;
      Returns:
      The bytes for slotSupplierKind.

    • getTotalProcessedTasks

      int getTotalProcessedTasks()
       Total number of tasks processed (completed both successfully and unsuccesfully, or any other way)
 by the worker since the worker started. This is a cumulative counter.
      int32 total_processed_tasks = 4;
      Returns:
      The totalProcessedTasks.

    • getTotalFailedTasks

      int getTotalFailedTasks()
       Total number of failed tasks processed by the worker so far.
      int32 total_failed_tasks = 5;
      Returns:
      The totalFailedTasks.

    • getLastIntervalProcessedTasks

      int getLastIntervalProcessedTasks()
       Number of tasks processed in since the last heartbeat from the worker.
 This is a cumulative counter, and it is reset to 0 each time the worker sends a heartbeat.
 Contains both successful and failed tasks.
      int32 last_interval_processed_tasks = 6;
      Returns:
      The lastIntervalProcessedTasks.

    • getLastIntervalFailureTasks

      int getLastIntervalFailureTasks()
       Number of failed tasks processed since the last heartbeat from the worker.
      int32 last_interval_failure_tasks = 7;
      Returns:
      The lastIntervalFailureTasks.