fast_flow_runner

type Config struct {
	FlowName                       string               `config:"flow"`
	InputQueue                     string               `config:"input_queue"`
	NumOfWorkers                   int                  `config:"worker_size"`
	FlowMaxRunningTimeoutInSeconds int                  `config:"flow_max_running_timeout_in_second"`
	Consumer                       queue.ConsumerConfig `config:"consumer"`
}

type FlowRunnerProcessor struct {
	// contains filtered or unexported fields
}