engine

package module

Go to main page

Versions in this module

v1

v1.2.2

Apr 29, 2020

v1.2.1

Apr 15, 2020

Changes in this version

type PluginConfig

+ UIDir string

v1.2.0

Apr 11, 2020

Changes in this version

+ func Print(v ...interface{})

+ func Printf(format string, v ...interface{})

+ func Println(v ...interface{})

+ type MultiLogWriter struct

+ func (w *MultiLogWriter) Write(data []byte) (n int, err error)

v1.1.3

Apr 8, 2020

Changes in this version

type PluginConfig

+ Dir string

v1.1.2

Mar 22, 2020

Changes in this version

+ var OnRoomClosedHooks = make(OnRoomClosedHook, 0)

+ var OnUnSubscribeHooks = make(OnUnSubscribeHook, 0)

+ type OnRoomClosedHook []func(*Room)

+ func (h OnRoomClosedHook) AddHook(hook func(*Room))

+ func (h OnRoomClosedHook) Trigger(v *Room)

+ type OnUnSubscribeHook []func(s *OutputStream)

+ func (h OnUnSubscribeHook) AddHook(hook func(s *OutputStream))

+ func (h OnUnSubscribeHook) Trigger(s *OutputStream)

v1.1.1

Mar 8, 2020

v1.1.0

Mar 5, 2020

v1.0.3

Mar 4, 2020

v1.0.2

Feb 29, 2020

Changes in this version

+ const PLUGIN_NONE

type PluginConfig

+ Version string

v1.0.1

Feb 27, 2020

Changes in this version

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

type PluginConfig

+ UI string

v1.0.0

Feb 27, 2020

Changes in this version

+ const PLUGIN_HOOK

+ const PLUGIN_PUBLISHER

+ const PLUGIN_SUBSCRIBER

+ var AllRoom = Collection

+ var AuthHooks = make(AuthHook, 0)

+ var ConfigRaw []byte

+ var EngineInfo = &struct{ ... }

+ var OnDropHooks = make(OnDropHook, 0)

+ var OnPublishHooks = make(OnPublishHook, 0)

+ var OnSubscribeHooks = make(OnSubscribeHook, 0)

+ var OnSummaryHooks = make(OnSummaryHook, 0)

+ var Summary = ServerSummary

+ var Version = "1.0.0"

+ func AddWriter(wn io.Writer)

+ func InstallPlugin(opt *PluginConfig)

+ func MayBeError(info error) (hasError bool)

+ func Run(configFile string) (err error)

+ type AuthHook []func(string) error

+ func (h AuthHook) AddHook(hook func(string) error)

+ func (h AuthHook) Trigger(sign string) error

+ type ChangeRoomCmd struct

+ NewRoom *Room

+ type Collection struct

+ func (c *Collection) Get(name string) (result *Room)

+ type Config struct

+ Plugins map[string]interface{}

+ type InputStream struct

+ func (p *InputStream) Close()

+ func (p *InputStream) OnClosed()

+ func (p *InputStream) Publish(streamPath string, publisher Publisher) bool

+ func (p *InputStream) Running() bool

+ type ListenerConfig struct

+ ListenAddr string

+ type LogWriter struct

+ func (w *LogWriter) Write(data []byte) (n int, err error)

+ type NetWorkInfo struct

+ Name string

+ Receive uint64

+ ReceiveSpeed uint64

+ Sent uint64

+ SentSpeed uint64

+ type OnDropHook []func(s *OutputStream)

+ func (h OnDropHook) AddHook(hook func(s *OutputStream))

+ func (h OnDropHook) Trigger(s *OutputStream)

+ type OnPublishHook []func(r *Room)

+ func (h OnPublishHook) AddHook(hook func(r *Room))

+ func (h OnPublishHook) Trigger(r *Room)

+ type OnSubscribeHook []func(s *OutputStream)

+ func (h OnSubscribeHook) AddHook(hook func(s *OutputStream))

+ func (h OnSubscribeHook) Trigger(s *OutputStream)

+ type OnSummaryHook []func(bool)

+ func (h OnSummaryHook) AddHook(hook func(bool))

+ func (h OnSummaryHook) Trigger(v bool)

+ type OutputStream struct

+ ASentTime uint32

+ ATSent bool

+ Cancel context.CancelFunc

+ OffsetTime uint32

+ SendHandler func(*avformat.SendPacket) error

+ Sign string

+ VSentTime uint32

+ VTSent bool

+ func (s *OutputStream) Close()

+ func (s *OutputStream) IsClosed() bool

+ func (s *OutputStream) Play(streamPath string) (err error)

+ type PluginConfig struct

+ Config interface{}

+ Name string

+ Run func()

+ Type byte

+ type Publisher interface

+ OnClosed func()

+ type Room struct

+ AudioChan chan *avformat.AVPacket

+ AudioTag *avformat.AVPacket

+ Cancel context.CancelFunc

+ Control chan interface{}

+ FirstScreen []*avformat.AVPacket

+ Subscribers map[string]*OutputStream

+ UseTimestamp bool

+ VideoChan chan *avformat.AVPacket

+ VideoTag *avformat.AVPacket

+ func (r *Room) PushAudio(audio *avformat.AVPacket)

+ func (r *Room) PushVideo(video *avformat.AVPacket)

+ func (r *Room) Run()

+ func (r *Room) Subscribe(s *OutputStream)

+ func (r *Room) UnSubscribe(s *OutputStream)

+ type RoomInfo struct

+ AudioInfo struct{ ... }

+ StartTime time.Time

+ StreamPath string

+ SubscriberInfo []*SubscriberInfo

+ Type string

+ VideoInfo struct{ ... }

+ type ServerSummary struct

+ Address string

+ CPUUsage float64

+ Children map[string]*ServerSummary

+ HardDisk struct{ ... }

+ Memory struct{ ... }

+ NetWork []NetWorkInfo

+ Rooms []*RoomInfo

+ func (s *ServerSummary) Add()

+ func (s *ServerSummary) Done()

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

+ func (s *ServerSummary) Running() bool

+ func (s *ServerSummary) StartSummary()

+ type SubscribeCmd struct

+ type Subscriber interface

+ Send func(*avformat.SendPacket) error

+ type SubscriberInfo struct

+ BufferLength int

+ ID string

+ SubscribeTime time.Time

+ TotalDrop int

+ TotalPacket int

+ Type string

+ type UnSubscribeCmd struct

Other modules containing this package

github.com/Monibuca/engine/v2

github.com/Monibuca/engine/v3

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL