block

Documentation

Index

• Constants
• type Block
  • func NewBlockFromReader(reader io.Reader) (*Block, error)
  • func NewConnectBlock(connectID uint32, blockID uint32, address string) Block
  • func NewDataBlocks(connectID uint32, blockID *atomic.Uint32, data []byte) []Block
  • func NewDisconnectBlock(connectID uint32, blockID uint32, shutdownType uint8) Block
  • func (block *Block) Pack() []byte

Constants

const (
	TypeConnect = iota
	TypeDisconnect
	TypeData

	ShutdownRead = iota
	ShutdownWrite
	ShutdownBoth

	HeaderSize = 1 + 4 + 4 + 4
	DataSize   = 16*1024 - 13
	MaxSize    = HeaderSize + DataSize
)

Types

type Block

type Block struct {
	Type         uint8  // 1 byte
	ConnectionID uint32 // 4 bytes
	BlockID      uint32 // 4 bytes
	BlockLength  uint32 // 4 bytes
	BlockData    []byte
	// contains filtered or unexported fields
}

func NewBlockFromReader

func NewBlockFromReader(reader io.Reader) (*Block, error)

func NewConnectBlock

func NewConnectBlock(connectID uint32, blockID uint32, address string) Block

func NewDataBlocks

func NewDataBlocks(connectID uint32, blockID *atomic.Uint32, data []byte) []Block

func NewDisconnectBlock

func NewDisconnectBlock(connectID uint32, blockID uint32, shutdownType uint8) Block

func (*Block) Pack

func (block *Block) Pack() []byte