mocks

Documentation

Index

• type AsyncDeleter
  • func NewAsyncDeleter(t interface{ ... }) *AsyncDeleter
  • func (_m *AsyncDeleter) AsyncDelete(req *pb.TransmitRequest)
• type MockRunner
  • func (m *MockRunner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (run *pipeline.Run, trrs pipeline.TaskRunResults, err error)
• type MockTask
  • func (m *MockTask) Base() *pipeline.BaseTask
  • func (m *MockTask) DotID() string
  • func (m *MockTask) ID() int
  • func (m *MockTask) Inputs() []pipeline.TaskDependency
  • func (m *MockTask) OutputIndex() int32
  • func (m *MockTask) Outputs() []pipeline.Task
  • func (m *MockTask) Run(ctx context.Context, lggr logger.Logger, vars pipeline.Vars, ...) (pipeline.Result, pipeline.RunInfo)
  • func (m *MockTask) TaskMaxBackoff() time.Duration
  • func (m *MockTask) TaskMinBackoff() time.Duration
  • func (m *MockTask) TaskRetries() uint32
  • func (m *MockTask) TaskTimeout() (time.Duration, bool)
  • func (m *MockTask) Type() pipeline.TaskType

Types

type AsyncDeleter

type AsyncDeleter struct {
	mock.Mock
}

AsyncDeleter is an autogenerated mock type for the asyncDeleter type

func NewAsyncDeleter

func NewAsyncDeleter(t interface {
	mock.TestingT
	Cleanup(func())
}) *AsyncDeleter

NewAsyncDeleter creates a new instance of AsyncDeleter. 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 (*AsyncDeleter) AsyncDelete

func (_m *AsyncDeleter) AsyncDelete(req *pb.TransmitRequest)

AsyncDelete provides a mock function with given fields: req

type MockRunner

type MockRunner struct {
	Trrs pipeline.TaskRunResults
	Err  error
}

func (*MockRunner) ExecuteRun

func (m *MockRunner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (run *pipeline.Run, trrs pipeline.TaskRunResults, err error)

type MockTask

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

func (*MockTask) Base

func (m *MockTask) Base() *pipeline.BaseTask

func (*MockTask) DotID

func (m *MockTask) DotID() string

func (*MockTask) ID

func (m *MockTask) ID() int

func (*MockTask) Inputs

func (m *MockTask) Inputs() []pipeline.TaskDependency

func (*MockTask) OutputIndex

func (m *MockTask) OutputIndex() int32

func (*MockTask) Outputs

func (m *MockTask) Outputs() []pipeline.Task

func (*MockTask) Run

func (m *MockTask) Run(ctx context.Context, lggr logger.Logger, vars pipeline.Vars, inputs []pipeline.Result) (pipeline.Result, pipeline.RunInfo)

func (*MockTask) TaskMaxBackoff

func (m *MockTask) TaskMaxBackoff() time.Duration

func (*MockTask) TaskMinBackoff

func (m *MockTask) TaskMinBackoff() time.Duration

func (*MockTask) TaskRetries

func (m *MockTask) TaskRetries() uint32

func (*MockTask) TaskTimeout

func (m *MockTask) TaskTimeout() (time.Duration, bool)

func (*MockTask) Type

func (m *MockTask) Type() pipeline.TaskType