mocks

package
v2.15.0-beta0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 29, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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() config.Duration

DefaultHTTPTimeout provides a mock function with given fields:

func (*Config) EXPECT added in v2.15.0 

func (_m *Config) EXPECT() *Config_Expecter

func (*Config) MaxRunDuration added in v2.3.0 

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

MaxRunDuration provides a mock function with given fields:

func (*Config) ReaperInterval added in v2.3.0 

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

ReaperInterval provides a mock function with given fields:

func (*Config) ReaperThreshold added in v2.3.0 

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

ReaperThreshold provides a mock function with given fields:

func (*Config) VerboseLogging added in v2.11.0 

func (_m *Config) VerboseLogging() bool

VerboseLogging provides a mock function with given fields:

type Config_DefaultHTTPLimit_Call added in v2.15.0 

type Config_DefaultHTTPLimit_Call struct {
	*mock.Call
}

Config_DefaultHTTPLimit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefaultHTTPLimit'

func (*Config_DefaultHTTPLimit_Call) Return added in v2.15.0 

func (_c *Config_DefaultHTTPLimit_Call) Return(_a0 int64) *Config_DefaultHTTPLimit_Call

func (*Config_DefaultHTTPLimit_Call) Run added in v2.15.0 

func (_c *Config_DefaultHTTPLimit_Call) Run(run func()) *Config_DefaultHTTPLimit_Call

func (*Config_DefaultHTTPLimit_Call) RunAndReturn added in v2.15.0 

func (_c *Config_DefaultHTTPLimit_Call) RunAndReturn(run func() int64) *Config_DefaultHTTPLimit_Call

type Config_DefaultHTTPTimeout_Call added in v2.15.0 

type Config_DefaultHTTPTimeout_Call struct {
	*mock.Call
}

Config_DefaultHTTPTimeout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefaultHTTPTimeout'

func (*Config_DefaultHTTPTimeout_Call) Return added in v2.15.0 

func (_c *Config_DefaultHTTPTimeout_Call) Return(_a0 config.Duration) *Config_DefaultHTTPTimeout_Call

func (*Config_DefaultHTTPTimeout_Call) Run added in v2.15.0 

func (_c *Config_DefaultHTTPTimeout_Call) Run(run func()) *Config_DefaultHTTPTimeout_Call

func (*Config_DefaultHTTPTimeout_Call) RunAndReturn added in v2.15.0 

func (_c *Config_DefaultHTTPTimeout_Call) RunAndReturn(run func() config.Duration) *Config_DefaultHTTPTimeout_Call

type Config_Expecter added in v2.15.0 

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

func (*Config_Expecter) DefaultHTTPLimit added in v2.15.0 

func (_e *Config_Expecter) DefaultHTTPLimit() *Config_DefaultHTTPLimit_Call

DefaultHTTPLimit is a helper method to define mock.On call

func (*Config_Expecter) DefaultHTTPTimeout added in v2.15.0 

func (_e *Config_Expecter) DefaultHTTPTimeout() *Config_DefaultHTTPTimeout_Call

DefaultHTTPTimeout is a helper method to define mock.On call

func (*Config_Expecter) MaxRunDuration added in v2.15.0 

func (_e *Config_Expecter) MaxRunDuration() *Config_MaxRunDuration_Call

MaxRunDuration is a helper method to define mock.On call

func (*Config_Expecter) ReaperInterval added in v2.15.0 

func (_e *Config_Expecter) ReaperInterval() *Config_ReaperInterval_Call

ReaperInterval is a helper method to define mock.On call

func (*Config_Expecter) ReaperThreshold added in v2.15.0 

func (_e *Config_Expecter) ReaperThreshold() *Config_ReaperThreshold_Call

ReaperThreshold is a helper method to define mock.On call

func (*Config_Expecter) VerboseLogging added in v2.15.0 

func (_e *Config_Expecter) VerboseLogging() *Config_VerboseLogging_Call

VerboseLogging is a helper method to define mock.On call

type Config_MaxRunDuration_Call added in v2.15.0 

type Config_MaxRunDuration_Call struct {
	*mock.Call
}

Config_MaxRunDuration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MaxRunDuration'

func (*Config_MaxRunDuration_Call) Return added in v2.15.0 

func (_c *Config_MaxRunDuration_Call) Return(_a0 time.Duration) *Config_MaxRunDuration_Call

func (*Config_MaxRunDuration_Call) Run added in v2.15.0 

func (_c *Config_MaxRunDuration_Call) Run(run func()) *Config_MaxRunDuration_Call

func (*Config_MaxRunDuration_Call) RunAndReturn added in v2.15.0 

func (_c *Config_MaxRunDuration_Call) RunAndReturn(run func() time.Duration) *Config_MaxRunDuration_Call

type Config_ReaperInterval_Call added in v2.15.0 

type Config_ReaperInterval_Call struct {
	*mock.Call
}

Config_ReaperInterval_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReaperInterval'

func (*Config_ReaperInterval_Call) Return added in v2.15.0 

func (_c *Config_ReaperInterval_Call) Return(_a0 time.Duration) *Config_ReaperInterval_Call

func (*Config_ReaperInterval_Call) Run added in v2.15.0 

func (_c *Config_ReaperInterval_Call) Run(run func()) *Config_ReaperInterval_Call

func (*Config_ReaperInterval_Call) RunAndReturn added in v2.15.0 

func (_c *Config_ReaperInterval_Call) RunAndReturn(run func() time.Duration) *Config_ReaperInterval_Call

type Config_ReaperThreshold_Call added in v2.15.0 

type Config_ReaperThreshold_Call struct {
	*mock.Call
}

Config_ReaperThreshold_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReaperThreshold'

func (*Config_ReaperThreshold_Call) Return added in v2.15.0 

func (_c *Config_ReaperThreshold_Call) Return(_a0 time.Duration) *Config_ReaperThreshold_Call

