Function enqueuePendingProcessStep

api/controller/relay/relay_stream_event.go:172–182

(c *gin.Context, requestID string, step ProcessStep)

}

func enqueuePendingProcessStep(c *gin.Context, requestID string, step ProcessStep) {
	if c == nil {
		return
	}
	steps := getPendingProcessSteps(c)
	steps = append(steps, pendingProcessStep{
		RequestID: requestID,
		Step:      step,
	})
	c.Set(ctxKeyPendingProcessSteps, steps)
}

func flushPendingProcessSteps(c *gin.Context) error {
	if c == nil {