Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mpegps

package

Go to main page

Versions in this module

v0

v0.3.3

Aug 6, 2024

Changes in this version

+ const CodecH264

+ const CodecH265

+ const CodecH266

+ const CodecMpeg4

+ const CodecUnknown

+ var H264AudNalu []byte = []byte

+ var H265AudNalu []byte = []byte

type CommonPesPacket

+ PesPacketLength uint16

+ StreamId uint8

+ type ElementaryStream struct

+ PStdBufferBoundScale uint8

+ PStdBufferSizeBound uint16

+ StreamId uint8

+ func NewElementaryStream(sid uint8) *ElementaryStream

+ type ElementaryStreamElem struct

+ ElementaryStreamId uint8

+ ElementaryStreamInfoLength uint16

+ StreamType uint8

+ func NewElementaryStreamElem(stype uint8, esid uint8) *ElementaryStreamElem

type PesPacket

+ AdditionalCopyInfo uint8

+ AdditionalCopyInfoFlag uint8

+ DataAlignmentIndicator uint8

+ DsmTrickModeFlag uint8

+ EsRate uint32

+ EsRateFlag uint8

+ EscrBase uint64

+ EscrExtension uint16

+ EscrFlag uint8

+ OriginalOrCopy uint8

+ PesCrcFlag uint8

+ PesExtensionFlag uint8

+ PesHeaderDataLength uint8

+ PesPacketLength uint16

+ PesPayload []byte

+ PesPriority uint8

+ PesScramblingControl uint8

+ PreviousPesPacketCrc uint16

+ PtsDtsFlags uint8

+ StreamId uint8

+ TrickModeControl uint8

+ TrickValue uint8

+ type PesStreamId int

+ const PesStreamAudio

+ const PesStreamEnd

+ const PesStreamMap

+ const PesStreamPrivate

+ const PesStreamStart

+ const PesStreamSystemHead

+ const PesStreamVideo

+ type ProgramStreamDirectory struct

+ PesPacketLength uint16

+ func (psd *ProgramStreamDirectory) Decode(bs *BitStream) error

+ type ProgramStreamMap struct

+ CurrentNextIndicator uint8

+ ElementaryStreamMapLength uint16

+ MapStreamId uint8

+ ProgramStreamInfoLength uint16

+ ProgramStreamMapLength uint16

+ ProgramStreamMapVersion uint8

+ StreamMap []*ElementaryStreamElem

+ func (psm *ProgramStreamMap) Decode(bs *BitStream) error

+ func (psm *ProgramStreamMap) Encode(bsw *BitStreamWriter)

+ func (psm *ProgramStreamMap) PrettyPrint(file *os.File)

+ type PsDemuxer struct

+ OnFrame func(frame []byte, cid PsStreamType, pts uint64, dts uint64)

+ OnPacket func(pkg Display, decodeResult error)

+ func NewPsDemuxer() *PsDemuxer

+ func (psDemuxer *PsDemuxer) Flush()

+ func (psDemuxer *PsDemuxer) Input(data []byte) error

+ type PsMuxer struct

+ OnPacket func(pkg []byte, pts uint64)

+ func (muxer *PsMuxer) AddStream(cid PsStreamType) uint8

+ func (muxer *PsMuxer) Write(sid uint8, frame []byte, pts uint64, dts uint64) error

+ type PsPackHeader struct

+ IsMpeg1 bool

+ PackStuffingLength uint8

+ ProgramMuxRate uint32

+ SystemClockReferenceBase uint64

+ SystemClockReferenceExtension uint16

+ func (psPackHeader *PsPackHeader) Decode(bs *BitStream) error

+ func (psPackHeader *PsPackHeader) Encode(bsw *BitStreamWriter)

+ func (psPackHeader *PsPackHeader) PrettyPrint(file *os.File)

+ type PsPacket struct

+ CommPes *CommonPesPacket

+ Header *PsPackHeader

+ Pes *PesPacket

+ Psd *ProgramStreamDirectory

+ Psm *ProgramStreamMap

+ System *SystemHeader

+ type PsStreamType int

+ const PsStreamAac

+ const PsStreamG711A

+ const PsStreamG711U

+ const PsStreamH264

+ const PsStreamH265

+ const PsStreamUnknow

+ type StartCodeType int

+ const STartCode4

+ const StartCode3

+ type SystemHeader struct

+ AudioBound uint8

+ CspsFlag uint8

+ FixedFlag uint8

+ HeaderLength uint16

+ PacketRateRestrictionFlag uint8

+ RateBound uint32

+ Streams []*ElementaryStream

+ SystemAudioLockFlag uint8

+ SystemVideoLockFlag uint8

+ VideoBound uint8

+ func (sh *SystemHeader) Decode(bs *BitStream) error

+ func (sh *SystemHeader) Encode(bsw *BitStreamWriter)

+ func (sh *SystemHeader) PrettyPrint(file *os.File)

+ type TsStreamType int

+ const TsStreamAac

