receiver

package

v0.0.1 Latest Latest Go to latest Published: Aug 23, 2018 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/awesome-flow/flow

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

View Source

const (
	TCP_RESP_ACPT = "ACCEPTED"
	TCP_RESP_SENT = "SENT"
	TCP_RESP_PSNT = "PART_SENT"
	TCP_RESP_FAIL = "FAILED"
	TCP_RESP_INVD = "INVALID"
	TCP_RESP_TIME = "TIMEOUT"
	TCP_RESP_UNRT = "UNROUTABLE"
	TCP_RESP_THRT = "THROTTLED"
)

View Source

const (
	MaxTCPBufSize = 65536
)

Variables ¶

View Source

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

View Source

var (
	TcpMsgSendTimeout = 100 * time.Millisecond
)

Functions ¶

func NewTCP ¶

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

Types ¶

type TCP ¶

type TCP struct {
	Name string

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

Source Files ¶

View all Source files

tcp.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL