mocks

Documentation

Index

• type Config
  • func NewConfig(t interface{ ... }) *Config
  • func (_m *Config) DefaultHTTPLimit() int64
  • func (_m *Config) DefaultHTTPTimeout() models.Duration
  • func (_m *Config) MaxRunDuration() time.Duration
  • func (_m *Config) ReaperInterval() time.Duration
  • func (_m *Config) ReaperThreshold() time.Duration
• type ORM
  • func NewORM(t interface{ ... }) *ORM
  • func (_m *ORM) Close() error
  • func (_m *ORM) CreateRun(run *pipeline.Run, qopts ...pg.QOpt) error
  • func (_m *ORM) CreateSpec(_a0 pipeline.Pipeline, maxTaskTimeout models.Interval, qopts ...pg.QOpt) (int32, error)
  • func (_m *ORM) DeleteRun(id int64) error
  • func (_m *ORM) DeleteRunsOlderThan(_a0 context.Context, _a1 time.Duration) error
  • func (_m *ORM) FindRun(id int64) (pipeline.Run, error)
  • func (_m *ORM) GetAllRuns() ([]pipeline.Run, error)
  • func (_m *ORM) GetQ() pg.Q
  • func (_m *ORM) GetUnfinishedRuns(_a0 context.Context, _a1 time.Time, _a2 func(pipeline.Run) error) error
  • func (_m *ORM) HealthReport() map[string]error
  • func (_m *ORM) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error
  • func (_m *ORM) InsertFinishedRuns(run []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error
  • func (_m *ORM) InsertRun(run *pipeline.Run, qopts ...pg.QOpt) error
  • func (_m *ORM) Name() string
  • func (_m *ORM) Ready() error
  • func (_m *ORM) Start(_a0 context.Context) error
  • func (_m *ORM) StoreRun(run *pipeline.Run, qopts ...pg.QOpt) (bool, error)
  • func (_m *ORM) UpdateTaskRunResult(taskID uuid.UUID, result pipeline.Result) (pipeline.Run, bool, error)
• type PipelineParamUnmarshaler
  • func NewPipelineParamUnmarshaler(t interface{ ... }) *PipelineParamUnmarshaler
  • func (_m *PipelineParamUnmarshaler) UnmarshalPipelineParam(val interface{}) error
• type Runner
  • func NewRunner(t interface{ ... }) *Runner
  • func (_m *Runner) Close() error
  • func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger, ...) (int64, pipeline.FinalResult, error)
  • func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (*pipeline.Run, pipeline.TaskRunResults, error)
  • func (_m *Runner) HealthReport() map[string]error
  • func (_m *Runner) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error
  • func (_m *Runner) InsertFinishedRuns(runs []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error
  • func (_m *Runner) Name() string
  • func (_m *Runner) OnRunFinished(_a0 func(*pipeline.Run))
  • func (_m *Runner) Ready() error
  • func (_m *Runner) ResumeRun(taskID uuid.UUID, value interface{}, err error) error
  • func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, l logger.Logger, ...) (bool, error)
  • func (_m *Runner) Start(_a0 context.Context) error

Types

type Config

type Config struct {
	mock.Mock
}

Config is an autogenerated mock type for the Config type

func NewConfig

func NewConfig(t interface {
	mock.TestingT
	Cleanup(func())
}) *Config

NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Config) DefaultHTTPLimit

func (_m *Config) DefaultHTTPLimit() int64

DefaultHTTPLimit provides a mock function with given fields:

func (*Config) DefaultHTTPTimeout

func (_m *Config) DefaultHTTPTimeout() models.Duration

DefaultHTTPTimeout provides a mock function with given fields:

func (*Config) MaxRunDuration

func (_m *Config) MaxRunDuration() time.Duration

MaxRunDuration provides a mock function with given fields:

func (*Config) ReaperInterval

func (_m *Config) ReaperInterval() time.Duration

ReaperInterval provides a mock function with given fields:

func (*Config) ReaperThreshold

func (_m *Config) ReaperThreshold() time.Duration

ReaperThreshold provides a mock function with given fields:

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *ORM

NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ORM) Close

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CreateRun

func (_m *ORM) CreateRun(run *pipeline.Run, qopts ...pg.QOpt) error

CreateRun provides a mock function with given fields: run, qopts

func (*ORM) CreateSpec

func (_m *ORM) CreateSpec(_a0 pipeline.Pipeline, maxTaskTimeout models.Interval, qopts ...pg.QOpt) (int32, error)

CreateSpec provides a mock function with given fields: _a0, maxTaskTimeout, qopts

func (*ORM) DeleteRun

func (_m *ORM) DeleteRun(id int64) error

DeleteRun provides a mock function with given fields: id

func (*ORM) DeleteRunsOlderThan

func (_m *ORM) DeleteRunsOlderThan(_a0 context.Context, _a1 time.Duration) error

