Package responsive.controller.v1.controller.proto

Class ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

responsive.controller.v1.controller.proto.ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, java.lang.Cloneable, ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Enclosing class:

ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec

public static final class ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>
implements ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Protobuf type responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec

Method Summary

Modifier and Type	Method	Description
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec	build()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec	buildPartial()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clear()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearFixedReplicas()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearGraceSeconds()	optional int32 grace_seconds = 10;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearMaxExpectedLatencySeconds()	int32 max_expected_latency_seconds = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearProjectionSeconds()	optional int32 projection_seconds = 8;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearRateBased()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearScaleDownBufferSeconds()	optional int32 scale_down_buffer_seconds = 9;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearScaleToMax()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearScaleUpStrategy()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearStaggerSeconds()	optional int32 stagger_seconds = 11;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	clearWindowSeconds()	optional int32 window_seconds = 7;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec	getFixedReplicas()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec.Builder	getFixedReplicasBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpecOrBuilder	getFixedReplicasOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
int	getGraceSeconds()	optional int32 grace_seconds = 10;
int	getMaxExpectedLatencySeconds()	int32 max_expected_latency_seconds = 1;
int	getProjectionSeconds()	optional int32 projection_seconds = 8;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec	getRateBased()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec.Builder	getRateBasedBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpecOrBuilder	getRateBasedOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
int	getScaleDownBufferSeconds()	optional int32 scale_down_buffer_seconds = 9;
ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec	getScaleToMax()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec.Builder	getScaleToMaxBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpecOrBuilder	getScaleToMaxOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.ScaleUpStrategyCase	getScaleUpStrategyCase()
int	getStaggerSeconds()	optional int32 stagger_seconds = 11;
int	getWindowSeconds()	optional int32 window_seconds = 7;
boolean	hasFixedReplicas()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
boolean	hasGraceSeconds()	optional int32 grace_seconds = 10;
boolean	hasProjectionSeconds()	optional int32 projection_seconds = 8;
boolean	hasRateBased()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
boolean	hasScaleDownBufferSeconds()	optional int32 scale_down_buffer_seconds = 9;
boolean	hasScaleToMax()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
boolean	hasStaggerSeconds()	optional int32 stagger_seconds = 11;
boolean	hasWindowSeconds()	optional int32 window_seconds = 7;
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeFrom(com.google.protobuf.Message other)
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeFrom(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec other)
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setGraceSeconds(int value)	optional int32 grace_seconds = 10;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setMaxExpectedLatencySeconds(int value)	int32 max_expected_latency_seconds = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setProjectionSeconds(int value)	optional int32 projection_seconds = 8;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setScaleDownBufferSeconds(int value)	optional int32 scale_down_buffer_seconds = 9;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setStaggerSeconds(int value)	optional int32 stagger_seconds = 11;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	setWindowSeconds(int value)	optional int32 window_seconds = 7;

Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFieldSetBuilder, setUnknownFieldsProto3

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Method Detail

getDescriptor

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

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

clear

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.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.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.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.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

getDefaultInstanceForType

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.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<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

