sdk

package

Go to main page

Versions in this module

v0

v0.1.4

Jun 20, 2023

Changes in this version

type EventHandler

+ Copy func() (EventHandler, error)

type StateStore

+ Incr func(key string, value int64) (int64, error)

v0.1.3

Apr 24, 2023

v0.1.2

Apr 24, 2023

Changes in this version

type DataStore

+ CopyStore func() (DataStore, error)

type StateStore

+ CopyStore func() (StateStore, error)

v0.1.1

Oct 23, 2022

Changes in this version

+ const DEPTH_DECREMENT

+ const DEPTH_INCREMENT

+ const DEPTH_SAME

+ const StateFailure

+ const StateOngoing

+ const StateSuccess

+ var DefaultForwarder = func(data []byte) []byte

+ var ERR_CYCLIC = fmt.Errorf("dag has cyclic dependency")

+ var ERR_DUPLICATE_EDGE = fmt.Errorf("edge redefined")

+ var ERR_DUPLICATE_VERTEX = fmt.Errorf("vertex redefined")

+ var ERR_MULTIPLE_START = fmt.Errorf("only one start vertex is allowed")

+ var ERR_NO_VERTEX = fmt.Errorf("dag has no vertex set")

+ var ERR_RECURSIVE_DEP = fmt.Errorf("dag has recursive dependency")

+ func GetPipelineDefinition(pipeline *Pipeline) string

+ type Aggregator func(map[string][]byte) ([]byte, error)

+ type BlankOperation struct

+ func (ops *BlankOperation) Encode() []byte

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

+ func (ops *BlankOperation) GetId() string

+ func (ops *BlankOperation) GetProperties() map[string][]string

+ type Condition func([]byte) []string

+ 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

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

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

+ func (context *Context) GetNode() string

+ func (context *Context) GetRequestId() string

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

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

+ type Dag struct

+ Id string

+ func NewDag() *Dag

+ func (this *Dag) AddEdge(from, to string) error

+ func (this *Dag) AddVertex(id string, operations []Operation) *Node

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

+ func (this *Dag) GetEndNode() *Node

+ func (this *Dag) GetInitialNode() *Node

+ func (this *Dag) GetNode(id string) *Node

+ func (this *Dag) GetNodes(dynamicOption string) []string

+ func (this *Dag) GetParentNode() *Node

+ func (this *Dag) HasBranch() bool

+ func (this *Dag) HasEdge() bool

+ func (this *Dag) IsExecutionFlow() bool

+ func (this *Dag) Validate() error

+ type DagExporter struct

+ EndNode string

+ ExecutionOnlyDag bool

+ HasBranch bool

+ HasEdge bool

+ Id string

+ IsValid bool

+ Nodes map[string]*NodeExporter

+ StartNode string

+ ValidationError string

+ type DataStore interface

+ Cleanup func() error

+ Configure func(flowName string, requestId string)

+ Del func(key string) error

+ Get func(key string) ([]byte, error)

+ Init func() error

+ Set func(key string, value []byte) error

+ type EventHandler interface

+ Configure func(flowName string, requestId string)

+ Flush func()

+ Init func() error

+ ReportExecutionContinuation func(requestId string)

+ ReportExecutionForward func(nodeId string, requestId string)

+ ReportNodeEnd func(nodeId string, requestId string)

+ ReportNodeFailure func(nodeId string, requestId string, err error)

+ ReportNodeStart func(nodeId string, requestId string)

+ ReportOperationEnd func(operationId string, nodeId string, requestId string)

+ ReportOperationFailure func(operationId string, nodeId string, requestId string, err error)

+ ReportOperationStart func(operationId string, nodeId string, requestId string)

+ ReportRequestEnd func(requestId string)

+ ReportRequestFailure func(requestId string, err error)

+ ReportRequestStart func(requestId string)

+ type ForEach func([]byte) map[string][]byte

+ type Forwarder func([]byte) []byte

+ type Logger interface

+ Configure func(flowName string, requestId string)

+ Init func() error

+ Log func(str string)

+ type Node struct

+ Id string

+ func (this *Node) AddAggregator(aggregator Aggregator)

+ func (this *Node) AddCondition(condition Condition)

+ func (this *Node) AddConditionalDag(condition string, dag *Dag)

+ func (this *Node) AddForEach(foreach ForEach)

+ func (this *Node) AddForEachDag(subDag *Dag) error

+ func (this *Node) AddForwarder(children string, forwarder Forwarder)

+ func (this *Node) AddOperation(operation Operation)

+ func (this *Node) AddSubAggregator(aggregator Aggregator)

+ func (this *Node) AddSubDag(subDag *Dag) error

+ func (this *Node) Children() []*Node

+ func (this *Node) Dependency() []*Node

+ func (this *Node) Dynamic() bool

+ func (this *Node) DynamicIndegree() int

+ func (this *Node) GetAggregator() Aggregator

+ func (this *Node) GetAllConditionalDags() map[string]*Dag

+ func (this *Node) GetCondition() Condition

+ func (this *Node) GetConditionalDag(condition string) *Dag

+ func (this *Node) GetForEach() ForEach

+ func (this *Node) GetForwarder(children string) Forwarder

+ func (this *Node) GetSubAggregator() Aggregator

+ func (this *Node) GetUniqueId() string

+ func (this *Node) Indegree() int

+ func (this *Node) Operations() []Operation

+ func (this *Node) Outdegree() int

+ func (this *Node) ParentDag() *Dag

+ func (this *Node) SubDag() *Dag

+ type NodeExporter struct

+ Children []string

+ ChildrenExecOnly map[string]bool

+ ConditionalDags map[string]*DagExporter

+ DynamicExecOnly bool

+ ForeachDag *DagExporter

+ HasAggregator bool

+ HasSubAggregator bool

+ HasSubDag bool

+ Id string

+ InDegree int

+ Index int

+ IsCondition bool

+ IsDynamic bool

+ IsForeach bool

+ Operations []*OperationExporter

+ OutDegree int

+ SubDag *DagExporter

+ UniqueId string

+ type Operation interface

+ Encode func() []byte

+ Execute func([]byte, map[string]interface{}) ([]byte, error)

+ GetId func() string

+ GetProperties func() map[string][]string

+ type OperationExporter struct

+ Name string

+ Properties map[string][]string

+ type Pipeline struct

+ CurrentDynamicOption map[string]string

+ Dag *Dag

+ ExecutionDepth int

+ ExecutionPosition map[string]string

+ FailureHandler PipelineErrorHandler

+ Finally PipelineHandler

+ func CreatePipeline() *Pipeline

+ func (pipeline *Pipeline) ApplyState(state string)

+ func (pipeline *Pipeline) CountNodes() int

+ func (pipeline *Pipeline) GetAllNodesUniqueId() []string

+ func (pipeline *Pipeline) GetCurrentNodeDag() (*Node, *Dag)

+ func (pipeline *Pipeline) GetInitialNodeId() string

+ func (pipeline *Pipeline) GetNodeExecutionUniqueId(node *Node) string

+ func (pipeline *Pipeline) GetState() string

+ func (pipeline *Pipeline) SetDag(dag *Dag)

+ func (pipeline *Pipeline) UpdatePipelineExecutionPosition(depthAdjustment int, vertex string)

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

+ type PipelineHandler func(string)

+ type StateStore interface

+ Cleanup func() error

+ Configure func(flowName string, requestId string)

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

+ Init func() error

+ Set func(key string, value string) error

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

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