track

Feb 26, 2024

Changes in this version

type Audio

+ func (a *Audio) GetCodec() codec.AudioCodecID

type Base

+ DropCount int

+ Drops int

+ Publisher common.IPuber

+ RawPart []int

+ RawSize int

+ State common.TrackState

+ func (bt *Base[T, F]) Dispose()

+ func (bt *Base[T, F]) GetBPS() int

+ func (bt *Base[T, F]) GetDrops() int

+ func (bt *Base[T, F]) GetFPS() int

+ func (bt *Base[T, F]) GetPublisher() common.IPuber

+ func (bt *Base[T, F]) GetRBSize() int

+ func (bt *Base[T, F]) SetStuff(stuff ...any)

+ func (bt *Base[T, F]) SnapForJson()

type Media

+ BufferTime time.Duration

type Video

+ func (vt *Video) GetCodec() codec.VideoCodecID

Feb 20, 2024

Changes in this version

+ type Channel struct

+ func (r *Channel[T]) AddListener(c chan T)

+ func (r *Channel[T]) CreateReader(l int) chan T

+ func (r *Channel[T]) Write(data T)

Nov 17, 2023

Changes in this version

+ type AV1 struct

+ func NewAV1(stream IStream, stuff ...any) (vt *AV1)

+ func (vt *AV1) CompleteAVCC(rv *AVFrame)

+ func (vt *AV1) CompleteRTP(value *AVFrame)

+ func (vt *AV1) WriteRTPFrame(rtpItem *util.ListItem[RTPFrame])

+ func (vt *AV1) WriteSequenceHead(head []byte) (err error)

type Audio

+ func (av *Audio) WriteSequenceHead(sh []byte) error

type H264

+ func (vt *H264) WriteSequenceHead(head []byte) (err error)

type H265

+ func (vt *H265) CompleteAVCC(rv *AVFrame)

+ func (vt *H265) WriteSequenceHead(head []byte) (err error)

+ type Opus struct

+ func NewOpus(stream IStream, stuff ...any) (opus *Opus)

+ func (opus *Opus) CompleteRTP(value *AVFrame)

+ func (opus *Opus) WriteAVCC(ts uint32, frame *util.BLL) error

+ func (opus *Opus) WriteRTPFrame(rtpItem *util.ListItem[RTPFrame])

Aug 6, 2023

Changes in this version

type G711

+ func (g711 *G711) CompleteRTP(value *AVFrame)

Jul 14, 2023

Changes in this version

type AVRingReader

+ StartTs time.Duration

Jun 30, 2023

Changes in this version

+ var ErrDiscard = errors.New("dsicard")

type Data

+ func (dt *Data[T]) Init(n int)

+ type RingReader struct

+ Count int

+ func (r *RingReader[T, F]) Read(ring *util.Ring[F]) (err error)

+ func (r *RingReader[T, F]) ReadNext() (err error)

+ func (r *RingReader[T, F]) StartRead(ring *util.Ring[F]) (err error)

+ func (r *RingReader[T, F]) TryRead() (f F, err error)

Jun 17, 2023

Changes in this version

type H264

+ func (vt *H264) GetNALU_SEI() (item *util.ListItem[util.Buffer])

type H265

+ func (vt *H265) GetNALU_SEI() (item *util.ListItem[util.Buffer])

type SpesificTrack

+ GetNALU_SEI func() *util.ListItem[util.Buffer]

Jun 16, 2023

Changes in this version

+ type BytesData struct

+ Pool util.BytesPool

+ func NewBytesDataTrack(name string) (dt *BytesData)

type Data

+ func (d *Data[T]) Dispose()

+ type DataReader struct

+ Ctx context.Context

+ func (r *DataReader[T]) MoveNext()

+ func (r *DataReader[T]) Read() (item *common.DataFrame[T])

+ func (r *DataReader[T]) TryRead() (item *common.DataFrame[T])

type IDRingList

+ IDRList util.List[*util.Ring[AVFrame]]

type Media

+ func (av *Media) Dispose()

+ type RecycleData struct

+ func NewRecycleDataTrack(name string) (dt *RecycleData[T])

+ func (dt *RecycleData[T]) Push(data T)

type Video

