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 with its respective configurable options.

func NewKCP

func NewKCP() *KCP

NewKCP instantiates a new instance of the KCP 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.

func (*KCP) Listen

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

Listen listens for incoming KCP connections on a specified port.

type Layer

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

Layer represents a transport protocol layer.

type TCP

type TCP struct {
	WriteBufferSize int
	ReadBufferSize  int
	NoDelay         bool
}

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

func NewTCP

func NewTCP() *TCP

NewTCP instantiates a new instance of the TCP transport protocol.

func (*TCP) Dial

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

Dial dials an address via. the TCP protocol.

func (*TCP) Listen

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

Listen listens for incoming TCP connections on a specified port.