Versions in this module Expand all Collapse all v2 v2.2.1 Feb 6, 2023 v2.2.0 Aug 19, 2022 Changes in this version + const NullPacketPid + const PacketSize + const SyncByte + var TestPatPacket = Packet + var TestPmtPacket = Packet + func ContainsAdaptationField(packet *Packet) bool + func ContainsPayload(packet *Packet) bool + func ContinuityCounter(packet *Packet) uint8 + func Equal(a, b *Packet) bool + func Header(packet *Packet) []byte + func IsNull(packet *Packet) bool + func IsPat(packet *Packet) bool + func IsSynced(r Peeker) (ok bool, err error) + func PESHeader(packet *Packet) ([]byte, error) + func Payload(packet *Packet) ([]byte, error) + func PayloadUnitStartIndicator(packet *Packet) bool + func Pid(packet *Packet) int + func SetPayload(pkt *Packet, pay []byte) int + func Sync(r PeekScanner) (off int64, err error) + func WithAFPrivateDataFlag(pkt *Packet) + func WithContinuousAF(pkt *Packet) + func WithDiscontinuousAF(pkt *Packet) + func WithHasAdaptationFieldFlag(pkt *Packet) + func WithHasPayloadFlag(pkt *Packet) + func WithPES(pkt *Packet, pts uint64) + func WithPUSI(pkt *Packet) + type Accumulator interface + Bytes func() []byte + Packets func() []*Packet + Reset func() + WritePacket func(*Packet) (int, error) + func NewAccumulator(f func(data []byte) (done bool, err error)) Accumulator + type AdaptationField Packet + func NewAdaptationField() *AdaptationField + func (af *AdaptationField) AdaptationFieldExtension() ([]byte, error) + func (af *AdaptationField) Discontinuity() (bool, error) + func (af *AdaptationField) ElementaryStreamPriority() (bool, error) + func (af *AdaptationField) HasAdaptationFieldExtension() (bool, error) + func (af *AdaptationField) HasOPCR() (bool, error) + func (af *AdaptationField) HasPCR() (bool, error) + func (af *AdaptationField) HasSplicingPoint() (bool, error) + func (af *AdaptationField) HasTransportPrivateData() (bool, error) + func (af *AdaptationField) Length() int + func (af *AdaptationField) OPCR() (uint64, error) + func (af *AdaptationField) PCR() (uint64, error) + func (af *AdaptationField) RandomAccess() (bool, error) + func (af *AdaptationField) SetAdaptationFieldExtension(data []byte) error + func (af *AdaptationField) SetDiscontinuity(value bool) error + func (af *AdaptationField) SetElementaryStreamPriority(value bool) error + func (af *AdaptationField) SetHasAdaptationFieldExtension(value bool) error + func (af *AdaptationField) SetHasOPCR(value bool) error + func (af *AdaptationField) SetHasPCR(value bool) error + func (af *AdaptationField) SetHasSplicingPoint(value bool) error + func (af *AdaptationField) SetHasTransportPrivateData(value bool) error + func (af *AdaptationField) SetOPCR(PCR uint64) error + func (af *AdaptationField) SetPCR(PCR uint64) error + func (af *AdaptationField) SetRandomAccess(value bool) error + func (af *AdaptationField) SetSpliceCountdown(value byte) error + func (af *AdaptationField) SetTransportPrivateData(data []byte) error + func (af *AdaptationField) SpliceCountdown() (int, error) + func (af *AdaptationField) TransportPrivateData() ([]byte, error) + type AdaptationFieldControlOptions byte + const AdaptationFieldFlag + const PayloadAndAdaptationFieldFlag + const PayloadFlag + type Packet [PacketSize]byte + func CopyPackets(packets []*Packet) []*Packet + func Create(pid int, options ...func(*Packet)) *Packet + func CreateDCPacket(pid int, cc uint8) *Packet + func CreatePacketWithPayload(pid int, cc uint8, pay []byte) *Packet + func CreateTestPacket(pid int, cc uint8, pusi, hasPay bool) *Packet + func FromBytes(bytes []byte) (*Packet, error) + func IncrementCC(packet *Packet) *Packet + func New() *Packet + func SetCC(packet *Packet, newCC uint8) *Packet + func ZeroCC(packet *Packet) *Packet + func (p *Packet) AdaptationField() (*AdaptationField, error) + func (p *Packet) AdaptationFieldControl() AdaptationFieldControlOptions + func (p *Packet) CheckErrors() error + func (p *Packet) ContinuityCounter() int + func (p *Packet) Equals(r *Packet) bool + func (p *Packet) HasAdaptationField() bool + func (p *Packet) HasPayload() bool + func (p *Packet) IncContinuityCounter() + func (p *Packet) IsNull() bool + func (p *Packet) IsPAT() bool + func (p *Packet) PID() int + func (p *Packet) Payload() ([]byte, error) + func (p *Packet) PayloadUnitStartIndicator() bool + func (p *Packet) SetAdaptationField(af *AdaptationField) error + func (p *Packet) SetAdaptationFieldControl(value AdaptationFieldControlOptions) error + func (p *Packet) SetContinuityCounter(value int) + func (p *Packet) SetPID(pid int) + func (p *Packet) SetPayload(data []byte) (int, error) + func (p *Packet) SetPayloadUnitStartIndicator(value bool) + func (p *Packet) SetTransportErrorIndicator(value bool) + func (p *Packet) SetTransportPriority(value bool) + func (p *Packet) SetTransportScramblingControl(value TransportScramblingControlOptions) + func (p *Packet) TransportErrorIndicator() bool + func (p *Packet) TransportPriority() bool + func (p *Packet) TransportScramblingControl() TransportScramblingControlOptions + func (p *Packet) ZeroContinuityCounter() + type PacketWriteCloser interface + func NopCloser(r PacketWriter) PacketWriteCloser + type PacketWriter interface + WritePacket func(p *Packet) (n int, err error) + type PacketWriterFunc func(*Packet) (int, error) + func (f PacketWriterFunc) WritePacket(p *Packet) (n int, err error) + type PeekScanner interface + type Peeker interface + Peek func(n int) ([]byte, error) + type TransportScramblingControlOptions byte + const NoScrambleFlag + const ScrambleEvenKeyFlag + const ScrambleOddKeyFlag + type WriteCloser interface + func IOWriteCloser(w PacketWriteCloser) WriteCloser + type Writer interface + func IOWriter(w PacketWriter) Writer Other modules containing this package github.com/Comcast/gots