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 + var LocalCert []byte + var LocalKey []byte + type Card struct + Component string + ComponentProps map[string]any + Index int + Properties map[string]any + Type string + type Config struct + Default any + Enum []struct{ ... } + Env any + File any + Global *Config + Modify any + Ptr reflect.Value + func (config *Config) Get(key string) (v *Config) + func (config *Config) GetFormily() (r Object) + func (config *Config) GetMap() map[string]any + func (config *Config) GetValue() any + func (config *Config) IsMap() bool + func (config *Config) MarshalJSON() ([]byte, error) + func (config *Config) Parse(s any, prefix ...string) + func (config *Config) ParseDefaultYaml(defaultYaml map[string]any) + func (config *Config) ParseGlobal(g *Config) + func (config *Config) ParseModifyFile(conf map[string]any) + func (config *Config) ParseUserFile(conf map[string]any) + func (config *Config) Range(f func(key string, value Config)) + func (config Config) Has(key string) (ok bool) + type Console struct + PublicAddr string + PublicAddrTLS string + Secret string + Server string + type Engine struct + DisableAll bool + EnableAVCC bool + EnableAuth bool + EnableRTP bool + EnableSubEvent bool + EventBusSize int + LogLang string + LogLevel string + PoolSize int + PulseInterval time.Duration + RTPReorderBufferLen int + var Global *Engine + func (cfg *Engine) GetEnableReport() bool + func (cfg *Engine) GetInstanceId() string + func (cfg *Engine) InitDefaultHttp() + func (cfg *Engine) OnEvent(event any) + func (cfg *Engine) ReceiveRequest(s quic.Stream, conn quic.Connection) error + func (cfg *Engine) Remote(ctx context.Context) (wasConnected bool, err error) + func (cfg *Engine) WsRemote() + func (cfg *Engine) WtRemote(ctx context.Context) + type HTTP struct + CORS bool + CertFile string + IdleTimeout time.Duration + KeyFile string + ListenAddr string + ListenAddrTLS string + Password string + ReadTimeout time.Duration + UserName string + WriteTimeout time.Duration + func (config *HTTP) AddMiddleware(middleware Middleware) + func (config *HTTP) GetHTTPConfig() *HTTP + func (config *HTTP) Handle(path string, f http.Handler) + func (config *HTTP) Handler(r *http.Request) (h http.Handler, pattern string) + func (config *HTTP) Listen(ctx context.Context) error + type HTTPConfig interface + AddMiddleware func(Middleware) + GetHTTPConfig func() *HTTP + Handle func(string, http.Handler) + Handler func(*http.Request) (http.Handler, string) + Listen func(ctx context.Context) error + type HTTPPlugin interface + type Middleware func(string, http.Handler) http.Handler + type Object struct + Properties map[string]any + Type string + type Plugin interface + OnEvent func(any) + type Property struct + Component string + ComponentProps map[string]any + Decorator string + DecoratorProps map[string]any + Default any + Description string + Enum []struct{ ... } + Index int + Items *Object + Properties map[string]any + Title string + Type string + type Publish struct + BufferTime time.Duration + DelayCloseTimeout time.Duration + ExpireArgName string + IdleTimeout time.Duration + Key string + KickExist bool + PauseTimeout time.Duration + PubAudio bool + PubVideo bool + PublishTimeout time.Duration + RingSize string + SecretArgName string + SpeedLimit time.Duration + WaitCloseTimeout time.Duration + func (c Publish) GetPublishConfig() Publish + type PublishConfig interface + GetPublishConfig func() Publish + type Pull struct + EnableRegexp bool + Proxy string + PullOnStart map[string]string + PullOnStartLocker sync.RWMutex + PullOnSub map[string]string + PullOnSubLocker sync.RWMutex + RePull int + func (p *Pull) CheckPullOnStart(streamPath string) string + func (p *Pull) CheckPullOnSub(streamPath string) string + func (p *Pull) GetPullConfig() *Pull + type PullConfig interface + GetPullConfig func() *Pull + type Push struct + EnableRegexp bool + Proxy string + PushList map[string]string + RePush int + func (p *Push) AddPush(url string, streamPath string) + func (p *Push) CheckPush(streamPath string) string + func (p *Push) GetPushConfig() *Push + type PushConfig interface + GetPushConfig func() *Push + type Quic struct + CertFile string + KeyFile string + ListenAddr string + func (q *Quic) ListenQuic(ctx context.Context, plugin QuicPlugin) error + type QuicConfig interface + ListenQuic func(context.Context, QuicPlugin) error + type QuicPlugin interface + ServeQuic func(quic.Connection) + type Regexp struct + func (r *Regexp) UnmarshalJSON(b []byte) error + func (r *Regexp) UnmarshalYAML(node *yaml.Node) error + func (r *Regexp) Valid() bool + func (r Regexp) MarshalJSON() ([]byte, error) + func (r Regexp) MarshalYAML() (interface{}, error) + func (r Regexp) String() string + type Subscribe struct + ExpireArgName string + IFrameOnly bool + Internal bool + Key string + SecretArgName string + SubAudio bool + SubAudioArgName string + SubAudioTracks []string + SubDataArgName string + SubDataTracks []string + SubMode int + SubModeArgName string + SubVideo bool + SubVideoArgName string + SubVideoTracks []string + SyncMode int + WaitTimeout time.Duration + WriteBufferSize int + func (c *Subscribe) GetSubscribeConfig() *Subscribe + type SubscribeConfig interface + GetSubscribeConfig func() *Subscribe + type TCP struct + CertFile string + KeyFile string + ListenAddr string + ListenAddrTLS string + ListenNum int + NoDelay bool + func (tcp *TCP) ListenTCP(ctx context.Context, plugin TCPPlugin) error + type TCPConfig interface + ListenTCP func(context.Context, TCPPlugin) error + type TCPPlugin interface + ServeTCP func(net.Conn)
Go to main page