mocks

Documentation

Index

• type MockedNoder
  • func NewDefaultMockedNoder() *MockedNoder
  • func NewMockedNoder(onStart func(ctx context.Context, tc astikit.TaskCreator), ...) *MockedNoder
  • func (n *MockedNoder) DeltaStats() []astikit.DeltaStat
  • func (n *MockedNoder) Start(ctx context.Context, tc astikit.TaskCreator)
• type MockedPlugin
  • func NewMockedPlugin() *MockedPlugin
  • func (p *MockedPlugin) Init(c *astikit.Closer, f *astiflow.Flow) error
  • func (p *MockedPlugin) Start(ctx context.Context, tc astikit.TaskCreator)

Types

type MockedNoder

type MockedNoder struct {
	N *astiflow.Node
	// contains filtered or unexported fields
}

func NewDefaultMockedNoder

func NewDefaultMockedNoder() *MockedNoder

func NewMockedNoder

func NewMockedNoder(onStart func(ctx context.Context, tc astikit.TaskCreator), ss []astikit.DeltaStat) *MockedNoder

func (*MockedNoder) DeltaStats

func (n *MockedNoder) DeltaStats() []astikit.DeltaStat

func (*MockedNoder) Start

func (n *MockedNoder) Start(ctx context.Context, tc astikit.TaskCreator)

type MockedPlugin

type MockedPlugin struct {
	Initialized bool
	Started     bool
}

func NewMockedPlugin

func NewMockedPlugin() *MockedPlugin

func (*MockedPlugin) Init

func (p *MockedPlugin) Init(c *astikit.Closer, f *astiflow.Flow) error

func (*MockedPlugin) Start

func (p *MockedPlugin) Start(ctx context.Context, tc astikit.TaskCreator)