runner

README

Component Runner

Documentation

Index

• Variables
• func UpdateWithConfigurableDefinitions(original []byte, updateWith []byte, ...) ([]byte, error)
• type Msg
• type Runner
  • func NewRunner(node v1alpha1.TinyNode, component m.Component, callbacks ...tracker.Callback) *Runner
  • func (c *Runner) Configure(ctx context.Context, node v1alpha1.TinyNode, outputCh chan *Msg) error
  • func (c *Runner) Destroy() error
  • func (c *Runner) GetStats() map[string]interface{}
  • func (c *Runner) GetStatus() v1alpha1.TinyNodeStatus
  • func (c *Runner) Process(ctx context.Context, inputCh chan *Msg, outputCh chan *Msg) error
  • func (c *Runner) Run(ctx context.Context, wg *errgroup.Group, outputCh chan *Msg) error
  • func (c *Runner) SetLogger(l logr.Logger) *Runner
  • func (c *Runner) SetManager(m manager.ResourceInterface) *Runner

Variables

var EmptyCallback = func(err error) {}

Functions

func UpdateWithConfigurableDefinitions

func UpdateWithConfigurableDefinitions(original []byte, updateWith []byte, configurableDefinitions map[string]*ajson.Node) ([]byte, error)

Types

type Msg

type Msg struct {
	// which edge lead this message, optional
	EdgeID string `json:"edgeID"`
	// which node:port sent message, optional
	From string `json:"from"`
	// recipient of this message in a format node:port
	To string `json:"to"`

	Data []byte `json:"data"`

	Callback func(error) `json:"-"` // to track if msg was rejected
}

Msg being sent via instances edges

type Runner

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

func NewRunner

func NewRunner(node v1alpha1.TinyNode, component m.Component, callbacks ...tracker.Callback) *Runner

func (*Runner) Configure

func (c *Runner) Configure(ctx context.Context, node v1alpha1.TinyNode, outputCh chan *Msg) error

Configure updates specs and decides do we need to restart which handles by Run method

func (*Runner) Destroy

func (c *Runner) Destroy() error

Destroy stops the instance inclusing emit

func (*Runner) GetStats

func (c *Runner) GetStats() map[string]interface{}

func (*Runner) GetStatus

func (c *Runner) GetStatus() v1alpha1.TinyNodeStatus

GetStatus recreates status from scratch

func (*Runner) Process

func (c *Runner) Process(ctx context.Context, inputCh chan *Msg, outputCh chan *Msg) error

Process main instance loop read input port and push it to the component

func (*Runner) Run

func (c *Runner) Run(ctx context.Context, wg *errgroup.Group, outputCh chan *Msg) error

func (*Runner) SetLogger

func (c *Runner) SetLogger(l logr.Logger) *Runner

func (*Runner) SetManager

func (c *Runner) SetManager(m manager.ResourceInterface) *Runner