Package io.confluent.monitoring.record

Class Monitoring.MonitoringMessage.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<Monitoring.MonitoringMessage.Builder>

com.google.protobuf.GeneratedMessage.Builder<Monitoring.MonitoringMessage.Builder>

io.confluent.monitoring.record.Monitoring.MonitoringMessage.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Monitoring.MonitoringMessageOrBuilder, Cloneable

Enclosing class:

Monitoring.MonitoringMessage

public static final class Monitoring.MonitoringMessage.Builder
extends com.google.protobuf.GeneratedMessage.Builder<Monitoring.MonitoringMessage.Builder>
implements Monitoring.MonitoringMessageOrBuilder

Protobuf type monitoring.MonitoringMessage

Method Summary

Modifier and Type	Method	Description
Monitoring.MonitoringMessage	build()
Monitoring.MonitoringMessage	buildPartial()
Monitoring.MonitoringMessage.Builder	clear()
Monitoring.MonitoringMessage.Builder	clearAggregateBytes()	int64 aggregateBytes = 11;
Monitoring.MonitoringMessage.Builder	clearAggregateCrc()	int32 aggregateCrc = 12;
Monitoring.MonitoringMessage.Builder	clearArrivalTime()	C3 time when the message arrived to C3
Monitoring.MonitoringMessage.Builder	clearClientId()	string clientId = 2;
Monitoring.MonitoringMessage.Builder	clearClientType()	.monitoring.ClientType clientType = 1;
Monitoring.MonitoringMessage.Builder	clearClusterId()	Kafka cluster ID (required)
Monitoring.MonitoringMessage.Builder	clearClusterName()	Kafka cluster name (optional, human-friendly)
Monitoring.MonitoringMessage.Builder	clearCount()	int64 count = 10;
Monitoring.MonitoringMessage.Builder	clearGroup()	string group = 3;
Monitoring.MonitoringMessage.Builder	clearMaxLatency()	int64 maxLatency = 15;
Monitoring.MonitoringMessage.Builder	clearMaxWindow()	int64 maxWindow = 20;
Monitoring.MonitoringMessage.Builder	clearMinLatency()	int64 minLatency = 14;
Monitoring.MonitoringMessage.Builder	clearMinWindow()	int64 minWindow = 19;
Monitoring.MonitoringMessage.Builder	clearMonitoringTopicPartition()	int32 monitoringTopicPartition = 21;
Monitoring.MonitoringMessage.Builder	clearPartition()	int32 partition = 9;
Monitoring.MonitoringMessage.Builder	clearSamplePeriod()	int64 samplePeriod = 16;
Monitoring.MonitoringMessage.Builder	clearSequence()	int64 sequence = 5;
Monitoring.MonitoringMessage.Builder	clearSession()	string session = 4;
Monitoring.MonitoringMessage.Builder	clearShutdown()	bool shutdown = 18;
Monitoring.MonitoringMessage.Builder	clearTimestamp()	int64 timestamp = 7;
Monitoring.MonitoringMessage.Builder	clearTopic()	string topic = 8;
Monitoring.MonitoringMessage.Builder	clearTotalLatency()	int64 totalLatency = 13;
Monitoring.MonitoringMessage.Builder	clearType()	.monitoring.MessageType type = 17;
Monitoring.MonitoringMessage.Builder	clearWindow()	int64 window = 6;
long	getAggregateBytes()	int64 aggregateBytes = 11;
int	getAggregateCrc()	int32 aggregateCrc = 12;
long	getArrivalTime()	C3 time when the message arrived to C3
String	getClientId()	string clientId = 2;
com.google.protobuf.ByteString	getClientIdBytes()	string clientId = 2;
Monitoring.ClientType	getClientType()	.monitoring.ClientType clientType = 1;
int	getClientTypeValue()	.monitoring.ClientType clientType = 1;
String	getClusterId()	Kafka cluster ID (required)
com.google.protobuf.ByteString	getClusterIdBytes()	Kafka cluster ID (required)
String	getClusterName()	Kafka cluster name (optional, human-friendly)
com.google.protobuf.ByteString	getClusterNameBytes()	Kafka cluster name (optional, human-friendly)
long	getCount()	int64 count = 10;
Monitoring.MonitoringMessage	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
String	getGroup()	string group = 3;
com.google.protobuf.ByteString	getGroupBytes()	string group = 3;
long	getMaxLatency()	int64 maxLatency = 15;
long	getMaxWindow()	int64 maxWindow = 20;
long	getMinLatency()	int64 minLatency = 14;
long	getMinWindow()	int64 minWindow = 19;
int	getMonitoringTopicPartition()	int32 monitoringTopicPartition = 21;
int	getPartition()	int32 partition = 9;
long	getSamplePeriod()	int64 samplePeriod = 16;
long	getSequence()	int64 sequence = 5;
String	getSession()	string session = 4;
com.google.protobuf.ByteString	getSessionBytes()	string session = 4;
boolean	getShutdown()	bool shutdown = 18;
long	getTimestamp()	int64 timestamp = 7;
String	getTopic()	string topic = 8;
com.google.protobuf.ByteString	getTopicBytes()	string topic = 8;
long	getTotalLatency()	int64 totalLatency = 13;
Monitoring.MessageType	getType()	.monitoring.MessageType type = 17;
int	getTypeValue()	.monitoring.MessageType type = 17;
long	getWindow()	int64 window = 6;
final boolean	isInitialized()
Monitoring.MonitoringMessage.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Monitoring.MonitoringMessage.Builder	mergeFrom(com.google.protobuf.Message other)
Monitoring.MonitoringMessage.Builder	mergeFrom(Monitoring.MonitoringMessage other)
Monitoring.MonitoringMessage.Builder	setAggregateBytes(long value)	int64 aggregateBytes = 11;
Monitoring.MonitoringMessage.Builder	setAggregateCrc(int value)	int32 aggregateCrc = 12;
Monitoring.MonitoringMessage.Builder	setArrivalTime(long value)	C3 time when the message arrived to C3
Monitoring.MonitoringMessage.Builder	setClientId(String value)	string clientId = 2;
Monitoring.MonitoringMessage.Builder	setClientIdBytes(com.google.protobuf.ByteString value)	string clientId = 2;
Monitoring.MonitoringMessage.Builder	setClientType(Monitoring.ClientType value)	.monitoring.ClientType clientType = 1;
Monitoring.MonitoringMessage.Builder	setClientTypeValue(int value)	.monitoring.ClientType clientType = 1;
Monitoring.MonitoringMessage.Builder	setClusterId(String value)	Kafka cluster ID (required)
Monitoring.MonitoringMessage.Builder	setClusterIdBytes(com.google.protobuf.ByteString value)	Kafka cluster ID (required)
Monitoring.MonitoringMessage.Builder	setClusterName(String value)	Kafka cluster name (optional, human-friendly)
Monitoring.MonitoringMessage.Builder	setClusterNameBytes(com.google.protobuf.ByteString value)	Kafka cluster name (optional, human-friendly)
Monitoring.MonitoringMessage.Builder	setCount(long value)	int64 count = 10;
Monitoring.MonitoringMessage.Builder	setGroup(String value)	string group = 3;
Monitoring.MonitoringMessage.Builder	setGroupBytes(com.google.protobuf.ByteString value)	string group = 3;
Monitoring.MonitoringMessage.Builder	setMaxLatency(long value)	int64 maxLatency = 15;
Monitoring.MonitoringMessage.Builder	setMaxWindow(long value)	int64 maxWindow = 20;
Monitoring.MonitoringMessage.Builder	setMinLatency(long value)	int64 minLatency = 14;
Monitoring.MonitoringMessage.Builder	setMinWindow(long value)	int64 minWindow = 19;
Monitoring.MonitoringMessage.Builder	setMonitoringTopicPartition(int value)	int32 monitoringTopicPartition = 21;
Monitoring.MonitoringMessage.Builder	setPartition(int value)	int32 partition = 9;
Monitoring.MonitoringMessage.Builder	setSamplePeriod(long value)	int64 samplePeriod = 16;
Monitoring.MonitoringMessage.Builder	setSequence(long value)	int64 sequence = 5;
Monitoring.MonitoringMessage.Builder	setSession(String value)	string session = 4;
Monitoring.MonitoringMessage.Builder	setSessionBytes(com.google.protobuf.ByteString value)	string session = 4;
Monitoring.MonitoringMessage.Builder	setShutdown(boolean value)	bool shutdown = 18;
Monitoring.MonitoringMessage.Builder	setTimestamp(long value)	int64 timestamp = 7;
Monitoring.MonitoringMessage.Builder	setTopic(String value)	string topic = 8;
Monitoring.MonitoringMessage.Builder	setTopicBytes(com.google.protobuf.ByteString value)	string topic = 8;
Monitoring.MonitoringMessage.Builder	setTotalLatency(long value)	int64 totalLatency = 13;
Monitoring.MonitoringMessage.Builder	setType(Monitoring.MessageType value)	.monitoring.MessageType type = 17;
Monitoring.MonitoringMessage.Builder	setTypeValue(int value)	.monitoring.MessageType type = 17;
Monitoring.MonitoringMessage.Builder	setWindow(long value)	int64 window = 6;

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

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields

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

findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString

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

mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom

Methods inherited from class java.lang.Object

equals, 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 Details

getDescriptor

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

clear

public Monitoring.MonitoringMessage.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<Monitoring.MonitoringMessage.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<Monitoring.MonitoringMessage.Builder>

getDefaultInstanceForType

public Monitoring.MonitoringMessage getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public Monitoring.MonitoringMessage build()

Specified by:

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

Specified by:

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

buildPartial

public Monitoring.MonitoringMessage buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

public Monitoring.MonitoringMessage.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<Monitoring.MonitoringMessage.Builder>

mergeFrom

public Monitoring.MonitoringMessage.Builder mergeFrom(Monitoring.MonitoringMessage other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<Monitoring.MonitoringMessage.Builder>

mergeFrom

public Monitoring.MonitoringMessage.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<Monitoring.MonitoringMessage.Builder>

Throws:

IOException

getClientTypeValue

public int getClientTypeValue()

.monitoring.ClientType clientType = 1;

Specified by:

getClientTypeValue in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The enum numeric value on the wire for clientType.

setClientTypeValue

public Monitoring.MonitoringMessage.Builder setClientTypeValue(int value)

.monitoring.ClientType clientType = 1;

Parameters:

value - The enum numeric value on the wire for clientType to set.

Returns:

This builder for chaining.

getClientType

public Monitoring.ClientType getClientType()

.monitoring.ClientType clientType = 1;

Specified by:

getClientType in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The clientType.

setClientType

public Monitoring.MonitoringMessage.Builder setClientType(Monitoring.ClientType value)

.monitoring.ClientType clientType = 1;

Parameters:

value - The clientType to set.

Returns:

This builder for chaining.

clearClientType

public Monitoring.MonitoringMessage.Builder clearClientType()

.monitoring.ClientType clientType = 1;

Returns:

This builder for chaining.

getClientId

public String getClientId()

string clientId = 2;

Specified by:

getClientId in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The clientId.

getClientIdBytes

public com.google.protobuf.ByteString getClientIdBytes()

string clientId = 2;

Specified by:

getClientIdBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for clientId.

setClientId

public Monitoring.MonitoringMessage.Builder setClientId(String value)

string clientId = 2;

Parameters:

value - The clientId to set.

Returns:

This builder for chaining.

clearClientId

public Monitoring.MonitoringMessage.Builder clearClientId()

string clientId = 2;

Returns:

This builder for chaining.

setClientIdBytes

public Monitoring.MonitoringMessage.Builder setClientIdBytes(com.google.protobuf.ByteString value)

string clientId = 2;

Parameters:

value - The bytes for clientId to set.

Returns:

This builder for chaining.

getGroup

public String getGroup()

string group = 3;

Specified by:

getGroup in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The group.

getGroupBytes

public com.google.protobuf.ByteString getGroupBytes()

string group = 3;

Specified by:

getGroupBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for group.

setGroup

public Monitoring.MonitoringMessage.Builder setGroup(String value)

string group = 3;

Parameters:

value - The group to set.

Returns:

This builder for chaining.

clearGroup

public Monitoring.MonitoringMessage.Builder clearGroup()

string group = 3;

Returns:

This builder for chaining.

setGroupBytes

public Monitoring.MonitoringMessage.Builder setGroupBytes(com.google.protobuf.ByteString value)

string group = 3;

Parameters:

value - The bytes for group to set.

Returns:

This builder for chaining.

getSession

public String getSession()

string session = 4;

Specified by:

getSession in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The session.

getSessionBytes

public com.google.protobuf.ByteString getSessionBytes()

string session = 4;

Specified by:

getSessionBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for session.

setSession

public Monitoring.MonitoringMessage.Builder setSession(String value)

string session = 4;

Parameters:

value - The session to set.

Returns:

This builder for chaining.

clearSession

public Monitoring.MonitoringMessage.Builder clearSession()

string session = 4;

Returns:

This builder for chaining.

setSessionBytes

public Monitoring.MonitoringMessage.Builder setSessionBytes(com.google.protobuf.ByteString value)

string session = 4;

Parameters:

value - The bytes for session to set.

Returns:

This builder for chaining.

getSequence

public long getSequence()

int64 sequence = 5;

Specified by:

getSequence in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The sequence.

setSequence

public Monitoring.MonitoringMessage.Builder setSequence(long value)

int64 sequence = 5;

Parameters:

value - The sequence to set.

Returns:

This builder for chaining.

clearSequence

public Monitoring.MonitoringMessage.Builder clearSequence()

int64 sequence = 5;

Returns:

This builder for chaining.

getWindow

public long getWindow()

int64 window = 6;

Specified by:

getWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The window.

setWindow

public Monitoring.MonitoringMessage.Builder setWindow(long value)

int64 window = 6;

Parameters:

value - The window to set.

Returns:

This builder for chaining.

clearWindow

public Monitoring.MonitoringMessage.Builder clearWindow()

int64 window = 6;

Returns:

This builder for chaining.

getTimestamp

public long getTimestamp()

int64 timestamp = 7;

Specified by:

getTimestamp in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The timestamp.

setTimestamp

public Monitoring.MonitoringMessage.Builder setTimestamp(long value)

int64 timestamp = 7;

Parameters:

value - The timestamp to set.

Returns:

This builder for chaining.

clearTimestamp

public Monitoring.MonitoringMessage.Builder clearTimestamp()

int64 timestamp = 7;

Returns:

This builder for chaining.

getTopic

public String getTopic()

string topic = 8;

Specified by:

getTopic in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The topic.

getTopicBytes

public com.google.protobuf.ByteString getTopicBytes()

string topic = 8;

Specified by:

getTopicBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for topic.

setTopic

public Monitoring.MonitoringMessage.Builder setTopic(String value)

string topic = 8;

Parameters:

value - The topic to set.

Returns:

This builder for chaining.

clearTopic

public Monitoring.MonitoringMessage.Builder clearTopic()

string topic = 8;

Returns:

This builder for chaining.

setTopicBytes

public Monitoring.MonitoringMessage.Builder setTopicBytes(com.google.protobuf.ByteString value)

string topic = 8;

Parameters:

value - The bytes for topic to set.

Returns:

This builder for chaining.

getPartition

public int getPartition()

int32 partition = 9;

Specified by:

getPartition in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The partition.

setPartition

public Monitoring.MonitoringMessage.Builder setPartition(int value)

int32 partition = 9;

Parameters:

value - The partition to set.

Returns:

This builder for chaining.

clearPartition

public Monitoring.MonitoringMessage.Builder clearPartition()

int32 partition = 9;

Returns:

This builder for chaining.

getCount

public long getCount()

int64 count = 10;

Specified by:

getCount in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The count.

setCount

public Monitoring.MonitoringMessage.Builder setCount(long value)

int64 count = 10;

Parameters:

value - The count to set.

Returns:

This builder for chaining.

clearCount

public Monitoring.MonitoringMessage.Builder clearCount()

int64 count = 10;

Returns:

This builder for chaining.

getAggregateBytes

public long getAggregateBytes()

int64 aggregateBytes = 11;

Specified by:

getAggregateBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The aggregateBytes.

setAggregateBytes

public Monitoring.MonitoringMessage.Builder setAggregateBytes(long value)

int64 aggregateBytes = 11;

Parameters:

value - The aggregateBytes to set.

Returns:

This builder for chaining.

clearAggregateBytes

public Monitoring.MonitoringMessage.Builder clearAggregateBytes()

int64 aggregateBytes = 11;

Returns:

This builder for chaining.

getAggregateCrc

public int getAggregateCrc()

int32 aggregateCrc = 12;

Specified by:

getAggregateCrc in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The aggregateCrc.

setAggregateCrc

public Monitoring.MonitoringMessage.Builder setAggregateCrc(int value)

int32 aggregateCrc = 12;

Parameters:

value - The aggregateCrc to set.

Returns:

This builder for chaining.

clearAggregateCrc

public Monitoring.MonitoringMessage.Builder clearAggregateCrc()

int32 aggregateCrc = 12;

Returns:

This builder for chaining.

getTotalLatency

public long getTotalLatency()

int64 totalLatency = 13;

Specified by:

getTotalLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The totalLatency.

setTotalLatency

public Monitoring.MonitoringMessage.Builder setTotalLatency(long value)

int64 totalLatency = 13;

Parameters:

value - The totalLatency to set.

Returns:

This builder for chaining.

clearTotalLatency

public Monitoring.MonitoringMessage.Builder clearTotalLatency()

int64 totalLatency = 13;

Returns:

This builder for chaining.

getMinLatency

public long getMinLatency()

int64 minLatency = 14;

Specified by:

getMinLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The minLatency.

setMinLatency

public Monitoring.MonitoringMessage.Builder setMinLatency(long value)

int64 minLatency = 14;

Parameters:

value - The minLatency to set.

Returns:

This builder for chaining.

clearMinLatency

public Monitoring.MonitoringMessage.Builder clearMinLatency()

int64 minLatency = 14;

Returns:

This builder for chaining.

getMaxLatency

public long getMaxLatency()

int64 maxLatency = 15;

Specified by:

getMaxLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The maxLatency.

setMaxLatency

public Monitoring.MonitoringMessage.Builder setMaxLatency(long value)

int64 maxLatency = 15;

Parameters:

value - The maxLatency to set.

Returns:

This builder for chaining.

clearMaxLatency

public Monitoring.MonitoringMessage.Builder clearMaxLatency()

int64 maxLatency = 15;

Returns:

This builder for chaining.

getSamplePeriod

public long getSamplePeriod()

int64 samplePeriod = 16;

Specified by:

getSamplePeriod in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The samplePeriod.

setSamplePeriod

public Monitoring.MonitoringMessage.Builder setSamplePeriod(long value)

int64 samplePeriod = 16;

Parameters:

value - The samplePeriod to set.

Returns:

This builder for chaining.

clearSamplePeriod

public Monitoring.MonitoringMessage.Builder clearSamplePeriod()

int64 samplePeriod = 16;

Returns:

This builder for chaining.

getTypeValue

public int getTypeValue()

.monitoring.MessageType type = 17;

Specified by:

getTypeValue in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The enum numeric value on the wire for type.

setTypeValue

public Monitoring.MonitoringMessage.Builder setTypeValue(int value)

.monitoring.MessageType type = 17;

Parameters:

value - The enum numeric value on the wire for type to set.

Returns:

This builder for chaining.

getType

public Monitoring.MessageType getType()

.monitoring.MessageType type = 17;

Specified by:

getType in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The type.

setType

public Monitoring.MonitoringMessage.Builder setType(Monitoring.MessageType value)

.monitoring.MessageType type = 17;

Parameters:

value - The type to set.

Returns:

This builder for chaining.

clearType

public Monitoring.MonitoringMessage.Builder clearType()

.monitoring.MessageType type = 17;

Returns:

This builder for chaining.

getShutdown

public boolean getShutdown()

bool shutdown = 18;

Specified by:

getShutdown in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The shutdown.

setShutdown

public Monitoring.MonitoringMessage.Builder setShutdown(boolean value)

bool shutdown = 18;

Parameters:

value - The shutdown to set.

Returns:

This builder for chaining.

clearShutdown

public Monitoring.MonitoringMessage.Builder clearShutdown()

bool shutdown = 18;

Returns:

This builder for chaining.

getMinWindow

public long getMinWindow()

int64 minWindow = 19;

Specified by:

getMinWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The minWindow.

setMinWindow

public Monitoring.MonitoringMessage.Builder setMinWindow(long value)

int64 minWindow = 19;

Parameters:

value - The minWindow to set.

Returns:

This builder for chaining.

clearMinWindow

public Monitoring.MonitoringMessage.Builder clearMinWindow()

int64 minWindow = 19;

Returns:

This builder for chaining.

getMaxWindow

public long getMaxWindow()

int64 maxWindow = 20;

Specified by:

getMaxWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The maxWindow.

setMaxWindow

public Monitoring.MonitoringMessage.Builder setMaxWindow(long value)

int64 maxWindow = 20;

Parameters:

value - The maxWindow to set.

Returns:

This builder for chaining.

clearMaxWindow

public Monitoring.MonitoringMessage.Builder clearMaxWindow()

int64 maxWindow = 20;

Returns:

This builder for chaining.

getMonitoringTopicPartition

public int getMonitoringTopicPartition()

int32 monitoringTopicPartition = 21;

Specified by:

getMonitoringTopicPartition in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The monitoringTopicPartition.

setMonitoringTopicPartition

public Monitoring.MonitoringMessage.Builder setMonitoringTopicPartition(int value)

int32 monitoringTopicPartition = 21;

Parameters:

value - The monitoringTopicPartition to set.

Returns:

This builder for chaining.

clearMonitoringTopicPartition

public Monitoring.MonitoringMessage.Builder clearMonitoringTopicPartition()

int32 monitoringTopicPartition = 21;

Returns:

This builder for chaining.

getClusterId

public String getClusterId()

 Kafka cluster ID (required)
 

string clusterId = 22;

Specified by:

getClusterId in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The clusterId.

getClusterIdBytes

public com.google.protobuf.ByteString getClusterIdBytes()

 Kafka cluster ID (required)
 

string clusterId = 22;

Specified by:

getClusterIdBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for clusterId.

setClusterId

public Monitoring.MonitoringMessage.Builder setClusterId(String value)

 Kafka cluster ID (required)
 

string clusterId = 22;

Parameters:

value - The clusterId to set.

Returns:

This builder for chaining.

clearClusterId

public Monitoring.MonitoringMessage.Builder clearClusterId()

 Kafka cluster ID (required)
 

string clusterId = 22;

Returns:

This builder for chaining.

setClusterIdBytes

public Monitoring.MonitoringMessage.Builder setClusterIdBytes(com.google.protobuf.ByteString value)

 Kafka cluster ID (required)
 

string clusterId = 22;

Parameters:

value - The bytes for clusterId to set.

Returns:

This builder for chaining.

getClusterName

public String getClusterName()

 Kafka cluster name (optional, human-friendly)
 

string clusterName = 23;

Specified by:

getClusterName in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The clusterName.

getClusterNameBytes

public com.google.protobuf.ByteString getClusterNameBytes()

 Kafka cluster name (optional, human-friendly)
 

string clusterName = 23;

Specified by:

getClusterNameBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The bytes for clusterName.

setClusterName

public Monitoring.MonitoringMessage.Builder setClusterName(String value)

 Kafka cluster name (optional, human-friendly)
 

string clusterName = 23;

Parameters:

value - The clusterName to set.

Returns:

This builder for chaining.

clearClusterName

public Monitoring.MonitoringMessage.Builder clearClusterName()

 Kafka cluster name (optional, human-friendly)
 

string clusterName = 23;

Returns:

This builder for chaining.

setClusterNameBytes

public Monitoring.MonitoringMessage.Builder setClusterNameBytes(com.google.protobuf.ByteString value)

 Kafka cluster name (optional, human-friendly)
 

string clusterName = 23;

Parameters:

value - The bytes for clusterName to set.

Returns:

This builder for chaining.

getArrivalTime

public long getArrivalTime()

 C3 time when the message arrived to C3
 

int64 arrivalTime = 24;

Specified by:

getArrivalTime in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The arrivalTime.

setArrivalTime

public Monitoring.MonitoringMessage.Builder setArrivalTime(long value)

 C3 time when the message arrived to C3
 

int64 arrivalTime = 24;

Parameters:

value - The arrivalTime to set.

Returns:

This builder for chaining.

clearArrivalTime

public Monitoring.MonitoringMessage.Builder clearArrivalTime()

 C3 time when the message arrived to C3
 

int64 arrivalTime = 24;

Returns:

This builder for chaining.