link

Documentation

Index

• Constants
• func Multiplex(msg *core.Message, links []core.Link, timeout time.Duration) error
• func New(name string, _ core.Params) (core.Link, error)
• type MPX
  • func (mpx *MPX) ConnectTo(core.Link) error
  • func (mpx *MPX) LinkTo(links []core.Link) error

Constants

const (
	MpxMsgSendTimeout = 50 * time.Millisecond
)

Functions

func Multiplex

func Multiplex(msg *core.Message, links []core.Link, timeout time.Duration) error

func New

func New(name string, _ core.Params) (core.Link, error)

Types

type MPX

type MPX struct {
	Name string

	*core.Connector
	*sync.Mutex
	// contains filtered or unexported fields
}

func (*MPX) ConnectTo

func (mpx *MPX) ConnectTo(core.Link) error

func (*MPX) LinkTo

func (mpx *MPX) LinkTo(links []core.Link) error