nwsconnection

package

v0.0.0-...-6ce7508 Latest Latest Go to latest Published: May 5, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/the-dev-tools/dev-tools

Links

Open Source Insights

Documentation ¶

Index ¶

type NodeWsConnection
- func New(id idwrap.IDWrap, name string, url string, headers map[string]string, ...) *NodeWsConnection

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type NodeWsConnection ¶

type NodeWsConnection struct {
	FlowNodeID idwrap.IDWrap
	Name       string
	URL        string
	Headers    map[string]string
	HTTPClient *http.Client // shared client with cookie jar for upgrade handshake
}

NodeWsConnection is a listener entry node that connects to a WebSocket and dispatches HandleWsMessage chains for each incoming message.

func New ¶

func New(id idwrap.IDWrap, name string, url string, headers map[string]string, httpClient *http.Client) *NodeWsConnection

func (*NodeWsConnection) GetID ¶

func (n *NodeWsConnection) GetID() idwrap.IDWrap

func (*NodeWsConnection) GetName ¶

func (n *NodeWsConnection) GetName() string

func (*NodeWsConnection) GetOutputVariables ¶

func (n *NodeWsConnection) GetOutputVariables() []string

GetOutputVariables implements node.VariableIntrospector.

func (*NodeWsConnection) GetRequiredVariables ¶

func (n *NodeWsConnection) GetRequiredVariables() []string

GetRequiredVariables implements node.VariableIntrospector.

func (*NodeWsConnection) IsEntryNode ¶

func (n *NodeWsConnection) IsEntryNode() bool

IsEntryNode marks this as a valid flow entry point (no incoming edges).

func (*NodeWsConnection) IsLoopCoordinator ¶

func (n *NodeWsConnection) IsLoopCoordinator() bool

IsLoopCoordinator prevents the runner from applying per-node timeout.

func (*NodeWsConnection) RunAsync ¶

func (n *NodeWsConnection) RunAsync(ctx context.Context, req *node.FlowNodeRequest, resultChan chan node.FlowNodeResult)

func (*NodeWsConnection) RunSync ¶

func (n *NodeWsConnection) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult

func (*NodeWsConnection) SetID ¶

func (n *NodeWsConnection) SetID(id idwrap.IDWrap)

Source Files ¶

View all Source files

nwsconnection.go

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