faasflow

package module

Go to main page

Versions in this module

v0

v0.6.0

May 18, 2020

Changes in this version

type FaasOperation

+ HttpRequestUrl string

type Node

+ func (node *Node) Request(url string, opts ...Option) *Node

v0.5.0

Aug 27, 2019

Changes in this version

+ var BLANK_MODIFIER = func(data []byte) ([]byte, error)

+ type FaasOperation struct

+ CallbackUrl string

+ FailureHandler FuncErrorHandler

+ Function string

+ Header map[string]string

+ Mod Modifier

+ OnResphandler RespHandler

+ Param map[string][]string

+ Requesthandler ReqHandler

+ func (operation *FaasOperation) Encode() []byte

+ func (operation *FaasOperation) Execute(data []byte, option map[string]interface{}) ([]byte, error)

+ func (operation *FaasOperation) GetHeaders() map[string]string

+ func (operation *FaasOperation) GetId() string

+ func (operation *FaasOperation) GetParams() map[string][]string

+ func (operation *FaasOperation) GetProperties() map[string][]string

+ type FuncErrorHandler func(error) error

+ type Modifier func([]byte) ([]byte, error)

type Node

+ func (node *Node) AddOperation(operation sdk.Operation) *Node

+ type ReqHandler func(*http.Request)

+ type RespHandler func(*http.Response) ([]byte, error)

v0.4.0

Jul 21, 2019

Changes in this version

+ type BranchOption func(*BranchOptions)

+ func InvokeEdge() BranchOption

+ type BranchOptions struct

+ type Dag struct

+ func NewDag() *Dag

+ func (this *Dag) Append(dag *Dag)

+ func (this *Dag) ConditionalBranch(vertex string, conditions []string, condition sdk.Condition, ...) (conditiondags map[string]*Dag)

+ func (this *Dag) Edge(from, to string, opts ...BranchOption)

+ func (this *Dag) ForEachBranch(vertex string, foreach sdk.ForEach, options ...BranchOption) (dag *Dag)

+ func (this *Dag) Node(vertex string, options ...BranchOption) *Node

+ func (this *Dag) SubDag(vertex string, dag *Dag)

+ type Node struct

+ func (node *Node) Apply(function string, opts ...Option) *Node

+ func (node *Node) Callback(url string, opts ...Option) *Node

+ func (node *Node) Modify(mod sdk.Modifier) *Node

type Option

+ func RequestHandler(handler sdk.ReqHandler) Option

type StateStore

+ Get func(key string) (string, error)

+ Set func(key string, value string) error

+ Update func(key string, oldValue string, newValue string) error

type Workflow

+ func GetWorkflow() *Workflow

+ func (flow *Workflow) Dag() *Dag

+ func (flow *Workflow) SetDag(dag *Dag)

+ func (flow *Workflow) SyncNode(options ...BranchOption) *Node

v0.2.0

Dec 14, 2018

Changes in this version

+ const StateFailure

+ const StateOngoing

+ const StateSuccess

+ var Execution = ExecutionOnly()

+ var INVAL_OPTION = fmt.Errorf("invalid option specified")

+ var Sync = SyncCall()

+ type Context struct

+ Name string

+ NodeInput map[string][]byte

+ Query url.Values

+ State string

+ func CreateContext(id string, node string, name string, dstore DataStore) *Context

+ func (context *Context) Del(key string) error

+ func (context *Context) Get(key string) (interface{}, error)

+ func (context *Context) GetBool(key string) (bool, error)

+ func (context *Context) GetBytes(key string) ([]byte, error)

+ func (context *Context) GetInt(key string) (int, error)

+ func (context *Context) GetNode() string

+ func (context *Context) GetRequestId() string

+ func (context *Context) GetString(key string) (string, error)

+ func (context *Context) Set(key string, data interface{}) error

+ type DagFlow struct

+ func CreateDag() *DagFlow

+ func (this *DagFlow) AddCallback(vertex string, url string, opts ...Option)

+ func (this *DagFlow) AddConditionalDags(vertex string, subdags map[string]*DagFlow, condition Option) error

+ func (this *DagFlow) AddEdge(from, to string, opts ...Option) error

+ func (this *DagFlow) AddForEachDag(vertex string, dag *DagFlow, foreach Option) error

+ func (this *DagFlow) AddFunction(vertex string, function string, opts ...Option)

+ func (this *DagFlow) AddModifier(vertex string, mod sdk.Modifier)

+ func (this *DagFlow) AddSubDag(vertex string, dag *DagFlow) error

+ func (this *DagFlow) AddVertex(vertex string, opts ...Option)

+ func (this *DagFlow) AppendDag(dag *DagFlow) error

+ type DataStore interface

+ Cleanup func() error

+ Configure func(flowName string, requestId string)

+ Del func(key string) error

+ Get func(key string) (string, error)

+ Init func() error

+ Set func(key string, value string) error

+ type Option func(*Options)

+ func Aggregator(aggregator sdk.Aggregator) Option

+ func Condition(condition sdk.Condition, aggregator sdk.Aggregator) Option

+ func ExecutionOnly() Option

+ func ForEach(foreach sdk.ForEach, aggregator sdk.Aggregator) Option

+ func Forwarder(forwarder sdk.Forwarder) Option

+ func Header(key, value string) Option

+ func OnFailure(handler sdk.FuncErrorHandler) Option

+ func OnReponse(handler sdk.RespHandler) Option

+ func Query(key string, value ...string) Option

+ func SyncCall() Option

+ type Options struct

+ type StateStore interface

+ Cleanup func() error

+ Configure func(flowName string, requestId string)

+ Create func(vertexs []string) error

+ GetState func() (bool, error)

+ IncrementCounter func(vertex string) (int, error)

+ Init func() error

+ SetState func(state bool) error

+ type Workflow struct

+ func NewFaasflow(name string) *Workflow

+ func (flow *Workflow) Apply(function string, opts ...Option) *Workflow

+ func (flow *Workflow) Callback(url string, opts ...Option) *Workflow

+ func (flow *Workflow) ExecuteDag(dag *DagFlow) error

+ func (flow *Workflow) Finally(handler sdk.PipelineHandler) *Workflow

+ func (flow *Workflow) GetPipeline() *sdk.Pipeline

+ func (flow *Workflow) Modify(mod sdk.Modifier) *Workflow

+ func (flow *Workflow) OnFailure(handler sdk.PipelineErrorHandler) *Workflow

v0.1.0

Nov 27, 2018

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