flow

Documentation

Index

• Variables
• func GoAndRun(ctx context.Context, wg *sync.WaitGroup, reg *NodesReg, firstValue []byte)
• func PrepareOutputs(outputs NodeConnection) [][]Connection
• func VisitAndFetch(ctx context.Context, reg *NodesReg) error
• type Connection
• type Connections
• type CountStucker
• type Inputs
  • func PrepareInputs(inputs NodeConnection) []Inputs
• type NodeConnection
• type NodeData
• type NodeRet
• type NodeRetDatas
• type NodeRetRespond
• type NodeRetRespondData
• type NodeRetSelection
• type NodeRetValues
• type Noder
• type NoderEndpoint
• type NodesData
  • func ParseData(content []byte) (NodesData, error)
• type NodesReg
  • func DataToNode(ctx context.Context, controlName, startName, method string, datas NodesData, ...) (*NodesReg, error)
  • func NewNodesReg(ctx context.Context, controlName, startName, method string, ...) *NodesReg
  • func StartFlow(ctx context.Context, wg *sync.WaitGroup, controlName, endPoint, method string, ...) (*NodesReg, error)
  • func (r *NodesReg) AddError(err error)
  • func (r *NodesReg) Get(number string) (Noder, bool)
  • func (r *NodesReg) GetChan() <-chan Respond
  • func (r *NodesReg) GetStarts() []Connection
  • func (r *NodesReg) GetStuckCtx() context.Context
  • func (r *NodesReg) Set(number string, node Noder)
  • func (r *NodesReg) SetChanInactive()
  • func (r *NodesReg) UpdateStuck(typeCount CountStucker, trigger bool)
• type Respond

Variables

var (
	ErrStopGoroutine    = errors.New("stop goroutine")
	ErrEndpointNotFound = errors.New("endpoint not found")
)

var Input1 = "input_1"

var NodeTypes = make(map[string]func(context.Context, *NodesReg, NodeData, string) (Noder, error))

NodeTypes hold new function of releated node.

Functions

func GoAndRun

func GoAndRun(ctx context.Context, wg *sync.WaitGroup, reg *NodesReg, firstValue []byte)

func PrepareOutputs

func PrepareOutputs(outputs NodeConnection) [][]Connection

func VisitAndFetch

func VisitAndFetch(ctx context.Context, reg *NodesReg) error

Types

type Connection

type Connection = struct {
	Node   string `json:"node"`
	Output string `json:"output"`
}

type Connections

type Connections = struct {
	Connections []Connection `json:"connections"`
}

type CountStucker

type CountStucker uint

const (
	CountTotalIncrease CountStucker = iota + 1
	CountTotalDecrease
	CountStuckIncrease
	CountStuckDecrease
)

type Inputs

type Inputs struct {
	Node      string
	InputName string
	Active    bool
}

func PrepareInputs

func PrepareInputs(inputs NodeConnection) []Inputs

type NodeConnection

type NodeConnection = map[string]Connections

type NodeData

type NodeData struct {
	Data    map[string]interface{} `json:"data"`
	Inputs  NodeConnection         `json:"inputs"`
	Outputs NodeConnection         `json:"outputs"`
	Name    string
}

type NodeRet

type NodeRet interface {
	GetBinaryData() []byte
}

NodeRet simple return.

type NodeRetDatas

type NodeRetDatas interface {
	GetBinaryDatas() [][]byte
}

NodeRetDatas usuful for-loop operation.

type NodeRetRespond

type NodeRetRespond interface {
	GetRespond() Respond
}

NodeRetRespond using for responding request.

type NodeRetRespondData

type NodeRetRespondData interface {
	GetRespondData() Respond
}

NodeRetRespondData using if next node wants to respond data.

type NodeRetSelection

type NodeRetSelection interface {
	GetSelection() []int
}

NodeRetSelection usable if more than one output and want to choice between of them. Write to output numbers 0-4-5.

type NodeRetValues

type NodeRetValues interface {
	GetBinaryValues() []byte
}

type Noder

type Noder interface {
	GetType() string
	Run(context.Context, *sync.WaitGroup, *registry.AppStore, NodeRet, string) (NodeRet, error)
	Fetch(context.Context, *gorm.DB) error
	IsFetched() bool
	Validate() error
	ActiveInput(string)
	Next(int) []Connection
	NextCount() int
	IsRespond() bool
	Check()
	IsChecked() bool
	NodeID() string
}

Noder for nodes like script, endpoint.

type NoderEndpoint

type NoderEndpoint interface {
	Endpoint() string
	Methods() []string
}

type NodesData

type NodesData = map[string]NodeData

NodesData is content's represent.

func ParseData

func ParseData(content []byte) (NodesData, error)

type NodesReg

type NodesReg struct {
	// contains filtered or unexported fields
}

NodesReg hold concreate information of nodes and start points.

func DataToNode

func DataToNode(
	ctx context.Context,
	controlName, startName, method string,
	datas NodesData,
	appStore *registry.AppStore,
) (*NodesReg, error)

func NewNodesReg

func NewNodesReg(ctx context.Context, controlName, startName, method string, appStore *registry.AppStore) *NodesReg

func StartFlow

func StartFlow(
	ctx context.Context,
	wg *sync.WaitGroup,
	controlName, endPoint, method string,
	content []byte,
	appStore *registry.AppStore,
	value []byte,
) (*NodesReg, error)

func (*NodesReg) AddError

func (r *NodesReg) AddError(err error)

func (*NodesReg) Get

func (r *NodesReg) Get(number string) (Noder, bool)

func (*NodesReg) GetChan

func (r *NodesReg) GetChan() <-chan Respond

func (*NodesReg) GetStarts

func (r *NodesReg) GetStarts() []Connection

func (*NodesReg) GetStuckCtx

func (r *NodesReg) GetStuckCtx() context.Context

GetStuckChan return nil if not started.

func (*NodesReg) Set

func (r *NodesReg) Set(number string, node Noder)

Set a concreate node to registry. Number is a node number like 2, 4.

func (*NodesReg) SetChanInactive

func (r *NodesReg) SetChanInactive()

func (*NodesReg) UpdateStuck

func (r *NodesReg) UpdateStuck(typeCount CountStucker, trigger bool)

type Respond

type Respond struct {
	Header  map[string]interface{} `json:"header"`
	Data    []byte                 `json:"data"`
	Status  int                    `json:"status"`
	IsError bool                   `json:"-"`
}