transport

Documentation

Index

• type KCP
  • func NewKCP() *KCP
  • func (t *KCP) Dial(address string) (net.Conn, error)
  • func (t *KCP) Listen(port int) (net.Listener, error)
• type Layer
• type TCP
  • func NewTCP() *TCP
  • func (t *TCP) Dial(address string) (net.Conn, error)
  • func (t *TCP) Listen(port int) (net.Listener, error)

Types

type KCP

type KCP struct {
	DataShards     int
	ParityShards   int
	SendWindowSize int
	RecvWindowSize int
}

KCP represents the KCP transport protocol alongside its respective configurable options.

func NewKCP

func NewKCP() *KCP

NewKCP instantiates a new instance of the KCP transport protocol.

func (*KCP) Dial

func (t *KCP) Dial(address string) (net.Conn, error)

Dial dials an address via. the KCP protocol, with optional Reed-Solomon message sharding and send/receive window size configurations.

func (*KCP) Listen

func (t *KCP) Listen(port int) (net.Listener, error)

Listen listens for incoming KCP connections on a specified port, with optional Reed-Solomon message sharding.

type Layer

type Layer interface {
	Listen(port int) (net.Listener, error)
	Dial(address string) (net.Conn, error)
}

type TCP

type TCP struct {
	WriteBufferSize int
	ReadBufferSize  int
	NoDelay         bool
}

func NewTCP

func NewTCP() *TCP

func (*TCP) Dial

func (t *TCP) Dial(address string) (net.Conn, error)

func (*TCP) Listen

func (t *TCP) Listen(port int) (net.Listener, error)