logic

package

Go to main page

Versions in this module

v0

v0.24.28

Oct 29, 2021

v0.24.27

Oct 29, 2021

v0.24.26

Oct 28, 2021

v0.24.25

Oct 28, 2021

v0.24.24

Oct 21, 2021

v0.24.23

Oct 21, 2021

v0.24.22

Oct 15, 2021

v0.24.21

Sep 12, 2021

v0.24.20

Sep 12, 2021

v0.24.19

Sep 12, 2021

v0.24.18

Aug 24, 2021

v0.24.17

Aug 24, 2021

v0.24.16

Aug 24, 2021

v0.24.15

Aug 24, 2021

v0.24.14

Aug 24, 2021

v0.24.13

Aug 22, 2021

v0.24.12

Aug 22, 2021

v0.24.11

Aug 22, 2021

v0.24.10

Aug 22, 2021

v0.24.9

Aug 22, 2021

v0.24.8

Aug 22, 2021

v0.24.7

Aug 22, 2021

v0.24.6

Aug 20, 2021

v0.24.5

Aug 20, 2021

v0.24.4

Aug 19, 2021

v0.24.3

Aug 19, 2021

Changes in this version

+ func SetConfig(c *Config)

v0.24.2

Aug 19, 2021

Changes in this version

type ServerManager

+ func NewStandaloneServerManager(config *Config) *ServerManager

v0.24.1

Aug 19, 2021

Changes in this version

+ func Init(confFile string)

+ func RunLoop()

+ type CommonHttpAddrConfig struct

+ HttpListenAddr string

+ HttpsCertFile string

+ HttpsKeyFile string

+ HttpsListenAddr string

+ type CommonHttpServerConfig struct

+ Enable bool

+ EnableHttps bool

+ UrlPattern string

type Config

+ DefaultHttpConfig DefaultHttpConfig

+ HlsConfig HlsConfig

+ HttpApiConfig HttpApiConfig

+ HttpNotifyConfig HttpNotifyConfig

+ HttpflvConfig HttpflvConfig

+ HttptsConfig HttptsConfig

+ PprofConfig PprofConfig

+ RtmpConfig RtmpConfig

+ RtspConfig RtspConfig

+ ServerId string

+ func GetConfig() *Config

+ type DefaultHttpConfig struct

+ type Gop struct

+ func (g *Gop) Clear()

+ func (g *Gop) Feed(msg base.RtmpMsg, b []byte)

+ type GopCache struct

+ AacSeqHeader []byte

+ Metadata []byte

+ VideoSeqHeader []byte

+ func NewGopCache(t string, uniqueKey string, gopNum int) *GopCache

+ func (gc *GopCache) Clear()

+ func (gc *GopCache) Feed(msg base.RtmpMsg, lg LazyGet)

+ func (gc *GopCache) GetGopCount() int

+ func (gc *GopCache) GetGopDataAt(pos int) [][]byte

type Group

+ func (group *Group) AddHttpflvSubSession(session *httpflv.SubSession)

+ func (group *Group) AddHttptsSubSession(session *httpts.SubSession)

+ func (group *Group) AddRtmpPubSession(session *rtmp.ServerSession) bool

+ func (group *Group) AddRtmpPullSession(session *rtmp.PullSession) bool

+ func (group *Group) AddRtmpPushSession(url string, session *rtmp.PushSession)

+ func (group *Group) AddRtmpSubSession(session *rtmp.ServerSession)

+ func (group *Group) AddRtspPubSession(session *rtsp.PubSession) bool

+ func (group *Group) DelHttpflvSubSession(session *httpflv.SubSession)

+ func (group *Group) DelHttptsSubSession(session *httpts.SubSession)

+ func (group *Group) DelRtmpPubSession(session *rtmp.ServerSession)

+ func (group *Group) DelRtmpPullSession(session *rtmp.PullSession)

+ func (group *Group) DelRtmpPushSession(url string, session *rtmp.PushSession)

+ func (group *Group) DelRtmpSubSession(session *rtmp.ServerSession)

+ func (group *Group) DelRtspPubSession(session *rtsp.PubSession)

