logic

Apr 18, 2024

Changes in this version

type RtspConfig

+ WsRtspAddr string

+ WsRtspEnable bool

Jul 13, 2023

Changes in this version

+ var CheckSessionAliveIntervalSec uint32 = 10

+ var DefaultApiCtrlStartRelayPullReqPullTimeoutMs = 10000

+ var DefaultApiCtrlStartRtpPubReqTimeoutMs = 60000

+ var RelayPushTimeoutMs = 10000

+ var RelayPushWriteAvTimeoutMs = 10000

+ var StaticRelayPullTimeoutMs = 10000

Apr 15, 2023

Changes in this version

+ type GroupOption struct

+ type ICustomizeHookSessionContext interface

+ OnMsg func(msg base.RtmpMsg)

+ OnStop func()

type ILalServer

+ WithOnHookSession func(...)

type ServerManager

+ func (sm *ServerManager) WithOnHookSession(...)

Jan 30, 2023

Changes in this version

type CustomizePubSessionContext

+ func (ctx *CustomizePubSessionContext) FeedRtmpMsg(msg base.RtmpMsg) error

+ func (ctx *CustomizePubSessionContext) WithCustomizePubSessionContextOption(modFn func(option *CustomizePubSessionOption)) *CustomizePubSessionContext

+ type CustomizePubSessionOption struct

+ DebugDumpPacket string

type Group

+ func (group *Group) AddHlsSubSession(session *hls.SubSession)

+ func (group *Group) DelHlsSubSession(session *hls.SubSession)

type HlsConfig

+ SubSessionHashKey string

+ SubSessionTimeoutMs int

type HttpflvConfig

+ SingleGopMaxFrameNum int

type HttptsConfig

+ SingleGopMaxFrameNum int

type ICustomizePubSessionContext

+ FeedRtmpMsg func(msg base.RtmpMsg) error

+ type ModCustomizePubSessionOptionFn func(option *CustomizePubSessionOption)

type RtmpConfig

+ SingleGopMaxFrameNum int

type ServerManager

+ func (sm *ServerManager) OnDelHlsSubSession(session *hls.SubSession)

+ func (sm *ServerManager) OnNewHlsSubSession(session *hls.SubSession) error

Nov 10, 2022

Changes in this version

type Config

+ InSessionConfig InSessionConfig

type CustomizePubSessionContext

+ func (ctx *CustomizePubSessionContext) Dispose()

+ type InSessionConfig struct

+ AddDummyAudioEnable bool

+ AddDummyAudioWaitAudioMs int

type Option

+ ConfRawContent []byte

type RtmpConfig

+ RtmpsAddr string

+ RtmpsCertFile string

+ RtmpsEnable bool

+ RtmpsKeyFile string

type RtspConfig

+ RtspsAddr string

+ RtspsCertFile string

+ RtspsEnable bool

+ RtspsKeyFile string

Oct 7, 2022

Changes in this version

type Group

+ func (group *Group) DelPsPubSession(session *gb28181.PubSession)

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

+ func (group *Group) StartRtpPub(req base.ApiCtrlStartRtpPubReq) (ret base.ApiCtrlStartRtpPub)

+ type IAuthentication interface

+ OnHls func(streamName, urlParam string) error

+ OnPubStart func(info base.PubStartInfo) error

+ OnSubStart func(info base.SubStartInfo) error

+ type ModConfigGroupCreator func(appName, streamName string, baseConfig *Config)

type Option

+ Authentication IAuthentication

+ ModConfigGroupCreator ModConfigGroupCreator

type ServerManager

+ func (sm *ServerManager) CtrlStartRtpPub(info base.ApiCtrlStartRtpPubReq) (ret base.ApiCtrlStartRtpPub)

Jun 15, 2022

Changes in this version

type Config

+ StaticRelayPullConfig StaticRelayPullConfig

type Group

+ func (group *Group) AddRtspPullSession(session *rtsp.PullSession) error

+ func (group *Group) DelRtspPullSession(session *rtsp.PullSession)

+ func (group *Group) IsInactive() bool

+ func (group *Group) KickSession(sessionId string) bool

+ func (group *Group) OnHlsMakeTs(info base.HlsMakeTsInfo)

+ func (group *Group) OutSessionNum() int

+ func (group *Group) StopPull() string

type HttpNotify

+ func (h *HttpNotify) NotifyOnHlsMakeTs(info base.HlsMakeTsInfo)

+ func (h *HttpNotify) NotifyPullStart(info base.PullStartInfo)

+ func (h *HttpNotify) NotifyPullStop(info base.PullStopInfo)

+ func (h *HttpNotify) OnHlsMakeTs(info base.HlsMakeTsInfo)

+ func (h *HttpNotify) OnRelayPullStart(info base.PullStartInfo)

+ func (h *HttpNotify) OnRelayPullStop(info base.PullStopInfo)

type HttpNotifyConfig

+ OnHlsMakeTs string

+ OnRelayPullStart string

+ OnRelayPullStop string

type IGroupObserver

+ OnHlsMakeTs func(info base.HlsMakeTsInfo)

+ OnRelayPullStart func(info base.PullStartInfo)

+ OnRelayPullStop func(info base.PullStopInfo)

type ILalServer

+ CtrlKickSession func(info base.ApiCtrlKickSession) base.HttpResponseBasic

+ CtrlStartRelayPull func(info base.ApiCtrlStartRelayPullReq) base.ApiCtrlStartRelayPull

+ CtrlStopRelayPull func(streamName string) base.ApiCtrlStopRelayPull

type INotifyHandler

+ OnHlsMakeTs func(info base.HlsMakeTsInfo)

+ OnRelayPullStart func(info base.PullStartInfo)

+ OnRelayPullStop func(info base.PullStopInfo)

type ServerManager

+ func (sm *ServerManager) CtrlKickSession(info base.ApiCtrlKickSession) (ret base.HttpResponseBasic)

+ func (sm *ServerManager) CtrlStartRelayPull(info base.ApiCtrlStartRelayPullReq) (ret base.ApiCtrlStartRelayPull)

+ func (sm *ServerManager) CtrlStopRelayPull(streamName string) (ret base.ApiCtrlStopRelayPull)

+ func (sm *ServerManager) OnHlsMakeTs(info base.HlsMakeTsInfo)

+ func (sm *ServerManager) OnRelayPullStart(info base.PullStartInfo)

+ func (sm *ServerManager) OnRelayPullStop(info base.PullStopInfo)

+ type StaticRelayPullConfig struct

+ Addr string

+ Enable bool

May 3, 2022

Changes in this version

+ var DefaultConfFilenameList = []string

+ type CustomizePubSessionContext struct

+ func NewCustomizePubSessionContext(streamName string) *CustomizePubSessionContext

+ func (ctx *CustomizePubSessionContext) FeedAudioSpecificConfig(asc []byte)

+ func (ctx *CustomizePubSessionContext) FeedAvPacket(packet base.AvPacket)

+ func (ctx *CustomizePubSessionContext) StreamName() string

+ func (ctx *CustomizePubSessionContext) UniqueKey() string

+ func (ctx *CustomizePubSessionContext) WithOnRtmpMsg(onRtmpMsg func(msg base.RtmpMsg)) *CustomizePubSessionContext

+ func (ctx *CustomizePubSessionContext) WithOption(modOption func(option *base.AvPacketStreamOption))

type Group

+ func (group *Group) AddCustomizePubSession(streamName string) (ICustomizePubSessionContext, error)

+ func (group *Group) DelCustomizePubSession(sessionCtx ICustomizePubSessionContext)

+ type ICustomizePubSessionContext interface

+ StreamName func() string

+ UniqueKey func() string

type ILalServer

+ AddCustomizePubSession func(streamName string) (ICustomizePubSessionContext, error)

+ DelCustomizePubSession func(ICustomizePubSessionContext)

type Option

+ ConfFilename string

type RtspConfig

+ OutWaitKeyFrameFlag bool

type ServerManager

+ func (sm *ServerManager) AddCustomizePubSession(streamName string) (ICustomizePubSessionContext, error)

+ func (sm *ServerManager) DelCustomizePubSession(sessionCtx ICustomizePubSessionContext)

Mar 27, 2022

Changes in this version

+ var Log = nazalog.GetGlobalLogger()

type Group

+ func (group *Group) OnFragmentOpen()

type HttptsConfig

+ GopNum int

+ type IGroupObserver interface

+ CleanupHlsIfNeeded func(appName string, streamName string, path string)

+ type IHttpServerHandlerObserver interface

+ OnDelHttpflvSubSession func(session *httpflv.SubSession)

+ OnDelHttptsSubSession func(session *httpts.SubSession)

