test

package

v0.20.0 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rulego/rulego

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateAndInitNode(targetNodeType string, initConfig types.Configuration, ...) (types.Node, error)
func EndpointMessage(t *testing.T, m interface{})
func NewRuleContext(config types.Config, ...) types.RuleContext
func NewRuleContextFull(config types.Config, self types.Node, childrenNodes map[string]types.Node, ...) types.RuleContext
func NodeInit(t *testing.T, targetNodeType string, initConfig types.Configuration, ...)
func NodeNew(t *testing.T, targetNodeType string, targetNode types.Node, ...)
func NodeOnMsg(t *testing.T, node types.Node, msgList []Msg, ...)
func NodeOnMsgWithChildren(t *testing.T, node types.Node, msgList []Msg, ...)
type Msg
type NodeAndCallback
type NodeTestRuleContext
type TimeNode
type UpperNode

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateAndInitNode ¶ added in v0.18.0

func CreateAndInitNode(targetNodeType string, initConfig types.Configuration, registry *types.SafeComponentSlice) (types.Node, error)

CreateAndInitNode 创建并初始化一个节点实例

func EndpointMessage ¶ added in v0.18.0

func EndpointMessage(t *testing.T, m interface{})

EndpointMessage 测试endpoint请求、响应消息

func NewRuleContext ¶

func NewRuleContext(config types.Config, callback func(msg types.RuleMsg, relationType string, err error)) types.RuleContext

func NewRuleContextFull ¶ added in v0.16.0

func NewRuleContextFull(config types.Config, self types.Node, childrenNodes map[string]types.Node, callback func(msg types.RuleMsg, relationType string, err error)) types.RuleContext

func NodeInit ¶ added in v0.18.0

func NodeInit(t *testing.T, targetNodeType string, initConfig types.Configuration, expected types.Configuration, registry *types.SafeComponentSlice)

NodeInit 测试初始化

func NodeNew ¶ added in v0.18.0

func NodeNew(t *testing.T, targetNodeType string, targetNode types.Node, defaultConfig types.Configuration, registry *types.SafeComponentSlice)

NodeNew 测试创建节点实例

func NodeOnMsg ¶ added in v0.18.0

func NodeOnMsg(t *testing.T, node types.Node, msgList []Msg, callback func(msg types.RuleMsg, relationType string, err error))

NodeOnMsg 发送消息

func NodeOnMsgWithChildren ¶ added in v0.18.0

func NodeOnMsgWithChildren(t *testing.T, node types.Node, msgList []Msg, childrenNodes map[string]types.Node, callback func(msg types.RuleMsg, relationType string, err error))

NodeOnMsgWithChildren 发送消息

Types ¶

type Msg ¶ added in v0.18.0

type Msg struct {
	MetaData types.Metadata
	DataType types.DataType
	MsgType  string
	Data     string
	//发之后暂停间隔
	AfterSleep time.Duration
}

type NodeAndCallback ¶ added in v0.18.0

type NodeAndCallback struct {
	Node          types.Node
	MsgList       []Msg
	ChildrenNodes map[string]types.Node
	Callback      func(msg types.RuleMsg, relationType string, err error)
}

type NodeTestRuleContext ¶

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

NodeTestRuleContext 只为测试单节点，临时创建的上下文无法把多个节点组成链式 callback 回调处理结果

func (*NodeTestRuleContext) Config ¶

func (ctx *NodeTestRuleContext) Config() types.Config

func (*NodeTestRuleContext) DoOnEnd ¶ added in v0.18.0

func (ctx *NodeTestRuleContext) DoOnEnd(msg types.RuleMsg, err error, relationType string)

func (*NodeTestRuleContext) ExecuteNode ¶ added in v0.17.0

func (ctx *NodeTestRuleContext) ExecuteNode(context context.Context, nodeId string, msg types.RuleMsg, skipTellNext bool, callback types.OnEndFunc)

ExecuteNode 独立执行某个节点，通过callback获取节点执行情况，用于节点分组类节点控制执行某个节点

func (*NodeTestRuleContext) From ¶ added in v0.18.0

func (ctx *NodeTestRuleContext) From() types.NodeCtx

func (*NodeTestRuleContext) GetCallbackFunc ¶ added in v0.20.0

func (ctx *NodeTestRuleContext) GetCallbackFunc(functionName string) interface{}

GetCallbackFunc 获取回调函数

