cfa

README

configurable-flow-actor

CFA is a backend logical engine to simply backend logic.

Documentation

Index

• Constants
• func CFARun(lg *log.Logger, flowName string, request string) ([]byte, error)
• func IsArray(expr string) bool
• func IsObject(expr string) bool
• func IsTaskTsp(source string) bool
• type Context
  • func (c *Context) GetRequest() *fastjson.Value
  • func (c *Context) GetValue(source string) ([]*fastjson.Value, error)
  • func (c *Context) Init(request string) error
  • func (c *Context) MarshalActionRequest(id string) string
  • func (c *Context) MarshalActionResponse(id string) string
  • func (c *Context) MarshalResponse() ([]byte, error)
  • func (c *Context) NewTaskResult(id string)
  • func (c *Context) SetCmdDir(dir string)
  • func (c *Context) SetHeaders(id string, headers http.Header) error
  • func (c *Context) SetResponse(v []*fastjson.Value)
  • func (c *Context) SetRsp(id string, rsp []byte) error
  • func (c *Context) SetValue(dst string, v []*fastjson.Value) error
• type DataBuilder
  • func (t *DataBuilder) DoTask(ctx *Context) error
• type End
  • func (t *End) DoTask(ctx *Context) error
• type Expr
  • func ExpressionParse(expr string) (*Expr, error)
  • func (e *Expr) IsActionRequest() bool
  • func (e *Expr) IsRequest() bool
  • func (e *Expr) IsResponse() bool
  • func (e *Expr) IsTaskTsp() bool
• type Flow
  • func (f *Flow) Run(ctx *Context) error
• type HttpRequest
  • func (t *HttpRequest) DoTask(ctx *Context) error
• type Node
• type ParamNode
• type Request
• type RunNode
  • func (n *RunNode) Run(ctx *Context) error
• type Start
  • func (t *Start) DoTask(ctx *Context) error
• type Task
  • func NewTask(tp *TaskParam, taskType string) Task
• type TaskParam
• type TaskResult
• type YtbDownloader
  • func (t *YtbDownloader) DoTask(ctx *Context) error
• type YtbParams

Constants

const (
	GATEWAY = "gateway"
	START   = "start"
	END     = "end"
	TASK    = "task"
)

const (
	HTTPREQUEST   = "HttpRequest"
	DATABUILDER   = "DataBuilder"
	YTBDOWNLOADER = "YtbDownloader"
)

const (
	ExprTypeHead = iota
	ExprTypeObject
	ExprTypeArray
)

Functions

func CFARun

func CFARun(lg *log.Logger, flowName string, request string) ([]byte, error)

func IsArray

func IsArray(expr string) bool

func IsObject

func IsObject(expr string) bool

func IsTaskTsp

func IsTaskTsp(source string) bool

Types

type Context

type Context struct {
	Logger *log.Logger

	A *fastjson.Arena

	// flow process result
	Exit   bool
	CmdDir string
	// contains filtered or unexported fields
}

func (*Context) GetRequest

func (c *Context) GetRequest() *fastjson.Value

func (*Context) GetValue

func (c *Context) GetValue(source string) ([]*fastjson.Value, error)

func (*Context) Init

func (c *Context) Init(request string) error

func (*Context) MarshalActionRequest

func (c *Context) MarshalActionRequest(id string) string

func (*Context) MarshalActionResponse

func (c *Context) MarshalActionResponse(id string) string

func (*Context) MarshalResponse

func (c *Context) MarshalResponse() ([]byte, error)

func (*Context) NewTaskResult

func (c *Context) NewTaskResult(id string)

func (*Context) SetCmdDir

func (c *Context) SetCmdDir(dir string)

func (*Context) SetHeaders

func (c *Context) SetHeaders(id string, headers http.Header) error

func (*Context) SetResponse

func (c *Context) SetResponse(v []*fastjson.Value)

func (*Context) SetRsp

func (c *Context) SetRsp(id string, rsp []byte) error

func (*Context) SetValue

func (c *Context) SetValue(dst string, v []*fastjson.Value) error

type DataBuilder

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

func (*DataBuilder) DoTask

func (t *DataBuilder) DoTask(ctx *Context) error

type End

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

func (*End) DoTask

func (t *End) DoTask(ctx *Context) error

type Expr

type Expr struct {
	Type  int // Object Array
	Token string
	// contains filtered or unexported fields
}

func ExpressionParse

func ExpressionParse(expr string) (*Expr, error)

func (*Expr) IsActionRequest

func (e *Expr) IsActionRequest() bool

func (*Expr) IsRequest

func (e *Expr) IsRequest() bool

func (*Expr) IsResponse

func (e *Expr) IsResponse() bool

func (*Expr) IsTaskTsp

func (e *Expr) IsTaskTsp() bool

type Flow

type Flow map[string]*Node

func (*Flow) Run

func (f *Flow) Run(ctx *Context) error

type HttpRequest

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

func (*HttpRequest) DoTask

func (t *HttpRequest) DoTask(ctx *Context) error

type Node

type Node struct {
	ID      string     `json:"id"`
	Type    string     `json:"type"` // start, end, gateway, task
	Expr    string     `json:"expr"`
	Next    string     `json:"next"`
	Default string     `json:"default"`
	Task    *TaskParam `json:"task"`
}

type ParamNode

type ParamNode struct {
	Data      string            `json:"data"`
	Type      string            `json:"type"`       // string, number, bool, array
	Action    string            `json:"action"`     // data parse method, expr, data, iNfunc
	TargetIdx map[string]string `json:"target_idx"` // to replace target dst item
	SourceIdx map[string]string `json:"source_idx"` // to replace source dst item
}

type Request

type Request struct {
	Post interface{}            `json:"post"`
	Get  map[string]interface{} `json:"get"`
}

type RunNode

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

func (*RunNode) Run

func (n *RunNode) Run(ctx *Context) error

type Start

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

func (*Start) DoTask

func (t *Start) DoTask(ctx *Context) error

type Task

type Task interface {
	DoTask(ctx *Context) error
}

func NewTask

func NewTask(tp *TaskParam, taskType string) Task

type TaskParam

type TaskParam struct {
	ID          string                `json:"id"`
	TaskType    string                `json:"task_type"`
	Path        string                `json:"path"`
	Method      string                `json:"method"`
	ContentType string                `json:"content_type"`
	Request     map[string]*ParamNode `json:"request"` // 后续在更改为可以替换的
	Response    map[string]*ParamNode `json:"response"`
}

type TaskResult

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

type YtbDownloader

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

func (*YtbDownloader) DoTask

func (t *YtbDownloader) DoTask(ctx *Context) error

type YtbParams

type YtbParams struct {
	DstDir     string `json:"dst_dir"`
	IsPlayList bool   `json:"is_playlist"`
	Format     string `json:"format"`
	Url        string `json:"url"`
}