Package com.linkedin.venice.protocols
Interface IngestionMonitorResponseOrBuilder
- All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder
- All Known Implementing Classes:
IngestionMonitorResponse,IngestionMonitorResponse.Builder
public interface IngestionMonitorResponseOrBuilder
extends com.google.protobuf.MessageOrBuilder
-
Method Summary
Modifier and TypeMethodDescriptiondoubledouble bytes_ingested_per_sec = 5;doubleProcessing latencylongTimingbooleanbool is_hybrid = 3;doubledouble leader_bytes_produced_per_sec = 13;string leader_follower_state = 2;com.google.protobuf.ByteStringstring leader_follower_state = 2;doubledouble leader_preprocessing_latency_avg_ms = 8;doubleProduce latency (leader)doubledouble leader_producer_callback_latency_avg_ms = 11;doubledouble leader_producer_completion_latency_avg_ms = 10;doubleLeader outputdoubledouble leader_rmd_lookup_latency_avg_ms = 16;doubleRT lookup latency (leader)doubleIngestion throughput (measured after drainer processing / conflict resolution)doubleStorage latencylongint64 timestamp_ms = 1;Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder
isInitializedMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getTimestampMs
long getTimestampMs()int64 timestamp_ms = 1;- Returns:
- The timestampMs.
-
getLeaderFollowerState
String getLeaderFollowerState()string leader_follower_state = 2;- Returns:
- The leaderFollowerState.
-
getLeaderFollowerStateBytes
com.google.protobuf.ByteString getLeaderFollowerStateBytes()string leader_follower_state = 2;- Returns:
- The bytes for leaderFollowerState.
-
getIsHybrid
boolean getIsHybrid()bool is_hybrid = 3;- Returns:
- The isHybrid.
-
getRecordsIngestedPerSec
double getRecordsIngestedPerSec()Ingestion throughput (measured after drainer processing / conflict resolution)
double records_ingested_per_sec = 4;- Returns:
- The recordsIngestedPerSec.
-
getBytesIngestedPerSec
double getBytesIngestedPerSec()double bytes_ingested_per_sec = 5;- Returns:
- The bytesIngestedPerSec.
-
getConsumedRecordE2EProcessingLatencyAvgMs
double getConsumedRecordE2EProcessingLatencyAvgMs()Processing latency
double consumed_record_e2e_processing_latency_avg_ms = 7;- Returns:
- The consumedRecordE2eProcessingLatencyAvgMs.
-
getLeaderPreprocessingLatencyAvgMs
double getLeaderPreprocessingLatencyAvgMs()double leader_preprocessing_latency_avg_ms = 8;- Returns:
- The leaderPreprocessingLatencyAvgMs.
-
getLeaderProduceLatencyAvgMs
double getLeaderProduceLatencyAvgMs()Produce latency (leader)
double leader_produce_latency_avg_ms = 9;- Returns:
- The leaderProduceLatencyAvgMs.
-
getLeaderProducerCompletionLatencyAvgMs
double getLeaderProducerCompletionLatencyAvgMs()double leader_producer_completion_latency_avg_ms = 10;- Returns:
- The leaderProducerCompletionLatencyAvgMs.
-
getLeaderProducerCallbackLatencyAvgMs
double getLeaderProducerCallbackLatencyAvgMs()double leader_producer_callback_latency_avg_ms = 11;- Returns:
- The leaderProducerCallbackLatencyAvgMs.
-
getLeaderRecordsProducedPerSec
double getLeaderRecordsProducedPerSec()Leader output
double leader_records_produced_per_sec = 12;- Returns:
- The leaderRecordsProducedPerSec.
-
getLeaderBytesProducedPerSec
double getLeaderBytesProducedPerSec()double leader_bytes_produced_per_sec = 13;- Returns:
- The leaderBytesProducedPerSec.
-
getStorageEnginePutLatencyAvgMs
double getStorageEnginePutLatencyAvgMs()Storage latency
double storage_engine_put_latency_avg_ms = 14;- Returns:
- The storageEnginePutLatencyAvgMs.
-
getLeaderValueBytesLookupLatencyAvgMs
double getLeaderValueBytesLookupLatencyAvgMs()RT lookup latency (leader)
double leader_value_bytes_lookup_latency_avg_ms = 15;- Returns:
- The leaderValueBytesLookupLatencyAvgMs.
-
getLeaderRmdLookupLatencyAvgMs
double getLeaderRmdLookupLatencyAvgMs()double leader_rmd_lookup_latency_avg_ms = 16;- Returns:
- The leaderRmdLookupLatencyAvgMs.
-
getElapsedTimeSinceLastRecordMs
long getElapsedTimeSinceLastRecordMs()Timing
int64 elapsed_time_since_last_record_ms = 17;- Returns:
- The elapsedTimeSinceLastRecordMs.
-