DeleteRunsOlderThan provides a mock function with given fields: _a0, _a1

func (*ORM) FindRun

func (_m *ORM) FindRun(id int64) (pipeline.Run, error)

FindRun provides a mock function with given fields: id

func (*ORM) GetAllRuns

func (_m *ORM) GetAllRuns() ([]pipeline.Run, error)

GetAllRuns provides a mock function with given fields:

func (*ORM) GetQ

func (_m *ORM) GetQ() pg.Q

GetQ provides a mock function with given fields:

func (*ORM) GetUnfinishedRuns

func (_m *ORM) GetUnfinishedRuns(_a0 context.Context, _a1 time.Time, _a2 func(pipeline.Run) error) error

GetUnfinishedRuns provides a mock function with given fields: _a0, _a1, _a2

func (*ORM) HealthReport

func (_m *ORM) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*ORM) InsertFinishedRun

func (_m *ORM) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRun provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*ORM) InsertFinishedRuns

func (_m *ORM) InsertFinishedRuns(run []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRuns provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*ORM) InsertRun

func (_m *ORM) InsertRun(run *pipeline.Run, qopts ...pg.QOpt) error

InsertRun provides a mock function with given fields: run, qopts

func (*ORM) Name

func (_m *ORM) Name() string

Name provides a mock function with given fields:

func (*ORM) Ready

func (_m *ORM) Ready() error

Ready provides a mock function with given fields:

func (*ORM) Start

func (_m *ORM) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*ORM) StoreRun

func (_m *ORM) StoreRun(run *pipeline.Run, qopts ...pg.QOpt) (bool, error)

StoreRun provides a mock function with given fields: run, qopts

func (*ORM) UpdateTaskRunResult

func (_m *ORM) UpdateTaskRunResult(taskID uuid.UUID, result pipeline.Result) (pipeline.Run, bool, error)

UpdateTaskRunResult provides a mock function with given fields: taskID, result

type PipelineParamUnmarshaler

type PipelineParamUnmarshaler struct {
	mock.Mock
}

PipelineParamUnmarshaler is an autogenerated mock type for the PipelineParamUnmarshaler type

func NewPipelineParamUnmarshaler

func NewPipelineParamUnmarshaler(t interface {
	mock.TestingT
	Cleanup(func())
}) *PipelineParamUnmarshaler

NewPipelineParamUnmarshaler creates a new instance of PipelineParamUnmarshaler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PipelineParamUnmarshaler) UnmarshalPipelineParam

func (_m *PipelineParamUnmarshaler) UnmarshalPipelineParam(val interface{}) error

UnmarshalPipelineParam provides a mock function with given fields: val

type Runner

type Runner struct {
	mock.Mock
}

Runner is an autogenerated mock type for the Runner type

func NewRunner

func NewRunner(t interface {
	mock.TestingT
	Cleanup(func())
}) *Runner

NewRunner creates a new instance of Runner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Runner) Close

func (_m *Runner) Close() error

Close provides a mock function with given fields:

func (*Runner) ExecuteAndInsertFinishedRun

func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger, saveSuccessfulTaskRuns bool) (int64, pipeline.FinalResult, error)

ExecuteAndInsertFinishedRun provides a mock function with given fields: ctx, spec, vars, l, saveSuccessfulTaskRuns

func (*Runner) ExecuteRun

func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (*pipeline.Run, pipeline.TaskRunResults, error)

ExecuteRun provides a mock function with given fields: ctx, spec, vars, l

func (*Runner) HealthReport

func (_m *Runner) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*Runner) InsertFinishedRun

func (_m *Runner) InsertFinishedRun(run *pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRun provides a mock function with given fields: run, saveSuccessfulTaskRuns, qopts

func (*Runner) InsertFinishedRuns

func (_m *Runner) InsertFinishedRuns(runs []*pipeline.Run, saveSuccessfulTaskRuns bool, qopts ...pg.QOpt) error

InsertFinishedRuns provides a mock function with given fields: runs, saveSuccessfulTaskRuns, qopts

func (*Runner) Name

func (_m *Runner) Name() string

Name provides a mock function with given fields:

func (*Runner) OnRunFinished

func (_m *Runner) OnRunFinished(_a0 func(*pipeline.Run))

OnRunFinished provides a mock function with given fields: _a0

func (*Runner) Ready

func (_m *Runner) Ready() error

Ready provides a mock function with given fields:

func (*Runner) ResumeRun

func (_m *Runner) ResumeRun(taskID uuid.UUID, value interface{}, err error) error

ResumeRun provides a mock function with given fields: taskID, value, err

func (*Runner) Run

func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, l logger.Logger, saveSuccessfulTaskRuns bool, fn func(pg.Queryer) error) (bool, error)

Run provides a mock function with given fields: ctx, run, l, saveSuccessfulTaskRuns, fn

func (*Runner) Start

func (_m *Runner) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0