Package io.confluent.monitoring.record

Class Monitoring.MonitoringMessage

java.lang.Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

io.confluent.monitoring.record.Monitoring.MonitoringMessage

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Monitoring.MonitoringMessageOrBuilder, Serializable

Enclosing class:

Monitoring

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

Protobuf type monitoring.MonitoringMessage

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Monitoring.MonitoringMessage.Builder	Protobuf type monitoring.MonitoringMessage

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	AGGREGATEBYTES_FIELD_NUMBER
static final int	AGGREGATECRC_FIELD_NUMBER
static final int	ARRIVALTIME_FIELD_NUMBER
static final int	CLIENTID_FIELD_NUMBER
static final int	CLIENTTYPE_FIELD_NUMBER
static final int	CLUSTERID_FIELD_NUMBER
static final int	CLUSTERNAME_FIELD_NUMBER
static final int	COUNT_FIELD_NUMBER
static final int	GROUP_FIELD_NUMBER
static final int	MAXLATENCY_FIELD_NUMBER
static final int	MAXWINDOW_FIELD_NUMBER
static final int	MINLATENCY_FIELD_NUMBER
static final int	MINWINDOW_FIELD_NUMBER
static final int	MONITORINGTOPICPARTITION_FIELD_NUMBER
static final int	PARTITION_FIELD_NUMBER
static final int	SAMPLEPERIOD_FIELD_NUMBER
static final int	SEQUENCE_FIELD_NUMBER
static final int	SESSION_FIELD_NUMBER
static final int	SHUTDOWN_FIELD_NUMBER
static final int	TIMESTAMP_FIELD_NUMBER
static final int	TOPIC_FIELD_NUMBER
static final int	TOTALLATENCY_FIELD_NUMBER
static final int	TYPE_FIELD_NUMBER
static final int	WINDOW_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
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;
static Monitoring.MonitoringMessage	getDefaultInstance()
Monitoring.MonitoringMessage	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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;
com.google.protobuf.Parser<Monitoring.MonitoringMessage>	getParserForType()
int	getPartition()	int32 partition = 9;
long	getSamplePeriod()	int64 samplePeriod = 16;
long	getSequence()	int64 sequence = 5;
int	getSerializedSize()
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;
int	hashCode()
final boolean	isInitialized()
static Monitoring.MonitoringMessage.Builder	newBuilder()
static Monitoring.MonitoringMessage.Builder	newBuilder(Monitoring.MonitoringMessage prototype)
Monitoring.MonitoringMessage.Builder	newBuilderForType()
static Monitoring.MonitoringMessage	parseDelimitedFrom(InputStream input)
static Monitoring.MonitoringMessage	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Monitoring.MonitoringMessage	parseFrom(byte[] data)
static Monitoring.MonitoringMessage	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Monitoring.MonitoringMessage	parseFrom(com.google.protobuf.ByteString data)
static Monitoring.MonitoringMessage	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Monitoring.MonitoringMessage	parseFrom(com.google.protobuf.CodedInputStream input)
static Monitoring.MonitoringMessage	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Monitoring.MonitoringMessage	parseFrom(InputStream input)
static Monitoring.MonitoringMessage	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Monitoring.MonitoringMessage	parseFrom(ByteBuffer data)
static Monitoring.MonitoringMessage	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<Monitoring.MonitoringMessage>	parser()
Monitoring.MonitoringMessage.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Field Details

CLIENTTYPE_FIELD_NUMBER

public static final int CLIENTTYPE_FIELD_NUMBER

See Also:

• Constant Field Values

CLIENTID_FIELD_NUMBER

public static final int CLIENTID_FIELD_NUMBER

See Also:

• Constant Field Values

GROUP_FIELD_NUMBER

public static final int GROUP_FIELD_NUMBER

See Also:

• Constant Field Values

SESSION_FIELD_NUMBER

public static final int SESSION_FIELD_NUMBER

See Also:

• Constant Field Values

SEQUENCE_FIELD_NUMBER

public static final int SEQUENCE_FIELD_NUMBER

See Also:

• Constant Field Values

WINDOW_FIELD_NUMBER

public static final int WINDOW_FIELD_NUMBER

See Also:

• Constant Field Values

TIMESTAMP_FIELD_NUMBER

public static final int TIMESTAMP_FIELD_NUMBER

See Also:

• Constant Field Values

TOPIC_FIELD_NUMBER

public static final int TOPIC_FIELD_NUMBER

See Also:

• Constant Field Values

PARTITION_FIELD_NUMBER

public static final int PARTITION_FIELD_NUMBER

See Also:

• Constant Field Values

COUNT_FIELD_NUMBER

public static final int COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

AGGREGATEBYTES_FIELD_NUMBER

public static final int AGGREGATEBYTES_FIELD_NUMBER

See Also:

• Constant Field Values

AGGREGATECRC_FIELD_NUMBER

public static final int AGGREGATECRC_FIELD_NUMBER

See Also:

• Constant Field Values

TOTALLATENCY_FIELD_NUMBER

public static final int TOTALLATENCY_FIELD_NUMBER

See Also:

• Constant Field Values

MINLATENCY_FIELD_NUMBER

public static final int MINLATENCY_FIELD_NUMBER