func (*Config_ReaperThreshold_Call) Run added in v2.15.0 

func (_c *Config_ReaperThreshold_Call) Run(run func()) *Config_ReaperThreshold_Call

func (*Config_ReaperThreshold_Call) RunAndReturn added in v2.15.0 

func (_c *Config_ReaperThreshold_Call) RunAndReturn(run func() time.Duration) *Config_ReaperThreshold_Call

type Config_VerboseLogging_Call added in v2.15.0 

type Config_VerboseLogging_Call struct {
	*mock.Call
}

Config_VerboseLogging_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'VerboseLogging'

func (*Config_VerboseLogging_Call) Return added in v2.15.0 

func (_c *Config_VerboseLogging_Call) Return(_a0 bool) *Config_VerboseLogging_Call

func (*Config_VerboseLogging_Call) Run added in v2.15.0 

func (_c *Config_VerboseLogging_Call) Run(run func()) *Config_VerboseLogging_Call

func (*Config_VerboseLogging_Call) RunAndReturn added in v2.15.0 

func (_c *Config_VerboseLogging_Call) RunAndReturn(run func() bool) *Config_VerboseLogging_Call

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(ctx context.Context, run *pipeline.Run) error

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

func (*ORM) CreateSpec 

func (_m *ORM) CreateSpec(ctx context.Context, _a1 pipeline.Pipeline, maxTaskTimeout models.Interval) (int32, error)

CreateSpec provides a mock function with given fields: ctx, _a1, maxTaskTimeout

func (*ORM) DataSource added in v2.12.0 

func (_m *ORM) DataSource() sqlutil.DataSource

DataSource provides a mock function with given fields:

func (*ORM) DeleteRun 

func (_m *ORM) DeleteRun(ctx context.Context, id int64) error

DeleteRun provides a mock function with given fields: ctx, 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) EXPECT added in v2.15.0 

func (_m *ORM) EXPECT() *ORM_Expecter

func (*ORM) FindRun 

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

FindRun provides a mock function with given fields: ctx, id

func (*ORM) GetAllRuns 

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

GetAllRuns provides a mock function with given fields: ctx

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(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool) error

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

func (*ORM) InsertFinishedRunWithSpec added in v2.11.0 

func (_m *ORM) InsertFinishedRunWithSpec(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool) error

InsertFinishedRunWithSpec provides a mock function with given fields: ctx, run, saveSuccessfulTaskRuns

func (*ORM) InsertFinishedRuns 

func (_m *ORM) InsertFinishedRuns(ctx context.Context, run []*pipeline.Run, saveSuccessfulTaskRuns bool) error

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

func (*ORM) InsertRun 

func (_m *ORM) InsertRun(ctx context.Context, run *pipeline.Run) error

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

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(ctx context.Context, run *pipeline.Run) (bool, error)

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

func (*ORM) Transact added in v2.12.0 

func (_m *ORM) Transact(_a0 context.Context, _a1 func(pipeline.ORM) error) error

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

func (*ORM) UpdateTaskRunResult 

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

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

func (*ORM) WithDataSource added in v2.12.0 

func (_m *ORM) WithDataSource(_a0 sqlutil.DataSource) pipeline.ORM

WithDataSource provides a mock function with given fields: _a0

type ORM_Close_Call added in v2.15.0 

type ORM_Close_Call struct {
	*mock.Call
}

ORM_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*ORM_Close_Call) Return added in v2.15.0 

func (_c *ORM_Close_Call) Return(_a0 error) *ORM_Close_Call

func (*ORM_Close_Call) Run added in v2.15.0 

func (_c *ORM_Close_Call) Run(run func()) *ORM_Close_Call

func (*ORM_Close_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_Close_Call) RunAndReturn(run func() error) *ORM_Close_Call

type ORM_CreateRun_Call added in v2.15.0 

type ORM_CreateRun_Call struct {
	*mock.Call
}

ORM_CreateRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateRun'

func (*ORM_CreateRun_Call) Return added in v2.15.0 

func (_c *ORM_CreateRun_Call) Return(err error) *ORM_CreateRun_Call

func (*ORM_CreateRun_Call) Run added in v2.15.0 

func (_c *ORM_CreateRun_Call) Run(run func(ctx context.Context, run *pipeline.Run)) *ORM_CreateRun_Call

func (*ORM_CreateRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_CreateRun_Call) RunAndReturn(run func(context.Context, *pipeline.Run) error) *ORM_CreateRun_Call

type ORM_CreateSpec_Call added in v2.15.0 

type ORM_CreateSpec_Call struct {
	*mock.Call
}

ORM_CreateSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateSpec'

func (*ORM_CreateSpec_Call) Return added in v2.15.0 

func (_c *ORM_CreateSpec_Call) Return(_a0 int32, _a1 error) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) Run added in v2.15.0 

func (_c *ORM_CreateSpec_Call) Run(run func(ctx context.Context, _a1 pipeline.Pipeline, maxTaskTimeout models.Interval)) *ORM_CreateSpec_Call

func (*ORM_CreateSpec_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_CreateSpec_Call) RunAndReturn(run func(context.Context, pipeline.Pipeline, models.Interval) (int32, error)) *ORM_CreateSpec_Call

type ORM_DataSource_Call added in v2.15.0 

type ORM_DataSource_Call struct {
	*mock.Call
}

ORM_DataSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DataSource'

func (*ORM_DataSource_Call) Return added in v2.15.0 

func (_c *ORM_DataSource_Call) Return(_a0 sqlutil.DataSource) *ORM_DataSource_Call

func (*ORM_DataSource_Call) Run added in v2.15.0 

func (_c *ORM_DataSource_Call) Run(run func()) *ORM_DataSource_Call

func (*ORM_DataSource_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_DataSource_Call) RunAndReturn(run func() sqlutil.DataSource) *ORM_DataSource_Call

