sink

Documentation

Index

• Constants
• func New(name string, params core.Params) (core.Link, error)
• type TCP
  • func (tcp *TCP) ConnectTo(core.Link) error
  • func (tcp *TCP) Recv(msg *core.Message) error
  • func (tcp *TCP) String() string

Constants

const (
	TcpConnTimeout   = 2 * time.Second
	TcpWriteDeadline = 200 * time.Millisecond
)

Functions

func New

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

Types

type TCP

type TCP struct {
	Name string

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

func (*TCP) ConnectTo

func (tcp *TCP) ConnectTo(core.Link) error

func (*TCP) Recv

func (tcp *TCP) Recv(msg *core.Message) error

func (*TCP) String

func (tcp *TCP) String() string