+ OnNewHttpflvSubSession func(session *httpflv.SubSession) error

+ OnNewHttptsSubSession func(session *httpts.SubSession) error

Jan 23, 2022

Changes in this version

+ func SimpleAuthCalcSecret(key string, streamName string) string

type Config

+ DebugConfig DebugConfig

+ SimpleAuthConfig SimpleAuthConfig

+ type DebugConfig struct

+ LogGroupIntervalSec int

+ LogGroupMaxGroupNum int

+ LogGroupMaxSubNumPerGroup int

type Option

+ NotifyHandler INotifyHandler

+ type SimpleAuthConfig struct

+ DangerousLalSecret string

+ HlsM3u8Enable bool

+ Key string

+ PubRtmpEnable bool

+ PubRtspEnable bool

+ SubHttpflvEnable bool

+ SubHttptsEnable bool

+ SubRtmpEnable bool

+ SubRtspEnable bool

+ type SimpleAuthCtx struct

+ func NewSimpleAuthCtx(config SimpleAuthConfig) *SimpleAuthCtx

+ func (s *SimpleAuthCtx) OnHls(streamName string, urlParam string) error

+ func (s *SimpleAuthCtx) OnPubStart(info base.PubStartInfo) error

+ func (s *SimpleAuthCtx) OnSubStart(info base.SubStartInfo) error

Oct 24, 2021

Changes in this version

+ type ComplexGroupManager struct

+ func NewComplexGroupManager(groupCreator IGroupCreator) *ComplexGroupManager

+ func (gm *ComplexGroupManager) GetGroup(appName string, streamName string) *Group

+ func (gm *ComplexGroupManager) GetOrCreateGroup(appName string, streamName string) (group *Group, createFlag bool)

+ func (gm *ComplexGroupManager) Iterate(onIterateGroup func(group *Group) bool)

+ func (gm *ComplexGroupManager) Len() int

+ type GroupObserver interface

+ CleanupHlsIfNeeded func(appName string, streamName string, path string)

type HttpApiServer

+ func (h *HttpApiServer) RunLoop() error

type HttpNotify

+ func NewHttpNotify(cfg HttpNotifyConfig) *HttpNotify

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

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

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

+ func (h *HttpNotify) NotifyServerStart(info base.LalInfo)

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

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

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

+ type IGroupCreator interface

+ CreateGroup func(appName, streamName string) *Group

+ type IGroupManager interface

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

+ GetOrCreateGroup func(appName string, streamName string) (group *Group, createFlag bool)

+ Iterate func(onIterateGroup func(group *Group) bool)

+ Len func() int

+ type ILalServer interface

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

+ CtrlStartPull func(info base.ApiCtrlStartPullReq)

+ Dispose func()

+ RunLoop func() error

+ StatAllGroup func() (sgs []base.StatGroup)

+ StatGroup func(streamName string) *base.StatGroup

+ StatLalInfo func() base.LalInfo

+ func NewLalServer(confFile string, modOption ...ModOption) ILalServer

+ type INotifyHandler interface

+ OnPubStart func(info base.PubStartInfo)

+ OnPubStop func(info base.PubStopInfo)

+ OnRtmpConnect func(info base.RtmpConnectInfo)

+ OnServerStart func(info base.LalInfo)

+ OnSubStart func(info base.SubStartInfo)

+ OnSubStop func(info base.SubStopInfo)

+ OnUpdate func(info base.UpdateInfo)

+ type ModOption func(option *Option)

+ type Option struct

type ServerManager

+ func (sm *ServerManager) CleanupHlsIfNeeded(appName string, streamName string, path string)

+ func (sm *ServerManager) Config() *Config

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

+ func (sm *ServerManager) CtrlKickOutSession(info base.ApiCtrlKickOutSession) base.HttpResponseBasic

+ func (sm *ServerManager) CtrlStartPull(info base.ApiCtrlStartPullReq)

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

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

+ func (sm *ServerManager) StatLalInfo() base.LalInfo

+ type SimpleGroupManager struct

+ func NewSimpleGroupManager(groupCreator IGroupCreator) *SimpleGroupManager

+ func (s *SimpleGroupManager) GetGroup(appName string, streamName string) *Group

+ func (s *SimpleGroupManager) GetOrCreateGroup(appName string, streamName string) (group *Group, createFlag bool)

