Documentation ¶
Index ¶
- Variables
- func UpdateWithConfigurableDefinitions(original []byte, updateWith []byte, ...) ([]byte, error)
- type Msg
- type Runner
- func (c *Runner) ApplyStatus() error
- 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) Process(ctx context.Context, wg *errgroup.Group, instanceCh chan *Msg, ...) error
- func (c *Runner) SetLogger(l logr.Logger) *Runner
- func (c *Runner) SetManager(m manager.ResourceInterface) *Runner
Constants ¶
This section is empty.
Variables ¶
View Source
var EmptyCallback = func(err error) {}
Functions ¶
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 (*Runner) ApplyStatus ¶ added in v0.1.41
ApplyStatus recreates status from scratch
func (*Runner) Configure ¶
Configure updates specs and decides do we need to restart which handles by Run method
func (*Runner) Process ¶
func (c *Runner) Process(ctx context.Context, wg *errgroup.Group, instanceCh chan *Msg, outputCh chan *Msg) error
Process main instance loop read input port and apply it to the component
func (*Runner) SetManager ¶ added in v0.1.25
func (c *Runner) SetManager(m manager.ResourceInterface) *Runner
Click to show internal directories.
Click to hide internal directories.