Index

A

add_msink() (metrix.coordinator.MCoordinator method)

add_mstream() (metrix.coordinator.MCoordinator method) agg (metrix.stream.MStream attribute)

B

batch_size (metrix.stream.MStream attribute)

D

default_tags (metrix.stream.MStream attribute)

G

group_has_elements() (in module metrix.stream)

K

key_from_tags() (in module metrix.element)

L

level (metrix.sinks.MSinkLogger attribute)

logger (metrix.sinks.MSinkLogger attribute)

M

MCoordinator (class in metrix.coordinator) MElement (class in metrix.element) metric_mstreams (metrix.coordinator.MCoordinator attribute) metrix.coordinator module metrix.element module metrix.sinks module metrix.stream module

module metrix.coordinator metrix.element metrix.sinks metrix.stream msg_fmt_str (metrix.sinks.MSinkLogger attribute) MSink (class in metrix.sinks) MSinkLogger (class in metrix.sinks) MSinkPrinter (class in metrix.sinks) msinks (metrix.coordinator.MCoordinator attribute) MSinkTSDB (class in metrix.sinks) MStream (class in metrix.stream)

N

name (metrix.stream.MStream attribute)

S

send() (metrix.coordinator.MCoordinator method) (metrix.stream.MStream method)

source (metrix.stream.MStream attribute) stream (metrix.coordinator.MCoordinator attribute) (metrix.stream.MStream attribute)

T

tags_from_key() (in module metrix.element) timer() (metrix.coordinator.MCoordinator method) (metrix.stream.MStream method)

tsdb_client (metrix.sinks.MSinkTSDB attribute)

W

window_size (metrix.stream.MStream attribute)