+ func (s *SimpleGroupManager) Iterate(onIterateGroup func(group *Group) bool)

+ func (s *SimpleGroupManager) Len() int

Aug 28, 2021

Changes in this version

+ type DummyAudioFilter struct

+ func NewDummyAudioFilter(uk string, waitAudioMs int, onPop rtmp.OnReadRtmpAvMsg) *DummyAudioFilter

+ func (filter *DummyAudioFilter) Feed(msg base.RtmpMsg)

+ func (filter *DummyAudioFilter) OnReadRtmpAvMsg(msg base.RtmpMsg)

type RtmpConfig

+ AddDummyAudioEnable bool

+ AddDummyAudioWaitAudioMs int

Jun 6, 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 (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) BroadcastByRtmpMsg(msg base.RtmpMsg)

+ 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

+ 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)

May 3, 2021

Changes in this version

type Config

+ RecordConfig RecordConfig

type Group

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

type HLSConfig

+ UseMemoryAsDiskFlag bool

+ type RecordConfig struct

+ EnableFLV bool

+ EnableMPEGTS bool

+ FLVOutPath string

+ MPEGTSOutPath string

Apr 11, 2021

Changes in this version

+ const ConfVersion

type Config

+ ConfVersion string

+ func LoadConfAndInitLog(confFile string) *Config

type Group

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

Jan 24, 2021

Changes in this version

type Group

+ func (group *Group) StringifyDebugStats() string

Dec 27, 2020

Changes in this version

type Group

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

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

type ServerManager

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

+ 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

Nov 21, 2020

Changes in this version

+ const ConfigVersion

type Config

+ HTTPNotifyConfig HTTPNotifyConfig

+ ServerID string

type Group

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

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

+ func (group *Group) HasInSession() bool

+ func (group *Group) HasOutSession() bool

+ func (group *Group) IsHLSMuxerAlive() bool

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

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

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

type HLSConfig

+ CleanupFlag bool

type HTTPAPIServerObserver

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

+ OnCtrlStartPull func(info base.APICtrlStartPullReq)

+ 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 PostTask struct

type ServerManager

+ 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) OnDelRTSPSubSession(session *rtsp.SubSession)

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

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

Oct 23, 2020

Changes in this version

+ const DespGroupNotFound

+ const DespSucc

+ const ErrorCodeGroupNotFound

+ const ErrorCodeSucc

+ type APIStatAllGroup struct

+ Data struct{ ... }

+ type APIStatGroup struct

+ Data *base.StatGroup

+ type APIStatLALInfo struct

+ Data struct{ ... }

type Config

+ HTTPAPIConfig HTTPAPIConfig

type Group

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

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

+ 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

+ OnStatAllGroup func() []base.StatGroup

+ OnStatGroup func(streamName string) *base.StatGroup

+ type HTTPResponseBasic struct

+ Desp string

+ ErrorCode int

type ServerManager

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

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

Sep 19, 2020

Changes in this version

+ func Dispose()

type Config

+ HTTPTSConfig HTTPTSConfig

type Group

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

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

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

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

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

+ type HTTPTSConfig struct

+ Enable bool

+ SubListenAddr string

type ServerManager

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

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

Aug 23, 2020

Changes in this version

type Config

+ RTSPConfig RTSPConfig

type Group

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

+ func (group *Group) OnASC(asc []byte)

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

+ func (group *Group) OnSPSPPS(sps, pps []byte)

+ type RTSPConfig struct

+ Addr string

+ Enable bool

type ServerManager

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

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

Jul 18, 2020

Changes in this version

type ServerManager

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

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

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

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

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

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

Jun 20, 2020

Changes in this version

type Config

+ RelayPullConfig RelayPullConfig

type Group

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

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

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

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

+ func (group *Group) StringifyStats() string

+ func (group *Group) Tick()

+ type RelayPullConfig struct

+ Addr string

+ Enable bool

Jun 13, 2020

Changes in this version

type Config

+ RelayPushConfig RelayPushConfig

type HLSConfig

+ Enable bool

+ type RelayPush struct

+ IsFresh bool

+ func NewRelayPush(url string) *RelayPush

+ func (rp *RelayPush) AsyncWrite(msg []byte) error

+ func (rp *RelayPush) Connected() bool

+ func (rp *RelayPush) Dispose()

+ func (rp *RelayPush) Start()

+ func (rp *RelayPush) Stop()

