node

package

Go to main page

Versions in this module

v0

v0.0.9

Nov 13, 2023

v0.0.8

Nov 13, 2023

v0.0.7

Nov 10, 2023

v0.0.4

Oct 4, 2023

Changes in this version

+ const ExtractSession

+ type MergerNode struct

+ func NewMerger() *MergerNode

+ func (b MergerNode) Busy() bool

+ func (b MergerNode) GetVars() *VarStorage

+ func (b MergerNode) ID() uuid.UUID

+ func (b MergerNode) IsReadOnly() bool

+ func (b MergerNode) LastInput() time.Time

+ func (b MergerNode) MergeVars(vars *VarStorage)

+ func (b MergerNode) Name() string

+ func (b MergerNode) SetID(id uuid.UUID)

+ func (b MergerNode) SetName(name string)

+ func (b MergerNode) SetVars(vars *VarStorage)

+ func (b MergerNode) Type() Type

+ func (n *MergerNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n MergerNode) GetInjections() map[string]transmission.Transmission

type Type

+ const TypeMerger

v0.0.2

Sep 28, 2023

Changes in this version

+ const ExtractBody

+ const ExtractHeader

+ const ExtractRegexBody

+ const ExtractStatus

+ const ExtractXPathHTML

+ const ExtractXPathJSON

+ const ExtractXPathXML

+ const IfContains

+ const IfEqual

+ const IfGreater

+ const IfGreaterOrEqual

+ const IfLess

+ const IfLessOrEqual

+ const IfNotContains

+ const IfNotEqual

+ const IfRegexMatch

+ const IfRegexNotMatch

+ type ExtractorNode struct

+ func NewExtractor() *ExtractorNode

+ func (b ExtractorNode) Busy() bool

+ func (b ExtractorNode) GetVars() *VarStorage

+ func (b ExtractorNode) ID() uuid.UUID

+ func (b ExtractorNode) IsReadOnly() bool

+ func (b ExtractorNode) LastInput() time.Time

+ func (b ExtractorNode) MergeVars(vars *VarStorage)

+ func (b ExtractorNode) Name() string

+ func (b ExtractorNode) SetID(id uuid.UUID)

+ func (b ExtractorNode) SetName(name string)

+ func (b ExtractorNode) SetVars(vars *VarStorage)

+ func (b ExtractorNode) Type() Type

+ func (n *ExtractorNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n ExtractorNode) GetInjections() map[string]transmission.Transmission

+ type IfNode struct

+ func NewIf() *IfNode

+ func (b IfNode) Busy() bool

+ func (b IfNode) GetVars() *VarStorage

+ func (b IfNode) ID() uuid.UUID

+ func (b IfNode) IsReadOnly() bool

+ func (b IfNode) LastInput() time.Time

+ func (b IfNode) MergeVars(vars *VarStorage)

+ func (b IfNode) Name() string

+ func (b IfNode) SetID(id uuid.UUID)

+ func (b IfNode) SetName(name string)

+ func (b IfNode) SetVars(vars *VarStorage)

+ func (b IfNode) Type() Type

+ func (n *IfNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n IfNode) GetInjections() map[string]transmission.Transmission

type Type

+ const TypeExtractor

+ const TypeIf

type VarStorage

+ func (s *VarStorage) ReadInputChoice(name string, dynamicInputs map[string]transmission.Transmission) (string, error)

v0.0.1

Aug 18, 2023

Changes in this version

+ type Channel string

+ const ChannelActivity

+ const ChannelStderr

+ const ChannelStdout

+ type Connector struct

+ Description string

+ Linkable bool

+ Name string

+ Type transmission.ParentType

+ func NewConnector(name string, t transmission.ParentType, linkable bool, description ...string) Connector

+ type Connectors []Connector

+ func (c Connectors) FindByName(name string) (Connector, bool)

+ type DelayNode struct

+ func NewDelay() *DelayNode

+ func (b DelayNode) Busy() bool

+ func (b DelayNode) GetVars() *VarStorage

+ func (b DelayNode) ID() uuid.UUID

+ func (b DelayNode) IsReadOnly() bool

+ func (b DelayNode) LastInput() time.Time

+ func (b DelayNode) MergeVars(vars *VarStorage)

+ func (b DelayNode) Name() string

+ func (b DelayNode) SetID(id uuid.UUID)

+ func (b DelayNode) SetName(name string)

+ func (b DelayNode) SetVars(vars *VarStorage)

+ func (b DelayNode) Type() Type

+ func (n *DelayNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n DelayNode) GetInjections() map[string]transmission.Transmission

+ type FuzzerNode struct

+ func NewFuzzer() *FuzzerNode

+ func (b FuzzerNode) Busy() bool

+ func (b FuzzerNode) GetVars() *VarStorage

