Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

multicode

package

Go to main page

Versions in this module

v1

v1.4.3

Apr 25, 2018

v1.4.2

Apr 22, 2018

v1.4.1

Mar 30, 2018

v1.4.0

Dec 16, 2017

v1.3.0

Nov 21, 2017

v1.2.0

Nov 6, 2017

Changes in this version

+ const FRAGMENT_HEADER_BYTES

+ const FRAGMENT_SIZE

+ const KEEP_ALIVE_RESOLUTION

+ const MAX_CLIENTS

+ const MAX_PACKET_HEADER_BYTES

+ const NULL_SEQUENCE

+ const RELIABLE_CHANNEL_ID

+ const UNRELIABLE_CHANNEL_ID

+ var ErrClientInstanceClosed = errors.New("client instance closed")

+ var ErrClientInstanceNotConnected = errors.New("client instance not connected")

+ var ErrClientInstanceSendBufferFull = errors.New("client instance reliable send buffer full")

+ var ErrClientInstanceUnreliableDataTooLarge = errors.New("client instance unreliable data too large")

+ var ErrReliablePacketControllerPacketDataTooLarge = errors.New("reliable packet controller packet data too large")

+ var ErrValueOutOfRange = errors.New("variable length value out of range")

+ func GetVariableLengthBytes(val uint16) (int, error)

+ func PacketMaxValues(maxPacketSizeBytes int64) (int, int, error)

+ func ReadFragmentHeader(packetBuffer []byte, offset, bufferLength, maxFragments, fragmentSize int) (int, int, int, int, uint16, uint16, uint32, byte, error)

+ func ReadPacketHeader(packetBuffer []byte, offset, bufferLength int) (int, byte, uint16, uint16, uint32, error)

+ func ReadVariableLengthUint16(rw *ByteArrayReaderWriter) (uint16, error)

+ func SequenceGreaterThan(s1, s2 uint16) bool

+ func SequenceLessThan(s1, s2 uint16) bool

+ func WriteAckPacket(packetBuffer []byte, channelID byte, ack uint16, ackBits uint32) int

+ func WritePacketHeader(packetBuffer []byte, channelID byte, sequence uint16, ack uint16, ...) int

+ func WriteVariableLengthUint16(val uint16, rw *ByteArrayReaderWriter) error

+ type BufferedPacket struct

+ func (b *BufferedPacket) Resize(size int)

+ type ByteArrayReaderWriter struct

+ func NewByteArrayReaderWriter(data []byte) *ByteArrayReaderWriter

+ func (s *ByteArrayReaderWriter) ReadBuffer(buf []byte, length int) error

+ func (s *ByteArrayReaderWriter) ReadByte() (byte, error)

+ func (s *ByteArrayReaderWriter) ReadUint16() (uint16, error)

+ func (s *ByteArrayReaderWriter) SeekRead(offset int) int

+ func (s *ByteArrayReaderWriter) SeekWrite(offset int) int

+ func (s *ByteArrayReaderWriter) WriteBuffer(buf []byte, length int)

+ func (s *ByteArrayReaderWriter) WriteByte(b byte)

+ func (s *ByteArrayReaderWriter) WriteUint16(u uint16)

+ type ClientInstance struct

+ Address *net.UDPAddr

+ ExpiresAt int64

+ ProtocolId uint64

+ UserData []byte

+ func NewClientInstance(logger *zap.Logger, addr *net.UDPAddr, serverConn *NetcodeConn, ...) *ClientInstance

+ func (c *ClientInstance) Close(sendDisconnect bool)

+ func (c *ClientInstance) IsConnected() bool

+ func (c *ClientInstance) Read() ([]byte, bool, error)

+ func (c *ClientInstance) Send(payloadData []byte, reliable bool) error

+ type FragmentReassemblyPacketData struct

+ func NewFragmentReassemblyPacketData() *FragmentReassemblyPacketData

+ func (d *FragmentReassemblyPacketData) Clear()

