protocol

Documentation

Index

• Constants
• func WritePacket(bw *bufio.Writer, packet *Packet) error
• type Header
• type Packet
• type PacketType
• type TCPConn
  • func (c *TCPConn) ReceiveLoop(ctx context.Context, br *bufio.Reader, output chan<- *Packet) error
  • func (c *TCPConn) Run(ctx context.Context, input <-chan *voiceio.Chunk, output chan<- *Packet) error
  • func (c *TCPConn) SendLoop(ctx context.Context, input <-chan *voiceio.Chunk, bw *bufio.Writer) error

Constants

const (
	InitPacket          = 0
	DataPacket          = 1
	EndPacket           = 2
	HandshakePacket     = 3
	UserDisconectPacket = 4
)

const HeadeSize = 9

Functions

func WritePacket

func WritePacket(bw *bufio.Writer, packet *Packet) error

Types

type Header

type Header struct {
	Type       PacketType
	Length     uint32
	LengthUser uint32
}

type Packet

type Packet struct {
	Header  Header
	Payload []byte
	User    string
}

type PacketType

type PacketType uint8

type TCPConn

type TCPConn struct {
	Addr string
	User string
	Room string
}

func (*TCPConn) ReceiveLoop

func (c *TCPConn) ReceiveLoop(ctx context.Context, br *bufio.Reader, output chan<- *Packet) error

func (*TCPConn) Run

func (c *TCPConn) Run(ctx context.Context, input <-chan *voiceio.Chunk, output chan<- *Packet) error

func (*TCPConn) SendLoop

func (c *TCPConn) SendLoop(ctx context.Context, input <-chan *voiceio.Chunk, bw *bufio.Writer) error