runner

type Filter struct {
	Names  []string
	Tags   []string
	Groups []string
}

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

type ProcessResult struct {
	Result interface{}
	Error  error
}

type Progress interface {
	// IncrProgress increase current progress with 1
	IncrProgress()
	// IncrErrors increments number of errors happened during the process
	IncrErrors()
	// IndicateTermination makes progress indicate that bulker received "SIGINT" and terminates gracefully
	IndicateTermination()
}

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

type RepoHandler func(ctx context.Context, runContext *RunContext) (interface{}, error)

type RunContext struct {
	Manager *settings.Manager
	Config  *config.Config
	Repo    *model.Repo
	Args    []string
}

type Runner interface {
	Run(ctx context.Context, repos []settings.Repo, handler RepoHandler) (map[string]ProcessResult, error)
}

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