+ func (group *Group) DelRtspSubSession(session *rtsp.SubSession)

+ func (group *Group) HandleNewRtspSubSessionDescribe(session *rtsp.SubSession) (ok bool, sdp []byte)

+ func (group *Group) HandleNewRtspSubSessionPlay(session *rtsp.SubSession) bool

+ func (group *Group) IsHlsMuxerAlive() bool

+ func (group *Group) OnAvPacket(pkt base.AvPacket)

+ func (group *Group) OnPatPmt(b []byte)

+ func (group *Group) OnReadRtmpAvMsg(msg base.RtmpMsg)

+ func (group *Group) OnRtpPacket(pkt rtprtcp.RtpPacket)

+ func (group *Group) OnSdp(sdpCtx sdp.LogicContext)

+ func (group *Group) OnTsPackets(rawFrame []byte, boundary bool)

+ type HlsConfig struct

+ EventObserverConfig hls.MuxerEventObserver

+ HttpReadFileFallback hls.ReadFileFallback

+ UseMemoryAsDiskFlag bool

+ type HttpApiConfig struct

+ Addr string

+ Enable bool

+ type HttpApiServer struct

+ func NewHttpApiServer(addr string, observer HttpApiServerObserver) *HttpApiServer

+ func (h *HttpApiServer) Listen() (err error)

+ func (h *HttpApiServer) Runloop() error

+ type HttpApiServerObserver interface

+ OnCtrlKickOutSession func(info base.ApiCtrlKickOutSession) base.HttpResponseBasic

+ OnCtrlStartPull func(info base.ApiCtrlStartPullReq)

+ OnStatAllGroup func() []base.StatGroup

+ OnStatGroup func(streamName string) *base.StatGroup

+ type HttpNotify struct

+ func (h *HttpNotify) OnPubStart(info base.PubStartInfo)

+ func (h *HttpNotify) OnPubStop(info base.PubStopInfo)

+ func (h *HttpNotify) OnRtmpConnect(info base.RtmpConnectInfo)

+ func (h *HttpNotify) OnServerStart()

+ func (h *HttpNotify) OnSubStart(info base.SubStartInfo)

+ func (h *HttpNotify) OnSubStop(info base.SubStopInfo)

+ func (h *HttpNotify) OnUpdate(info base.UpdateInfo)

+ func (h *HttpNotify) RunLoop()

+ type HttpNotifyConfig struct

+ Enable bool

+ OnPubStart string

+ OnPubStop string

+ OnRtmpConnect string

+ OnServerStart string

+ OnSubStart string

+ OnSubStop string

+ OnUpdate string

+ UpdateIntervalSec int

+ type HttpServerHandler struct

+ func NewHttpServerHandler(observer HttpServerHandlerObserver) *HttpServerHandler

+ func (h *HttpServerHandler) ServeSubSession(writer http.ResponseWriter, req *http.Request)

+ type HttpServerHandlerObserver interface

+ OnDelHttpflvSubSession func(session *httpflv.SubSession)

+ OnDelHttptsSubSession func(session *httpts.SubSession)

+ OnNewHttpflvSubSession func(session *httpflv.SubSession) bool

+ OnNewHttptsSubSession func(session *httpts.SubSession) bool

+ type HttpflvConfig struct

+ GopNum int

+ type HttptsConfig struct

+ type LazyRtmpMsg2FlvTag struct

+ func (l *LazyRtmpMsg2FlvTag) Get() []byte

+ func (l *LazyRtmpMsg2FlvTag) Init(msg base.RtmpMsg)

+ type PprofConfig struct

+ Addr string

+ Enable bool

type RecordConfig

+ EnableFlv bool

+ EnableMpegts bool

+ FlvOutPath string

+ MpegtsOutPath string

+ type RtmpConfig struct

+ Addr string

+ Enable bool

+ GopNum int

+ MergeWriteSize int

+ type RtspConfig struct

+ Addr string

+ Enable bool

type ServerManager

+ func (sm *ServerManager) OnDelHttpflvSubSession(session *httpflv.SubSession)

