sockets

Documentation

Index

• type PacketsReader
  • func NewPacketsReader(r io.Reader, opcodeSize uint32, sourceType packet.Source) *PacketsReader
  • func (p *PacketsReader) EnableEncryption(crypto *crypto.Arc)
  • func (p *PacketsReader) Error() error
  • func (p *PacketsReader) Next() bool
  • func (p *PacketsReader) Packet() *packet.Packet
• type Socket

Types

type PacketsReader

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

func NewPacketsReader

func NewPacketsReader(r io.Reader, opcodeSize uint32, sourceType packet.Source) *PacketsReader

func (*PacketsReader) EnableEncryption

func (p *PacketsReader) EnableEncryption(crypto *crypto.Arc)

func (*PacketsReader) Error

func (p *PacketsReader) Error() error

func (*PacketsReader) Next

func (p *PacketsReader) Next() bool

func (*PacketsReader) Packet

func (p *PacketsReader) Packet() *packet.Packet

type Socket

type Socket interface {
	Close()
	ListenAndProcess(ctx context.Context) error

	Address() string

	SendPacket(*packet.Packet)
	Send(*packet.Writer)

	ReadChannel() <-chan *packet.Packet
	WriteChannel() chan<- *packet.Packet
}