+ SEIReader *DataReader[[]byte]

Jun 11, 2023

Changes in this version

+ type EmptyLocker struct

+ func (EmptyLocker) Lock()

+ func (EmptyLocker) Unlock()

Jun 4, 2023

Changes in this version

+ const SUBMODE_BUFFER

+ const SUBMODE_NOJUMP

+ const SUBMODE_REAL

May 25, 2023

Changes in this version

type Audio

+ func (av *Audio) WriteRawBytes(pts uint32, raw util.IBytes)

type Media

+ func (av *Media) GetFromPool(b util.IBytes) (item *util.ListItem[util.Buffer])

May 16, 2023

Changes in this version

+ type Custom interface

+ Dispose func()

type Data

+ func NewDataTrack(name string) (dt *Data[T])

May 14, 2023

Changes in this version

type AVRingReader

+ func NewAVRingReader(t *Media, poll time.Duration) *AVRingReader

Mar 28, 2023

Changes in this version

type Data

+ func (d *Data) GetRBSize() int

type Media

+ func (av *Media) GetRBSize() int

Mar 23, 2023

Changes in this version

type AVRingReader

+ Delay uint32

+ func (r *AVRingReader) GetDTS32() uint32

+ func (r *AVRingReader) GetPTS32() uint32

Mar 9, 2023

Changes in this version

type Video

+ func (vt *Video) WriteNalu(pts uint32, dts uint32, nalu []byte)

Mar 3, 2023

Changes in this version

type Audio

+ IndexDeltaLength int

+ IndexLength int

+ SizeLength int

Feb 26, 2023

Changes in this version

type Media

+ RtpPool util.Pool[RTPFrame]

+ func (av *Media) GetRTPFromPool() (result *util.ListItem[RTPFrame])

Feb 22, 2023

Changes in this version

type AVRingReader

+ func (r *AVRingReader) ResetAbsTime()

Feb 19, 2023

Changes in this version

type Media

+ func (av *Media) MpegTs2Ms(mpegTs uint32) uint32

+ func (av *Media) MpegTs2RTPTs(mpegTs uint32) uint32

+ func (av *Media) Ms2MpegTs(ms uint32) uint32

Feb 15, 2023

Changes in this version

type Data

+ func (d *Data) Attach()

Feb 8, 2023

Changes in this version

type AVRingReader

+ SkipRTPTs uint32

type Audio

+ SampleRate uint32

type Media

+ ClockRate uint32

+ func (av *Media) Ms2RTPTs(ms uint32) uint32

+ func (av *Media) RTPTs2Ms(rtpts uint32) uint32

Feb 3, 2023

Changes in this version

type AAC

+ SizeLength int

Feb 2, 2023

Changes in this version

+ const READSTATE_FIRST

+ const READSTATE_INIT

+ const READSTATE_NORMAL

+ const RTPMTU

type AAC

+ func (aac *AAC) WriteADTS(adts []byte)

+ func (aac *AAC) WriteSequenceHead(sh []byte)

+ type AVRingReader struct

+ AbsTime uint32

+ ConfSeq int

+ FirstSeq uint32

+ FirstTs uint32

+ Frame *common.AVFrame

+ Poll time.Duration

+ SkipTs uint32

+ State byte

+ Track *Media

+ func (r *AVRingReader) DecConfChanged() bool

+ func (r *AVRingReader) MoveNext()

+ func (r *AVRingReader) Read(ctx context.Context, mode int) (err error)

+ func (r *AVRingReader) ReadFrame() *common.AVFrame

+ func (r *AVRingReader) TryRead() (item *common.AVFrame)

type Audio

+ func (a *Audio) Narrow()

type H265

+ VPS []byte

+ type IDRingList struct

+ HistoryRing *util.Ring[AVFrame]

+ IDRing *util.Ring[AVFrame]

+ func (p *IDRingList) AddIDR(IDRing *util.Ring[AVFrame])

+ func (p *IDRingList) ShiftIDR()

type Media

+ BytesPool util.BytesPool

+ PayloadType byte

+ SequenceHead []byte

+ SequenceHeadSeq int

+ func (av *Media) AddIDR()

+ func (av *Media) AppendAuBytes(b ...[]byte)

+ func (av *Media) SnapForJson()

