connectors

Documentation

Index

• type Connector
  • func NewConnector(id string, typeName string, behaviour string, lArity, rArity int) Connector
  • func (c *Connector) NToOneBehaviour(act string, msg *messages.SAMessage, invoker string)
  • func (c *Connector) NToOneReqRepBehaviour(act string, msg *messages.SAMessage, invoker string)
  • func (c *Connector) OneToNBehaviour(act string, msg *messages.SAMessage, invoker string)
  • func (c *Connector) OneWayBehaviour(act string, msg *messages.SAMessage, invoker string)
  • func (c *Connector) RequestReplyBehaviour(act string, msg *messages.SAMessage, invoker string)
  • func (c *Connector) Run(msg *messages.SAMessage, act string, invoker string)

Types

type Connector

type Connector struct {
	Id                string
	TypeName          string
	DefaultLeftArity  int
	DefaultRightArity int
	LeftArity         int
	RightArity        int
	Buffer            chan messages.SAMessage
	State             []chan bool
	Behaviour         string
}

func NewConnector

func NewConnector(id string, typeName string, behaviour string, lArity, rArity int) Connector

func (*Connector) NToOneBehaviour

func (c *Connector) NToOneBehaviour(act string, msg *messages.SAMessage, invoker string)

func (*Connector) NToOneReqRepBehaviour

func (c *Connector) NToOneReqRepBehaviour(act string, msg *messages.SAMessage, invoker string)

func (*Connector) OneToNBehaviour

func (c *Connector) OneToNBehaviour(act string, msg *messages.SAMessage, invoker string)

func (*Connector) OneWayBehaviour

func (c *Connector) OneWayBehaviour(act string, msg *messages.SAMessage, invoker string)

func (*Connector) RequestReplyBehaviour

func (c *Connector) RequestReplyBehaviour(act string, msg *messages.SAMessage, invoker string)

func (*Connector) Run

func (c *Connector) Run(msg *messages.SAMessage, act string, invoker string)