link

Documentation

Index

• Constants
• func New(name string, params core.Params) (core.Link, error)
• type BufStrategy
• type Buffer
  • func (buf *Buffer) ConnectTo(link core.Link) error
  • func (buf *Buffer) ExecCmd(cmd *core.Cmd) error
  • func (buf *Buffer) LinkTo([]core.Link) error
  • func (buf *Buffer) Recv(msg *core.Message) error
  • func (buf *Buffer) RouteTo(map[string]core.Link) error
  • func (buf *Buffer) Send(msg *core.Message) error
  • func (buf *Buffer) String() string

Constants

const (
	MsgSendTimeout = 100 * time.Millisecond
)

Functions

func New

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

Types

type BufStrategy

type BufStrategy uint8

const (
	BufStrategyBlock BufStrategy = iota
	BufStrategySub
	BufStrategyDrop
)

type Buffer

type Buffer struct {
	Name string
	// contains filtered or unexported fields
}

func (*Buffer) ConnectTo

func (buf *Buffer) ConnectTo(link core.Link) error

func (*Buffer) ExecCmd

func (buf *Buffer) ExecCmd(cmd *core.Cmd) error

func (*Buffer) LinkTo

func (buf *Buffer) LinkTo([]core.Link) error

func (*Buffer) Recv

func (buf *Buffer) Recv(msg *core.Message) error

func (*Buffer) RouteTo

func (buf *Buffer) RouteTo(map[string]core.Link) error

func (*Buffer) Send

func (buf *Buffer) Send(msg *core.Message) error

func (*Buffer) String

func (buf *Buffer) String() string