loadbalanced

type NewReq struct {
	Logger       logr.Logger
	PipelineName string
	StepName     string
	SourceName   string
	SourceURN    string
	LeadReplica  bool
	Concurrency  int
	PollPeriod   time.Duration
	Process      source.Process
	RemoveItem   func(item interface{}) error
	ListItems    func() ([]interface{}, error)
}