Documentation
¶
Index ¶
- Constants
- type Component
- func (t *Component) GetInfo() module.ComponentInfo
- func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) module.Result
- func (t *Component) Instance() module.Component
- func (t *Component) OnSettings(_ context.Context, msg any) error
- func (t *Component) Ports() []module.Port
- type Context
- type InMessage
- type OutMessage
- type Settings
Constants ¶
View Source
const ( ComponentName = "async" InPort string = "in" OutPort string = "out" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Component ¶
type Component struct {
// contains filtered or unexported fields
}
func (*Component) GetInfo ¶
func (t *Component) GetInfo() module.ComponentInfo
func (*Component) Handle ¶
func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) module.Result
Handle dispatches the InPort. System ports go through the capability interfaces above.
func (*Component) OnSettings ¶ added in v0.2.0
OnSettings receives Settings from the SettingsPort and resizes the concurrency semaphore.
type InMessage ¶
type InMessage struct {
Context Context `json:"context" configurable:"true" required:"true" title:"Context" description:"Arbitrary message to be modified"`
}
type OutMessage ¶ added in v0.7.18
type OutMessage struct {
Context Context `json:"context" configurable:"true" title:"Context" description:"Passthrough — the message, unchanged"`
}
OutMessage keeps the passthrough Context under a `context` key so a downstream edge reads $.context.<field> — the mid-chain convention (same as the router, pod_logs_get, llm_tools). Was emitting the raw Context value at root.
Source Files
Click to show internal directories.
Click to hide internal directories.