(flowName string)
| 152 | } |
| 153 | |
| 154 | func getWorkflowID(flowName string) string { |
| 155 | return flowName + "-peerflow" |
| 156 | } |
| 157 | |
| 158 | func (h *FlowRequestHandler) CreateCDCFlow( |
| 159 | ctx context.Context, req *protos.CreateCDCFlowRequest, |
no outgoing calls
no test coverage detected