pipeline

type API struct {
	api.Handler
}

type PipeModule struct {
}

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

type PipeRunnerConfig struct {
	Name string `json:"name,omitempty" config:"name"`

	Enabled bool `json:"enabled,omitempty" config:"enabled"`

	MaxGoRoutine int `config:"max_go_routine"`

	//Speed Control
	ThresholdInMs int `config:"threshold_in_ms"`

	//Timeout Control
	TimeoutInMs int `config:"timeout_in_ms"`

	PipelineID string `config:"pipeline_id"`

	InputQueue string `config:"input_queue"`

	Schedule string `config:"schedule"`
	// contains filtered or unexported fields
}