Package responsive.controller.v1.controller.proto

Class ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

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

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

responsive.controller.v1.controller.proto.ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.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.DiagnoserSpecOrBuilder

Enclosing class:

ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec

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

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

Method Summary

Modifier and Type	Method	Description
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec	build()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec	buildPartial()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clear()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearArrivalRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearDiagnoser()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearExpectedLatency()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearLagScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearProcessingRateScaleDown()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearProcessingRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	clearThreadSaturation()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec	getArrivalRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder	getArrivalRateScaleUpBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder	getArrivalRateScaleUpOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.DiagnoserCase	getDiagnoserCase()
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec	getExpectedLatency()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder	getExpectedLatencyBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder	getExpectedLatencyOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec	getLagScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec.Builder	getLagScaleUpBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpecOrBuilder	getLagScaleUpOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec	getProcessingRateScaleDown()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder	getProcessingRateScaleDownBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder	getProcessingRateScaleDownOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec	getProcessingRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder	getProcessingRateScaleUpBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder	getProcessingRateScaleUpOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec	getThreadSaturation()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec.Builder	getThreadSaturationBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpecOrBuilder	getThreadSaturationOrBuilder()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
boolean	hasArrivalRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
boolean	hasExpectedLatency()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
boolean	hasLagScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
boolean	hasProcessingRateScaleDown()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
boolean	hasProcessingRateScaleUp()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
boolean	hasThreadSaturation()	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeFrom(com.google.protobuf.Message other)
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeFrom(ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec other)
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec value)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec.Builder builderForValue)	.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;
ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder	setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

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.DiagnoserSpec.Builder>

clear

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

getDefaultInstanceForType

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

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

mergeFrom

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeFrom(ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec 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.DiagnoserSpec.Builder>

mergeFrom

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

Throws:

java.io.IOException

getDiagnoserCase

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.DiagnoserCase getDiagnoserCase()

Specified by:

getDiagnoserCase in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

clearDiagnoser

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearDiagnoser()

hasProcessingRateScaleUp

public boolean hasProcessingRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

Specified by:

hasProcessingRateScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the processingRateScaleUp field is set.

getProcessingRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec getProcessingRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

Specified by:

getProcessingRateScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The processingRateScaleUp.

setProcessingRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

setProcessingRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

mergeProcessingRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeProcessingRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

clearProcessingRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearProcessingRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

getProcessingRateScaleUpBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder getProcessingRateScaleUpBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

getProcessingRateScaleUpOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder getProcessingRateScaleUpOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_up = 1;

Specified by:

getProcessingRateScaleUpOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

hasProcessingRateScaleDown

public boolean hasProcessingRateScaleDown()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

Specified by:

hasProcessingRateScaleDown in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the processingRateScaleDown field is set.

getProcessingRateScaleDown

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec getProcessingRateScaleDown()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

Specified by:

getProcessingRateScaleDown in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The processingRateScaleDown.

setProcessingRateScaleDown

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

setProcessingRateScaleDown

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

mergeProcessingRateScaleDown

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeProcessingRateScaleDown(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

clearProcessingRateScaleDown

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearProcessingRateScaleDown()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

getProcessingRateScaleDownBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder getProcessingRateScaleDownBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

getProcessingRateScaleDownOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder getProcessingRateScaleDownOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec processing_rate_scale_down = 2;

Specified by:

getProcessingRateScaleDownOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

hasArrivalRateScaleUp

public boolean hasArrivalRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

Specified by:

hasArrivalRateScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the arrivalRateScaleUp field is set.

getArrivalRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec getArrivalRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

Specified by:

getArrivalRateScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The arrivalRateScaleUp.

setArrivalRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

setArrivalRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

mergeArrivalRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeArrivalRateScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

clearArrivalRateScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearArrivalRateScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

getArrivalRateScaleUpBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec.Builder getArrivalRateScaleUpBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

getArrivalRateScaleUpOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.RateBasedDiagnoserSpecOrBuilder getArrivalRateScaleUpOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.RateBasedDiagnoserSpec arrival_rate_scale_up = 6;

Specified by:

getArrivalRateScaleUpOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

hasLagScaleUp

public boolean hasLagScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

Specified by:

hasLagScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the lagScaleUp field is set.

getLagScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec getLagScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

Specified by:

getLagScaleUp in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The lagScaleUp.

setLagScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

setLagScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

mergeLagScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeLagScaleUp(ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

clearLagScaleUp

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearLagScaleUp()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

getLagScaleUpBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpec.Builder getLagScaleUpBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

getLagScaleUpOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.LagDiagnoserSpecOrBuilder getLagScaleUpOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.LagDiagnoserSpec lag_scale_up = 3;

Specified by:

getLagScaleUpOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

hasExpectedLatency

public boolean hasExpectedLatency()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

Specified by:

hasExpectedLatency in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the expectedLatency field is set.

getExpectedLatency

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec getExpectedLatency()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

Specified by:

getExpectedLatency in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The expectedLatency.

setExpectedLatency

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

setExpectedLatency

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

mergeExpectedLatency

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeExpectedLatency(ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

clearExpectedLatency

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearExpectedLatency()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

getExpectedLatencyBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec.Builder getExpectedLatencyBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

getExpectedLatencyOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpecOrBuilder getExpectedLatencyOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ExpectedLatencyDiagnoserSpec expected_latency = 4;

Specified by:

getExpectedLatencyOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

hasThreadSaturation

public boolean hasThreadSaturation()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

Specified by:

hasThreadSaturation in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

Whether the threadSaturation field is set.

getThreadSaturation

public ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec getThreadSaturation()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

Specified by:

getThreadSaturation in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

Returns:

The threadSaturation.

setThreadSaturation

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

setThreadSaturation

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder setThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec.Builder builderForValue)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

mergeThreadSaturation

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder mergeThreadSaturation(ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec value)

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

clearThreadSaturation

public ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpec.Builder clearThreadSaturation()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

getThreadSaturationBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec.Builder getThreadSaturationBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

getThreadSaturationOrBuilder

public ControllerOuterClass.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpecOrBuilder getThreadSaturationOrBuilder()

.responsive.controller.v1.controller.proto.KafkaStreamsPolicySpec.ThreadSaturationDiagnoserSpec thread_saturation = 5;

Specified by:

getThreadSaturationOrBuilder in interface ControllerOuterClass.KafkaStreamsPolicySpec.DiagnoserSpecOrBuilder

setUnknownFields

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

mergeUnknownFields

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