type ORM_DeleteRun_Call added in v2.15.0 

type ORM_DeleteRun_Call struct {
	*mock.Call
}

ORM_DeleteRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRun'

func (*ORM_DeleteRun_Call) Return added in v2.15.0 

func (_c *ORM_DeleteRun_Call) Return(_a0 error) *ORM_DeleteRun_Call

func (*ORM_DeleteRun_Call) Run added in v2.15.0 

func (_c *ORM_DeleteRun_Call) Run(run func(ctx context.Context, id int64)) *ORM_DeleteRun_Call

func (*ORM_DeleteRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_DeleteRun_Call) RunAndReturn(run func(context.Context, int64) error) *ORM_DeleteRun_Call

type ORM_DeleteRunsOlderThan_Call added in v2.15.0 

type ORM_DeleteRunsOlderThan_Call struct {
	*mock.Call
}

ORM_DeleteRunsOlderThan_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRunsOlderThan'

func (*ORM_DeleteRunsOlderThan_Call) Return added in v2.15.0 

func (_c *ORM_DeleteRunsOlderThan_Call) Return(_a0 error) *ORM_DeleteRunsOlderThan_Call

func (*ORM_DeleteRunsOlderThan_Call) Run added in v2.15.0 

func (_c *ORM_DeleteRunsOlderThan_Call) Run(run func(_a0 context.Context, _a1 time.Duration)) *ORM_DeleteRunsOlderThan_Call

func (*ORM_DeleteRunsOlderThan_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_DeleteRunsOlderThan_Call) RunAndReturn(run func(context.Context, time.Duration) error) *ORM_DeleteRunsOlderThan_Call

type ORM_Expecter added in v2.15.0 

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

func (*ORM_Expecter) Close added in v2.15.0 

func (_e *ORM_Expecter) Close() *ORM_Close_Call

Close is a helper method to define mock.On call

func (*ORM_Expecter) CreateRun added in v2.15.0 

func (_e *ORM_Expecter) CreateRun(ctx interface{}, run interface{}) *ORM_CreateRun_Call

CreateRun is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run

func (*ORM_Expecter) CreateSpec added in v2.15.0 

func (_e *ORM_Expecter) CreateSpec(ctx interface{}, _a1 interface{}, maxTaskTimeout interface{}) *ORM_CreateSpec_Call

CreateSpec is a helper method to define mock.On call

  • ctx context.Context
  • _a1 pipeline.Pipeline
  • maxTaskTimeout models.Interval

func (*ORM_Expecter) DataSource added in v2.15.0 

func (_e *ORM_Expecter) DataSource() *ORM_DataSource_Call

DataSource is a helper method to define mock.On call

func (*ORM_Expecter) DeleteRun added in v2.15.0 

func (_e *ORM_Expecter) DeleteRun(ctx interface{}, id interface{}) *ORM_DeleteRun_Call

DeleteRun is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) DeleteRunsOlderThan added in v2.15.0 

func (_e *ORM_Expecter) DeleteRunsOlderThan(_a0 interface{}, _a1 interface{}) *ORM_DeleteRunsOlderThan_Call

DeleteRunsOlderThan is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 time.Duration

func (*ORM_Expecter) FindRun added in v2.15.0 

func (_e *ORM_Expecter) FindRun(ctx interface{}, id interface{}) *ORM_FindRun_Call

FindRun is a helper method to define mock.On call

  • ctx context.Context
  • id int64

func (*ORM_Expecter) GetAllRuns added in v2.15.0 

func (_e *ORM_Expecter) GetAllRuns(ctx interface{}) *ORM_GetAllRuns_Call

GetAllRuns is a helper method to define mock.On call

  • ctx context.Context

func (*ORM_Expecter) GetUnfinishedRuns added in v2.15.0 

func (_e *ORM_Expecter) GetUnfinishedRuns(_a0 interface{}, _a1 interface{}, _a2 interface{}) *ORM_GetUnfinishedRuns_Call

GetUnfinishedRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 time.Time
  • _a2 func(pipeline.Run) error

func (*ORM_Expecter) HealthReport added in v2.15.0 

func (_e *ORM_Expecter) HealthReport() *ORM_HealthReport_Call

HealthReport is a helper method to define mock.On call

func (*ORM_Expecter) InsertFinishedRun added in v2.15.0 

func (_e *ORM_Expecter) InsertFinishedRun(ctx interface{}, run interface{}, saveSuccessfulTaskRuns interface{}) *ORM_InsertFinishedRun_Call

InsertFinishedRun is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run
  • saveSuccessfulTaskRuns bool

func (*ORM_Expecter) InsertFinishedRunWithSpec added in v2.15.0 

func (_e *ORM_Expecter) InsertFinishedRunWithSpec(ctx interface{}, run interface{}, saveSuccessfulTaskRuns interface{}) *ORM_InsertFinishedRunWithSpec_Call

InsertFinishedRunWithSpec is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run
  • saveSuccessfulTaskRuns bool

func (*ORM_Expecter) InsertFinishedRuns added in v2.15.0 

func (_e *ORM_Expecter) InsertFinishedRuns(ctx interface{}, run interface{}, saveSuccessfulTaskRuns interface{}) *ORM_InsertFinishedRuns_Call

InsertFinishedRuns is a helper method to define mock.On call

  • ctx context.Context
  • run []*pipeline.Run
  • saveSuccessfulTaskRuns bool

func (*ORM_Expecter) InsertRun added in v2.15.0 

func (_e *ORM_Expecter) InsertRun(ctx interface{}, run interface{}) *ORM_InsertRun_Call

InsertRun is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run

func (*ORM_Expecter) Name added in v2.15.0 

func (_e *ORM_Expecter) Name() *ORM_Name_Call

Name is a helper method to define mock.On call

func (*ORM_Expecter) Ready added in v2.15.0 

func (_e *ORM_Expecter) Ready() *ORM_Ready_Call

