Method bufferMessage

server/querylog_kafka_writer.go:249–269 · view source on GitHub ↗

(batches *queryLogKafkaPartitionBatches, msg QueryLogKafkaConsumedMessage)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

RunMethod · 0.95

currentTimeMethod · 0.95

effectiveBatchSizeMethod · 0.95

recordQueryLogKafkaWriterEventFunction · 0.85

validateQueryLogKafkaEventFunction · 0.85

queryLogEntryFromKafkaEventFunction · 0.85

addDroppedMethod · 0.80

addEventMethod · 0.80

orgLenMethod · 0.80

no test coverage detected