+ type RelayPushConfig struct

+ AddrList []string

+ Enable bool

+ type RelayPushStatus uint

+ const RelayPushStatusDispose

+ const RelayPushStatusStart

+ const RelayPushStatusStop

Jun 6, 2020

Changes in this version

+ func Entry(confFile string)

type Config

+ HLSConfig HLSConfig

+ HTTPFLVConfig HTTPFLVConfig

+ LogConfig nazalog.Option

+ PProfConfig PProfConfig

+ RTMPConfig RTMPConfig

type GOP

+ func (g *GOP) Clear()

type GOPCache

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

+ func (gc *GOPCache) GetGOPCount() int

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

+ type HLSConfig struct

+ SubListenAddr string

+ type HTTPFLVConfig struct

+ Enable bool

+ GOPNum int

+ SubListenAddr string

+ type PProfConfig struct

+ Addr string

+ Enable bool

+ type RTMPConfig struct

+ Addr string

+ Enable bool

+ GOPNum int

May 30, 2020

Changes in this version

type Config

+ HLS HLS

+ type HLS struct

+ SubListenAddr string

Apr 18, 2020

Changes in this version

+ type GOP struct

+ func (g *GOP) Feed(msg rtmp.AVMsg, b []byte)

type GOPCache

+ AACSeqHeader []byte

+ Metadata []byte

+ VideoSeqHeader []byte

+ func (gc *GOPCache) Clear()

+ func (gc *GOPCache) GetFullGOP() []*GOP

+ func (gc *GOPCache) GetLastGOP() *GOP

type HTTPFLV

+ GOPNum int

+ type LazyGet func() []byte

+ type LazyRTMPMsg2FLVTag struct

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

+ func (l *LazyRTMPMsg2FLVTag) Init(msg rtmp.AVMsg)

type RTMP

+ GOPNum int

Dec 13, 2019

Changes in this version

+ type GOPCache struct

+ func NewGopCache(num int) *GOPCache

+ func (gc *GOPCache) Feed(msg rtmp.AVMsg, lcd LazyChunkDivider)

+ type LazyChunkDivider struct

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

+ func (lcd *LazyChunkDivider) Init(message []byte, header *rtmp.Header)

Nov 1, 2019

Changes in this version

type Group

+ func (group *Group) OnReadRTMPAVMsg(msg rtmp.AVMsg)

Oct 25, 2019

Changes in this version

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

type Config

+ HTTPFLV HTTPFLV

type Group

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

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

+ type HTTPFLV struct

+ SubListenAddr string

type ServerManager

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

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

Sep 21, 2019

Changes in this version

+ var Trans trans

+ type Config struct

+ GOPCacheNum int

+ HTTPFlv HTTPFlv

+ Log log.Config

+ PProf PProf

+ Pull Pull

+ RTMP RTMP

+ SubIdleTimeout int64

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

+ type Group struct

+ UniqueKey string

+ func NewGroup(appName string, streamName string) *Group

+ func (group *Group) AddHTTPFlvSubSession(session *httpflv.SubSession, httpFlvGroup *httpflv.Group)

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

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

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

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

+ func (group *Group) Dispose(err error)

+ func (group *Group) IsInExist() bool

+ func (group *Group) IsTotalEmpty() bool

+ func (group *Group) Pull(addr string, connectTimeout int64)

+ func (group *Group) ReadFlvHeaderCB(flvHeader []byte)

+ func (group *Group) ReadFlvTagCB(tag *httpflv.Tag)

+ func (group *Group) ReadHTTPRespHeaderCB()

+ func (group *Group) ReadRTMPAVMsgCB(header rtmp.Header, timestampAbs uint32, message []byte)

+ func (group *Group) RunLoop()

+ type HTTPFlv struct

+ SubListenAddr string

+ type PProf struct

+ Addr string

+ type Pull struct

+ Addr string

+ ConnectTimeout int64

+ ReadTimeout int64

+ StopPullWhileNoSubTimeout int64

+ Type string

+ type RTMP struct

+ Addr string

+ type ServerManager struct

+ func NewServerManager(config *Config) *ServerManager

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

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

+ func (sm *ServerManager) Dispose()

+ func (sm *ServerManager) NewHTTPFlvSubSessionCB(session *httpflv.SubSession, httpFlvGroup *httpflv.Group) bool

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

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

+ func (sm *ServerManager) RunLoop()