+ func (b FuzzerNode) ID() uuid.UUID

+ func (b FuzzerNode) IsReadOnly() bool

+ func (b FuzzerNode) LastInput() time.Time

+ func (b FuzzerNode) MergeVars(vars *VarStorage)

+ func (b FuzzerNode) Name() string

+ func (b FuzzerNode) SetID(id uuid.UUID)

+ func (b FuzzerNode) SetName(name string)

+ func (b FuzzerNode) SetVars(vars *VarStorage)

+ func (b FuzzerNode) Type() Type

+ func (n *FuzzerNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n FuzzerNode) GetInjections() map[string]transmission.Transmission

+ type Input struct

+ Data map[string]transmission.Transmission

+ Last bool

+ type Link struct

+ Annotation string

+ From LinkDirection

+ To LinkDirection

+ type LinkDirection struct

+ Connector string

+ Node uuid.UUID

+ type Node interface

+ AddStaticInputValue func(string, transmission.Transmission) error

+ Busy func() bool

+ GetInjections func() map[string]transmission.Transmission

+ GetInputs func() Connectors

+ GetOutputs func() Connectors

+ GetVars func() *VarStorage

+ ID func() uuid.UUID

+ IsReadOnly func() bool

+ LastInput func() time.Time

+ MergeVars func(*VarStorage)

+ Name func() string

+ SetID func(uuid.UUID)

+ SetName func(string)

+ SetStaticInputValues func(map[string]transmission.Transmission) error

+ SetVars func(*VarStorage)

+ Start func(context.Context, <-chan Input, chan<- OutputInstance, chan<- Output) error

+ Type func() Type

+ Validate func(params map[string]transmission.Transmission) error

+ func FromType(t Type) (Node, error)

+ type Output struct

+ Channel Channel

+ Message string

+ Node uuid.UUID

+ func (o Output) Pack() OutputM

+ type OutputInstance struct

+ Complete bool

+ Current int

+ Data transmission.Transmission

+ OutputName string

+ Total int

+ type OutputM struct

+ Channel string

+ Message string

+ Node string

+ type OutputNode struct

+ func NewOutput() *OutputNode

+ func (b OutputNode) Busy() bool

+ func (b OutputNode) GetVars() *VarStorage

+ func (b OutputNode) ID() uuid.UUID

+ func (b OutputNode) IsReadOnly() bool

+ func (b OutputNode) LastInput() time.Time

+ func (b OutputNode) MergeVars(vars *VarStorage)

+ func (b OutputNode) Name() string

+ func (b OutputNode) SetID(id uuid.UUID)

+ func (b OutputNode) SetName(name string)

+ func (b OutputNode) SetVars(vars *VarStorage)

+ func (b OutputNode) Type() Type

+ func (n *OutputNode) Start(ctx context.Context, in <-chan Input, _ chan<- OutputInstance, ...) error

+ func (n OutputNode) GetInjections() map[string]transmission.Transmission

+ type RequestNode struct

+ func NewRequest() *RequestNode

+ func (b RequestNode) Busy() bool

+ func (b RequestNode) GetVars() *VarStorage

+ func (b RequestNode) ID() uuid.UUID

+ func (b RequestNode) IsReadOnly() bool

+ func (b RequestNode) LastInput() time.Time

+ func (b RequestNode) MergeVars(vars *VarStorage)

+ func (b RequestNode) Name() string

+ func (b RequestNode) SetID(id uuid.UUID)

+ func (b RequestNode) SetName(name string)

+ func (b RequestNode) SetVars(vars *VarStorage)

+ func (b RequestNode) Type() Type

+ func (n *RequestNode) GetInjections() map[string]transmission.Transmission