Ready is a helper method to define mock.On call

func (*ORM_Expecter) Start added in v2.15.0 

func (_e *ORM_Expecter) Start(_a0 interface{}) *ORM_Start_Call

Start is a helper method to define mock.On call

  • _a0 context.Context

func (*ORM_Expecter) StoreRun added in v2.15.0 

func (_e *ORM_Expecter) StoreRun(ctx interface{}, run interface{}) *ORM_StoreRun_Call

StoreRun is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run

func (*ORM_Expecter) Transact added in v2.15.0 

func (_e *ORM_Expecter) Transact(_a0 interface{}, _a1 interface{}) *ORM_Transact_Call

Transact is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 func(pipeline.ORM) error

func (*ORM_Expecter) UpdateTaskRunResult added in v2.15.0 

func (_e *ORM_Expecter) UpdateTaskRunResult(ctx interface{}, taskID interface{}, result interface{}) *ORM_UpdateTaskRunResult_Call

UpdateTaskRunResult is a helper method to define mock.On call

  • ctx context.Context
  • taskID uuid.UUID
  • result pipeline.Result

func (*ORM_Expecter) WithDataSource added in v2.15.0 

func (_e *ORM_Expecter) WithDataSource(_a0 interface{}) *ORM_WithDataSource_Call

WithDataSource is a helper method to define mock.On call

  • _a0 sqlutil.DataSource

type ORM_FindRun_Call added in v2.15.0 

type ORM_FindRun_Call struct {
	*mock.Call
}

ORM_FindRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindRun'

func (*ORM_FindRun_Call) Return added in v2.15.0 

func (_c *ORM_FindRun_Call) Return(_a0 pipeline.Run, _a1 error) *ORM_FindRun_Call

func (*ORM_FindRun_Call) Run added in v2.15.0 

func (_c *ORM_FindRun_Call) Run(run func(ctx context.Context, id int64)) *ORM_FindRun_Call

func (*ORM_FindRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_FindRun_Call) RunAndReturn(run func(context.Context, int64) (pipeline.Run, error)) *ORM_FindRun_Call

type ORM_GetAllRuns_Call added in v2.15.0 

type ORM_GetAllRuns_Call struct {
	*mock.Call
}

ORM_GetAllRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAllRuns'

func (*ORM_GetAllRuns_Call) Return added in v2.15.0 

func (_c *ORM_GetAllRuns_Call) Return(_a0 []pipeline.Run, _a1 error) *ORM_GetAllRuns_Call

func (*ORM_GetAllRuns_Call) Run added in v2.15.0 

func (_c *ORM_GetAllRuns_Call) Run(run func(ctx context.Context)) *ORM_GetAllRuns_Call

func (*ORM_GetAllRuns_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_GetAllRuns_Call) RunAndReturn(run func(context.Context) ([]pipeline.Run, error)) *ORM_GetAllRuns_Call

type ORM_GetUnfinishedRuns_Call added in v2.15.0 

type ORM_GetUnfinishedRuns_Call struct {
	*mock.Call
}

ORM_GetUnfinishedRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUnfinishedRuns'

func (*ORM_GetUnfinishedRuns_Call) Return added in v2.15.0 

func (_c *ORM_GetUnfinishedRuns_Call) Return(_a0 error) *ORM_GetUnfinishedRuns_Call

func (*ORM_GetUnfinishedRuns_Call) Run added in v2.15.0 

func (_c *ORM_GetUnfinishedRuns_Call) Run(run func(_a0 context.Context, _a1 time.Time, _a2 func(pipeline.Run) error)) *ORM_GetUnfinishedRuns_Call

func (*ORM_GetUnfinishedRuns_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_GetUnfinishedRuns_Call) RunAndReturn(run func(context.Context, time.Time, func(pipeline.Run) error) error) *ORM_GetUnfinishedRuns_Call

type ORM_HealthReport_Call added in v2.15.0 

type ORM_HealthReport_Call struct {
	*mock.Call
}

ORM_HealthReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthReport'

func (*ORM_HealthReport_Call) Return added in v2.15.0 

func (_c *ORM_HealthReport_Call) Return(_a0 map[string]error) *ORM_HealthReport_Call

func (*ORM_HealthReport_Call) Run added in v2.15.0 

func (_c *ORM_HealthReport_Call) Run(run func()) *ORM_HealthReport_Call

func (*ORM_HealthReport_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_HealthReport_Call) RunAndReturn(run func() map[string]error) *ORM_HealthReport_Call

type ORM_InsertFinishedRunWithSpec_Call added in v2.15.0 

type ORM_InsertFinishedRunWithSpec_Call struct {
	*mock.Call
}

ORM_InsertFinishedRunWithSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertFinishedRunWithSpec'

func (*ORM_InsertFinishedRunWithSpec_Call) Return added in v2.15.0 

func (_c *ORM_InsertFinishedRunWithSpec_Call) Return(err error) *ORM_InsertFinishedRunWithSpec_Call

func (*ORM_InsertFinishedRunWithSpec_Call) Run added in v2.15.0 

func (_c *ORM_InsertFinishedRunWithSpec_Call) Run(run func(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool)) *ORM_InsertFinishedRunWithSpec_Call

func (*ORM_InsertFinishedRunWithSpec_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_InsertFinishedRunWithSpec_Call) RunAndReturn(run func(context.Context, *pipeline.Run, bool) error) *ORM_InsertFinishedRunWithSpec_Call

type ORM_InsertFinishedRun_Call added in v2.15.0 

type ORM_InsertFinishedRun_Call struct {
	*mock.Call
}

ORM_InsertFinishedRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertFinishedRun'

func (*ORM_InsertFinishedRun_Call) Return added in v2.15.0 

func (_c *ORM_InsertFinishedRun_Call) Return(err error) *ORM_InsertFinishedRun_Call