func (*NodeTestRuleContext) GetContext ¶ added in v0.13.0

func (ctx *NodeTestRuleContext) GetContext() context.Context

func (*NodeTestRuleContext) GetEndFunc ¶

func (ctx *NodeTestRuleContext) GetEndFunc() types.OnEndFunc

func (*NodeTestRuleContext) GetSelfId ¶

func (ctx *NodeTestRuleContext) GetSelfId() string

func (*NodeTestRuleContext) NewMsg ¶

func (ctx *NodeTestRuleContext) NewMsg(msgType string, metaData types.Metadata, data string) types.RuleMsg

func (*NodeTestRuleContext) OnDebug ¶ added in v0.20.0

func (ctx *NodeTestRuleContext) OnDebug(ruleChainId string, flowType string, nodeId string, msg types.RuleMsg, relationType string, err error)

OnDebug 调用配置的OnDebug回调函数

func (*NodeTestRuleContext) RuleChain ¶ added in v0.18.0

func (ctx *NodeTestRuleContext) RuleChain() types.NodeCtx

func (*NodeTestRuleContext) Self ¶ added in v0.18.0

func (ctx *NodeTestRuleContext) Self() types.NodeCtx

func (*NodeTestRuleContext) SetCallbackFunc ¶ added in v0.20.0

func (ctx *NodeTestRuleContext) SetCallbackFunc(functionName string, f interface{})

SetCallbackFunc 设置回调函数

func (*NodeTestRuleContext) SetContext ¶ added in v0.13.0

func (ctx *NodeTestRuleContext) SetContext(c context.Context) types.RuleContext

func (*NodeTestRuleContext) SetEndFunc ¶

func (ctx *NodeTestRuleContext) SetEndFunc(onEndFunc types.OnEndFunc) types.RuleContext

func (*NodeTestRuleContext) SetOnAllNodeCompleted ¶ added in v0.17.0

func (ctx *NodeTestRuleContext) SetOnAllNodeCompleted(onAllNodeCompleted func())

SetOnAllNodeCompleted 设置所有节点执行完回调

func (*NodeTestRuleContext) SubmitTack ¶

func (ctx *NodeTestRuleContext) SubmitTack(task func())

func (*NodeTestRuleContext) TellFailure ¶

func (ctx *NodeTestRuleContext) TellFailure(msg types.RuleMsg, err error)

func (*NodeTestRuleContext) TellFlow ¶ added in v0.17.0

func (ctx *NodeTestRuleContext) TellFlow(msg types.RuleMsg, chainId string, endFunc types.OnEndFunc, onAllNodeCompleted func())

func (*NodeTestRuleContext) TellNext ¶

func (ctx *NodeTestRuleContext) TellNext(msg types.RuleMsg, relationTypes ...string)

func (*NodeTestRuleContext) TellSelf ¶

func (ctx *NodeTestRuleContext) TellSelf(msg types.RuleMsg, delayMs int64)

func (*NodeTestRuleContext) TellSuccess ¶

func (ctx *NodeTestRuleContext) TellSuccess(msg types.RuleMsg)

type TimeNode ¶ added in v0.18.0

type TimeNode struct{}

TimeNode A plugin that adds a timestamp to the message metadata

func (*TimeNode) Destroy ¶ added in v0.18.0

func (n *TimeNode) Destroy()

func (*TimeNode) Init ¶ added in v0.18.0

func (n *TimeNode) Init(ruleConfig types.Config, configuration types.Configuration) error

func (*TimeNode) New ¶ added in v0.18.0

func (n *TimeNode) New() types.Node

func (*TimeNode) OnMsg ¶ added in v0.18.0

func (n *TimeNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)

func (*TimeNode) Type ¶ added in v0.18.0

func (n *TimeNode) Type() string

type UpperNode ¶ added in v0.18.0

type UpperNode struct{}

UpperNode A plugin that converts the message data to uppercase

func (*UpperNode) Destroy ¶ added in v0.18.0

func (n *UpperNode) Destroy()

func (*UpperNode) Init ¶ added in v0.18.0

func (n *UpperNode) Init(ruleConfig types.Config, configuration types.Configuration) error

func (*UpperNode) New ¶ added in v0.18.0

func (n *UpperNode) New() types.Node

func (*UpperNode) OnMsg ¶ added in v0.18.0

func (n *UpperNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)

func (*UpperNode) Type ¶ added in v0.18.0

func (n *UpperNode) Type() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
assert

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