tsio

Documentation

Index

• Constants
• Variables
• func FillPESHeader(h []byte, streamid uint8, datalen int, pts, dts time.Duration) (n int)
• func FillPSI(h []byte, tableid uint8, tableext uint16, datalen int) (n int)
• func PCRToTime(pcr uint64) (tm time.Duration)
• func ParsePESHeader(h []byte) (hdrlen int, streamid uint8, datalen int, pts, dts time.Duration, err error)
• func ParsePSI(h []byte) (tableid uint8, tableext uint16, hdrlen int, datalen int, err error)
• func ParseTSHeader(tshdr []byte) (pid uint16, start bool, iskeyframe bool, hdrlen int, err error)
• func TimeToPCR(tm time.Duration) (pcr uint64)
• func TimeToTs(tm time.Duration) (v uint64)
• func TsToTime(v uint64) (tm time.Duration)
• type Descriptor
• type ElementaryStreamInfo
• type PAT
  • func (self PAT) Len() (n int)
  • func (self PAT) Marshal(b []byte) (n int)
  • func (self *PAT) Unmarshal(b []byte) (n int, err error)
• type PATEntry
• type PMT
  • func (self PMT) Len() (n int)
  • func (self PMT) Marshal(b []byte) (n int)
  • func (self *PMT) Unmarshal(b []byte) (n int, err error)
• type TSWriter
  • func NewTSWriter(pid uint16) *TSWriter
  • func (self *TSWriter) WritePackets(w io.Writer, datav [][]byte, pcr time.Duration, sync bool, paddata bool) (err error)

Constants

const (
	StreamIdH264 = 0xe0
	StreamIdAAC  = 0xc0
	StreamIDOpus = 0xc1
)

const (
	PAT_PID = 0
	PMT_PID = 0x1000
)

const (
	ElementaryStreamTypeTabled  = 0x06
	ElementaryStreamTypeH264    = 0x1B
	ElementaryStreamTypeAdtsAAC = 0x0F
)

const (
	PTS_HZ = 90000
	PCR_HZ = 27000000
)

const MaxPESHeaderLength = 19

const MaxTSHeaderLength = 12

const PSIHeaderLength = 9

const StreamTagOpus = 0x4f707573

const TableExtPAT = 1

const TableExtPMT = 1

const TableIdPAT = 0

const TableIdPMT = 2

const TagPrivateRegistration = 0x05

Variables

var ErrPESHeader = fmt.Errorf("invalid PES header")

var ErrPSIHeader = fmt.Errorf("invalid PSI header")

var ErrParsePAT = fmt.Errorf("invalid PAT")

var ErrParsePMT = fmt.Errorf("invalid PMT")

Functions

func FillPESHeader

func FillPESHeader(h []byte, streamid uint8, datalen int, pts, dts time.Duration) (n int)

func FillPSI

func FillPSI(h []byte, tableid uint8, tableext uint16, datalen int) (n int)

func PCRToTime

func PCRToTime(pcr uint64) (tm time.Duration)

func ParsePESHeader

func ParsePESHeader(h []byte) (hdrlen int, streamid uint8, datalen int, pts, dts time.Duration, err error)

func ParsePSI

func ParsePSI(h []byte) (tableid uint8, tableext uint16, hdrlen int, datalen int, err error)

func ParseTSHeader

func ParseTSHeader(tshdr []byte) (pid uint16, start bool, iskeyframe bool, hdrlen int, err error)

func TimeToPCR

func TimeToPCR(tm time.Duration) (pcr uint64)

func TimeToTs

func TimeToTs(tm time.Duration) (v uint64)

func TsToTime

func TsToTime(v uint64) (tm time.Duration)

Types

type Descriptor

type Descriptor struct {
	Tag  uint8
	Data []byte
}

type ElementaryStreamInfo

type ElementaryStreamInfo struct {
	StreamType    uint8
	ElementaryPID uint16
	Descriptors   []Descriptor
}

type PAT

type PAT struct {
	Entries []PATEntry
}

func (PAT) Len

func (self PAT) Len() (n int)

func (PAT) Marshal

func (self PAT) Marshal(b []byte) (n int)

func (*PAT) Unmarshal

func (self *PAT) Unmarshal(b []byte) (n int, err error)

type PATEntry

type PATEntry struct {
	ProgramNumber uint16
	NetworkPID    uint16
	ProgramMapPID uint16
}

type PMT

type PMT struct {
	PCRPID                uint16
	ProgramDescriptors    []Descriptor
	ElementaryStreamInfos []ElementaryStreamInfo
}

func (PMT) Len

func (self PMT) Len() (n int)

func (PMT) Marshal

func (self PMT) Marshal(b []byte) (n int)

func (*PMT) Unmarshal

func (self *PMT) Unmarshal(b []byte) (n int, err error)

type TSWriter

type TSWriter struct {
	ContinuityCounter uint
	// contains filtered or unexported fields
}

func NewTSWriter

func NewTSWriter(pid uint16) *TSWriter

func (*TSWriter) WritePackets

func (self *TSWriter) WritePackets(w io.Writer, datav [][]byte, pcr time.Duration, sync bool, paddata bool) (err error)