+ func (n *RequestNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ type SenderNode struct

+ func NewSender() *SenderNode

+ func (b SenderNode) Busy() bool

+ func (b SenderNode) GetVars() *VarStorage

+ func (b SenderNode) ID() uuid.UUID

+ func (b SenderNode) IsReadOnly() bool

+ func (b SenderNode) LastInput() time.Time

+ func (b SenderNode) MergeVars(vars *VarStorage)

+ func (b SenderNode) Name() string

+ func (b SenderNode) SetID(id uuid.UUID)

+ func (b SenderNode) SetName(name string)

+ func (b SenderNode) SetVars(vars *VarStorage)

+ func (b SenderNode) Type() Type

+ func (n *SenderNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n SenderNode) GetInjections() map[string]transmission.Transmission

+ type StartNode struct

+ func NewStart() *StartNode

+ func (b StartNode) Busy() bool

+ func (b StartNode) GetVars() *VarStorage

+ func (b StartNode) ID() uuid.UUID

+ func (b StartNode) IsReadOnly() bool

+ func (b StartNode) LastInput() time.Time

+ func (b StartNode) MergeVars(vars *VarStorage)

+ func (b StartNode) Name() string

+ func (b StartNode) SetID(id uuid.UUID)

+ func (b StartNode) SetName(name string)

+ func (b StartNode) SetVars(vars *VarStorage)

+ func (b StartNode) Type() Type

+ func (n *StartNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n StartNode) GetInjections() map[string]transmission.Transmission

+ type StatusFilterNode struct

+ func NewStatusFilter() *StatusFilterNode

+ func (b StatusFilterNode) Busy() bool

+ func (b StatusFilterNode) GetVars() *VarStorage

+ func (b StatusFilterNode) ID() uuid.UUID

+ func (b StatusFilterNode) IsReadOnly() bool

+ func (b StatusFilterNode) LastInput() time.Time

+ func (b StatusFilterNode) MergeVars(vars *VarStorage)

+ func (b StatusFilterNode) Name() string

+ func (b StatusFilterNode) SetID(id uuid.UUID)

+ func (b StatusFilterNode) SetName(name string)

+ func (b StatusFilterNode) SetVars(vars *VarStorage)

+ func (b StatusFilterNode) Type() Type

+ func (n *StatusFilterNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

+ func (n StatusFilterNode) GetInjections() map[string]transmission.Transmission

+ type TransmissionM struct

+ ChildType uint32

+ Data interface{}

+ ParentType uint32

+ func (m *TransmissionM) Unpack() (transmission.Transmission, error)

+ type Type int

+ const TypeDelay

+ const TypeFuzzer

+ const TypeOutput

+ const TypeRequest

+ const TypeSender

+ const TypeStart

+ const TypeStatusFilter

+ const TypeUnknown

+ const TypeVariables

+ type VarStorage struct

+ func NewVarStorage(inputs, outputs Connectors, defaults map[string]transmission.Transmission) *VarStorage

+ func (s *VarStorage) AddStaticInputValue(key string, value transmission.Transmission) error

+ func (s *VarStorage) FindInput(name string) (Connector, bool)

+ func (s *VarStorage) FindOutput(name string) (Connector, bool)

+ func (s *VarStorage) GetInputs() Connectors

+ func (s *VarStorage) GetOutputs() Connectors

+ func (s *VarStorage) MarshalJSON() ([]byte, error)

+ func (s *VarStorage) Merge(other *VarStorage)

+ func (s *VarStorage) Pack() (*VarStorageM, error)

+ func (s *VarStorage) ReadInputBool(name string, dynamicInputs map[string]transmission.Transmission) (bool, error)

+ func (s *VarStorage) ReadInputInt(name string, dynamicInputs map[string]transmission.Transmission) (int, error)

+ func (s *VarStorage) ReadInputList(name string, dynamicInputs map[string]transmission.Transmission) (transmission.Lister, error)

+ func (s *VarStorage) ReadInputMap(name string, dynamicInputs map[string]transmission.Transmission) (map[string]string, error)

+ func (s *VarStorage) ReadInputRequest(name string, dynamicInputs map[string]transmission.Transmission) (*packaging.HttpRequest, error)

+ func (s *VarStorage) ReadInputResponse(name string, dynamicInputs map[string]transmission.Transmission) (*packaging.HttpResponse, error)

+ func (s *VarStorage) ReadInputString(name string, dynamicInputs map[string]transmission.Transmission) (string, error)

+ func (s *VarStorage) ReadValue(name string, dynamicInputs map[string]transmission.Transmission) (transmission.Transmission, error)

+ func (s *VarStorage) SetStaticInputValues(values map[string]transmission.Transmission) error

+ func (s *VarStorage) UnmarshalJSON(data []byte) error

+ func (s *VarStorage) Validate(params map[string]transmission.Transmission) error

+ type VarStorageM struct

+ Inputs Connectors

+ Outputs Connectors

+ Static map[string]TransmissionM

+ func (m *VarStorageM) Unpack() (*VarStorage, error)

+ type VarsNode struct

+ func NewVars() *VarsNode

+ func (b VarsNode) Busy() bool

+ func (b VarsNode) GetVars() *VarStorage

+ func (b VarsNode) ID() uuid.UUID

+ func (b VarsNode) IsReadOnly() bool

+ func (b VarsNode) LastInput() time.Time

+ func (b VarsNode) MergeVars(vars *VarStorage)

+ func (b VarsNode) Name() string

+ func (b VarsNode) SetID(id uuid.UUID)

+ func (b VarsNode) SetName(name string)

+ func (b VarsNode) SetVars(vars *VarStorage)

+ func (b VarsNode) Type() Type

+ func (n *VarsNode) GetInjections() map[string]transmission.Transmission

+ func (n *VarsNode) Start(ctx context.Context, in <-chan Input, out chan<- OutputInstance, ...) error

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