flow_replay

type Config struct {
	QueueField   param.ParaKey `config:"queue_name_field"`
	MessageField param.ParaKey `config:"message_field"`

	MessageIncludeResponse         bool   `config:"message_include_response"`
	KeepTags                       bool   `config:"keep_tags"`
	FlowName                       string `config:"flow"`
	FlowMaxRunningTimeoutInSeconds int    `config:"flow_max_running_timeout_in_second"`
	CommitOnTag                    string `config:"commit_on_tag"`
	IdleWaitTimeoutInSeconds       int    `config:"idle_wait_timeout_in_second"`
}

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