+ func (sm *ServerManager) OnDelHttptsSubSession(session *httpts.SubSession)

+ func (sm *ServerManager) OnDelRtmpPubSession(session *rtmp.ServerSession)

+ func (sm *ServerManager) OnDelRtmpSubSession(session *rtmp.ServerSession)

+ func (sm *ServerManager) OnDelRtspPubSession(session *rtsp.PubSession)

+ func (sm *ServerManager) OnDelRtspSession(session *rtsp.ServerCommandSession)

+ func (sm *ServerManager) OnDelRtspSubSession(session *rtsp.SubSession)

+ func (sm *ServerManager) OnNewHttpflvSubSession(session *httpflv.SubSession) bool

+ func (sm *ServerManager) OnNewHttptsSubSession(session *httpts.SubSession) bool

+ func (sm *ServerManager) OnNewRtmpPubSession(session *rtmp.ServerSession) bool

+ func (sm *ServerManager) OnNewRtmpSubSession(session *rtmp.ServerSession) bool

+ func (sm *ServerManager) OnNewRtspPubSession(session *rtsp.PubSession) bool

+ func (sm *ServerManager) OnNewRtspSessionConnect(session *rtsp.ServerCommandSession)

+ func (sm *ServerManager) OnNewRtspSubSessionDescribe(session *rtsp.SubSession) (ok bool, sdp []byte)

+ func (sm *ServerManager) OnNewRtspSubSessionPlay(session *rtsp.SubSession) bool

+ func (sm *ServerManager) OnRtmpConnect(session *rtmp.ServerSession, opa rtmp.ObjectPairArray)

v0.19.16

Aug 18, 2021

v0.19.15

Aug 18, 2021

v0.19.14

Aug 18, 2021

v0.19.13

Aug 16, 2021

v0.19.12

May 1, 2021

Changes in this version

+ const ConfVersion

type Config

+ ConfVersion string

+ RecordConfig RecordConfig

+ func LoadConfAndInitLog(confFile string) *Config

type Group

+ func (group *Group) BroadcastRTMP(msg base.RTMPMsg)

type HLSConfig

+ UseMemoryAsDiskFlag bool

+ type RecordConfig struct

+ EnableFLV bool

+ EnableMPEGTS bool

+ FLVOutPath string

+ MPEGTSOutPath string

v0.19.11

Apr 14, 2021

v0.19.10

Apr 14, 2021

v0.19.9

Apr 14, 2021

Changes in this version

type HLSConfig

+ HttpReadFileFallback hls.ReadFileFallback

v0.19.8

Mar 22, 2021

v0.19.7

Mar 22, 2021

v0.19.6

Mar 22, 2021

v0.19.5

Mar 22, 2021

v0.19.4

Mar 22, 2021

v0.19.3

Mar 22, 2021

Changes in this version

type HLSConfig

+ EventObserverConfig hls.MuxerEventObserver

v0.19.2

Mar 19, 2021

Changes in this version

+ const ConfigVersion

+ var ErrLogic = errors.New("lal.logic: fxxk")

+ func Dispose()

+ func Entry(confFile string)

+ func RunServer(c *Config)

+ type Config struct

+ HLSConfig HLSConfig

+ HTTPAPIConfig HTTPAPIConfig

+ HTTPFLVConfig HTTPFLVConfig

+ HTTPNotifyConfig HTTPNotifyConfig

+ HTTPTSConfig HTTPTSConfig

+ LogConfig nazalog.Option

+ PProfConfig PProfConfig

+ RTMPConfig RTMPConfig

+ RTSPConfig RTSPConfig

+ RelayPullConfig RelayPullConfig

+ RelayPushConfig RelayPushConfig

+ ServerID string

+ func LoadConf(confFile string) (*Config, error)

+ type GOP struct

+ func (g *GOP) Clear()

+ func (g *GOP) Feed(msg base.RTMPMsg, b []byte)

+ type GOPCache struct

+ AACSeqHeader []byte

+ Metadata []byte

+ VideoSeqHeader []byte