func (*ORM_InsertFinishedRun_Call) Run added in v2.15.0 

func (_c *ORM_InsertFinishedRun_Call) Run(run func(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool)) *ORM_InsertFinishedRun_Call

func (*ORM_InsertFinishedRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_InsertFinishedRun_Call) RunAndReturn(run func(context.Context, *pipeline.Run, bool) error) *ORM_InsertFinishedRun_Call

type ORM_InsertFinishedRuns_Call added in v2.15.0 

type ORM_InsertFinishedRuns_Call struct {
	*mock.Call
}

ORM_InsertFinishedRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertFinishedRuns'

func (*ORM_InsertFinishedRuns_Call) Return added in v2.15.0 

func (_c *ORM_InsertFinishedRuns_Call) Return(err error) *ORM_InsertFinishedRuns_Call

func (*ORM_InsertFinishedRuns_Call) Run added in v2.15.0 

func (_c *ORM_InsertFinishedRuns_Call) Run(run func(ctx context.Context, run []*pipeline.Run, saveSuccessfulTaskRuns bool)) *ORM_InsertFinishedRuns_Call

func (*ORM_InsertFinishedRuns_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_InsertFinishedRuns_Call) RunAndReturn(run func(context.Context, []*pipeline.Run, bool) error) *ORM_InsertFinishedRuns_Call

type ORM_InsertRun_Call added in v2.15.0 

type ORM_InsertRun_Call struct {
	*mock.Call
}

ORM_InsertRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertRun'

func (*ORM_InsertRun_Call) Return added in v2.15.0 

func (_c *ORM_InsertRun_Call) Return(_a0 error) *ORM_InsertRun_Call

func (*ORM_InsertRun_Call) Run added in v2.15.0 

func (_c *ORM_InsertRun_Call) Run(run func(ctx context.Context, run *pipeline.Run)) *ORM_InsertRun_Call

func (*ORM_InsertRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_InsertRun_Call) RunAndReturn(run func(context.Context, *pipeline.Run) error) *ORM_InsertRun_Call

type ORM_Name_Call added in v2.15.0 

type ORM_Name_Call struct {
	*mock.Call
}

ORM_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*ORM_Name_Call) Return added in v2.15.0 

func (_c *ORM_Name_Call) Return(_a0 string) *ORM_Name_Call

func (*ORM_Name_Call) Run added in v2.15.0 

func (_c *ORM_Name_Call) Run(run func()) *ORM_Name_Call

func (*ORM_Name_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_Name_Call) RunAndReturn(run func() string) *ORM_Name_Call

type ORM_Ready_Call added in v2.15.0 

type ORM_Ready_Call struct {
	*mock.Call
}

ORM_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*ORM_Ready_Call) Return added in v2.15.0 

func (_c *ORM_Ready_Call) Return(_a0 error) *ORM_Ready_Call

func (*ORM_Ready_Call) Run added in v2.15.0 

func (_c *ORM_Ready_Call) Run(run func()) *ORM_Ready_Call

func (*ORM_Ready_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_Ready_Call) RunAndReturn(run func() error) *ORM_Ready_Call

type ORM_Start_Call added in v2.15.0 

type ORM_Start_Call struct {
	*mock.Call
}

ORM_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*ORM_Start_Call) Return added in v2.15.0 

func (_c *ORM_Start_Call) Return(_a0 error) *ORM_Start_Call

func (*ORM_Start_Call) Run added in v2.15.0 

func (_c *ORM_Start_Call) Run(run func(_a0 context.Context)) *ORM_Start_Call

func (*ORM_Start_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_Start_Call) RunAndReturn(run func(context.Context) error) *ORM_Start_Call

type ORM_StoreRun_Call added in v2.15.0 

type ORM_StoreRun_Call struct {
	*mock.Call
}

ORM_StoreRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StoreRun'

func (*ORM_StoreRun_Call) Return added in v2.15.0 

func (_c *ORM_StoreRun_Call) Return(restart bool, err error) *ORM_StoreRun_Call

func (*ORM_StoreRun_Call) Run added in v2.15.0 

func (_c *ORM_StoreRun_Call) Run(run func(ctx context.Context, run *pipeline.Run)) *ORM_StoreRun_Call

func (*ORM_StoreRun_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_StoreRun_Call) RunAndReturn(run func(context.Context, *pipeline.Run) (bool, error)) *ORM_StoreRun_Call

type ORM_Transact_Call added in v2.15.0 

type ORM_Transact_Call struct {
	*mock.Call
}

ORM_Transact_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transact'

func (*ORM_Transact_Call) Return added in v2.15.0 

func (_c *ORM_Transact_Call) Return(_a0 error) *ORM_Transact_Call

func (*ORM_Transact_Call) Run added in v2.15.0 

func (_c *ORM_Transact_Call) Run(run func(_a0 context.Context, _a1 func(pipeline.ORM) error)) *ORM_Transact_Call

func (*ORM_Transact_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_Transact_Call) RunAndReturn(run func(context.Context, func(pipeline.ORM) error) error) *ORM_Transact_Call

type ORM_UpdateTaskRunResult_Call added in v2.15.0 

type ORM_UpdateTaskRunResult_Call struct {
	*mock.Call
}

ORM_UpdateTaskRunResult_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTaskRunResult'

func (*ORM_UpdateTaskRunResult_Call) Return added in v2.15.0 

func (_c *ORM_UpdateTaskRunResult_Call) Return(run pipeline.Run, start bool, err error) *ORM_UpdateTaskRunResult_Call

func (*ORM_UpdateTaskRunResult_Call) Run added in v2.15.0 

func (_c *ORM_UpdateTaskRunResult_Call) Run(run func(ctx context.Context, taskID uuid.UUID, result pipeline.Result)) *ORM_UpdateTaskRunResult_Call

