public static interface Monitoring.MonitoringMessageOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
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; |
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; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
int getClientTypeValue()
.monitoring.ClientType clientType = 1;
Monitoring.ClientType getClientType()
.monitoring.ClientType clientType = 1;
String getClientId()
string clientId = 2;
com.google.protobuf.ByteString getClientIdBytes()
string clientId = 2;
String getGroup()
string group = 3;
com.google.protobuf.ByteString getGroupBytes()
string group = 3;
String getSession()
string session = 4;
com.google.protobuf.ByteString getSessionBytes()
string session = 4;
long getSequence()
int64 sequence = 5;
long getWindow()
int64 window = 6;
long getTimestamp()
int64 timestamp = 7;
String getTopic()
string topic = 8;
com.google.protobuf.ByteString getTopicBytes()
string topic = 8;
int getPartition()
int32 partition = 9;
long getCount()
int64 count = 10;
long getAggregateBytes()
int64 aggregateBytes = 11;
int getAggregateCrc()
int32 aggregateCrc = 12;
long getTotalLatency()
int64 totalLatency = 13;
long getMinLatency()
int64 minLatency = 14;
long getMaxLatency()
int64 maxLatency = 15;
long getSamplePeriod()
int64 samplePeriod = 16;
int getTypeValue()
.monitoring.MessageType type = 17;
Monitoring.MessageType getType()
.monitoring.MessageType type = 17;
boolean getShutdown()
bool shutdown = 18;
long getMinWindow()
int64 minWindow = 19;
long getMaxWindow()
int64 maxWindow = 20;
int getMonitoringTopicPartition()
int32 monitoringTopicPartition = 21;
String getClusterId()
Kafka cluster ID (required)
string clusterId = 22;
com.google.protobuf.ByteString getClusterIdBytes()
Kafka cluster ID (required)
string clusterId = 22;
String getClusterName()
Kafka cluster name (optional, human-friendly)
string clusterName = 23;
com.google.protobuf.ByteString getClusterNameBytes()
Kafka cluster name (optional, human-friendly)
string clusterName = 23;
long getArrivalTime()
C3 time when the message arrived to C3
int64 arrivalTime = 24;