buffer

Documentation

Index

• Constants
• func CreateBidirectionalBuffer(receiveStreamID, sendStreamID int, ch *channel.Channel, ...) *bufio.ReadWriter
• func CreateReader(streamID int, ch *channel.Channel, readyCallback func(int)) *bufio.Reader
• func CreateWriter(streamID int, ch *channel.Channel) *bufio.Writer
• type Buffer
  • func (b *Buffer) Close() error
  • func (b *Buffer) Read(p []byte) (n int, err error)
  • func (b *Buffer) Write(p []byte) (n int, err error)
• type RawChannelReader
  • func NewRawChannelReader(streamID int, ch *channel.Channel) *RawChannelReader
  • func (r *RawChannelReader) AddReadyCallback(cb func(int))
  • func (r *RawChannelReader) HandleMessage(msg channel.MessageBase) bool
  • func (r *RawChannelReader) Read(p []byte) (n int, err error)
  • func (r *RawChannelReader) RemoveReadyCallback(cb func(int))
• type RawChannelWriter
  • func NewRawChannelWriter(streamID int, ch *channel.Channel) *RawChannelWriter
  • func (w *RawChannelWriter) Close() error
  • func (w *RawChannelWriter) Write(p []byte) (n int, err error)
• type StreamDataMessage
  • func (m *StreamDataMessage) GetType() uint16
  • func (m *StreamDataMessage) Pack() ([]byte, error)
  • func (m *StreamDataMessage) Unpack(data []byte) error

Constants

const (
	StreamIDMax   = 0x3fff // 16383
	MaxChunkLen   = 16 * 1024
	MaxDataLen    = 457 // MDU - 2 - 6 (2 for stream header, 6 for channel envelope)
	CompressTries = 4
)

Functions

func CreateBidirectionalBuffer

func CreateBidirectionalBuffer(receiveStreamID, sendStreamID int, ch *channel.Channel, readyCallback func(int)) *bufio.ReadWriter

func CreateReader

func CreateReader(streamID int, ch *channel.Channel, readyCallback func(int)) *bufio.Reader

func CreateWriter

func CreateWriter(streamID int, ch *channel.Channel) *bufio.Writer

Types

type Buffer

type Buffer struct {
	ReadWriter *bufio.ReadWriter
}

func (*Buffer) Close

func (b *Buffer) Close() error

func (*Buffer) Read

func (b *Buffer) Read(p []byte) (n int, err error)

func (*Buffer) Write

func (b *Buffer) Write(p []byte) (n int, err error)

type RawChannelReader

type RawChannelReader struct {
	// contains filtered or unexported fields
}

func NewRawChannelReader

func NewRawChannelReader(streamID int, ch *channel.Channel) *RawChannelReader

func (*RawChannelReader) AddReadyCallback

func (r *RawChannelReader) AddReadyCallback(cb func(int))

func (*RawChannelReader) HandleMessage

func (r *RawChannelReader) HandleMessage(msg channel.MessageBase) bool

func (*RawChannelReader) Read

func (r *RawChannelReader) Read(p []byte) (n int, err error)

func (*RawChannelReader) RemoveReadyCallback

func (r *RawChannelReader) RemoveReadyCallback(cb func(int))

type RawChannelWriter

type RawChannelWriter struct {
	// contains filtered or unexported fields
}

func NewRawChannelWriter

func NewRawChannelWriter(streamID int, ch *channel.Channel) *RawChannelWriter

func (*RawChannelWriter) Close

func (w *RawChannelWriter) Close() error

func (*RawChannelWriter) Write

func (w *RawChannelWriter) Write(p []byte) (n int, err error)

type StreamDataMessage

type StreamDataMessage struct {
	StreamID   uint16
	Data       []byte
	EOF        bool
	Compressed bool
}

func (*StreamDataMessage) GetType

func (m *StreamDataMessage) GetType() uint16

func (*StreamDataMessage) Pack

func (m *StreamDataMessage) Pack() ([]byte, error)

func (*StreamDataMessage) Unpack

func (m *StreamDataMessage) Unpack(data []byte) error