| 118 | } |
| 119 | |
| 120 | void TJsonTraceConsumer::WriteFlow(const TEventFlow& flow) { |
| 121 | if (flow.Type == EFlowType::None) { |
| 122 | return; |
| 123 | } |
| 124 | |
| 125 | if (flow.Type == EFlowType::Producer || flow.Type == EFlowType::Step) { |
| 126 | Json.WriteKey(TStringBuf("flow_out")).WriteBool(true); |
| 127 | } |
| 128 | |
| 129 | if (flow.Type == EFlowType::Consumer || flow.Type == EFlowType::Step) { |
| 130 | Json.WriteKey(TStringBuf("flow_in")).WriteBool(true); |
| 131 | } |
| 132 | |
| 133 | Json.WriteKey(TStringBuf("bind_id")).WriteULongLong(flow.BindId); |
| 134 | } |
nothing calls this directly
no test coverage detected