erlang

Documentation

Index

• Constants
• type Node
  • func NewErlangNode(c *NodeConfig) (*Node, error)
  • func (s *Node) Call(message *RpcMessage) (etf.Term, error)
  • func (s *Node) CallWithTimeout(req *RpcMessage, timeout int) (etf.Term, error)
  • func (s *Node) Get() node.Node
  • func (s *Node) Run()
  • func (s *Node) Spawn(name string, opts gen.ProcessOptions, object gen.ProcessBehavior, ...) (gen.Process, error)
  • func (s *Node) Start() error
  • func (s *Node) Stop() error
• type NodeConfig
• type RpcMessage
• type RpcServer
  • func (tgs *RpcServer) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
  • func (tgs *RpcServer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
  • func (tgs *RpcServer) HandleDirect(process *gen.ServerProcess, ref etf.Ref, message interface{}) (interface{}, gen.DirectStatus)
  • func (tgs *RpcServer) HandleInfo(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
  • func (tgs *RpcServer) Init(process *gen.ServerProcess, args ...etf.Term) error
  • func (tgs *RpcServer) Terminate(process *gen.ServerProcess, reason string)

Constants

const (
	DefaultProcessName = "ErlangRPC"
	DefaultCallTimeout = 5
)

Types

type Node

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

func NewErlangNode

func NewErlangNode(c *NodeConfig) (*Node, error)

func (*Node) Call

func (s *Node) Call(message *RpcMessage) (etf.Term, error)

func (*Node) CallWithTimeout

func (s *Node) CallWithTimeout(req *RpcMessage, timeout int) (etf.Term, error)

func (*Node) Get

func (s *Node) Get() node.Node

func (*Node) Run

func (s *Node) Run()

func (*Node) Spawn

func (s *Node) Spawn(name string, opts gen.ProcessOptions, object gen.ProcessBehavior, args ...etf.Term) (gen.Process, error)

func (*Node) Start

func (s *Node) Start() error

func (*Node) Stop

func (s *Node) Stop() error

type NodeConfig

type NodeConfig struct {
	NodeName   string   `yaml:"nodeName" json:"nodeName"`
	Cookie     string   `yaml:"cookie" json:"cookie"`
	ServerName string   `yaml:"serverName" json:"serverName"`
	Nodes      []string `yaml:"nodes" json:"nodes"`
}

type RpcMessage

type RpcMessage struct {
	Node string
	Mod  string
	Fun  string
	Args []etf.Term
}

type RpcServer

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

func (*RpcServer) HandleCall

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

func (*RpcServer) HandleCast

func (tgs *RpcServer) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus

func (*RpcServer) HandleDirect

func (tgs *RpcServer) HandleDirect(process *gen.ServerProcess, ref etf.Ref, message interface{}) (interface{}, gen.DirectStatus)

func (*RpcServer) HandleInfo

func (tgs *RpcServer) HandleInfo(process *gen.ServerProcess, message etf.Term) gen.ServerStatus

func (*RpcServer) Init

func (tgs *RpcServer) Init(process *gen.ServerProcess, args ...etf.Term) error

func (*RpcServer) Terminate

func (tgs *RpcServer) Terminate(process *gen.ServerProcess, reason string)