mergeFrom

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeFrom(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

mergeFrom

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
                                                                                                  com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                                                           throws java.io.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<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

Throws:

java.io.IOException

getScaleUpStrategyCase

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.ScaleUpStrategyCase getScaleUpStrategyCase()

Specified by:

getScaleUpStrategyCase in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

clearScaleUpStrategy

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearScaleUpStrategy()

getMaxExpectedLatencySeconds

public int getMaxExpectedLatencySeconds()

int32 max_expected_latency_seconds = 1;

Specified by:

getMaxExpectedLatencySeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The maxExpectedLatencySeconds.

setMaxExpectedLatencySeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setMaxExpectedLatencySeconds(int value)

int32 max_expected_latency_seconds = 1;

Parameters:

value - The maxExpectedLatencySeconds to set.

Returns:

This builder for chaining.

clearMaxExpectedLatencySeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearMaxExpectedLatencySeconds()

int32 max_expected_latency_seconds = 1;

Returns:

This builder for chaining.

hasWindowSeconds

public boolean hasWindowSeconds()

optional int32 window_seconds = 7;

Specified by:

hasWindowSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the windowSeconds field is set.

getWindowSeconds

public int getWindowSeconds()

optional int32 window_seconds = 7;

Specified by:

getWindowSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The windowSeconds.

setWindowSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setWindowSeconds(int value)

optional int32 window_seconds = 7;

Parameters:

value - The windowSeconds to set.

Returns:

This builder for chaining.

clearWindowSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearWindowSeconds()

optional int32 window_seconds = 7;

Returns:

This builder for chaining.

hasProjectionSeconds

public boolean hasProjectionSeconds()

optional int32 projection_seconds = 8;

Specified by:

hasProjectionSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the projectionSeconds field is set.

getProjectionSeconds

public int getProjectionSeconds()

optional int32 projection_seconds = 8;

Specified by:

getProjectionSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The projectionSeconds.

setProjectionSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setProjectionSeconds(int value)

optional int32 projection_seconds = 8;

Parameters:

value - The projectionSeconds to set.

Returns:

This builder for chaining.

clearProjectionSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearProjectionSeconds()

optional int32 projection_seconds = 8;

Returns:

This builder for chaining.

hasScaleDownBufferSeconds

public boolean hasScaleDownBufferSeconds()

optional int32 scale_down_buffer_seconds = 9;

Specified by:

hasScaleDownBufferSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the scaleDownBufferSeconds field is set.

getScaleDownBufferSeconds

public int getScaleDownBufferSeconds()

optional int32 scale_down_buffer_seconds = 9;

Specified by:

getScaleDownBufferSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The scaleDownBufferSeconds.

setScaleDownBufferSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setScaleDownBufferSeconds(int value)

optional int32 scale_down_buffer_seconds = 9;

Parameters:

value - The scaleDownBufferSeconds to set.

Returns:

This builder for chaining.

clearScaleDownBufferSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearScaleDownBufferSeconds()

optional int32 scale_down_buffer_seconds = 9;

Returns:

This builder for chaining.

hasGraceSeconds

public boolean hasGraceSeconds()

optional int32 grace_seconds = 10;

Specified by:

hasGraceSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the graceSeconds field is set.

getGraceSeconds

public int getGraceSeconds()

optional int32 grace_seconds = 10;

Specified by:

getGraceSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The graceSeconds.

setGraceSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setGraceSeconds(int value)

optional int32 grace_seconds = 10;

Parameters:

value - The graceSeconds to set.

Returns:

This builder for chaining.

clearGraceSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearGraceSeconds()

optional int32 grace_seconds = 10;

Returns:

This builder for chaining.

hasStaggerSeconds

public boolean hasStaggerSeconds()

optional int32 stagger_seconds = 11;

Specified by:

hasStaggerSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the staggerSeconds field is set.

getStaggerSeconds

public int getStaggerSeconds()

optional int32 stagger_seconds = 11;

Specified by:

getStaggerSeconds in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The staggerSeconds.

setStaggerSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setStaggerSeconds(int value)

optional int32 stagger_seconds = 11;

Parameters:

value - The staggerSeconds to set.

Returns:

This builder for chaining.

clearStaggerSeconds

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearStaggerSeconds()

optional int32 stagger_seconds = 11;

Returns:

This builder for chaining.

hasFixedReplicas

public boolean hasFixedReplicas()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

Specified by:

hasFixedReplicas in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the fixedReplicas field is set.

getFixedReplicas

public ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec getFixedReplicas()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

Specified by:

getFixedReplicas in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The fixedReplicas.

setFixedReplicas

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

setFixedReplicas

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

mergeFixedReplicas

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeFixedReplicas(ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

clearFixedReplicas

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearFixedReplicas()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

getFixedReplicasBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec.Builder getFixedReplicasBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

getFixedReplicasOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpecOrBuilder getFixedReplicasOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.FixedReplicaScaleUpStrategySpec fixed_replicas = 2;

Specified by:

getFixedReplicasOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

hasRateBased

public boolean hasRateBased()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

Specified by:

hasRateBased in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the rateBased field is set.

getRateBased

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec getRateBased()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

Specified by:

getRateBased in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The rateBased.

setRateBased

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

setRateBased

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

mergeRateBased

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeRateBased(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

clearRateBased

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearRateBased()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

getRateBasedBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec.Builder getRateBasedBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

getRateBasedOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpecOrBuilder getRateBasedOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedScaleUpStrategySpec rate_based = 3;

Specified by:

getRateBasedOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

hasScaleToMax

public boolean hasScaleToMax()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

Specified by:

hasScaleToMax in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

Whether the scaleToMax field is set.

getScaleToMax

public ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec getScaleToMax()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

Specified by:

getScaleToMax in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

Returns:

The scaleToMax.

setScaleToMax

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

setScaleToMax

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

mergeScaleToMax

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeScaleToMax(ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

clearScaleToMax

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder clearScaleToMax()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

getScaleToMaxBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec.Builder getScaleToMaxBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

getScaleToMaxOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ScaleToMaxStrategySpecOrBuilder getScaleToMaxOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ScaleToMaxStrategySpec scale_to_max = 4;

Specified by:

getScaleToMaxOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder

setUnknownFields

public final ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

setUnknownFields in interface com.google.protobuf.Message.Builder

Overrides:

setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>

mergeUnknownFields

public final ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

mergeUnknownFields in interface com.google.protobuf.Message.Builder

Overrides:

mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder>