idou老师教你学istio 31:Istio-proxy的report流程
Istio-proxy的report主要是将envoy采集到的连接attributes的信息上报给控制面的mixer,它的入口在request_handler_impl.cc文件中,这里需要打开enable_mixer_report开关,提取出report_data中的attribute信息,调用SendReport发送出去。
SendReport的实现在client_context_base.cc中,跳转到client_impl中。
client_impl.cc跳转到report_batch中。
report_batch.cc中会在batch_compresser中添加attributes作为向mixer发起的请求report,这里的Add是一个bool,判断是否所有的上次请求所用的attributes都在本次的report的请求中。
attribute_compressor.cc中定义了Add的方法,利用CompressByDict更新压缩过的attributes &pb,如果在这一步压缩的变量全部都在,那么compressbydict的返回值是true,会更新pb。如果有的attributes的变量不存在,那么返回值为false,不更新pb,回到上一张图。
Compress是否成功在下图的函数中判断,这里用到的是delta_update,在delta_update.cc中,也就是增量更新:
具体是最先Start(),这里会设置set变量prev_set_,将之前一次report的map中的index存入,然后调用Check,利用MessageDifferencer::Equals比较同一个index的值是否更新,如果更新就会刷新prev_map_中index对应的value。如果是新的index,那么会作为一个新的元素插入prev_map_,每次执行一次index的比较,就会删去prev_set_中当前的index值,直到执行完成所有的当前上报的attributes的index:
对于index的对应的value有更新,或者新的index的情况,Check返回false,会根据对应的值的属性添加到对应的map中,更新pb的值。
当所有的attributes都for循环完成之后,这个函数会返回delta_update.Finish(),也就是prev_set_中的index是否全部存在。如果全部存在都会被erase掉,此时set为空,返回true,证明CompressByDict完成。如果有值没有上报,那么返回值为false。
现在我们会回到report_batch.cc中,现在request已经压缩完成如果Add值为true,这时会判断compressor的尺寸是否大于等于预设的batch的大小,或是否超过了上报的max_batch_time,如果两者其中一个满足条件,就会调用FlushWithLock()像mixer发送report。
如果add的值为false,那么会将这条request之前的已经压缩好的信息调用FlushWithLock()先发送出去,然后再执行一遍Add操作,本次的request会在下一次report中发送出去。
max_batch_entries和max_batch_time_ms的默认值在options.h中,分别为1000条和1000ms。
在FlushWithLock中:
attribute_compressor.cc中用Finish()把dictionary中的message_words_添加上。
需要report的信息完整之后,reset_compressor,调用transport_把report的request发送给mixer,并且删除response。
如果发送的信息状态!ok,返回ERROR提示"Mixer Report failed with: ",并且将GlobalDictionary()重置大小。
相关服务请访问:https://support.huaweicloud.com/cce/index.html?utm_content=cce_helpcenter_2019
- 点赞
- 收藏
- 关注作者
评论(0)