Documentation ¶
Index ¶
- func UpdateWithConfigurableDefinitions(original []byte, updateWith []byte, ...) ([]byte, error)
- type Handler
- type Msg
- type Runner
- func (c *Runner) Cancel()
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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"` }
Msg being sent via instances edges
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
func (*Runner) Cancel ¶ added in v0.1.53
func (c *Runner) Cancel()
Cancel cancels all ongoing requests
func (*Runner) Input ¶ added in v0.1.53
Input processes input to the inherited component applies port config for the given port if any
func (*Runner) SetNode ¶ added in v0.1.63
SetNode updates specs and decides do we need to restart which handles by Run method
func (*Runner) UpdateStatus ¶ added in v0.1.43
func (c *Runner) UpdateStatus(status *v1alpha1.TinyNodeStatus) error
UpdateStatus apply status changes
Click to show internal directories.
Click to hide internal directories.