+ func (av *Media) WriteSequenceHead(sh []byte)

type SpesificTrack

+ WriteSequenceHead func([]byte)

type Video

+ PPS []byte

+ SPS []byte

+ func (vt *Video) WriteSequenceHead(sh []byte)

Jan 18, 2023

Changes in this version

type AAC

+ Mode int

+ func (aac *AAC) CompleteRTP(value *AVFrame[[]byte])

+ func (aac *AAC) WriteRTPFrame(frame *RTPFrame)

type Audio

+ func (a *Audio) CompleteAVCC(value *AVFrame[[]byte])

+ func (a *Audio) CompleteRTP(value *AVFrame[[]byte])

type G711

+ func (g711 *G711) WriteRTPFrame(frame *RTPFrame)

type H264

+ func (vt *H264) CompleteRTP(value *AVFrame[NALUSlice])

+ func (vt *H264) WriteRTPFrame(frame *RTPFrame)

+ func (vt *H264) WriteSliceBytes(slice []byte)

type H265

+ func (vt *H265) CompleteRTP(value *AVFrame[NALUSlice])

+ func (vt *H265) WriteRTPFrame(frame *RTPFrame)

+ func (vt *H265) WriteSliceBytes(slice []byte)

+ type SpesificTrack interface

+ CompleteAVCC func(*AVFrame[T])

+ CompleteRTP func(*AVFrame[T])

+ Flush func()

+ WriteRTPFrame func(*RTPFrame)

+ WriteSliceBytes func([]byte)

type Video

+ func (vt *Video) CompleteAVCC(rv *AVFrame[NALUSlice])

+ func (vt *Video) WriteRawBytes(slice []byte)

+ func (vt *Video) WriteSliceByte(b ...byte)

Dec 31, 2022

Changes in this version

type Media

+ func (av *Media[T]) SetStuff(stuff ...any)

+ func (av *Media[T]) WriteRTP(raw []byte)

+ func (av *Media[T]) WriteRTPPack(p *rtp.Packet)

+ type RTPWriter interface

Nov 22, 2022

Changes in this version

type Media

+ func (av *Media[T]) SetSpeedLimit(value int)

type Video

+ func (vt *Video) SetLostFlag()

Nov 13, 2022

Changes in this version

type Audio

+ func (av *Audio) WriteRaw(pts uint32, raw AudioSlice)

type Media

+ SSRC uint32

+ func (av *Media[T]) Init(n int)

Nov 4, 2022

Changes in this version

type Media

+ func (av *Media[T]) ComplementAVCC() bool

+ func (av *Media[T]) ComplementRTP() bool

+ type RTPDemuxer struct

+ type RTPMuxer struct

Oct 10, 2022

Changes in this version

type Audio

+ func (av *Audio) WriteAVCC(ts uint32, frame AVCCFrame)

Oct 2, 2022

Changes in this version

type Video

+ func (vt *Video) PlayFullAnnexB(ctx context.Context, onMedia func(net.Buffers) error) error

Jul 18, 2022

Changes in this version

type Audio

+ SampleSize byte

Jul 10, 2022

Changes in this version

type Audio

+ func (a *Audio) SnapForJson()

type Video

+ func (vt *Video) SnapForJson()

Jul 8, 2022

Changes in this version

type Audio

+ func (a *Audio) MarshalJSON() ([]byte, error)

type Media

+ RawPart []int

+ RawSize int

type Video

+ func (vt *Video) MarshalJSON() ([]byte, error)

May 16, 2022

Changes in this version

type Base

+ BPS int

+ FPS int

+ func (bt *Base) ComputeBPS(bytes int)

May 15, 2022

Changes in this version

+ type AAC struct

+ func NewAAC(stream IStream) (aac *AAC)

+ func (aac *AAC) Flush()

+ func (aac *AAC) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (aac *AAC) WriteRTP(raw []byte)

+ func (aac *AAC) WriteRTPPack(p *rtp.Packet)

+ type Audio struct

+ AVCCHead []byte

+ Channels byte

+ CodecID codec.AudioCodecID

+ Profile byte

+ func (a *Audio) Attach()

+ func (a *Audio) Detach()

+ func (a *Audio) Flush()

