Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChanReader ¶
type ChanReader struct {
// contains filtered or unexported fields
}
func NewChanReader ¶
func NewChanReader(ctx context.Context) *ChanReader
type ChanWriter ¶
type ChanWriter struct {
// contains filtered or unexported fields
}
func NewChanWriter ¶
func NewChanWriter(ctx context.Context) *ChanWriter
type CryptedFrameReadWriter ¶
type CryptedFrameReadWriter struct {
// contains filtered or unexported fields
}
func NewCryptedFrameReadWriter ¶
func NewCryptedFrameReadWriter(inner FrameReadWriter, secret []byte) (*CryptedFrameReadWriter, error)
func (*CryptedFrameReadWriter) ReadFrame ¶
func (f *CryptedFrameReadWriter) ReadFrame() (frame []byte, err error)
func (*CryptedFrameReadWriter) WriteFrame ¶
func (f *CryptedFrameReadWriter) WriteFrame(frame []byte) (err error)
type DebugFrameReadWriter ¶
type DebugFrameReadWriter struct {
// contains filtered or unexported fields
}
func NewDebugFrameReadWriter ¶
func NewDebugFrameReadWriter(inner FrameReadWriter) *DebugFrameReadWriter
func (*DebugFrameReadWriter) ReadFrame ¶
func (f *DebugFrameReadWriter) ReadFrame() (frame []byte, err error)
func (*DebugFrameReadWriter) WriteFrame ¶
func (f *DebugFrameReadWriter) WriteFrame(frame []byte) (err error)
type DebugReadWriter ¶
type DebugReadWriter struct {
// contains filtered or unexported fields
}
func NewDebugReadWriter ¶
func NewDebugReadWriter(inner io.ReadWriter) *DebugReadWriter
type FrameReadWriter ¶
type FullReadWriter ¶
type FullReadWriter struct {
// contains filtered or unexported fields
}
func NewFullReadWriter ¶
func NewFullReadWriter(inner io.ReadWriter) *FullReadWriter
type OrderedFrameReadWriter ¶
type OrderedFrameReadWriter struct {
// contains filtered or unexported fields
}
func NewOrderedFramReadWriter ¶
func NewOrderedFramReadWriter(inner FrameReadWriter) *OrderedFrameReadWriter
func (*OrderedFrameReadWriter) ReadFrame ¶
func (f *OrderedFrameReadWriter) ReadFrame() (frame []byte, err error)
func (*OrderedFrameReadWriter) WriteFrame ¶
func (f *OrderedFrameReadWriter) WriteFrame(frame []byte) (err error)
type PlainFrameReadWriter ¶
type PlainFrameReadWriter struct { MaxReadFrameSize uint32 // contains filtered or unexported fields }
func NewPlainFrameReadWriter ¶
func NewPlainFrameReadWriter(inner io.ReadWriter) *PlainFrameReadWriter
func (*PlainFrameReadWriter) ReadByte ¶
func (f *PlainFrameReadWriter) ReadByte() (byte, error)
func (*PlainFrameReadWriter) ReadFrame ¶
func (f *PlainFrameReadWriter) ReadFrame() (frame []byte, err error)
func (*PlainFrameReadWriter) WriteFrame ¶
func (f *PlainFrameReadWriter) WriteFrame(frame []byte) (err error)
type SnappyFrameReadWriter ¶
type SnappyFrameReadWriter struct {
// contains filtered or unexported fields
}
func NewSnappyFrameReadWriter ¶
func NewSnappyFrameReadWriter(inner FrameReadWriter) *SnappyFrameReadWriter
func (*SnappyFrameReadWriter) ReadFrame ¶
func (f *SnappyFrameReadWriter) ReadFrame() (frame []byte, err error)
func (*SnappyFrameReadWriter) WriteFrame ¶
func (f *SnappyFrameReadWriter) WriteFrame(frame []byte) (err error)
Click to show internal directories.
Click to hide internal directories.