receiver

Documentation

Index

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

Variables

var (
	RespAcpt = []byte("ACCEPTED")
	RespSent = []byte("SENT")
	RespPsnt = []byte("PART_SENT")
	RespFail = []byte("FAILED")
	RespInvd = []byte("INVALID")
	RespTime = []byte("TIMEOUT")
	RespUnrt = []byte("UNROUTABLE")
	RespThrt = []byte("THROTTLED")

	MsgSendTimeout = time.Second
)

Functions

func New

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

Types

type Evio

type Evio struct {
	Name string

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