flow_runner

type Config struct {
	FlowName                       string `config:"flow"`
	InputQueue                     string `config:"input_queue"`
	FlowMaxRunningTimeoutInSeconds int    `config:"flow_max_running_timeout_in_second"`
	CommitTimeoutInSeconds         int    `config:"commit_timeout_in_second"`

	SkipEmptyQueue bool `config:"skip_empty_queue"`

	CommitOnTag              string `config:"commit_on_tag"`
	IdleWaitTimeoutInSeconds int    `config:"idle_wait_timeout_in_second"`

	Consumer queue.ConsumerConfig `config:"consumer"`
}

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