mocks

Documentation

Index

• type AsyncDeleter
  • func NewAsyncDeleter(t interface{ ... }) *AsyncDeleter
  • func (_m *AsyncDeleter) AsyncDelete(req *pb.TransmitRequest)
  • func (_m *AsyncDeleter) EXPECT() *AsyncDeleter_Expecter
• type AsyncDeleter_AsyncDelete_Call
  • func (_c *AsyncDeleter_AsyncDelete_Call) Return() *AsyncDeleter_AsyncDelete_Call
  • func (_c *AsyncDeleter_AsyncDelete_Call) Run(run func(req *pb.TransmitRequest)) *AsyncDeleter_AsyncDelete_Call
  • func (_c *AsyncDeleter_AsyncDelete_Call) RunAndReturn(run func(*pb.TransmitRequest)) *AsyncDeleter_AsyncDelete_Call
• type AsyncDeleter_Expecter
  • func (_e *AsyncDeleter_Expecter) AsyncDelete(req interface{}) *AsyncDeleter_AsyncDelete_Call
• type MockRunner
  • func (m *MockRunner) ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars) (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

func (*AsyncDeleter) EXPECT

func (_m *AsyncDeleter) EXPECT() *AsyncDeleter_Expecter

type AsyncDeleter_AsyncDelete_Call

type AsyncDeleter_AsyncDelete_Call struct {
	*mock.Call
}

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

func (*AsyncDeleter_AsyncDelete_Call) Return

func (_c *AsyncDeleter_AsyncDelete_Call) Return() *AsyncDeleter_AsyncDelete_Call

func (*AsyncDeleter_AsyncDelete_Call) Run

func (_c *AsyncDeleter_AsyncDelete_Call) Run(run func(req *pb.TransmitRequest)) *AsyncDeleter_AsyncDelete_Call

func (*AsyncDeleter_AsyncDelete_Call) RunAndReturn

func (_c *AsyncDeleter_AsyncDelete_Call) RunAndReturn(run func(*pb.TransmitRequest)) *AsyncDeleter_AsyncDelete_Call

type AsyncDeleter_Expecter

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

func (*AsyncDeleter_Expecter) AsyncDelete

func (_e *AsyncDeleter_Expecter) AsyncDelete(req interface{}) *AsyncDeleter_AsyncDelete_Call

AsyncDelete is a helper method to define mock.On call

• req *pb.TransmitRequest

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