+ func NewGOPCache(t string, uniqueKey string, gopNum int) *GOPCache

+ func (gc *GOPCache) Clear()

+ func (gc *GOPCache) Feed(msg base.RTMPMsg, lg LazyGet)

+ func (gc *GOPCache) GetGOPCount() int

+ func (gc *GOPCache) GetGOPDataAt(pos int) [][]byte

+ type Group struct

+ UniqueKey string

+ func NewGroup(appName string, streamName string, pullEnable bool, pullURL string) *Group

+ func (group *Group) AddHTTPFLVSubSession(session *httpflv.SubSession)

+ func (group *Group) AddHTTPTSSubSession(session *httpts.SubSession)

+ func (group *Group) AddRTMPPubSession(session *rtmp.ServerSession) bool

+ func (group *Group) AddRTMPPullSession(session *rtmp.PullSession) bool

+ func (group *Group) AddRTMPPushSession(url string, session *rtmp.PushSession)

+ func (group *Group) AddRTMPSubSession(session *rtmp.ServerSession)

+ func (group *Group) AddRTSPPubSession(session *rtsp.PubSession) bool

+ func (group *Group) DelHTTPFLVSubSession(session *httpflv.SubSession)

+ func (group *Group) DelHTTPTSSubSession(session *httpts.SubSession)

+ func (group *Group) DelRTMPPubSession(session *rtmp.ServerSession)

+ func (group *Group) DelRTMPPullSession(session *rtmp.PullSession)

+ func (group *Group) DelRTMPPushSession(url string, session *rtmp.PushSession)

+ func (group *Group) DelRTMPSubSession(session *rtmp.ServerSession)

+ func (group *Group) DelRTSPPubSession(session *rtsp.PubSession)

+ func (group *Group) DelRTSPSubSession(session *rtsp.SubSession)

+ func (group *Group) Dispose()

+ func (group *Group) GetStat() base.StatGroup

+ func (group *Group) HandleNewRTSPSubSessionDescribe(session *rtsp.SubSession) (ok bool, sdp []byte)

+ func (group *Group) HandleNewRTSPSubSessionPlay(session *rtsp.SubSession) bool

+ func (group *Group) HasInSession() bool

+ func (group *Group) HasOutSession() bool

+ func (group *Group) IsHLSMuxerAlive() bool

+ func (group *Group) IsTotalEmpty() bool

+ func (group *Group) KickOutSession(sessionID string) bool

+ func (group *Group) OnAVConfig(asc, vps, sps, pps []byte)

+ func (group *Group) OnAVPacket(pkt base.AVPacket)

+ func (group *Group) OnRTPPacket(pkt rtprtcp.RTPPacket)

+ func (group *Group) OnReadRTMPAVMsg(msg base.RTMPMsg)

+ func (group *Group) OnTSPackets(rawFrame []byte, boundary bool)

+ func (group *Group) RunLoop()

+ func (group *Group) StartPull(url string)

+ func (group *Group) StringifyDebugStats() string

+ func (group *Group) Tick()

+ type HLSConfig struct

+ CleanupFlag bool

+ SubListenAddr string

+ type HTTPAPIConfig struct

+ Addr string

+ Enable bool

+ type HTTPAPIServer struct

+ func NewHTTPAPIServer(addr string, observer HTTPAPIServerObserver) *HTTPAPIServer

+ func (h *HTTPAPIServer) Listen() (err error)

+ func (h *HTTPAPIServer) Runloop() error

+ type HTTPAPIServerObserver interface

+ OnCtrlKickOutSession func(info base.APICtrlKickOutSession) base.HTTPResponseBasic

+ OnCtrlStartPull func(info base.APICtrlStartPullReq)

+ OnStatAllGroup func() []base.StatGroup

+ OnStatGroup func(streamName string) *base.StatGroup

+ type HTTPFLVConfig struct

+ GOPNum int

+ type HTTPNotify struct

+ func (h *HTTPNotify) OnPubStart(info base.PubStartInfo)

+ func (h *HTTPNotify) OnPubStop(info base.PubStopInfo)

