engine

Jul 9, 2024

Changes in this version

type TrackPlayer

+ func (player *TrackPlayer) StopPlay()

Feb 27, 2024

Changes in this version

type Publisher

+ func (p *Publisher) CreateAudioTrack(codecID codec.AudioCodecID, stuff ...any) common.AudioTrack

+ func (p *Publisher) CreateVideoTrack(codecID codec.VideoCodecID, stuff ...any) common.VideoTrack

Feb 26, 2024

Changes in this version

type Publisher

+ func (p *Publisher) GetAudioTrack() common.AudioTrack

+ func (p *Publisher) GetConfig() *config.Publish

+ func (p *Publisher) GetVideoTrack() common.VideoTrack

type Stream

+ func (s *Stream) GetPath() string

Feb 20, 2024

Changes in this version

type Tracks

+ Audio []*track.Audio

+ Data []common.Track

+ Video []*track.Video

Dec 20, 2023

Changes in this version

+ func EmitEvent[T any](event T)

+ func ListenEvent[T any](handler func(event T))

+ type UpdateConfig *config.Config

Nov 17, 2023

Changes in this version

type Stream

+ ID uint32

Nov 2, 2023

Changes in this version

+ type StopError []zapcore.Field

+ func (s StopError) Error() string

Oct 19, 2023

Changes in this version

+ func InviteTrack(name string, suber ISubscriber)

type IPuller

+ OnConnected func()

+ type InviteTrackEvent struct

type Puller

+ func (pub *Puller) OnConnected()

+ type SEtrackAvaliable struct

type StreamAction

+ const ACTION_NOTRACK

+ const ACTION_PUBLISHCLOSE

+ const ACTION_TRACKAVAILABLE

type StreamState

+ const STATE_WAITTRACK

type Subscribers

+ func (s *Subscribers) SendInviteTrack(stream *Stream)

type Tracks

+ MainAudio *track.Audio

Aug 12, 2023

Changes in this version

+ func TryInvitePublish(streamPath string)

type IPuller

+ Disconnect func()

type IPusher

+ Disconnect func()

+ type InvitePublish struct

type Plugin

+ func (opt *Plugin) AssignPubConfig(puber *Publisher)

+ func (opt *Plugin) AssignSubConfig(suber *Subscriber)