func (*ORM_UpdateTaskRunResult_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_UpdateTaskRunResult_Call) RunAndReturn(run func(context.Context, uuid.UUID, pipeline.Result) (pipeline.Run, bool, error)) *ORM_UpdateTaskRunResult_Call

type ORM_WithDataSource_Call added in v2.15.0 

type ORM_WithDataSource_Call struct {
	*mock.Call
}

ORM_WithDataSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithDataSource'

func (*ORM_WithDataSource_Call) Return added in v2.15.0 

func (_c *ORM_WithDataSource_Call) Return(_a0 pipeline.ORM) *ORM_WithDataSource_Call

func (*ORM_WithDataSource_Call) Run added in v2.15.0 

func (_c *ORM_WithDataSource_Call) Run(run func(_a0 sqlutil.DataSource)) *ORM_WithDataSource_Call

func (*ORM_WithDataSource_Call) RunAndReturn added in v2.15.0 

func (_c *ORM_WithDataSource_Call) RunAndReturn(run func(sqlutil.DataSource) pipeline.ORM) *ORM_WithDataSource_Call

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) EXPECT added in v2.15.0 

func (_m *PipelineParamUnmarshaler) EXPECT() *PipelineParamUnmarshaler_Expecter

func (*PipelineParamUnmarshaler) UnmarshalPipelineParam 

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

UnmarshalPipelineParam provides a mock function with given fields: val

type PipelineParamUnmarshaler_Expecter added in v2.15.0 

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

func (*PipelineParamUnmarshaler_Expecter) UnmarshalPipelineParam added in v2.15.0 

func (_e *PipelineParamUnmarshaler_Expecter) UnmarshalPipelineParam(val interface{}) *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call

UnmarshalPipelineParam is a helper method to define mock.On call

  • val interface{}

type PipelineParamUnmarshaler_UnmarshalPipelineParam_Call added in v2.15.0 

type PipelineParamUnmarshaler_UnmarshalPipelineParam_Call struct {
	*mock.Call
}

PipelineParamUnmarshaler_UnmarshalPipelineParam_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnmarshalPipelineParam'

func (*PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) Return added in v2.15.0 

func (_c *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) Return(_a0 error) *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call

func (*PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) Run added in v2.15.0 

func (_c *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) Run(run func(val interface{})) *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call

func (*PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) RunAndReturn added in v2.15.0 

func (_c *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call) RunAndReturn(run func(interface{}) error) *PipelineParamUnmarshaler_UnmarshalPipelineParam_Call

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) EXPECT added in v2.15.0 

func (_m *Runner) EXPECT() *Runner_Expecter

func (*Runner) ExecuteAndInsertFinishedRun 

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

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

func (*Runner) ExecuteRun 

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

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

func (*Runner) HealthReport 

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

HealthReport provides a mock function with given fields:

func (*Runner) InitializePipeline added in v2.10.0 

func (_m *Runner) InitializePipeline(spec pipeline.Spec) (*pipeline.Pipeline, error)

InitializePipeline provides a mock function with given fields: spec

func (*Runner) InsertFinishedRun 

func (_m *Runner) InsertFinishedRun(ctx context.Context, ds sqlutil.DataSource, run *pipeline.Run, saveSuccessfulTaskRuns bool) error

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

func (*Runner) InsertFinishedRuns 

func (_m *Runner) InsertFinishedRuns(ctx context.Context, ds sqlutil.DataSource, runs []*pipeline.Run, saveSuccessfulTaskRuns bool) error

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

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(ctx context.Context, taskID uuid.UUID, value interface{}, err error) error

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

func (*Runner) Run 

func (_m *Runner) Run(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool, fn func(sqlutil.DataSource) error) (bool, error)

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

func (*Runner) Start 

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

Start provides a mock function with given fields: _a0

type Runner_Close_Call added in v2.15.0 

type Runner_Close_Call struct {
	*mock.Call
}

Runner_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Runner_Close_Call) Return added in v2.15.0 

func (_c *Runner_Close_Call) Return(_a0 error) *Runner_Close_Call

func (*Runner_Close_Call) Run added in v2.15.0 

func (_c *Runner_Close_Call) Run(run func()) *Runner_Close_Call

func (*Runner_Close_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_Close_Call) RunAndReturn(run func() error) *Runner_Close_Call

type Runner_ExecuteAndInsertFinishedRun_Call added in v2.15.0 

type Runner_ExecuteAndInsertFinishedRun_Call struct {
	*mock.Call
}

Runner_ExecuteAndInsertFinishedRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteAndInsertFinishedRun'

func (*Runner_ExecuteAndInsertFinishedRun_Call) Return added in v2.15.0 

func (_c *Runner_ExecuteAndInsertFinishedRun_Call) Return(runID int64, results pipeline.TaskRunResults, err error) *Runner_ExecuteAndInsertFinishedRun_Call

func (*Runner_ExecuteAndInsertFinishedRun_Call) Run added in v2.15.0 

func (_c *Runner_ExecuteAndInsertFinishedRun_Call) Run(run func(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, saveSuccessfulTaskRuns bool)) *Runner_ExecuteAndInsertFinishedRun_Call

func (*Runner_ExecuteAndInsertFinishedRun_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_ExecuteAndInsertFinishedRun_Call) RunAndReturn(run func(context.Context, pipeline.Spec, pipeline.Vars, bool) (int64, pipeline.TaskRunResults, error)) *Runner_ExecuteAndInsertFinishedRun_Call

type Runner_ExecuteRun_Call added in v2.15.0 

type Runner_ExecuteRun_Call struct {
	*mock.Call
}

Runner_ExecuteRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteRun'

func (*Runner_ExecuteRun_Call) Return added in v2.15.0 

func (_c *Runner_ExecuteRun_Call) Return(run *pipeline.Run, trrs pipeline.TaskRunResults, err error) *Runner_ExecuteRun_Call

func (*Runner_ExecuteRun_Call) Run added in v2.15.0 