+ func (h *HTTPNotify) OnRTMPConnect(info base.RTMPConnectInfo)

+ func (h *HTTPNotify) OnServerStart()

+ func (h *HTTPNotify) OnSubStart(info base.SubStartInfo)

+ func (h *HTTPNotify) OnSubStop(info base.SubStopInfo)

+ func (h *HTTPNotify) OnUpdate(info base.UpdateInfo)

+ func (h *HTTPNotify) RunLoop()

+ type HTTPNotifyConfig struct

+ Enable bool

+ OnPubStart string

+ OnPubStop string

+ OnRTMPConnect string

+ OnServerStart string

+ OnSubStart string

+ OnSubStop string

+ OnUpdate string

+ UpdateIntervalSec int

+ type HTTPTSConfig struct

+ Enable bool

+ SubListenAddr string

+ type LazyChunkDivider struct

+ func (lcd *LazyChunkDivider) Get() []byte

+ func (lcd *LazyChunkDivider) Init(message []byte, header *base.RTMPHeader)

+ type LazyGet func() []byte

+ type LazyRTMPMsg2FLVTag struct

+ func (l *LazyRTMPMsg2FLVTag) Get() []byte

+ func (l *LazyRTMPMsg2FLVTag) Init(msg base.RTMPMsg)

+ type PProfConfig struct

+ Addr string

+ Enable bool

+ type PostTask struct

+ type RTMPConfig struct

+ Addr string

+ Enable bool

+ GOPNum int

+ type RTSPConfig struct

+ Addr string

+ Enable bool

+ type RelayPullConfig struct

+ Addr string

+ Enable bool

+ type RelayPushConfig struct

+ AddrList []string

+ Enable bool

+ type ServerManager struct

+ func NewServerManager() *ServerManager

+ func (sm *ServerManager) Dispose()

+ func (sm *ServerManager) GetGroup(appName string, streamName string) *Group

+ func (sm *ServerManager) OnCtrlKickOutSession(info base.APICtrlKickOutSession) base.HTTPResponseBasic

+ func (sm *ServerManager) OnCtrlStartPull(info base.APICtrlStartPullReq)

+ func (sm *ServerManager) OnDelHTTPFLVSubSession(session *httpflv.SubSession)

+ func (sm *ServerManager) OnDelHTTPTSSubSession(session *httpts.SubSession)

+ func (sm *ServerManager) OnDelRTMPPubSession(session *rtmp.ServerSession)

+ func (sm *ServerManager) OnDelRTMPSubSession(session *rtmp.ServerSession)

+ func (sm *ServerManager) OnDelRTSPPubSession(session *rtsp.PubSession)

+ func (sm *ServerManager) OnDelRTSPSession(session *rtsp.ServerCommandSession)

+ func (sm *ServerManager) OnDelRTSPSubSession(session *rtsp.SubSession)

+ func (sm *ServerManager) OnNewHTTPFLVSubSession(session *httpflv.SubSession) bool

+ func (sm *ServerManager) OnNewHTTPTSSubSession(session *httpts.SubSession) bool

+ func (sm *ServerManager) OnNewRTMPPubSession(session *rtmp.ServerSession) bool

+ func (sm *ServerManager) OnNewRTMPSubSession(session *rtmp.ServerSession) bool

+ func (sm *ServerManager) OnNewRTSPPubSession(session *rtsp.PubSession) bool

+ func (sm *ServerManager) OnNewRTSPSessionConnect(session *rtsp.ServerCommandSession)

+ func (sm *ServerManager) OnNewRTSPSubSessionDescribe(session *rtsp.SubSession) (ok bool, sdp []byte)

+ func (sm *ServerManager) OnNewRTSPSubSessionPlay(session *rtsp.SubSession) bool

+ func (sm *ServerManager) OnRTMPConnect(session *rtmp.ServerSession, opa rtmp.ObjectPairArray)

+ func (sm *ServerManager) OnStatAllGroup() (sgs []base.StatGroup)

+ func (sm *ServerManager) OnStatGroup(streamName string) *base.StatGroup

+ func (sm *ServerManager) RunLoop()

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