Aug 6, 2023

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_stop_push(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_stop_subscribe(w http.ResponseWriter, r *http.Request)

type IO

+ RemoteAddr string

type Subscribers

+ func (s *Subscribers) Find(id string) ISubscriber

+ type SummaryUtil Summary

+ func (s *SummaryUtil) MarshalJSON() ([]byte, error)

+ func (s *SummaryUtil) MarshalYAML() (any, error)

+ type TSReader struct

+ func NewTSReader(pub *TSPublisher) (r *TSReader)

+ func (t *TSReader) Close()

+ func (t *TSReader) ReadPES()

Jul 7, 2023

Changes in this version

+ var ErrDuplicatePublish = errors.New("Duplicate Publish")

Jun 16, 2023

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_insertSEI(w http.ResponseWriter, r *http.Request)

type Tracks

+ SEI *track.Data[[]byte]

+ func (tracks *Tracks) AddSEI(t byte, data []byte) bool

Jun 11, 2023

Changes in this version

type Stream

+ IsPause bool

+ func (s *Stream) Pause()

+ func (s *Stream) Resume()

type StreamTimeoutConfig

+ PauseTimeout time.Duration

Jun 4, 2023

Changes in this version

type StreamTimeoutConfig

+ NeverTimeout bool

May 25, 2023

Changes in this version

type AudioFrame

+ func (a AudioFrame) WriteRawTo(w io.Writer) (n int64, err error)

May 21, 2023

Changes in this version

type RTPDumpPublisher

+ APayloadType uint8

+ VPayloadType uint8

type Tracks

+ func (tracks *Tracks) Range(f func(name string, t Track))

May 14, 2023

Changes in this version

+ var ErrTrackMute = errors.New("Track Mute")

+ var SettingDir = filepath.Join(ExecDir, ".m7s")

type StreamTimeoutConfig

+ IdleTimeout time.Duration

Apr 29, 2023

Changes in this version

+ func ShouldYaml(r *http.Request) bool

Apr 24, 2023

Changes in this version

+ var ErrAuth = errors.New("Auth Failed")

Apr 23, 2023

Changes in this version

type GlobalConfig

+ func (c *GlobalConfig) API_replay_ps(w http.ResponseWriter, r *http.Request)

type IPublisher

+ Publish func(streamPath string, pub IPublisher) error

type ISubscriber

+ Subscribe func(streamPath string, sub ISubscriber) error

type PSPublisher

+ func (p *PSPublisher) Replay(f *os.File) (err error)

type Publisher

+ func (p *Publisher) Publish(streamPath string, pub IPublisher) error

type StreamAction

+ func (s StreamAction) String() string

type StreamState

+ func (s StreamState) String() string

type Subscriber

+ func (s *Subscriber) Subscribe(streamPath string, sub ISubscriber) error

Apr 12, 2023

Changes in this version

type Subscriber

+ func (s *Subscriber) SetIO(i any)

Mar 28, 2023

Changes in this version

+ type AddTrackEvent struct

+ type ErrorEvent struct

+ Error error

+ type Event struct

+ Target T

+ Time time.Time

+ func CreateEvent(target T) (event Event[T])

type GlobalConfig

+ func (conf *GlobalConfig) OnEvent(event any)

+ func (conf *GlobalConfig) Report(t string, v any)

+ type NoMoreTrack struct

type Plugin

+ Disabled bool

+ type PulseEvent struct

+ type ReportAddTrack struct

+ Name string

+ StreamPath string

+ Time int64

+ type ReportCloseStream struct

+ StreamPath string

+ Time int64

+ type ReportCreateStream struct

+ StreamPath string

+ Time int64

+ type ReportPulse struct

+ StreamPath string

+ Subscribers map[string]struct{ ... }

+ Time int64

+ Tracks map[string]ReportTrackInfo

+ type ReportTrackInfo struct

+ BPS int

+ Drops int

+ FPS int

+ RBSize int

+ type Reportor struct

+ func (r *Reportor) OnEvent(event any)

+ type SEcreate struct

+ type StreamEvent struct

+ type SubPulse struct

type Subscriber

+ func (s *Subscriber) SubPulse()

+ type TrackTimeoutEvent struct

+ type Unsubscribe ISubscriber

Mar 23, 2023

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_replay_mp4(w http.ResponseWriter, r *http.Request)

+ type MP4Publisher struct

+ func (p *MP4Publisher) ReadMP4Data(source io.ReadSeeker) error

type RTPDumpPublisher

+ func (t *RTPDumpPublisher) Feed(file *os.File)

+ func (t *RTPDumpPublisher) WriteRTP(raw []byte)

Mar 13, 2023

Changes in this version

type Stream

+ func (s *Stream) GetType() string

Mar 9, 2023

Changes in this version

type PSPublisher

+ func (p *PSPublisher) OnFrame(frame []byte, cid mpeg2.PS_STREAM_TYPE, pts uint64, dts uint64)

+ func (p *PSPublisher) OnPacket(pkg mpeg2.Display, decodeResult error)

type Stream

+ func (s *Stream) GetStartTime() time.Time

Mar 3, 2023

Changes in this version

type IIO

+ SetLogger func(*zap.Logger)

type IO

+ func (i *IO) SetLogger(logger *zap.Logger)

Feb 28, 2023

Changes in this version

type AudioFrame

+ func (a AudioFrame) GetADTS() (r net.Buffers)

+ type PSPublisher struct

+ DisableReorder bool

+ func (p *PSPublisher) PushPS(rtp *rtp.Packet)

+ func (p *PSPublisher) ReceiveAudio(es mpegps.MpegPsEsStream)

+ func (p *PSPublisher) ReceiveVideo(es mpegps.MpegPsEsStream)

Feb 22, 2023

Changes in this version

type FLVFrame

+ func (f FLVFrame) IsAudio() bool

+ func (f FLVFrame) IsVideo() bool

Feb 19, 2023

Changes in this version

type MemoryTs

+ func (ts *MemoryTs) WritePMTPacket(audio codec.AudioCodecID, video codec.VideoCodecID)

type Subscriber

+ func (s *Subscriber) CreateTrackReader(t *track.Media) (result track.AVRingReader)

Feb 15, 2023

Changes in this version

+ var ErrBadStreamName = errors.New("Stream Already Exist")

+ var ErrBadTrackName = errors.New("Track Already Exist")

+ type MemoryTs struct

+ PMT util.Buffer

+ func (ts *MemoryTs) WriteAudioFrame(frame *AudioFrame, aac_asc *codec.AudioSpecificConfig, ...) (err error)

+ func (ts *MemoryTs) WritePESPacket(frame *mpegts.MpegtsPESFrame, packet mpegts.MpegTsPESPacket) (err error)

+ func (ts *MemoryTs) WriteTo(w io.Writer) (int64, error)

+ func (ts *MemoryTs) WriteVideoFrame(frame *VideoFrame, paramaterSets common.ParamaterSets, ...) (err error)

Feb 3, 2023

Changes in this version

+ type SErepublish struct

type Stream

+ SEHistory []StateEvent

Feb 2, 2023

Changes in this version

type AudioDeConf

+ func (a AudioDeConf) WithOutRTMP() []byte

type AudioFrame

+ AbsTime uint32

+ DTS uint32

+ PTS uint32

type Stream

+ func (s *Stream) GetPublisherConfig() *config.Publish

+ func (s *Stream) SetIDR(video Track)

type TrackPlayer

+ AudioReader track.AVRingReader

+ VideoReader track.AVRingReader

type Tracks

+ MainVideo *track.Video

+ func (tracks *Tracks) Add(name string, t Track) bool

+ func (tracks *Tracks) SetIDR(video Track)

type VideoDeConf

+ func (v VideoDeConf) WithOutRTMP() []byte

type VideoFrame

+ AbsTime uint32

+ DTS uint32

+ PTS uint32

+ func (v VideoFrame) WriteAnnexBTo(w io.Writer) (n int64, err error)

Jan 10, 2023

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_replay_ts(w http.ResponseWriter, r *http.Request)

type TSPublisher

+ func (t *TSPublisher) ReadPES()

Jan 3, 2023

Changes in this version

+ type DefaultYaml string

Dec 31, 2022

Changes in this version

+ var ErrPublisherLost = errors.New("Publisher Lost")

type Subscriber

+ IsInternal bool

type Subscribers

+ func (s *Subscribers) AbortWait()

+ func (s *Subscribers) Dispose()

+ func (s *Subscribers) Init()

+ func (s *Subscribers) Len() int

+ func (s *Subscribers) OnPublisherLost(event StateEvent)

+ func (s *Subscribers) OnTrack(track common.Track)

+ func (s *Subscribers) RangeAll(f func(sub ISubscriber, wait *waitTracks))

Dec 18, 2022

Changes in this version

type IO

+ Spesific IIO

+ type Subscribers map[ISubscriber]*waitTracks

+ func (s Subscribers) Add(suber ISubscriber, wait *waitTracks)

+ func (s Subscribers) Broadcast(event any)

+ func (s Subscribers) Delete(suber ISubscriber)

+ func (s Subscribers) MarshalJSON() ([]byte, error)

+ func (s Subscribers) Pick() ISubscriber

Dec 15, 2022

Changes in this version

+ var OnAuthPub func(p *util.Promise[IPublisher]) error

+ var OnAuthSub func(p *util.Promise[ISubscriber]) error

+ type AuthPub interface

+ OnAuth func(*util.Promise[IPublisher]) error

+ type AuthSub interface

+ OnAuth func(*util.Promise[ISubscriber]) error

type IIO

+ IsShutdown func() bool

+ SetStuff func(...any)

type IO

+ func (io *IO) IsShutdown() bool

type IPublisher

+ GetPublisher func() *Publisher

type ISubscriber

+ GetSubscriber func() *Subscriber

type Publisher

+ Config *config.Publish

+ func (p *Publisher) GetPublisher() *Publisher

type Stream

+ StateEvent StateEvent

type Subscriber

+ Config *config.Subscribe

+ func (s *Subscriber) GetSubscriber() *Subscriber

+ type UnsubscribeEvent struct

+ Subscriber ISubscriber

Nov 30, 2022

Changes in this version

+ var ErrStreamNotExist = errors.New("stream not exist")

type Plugin

+ func (opt *Plugin) SubscribeExist(streamPath string, sub ISubscriber) error

Nov 22, 2022

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_replay_rtpdump(w http.ResponseWriter, r *http.Request)

+ type RTPDumpPublisher struct

+ ACodec codec.AudioCodecID

+ DumpFile string

+ VCodec codec.VideoCodecID

+ func (t *RTPDumpPublisher) OnEvent(event any)

Nov 17, 2022

Changes in this version

+ var ErrBadName = errors.New("Stream Already Exist")

+ var ErrNoPullConfig = errors.New("no pull config")

+ var ErrNoPushConfig = errors.New("no push config")

+ var ErrStreamIsClosed = errors.New("Stream Is Closed")

type IO

+ func (i *IO[C]) SetStuff(stuffs ...any)

Nov 4, 2022

Changes in this version

+ type StreamList []*Stream

+ func GetSortedStreamList() StreamList

+ func (l StreamList) Len() int

+ func (l StreamList) Less(i, j int) bool

+ func (l StreamList) Sort()

+ func (l StreamList) Swap(i, j int)

Oct 7, 2022

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_stopPush(w http.ResponseWriter, r *http.Request)

Oct 5, 2022

Changes in this version

type Plugin

+ Yaml string

Oct 2, 2022

Changes in this version

+ type HasAnnexB interface

+ GetAnnexB func() (r net.Buffers)

Sep 14, 2022

Changes in this version

+ const SUBSTATE_FIRST

+ const SUBSTATE_INIT

+ const SUBSTATE_NORMAL

type TrackPlayer

+ func (tp *TrackPlayer) ReadAudio() (ap *AVFrame[AudioSlice])

+ func (tp *TrackPlayer) ReadVideo() (vp *AVFrame[NALUSlice])

Sep 4, 2022

Changes in this version

type IIO

+ GetStream func() *Stream

type IO

+ func (io *IO[C]) GetStream() *Stream

type Stream

+ CloseReason StreamAction

+ func (r *Stream) IsShutdown() bool

Aug 28, 2022

Changes in this version

+ var Pullers sync.Map

+ var Pushers sync.Map

type GlobalConfig

+ func (conf *GlobalConfig) API_list_pull(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_list_push(w http.ResponseWriter, r *http.Request)

Aug 13, 2022

Changes in this version

type StreamTimeoutConfig

+ DelayCloseTimeout time.Duration

Jul 17, 2022

Changes in this version

+ var SysInfo struct

Jul 10, 2022

Changes in this version

+ type Tracks struct

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

Jun 25, 2022

Changes in this version

+ type AudioRTP RTPFrame

type Subscriber

+ func (s *Subscriber) PlayRTP()

+ type VideoRTP RTPFrame

Jun 19, 2022

Changes in this version

+ const SUBTYPE_AVCC

+ const SUBTYPE_FLV

+ const SUBTYPE_RAW

+ const SUBTYPE_RTP

+ type FLVFrame net.Buffers

+ func (f FLVFrame) WriteTo(w io.Writer) (int64, error)

type ISubscriber

+ PlayFLV func()

+ PlayRaw func()

type PlayContext

+ Frame *AVFrame[R]

type Subscriber

+ func (s *Subscriber) PlayFLV()

+ func (s *Subscriber) PlayRaw()

type TrackPlayer

+ FirstAbsTS uint32

+ SkipTS uint32

Jun 12, 2022

Changes in this version

type VideoDeConf

+ func (v VideoDeConf) GetAnnexB() (r net.Buffers)

type VideoFrame

+ func (v *VideoFrame) GetAnnexB() (r net.Buffers)

Jun 11, 2022

Changes in this version

+ const NO_SUCH_CONIFG

+ const NO_SUCH_STREAM

Jun 7, 2022

Changes in this version

type GlobalConfig

+ func (conf *GlobalConfig) API_plugins(rw http.ResponseWriter, r *http.Request)

May 20, 2022

Changes in this version

+ type ClientIO struct

+ Config *C

+ ReConnectCount int

+ RemoteURL string

+ StreamPath string

type GlobalConfig

+ func (conf *GlobalConfig) API_stream(rw http.ResponseWriter, r *http.Request)

type Publisher

+ func (p *Publisher) WriteAVCCAudio(ts uint32, frame common.AVCCFrame)

+ func (p *Publisher) WriteAVCCVideo(ts uint32, frame common.AVCCFrame)

type Stream

+ func (s *Stream) Summary() (r StreamSummay)

+ type StreamSummay struct

+ BPS int

+ Path string

+ StartTime int64

+ State StreamState

+ Subscribers int

+ Tracks []string

+ Type string

May 16, 2022

Changes in this version

type TSPublisher

+ func (t *TSPublisher) Feed(r io.Reader) error

May 15, 2022

Changes in this version

+ var ActionNames = [...]string

+ var BadNameErr = errors.New("Bad Name")

+ var ConfigRaw []byte

+ var Engine = InstallPlugin(EngineConfig)

+ var EngineConfig = &GlobalConfig

+ var EventBus = make(chan any, 10)

+ var ExecDir = filepath.Dir(ExecPath)

+ var ExecPath = os.Args[0]

+ var MergeConfigs = []string

+ var NoPullConfigErr = errors.New("no pull config")

+ var NoPushConfigErr = errors.New("no push config")

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

+ var StartTime time.Time

+ var StateNames = [...]string

+ var StreamFSM = [len(StateNames)]map[StreamAction]StreamState

+ var StreamIsClosedErr = errors.New("Stream Is Closed")

+ var Streams = util.Map[string, *Stream]

+ func Run(ctx context.Context, configFile string) (err error)

+ type AudioDeConf DecoderConfiguration[AudioSlice]

+ func (a AudioDeConf) GetAVCC() net.Buffers

+ func (a AudioDeConf) GetFLV() net.Buffers

+ type AudioFrame AVFrame[AudioSlice]

+ func (a *AudioFrame) GetAVCC() net.Buffers

+ func (a *AudioFrame) GetFLV() net.Buffers

+ func (a *AudioFrame) GetRTP() []*RTPFrame

+ type Client struct

+ Config *C

+ ReConnectCount int

+ RemoteURL string

+ StreamPath string

+ type ClientConfig interface

+ type FirstConfig config.Config

+ type GlobalConfig struct

+ func (conf *GlobalConfig) API_closeStream(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_getConfig(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_modifyConfig(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_summary(rw http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_sysInfo(rw http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) API_updateConfig(w http.ResponseWriter, r *http.Request)

+ func (conf *GlobalConfig) ServeHTTP(rw http.ResponseWriter, r *http.Request)

+ type HaveAVCC interface

+ GetAVCC func() net.Buffers

+ type HaveFLV interface

+ GetFLV func() net.Buffers

+ type HaveRTP interface

+ GetRTP func() []*RTPFrame

+ type IIO interface

+ IsClosed func() bool

+ OnEvent func(any)

+ SetIO func(any)

+ SetParentCtx func(context.Context)

+ Stop func()

+ type IO struct

+ Args url.Values

+ Config *C

+ ID string

+ Spesic S

+ StartTime time.Time

+ Stream *Stream

+ Type string

+ func (i *IO[C, S]) OnEvent(event any)

+ func (i *IO[C, S]) SetIO(conn any)

+ func (i *IO[C, S]) SetParentCtx(parent context.Context)

+ func (io *IO[C, S]) GetConfig() *C

+ func (io *IO[C, S]) GetIO() *IO[C, S]

+ func (io *IO[C, S]) IsClosed() bool

+ func (io *IO[C, S]) Stop()

+ type IOConfig interface

+ type IPublisher interface

+ GetConfig func() *config.Publish

+ GetIO func() *IO[config.Publish, IPublisher]

+ type IPuller interface

+ Connect func() error

+ Pull func()

+ Reconnect func() bool

+ type IPusher interface

+ Connect func() error

+ Push func() error

+ Reconnect func() bool

+ type ISubscriber interface

+ GetConfig func() *config.Subscribe

+ GetIO func() *IO[config.Subscribe, ISubscriber]

+ IsPlaying func() bool

+ PlayBlock func()

+ Stop func()

+ type NetWorkInfo struct

+ Name string

+ Receive uint64

+ ReceiveSpeed uint64

+ Sent uint64

+ SentSpeed uint64

+ type PlayContext struct

+ First AVFrame[R]

+ Track T

+ func (p *PlayContext[T, R]) MarshalJSON() ([]byte, error)

+ type Plugin struct

+ Config config.Plugin

+ Modified config.Config

+ Name string

+ RawConfig config.Config

+ Version string

+ func InstallPlugin(config config.Plugin) *Plugin

+ func (opt *Plugin) Publish(streamPath string, pub IPublisher) error

+ func (opt *Plugin) Pull(streamPath string, url string, puller IPuller, save bool) (err error)

+ func (opt *Plugin) Push(streamPath string, url string, pusher IPusher, save bool) (err error)

+ func (opt *Plugin) Save() error

+ func (opt *Plugin) Subscribe(streamPath string, sub ISubscriber) error

+ func (opt *Plugin) SubscribeBlock(streamPath string, sub ISubscriber) (err error)

+ func (opt *Plugin) Update(conf config.Config)

+ type Publisher struct

+ func (p *Publisher) Equal(p2 IPublisher) bool

+ func (p *Publisher) OnEvent(event any)

+ func (p *Publisher) Stop()

+ type Puller struct

+ func (pub *Puller) Reconnect() (ok bool)

+ type Pusher struct

+ func (pub *Pusher) Reconnect() bool

+ type SEKick struct

+ type SEclose struct

+ type SEpublish struct

+ type SEwaitClose struct

+ type SEwaitPublish struct

+ Publisher IPublisher

+ type StateEvent struct

+ Action StreamAction

+ From StreamState

+ Stream *Stream

+ func (se StateEvent) Next() (next StreamState, ok bool)

+ type Stream struct

+ AppName string

+ Path string

+ Publisher IPublisher

+ StartTime time.Time

+ State StreamState

+ StreamName string

+ Subscribers []ISubscriber

+ Tracks map[string]Track

+ func FilterStreams() (ss []*Stream)

+ func (r *Stream) IsClosed() bool

+ func (r *Stream) NewAudioTrack() (at *track.UnknowAudio)

+ func (r *Stream) NewDataTrack(locker sync.Locker) (dt *track.Data)

+ func (r *Stream) NewVideoTrack() (vt *track.UnknowVideo)

+ func (s *Stream) AddTrack(t Track)

+ func (s *Stream) Close()

+ func (s *Stream) Receive(event any) bool

+ func (s *Stream) RemoveTrack(t Track)

+ func (s *Stream) SSRC() uint32

+ type StreamAction byte

+ const ACTION_CLOSE

+ const ACTION_FIRSTENTER

+ const ACTION_LASTLEAVE

+ const ACTION_PUBLISH

+ const ACTION_PUBLISHLOST

+ const ACTION_TIMEOUT

+ type StreamState byte

+ const STATE_CLOSED

+ const STATE_PUBLISHING

+ const STATE_WAITCLOSE

+ const STATE_WAITPUBLISH

+ type StreamTimeoutConfig struct

+ PublishTimeout time.Duration

+ WaitCloseTimeout time.Duration

+ WaitTimeout time.Duration

+ type Subscriber struct

+ func (s *Subscriber) AddTrack(t Track) bool

+ func (s *Subscriber) IsPlaying() bool

+ func (s *Subscriber) OnEvent(event any)

+ func (s *Subscriber) PlayBlock()

+ type Summary struct

+ Address string

+ CPUUsage float64

+ HardDisk struct{ ... }

+ Memory struct{ ... }

+ NetWork []NetWorkInfo

+ Streams []*Stream

+ func (s *Summary) Add()

+ func (s *Summary) Done()

+ func (s *Summary) Point() *Summary

+ func (s *Summary) Report(slave *Summary)

+ func (s *Summary) Running() bool

+ func (s *Summary) Start()

+ type TSPublisher struct

+ func (t *TSPublisher) OnEvent(event any)

+ func (t *TSPublisher) OnPES(pes mpegts.MpegTsPESPacket)

+ func (t *TSPublisher) OnPmtStream(s mpegts.MpegTsPmtStream)

+ type TrackPlayer struct

+ Audio PlayContext[*track.Audio, AudioSlice]

+ Video PlayContext[*track.Video, NALUSlice]

+ type TrackRemoved struct

+ type VideoDeConf DecoderConfiguration[NALUSlice]

+ func (a VideoDeConf) GetAVCC() net.Buffers

+ func (a VideoDeConf) GetFLV() net.Buffers

+ type VideoFrame AVFrame[NALUSlice]

+ func (v *VideoFrame) GetAVCC() net.Buffers

+ func (v *VideoFrame) GetFLV() net.Buffers

+ func (v *VideoFrame) GetRTP() []*RTPFrame