mocks

Documentation

Index

• type Config
  • func (_m *Config) BridgeResponseURL() *url.URL
  • func (_m *Config) DatabaseMaximumTxDuration() time.Duration
  • func (_m *Config) DatabaseURL() string
  • func (_m *Config) DefaultHTTPAllowUnrestrictedNetworkAccess() bool
  • func (_m *Config) DefaultHTTPLimit() int64
  • func (_m *Config) DefaultHTTPTimeout() models.Duration
  • func (_m *Config) DefaultMaxHTTPAttempts() uint
  • func (_m *Config) JobPipelineDBPollInterval() time.Duration
  • func (_m *Config) JobPipelineMaxTaskDuration() time.Duration
  • func (_m *Config) JobPipelineParallelism() uint8
  • func (_m *Config) JobPipelineReaperInterval() time.Duration
  • func (_m *Config) JobPipelineReaperThreshold() time.Duration
• type ORM
  • func (_m *ORM) AwaitRun(ctx context.Context, runID int64) error
  • func (_m *ORM) CreateRun(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
  • func (_m *ORM) CreateSpec(ctx context.Context, taskDAG pipeline.TaskDAG) (int32, error)
  • func (_m *ORM) DeleteRunsOlderThan(threshold time.Duration) error
  • func (_m *ORM) FindBridge(name models.TaskType) (models.BridgeType, error)
  • func (_m *ORM) ListenForNewRuns() (postgres.Subscription, error)
  • func (_m *ORM) ProcessNextUnclaimedTaskRun(ctx context.Context, fn pipeline.ProcessTaskRunFunc) (bool, error)
  • func (_m *ORM) ResultsForRun(ctx context.Context, runID int64) ([]pipeline.Result, error)
  • func (_m *ORM) RunFinished(runID int64) (bool, error)
• type Task
  • func (_m *Task) DotID() string
  • func (_m *Task) OutputIndex() int32
  • func (_m *Task) OutputTask() pipeline.Task
  • func (_m *Task) Run(ctx context.Context, taskRun pipeline.TaskRun, inputs []pipeline.Result) pipeline.Result
  • func (_m *Task) SetOutputTask(task pipeline.Task)
  • func (_m *Task) Type() pipeline.TaskType

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

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

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

JobPipelineDBPollInterval provides a mock function with given fields:

func (*Config) JobPipelineMaxTaskDuration

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

JobPipelineMaxTaskDuration provides a mock function with given fields:

func (*Config) JobPipelineParallelism

func (_m *Config) JobPipelineParallelism() uint8

JobPipelineParallelism 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:

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func (*ORM) AwaitRun

func (_m *ORM) AwaitRun(ctx context.Context, runID int64) error

AwaitRun provides a mock function with given fields: ctx, runID

func (*ORM) CreateRun

func (_m *ORM) CreateRun(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)

CreateRun provides a mock function with given fields: ctx, jobID, meta

func (*ORM) CreateSpec

func (_m *ORM) CreateSpec(ctx context.Context, taskDAG pipeline.TaskDAG) (int32, error)

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

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

func (_m *ORM) ListenForNewRuns() (postgres.Subscription, error)

ListenForNewRuns provides a mock function with given fields:

func (*ORM) ProcessNextUnclaimedTaskRun

func (_m *ORM) ProcessNextUnclaimedTaskRun(ctx context.Context, fn pipeline.ProcessTaskRunFunc) (bool, error)

ProcessNextUnclaimedTaskRun provides a mock function with given fields: ctx, fn

func (*ORM) ResultsForRun

func (_m *ORM) ResultsForRun(ctx context.Context, runID int64) ([]pipeline.Result, error)

ResultsForRun provides a mock function with given fields: ctx, runID

func (*ORM) RunFinished

func (_m *ORM) RunFinished(runID int64) (bool, error)

RunFinished provides a mock function with given fields: runID

type Task

type Task struct {
	mock.Mock
}

Task is an autogenerated mock type for the Task type

func (*Task) DotID

func (_m *Task) DotID() string

DotID provides a mock function with given fields:

func (*Task) OutputIndex

func (_m *Task) OutputIndex() int32

OutputIndex provides a mock function with given fields:

func (*Task) OutputTask

func (_m *Task) OutputTask() pipeline.Task

OutputTask provides a mock function with given fields:

func (*Task) Run

func (_m *Task) Run(ctx context.Context, taskRun pipeline.TaskRun, inputs []pipeline.Result) pipeline.Result

Run provides a mock function with given fields: ctx, taskRun, inputs

func (*Task) SetOutputTask

func (_m *Task) SetOutputTask(task pipeline.Task)

SetOutputTask provides a mock function with given fields: task

func (*Task) Type

func (_m *Task) Type() pipeline.TaskType

Type provides a mock function with given fields: