runner

README

Component Wrapper

Documentation

Index

• func UpdateWithConfigurableDefinitions(original []byte, updateWith []byte, ...) ([]byte, error)
• type Handler
• type Msg
• type Runner
  • func NewRunner(name string, component m.Component) *Runner
  • func (c *Runner) Cancel()
  • func (c *Runner) Configure(ctx context.Context, node v1alpha1.TinyNode) error
  • func (c *Runner) GetStats() map[string]interface{}
  • func (c *Runner) Input(ctx context.Context, msg *Msg, outputHandler Handler) error
  • func (c *Runner) Node() v1alpha1.TinyNode
  • func (c *Runner) SetLogger(l logr.Logger) *Runner
  • func (c *Runner) SetMeter(m metric.Meter) *Runner
  • func (c *Runner) SetTracer(t trace.Tracer) *Runner
  • func (c *Runner) UpdateStatus(status *v1alpha1.TinyNodeStatus) error

Functions

func UpdateWithConfigurableDefinitions

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

Types

type Handler

type Handler func(ctx context.Context, msg *Msg) error

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"`
}

Msg being sent via instances edges

type Runner

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

func NewRunner

func NewRunner(name string, component m.Component) *Runner

func (*Runner) Cancel

func (c *Runner) Cancel()

Cancel cancels all entity requests

func (*Runner) Configure

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

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

func (*Runner) GetStats

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

GetStats @todo deprecate

func (*Runner) Input

func (c *Runner) Input(ctx context.Context, msg *Msg, outputHandler Handler) error

Input processes input to the inherited component

func (*Runner) Node

func (c *Runner) Node() v1alpha1.TinyNode

func (*Runner) SetLogger

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

func (*Runner) SetMeter

func (c *Runner) SetMeter(m metric.Meter) *Runner

func (*Runner) SetTracer

func (c *Runner) SetTracer(t trace.Tracer) *Runner

func (*Runner) UpdateStatus

func (c *Runner) UpdateStatus(status *v1alpha1.TinyNodeStatus) error

UpdateStatus apply status changes