|
|
@ -18,6 +18,7 @@ import (
|
|
|
|
"golang.org/x/sync/semaphore"
|
|
|
|
"golang.org/x/sync/semaphore"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Execer executes the pipeline.
|
|
|
|
type Execer struct {
|
|
|
|
type Execer struct {
|
|
|
|
mu sync.Mutex
|
|
|
|
mu sync.Mutex
|
|
|
|
engine Engine
|
|
|
|
engine Engine
|
|
|
@ -26,7 +27,7 @@ type Execer struct {
|
|
|
|
sem *semaphore.Weighted
|
|
|
|
sem *semaphore.Weighted
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// NewExecer returns a new execer used
|
|
|
|
// NewExecer returns a new execer.
|
|
|
|
func NewExecer(
|
|
|
|
func NewExecer(
|
|
|
|
reporter pipeline.Reporter,
|
|
|
|
reporter pipeline.Reporter,
|
|
|
|
streamer pipeline.Streamer,
|
|
|
|
streamer pipeline.Streamer,
|
|
|
|