Versions in this module Expand all Collapse all v4 v4.15.3 Apr 23, 2024 v4.15.2 Apr 23, 2024 Changes in this version + func SplitAnnexB[T ~[]byte](frame T, process func(T), delimiter []byte) + type AVFrame struct + ADTS util.LIBP + AUList util.BLLs + AVCC util.BLL + DTS time.Duration + IFrame bool + PTS time.Duration + RTP util.List[RTPFrame] + Timestamp time.Duration + func NewAVFrame() *AVFrame + func (av *AVFrame) Assign(source *AVFrame) + func (av *AVFrame) Reset() + func (av *AVFrame) WriteAVCC(ts uint32, frame *util.BLL) + type AVTrack interface + Attach func() + CurrentFrame func() *AVFrame + Detach func() + Flush func() + GetFromPool func(util.IBytes) util.LIBP + GetRTPFromPool func() *LIRTP + PreFrame func() *AVFrame + SetSpeedLimit func(time.Duration) + WriteAVCC func(ts uint32, frame *util.BLL) error + WriteRTP func(*LIRTP) + WriteRTPPack func(*rtp.Packet) + WriteSequenceHead func(sh []byte) error + type AudioTrack interface + GetCodec func() codec.AudioCodecID + Narrow func() + WriteADTS func(uint32, util.IBytes) + WriteRawBytes func(uint32, util.IBytes) + type DataFrame struct + BytesIn int + CanRead bool + Data T + DeltaTime uint32 + Sequence uint32 + WriteTime time.Time + func NewDataFrame[T any]() *DataFrame[T] + func (df *DataFrame[T]) Discard() int32 + func (df *DataFrame[T]) GetSequence() uint32 + func (df *DataFrame[T]) Init() + func (df *DataFrame[T]) IsDiscarded() bool + func (df *DataFrame[T]) IsWriting() bool + func (df *DataFrame[T]) ReaderCount() int32 + func (df *DataFrame[T]) ReaderEnter() int32 + func (df *DataFrame[T]) ReaderLeave() int32 + func (df *DataFrame[T]) Ready() + func (df *DataFrame[T]) Reset() + func (df *DataFrame[T]) SetSequence(sequence uint32) + func (df *DataFrame[T]) StartWrite() bool + type IIO interface + GetStream func() IStream + IsClosed func() bool + IsShutdown func() bool + OnEvent func(any) + SetIO func(any) + SetLogger func(*log.Logger) + SetParentCtx func(context.Context) + Stop func(reason ...zapcore.Field) + type IPuber interface + GetAudioTrack func() AudioTrack + GetConfig func() *config.Publish + GetVideoTrack func() VideoTrack + Publish func(streamPath string, pub IPuber) error + type IStream interface + AddTrack func(Track) *util.Promise[Track] + Close func() + GetPublisherConfig func() *config.Publish + GetStartTime func() time.Time + GetType func() string + IsClosed func() bool + Receive func(any) bool + RemoveTrack func(Track) + SSRC func() uint32 + SetIDR func(Track) + type LIRTP = util.ListItem[RTPFrame] + type ParamaterSets [][]byte + func (v ParamaterSets) GetAnnexB() (r net.Buffers) + func (v ParamaterSets) WriteAnnexBTo(w io.Writer) (n int, err error) + type RTPFrame struct + Raw []byte + func (r *RTPFrame) H264Type() (naluType codec.H264NALUType) + func (r *RTPFrame) H265Type() (naluType codec.H265NALUType) + func (r *RTPFrame) Unmarshal(raw []byte) *RTPFrame + type TimelineData struct + Timestamp time.Time + Value T + type Track interface + Dispose func() + GetBPS func() int + GetDrops func() int + GetFPS func() int + GetName func() string + GetPublisher func() IPuber + GetRBSize func() int + GetReaderCount func() int32 + LastWriteTime func() time.Time + SetStuff func(stuff ...any) + SnapForJson func() + type TrackState byte + const TrackStateOffline + const TrackStateOnline + type VideoTrack interface + GetCodec func() codec.VideoCodecID + SetLostFlag func() + WriteAnnexB func(uint32, uint32, []byte) + WriteNalu func(uint32, uint32, []byte) + WriteSliceBytes func(slice []byte)
Go to main page