Documentation
¶
Overview ¶
Package httprequest provides HTTP request node factory for the registry system.
Package httprequest provides HTTP request node implementation for workflow graph execution.
Index ¶
- Constants
- func NewHTTPRequestNodeFactory() protocol.NodeFactory
- type HTTPError
- type HTTPRequestConfig
- type HTTPRequestNode
- func (n *HTTPRequestNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)
- func (n *HTTPRequestNode) ID() string
- func (n *HTTPRequestNode) InputPorts() []models.InputPort
- func (n *HTTPRequestNode) OutputPorts() []models.OutputPort
- func (n *HTTPRequestNode) Type() string
- func (n *HTTPRequestNode) Validate(config map[string]any) error
- type HTTPRequestNodeFactory
- func (f *HTTPRequestNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)
- func (f *HTTPRequestNodeFactory) Description() string
- func (f *HTTPRequestNodeFactory) ID() string
- func (f *HTTPRequestNodeFactory) Name() string
- func (f *HTTPRequestNodeFactory) Schema() map[string]any
Constants ¶
const ( OutputPortSuccess = "success" OutputPortError = "error" InputPortMain = "main" )
Variables ¶
This section is empty.
Functions ¶
func NewHTTPRequestNodeFactory ¶
func NewHTTPRequestNodeFactory() protocol.NodeFactory
NewHTTPRequestNodeFactory creates a new HTTP request node factory.
Types ¶
type HTTPRequestConfig ¶
type HTTPRequestConfig struct {
URL string `json:"url"`
Method string `json:"method"`
Headers map[string]string `json:"headers"`
Body string `json:"body,omitempty"`
Timeout int `json:"timeout"`
}
HTTPRequestConfig defines the configuration for HTTP request nodes.
type HTTPRequestNode ¶
type HTTPRequestNode struct {
// contains filtered or unexported fields
}
HTTPRequestNode implements the Node interface for HTTP requests with multiple output ports.
func NewHTTPRequestNode ¶
func NewHTTPRequestNode(id string, config map[string]any) (*HTTPRequestNode, error)
NewHTTPRequestNode creates a new HTTP request node.
func (*HTTPRequestNode) Execute ¶
func (n *HTTPRequestNode) Execute(ctx models.ExecutionContext, inputs map[string]models.NodeResult) (map[string]models.NodeResult, error)
Execute performs the HTTP request and returns results on appropriate output ports.
func (*HTTPRequestNode) InputPorts ¶
func (n *HTTPRequestNode) InputPorts() []models.InputPort
InputPorts returns the input ports for the node.
func (*HTTPRequestNode) OutputPorts ¶
func (n *HTTPRequestNode) OutputPorts() []models.OutputPort
OutputPorts returns the output ports for the node.
type HTTPRequestNodeFactory ¶
type HTTPRequestNodeFactory struct{}
HTTPRequestNodeFactory creates HTTPRequestNode instances.
func (*HTTPRequestNodeFactory) Create ¶
func (f *HTTPRequestNodeFactory) Create(ctx context.Context, id string, config map[string]any) (protocol.Node, error)
Create creates a new HTTPRequestNode instance.
func (*HTTPRequestNodeFactory) Description ¶
func (f *HTTPRequestNodeFactory) Description() string
Description returns the factory description.
func (*HTTPRequestNodeFactory) ID ¶
func (f *HTTPRequestNodeFactory) ID() string
ID returns the factory ID.
func (*HTTPRequestNodeFactory) Name ¶
func (f *HTTPRequestNodeFactory) Name() string
Name returns the factory name.
func (*HTTPRequestNodeFactory) Schema ¶
func (f *HTTPRequestNodeFactory) Schema() map[string]any
Schema returns the JSON schema for HTTP request node configuration.
Source Files