mocknode

Documentation

Index

• type MockNode
  • func NewDelayedMockNode(id idwrap.IDWrap, next []idwrap.IDWrap, delay time.Duration) *MockNode
  • func NewMockNode(id idwrap.IDWrap, next []idwrap.IDWrap, onRun func()) *MockNode
  • func (mn *MockNode) GetID() idwrap.IDWrap
  • func (mn *MockNode) GetName() string
  • func (mn *MockNode) RunAsync(ctx context.Context, req *node.FlowNodeRequest, ...)
  • func (mn *MockNode) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult
  • func (mn *MockNode) SetID(id idwrap.IDWrap)

Types

type MockNode

type MockNode struct {
	ID    idwrap.IDWrap
	Next  []idwrap.IDWrap
	OnRun func()
	Delay time.Duration
}

func NewDelayedMockNode

func NewDelayedMockNode(id idwrap.IDWrap, next []idwrap.IDWrap, delay time.Duration) *MockNode

func NewMockNode

func NewMockNode(id idwrap.IDWrap, next []idwrap.IDWrap, onRun func()) *MockNode

func (*MockNode) GetID

func (mn *MockNode) GetID() idwrap.IDWrap

func (*MockNode) GetName

func (mn *MockNode) GetName() string

func (*MockNode) RunAsync

func (mn *MockNode) RunAsync(ctx context.Context, req *node.FlowNodeRequest, resultChan chan node.FlowNodeResult)

func (*MockNode) RunSync

func (mn *MockNode) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult

func (*MockNode) SetID

func (mn *MockNode) SetID(id idwrap.IDWrap)