tcp

Documentation

Index

• Constants
• type ConnWriter
  • func Dial(udpAddrPort netip.AddrPort) (*ConnWriter, error)
• type TCPService
  • func NewTCPService(udpAddr *net.UDPAddr, log logger.Logger) (*TCPService, error)
  • func (t *TCPService) Messages() <-chan *types.Msg

Constants

const BUFFER_SIZE = 32 * 1024 // 32KB

Types

type ConnWriter

type ConnWriter struct {
	Conn   net.Conn
	Writer *bufio.Writer
}

func Dial

func Dial(udpAddrPort netip.AddrPort) (*ConnWriter, error)

type TCPService

type TCPService struct {
	// contains filtered or unexported fields
}

func NewTCPService

func NewTCPService(udpAddr *net.UDPAddr, log logger.Logger) (*TCPService, error)

NewTCPService creates a listner that accepts TCP connections. The UDP port is incremented by one to get the TCP port.

func (*TCPService) Messages

func (t *TCPService) Messages() <-chan *types.Msg