datapoint1
Listen (UDP-messagepack)
Worker 1
MAX_RESOLUTION
thread
chunk
metric name 2
datapoint2
...
循环创建进程
(timeseries) List
... ...
ROOMBA_PROCESSES
Worker 2
process
add metric name
Set
run algorithms
metric name
FULL_NAMESPACE
Queue
+ ${metric name 1}：
Horizon
fetch timeseries
过滤timeseries：MIN_TOLERABLE_LENGTHSTALE_PERIODFULL_DURATIONMAX_TOLERABLE_BOREDOM算法相关：CONSENSUSALGORITHMS
tuples
判断anomalous的9个算法
datasource
chunk满时enqueue
enqueue datapoint[Messagepack]
Redis
send E-mail
Roomba和Analyzer spawn的进程在退出时会判断是否运行时间太短了，如果太短就sleep 10s，防止频繁创建和销毁进程所带来的性能消耗。
dump JSONP for webapp
MAX_QUEUE_SIZE
Analyzer
tuple
WORKER_PROCESSES
+ ${metric name 2}：
metric name 1
FULL_DURATIONMINI_DURATIONROOMBA_GRACE_TIME
CHUNK_SIZE
timestamp
dequeue chunk
Listen (TCP-pickle)
Algorithms
trim or purge(divide & conquer)
chunk2
ANALYZER_PROCESSES
udp protocol
+ 'unique_metrics'：
value
MINI_NAMESPACE
tcp protocol
chunk1
datapoint (array)
Roomba
