async

package

v0.2.0 Latest Latest Go to latest Published: May 7, 2026 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tiny-systems/common-module

Links

Open Source Insights

Documentation ¶

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{}) any

Handle dispatches the InPort. System ports go through the capability interfaces above.

func (*Component) Instance ¶

func (t *Component) Instance() module.Component

func (*Component) OnSettings ¶ added in v0.2.0

func (t *Component) OnSettings(_ context.Context, msg any) error

OnSettings receives Settings from the SettingsPort and resizes the concurrency semaphore.

func (*Component) Ports ¶

func (t *Component) Ports() []module.Port

type Context ¶

type Context any

type InMessage ¶

type InMessage struct {
	Context Context `json:"context" configurable:"true" required:"true" title:"Context" description:"Arbitrary message to be modified"`
}

type Settings ¶ added in v0.1.173

type Settings struct {
	MaxConcurrency int `` /* 133-byte string literal not displayed */
}

Source Files ¶

View all Source files

async.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL