Method WriteFlow

library/cpp/chromium_trace/yson.cpp:138–156

}

void TYsonTraceConsumer::WriteFlow(const TEventFlow& flow) {
    if (flow.Type == EFlowType::None) {
        return;
    }

    if (flow.Type == EFlowType::Producer || flow.Type == EFlowType::Step) {
        Yson.OnKeyedItem(TStringBuf("flow_out"));
        Yson.OnBooleanScalar(true);
    }

    if (flow.Type == EFlowType::Consumer || flow.Type == EFlowType::Step) {
        Yson.OnKeyedItem(TStringBuf("flow_in"));
        Yson.OnBooleanScalar(true);
    }

    TString bindId = TStringBuilder() << JobId << "::" << flow.BindId;
    Yson.OnKeyedItem(TStringBuf("bind_id"));
    Yson.OnStringScalar(bindId);
}