processor

type Control interface {
	Start(*config.Configuration) (*ExecutionID, error)
	Stop(*ExecutionID) statistics.AggregatorSnapShot
	Status(*ExecutionID) statistics.AggregatorSnapShot
	History() []*ExecutionID
	Events() <-chan string
}

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

type ExecutionBranch interface {
	Execute() error
}

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

type Host interface {
	SetControl(*Control)
}

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

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

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

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

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

type JobStream interface {
	HasNext() bool
	Next() core.Job
	Reset()
	Progress() int
	Size() int
}

type ListRingRevolver struct {
	Lists map[string]ListStream
}

type ListStream interface {
	HasNext() bool
	Next() map[string]interface{}
	Reset()
	Size() int
}

type PlanExecutionContext struct {
	Plan         core.Plan
	Lists        *ListRingRevolver
	Config       *config.Configuration
	Publisher    chan core.ExecutionResult
	PlanContext  core.ExtractionResult
	JobContexts  map[int]core.ExtractionResult
	StepContexts map[int]map[int]core.ExtractionResult
	Bar          ProgressBar
	// contains filtered or unexported fields
}

type PlanExecutor struct {
	Config *config.Configuration
	Bar    ProgressBar

	Publisher    chan core.ExecutionResult
	Lists        *ListRingRevolver
	Plan         core.Plan
	PlanContext  core.ExtractionResult
	JobContexts  map[int]core.ExtractionResult
	StepContexts map[int]map[int]core.ExtractionResult
	// contains filtered or unexported fields
}

type ProgressBar interface {
	Set(progress int) error
}

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

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

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

type StepStream interface {
	HasNext() bool
	Next() core.Step
	Reset()
	Progress() int
	Size() int
}