func (_c *Runner_ExecuteRun_Call) Run(run func(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars)) *Runner_ExecuteRun_Call

func (*Runner_ExecuteRun_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_ExecuteRun_Call) RunAndReturn(run func(context.Context, pipeline.Spec, pipeline.Vars) (*pipeline.Run, pipeline.TaskRunResults, error)) *Runner_ExecuteRun_Call

type Runner_Expecter added in v2.15.0 

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

func (*Runner_Expecter) Close added in v2.15.0 

func (_e *Runner_Expecter) Close() *Runner_Close_Call

Close is a helper method to define mock.On call

func (*Runner_Expecter) ExecuteAndInsertFinishedRun added in v2.15.0 

func (_e *Runner_Expecter) ExecuteAndInsertFinishedRun(ctx interface{}, spec interface{}, vars interface{}, saveSuccessfulTaskRuns interface{}) *Runner_ExecuteAndInsertFinishedRun_Call

ExecuteAndInsertFinishedRun is a helper method to define mock.On call

  • ctx context.Context
  • spec pipeline.Spec
  • vars pipeline.Vars
  • saveSuccessfulTaskRuns bool

func (*Runner_Expecter) ExecuteRun added in v2.15.0 

func (_e *Runner_Expecter) ExecuteRun(ctx interface{}, spec interface{}, vars interface{}) *Runner_ExecuteRun_Call

ExecuteRun is a helper method to define mock.On call

  • ctx context.Context
  • spec pipeline.Spec
  • vars pipeline.Vars

func (*Runner_Expecter) HealthReport added in v2.15.0 

func (_e *Runner_Expecter) HealthReport() *Runner_HealthReport_Call

HealthReport is a helper method to define mock.On call

func (*Runner_Expecter) InitializePipeline added in v2.15.0 

func (_e *Runner_Expecter) InitializePipeline(spec interface{}) *Runner_InitializePipeline_Call

InitializePipeline is a helper method to define mock.On call

  • spec pipeline.Spec

func (*Runner_Expecter) InsertFinishedRun added in v2.15.0 

func (_e *Runner_Expecter) InsertFinishedRun(ctx interface{}, ds interface{}, run interface{}, saveSuccessfulTaskRuns interface{}) *Runner_InsertFinishedRun_Call

InsertFinishedRun is a helper method to define mock.On call

  • ctx context.Context
  • ds sqlutil.DataSource
  • run *pipeline.Run
  • saveSuccessfulTaskRuns bool

func (*Runner_Expecter) InsertFinishedRuns added in v2.15.0 

func (_e *Runner_Expecter) InsertFinishedRuns(ctx interface{}, ds interface{}, runs interface{}, saveSuccessfulTaskRuns interface{}) *Runner_InsertFinishedRuns_Call

InsertFinishedRuns is a helper method to define mock.On call

  • ctx context.Context
  • ds sqlutil.DataSource
  • runs []*pipeline.Run
  • saveSuccessfulTaskRuns bool

func (*Runner_Expecter) Name added in v2.15.0 

func (_e *Runner_Expecter) Name() *Runner_Name_Call

Name is a helper method to define mock.On call

func (*Runner_Expecter) OnRunFinished added in v2.15.0 

func (_e *Runner_Expecter) OnRunFinished(_a0 interface{}) *Runner_OnRunFinished_Call

OnRunFinished is a helper method to define mock.On call

  • _a0 func(*pipeline.Run)

func (*Runner_Expecter) Ready added in v2.15.0 

func (_e *Runner_Expecter) Ready() *Runner_Ready_Call

Ready is a helper method to define mock.On call

func (*Runner_Expecter) ResumeRun added in v2.15.0 

func (_e *Runner_Expecter) ResumeRun(ctx interface{}, taskID interface{}, value interface{}, err interface{}) *Runner_ResumeRun_Call

ResumeRun is a helper method to define mock.On call

  • ctx context.Context
  • taskID uuid.UUID
  • value interface{}
  • err error

func (*Runner_Expecter) Run added in v2.15.0 

func (_e *Runner_Expecter) Run(ctx interface{}, run interface{}, saveSuccessfulTaskRuns interface{}, fn interface{}) *Runner_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context
  • run *pipeline.Run
  • saveSuccessfulTaskRuns bool
  • fn func(sqlutil.DataSource) error

func (*Runner_Expecter) Start added in v2.15.0 

func (_e *Runner_Expecter) Start(_a0 interface{}) *Runner_Start_Call

Start is a helper method to define mock.On call

  • _a0 context.Context

type Runner_HealthReport_Call added in v2.15.0 

type Runner_HealthReport_Call struct {
	*mock.Call
}

Runner_HealthReport_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HealthReport'

func (*Runner_HealthReport_Call) Return added in v2.15.0 

func (_c *Runner_HealthReport_Call) Return(_a0 map[string]error) *Runner_HealthReport_Call

func (*Runner_HealthReport_Call) Run added in v2.15.0 

func (_c *Runner_HealthReport_Call) Run(run func()) *Runner_HealthReport_Call

func (*Runner_HealthReport_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_HealthReport_Call) RunAndReturn(run func() map[string]error) *Runner_HealthReport_Call

type Runner_InitializePipeline_Call added in v2.15.0 

type Runner_InitializePipeline_Call struct {
	*mock.Call
}

Runner_InitializePipeline_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InitializePipeline'

func (*Runner_InitializePipeline_Call) Return added in v2.15.0 

func (_c *Runner_InitializePipeline_Call) Return(_a0 *pipeline.Pipeline, _a1 error) *Runner_InitializePipeline_Call

func (*Runner_InitializePipeline_Call) Run added in v2.15.0 

func (_c *Runner_InitializePipeline_Call) Run(run func(spec pipeline.Spec)) *Runner_InitializePipeline_Call

