README
¶
Component Wrapper
Documentation
¶
Index ¶
- Constants
- type Handler
- type Msg
- type 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) ReadStatus(status *v1alpha1.TinyNodeStatus) error
- 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
Constants ¶
View Source
const FromSignal = "signal"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"`
Nonce string `json:"nonce"`
}
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) ReadStatus ¶ added in v0.1.118
func (c *Runner) ReadStatus(status *v1alpha1.TinyNodeStatus) error
ReadStatus reads status
Source Files
Click to show internal directories.
Click to hide internal directories.