httpflv

README

Useful links

• https://medium.com/@nate510/don-t-use-go-s-default-http-client-4804cb19f779

Documentation

Index

• Constants
• Variables
• func ParseHeader(self *flvio.Tag, b []byte) (n int, err error)
• func ReadTag(r io.Reader, b []byte) (tag flvio.Tag, ts int32, err error)
• type AMF0
  • func NewReader(b []byte) *AMF0
  • func (a *AMF0) ReadByte() (byte, error)
  • func (a *AMF0) ReadEcmaArray() (map[string]any, error)
  • func (a *AMF0) ReadItem() (any, error)
  • func (a *AMF0) ReadMap() (map[any]any, error)
  • func (a *AMF0) ReadMetaData() map[string]any
  • func (a *AMF0) ReadNumber() (float64, error)
  • func (a *AMF0) ReadObject() (map[string]any, error)
  • func (a *AMF0) ReadString() (string, error)
• type Conn
  • func Accept(res *http.Response) (*Conn, error)
  • func Dial(uri string) (*Conn, error)
  • func (c *Conn) Close() (err error)
  • func (c *Conn) ReadPacket() (av.Packet, error)
  • func (c *Conn) Streams() ([]av.CodecData, error)

Constants

const (
	TypeNumber byte = iota
	TypeBoolean
	TypeString
	TypeObject
	TypeEcmaArray = 8
	TypeObjectEnd = 9
)

Variables

var Err = errors.New("amf0 read error")

Functions

func ParseHeader

func ParseHeader(self *flvio.Tag, b []byte) (n int, err error)

func ReadTag

func ReadTag(r io.Reader, b []byte) (tag flvio.Tag, ts int32, err error)

Types

type AMF0

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

AMF0 spec: http://download.macromedia.com/pub/labs/amf/amf0_spec_121207.pdf

func NewReader

func NewReader(b []byte) *AMF0

func (*AMF0) ReadByte

func (a *AMF0) ReadByte() (byte, error)

func (*AMF0) ReadEcmaArray

func (a *AMF0) ReadEcmaArray() (map[string]any, error)

func (*AMF0) ReadItem

func (a *AMF0) ReadItem() (any, error)

func (*AMF0) ReadMap

func (a *AMF0) ReadMap() (map[any]any, error)

func (*AMF0) ReadMetaData

func (a *AMF0) ReadMetaData() map[string]any

func (*AMF0) ReadNumber

func (a *AMF0) ReadNumber() (float64, error)

func (*AMF0) ReadObject

func (a *AMF0) ReadObject() (map[string]any, error)

func (*AMF0) ReadString

func (a *AMF0) ReadString() (string, error)

type Conn

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

func Accept

func Accept(res *http.Response) (*Conn, error)

func Dial

func Dial(uri string) (*Conn, error)

func (*Conn) Close

func (c *Conn) Close() (err error)

func (*Conn) ReadPacket

func (c *Conn) ReadPacket() (av.Packet, error)

func (*Conn) Streams

func (c *Conn) Streams() ([]av.CodecData, error)