MCPcopy Create free account

hub / github.com/amient/kafka-metrics / functions

Functions135 in github.com/amient/kafka-metrics

⨍ Functions 135◇ Types & classes 36
↓ 262 callersMethodput
(Collection<SinkRecord> sinkRecords)
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkTask.java:49
↓ 23 callersMethodget
(ObjectNode node, String fieldName)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:254
↓ 17 callersMethodtoString
(MeasurementV1 measurement)
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java:101
↓ 16 callersMethodnewTarget
(ObjectNode panel, String aliasPattern, String rawQuery)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:212
↓ 15 callersMethodget
(String group, TopicPartition tp)
metrics-reporter/src/main/java/io/amient/kafka/metrics/GroupMetrics.java:25
↓ 13 callersMethodgetTags
()
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:70
↓ 11 callersMethodnewGraph
(ArrayNode rowPanels, String title, int span, boolean showLegend)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:91
↓ 9 callersMethodclose
()
core/src/main/java/io/amient/kafka/metrics/MeasurementPublisher.java:26
↓ 9 callersMethodnewObject
()
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:244
↓ 8 callersMethodnewArray
(String... values)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:248
↓ 8 callersMethodvalue
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporter.java:180
↓ 7 callersMethodsetTags
(HashMap<String,String> tags)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:103
↓ 6 callersMethodbuild
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:127
↓ 6 callersMethodpublish
(MeasurementV1 m)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:97
↓ 5 callersMethodcreateMeasurement
(com.yammer.metrics.core.MetricName name, Long timestamp, Map<Stri
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:72
↓ 4 callersMethodanyValueToDouble
(Object anyValue)
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java:80
↓ 4 callersMethodfromBytes
(byte[] bytes)
core/src/main/java/io/amient/kafka/metrics/InternalAvroSerde.java:65
↓ 4 callersMethodpublish
(MeasurementV1 m)
core/src/main/java/io/amient/kafka/metrics/MeasurementPublisher.java:24
↓ 3 callersMethodhostPort
()
discovery/src/main/java/io/amient/kafka/metrics/Broker.java:35
↓ 3 callersMethodisTerminated
()
core/src/main/java/io/amient/kafka/metrics/JMXScanner.java:80
↓ 3 callersMethodnewPanel
(ArrayNode rowPanels, String title, int span, String type)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:222
↓ 3 callersMethodnewRow
(String rowTitle, int heightPx, boolean expand)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:79
↓ 3 callersMethodtoBytes
(MeasurementV1 measurement)
core/src/main/java/io/amient/kafka/metrics/InternalAvroSerde.java:48
↓ 2 callersMethodaddShutdownHook
()
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:91
↓ 2 callersMethodflush
(Map<TopicPartition, OffsetAndMetadata> offsets)
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkTask.java:57
↓ 2 callersMethodfromConnectData
(String topic, Schema schema, Object logicalValue)
metrics-connect/src/main/java/io/amient/kafka/metrics/MeasurementConverter.java:61
↓ 2 callersMethodgetAddress
()
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:66
↓ 2 callersMethodgetQueryIntervalSeconds
()
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:82
↓ 2 callersMethodnewStat
(ArrayNode rowPanels, String title, int span, String query)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:164
↓ 2 callersMethodshutdown
()
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:85
↓ 2 callersMethodstart
(long timeout, TimeUnit unit)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:103
↓ 1 callersMethodNewName
(String group, TopicPartition tp)
metrics-reporter/src/main/java/io/amient/kafka/metrics/GroupMetrics.java:46
↓ 1 callersMethodaddProducerShutdownHook
()
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:94
↓ 1 callersMethodclose
()
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:87
↓ 1 callersMethodconfigure
(Properties config)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:51
↓ 1 callersMethodconfigure
(Map<String, ?> configs, boolean isKey)
metrics-connect/src/main/java/io/amient/kafka/metrics/MeasurementConverter.java:36
↓ 1 callersMethoddecorateConfig
(Properties config)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:108
↓ 1 callersMethoddeserialize
(String topic, byte[] bytes)
core/src/main/java/io/amient/kafka/metrics/MeasurementDeserializer.java:40
↓ 1 callersMethodextractAttributesAsMeasurements
(ObjectInstance i, Long timestamp)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:180
↓ 1 callersMethodextractMeasurements
(ObjectInstance i, Long timestamp)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:134
↓ 1 callersMethodforRegistry
Builder for programmatic configuration into an existing Yammer Metrics registry @param registry metrics registry to which to attach the reporter @retu
metrics-reporter/src/main/java/io/amient/kafka/metrics/TopicReporter.java:57
↓ 1 callersMethodfromJsonTree
(JsonNode node)
core/src/main/java/io/amient/kafka/metrics/AutoJsonDeserializer.java:56
↓ 1 callersMethodgenerateDashboard
( String name, List<Broker> brokers, List<String> topics, String dataSource, String path, int inte
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:194
↓ 1 callersMethodgenerateScannerConfig
(List<Broker> brokers, String name, int interval_s)
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:134
↓ 1 callersMethodgetBroker
(String brokerId)
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:184
↓ 1 callersMethodgetKafkaBrokers
()
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:176
↓ 1 callersMethodgetKafkaTopics
()
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:168
↓ 1 callersMethodgetPollingIntervaSeconds
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:68
↓ 1 callersMethodgetQueryScope
()
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:74
↓ 1 callersMethodisTerminated
()
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:101
↓ 1 callersMethodnewTable
(ArrayNode rowPanels, String title, int span, String valueName, String alias, String query)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:138
↓ 1 callersMethodnewVariable
(String name, boolean includeAll, String... options)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:185
↓ 1 callersMethodrun
()
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:93
↓ 1 callersMethodsave
()
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:65
↓ 1 callersMethodsetAddress
(String address)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:58
↓ 1 callersMethodsetBootstrapServers
(String bootstrapServers)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:88
↓ 1 callersMethodsetQueryInterval
(long intervalSeconds)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:78
↓ 1 callersMethodsetQueryScope
(String query)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:62
↓ 1 callersMethodsetTag
(String tagName, String tagValue)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:93
↓ 1 callersMethodsetTag
(String propKey, String propVal)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:54
↓ 1 callersMethodsetTopic
(String topic)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:83
↓ 1 callersMethodshutdown
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporter.java:97
↓ 1 callersMethodshutdown
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:108
↓ 1 callersMethodstartReporter
(long pollingPeriodSecs)
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporter.java:66
↓ 1 callersMethodstartReporter
(long pollingPeriodSecs)
metrics-reporter/src/main/java/io/amient/kafka/metrics/TopicReporter.java:78
↓ 1 callersMethodtagSamzaMetricField
(String name, String field, Map<String, String> tags)
core/src/main/java/io/amient/kafka/metrics/AutoJsonDeserializer.java:121
↓ 1 callersMethodtoConnectData
(String topic, byte[] value)
metrics-connect/src/main/java/io/amient/kafka/metrics/MeasurementConverter.java:49
↓ 1 callersMethodtryPublish
(MeasurementV1 m)
influxdb-loader/src/main/java/io/amient/kafka/metrics/InfluxDbPublisher.java:72
↓ 1 callersMethodtryPublish
(MeasurementV1 m)
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:83
↓ 1 callersMethodversion
()
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkTask.java:36
↓ 1 callersMethodwriteTo
(ConsumerRecord<byte[], byte[]> consumerRecord, PrintStream output)
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java:44
MethodBroker
(String id, String host, int port, int jmxPort)
discovery/src/main/java/io/amient/kafka/metrics/Broker.java:28
MethodConsumerMetrics
(Properties props)
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:45
MethodDashboard
(String title, String dataSource, String filename)
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java:40
MethodDiscoveryTool
(String serverstring)
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:148
MethodGroupMetrics
(String metricName, Class<? extends T> cls, MetricsRegistry registry)
metrics-reporter/src/main/java/io/amient/kafka/metrics/GroupMetrics.java:19
MethodInfluxDbPublisher
(Properties config)
influxdb-loader/src/main/java/io/amient/kafka/metrics/InfluxDbPublisher.java:50
MethodJMXScanner
(Properties props, MeasurementPublisher publisher)
core/src/main/java/io/amient/kafka/metrics/JMXScanner.java:43
MethodJMXScannerTask
(JMXScannerConfig config, MeasurementPublisher publisher)
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java:88
MethodKafkaMetricsProcessor
( MetricsRegistry metricsRegistry, Map<org.apache.kafka.common.MetricName, KafkaMetric
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java:52
MethodKafkaMetricsProcessorBuilder
(MetricsRegistry registry)
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:47
MethodProducerPublisher
(Properties props)
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:48
MethodSchemaVersions
(SpecificDatumReader<?> reader)
core/src/main/java/io/amient/kafka/metrics/InternalAvroSerde.java:40
MethodTask
(MeasurementPublisher publisher, KafkaConsumer<String, List<MeasurementV1>> consumer)
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java:111
MethodTopicReporter
()
metrics-reporter/src/main/java/io/amient/kafka/metrics/TopicReporter.java:48
MethodX
(MetricsRegistry registry)
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporter.java:91
Methodclose
()
influxdb-loader/src/main/java/io/amient/kafka/metrics/InfluxDbPublisher.java:89
Methodclose
()
core/src/test/java/JmxScannerMain.java:27
Methodclose
()
core/src/main/java/io/amient/kafka/metrics/MeasurementSerializer.java:38
Methodclose
()
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java:75
Methodclose
()
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:119
Methodclose
()
core/src/main/java/io/amient/kafka/metrics/MeasurementDeserializer.java:50
Methodconfig
()
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkConnector.java:52
Methodconfigure
(Map<String, ?> map, boolean b)
core/src/main/java/io/amient/kafka/metrics/MeasurementSerializer.java:30
Methodconfigure
(Map<String, ?> configs, boolean isKey)
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java:105
Methodconfigure
(Map<String, ?> configs, boolean isKey)
core/src/main/java/io/amient/kafka/metrics/MeasurementDeserializer.java:35
MethoddecorateKafkaClientConfig
generate properties for New Kafka Client Producer ( 0.8.2+) and Consumer (0.9+) @param kafkaClientConfig
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java:122
Methoddeserialize
(byte[] bytes)
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java:157
MethodendToEndConversionTest
()
metrics-connect/src/test/java/io/amient/kafka/metrics/MeasurementConverterTest.java:13
MethodfromBytes
(byte[] bytes)
core/src/main/java/io/amient/kafka/metrics/AutoJsonDeserializer.java:38
next →1–100 of 135, ranked by callers