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 (inst PAT) Len() (n int)
  • func (inst PAT) Marshal(b []byte) (n int)
  • func (inst *PAT) Unmarshal(b []byte) (n int, err error)
• type PATEntry
• type PMT
  • func (inst PMT) Len() (n int)
  • func (inst PMT) Marshal(b []byte) (n int)
  • func (inst *PMT) Unmarshal(b []byte) (n int, err error)
• type TSWriter
  • func NewTSWriter(pid uint16) *TSWriter
  • func (inst *TSWriter) WritePackets(w io.Writer, datav [][]byte, pcr time.Duration, sync bool, paddata bool) (err error)

Constants

const (
	// StreamIDH264 const
	StreamIDH264 = 0xe0
	// StreamIDAAC const
	StreamIDAAC = 0xc0
)

const (
	// PatPID const
	PatPID = 0
	// PmtPID const
	PmtPID = 0x1000
)

const (
	// ElementaryStreamTypeH264 const
	ElementaryStreamTypeH264 = 0x1B
	// ElementaryStreamTypeAdtsAAC const
	ElementaryStreamTypeAdtsAAC = 0x0F
)

const (
	// PtsHZ const
	PtsHZ = 90000
	// PcrHZ const
	PcrHZ = 27000000
)

const MaxPESHeaderLength = 19

MaxPESHeaderLength var

const MaxTSHeaderLength = 12

MaxTSHeaderLength var

const PSIHeaderLength = 9

PSIHeaderLength var

const TableExtPAT = 1

TableExtPAT var

const TableExtPMT = 1

TableExtPMT var

const TableIDPAT = 0

TableIDPAT var

const TableIDPMT = 2

TableIDPMT var

Variables

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

ErrPESHeader func

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

ErrPSIHeader func

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

ErrParsePAT func

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

ErrParsePMT func

Functions

func FillPESHeader

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

FillPESHeader func

func FillPSI

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

FillPSI func

func PCRToTime

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

PCRToTime func

func ParsePESHeader

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

ParsePESHeader func

func ParsePSI

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

ParsePSI func

func ParseTSHeader

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

ParseTSHeader func

func TimeToPCR

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

TimeToPCR func

func TimeToTs

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

TimeToTs func

func TsToTime

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

TsToTime func

Types

type Descriptor

type Descriptor struct {
	Tag  uint8
	Data []byte
}

Descriptor func

type ElementaryStreamInfo

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

ElementaryStreamInfo func

type PAT

type PAT struct {
	Entries []PATEntry
}

PAT func

func (PAT) Len

func (inst PAT) Len() (n int)

Len func

func (PAT) Marshal

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

Marshal func

func (*PAT) Unmarshal

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

Unmarshal func

type PATEntry

type PATEntry struct {
	ProgramNumber uint16
	NetworkPID    uint16
	ProgramMapPID uint16
}

PATEntry func

type PMT

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

PMT func

func (PMT) Len

func (inst PMT) Len() (n int)

Len func

func (PMT) Marshal

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

Marshal func

func (*PMT) Unmarshal

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

Unmarshal func

type TSWriter

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

TSWriter func

func NewTSWriter

func NewTSWriter(pid uint16) *TSWriter

NewTSWriter func

func (*TSWriter) WritePackets

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

WritePackets func