mocks

Documentation

Index

• type Config
  • func (_m *Config) BridgeResponseURL() *url.URL
  • func (_m *Config) DatabaseMaximumTxDuration() time.Duration
  • func (_m *Config) DatabaseURL() url.URL
  • func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool
  • func (_m *Config) DefaultHTTPLimit() int64
  • func (_m *Config) DefaultHTTPTimeout() models.Duration
  • func (_m *Config) DefaultMaxHTTPAttempts() uint
  • func (_m *Config) JobPipelineMaxRunDuration() time.Duration
  • func (_m *Config) JobPipelineReaperInterval() time.Duration
  • func (_m *Config) JobPipelineReaperThreshold() time.Duration
  • func (_m *Config) TriggerFallbackDBPollInterval() time.Duration
• type ORM
  • func (_m *ORM) CreateSpec(ctx context.Context, db *gorm.DB, taskDAG pipeline.TaskDAG, ...) (int32, error)
  • func (_m *ORM) DB() *gorm.DB
  • func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error
  • func (_m *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)
  • func (_m *ORM) FindRun(id int64) (pipeline.Run, error)
  • func (_m *ORM) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs []pipeline.TaskRunResult, ...) (int64, error)
• type Runner
  • func (_m *Runner) Close() error
  • func (_m *Runner) ExecuteAndInsertFinishedRun(ctx context.Context, spec pipeline.Spec, meta pipeline.JSONSerializable, ...) (int64, pipeline.FinalResult, error)
  • func (_m *Runner) ExecuteRun(ctx context.Context, spec pipeline.Spec, meta pipeline.JSONSerializable, ...) (pipeline.TaskRunResults, error)
  • func (_m *Runner) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs pipeline.TaskRunResults, ...) (int64, error)
  • func (_m *Runner) Start() error

Types

type Config

type Config struct {
	mock.Mock
}

Config is an autogenerated mock type for the Config type

func (*Config) BridgeResponseURL

func (_m *Config) BridgeResponseURL() *url.URL

BridgeResponseURL provides a mock function with given fields:

func (*Config) DatabaseMaximumTxDuration

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

DatabaseMaximumTxDuration provides a mock function with given fields:

func (*Config) DatabaseURL

func (_m *Config) DatabaseURL() url.URL

DatabaseURL provides a mock function with given fields:

func (*Config) DefaultHTTPAllowUnrestrictedNetworkAccess

func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool

DefaultHTTPAllowUnrestrictedNetworkAccess provides a mock function with given fields:

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) DefaultMaxHTTPAttempts

func (_m *Config) DefaultMaxHTTPAttempts() uint

DefaultMaxHTTPAttempts provides a mock function with given fields:

func (*Config) JobPipelineMaxRunDuration

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

JobPipelineMaxRunDuration provides a mock function with given fields:

func (*Config) JobPipelineReaperInterval

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

JobPipelineReaperInterval provides a mock function with given fields:

func (*Config) JobPipelineReaperThreshold

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

JobPipelineReaperThreshold provides a mock function with given fields:

func (*Config) TriggerFallbackDBPollInterval

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

TriggerFallbackDBPollInterval 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 (*ORM) CreateSpec

func (_m *ORM) CreateSpec(ctx context.Context, db *gorm.DB, taskDAG pipeline.TaskDAG, maxTaskTimeout models.Interval) (int32, error)

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

func (*ORM) DB

func (_m *ORM) DB() *gorm.DB

DB provides a mock function with given fields:

func (*ORM) DeleteRunsOlderThan

func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error

DeleteRunsOlderThan provides a mock function with given fields: threshold

func (*ORM) FindBridge

func (_m *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)

FindBridge provides a mock function with given fields: name

func (*ORM) FindRun

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

FindRun provides a mock function with given fields: id

func (*ORM) InsertFinishedRun

func (_m *ORM) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs []pipeline.TaskRunResult, saveSuccessfulTaskRuns bool) (int64, error)

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

type Runner

type Runner struct {
	mock.Mock
}

Runner is an autogenerated mock type for the Runner type

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, meta pipeline.JSONSerializable, l logger.Logger, saveSuccessfulTaskRuns bool) (int64, pipeline.FinalResult, error)

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

func (*Runner) ExecuteRun

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

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

func (*Runner) InsertFinishedRun

func (_m *Runner) InsertFinishedRun(ctx context.Context, run pipeline.Run, trrs pipeline.TaskRunResults, saveSuccessfulTaskRuns bool) (int64, error)

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

func (*Runner) Start

func (_m *Runner) Start() error

Start provides a mock function with given fields: