engine

May 8, 2022

Changes in this version

+ const HOOK_ONDEMAND_PUBLISH

+ func IsNewer(value uint16, prev_value uint16) bool

type Stream

+ AutoCloseDelay *int

+ func WaitStream(streamPath string, waitTimeout time.Duration) (s *Stream)

Feb 2, 2022

Changes in this version

type Stream

+ AppName string

+ StreamName string

Dec 27, 2021

Changes in this version

type Stream

+ URL string

Dec 26, 2021

Changes in this version

type PluginConfig

+ func (opt *PluginConfig) Install(run func())

+ func (opt *PluginConfig) Save() error

Nov 25, 2021

Changes in this version

+ func AddHookGo(name string, callback interface{})

type RingBuffer

+ func (r *RingBuffer) ReadLoopConditionalGo(handler interface{}, goon func() bool)

Nov 23, 2021

Changes in this version

+ type DTSEstimator struct

+ func NewDTSEstimator() *DTSEstimator

+ func (d *DTSEstimator) Feed(pts uint32) uint32

+ type RTPDemuxer struct

+ OnDemux func(uint32, []byte)

+ PTS uint32

+ Reorder bool

+ func (r *RTPDemuxer) Push(rtpRaw []byte)

Nov 16, 2021

Changes in this version

+ type B struct

+ MaxTS uint32

+ func (b *B) Pop() interface{}

+ func (b *B) Push(x interface{})

type RTPAudio

+ func (p *RTPAudio) Push(payload []byte)

type RTPNalu

+ PTS uint32

type RTPVideo

+ func (p *RTPVideo) Push(payload []byte)

type Stream

+ AutoCloseAfter *int

Nov 11, 2021

Changes in this version

type AVRing

+ func (r *AVRing) TryRead() (item *AVItem, value interface{})

Oct 13, 2021

Changes in this version

+ var Ctx context.Context

+ var StreamTimeoutError = errors.New("timeout")

type RingBuffer

+ Size int

+ type StreamContext struct

+ IsTimeout bool

+ func (r *StreamContext) Err() error

+ func (r *StreamContext) Update()

Aug 19, 2021

Changes in this version

type AVRing

+ func (r *AVRing) PreItem() *AVItem

Aug 10, 2021

Changes in this version

type AVItem

+ Sequence int

+ Timestamp uint32

+ func (p *AVItem) SetTs(ts uint32)

+ func (p *AVItem) Since(ts uint32) uint32

type AVPack

+ Payload []byte

+ func (pack *AVPack) Bytes2Payload()

+ type AVTrack struct

+ CodecID byte

+ func (t *AVTrack) GetBPS()

+ type BaseTrack struct

+ BPS int

+ PacketCount int

+ Stream *Stream

+ type DataItem struct

+ Sequence int

+ Timestamp time.Time

+ Value interface{}

+ type DataTrack struct

+ func (dt *DataTrack) Play(onData func(*DataItem), exit1, exit2 <-chan struct{})

+ func (dt *DataTrack) Push(data interface{})

+ func (t *DataTrack) GetBPS()

type RingBuffer

+ func (r *RingBuffer) Step()

type Stream

+ DataTracks Tracks

+ func (r *Stream) WaitDataTrack(names ...string) *DataTrack

+ func (s *Stream) NewDataTrack(l sync.Locker) (dt *DataTrack)

type VideoPack

+ func (v *VideoPack) ResetNALUs()

+ func (v *VideoPack) SetNalu0(nalu []byte)

Jul 29, 2021

Changes in this version

+ type AVItem struct

+ Value interface{}

+ type AVRing struct

+ func (r *AVRing) Current() *AVItem

+ func (r *AVRing) CurrentValue() interface{}

+ func (r *AVRing) GetNext() *AVItem

+ func (r *AVRing) Init(ctx context.Context, n int) *AVRing

+ func (r *AVRing) NextRead() interface{}

+ func (r *AVRing) NextValue() interface{}

+ func (r *AVRing) Read() interface{}

+ func (r *AVRing) ReadLoop(handler interface{})

+ func (r *AVRing) Step()

+ func (r *AVRing) Write(value interface{})

+ func (r AVRing) SubRing(rr *ring.Ring) *AVRing

+ func (rb AVRing) Clone() *AVRing

+ type LockItem struct

+ Value interface{}

type RingBuffer

+ Flag *int32

+ func (r *RingBuffer) Dispose()

Jul 24, 2021

Changes in this version

type StreamCollection

+ func (sc *StreamCollection) Range(f func(*Stream))

Jul 23, 2021

Changes in this version

+ type RTPNalu struct

+ Next *RTPNalu

+ Payload []byte

+ Ts uint32

Jul 18, 2021

Changes in this version

type Stream

+ OnClose func()

+ func Publish(streamPath, t string) *Stream

+ func (r *Stream) AddOnClose(onClose func())

Jul 16, 2021

Changes in this version

+ func AddHookConditional(name string, callback interface{}, goon func() bool)

type RingBuffer

+ func (r *RingBuffer) NextRead() interface{}

+ func (r *RingBuffer) ReadLoopConditional(handler interface{}, goon func() bool)

type Tracks

+ func (ts *Tracks) OnTrack(callback func(Track))

Jul 16, 2021

Changes in this version

type RingBuffer

+ func (r *RingBuffer) ReadLoop(handler interface{}, goon func() bool)

type RingDisposable

+ func (r *RingDisposable) Goon() bool

+ func (r *RingDisposable) ReadLoop(handler interface{})

+ func (r RingDisposable) SubRing(rr *ring.Ring) *RingDisposable

+ func (rb *RingDisposable) Init(n int)

+ func (rb RingDisposable) Clone() *RingDisposable

Jul 14, 2021

Changes in this version

+ func AddHooks(hooks map[string]func(interface{}))

type Stream

+ ExtraProp interface{}

Jul 12, 2021

Changes in this version

type AudioTrack

+ func (at *AudioTrack) Play(ctx context.Context, onAudio func(AudioPack))

type VideoTrack

+ func (vt *VideoTrack) Play(ctx context.Context, onVideo func(VideoPack))

Jul 10, 2021

Changes in this version

+ type AVPack interface

+ Since func(uint32) uint32

+ type BasePack struct

+ Payload []byte

+ Sequence int

+ Timestamp uint32

+ func (p *BasePack) Since(ts uint32) uint32

+ type RingBuffer struct

+ func NewRingBuffer(n int) (r *RingBuffer)

+ func (r *RingBuffer) Current() *RingItem

+ func (r *RingBuffer) CurrentValue() interface{}

+ func (r *RingBuffer) GetNext() *RingItem

+ func (r *RingBuffer) Init(n int)

+ func (r *RingBuffer) MoveNext()

+ func (r *RingBuffer) NextValue() interface{}

+ func (r *RingBuffer) Read() interface{}

+ func (r *RingBuffer) SubRing(rr *ring.Ring) *RingBuffer

+ func (r *RingBuffer) Write(value interface{})

+ func (rb RingBuffer) Clone() *RingBuffer

+ type RingDisposable struct

+ Flag int32

+ func (r *RingDisposable) Dispose()

+ func (r *RingDisposable) Step()

+ func (r *RingDisposable) Write(value interface{})

+ type RingItem struct

+ Value interface{}

+ type Track_Base struct

+ BPS int

+ CodecID byte

+ PacketCount int

+ Stream *Stream

+ func (t *Track_Base) GetBPS()

type VideoTrack

+ IDRing *ring.Ring

Jun 28, 2021

Changes in this version

+ type RingItem_Track struct

+ Codec string

+ type Ring_Track struct

+ Current *RingItem_Track

+ Index byte

+ func NewRing_Track() (r *Ring_Track)

+ func (r *Ring_Track) GetAt(index byte) *RingItem_Track

+ func (r *Ring_Track) GoNext()

+ func (r *Ring_Track) GoTo(index byte)

+ func (r *Ring_Track) NextR()

+ func (r *Ring_Track) NextW(codec string, track Track)

+ func (r *Ring_Track) SubRing(index byte) *Ring_Track

type Tracks

+ TrackRing *Ring_Track

Jun 26, 2021

Changes in this version

type TrackWaiter

+ func (tw *TrackWaiter) MarshalJSON() ([]byte, error)

Jun 26, 2021

Changes in this version

+ const HOOK_PUBLISH

+ const HOOK_REQUEST_TRANSAUDIO

+ const HOOK_STREAMCLOSE

+ const HOOK_SUBSCRIBE

+ const HOOK_UNSUBSCRIBE

+ const Version

+ var ConfigRaw []byte

+ var HasTranscoder bool

+ var Hooks = NewRing_Hook()

+ var Plugins = make(map[string]*PluginConfig)

+ var StartTime time.Time

+ func AddHook(name string, callback func(interface{}))

+ func AddHookWithContext(ctx context.Context, name string, callback func(interface{}))

+ func InstallPlugin(opt *PluginConfig)

+ func Run(configFile string) (err error)

+ func TriggerHook(hook Hook)

+ type AudioPack struct

+ Payload []byte

+ Raw []byte

+ SequenceNumber uint16

+ Timestamp uint32

+ func (ap AudioPack) Copy(ts uint32) AudioPack

+ type AudioTrack struct

+ Channels byte

+ ExtraData []byte

+ PushByteStream func(pack AudioPack)

+ PushRaw func(pack AudioPack)

+ SoundRate int

+ SoundSize byte

+ WriteByteStream func(writer io.Writer, pack AudioPack)

+ func (at *AudioTrack) SetASC(asc []byte)

+ type Hook struct

+ Name string

+ Payload interface{}

+ type PluginConfig struct

+ Config interface{}

+ Dir string

+ HotConfig map[string]func(interface{})

+ Name string

+ Run func()

+ Version string

+ type RTPAudio struct

+ type RTPPublisher struct

+ Push func(payload []byte)

+ type RTPVideo struct

+ type RingItem_Audio struct

+ UpdateTime time.Time

+ type RingItem_Hook struct

+ UpdateTime time.Time

+ type RingItem_Video struct

+ UpdateTime time.Time

+ type Ring_Audio struct

+ Current *RingItem_Audio

+ Flag int32

+ Index byte

+ func NewRing_Audio() (r *Ring_Audio)

+ func (r *Ring_Audio) Dispose()

+ func (r *Ring_Audio) GetAt(index byte) *RingItem_Audio

+ func (r *Ring_Audio) GetBuffer() *bytes.Buffer

+ func (r *Ring_Audio) GetLast() *RingItem_Audio

+ func (r *Ring_Audio) GetNext() *RingItem_Audio

+ func (r *Ring_Audio) GoBack()

+ func (r *Ring_Audio) GoNext()

+ func (r *Ring_Audio) GoTo(index byte)

+ func (r *Ring_Audio) NextR() bool

+ func (r *Ring_Audio) NextW()

+ func (r *Ring_Audio) SubRing(index byte) *Ring_Audio

+ func (r *Ring_Audio) Timeout(t time.Duration) bool

+ type Ring_Hook struct

+ Current *RingItem_Hook

+ Index byte

+ func NewRing_Hook() (r *Ring_Hook)

+ func (r *Ring_Hook) GetAt(index byte) *RingItem_Hook

+ func (r *Ring_Hook) GetBuffer() *bytes.Buffer

+ func (r *Ring_Hook) GetLast() *RingItem_Hook

+ func (r *Ring_Hook) GetNext() *RingItem_Hook

+ func (r *Ring_Hook) GoBack()

+ func (r *Ring_Hook) GoNext()

+ func (r *Ring_Hook) GoTo(index byte)

+ func (r *Ring_Hook) NextR()

+ func (r *Ring_Hook) NextW()

+ func (r *Ring_Hook) SubRing(index byte) *Ring_Hook

+ func (r *Ring_Hook) Timeout(t time.Duration) bool

+ type Ring_Video struct

+ Current *RingItem_Video

+ Flag int32

+ Index byte

+ func NewRing_Video() (r *Ring_Video)

+ func (r *Ring_Video) Dispose()

+ func (r *Ring_Video) GetAt(index byte) *RingItem_Video

+ func (r *Ring_Video) GetBuffer() *bytes.Buffer

+ func (r *Ring_Video) GetLast() *RingItem_Video

+ func (r *Ring_Video) GetNext() *RingItem_Video

+ func (r *Ring_Video) GoBack()

+ func (r *Ring_Video) GoNext()

+ func (r *Ring_Video) GoTo(index byte)

+ func (r *Ring_Video) NextR() bool

+ func (r *Ring_Video) NextW()

+ func (r *Ring_Video) SubRing(index byte) *Ring_Video

+ func (r *Ring_Video) Timeout(t time.Duration) bool

+ type Stream struct

+ AudioTracks Tracks

+ AutoUnPublish bool

+ Close func()

+ StartTime time.Time

+ StreamPath string

+ Subscribers []*Subscriber

+ Transcoding map[string]string

+ Type string

+ VideoTracks Tracks

+ func FindStream(streamPath string) *Stream

+ func (r *Stream) Publish() bool

+ func (r *Stream) Subscribe(s *Subscriber)

+ func (r *Stream) UnSubscribe(s *Subscriber)

+ func (r *Stream) Update()

+ func (r *Stream) WaitAudioTrack(codecs ...string) *AudioTrack

+ func (r *Stream) WaitVideoTrack(codecs ...string) *VideoTrack

+ func (s *Stream) NewAudioTrack(codec byte) (at *AudioTrack)

+ func (s *Stream) NewRTPAudio(codec byte) (r *RTPAudio)

+ func (s *Stream) NewRTPVideo(codec byte) (r *RTPVideo)

+ func (s *Stream) NewVideoTrack(codec byte) (vt *VideoTrack)

+ type StreamCollection struct

+ var Streams StreamCollection

+ func (sc *StreamCollection) Delete(streamPath string)

+ func (sc *StreamCollection) GetStream(streamPath string) *Stream

+ func (sc *StreamCollection) ToList() (r []*Stream)

+ type Subscriber struct

+ BufferLength int

+ ByteStreamFormat bool

+ Ctx2 context.Context

+ Delay uint32

+ ID string

+ OnAudio func(pack AudioPack)

+ OnVideo func(pack VideoPack)

+ SubscribeArgs url.Values

+ SubscribeTime time.Time

+ TotalDrop int

+ TotalPacket int

+ Type string

+ func DeleteSliceItem_Subscriber(slice []*Subscriber, item *Subscriber) ([]*Subscriber, bool)

+ func (s *Subscriber) Close()

+ func (s *Subscriber) Play(at *AudioTrack, vt *VideoTrack)

+ func (s *Subscriber) PlayAudio(at *AudioTrack)

+ func (s *Subscriber) PlayVideo(vt *VideoTrack)

+ func (s *Subscriber) Subscribe(streamPath string) error

+ type TSSlice []uint32

+ func (s TSSlice) Len() int

+ func (s TSSlice) Less(i, j int) bool

+ func (s TSSlice) Swap(i, j int)

+ type Track interface

+ Dispose func()

+ GetBPS func(int)

+ type TrackWaiter struct

+ func (tw *TrackWaiter) Dispose()

+ func (tw *TrackWaiter) Ok(t Track)

+ func (tw *TrackWaiter) Wait(c chan<- Track)

+ type Track_Audio struct

+ BPS int

+ Buffer *Ring_Audio

+ CodecID byte

+ PacketCount int

+ Stream *Stream

+ func (t *Track_Audio) Dispose()

+ func (t *Track_Audio) GetBPS(payloadLen int)

+ type Track_Video struct

+ BPS int

+ Buffer *Ring_Video

+ CodecID byte

+ PacketCount int

+ Stream *Stream

+ func (t *Track_Video) Dispose()

+ func (t *Track_Video) GetBPS(payloadLen int)

+ type Tracks struct

+ func (ts *Tracks) AddTrack(codec string, t Track)

+ func (ts *Tracks) Codecs() (result []string)

+ func (ts *Tracks) Dispose()

+ func (ts *Tracks) GetTrack(codec string) (tw *TrackWaiter, ok bool)

+ func (ts *Tracks) Init()

+ func (ts *Tracks) MarshalJSON() ([]byte, error)

+ func (ts *Tracks) WaitTrack(codecs ...string) Track

+ type TransCodeReq struct

+ RequestCodec string

+ type VideoPack struct

+ CompositionTime uint32

+ IDR bool

+ NALUs [][]byte

+ Payload []byte

+ Sequence int

+ Timestamp uint32

+ func (vp VideoPack) Clone() VideoPack

+ func (vp VideoPack) Copy(ts uint32) VideoPack

+ type VideoTrack struct

+ ExtraData *VideoPack

+ GOP byte

+ IDRIndex byte

+ PushByteStream func(pack VideoPack)

+ PushNalu func(pack VideoPack)

+ SPSInfo codec.SPSInfo

+ UsingDonlField bool

+ WaitIDR context.Context

+ WriteByteStream func(writer io.Writer, pack VideoPack)

+ func (vt *VideoTrack) PushAnnexB(pack VideoPack)