Package com.google.cloud.managedkafka.v1

Class TaskRetryPolicy.Builder

java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder>
com.google.cloud.managedkafka.v1.TaskRetryPolicy.Builder
All Implemented Interfaces:
TaskRetryPolicyOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
Enclosing class:
TaskRetryPolicy
public static final class TaskRetryPolicy.Builder extends com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder> implements TaskRetryPolicyOrBuilder
 Task Retry Policy is implemented on a best-effort
 basis.
 Retry delay will be exponential based on provided minimum and maximum
 backoffs. https://en.wikipedia.org/wiki/Exponential_backoff.
 Note that the delay between consecutive task restarts may not always
 precisely match the configured settings. This can happen when the
 ConnectCluster is in rebalancing state or if the ConnectCluster is
 unresponsive etc. The default values for minimum and maximum backoffs are
 60 seconds and 30 minutes respectively.
Protobuf type google.cloud.managedkafka.v1.TaskRetryPolicy

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder>

    • clear

      public TaskRetryPolicy.Builder clear()
      Specified by:
      clear in interface com.google.protobuf.Message.Builder
      Specified by:
      clear in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      clear in class com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder>

    • getDescriptorForType

      public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
      Specified by:
      getDescriptorForType in interface com.google.protobuf.Message.Builder
      Specified by:
      getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
      Overrides:
      getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder>

    • getDefaultInstanceForType

      public TaskRetryPolicy getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

    • build

      public TaskRetryPolicy build()
      Specified by:
      build in interface com.google.protobuf.Message.Builder
      Specified by:
      build in interface com.google.protobuf.MessageLite.Builder

    • buildPartial

      public TaskRetryPolicy buildPartial()
      Specified by:
      buildPartial in interface com.google.protobuf.Message.Builder
      Specified by:
      buildPartial in interface com.google.protobuf.MessageLite.Builder

    • mergeFrom

      public TaskRetryPolicy.Builder mergeFrom(com.google.protobuf.Message other)
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<TaskRetryPolicy.Builder>

    • mergeFrom

      public TaskRetryPolicy.Builder mergeFrom(TaskRetryPolicy other)

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage.Builder<TaskRetryPolicy.Builder>

    • mergeFrom

      public TaskRetryPolicy.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Specified by:
      mergeFrom in interface com.google.protobuf.Message.Builder
      Specified by:
      mergeFrom in interface com.google.protobuf.MessageLite.Builder
      Overrides:
      mergeFrom in class com.google.protobuf.AbstractMessage.Builder<TaskRetryPolicy.Builder>
      Throws:
      IOException

    • hasMinimumBackoff

      public boolean hasMinimumBackoff()
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasMinimumBackoff in interface TaskRetryPolicyOrBuilder
      Returns:
      Whether the minimumBackoff field is set.

    • getMinimumBackoff

      public com.google.protobuf.Duration getMinimumBackoff()
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getMinimumBackoff in interface TaskRetryPolicyOrBuilder
      Returns:
      The minimumBackoff.

    • setMinimumBackoff

      public TaskRetryPolicy.Builder setMinimumBackoff(com.google.protobuf.Duration value)
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];

    • setMinimumBackoff

      public TaskRetryPolicy.Builder setMinimumBackoff(com.google.protobuf.Duration.Builder builderForValue)
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];

    • mergeMinimumBackoff

      public TaskRetryPolicy.Builder mergeMinimumBackoff(com.google.protobuf.Duration value)
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];

    • clearMinimumBackoff

      public TaskRetryPolicy.Builder clearMinimumBackoff()
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];

    • getMinimumBackoffBuilder

      public com.google.protobuf.Duration.Builder getMinimumBackoffBuilder()
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];

    • getMinimumBackoffOrBuilder

      public com.google.protobuf.DurationOrBuilder getMinimumBackoffOrBuilder()
       Optional. The minimum amount of time to wait before retrying a failed task.
 This sets a lower bound for the backoff delay.
      .google.protobuf.Duration minimum_backoff = 1 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getMinimumBackoffOrBuilder in interface TaskRetryPolicyOrBuilder

    • hasMaximumBackoff

      public boolean hasMaximumBackoff()
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      hasMaximumBackoff in interface TaskRetryPolicyOrBuilder
      Returns:
      Whether the maximumBackoff field is set.

    • getMaximumBackoff

      public com.google.protobuf.Duration getMaximumBackoff()
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getMaximumBackoff in interface TaskRetryPolicyOrBuilder
      Returns:
      The maximumBackoff.

    • setMaximumBackoff

      public TaskRetryPolicy.Builder setMaximumBackoff(com.google.protobuf.Duration value)
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];

    • setMaximumBackoff

      public TaskRetryPolicy.Builder setMaximumBackoff(com.google.protobuf.Duration.Builder builderForValue)
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];

    • mergeMaximumBackoff

      public TaskRetryPolicy.Builder mergeMaximumBackoff(com.google.protobuf.Duration value)
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];

    • clearMaximumBackoff

      public TaskRetryPolicy.Builder clearMaximumBackoff()
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];

    • getMaximumBackoffBuilder

      public com.google.protobuf.Duration.Builder getMaximumBackoffBuilder()
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];

    • getMaximumBackoffOrBuilder

      public com.google.protobuf.DurationOrBuilder getMaximumBackoffOrBuilder()
       Optional. The maximum amount of time to wait before retrying a failed task.
 This sets an upper bound for the backoff delay.
      .google.protobuf.Duration maximum_backoff = 2 [(.google.api.field_behavior) = OPTIONAL];
      Specified by:
      getMaximumBackoffOrBuilder in interface TaskRetryPolicyOrBuilder