framereader

Documentation

Index

• type FrameReader
  • func New(framer *http2.Framer, paths *sync.Map) *FrameReader
  • func (frameReader *FrameReader) Read(packet *models.Packet) (models.RenderModel, error)
• type Streams
  • func NewStreams() *Streams
  • func (streams *Streams) Add(connectionKey string, stream *models.Stream)
  • func (streams *Streams) Get(connectionKey string, streamID uint32) (*models.Stream, bool)

Types

type FrameReader

type FrameReader struct {
	Streams *Streams
	// contains filtered or unexported fields
}

FrameReader ...

func New

func New(framer *http2.Framer, paths *sync.Map) *FrameReader

New creates FrameReader

func (*FrameReader) Read

func (frameReader *FrameReader) Read(packet *models.Packet) (models.RenderModel, error)

Read ...

type Streams

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

Streams ...

func NewStreams

func NewStreams() *Streams

NewStreams ...

func (*Streams) Add

func (streams *Streams) Add(connectionKey string, stream *models.Stream)

Add ...

func (*Streams) Get

func (streams *Streams) Get(connectionKey string, streamID uint32) (*models.Stream, bool)

Get ...