app

Documentation

Index

• func MakeCmdRun(pLogger **zap.Logger, pDebug *bool) *cobra.Command
• type Job
  • func NewJob(logger *zap.Logger, fs afero.Fs, entry string, concurrency int, ...) (*Job, error)
  • func (j *Job) Close()
  • func (j *Job) Run(shouldStop func() bool)
  • func (j *Job) RunAmount(amount int64)
  • func (j *Job) RunDuration(duration time.Duration)

Functions

func MakeCmdRun

func MakeCmdRun(
	pLogger **zap.Logger,
	pDebug *bool,
) *cobra.Command

Types

type Job

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

func NewJob

func NewJob(
	logger *zap.Logger,
	fs afero.Fs,
	entry string,
	concurrency int,
	envs map[string]string,
	newFS func() afero.Fs,
	reporter stat.Reporter,
) (*Job, error)

func (*Job) Close

func (j *Job) Close()

func (*Job) Run

func (j *Job) Run(shouldStop func() bool)

func (*Job) RunAmount

func (j *Job) RunAmount(amount int64)

func (*Job) RunDuration

func (j *Job) RunDuration(duration time.Duration)