receiver

Documentation

Index

• Constants
• Variables
• func New(name string, params core.Params) (core.Link, error)
• type TCP

Constants

const (
	MaxTCPBufSize = 65536

	ConnReadTimeout  = 1 * time.Second
	ConnWriteTimeout = 1 * time.Second
)

Variables

var (
	TcpRespAcpt = []byte("ACCEPTED")
	TcpRespSent = []byte("SENT")
	TcpRespPsnt = []byte("PART_SENT")
	TcpRespFail = []byte("FAILED")
	TcpRespInvd = []byte("INVALID")
	TcpRespTime = []byte("TIMEOUT")
	TcpRespUnrt = []byte("UNROUTABLE")
	TcpRespThrt = []byte("THROTTLED")

	ErrMalformedPacket = fmt.Errorf("Malformed packet")
	ErrEmptyBody       = fmt.Errorf("Empty message body")

	TcpMsgSendTimeout = 100 * 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
	// contains filtered or unexported fields
}