runner

README

Component Wrapper

Documentation

Index

• type Handler
• type Msg
• type Runner
  • func NewRunner(name string, component m.Component) *Runner
  • func (c *Runner) Cancel()
  • func (c *Runner) HasPort(port string) bool
  • func (c *Runner) Input(ctx context.Context, msg *Msg, outputHandler Handler) (err 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) SetNode(node v1alpha1.TinyNode)
  • func (c *Runner) SetTracer(t trace.Tracer) *Runner
  • func (c *Runner) SetTracker(t tracker.Manager) *Runner
  • func (c *Runner) UpdateStatus(status *v1alpha1.TinyNodeStatus) 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 ongoing requests

func (*Runner) HasPort

func (c *Runner) HasPort(port string) bool

func (*Runner) Input

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

Input processes input to the inherited component applies port config for the given port if any

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

func (c *Runner) SetNode(node v1alpha1.TinyNode)

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

func (*Runner) SetTracer

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

func (*Runner) SetTracker

func (c *Runner) SetTracker(t tracker.Manager) *Runner

func (*Runner) UpdateStatus

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

UpdateStatus apply status changes