Versions in this module Expand all Collapse all v1 v1.0.3 Oct 14, 2021 v1.0.2 Oct 12, 2021 Changes in this version + const TS_PACKET_LENGTH + const TS_SECTION_BUFSIZE + func MangleValue(value string) string + func MatchesValue(input string, value interface{}, prefix string) bool + func NewEIT(tid mutablehome.DVBTableType, r *TSReader) (section mutablehome.DVBSection, err error) + func NewNIT(tid mutablehome.DVBTableType, r *TSReader) (section mutablehome.DVBSection, err error) + func NewPAT(tid mutablehome.DVBTableType, r *TSReader) (section mutablehome.DVBSection, err error) + func NewPMT(tid mutablehome.DVBTableType, r *TSReader) (section mutablehome.DVBSection, err error) + func NewSDT(tid mutablehome.DVBTableType, r *TSReader) (section mutablehome.DVBSection, err error) + func NewSectionEvent(source gopi.Unit, filter mutablehome.DVBFilter, section mutablehome.DVBSection) mutablehome.DVBSectionEvent + func TSRead(fd uintptr) (mutablehome.DVBSection, error) + type Demux struct + Adapter uint + Bus gopi.Bus + Demux uint + FilePoll gopi.FilePoll + Frontend mutablehome.DVBFrontend + func (Demux) Name() string + func (config Demux) New(log gopi.Logger) (gopi.Unit, error) + type Event struct + Descriptors []*RowDescriptor + Duration time.Duration + Id uint16 + Scrambled bool + Start time.Time + Status uint8 + func (this *Event) String() string + type Filter struct + func (this *Filter) AddPid(pid uint16) error + func (this *Filter) AddPids(pids []uint16) error + func (this *Filter) Close() error + func (this *Filter) Fd() uintptr + func (this *Filter) RemovePid(pid uint16) error + func (this *Filter) SetBufferSize(size uint32) error + func (this *Filter) Start() error + func (this *Filter) Stop() error + type Frontend struct + Adapter uint + Frontend uint + func (Frontend) Name() string + func (config Frontend) New(log gopi.Logger) (gopi.Unit, error) + type NITStream struct + Descriptors []*RowDescriptor + NetworkId uint16 + Pid uint16 + func (this *NITStream) String() string + type PMTStream struct + Descriptors []*RowDescriptor + Length uint16 + Pid uint16 + Type mutablehome.DVBStreamType + func (this *PMTStream) String() string + type Program struct + Pid uint16 + Program uint16 + func (this *Program) String() string + type RowDescriptor struct + Data []byte + Length uint8 + Tag uint8 + func NewDescriptors(r *TSReader) []*RowDescriptor + func (this *RowDescriptor) String() string + type SectionEIT struct + CRC []byte + Events []*Event + LastSection uint8 + LastTable uint8 + NetworkId uint16 + StreamId uint16 + func (this *SectionEIT) String() string + type SectionFilter struct + func NewSectionFilter(adapter, demux uint, pid uint16, tid home.DVBTableType) (*SectionFilter, error) + type SectionHeader struct + Current bool + LastSection uint8 + Section uint8 + ServiceId uint16 + TableId mutablehome.DVBTableType + Version uint8 + func NewHeader(tableId mutablehome.DVBTableType, r *TSReader) SectionHeader + func (this *SectionHeader) String() string + func (this *SectionHeader) Type() mutablehome.DVBTableType + type SectionNIT struct + CRC []byte + Descriptors []*RowDescriptor + Streams []*NITStream + func (this *SectionNIT) String() string + type SectionPAT struct + CRC []byte + Programs []*Program + func (this *SectionPAT) String() string + type SectionPMT struct + CRC []byte + ClockPid uint16 + Descriptors []*RowDescriptor + Streams []*PMTStream + func (this *SectionPMT) String() string + type SectionSDT struct + CRC []byte + NetworkId uint16 + Services []*Service + func (this *SectionSDT) String() string + type Service struct + Descriptors []*RowDescriptor + EITFollowing bool + EITSchedule bool + Id uint16 + Scrambled bool + Status uint8 + func (this *Service) String() string + type StreamFilter struct + func NewStreamFilter(adapter, demux uint, pid uint16, in dvb.DMXInput, out dvb.DMXOutput, ...) (*StreamFilter, error) + type TSReader struct + func NewTSReader(buf []byte) *TSReader + func NewTSReaderRead(fd uintptr, capacity int) (*TSReader, error) + func (this *TSReader) Bytes(sz int) (v []byte) + func (this *TSReader) DateTime() time.Time + func (this *TSReader) Duration() time.Duration + func (this *TSReader) IsEOF() bool + func (this *TSReader) SetLength(len int) + func (this *TSReader) Size() int + func (this *TSReader) String() string + func (this *TSReader) Uint16() (v uint16) + func (this *TSReader) Uint8() (v uint8) + type Table struct + Path string + func (Table) Name() string + func (config Table) New(log gopi.Logger) (gopi.Unit, error)