+ func (a *Audio) GetDecConfSeq() int

+ func (a *Audio) GetInfo() *Audio

+ func (a *Audio) GetName() string

+ func (a *Audio) IsAAC() bool

+ func (a *Audio) WriteADTS(adts []byte)

+ type Base struct

+ Name string

+ Stream IStream

+ func (bt *Base) Flush(bf *BaseFrame)

+ func (bt *Base) GetName() string

+ type Data struct

+ func (d *Data) LastWriteTime() time.Time

+ func (d *Data) Play(ctx context.Context, onData func(any) error) error

+ func (d *Data) ReadRing() *LockRing[any]

+ func (dt *Data) Push(data any)

+ type G711 struct

+ func NewG711(stream IStream, alaw bool) (g711 *G711)

+ func (g711 *G711) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (g711 *G711) WriteRTP(raw []byte)

+ func (g711 *G711) WriteRTPPack(p *rtp.Packet)

+ type H264 struct

+ func NewH264(stream IStream) (vt *H264)

+ func (vt *H264) Flush()

+ func (vt *H264) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (vt *H264) WriteAnnexB(pts uint32, dts uint32, frame AnnexBFrame)

+ func (vt *H264) WriteRTP(raw []byte)

+ func (vt *H264) WriteRTPPack(p *rtp.Packet)

+ func (vt *H264) WriteSlice(slice NALUSlice)

+ type H265 struct

+ func NewH265(stream IStream) (vt *H265)

+ func (vt *H265) Flush()

+ func (vt *H265) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (vt *H265) WriteAnnexB(pts uint32, dts uint32, frame AnnexBFrame)

+ func (vt *H265) WriteRTP(raw []byte)

+ func (vt *H265) WriteRTPPack(p *rtp.Packet)

+ func (vt *H265) WriteSlice(slice NALUSlice)

+ type Media struct

+ DecoderConfiguration DecoderConfiguration[T]

+ SampleRate uint32

+ SampleSize byte

+ func (av *Media[T]) CurrentFrame() *AVFrame[T]

+ func (av *Media[T]) Flush()

+ func (av *Media[T]) GetDecoderConfiguration() DecoderConfiguration[T]

+ func (av *Media[T]) LastWriteTime() time.Time

+ func (av *Media[T]) PacketizeRTP(payloads ...[]byte)

+ func (av *Media[T]) Play(ctx context.Context, onMedia func(*AVFrame[T]) error) error

+ func (av *Media[T]) PreFrame() *AVFrame[T]

+ func (av *Media[T]) ReadRing() *AVRing[T]

+ func (av *Media[T]) UnmarshalRTP(raw []byte) (frame *RTPFrame)

+ func (av *Media[T]) UnmarshalRTPPacket(p *rtp.Packet) (frame *RTPFrame)

+ func (av *Media[T]) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (av *Media[T]) WriteSlice(slice T)

+ type UnknowAudio struct

+ func (ua *UnknowAudio) Flush()

+ func (ua *UnknowAudio) GetName() string

+ func (ua *UnknowAudio) WriteAVCC(ts uint32, frame AVCCFrame)

+ type UnknowVideo struct

+ func (uv *UnknowVideo) Flush()

+ func (uv *UnknowVideo) GetName() string

+ func (vt *UnknowVideo) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (vt *UnknowVideo) WriteAnnexB(pts uint32, dts uint32, frame AnnexBFrame)

+ type Video struct

+ CodecID codec.VideoCodecID

+ GOP int

+ IDRing *util.Ring[AVFrame[NALUSlice]]

+ SPSInfo codec.SPSInfo

+ func (vt *Video) Attach()

+ func (vt *Video) ComputeGOP()

+ func (vt *Video) Detach()

+ func (vt *Video) Flush()

+ func (vt *Video) GetDecConfSeq() int

+ func (vt *Video) GetName() string

+ func (vt *Video) PacketizeRTP(payloads ...[]byte)

+ func (vt *Video) ReadRing() *AVRing[NALUSlice]

+ func (vt *Video) WriteAVCC(ts uint32, frame AVCCFrame)

+ func (vt *Video) WriteAnnexB(pts uint32, dts uint32, frame AnnexBFrame) (s []NALUSlice)