drpcwire

Apr 20, 2023

Changes in this version

type Kind

+ const KindCancel

type Packet

+ Control bool

Apr 25, 2022

Changes in this version

type Reader

+ func NewReaderWithOptions(r io.Reader, opts ReaderOptions) *Reader

+ type ReaderOptions struct

+ MaximumBufferSize int

Jul 14, 2021

Changes in this version

+ func SplitData(buf []byte, n int) (prefix, suffix []byte)

type Frame

+ func (fr Frame) String() string

type Writer

+ func (b *Writer) Empty() bool

May 14, 2021

Changes in this version

type Reader

+ func (s *Reader) ReadPacketUsing(buf []byte) (pkt Packet, err error)

Apr 27, 2021

Changes in this version

type Writer

+ func (b *Writer) Reset() *Writer

Mar 20, 2020

Changes in this version

type Frame

+ Control bool

type Kind

+ const KindInvokeMetadata

Jan 24, 2020

Changes in this version

type Kind

+ const KindClose

+ const KindCloseSend

+ const KindError

+ const KindInvoke

+ const KindMessage

Oct 4, 2019

Changes in this version

type ID

+ func (i ID) String() string

Aug 29, 2019

Changes in this version

+ func AppendFrame(buf []byte, fr Frame) []byte

+ func AppendVarint(buf []byte, x uint64) []byte

+ func MarshalError(err error) []byte

+ func ReadVarint(buf []byte) (rem []byte, out uint64, ok bool, err error)

+ func SplitFrame(data []byte, atEOF bool) (int, []byte, error)

+ func SplitN(pkt Packet, n int, cb func(fr Frame) error) error

+ func UnmarshalError(data []byte) error

+ type Frame struct

+ Data []byte

+ Done bool

+ ID ID

+ Kind Kind

+ func ParseFrame(buf []byte) (rem []byte, fr Frame, ok bool, err error)

+ type ID struct

+ Message uint64

+ Stream uint64

+ func (i ID) Less(j ID) bool

+ type Kind uint8

+ const Kind_Cancel

+ const Kind_Close

+ const Kind_CloseSend

+ const Kind_Error

+ const Kind_Invoke

+ const Kind_Largest

+ const Kind_Message

+ const Kind_Reserved

+ func (i Kind) String() string

+ type Packet struct

+ Data []byte

+ ID ID

+ Kind Kind

+ func (p Packet) String() string

+ type Reader struct

+ func NewReader(r io.Reader) *Reader

+ func (s *Reader) ReadPacket() (pkt Packet, err error)

+ type Writer struct

+ func NewWriter(w io.Writer, size int) *Writer

+ func (b *Writer) Flush() (err error)

+ func (b *Writer) WriteFrame(fr Frame) (err error)

+ func (b *Writer) WritePacket(pkt Packet) (err error)