MCPcopy
hub / github.com/faust-streaming/faust / timing

Method timing

faust/sensors/datadog.py:84–90  ·  view source on GitHub ↗
(self, metric: str, value: float, labels: Dict = None)

Source from the content-addressed store, hash-verified

82 self.decrement(metric, value=count)
83
84 def timing(self, metric: str, value: float, labels: Dict = None) -> None:
85 self.client.timing( # type: ignore
86 metric,
87 value=value,
88 tags=self._encode_labels(labels),
89 sample_rate=self.rate,
90 )
91
92 def timed(
93 self,

Callers 15

on_stream_event_outMethod · 0.80
on_commit_completedMethod · 0.80
on_send_completedMethod · 0.80
on_send_errorMethod · 0.80
on_assignment_errorMethod · 0.80
on_rebalance_returnMethod · 0.80
on_rebalance_endMethod · 0.80
on_web_request_endMethod · 0.80
on_stream_event_outMethod · 0.80
on_commit_completedMethod · 0.80
on_send_completedMethod · 0.80

Calls 1

_encode_labelsMethod · 0.95

Tested by

no test coverage detected