Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + const CONTROL + const CodeBinary + const CodecGob + const CodecJSON + const CodecMsgpack + const CodecProto + const CodecRaw + const ERROR + const FiveMB + const OneMB + const OptionsMaxSize + const STOP + const STREAM + const TenMB + const Version1 + const WORD + func Preallocate() + func ReceiveBinaryFrame(relay io.Reader, fr *Frame) error + func ReceiveFrame(relay io.Reader, fr *Frame) error + type Frame struct + func From(header []byte, payload []byte) *Frame + func NewFrame() *Frame + func ReadFrame(data []byte) *Frame + func ReadHeader(data []byte) *Frame + func (*Frame) AppendOptions(header *[]byte, options []byte) + func (*Frame) IsStop(header []byte) bool + func (*Frame) IsStream(header []byte) bool + func (*Frame) ReadHL(header []byte) byte + func (*Frame) ReadPayloadLen(header []byte) uint32 + func (*Frame) ReadVersion(header []byte) byte + func (*Frame) SetStopBit(header []byte) + func (*Frame) SetStreamFlag(header []byte) + func (*Frame) VerifyCRC(header []byte) bool + func (*Frame) WriteCRC(header []byte) + func (*Frame) WriteFlags(header []byte, flags ...byte) + func (*Frame) WritePayloadLen(header []byte, payloadLen uint32) + func (*Frame) WriteVersion(header []byte, version byte) + func (f *Frame) Bytes() []byte + func (f *Frame) Header() []byte + func (f *Frame) HeaderPtr() *[]byte + func (f *Frame) Payload() []byte + func (f *Frame) ReadFlags() byte + func (f *Frame) ReadOptions(header []byte) []uint32 + func (f *Frame) Reset() + func (f *Frame) WriteOptions(header *[]byte, options ...uint32) + func (f *Frame) WritePayload(data []byte) + type Pipe struct + func NewPipeRelay(in io.ReadCloser, out io.WriteCloser) *Pipe + func (rl *Pipe) Close() error + func (rl *Pipe) Receive(frame *Frame) error + func (rl *Pipe) Send(frame *Frame) error + type Transfer interface + Close func() error + Receive func(frame *Frame) error + Send func(frame *Frame) error + type TransferImp struct + func NewTransferImp(rwc io.ReadWriteCloser) *TransferImp + func (rl *TransferImp) Close() error + func (rl *TransferImp) Receive(frame *Frame) error + func (rl *TransferImp) Send(frame *Frame) error