+ const TsStreamAudioMpeg1

+ const TsStreamAudioMpeg2

+ const TsStreamH264

+ const TsStreamH265

v0.3.2

May 11, 2024

Changes in this version

+ const MaxPesLen

+ const MaxPesPayloadLen

+ const PesHeaderLen

+ const PsHeaderlen

+ const PsPackStartCodeAudioStream

+ const PsPackStartCodeHikStream

+ const PsPackStartCodePackEnd

+ const PsPackStartCodePackHeader

+ const PsPackStartCodePesEcm

+ const PsPackStartCodePesEmm

+ const PsPackStartCodePesPadding

+ const PsPackStartCodePesPrivate2

+ const PsPackStartCodePesPsd

+ const PsPackStartCodeProgramStreamMap

+ const PsPackStartCodeSystemHeader

+ const PsPackStartCodeVideoStream

+ const StreamIdAudio

+ const StreamIdVideo

+ const StreamTypeAAC

+ const StreamTypeG711A

+ const StreamTypeG7221

+ const StreamTypeG7231

+ const StreamTypeG729

+ const StreamTypeH264

+ const StreamTypeH265

+ const StreamTypeUnknown

+ const SysHeaderlen

+ const SysMapHeaderLen

+ var BitMask [8]byte = [8]byte

+ var ErrGb28181 = errors.New("tops.gb28181: fxxk")

+ var H264_AUD_NALU []byte = []byte

+ var H265_AUD_NALU []byte = []byte

+ func CalcCrc32(crc uint32, buffer []byte) uint32

+ func H264NaluType(h264 []byte) uint8

+ func H265NaluType(h265 []byte) uint8

+ func SplitFrame(frames []byte, onFrame func(nalu []byte) bool)

+ type BitStream struct

+ func NewBitStream(buf []byte) *BitStream

+ func (bs *BitStream) Bits() []byte

+ func (bs *BitStream) ByteOffset() int

+ func (bs *BitStream) DistanceFromMarkDot() int

+ func (bs *BitStream) EOS() bool

+ func (bs *BitStream) GetBit() uint8

+ func (bs *BitStream) GetBits(n int) uint64

+ func (bs *BitStream) GetBytes(n int) []byte

+ func (bs *BitStream) Markdot()

+ func (bs *BitStream) NextBits(n int) uint64

+ func (bs *BitStream) ReadSE() int64

+ func (bs *BitStream) ReadUE() uint64

+ func (bs *BitStream) RemainBits() int

+ func (bs *BitStream) RemainBytes() int

+ func (bs *BitStream) RemainData() []byte

+ func (bs *BitStream) SkipBits(n int)

+ func (bs *BitStream) Uint16(n int) uint16

+ func (bs *BitStream) Uint32(n int) uint32

+ func (bs *BitStream) Uint8(n int) uint8

+ func (bs *BitStream) UnRead(n int)

+ type BitStreamWriter struct

+ func NewBitStreamWriter(n int) *BitStreamWriter

+ func (bsw *BitStreamWriter) BitOffset() int

+ func (bsw *BitStreamWriter) Bits() []byte

+ func (bsw *BitStreamWriter) ByteOffset() int

+ func (bsw *BitStreamWriter) DistanceFromMarkDot() int

+ func (bsw *BitStreamWriter) FillRemainData(v byte)

+ func (bsw *BitStreamWriter) Markdot()

+ func (bsw *BitStreamWriter) PutByte(v byte)

+ func (bsw *BitStreamWriter) PutBytes(v []byte)

+ func (bsw *BitStreamWriter) PutRepetValue(v byte, n int)

+ func (bsw *BitStreamWriter) PutUint16(v uint16, n int)

+ func (bsw *BitStreamWriter) PutUint32(v uint32, n int)

+ func (bsw *BitStreamWriter) PutUint64(v uint64, n int)

+ func (bsw *BitStreamWriter) PutUint8(v uint8, n int)

+ func (bsw *BitStreamWriter) Reset()

+ func (bsw *BitStreamWriter) SetByte(v byte, where int)

+ func (bsw *BitStreamWriter) SetUint16(v uint16, where int)

+ type CommonPesPacket struct

+ PES_packet_length uint16

+ Stream_id uint8

+ func (compes *CommonPesPacket) Decode(bs *BitStream) error

+ type Display interface

+ PrettyPrint func(file *os.File)

+ type Elementary_Stream struct

+ P_STD_buffer_bound_scale uint8

+ P_STD_buffer_size_bound uint16

+ Stream_id uint8

+ func NewElementary_Stream(sid uint8) *Elementary_Stream

+ type Elementary_stream_elem struct

+ Elementary_stream_id uint8

+ Elementary_stream_info_length uint16

+ Stream_type uint8

+ func NewElementary_stream_elem(stype uint8, esid uint8) *Elementary_stream_elem

+ type Error interface

+ NeedMore func() bool

+ ParserError func() bool

+ StreamIdNotFound func() bool

+ type PES_STREMA_ID int

