servers

package

v0.0.0-...-0051623 Latest Latest Go to latest Published: Jan 6, 2023 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/boomerlang/volgre_flow_processor

Documentation ¶

Index ¶

Variables
func CreateRuleEngineServer() gen.ServerBehavior
type RuleEngineServer

Constants ¶

This section is empty.

Variables ¶

View Source

var EntryPoints map[string]interface{}

View Source

var ExitPointsProc map[string]interface{}

View Source

var ExitPointsSim map[string]interface{}

View Source

var Rule_engines []string = []string{"instruction-receiver", "sanctions-receiver", "accountlookup-receiver", "fundscontrol-receiver", "rtp-accountposting-receiver",
	"rtp-ack-receiver", "sim-sanctions-receiver", "sim-accountlookup-receiver", "sim-fundscontrol-receiver", "sim-rtp-accountposting-receiver",
	"accountlookup-request", "fundscontrol-request", "instruction-dupcheck", "instruction-parse", "instruction-validate", "mop-derivation", "pacs008-parse", "pacs008-validate", "rtp-accountposting-request", "rtp-transmit", "sanctions-request", "transaction-dupcheck", "transaction-idgeneration", "transaction-messageidentifier"}

View Source

var Tasks map[string]interface{}

Functions ¶

func CreateRuleEngineServer ¶

func CreateRuleEngineServer() gen.ServerBehavior

Types ¶

type RuleEngineServer ¶

type RuleEngineServer struct {
	gen.Server
	// contains filtered or unexported fields
}

func (*RuleEngineServer) Call ¶

func (gs *RuleEngineServer) Call(args ...etf.Term) (etf.Term, gen.ServerStatus)

func (*RuleEngineServer) CallProc ¶

func (gs *RuleEngineServer) CallProc(pid string, args ...etf.Term) (etf.Term, gen.ServerStatus)

func (*RuleEngineServer) Cast ¶

func (gs *RuleEngineServer) Cast(pid string, args ...etf.Term) gen.ServerStatus

func (*RuleEngineServer) HandleCall ¶

func (gs *RuleEngineServer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)

func (*RuleEngineServer) HandleCast ¶

func (gs *RuleEngineServer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus

func (*RuleEngineServer) HandleInfo ¶

func (gs *RuleEngineServer) HandleInfo(process *gen.ServerProcess, message etf.Term) gen.ServerStatus

func (*RuleEngineServer) Init ¶

func (gs *RuleEngineServer) Init(process *gen.ServerProcess, args ...etf.Term) error

func (*RuleEngineServer) Terminate ¶

func (gs *RuleEngineServer) Terminate(process *gen.ServerProcess, reason string)

Source Files ¶

View all Source files

rule_engine_server.go

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