flv

Documentation

Index

• Variables
• type Demuxer
  • func NewDemuxer() *Demuxer
  • func (d *Demuxer) Demux(p *av.Packet) error
  • func (d *Demuxer) DemuxH(p *av.Packet) error
• type FlvTagBody
  • func (tag *FlvTagBody) AACPacketType() uint8
  • func (tag *FlvTagBody) CodecID() uint8
  • func (tag *FlvTagBody) CompositionTime() int32
  • func (tag *FlvTagBody) IsKeyFrame() bool
  • func (tag *FlvTagBody) IsSeq() bool
  • func (tag *FlvTagBody) ParseMediaTagHeader(b []byte, isVideo bool) (n int, err error)
  • func (tag *FlvTagBody) SoundFormat() uint8
• type FlvTagHeader
• type Reader
  • func NewReader(r io.Reader, conf ...ReaderConf) *Reader
  • func (fr *Reader) Read() (p *av.Packet, err error)
• type ReaderConf
  • func WithReaderBuffer(size int) ReaderConf
• type Writer
  • func NewWriter(w io.Writer, conf ...WriterConf) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) Closed() bool
  • func (w *Writer) Write(p *av.Packet) error
• type WriterConf
  • func WithWriterBuffer(size int) WriterConf

Variables

var (
	FlvHeader          = []byte{0x46, 0x4c, 0x56, 0x01, 0x05, 0x00, 0x00, 0x00, 0x09}
	FlvFirstPreTagSize = []byte{0x00, 0x00, 0x00, 0x00}
	FlvFirstHeader     = append(FlvHeader, FlvFirstPreTagSize...)
)

var (
	ErrAvcEndSEQ = fmt.Errorf("avc end sequence")
)

var ErrHeader = errors.New("read flv header error")

var ErrInvalidAudioData = fmt.Errorf("invalid audio data")

var ErrInvalidVideoData = fmt.Errorf("invalid video data")

var ErrPreDataLen = errors.New("read flv pre data len error")

Types

type Demuxer

type Demuxer struct {
}

func NewDemuxer

func NewDemuxer() *Demuxer

func (*Demuxer) Demux

func (d *Demuxer) Demux(p *av.Packet) error

func (*Demuxer) DemuxH

func (d *Demuxer) DemuxH(p *av.Packet) error

type FlvTagBody

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

func (*FlvTagBody) AACPacketType

func (tag *FlvTagBody) AACPacketType() uint8

func (*FlvTagBody) CodecID

func (tag *FlvTagBody) CodecID() uint8

func (*FlvTagBody) CompositionTime

func (tag *FlvTagBody) CompositionTime() int32

func (*FlvTagBody) IsKeyFrame

func (tag *FlvTagBody) IsKeyFrame() bool

func (*FlvTagBody) IsSeq

func (tag *FlvTagBody) IsSeq() bool

func (*FlvTagBody) ParseMediaTagHeader

func (tag *FlvTagBody) ParseMediaTagHeader(b []byte, isVideo bool) (n int, err error)

ParseMediaTagHeader, parse video, audio, tag header

func (*FlvTagBody) SoundFormat

func (tag *FlvTagBody) SoundFormat() uint8

type FlvTagHeader

type FlvTagHeader struct {
	TagType           uint8
	DataSize          uint32
	Timestamp         uint32
	TimestampExtended uint8
	StreamID          uint32
	PreTagSzie        uint32
}

type Reader

type Reader struct {
	FlvTagHeader FlvTagHeader
	// contains filtered or unexported fields
}

func NewReader

func NewReader(r io.Reader, conf ...ReaderConf) *Reader

func (*Reader) Read

func (fr *Reader) Read() (p *av.Packet, err error)

type ReaderConf

type ReaderConf func(*Reader)

func WithReaderBuffer

func WithReaderBuffer(size int) ReaderConf

type Writer

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

func NewWriter

func NewWriter(w io.Writer, conf ...WriterConf) *Writer

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) Closed

func (w *Writer) Closed() bool

func (*Writer) Write

func (w *Writer) Write(p *av.Packet) error

type WriterConf

type WriterConf func(*Writer)

func WithWriterBuffer

func WithWriterBuffer(size int) WriterConf