Documentation
¶
Index ¶
- Constants
- type NodeRequest
- func (nr *NodeRequest) GetID() idwrap.IDWrap
- func (nr *NodeRequest) GetName() string
- func (nr *NodeRequest) GetOutputVariables() []string
- func (nr *NodeRequest) GetRequiredVariables() []string
- func (nr *NodeRequest) RunAsync(ctx context.Context, req *node.FlowNodeRequest, ...)
- func (nr *NodeRequest) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult
- func (nr *NodeRequest) SetID(id idwrap.IDWrap)
- type NodeRequestOutput
- type NodeRequestSideResp
Constants ¶
View Source
const ( OUTPUT_RESPONSE_NAME = "response" OUTPUT_REQUEST_NAME = "request" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NodeRequest ¶
type NodeRequest struct {
FlownNodeID idwrap.IDWrap
Name string
HttpReq mhttp.HTTP
Headers []mhttp.HTTPHeader
Params []mhttp.HTTPSearchParam
RawBody *mhttp.HTTPBodyRaw
FormBody []mhttp.HTTPBodyForm
UrlBody []mhttp.HTTPBodyUrlencoded
Asserts []mhttp.HTTPAssert
HttpClient httpclient.HttpClient
NodeRequestSideRespChan chan NodeRequestSideResp
// contains filtered or unexported fields
}
func New ¶
func New(id idwrap.IDWrap, name string, httpReq mhttp.HTTP, headers []mhttp.HTTPHeader, params []mhttp.HTTPSearchParam, rawBody *mhttp.HTTPBodyRaw, formBody []mhttp.HTTPBodyForm, urlBody []mhttp.HTTPBodyUrlencoded, asserts []mhttp.HTTPAssert, httpClient httpclient.HttpClient, nodeRequestSideRespChan chan NodeRequestSideResp, logger *slog.Logger, ) *NodeRequest
func (*NodeRequest) GetID ¶
func (nr *NodeRequest) GetID() idwrap.IDWrap
func (*NodeRequest) GetName ¶
func (nr *NodeRequest) GetName() string
func (*NodeRequest) GetOutputVariables ¶
func (nr *NodeRequest) GetOutputVariables() []string
GetOutputVariables implements node.VariableIntrospector. Returns the output paths this HTTP node produces.
func (*NodeRequest) GetRequiredVariables ¶
func (nr *NodeRequest) GetRequiredVariables() []string
GetRequiredVariables implements node.VariableIntrospector. It extracts all variable references from URL, headers, query params, and body.
func (*NodeRequest) RunAsync ¶
func (nr *NodeRequest) RunAsync(ctx context.Context, req *node.FlowNodeRequest, resultChan chan node.FlowNodeResult)
func (*NodeRequest) RunSync ¶
func (nr *NodeRequest) RunSync(ctx context.Context, req *node.FlowNodeRequest) node.FlowNodeResult
func (*NodeRequest) SetID ¶
func (nr *NodeRequest) SetID(id idwrap.IDWrap)
type NodeRequestOutput ¶
type NodeRequestOutput struct {
Request request.RequestResponseVar `json:"request"`
Response httpclient.ResponseVar `json:"response"`
}
type NodeRequestSideResp ¶
type NodeRequestSideResp struct {
// Execution tracking
ExecutionID idwrap.IDWrap // The specific execution ID for this request
// Request
HttpReq mhttp.HTTP
Headers []mhttp.HTTPHeader
Params []mhttp.HTTPSearchParam
RawBody *mhttp.HTTPBodyRaw
FormBody []mhttp.HTTPBodyForm
UrlBody []mhttp.HTTPBodyUrlencoded
// Resp
Resp response.ResponseCreateHTTPOutput
// Synchronization
Done chan struct{}
}
Source Files
Click to show internal directories.
Click to hide internal directories.