# Functions
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
ResolverHandler 完成所有 snapshot 的重排序和处理工作, resolver 保证处理是串行的,handler 无需考虑并发问题, 以 data package 为单位进行重排序, 以 snapshot pair 为单位进行处理, 处理结果写入 collector。 - dp 间,根据 day 和 seq 排序(http 和 rpc 乱序,通过 map 维护滑动窗口解决); - dp 内,根据 timestamp 排序(logger 本身乱序,通过 sort 解决); - dp 间,根据 timestamp 排序,两两组装 dp(logger 本身乱序,且乱序之处恰好处于两个 dp 间,通过 skiplist 解决); - 流式读取 snapshot,组装成对; - 处理每一对 snapshot,异步写入 collector;.
No description provided by the author
No description provided by the author
No description provided by the author
# Interfaces
ResolverHandler 完成所有 snapshot 的重排序和处理工作, resolver 保证处理是串行的,handler 无需考虑并发问题, 以 data package 为单位进行重排序, 以 snapshot pair 为单位进行处理, 处理结果写入 collector。 - dp 间,根据 day 和 seq 排序(http 和 rpc 乱序,通过 map 维护滑动窗口解决); - dp 内,根据 timestamp 排序(logger 本身乱序,通过 sort 解决); - dp 间,根据 timestamp 排序,两两组装 dp(logger 本身乱序,且乱序之处恰好处于两个 dp 间,通过 skiplist 解决); - 流式读取 snapshot,组装成对; - 处理每一对 snapshot,异步写入 collector;.