o `j@sfdZddlZddlmZddlmZmZmZmZddl m Z e e Z GdddZGdd d ZdS) z:Metrics for kafka.net connection manager and connections. N)AnonMeasurable)AvgCountMaxRate)TimeUnitc@eZdZdZddZdS)KafkaManagerMetricszMetrics for KafkaConnectionManager (equivalent to KafkaClientMetrics). Note that kafka.net does not track select_time or io_time. cs||_|d}|d|_|j|d|dt|d|_|j|d|dt||d|d tfd d dS) N-metricszconnections-closedzconnection-close-ratez,Connections closed per second in the window.zconnections-createdzconnection-creation-ratez5New connections established per second in the window.zconnection-countz)The current number of active connections.cstS)N)len)confignowconnsO/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/net/metrics.py!sz.KafkaManagerMetrics.__init__..) metricssensorconnection_closedadd metric_namerconnection_created add_metricr)selfrmetric_group_prefixrmetric_group_namerrr__init__s0     zKafkaManagerMetrics.__init__N__name__ __module__ __qualname____doc__rrrrrr s r c@r)KafkaConnectionMetricszMMetrics for a single KafkaConnection (equivalent to BrokerConnectionMetrics).c CsZ||_|ds|d}|d}||d|dttd|jd|gd}||d|d t||d |d ttd||d |d t||d|dt|jd|gd}||d|dt||d|dttd|d}||d|dt||d|dt|d} | |d|dt| |d|dt|d|d s|d!|}|jd|d |dgd}||d|d"t||d |d ttd||d |d t||d|dt|jd|d#|dgd}||d|d$t||d|d%ttd|jd|d&|dgd} | |d|dt| |d|dt|jd|d'|dgd} | |d|dt| |d|dt|d|d |_ |d|d#|_ |d|d&|_ |d|d'|_ dS)(Nzbytes-sent-receivedr znetwork-io-ratezYThe average number of network operations (reads or writes) on all connections per second.) sampled_statz bytes-sent)parentszoutgoing-byte-ratezDThe average number of outgoing bytes sent per second to all servers.z request-ratez/The average number of requests sent per second.zrequest-size-avgz/The average size of all requests in the window.zrequest-size-maxz3The maximum size of any request sent in the window.zbytes-receivedzincoming-byte-ratez!Bytes/second read off all socketsz response-ratez#Responses received sent per second.zrequest-latencyzrequest-latency-avgz"The average request latency in ms.zrequest-latency-maxz"The maximum request latency in ms.z throttle-timezthrottle-time-avgz The average throttle time in ms.zthrottle-time-maxz The maximum throttle time in ms.znode-z .bytes-sentz-node-metrics.node-z5The average number of outgoing bytes sent per second.z.bytes-receivedz,Bytes/second read off node-connection socketz4The average number of responses received per second.z.latencyz .throttle) r get_sensorrrrrrrr bytes_sentbytes_received request_time throttle_time) rrrnode_idrbytes_transferredr'r(request_latencyr*r)rrrr&s@                 zKafkaConnectionMetrics.__init__Nrrrrrr#$s r#)r"loggingkafka.metrics.measurablerkafka.metrics.statsrrrrkafka.metrics.stats.rater getLoggerrlogr r#rrrrs