+ func (d *FragmentReassemblyPacketData) StoreFragmentData(channelID byte, sequence uint16, ack uint16, ackBits uint32, fragmentID int, ...)

+ type NetcodeConn struct

+ func NewNetcodeConn(logger *zap.Logger, recvSize int, sendSize int, ...) *NetcodeConn

+ func (c *NetcodeConn) Close() error

+ func (c *NetcodeConn) Listen(address *net.UDPAddr) error

+ func (c *NetcodeConn) WriteTo(b []byte, to *net.UDPAddr) (int, error)

+ type NetcodeData struct

+ type PacketSet struct

+ type ReceivedPacketData struct

+ type ReliablePacketController struct

+ func NewReliablePacketController(maxPacketSize int, maxPacketFragments int) *ReliablePacketController

+ func (r *ReliablePacketController) ReceivePacket(time int64, packetData []byte, bufferLength int) (uint16, []byte, int, []uint16, error)

+ func (r *ReliablePacketController) SendAck(channelID byte) ([]byte, int)

+ func (r *ReliablePacketController) SendPacket(time int64, packetData []byte, length int, channelID byte) (uint16, [][]byte, []int, error)

+ func (r *ReliablePacketController) Update()

+ type SentPacketData struct

+ type SequenceBufferOutgoing struct

+ func NewSequenceBufferOutgoing(bufferSize int) *SequenceBufferOutgoing

+ func (s *SequenceBufferOutgoing) Find(sequence uint16) *PacketSet

+ func (s *SequenceBufferOutgoing) Insert(sequence uint16) *PacketSet

+ func (s *SequenceBufferOutgoing) RemoveEntries(startSequence, finishSequence int32)

+ type SequenceBufferPacket struct

+ func NewSequenceBufferPacket(bufferSize int) *SequenceBufferPacket

+ func (s *SequenceBufferPacket) Exists(sequence uint16) bool

+ func (s *SequenceBufferPacket) Find(sequence uint16) *BufferedPacket

+ func (s *SequenceBufferPacket) Insert(sequence uint16) *BufferedPacket

+ func (s *SequenceBufferPacket) Remove(sequence uint16)

+ func (s *SequenceBufferPacket) RemoveEntries(startSequence, finishSequence int32)

+ type SequenceBufferReassembly struct

+ func NewSequenceBufferReassembly(bufferSize int) *SequenceBufferReassembly

+ func (s *SequenceBufferReassembly) Find(sequence uint16) *FragmentReassemblyPacketData

+ func (s *SequenceBufferReassembly) Insert(sequence uint16) *FragmentReassemblyPacketData

+ func (s *SequenceBufferReassembly) Remove(sequence uint16)

+ func (s *SequenceBufferReassembly) RemoveEntries(startSequence, finishSequence int32)

+ type SequenceBufferReceived struct

+ func NewSequenceBufferReceived(bufferSize int) *SequenceBufferReceived

+ func (s *SequenceBufferReceived) Exists(sequence uint16) bool

+ func (s *SequenceBufferReceived) Find(sequence uint16) *ReceivedPacketData

+ func (s *SequenceBufferReceived) GenerateAckBits() (uint16, uint32)

+ func (s *SequenceBufferReceived) Insert(sequence uint16) *ReceivedPacketData

+ func (s *SequenceBufferReceived) RemoveEntries(startSequence, finishSequence int32)

+ func (s *SequenceBufferReceived) TestInsert(sequence uint16) bool

+ type SequenceBufferSent struct

+ func NewSequenceBufferSent(bufferSize int) *SequenceBufferSent

+ func (s *SequenceBufferSent) Find(sequence uint16) *SentPacketData

+ func (s *SequenceBufferSent) Insert(sequence uint16) *SentPacketData

+ func (s *SequenceBufferSent) RemoveEntries(startSequence, finishSequence int32)

+ type Server struct

+ func NewServer(logger *zap.Logger, listenAddr, publicAddr *net.UDPAddr, privateKey []byte, ...) (*Server, error)

+ func (s *Server) Listen() error

+ func (s *Server) Stop()