runner

Documentation

Index

• func NewCommandRunner(filter *Filter, sh shell.Shell, handler RepoHandler) func(cmd *cobra.Command, args []string) error
• func NewCommandRunnerForExistingRepos(filter *Filter, sh shell.Shell, handler RepoHandler) func(cmd *cobra.Command, args []string) error
• func ParseNegated(value string) (bool, string)
• type Filter
  • func (f *Filter) AddCommandFlags(command *cobra.Command)
  • func (f *Filter) FilterMatchingRepos(repos []settings.Repo, groups []settings.Group) []settings.Repo
  • func (f *Filter) MatchesRepo(repo settings.Repo, groups []settings.Group) bool
• type ParallelRunner
  • func (r *ParallelRunner) Run(ctx context.Context, repos []settings.Repo, handler RepoHandler) (map[string]ProcessResult, error)
• type ProcessResult
• type Progress
  • func NewProgress(conf *config.Config, maxCount int) Progress
• type ProgressBarProgress
  • func (p *ProgressBarProgress) IncrErrors()
  • func (p *ProgressBarProgress) IncrProgress()
  • func (p *ProgressBarProgress) IndicateTermination()
• type RepoHandler
• type RunContext
• type Runner
  • func NewRunner(conf *config.Config, sh shell.Shell, filter *Filter, progress Progress, ...) (Runner, error)
• type SequentialRunner
  • func (r *SequentialRunner) Run(ctx context.Context, repos []settings.Repo, handler RepoHandler) (map[string]ProcessResult, error)

Functions

func NewCommandRunner

func NewCommandRunner(filter *Filter, sh shell.Shell, handler RepoHandler) func(
	cmd *cobra.Command,
	args []string,
) error

func NewCommandRunnerForExistingRepos

func NewCommandRunnerForExistingRepos(filter *Filter, sh shell.Shell, handler RepoHandler) func(
	cmd *cobra.Command,
	args []string,
) error

func ParseNegated

func ParseNegated(value string) (bool, string)

ParseNegated gets a string value and analyzes if it is negated or not - effectively, if it starts with a prefix or not.

It returns a bool flag and a clean value, without the prefix even for negated value

Types

type Filter

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

func (*Filter) AddCommandFlags

func (f *Filter) AddCommandFlags(command *cobra.Command)

func (*Filter) FilterMatchingRepos

func (f *Filter) FilterMatchingRepos(repos []settings.Repo, groups []settings.Group) []settings.Repo

func (*Filter) MatchesRepo

func (f *Filter) MatchesRepo(repo settings.Repo, groups []settings.Group) bool

type ParallelRunner

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

func (*ParallelRunner) Run

func (r *ParallelRunner) Run(
	ctx context.Context, repos []settings.Repo, handler RepoHandler,
) (map[string]ProcessResult, error)

type ProcessResult

type ProcessResult struct {
	Result interface{}
	Error  error
}

type Progress

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()
}

func NewProgress

func NewProgress(conf *config.Config, maxCount int) Progress

type ProgressBarProgress

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

func (*ProgressBarProgress) IncrErrors

func (p *ProgressBarProgress) IncrErrors()

func (*ProgressBarProgress) IncrProgress

func (p *ProgressBarProgress) IncrProgress()

func (*ProgressBarProgress) IndicateTermination

func (p *ProgressBarProgress) IndicateTermination()

type RepoHandler

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

type RunContext

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

type Runner

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

func NewRunner

func NewRunner(conf *config.Config, sh shell.Shell, filter *Filter, progress Progress, args []string) (Runner, error)

type SequentialRunner

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

func (*SequentialRunner) Run

func (r *SequentialRunner) Run(
	ctx context.Context, repos []settings.Repo, handler RepoHandler,
) (map[string]ProcessResult, error)