utils

Apr 8, 2024

Changes in this version

+ var BigEndian bigEndian

+ var LittleEndian littleEndian

+ func BigLittleSwap(v uint) uint

+ func GetUev(buff []byte, start int) (value int, pos int)

Apr 7, 2024

Changes in this version

+ const AAC

+ const AAC_LOW

+ const G711A

+ const G7221AUDIOTYPE

+ const G7231AUDIOTYPE

+ const G729AUDIOTYPE

+ const HaiKangCode

+ const LocalCache

+ const MAPHeaderLength

+ const MAXFrameLen

+ const MEPGProgramEndCode

+ const MaxRtpDiff

+ const PESHeaderLength

+ const PESLoadLength

+ const PSHeaderLength

+ const RTPHeaderLength

+ const RtpLoadLength

+ const StartCodeAudio

+ const StartCodeMAP

+ const StartCodePS

+ const StartCodeSYS

+ const StartCodeVideo

+ const StreamIDAudio

+ const StreamIDVideo

+ const StreamTypeH264

+ const StreamTypeH265

+ const SystemHeaderLength

+ const TCPTransferActive

+ const TCPTransferPassive

+ const UDPTransfer

+ var ErrFormatPack = errors.New("not package standard")

+ var ErrMarkerBit = errors.New("marker bit value error")

+ var ErrNotFoundStartCode = errors.New("not found the need start code flag")

+ var ErrParsePakcet = errors.New("parse ps packet error")

+ var ErrTooLarge = errors.New("IOBuffer: too large")

+ func DecodeGbk(v interface{}, body []byte) error

+ func GbkToUtf8(s []byte) ([]byte, error)

+ func Get() *bytes.Buffer

+ func NewError(err error, params ...interface{}) error

+ func PrintStack()

+ func Put(b *bytes.Buffer)

+ func RandNum16String(n int) string

+ func RandNumString(n int) string

+ func RandString(n int) string

+ func ResolveSelfIP() (net.IP, error)

+ func ToJSONString(v interface{}) string

+ func ToPrettyString(v interface{}) string

+ type DecPSPackage struct

+ AudioStreamType uint32

+ DTS uint32

+ PTS uint32

+ Payload []byte

+ VideoStreamType uint32

+ func (dec *DecPSPackage) Read(ts uint32, pusher Pusher) error

+ func (dec *DecPSPackage) ReadPayload() (payload []byte, err error)

+ type Error struct

+ func (err *Error) Error() string

+ type IOBuffer struct

+ InitialBufferSize int

+ MaxBufSize int

+ func (b *IOBuffer) Len() int

+ func (b *IOBuffer) Next(n int) []byte

+ func (b *IOBuffer) ReadByte() (byte, error)

+ func (b *IOBuffer) ReadN(length int) ([]byte, error)

+ func (b *IOBuffer) Reset()

+ func (b *IOBuffer) Skip(n int) (err error)

+ func (b *IOBuffer) Uint16() (uint16, error)

+ func (b *IOBuffer) Uint32() (uint32, error)

+ func (b *IOBuffer) Write(p []byte) (n int, err error)

+ type Pool struct

+ func (p *Pool) Get() *bytes.Buffer

+ func (p *Pool) Put(b *bytes.Buffer)

+ type PriorityQueueRtp struct

+ func NewPqRtp() *PriorityQueueRtp

+ func (p *PriorityQueueRtp) Empty()

+ func (p *PriorityQueueRtp) Len() int

+ func (p *PriorityQueueRtp) Pop() (rtp.Packet, error)

+ func (p *PriorityQueueRtp) Push(v rtp.Packet)

+ type Pusher interface

+ PushAudio func(uint32, []byte)

+ PushVideo func(uint32, uint32, []byte)