+ const PES_STREAM_AUDIO

+ const PES_STREAM_END

+ const PES_STREAM_MAP

+ const PES_STREAM_PRIVATE

+ const PES_STREAM_START

+ const PES_STREAM_SYSTEM_HEAD

+ const PES_STREAM_VIDEO

+ type PSDemuxer struct

+ OnFrame func(frame []byte, cid PS_STREAM_TYPE, pts uint64, dts uint64)

+ OnPacket func(pkg Display, decodeResult error)

+ func NewPSDemuxer() *PSDemuxer

+ func (psdemuxer *PSDemuxer) Flush()

+ func (psdemuxer *PSDemuxer) Input(data []byte) error

+ type PSMuxer struct

+ OnPacket func(pkg []byte, pts uint64)

+ func NewPsMuxer() *PSMuxer

+ func (muxer *PSMuxer) AddStream(cid PS_STREAM_TYPE) uint8

+ func (muxer *PSMuxer) Write(sid uint8, frame []byte, pts uint64, dts uint64) error

+ type PSPackHeader struct

+ IsMpeg1 bool

+ Pack_stuffing_length uint8

+ Program_mux_rate uint32

+ System_clock_reference_base uint64

+ System_clock_reference_extension uint16

+ func (ps_pkg_hdr *PSPackHeader) Decode(bs *BitStream) error

+ func (ps_pkg_hdr *PSPackHeader) Encode(bsw *BitStreamWriter)

+ func (ps_pkg_hdr *PSPackHeader) PrettyPrint(file *os.File)

+ type PSPacket struct

+ CommPes *CommonPesPacket

+ Header *PSPackHeader

+ Pes *PesPacket

+ Psd *Program_stream_directory

+ Psm *Program_stream_map

+ System *System_header

+ type PS_STREAM_TYPE int

+ const PS_STREAM_AAC

+ const PS_STREAM_G711A

+ const PS_STREAM_G711U

+ const PS_STREAM_H264

+ const PS_STREAM_H265

+ const PS_STREAM_UNKNOW

+ type PesPacket struct

+ Additional_copy_info uint8

+ Additional_copy_info_flag uint8

+ Copyright uint8

+ DSM_trick_mode_flag uint8

+ Data_alignment_indicator uint8

+ Dts uint64

+ ESCR_base uint64

+ ESCR_extension uint16

+ ESCR_flag uint8

+ ES_rate uint32

+ ES_rate_flag uint8

+ Original_or_copy uint8

+ PES_CRC_flag uint8

+ PES_extension_flag uint8

+ PES_header_data_length uint8

+ PES_packet_length uint16

+ PES_priority uint8

+ PES_scrambling_control uint8

+ PTS_DTS_flags uint8

+ Pes_payload []byte

+ Previous_PES_packet_CRC uint16

+ Pts uint64

+ Stream_id uint8

+ Trick_mode_control uint8

+ Trick_value uint8

+ func NewPesPacket() *PesPacket

+ func (pkg *PesPacket) Decode(bs *BitStream) error

+ func (pkg *PesPacket) DecodeMpeg1(bs *BitStream) error

+ func (pkg *PesPacket) Encode(bsw *BitStreamWriter)

+ func (pkg *PesPacket) PrettyPrint(file *os.File)

+ type Program_stream_directory struct

+ PES_packet_length uint16

+ func (psd *Program_stream_directory) Decode(bs *BitStream) error

+ type Program_stream_map struct

+ Current_next_indicator uint8

+ Elementary_stream_map_length uint16

+ Map_stream_id uint8

+ Program_stream_info_length uint16

+ Program_stream_map_length uint16

+ Program_stream_map_version uint8

+ Stream_map []*Elementary_stream_elem

+ func (psm *Program_stream_map) Decode(bs *BitStream) error

+ func (psm *Program_stream_map) Encode(bsw *BitStreamWriter)

+ func (psm *Program_stream_map) PrettyPrint(file *os.File)

+ type START_CODE_TYPE int

+ const START_CODE_3

+ const START_CODE_4

+ func FindStartCode(nalu []byte, offset int) (int, START_CODE_TYPE)

+ type System_header struct

+ Audio_bound uint8

+ CSPS_flag uint8

+ Fixed_flag uint8

+ Header_length uint16

+ Packet_rate_restriction_flag uint8

+ Rate_bound uint32

+ Streams []*Elementary_Stream

+ System_audio_lock_flag uint8

+ System_video_lock_flag uint8

+ Video_bound uint8

+ func (sh *System_header) Decode(bs *BitStream) error

+ func (sh *System_header) Encode(bsw *BitStreamWriter)

+ func (sh *System_header) PrettyPrint(file *os.File)

+ type TS_STREAM_TYPE int

+ const TS_STREAM_AAC

+ const TS_STREAM_AUDIO_MPEG1

+ const TS_STREAM_AUDIO_MPEG2

+ const TS_STREAM_H264

+ const TS_STREAM_H265