func (*Runner_InitializePipeline_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_InitializePipeline_Call) RunAndReturn(run func(pipeline.Spec) (*pipeline.Pipeline, error)) *Runner_InitializePipeline_Call

type Runner_InsertFinishedRun_Call added in v2.15.0 

type Runner_InsertFinishedRun_Call struct {
	*mock.Call
}

Runner_InsertFinishedRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertFinishedRun'

func (*Runner_InsertFinishedRun_Call) Return added in v2.15.0 

func (_c *Runner_InsertFinishedRun_Call) Return(_a0 error) *Runner_InsertFinishedRun_Call

func (*Runner_InsertFinishedRun_Call) Run added in v2.15.0 

func (_c *Runner_InsertFinishedRun_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, run *pipeline.Run, saveSuccessfulTaskRuns bool)) *Runner_InsertFinishedRun_Call

func (*Runner_InsertFinishedRun_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_InsertFinishedRun_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, *pipeline.Run, bool) error) *Runner_InsertFinishedRun_Call

type Runner_InsertFinishedRuns_Call added in v2.15.0 

type Runner_InsertFinishedRuns_Call struct {
	*mock.Call
}

Runner_InsertFinishedRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InsertFinishedRuns'

func (*Runner_InsertFinishedRuns_Call) Return added in v2.15.0 

func (_c *Runner_InsertFinishedRuns_Call) Return(_a0 error) *Runner_InsertFinishedRuns_Call

func (*Runner_InsertFinishedRuns_Call) Run added in v2.15.0 

func (_c *Runner_InsertFinishedRuns_Call) Run(run func(ctx context.Context, ds sqlutil.DataSource, runs []*pipeline.Run, saveSuccessfulTaskRuns bool)) *Runner_InsertFinishedRuns_Call

func (*Runner_InsertFinishedRuns_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_InsertFinishedRuns_Call) RunAndReturn(run func(context.Context, sqlutil.DataSource, []*pipeline.Run, bool) error) *Runner_InsertFinishedRuns_Call

type Runner_Name_Call added in v2.15.0 

type Runner_Name_Call struct {
	*mock.Call
}

Runner_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*Runner_Name_Call) Return added in v2.15.0 

func (_c *Runner_Name_Call) Return(_a0 string) *Runner_Name_Call

func (*Runner_Name_Call) Run added in v2.15.0 

func (_c *Runner_Name_Call) Run(run func()) *Runner_Name_Call

func (*Runner_Name_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_Name_Call) RunAndReturn(run func() string) *Runner_Name_Call

type Runner_OnRunFinished_Call added in v2.15.0 

type Runner_OnRunFinished_Call struct {
	*mock.Call
}

Runner_OnRunFinished_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnRunFinished'

func (*Runner_OnRunFinished_Call) Return added in v2.15.0 

func (_c *Runner_OnRunFinished_Call) Return() *Runner_OnRunFinished_Call

func (*Runner_OnRunFinished_Call) Run added in v2.15.0 

func (_c *Runner_OnRunFinished_Call) Run(run func(_a0 func(*pipeline.Run))) *Runner_OnRunFinished_Call

func (*Runner_OnRunFinished_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_OnRunFinished_Call) RunAndReturn(run func(func(*pipeline.Run))) *Runner_OnRunFinished_Call

type Runner_Ready_Call added in v2.15.0 

type Runner_Ready_Call struct {
	*mock.Call
}

Runner_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*Runner_Ready_Call) Return added in v2.15.0 

func (_c *Runner_Ready_Call) Return(_a0 error) *Runner_Ready_Call

func (*Runner_Ready_Call) Run added in v2.15.0 

func (_c *Runner_Ready_Call) Run(run func()) *Runner_Ready_Call

func (*Runner_Ready_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_Ready_Call) RunAndReturn(run func() error) *Runner_Ready_Call

type Runner_ResumeRun_Call added in v2.15.0 

type Runner_ResumeRun_Call struct {
	*mock.Call
}

Runner_ResumeRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResumeRun'

func (*Runner_ResumeRun_Call) Return added in v2.15.0 

func (_c *Runner_ResumeRun_Call) Return(_a0 error) *Runner_ResumeRun_Call

func (*Runner_ResumeRun_Call) Run added in v2.15.0 

func (_c *Runner_ResumeRun_Call) Run(run func(ctx context.Context, taskID uuid.UUID, value interface{}, err error)) *Runner_ResumeRun_Call

func (*Runner_ResumeRun_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_ResumeRun_Call) RunAndReturn(run func(context.Context, uuid.UUID, interface{}, error) error) *Runner_ResumeRun_Call

type Runner_Run_Call added in v2.15.0 

type Runner_Run_Call struct {
	*mock.Call
}

Runner_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*Runner_Run_Call) Return added in v2.15.0 

func (_c *Runner_Run_Call) Return(incomplete bool, err error) *Runner_Run_Call

func (*Runner_Run_Call) Run added in v2.15.0 

func (_c *Runner_Run_Call) Run(run func(ctx context.Context, run *pipeline.Run, saveSuccessfulTaskRuns bool, fn func(sqlutil.DataSource) error)) *Runner_Run_Call

func (*Runner_Run_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_Run_Call) RunAndReturn(run func(context.Context, *pipeline.Run, bool, func(sqlutil.DataSource) error) (bool, error)) *Runner_Run_Call

type Runner_Start_Call added in v2.15.0 

type Runner_Start_Call struct {
	*mock.Call
}

Runner_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*Runner_Start_Call) Return added in v2.15.0 

func (_c *Runner_Start_Call) Return(_a0 error) *Runner_Start_Call

func (*Runner_Start_Call) Run added in v2.15.0 

func (_c *Runner_Start_Call) Run(run func(_a0 context.Context)) *Runner_Start_Call

func (*Runner_Start_Call) RunAndReturn added in v2.15.0 

func (_c *Runner_Start_Call) RunAndReturn(run func(context.Context) error) *Runner_Start_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.