See Also:

• Constant Field Values

MAXLATENCY_FIELD_NUMBER

public static final int MAXLATENCY_FIELD_NUMBER

See Also:

• Constant Field Values

SAMPLEPERIOD_FIELD_NUMBER

public static final int SAMPLEPERIOD_FIELD_NUMBER

See Also:

• Constant Field Values

TYPE_FIELD_NUMBER

public static final int TYPE_FIELD_NUMBER

See Also:

• Constant Field Values

SHUTDOWN_FIELD_NUMBER

public static final int SHUTDOWN_FIELD_NUMBER

See Also:

• Constant Field Values

MINWINDOW_FIELD_NUMBER

public static final int MINWINDOW_FIELD_NUMBER

See Also:

• Constant Field Values

MAXWINDOW_FIELD_NUMBER

public static final int MAXWINDOW_FIELD_NUMBER

See Also:

• Constant Field Values

MONITORINGTOPICPARTITION_FIELD_NUMBER

public static final int MONITORINGTOPICPARTITION_FIELD_NUMBER

See Also:

• Constant Field Values

CLUSTERID_FIELD_NUMBER

public static final int CLUSTERID_FIELD_NUMBER

See Also:

• Constant Field Values

CLUSTERNAME_FIELD_NUMBER

public static final int CLUSTERNAME_FIELD_NUMBER

See Also:

• Constant Field Values

ARRIVALTIME_FIELD_NUMBER

public static final int ARRIVALTIME_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

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.

getClientType

public Monitoring.ClientType getClientType()

.monitoring.ClientType clientType = 1;

Specified by:

getClientType in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The clientType.

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.

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.

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.

getSequence

public long getSequence()

int64 sequence = 5;

Specified by:

getSequence in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The sequence.

getWindow

public long getWindow()

int64 window = 6;

Specified by:

getWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The window.

getTimestamp

public long getTimestamp()

int64 timestamp = 7;

Specified by:

getTimestamp in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The timestamp.

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.

getPartition

public int getPartition()

int32 partition = 9;

Specified by:

getPartition in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The partition.

getCount

public long getCount()

int64 count = 10;

Specified by:

getCount in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The count.

getAggregateBytes

public long getAggregateBytes()

int64 aggregateBytes = 11;

Specified by:

getAggregateBytes in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The aggregateBytes.

getAggregateCrc

public int getAggregateCrc()

int32 aggregateCrc = 12;

Specified by:

getAggregateCrc in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The aggregateCrc.

getTotalLatency

public long getTotalLatency()

int64 totalLatency = 13;

Specified by:

getTotalLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The totalLatency.

getMinLatency

public long getMinLatency()

int64 minLatency = 14;

Specified by:

getMinLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The minLatency.

getMaxLatency

public long getMaxLatency()

int64 maxLatency = 15;

Specified by:

getMaxLatency in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The maxLatency.

getSamplePeriod

public long getSamplePeriod()

int64 samplePeriod = 16;

Specified by:

getSamplePeriod in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The samplePeriod.

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.

getType

public Monitoring.MessageType getType()

.monitoring.MessageType type = 17;

Specified by:

getType in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The type.

getShutdown

public boolean getShutdown()

bool shutdown = 18;

Specified by:

getShutdown in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The shutdown.

getMinWindow

public long getMinWindow()

int64 minWindow = 19;

Specified by:

getMinWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The minWindow.

getMaxWindow

public long getMaxWindow()

int64 maxWindow = 20;

Specified by:

getMaxWindow in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The maxWindow.

getMonitoringTopicPartition

public int getMonitoringTopicPartition()

int32 monitoringTopicPartition = 21;

Specified by:

getMonitoringTopicPartition in interface Monitoring.MonitoringMessageOrBuilder

Returns:

The monitoringTopicPartition.

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.

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.

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.

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessage

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static Monitoring.MonitoringMessage parseFrom(ByteBuffer data)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(com.google.protobuf.ByteString data)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(com.google.protobuf.ByteString data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(byte[] data)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(InputStream input)
                                              throws IOException

Throws:

IOException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws IOException

Throws:

IOException

parseDelimitedFrom

public static Monitoring.MonitoringMessage parseDelimitedFrom(InputStream input)
                                                       throws IOException

Throws:

IOException

parseDelimitedFrom

public static Monitoring.MonitoringMessage parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                       throws IOException

Throws:

IOException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(com.google.protobuf.CodedInputStream input)
                                              throws IOException

Throws:

IOException

parseFrom

public static Monitoring.MonitoringMessage parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                              throws IOException

Throws:

IOException

newBuilderForType

public Monitoring.MonitoringMessage.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static Monitoring.MonitoringMessage.Builder newBuilder()

newBuilder

public static Monitoring.MonitoringMessage.Builder newBuilder(Monitoring.MonitoringMessage prototype)

toBuilder

public Monitoring.MonitoringMessage.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static Monitoring.MonitoringMessage getDefaultInstance()

parser

public static com.google.protobuf.Parser<Monitoring.MonitoringMessage> parser()

getParserForType

public com.google.protobuf.Parser<Monitoring.MonitoringMessage> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessage

getDefaultInstanceForType

public Monitoring.MonitoringMessage getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder