logic

Documentation

Index

• Variables
• type Config
  • func LoadConf(confFile string) (*Config, error)
• type Group
  • func NewGroup(appName string, streamName string) *Group
  • func (group *Group) AddHTTPFLVSubSession(session *httpflv.SubSession)
  • func (group *Group) AddRTMPPubSession(session *rtmp.ServerSession) bool
  • func (group *Group) AddRTMPSubSession(session *rtmp.ServerSession)
  • func (group *Group) DelHTTPFLVSubSession(session *httpflv.SubSession)
  • func (group *Group) DelRTMPPubSession(session *rtmp.ServerSession)
  • func (group *Group) DelRTMPSubSession(session *rtmp.ServerSession)
  • func (group *Group) Dispose()
  • func (group *Group) IsInExist() bool
  • func (group *Group) IsTotalEmpty() bool
  • func (group *Group) OnReadRTMPAVMsg(msg rtmp.AVMsg)
  • func (group *Group) RunLoop()
• type HTTPFLV
• type PProf
• type RTMP
• type ServerManager
  • func NewServerManager(config *Config) *ServerManager
  • func (sm *ServerManager) DelHTTPFLVSubSessionCB(session *httpflv.SubSession)
  • 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) bool
  • func (sm *ServerManager) NewRTMPPubSessionCB(session *rtmp.ServerSession) bool
  • func (sm *ServerManager) NewRTMPSubSessionCB(session *rtmp.ServerSession) bool
  • func (sm *ServerManager) RunLoop()

Variables

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

var Trans trans

Types

type Config

type Config struct {
	RTMP    RTMP       `json:"rtmp"`
	HTTPFLV HTTPFLV    `json:"httpflv"`
	Log     log.Option `json:"log"`
	PProf   PProf      `json:"pprof"`
}

func LoadConf

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

type Group

type Group struct {
	UniqueKey string
	// contains filtered or unexported fields
}

func NewGroup

func NewGroup(appName string, streamName string) *Group

func (*Group) AddHTTPFLVSubSession

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

func (*Group) AddRTMPPubSession

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

func (*Group) AddRTMPSubSession

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

func (*Group) DelHTTPFLVSubSession

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

func (*Group) DelRTMPPubSession

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

func (*Group) DelRTMPSubSession

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

func (*Group) Dispose

func (group *Group) Dispose()

func (*Group) IsInExist

func (group *Group) IsInExist() bool

func (*Group) IsTotalEmpty

func (group *Group) IsTotalEmpty() bool

func (*Group) OnReadRTMPAVMsg

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

PubSession or PullSession

func (*Group) RunLoop

func (group *Group) RunLoop()

type HTTPFLV

type HTTPFLV struct {
	SubListenAddr string `json:"sub_listen_addr"`
}

type PProf

type PProf struct {
	Addr string `json:"addr"`
}

type RTMP

type RTMP struct {
	Addr string `json:"addr"`
}

type ServerManager

type ServerManager struct {
	// contains filtered or unexported fields
}

func NewServerManager

func NewServerManager(config *Config) *ServerManager

func (*ServerManager) DelHTTPFLVSubSessionCB

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

ServerObserver of httpflv.Server

func (*ServerManager) DelRTMPPubSessionCB

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

ServerObserver of rtmp.Server

func (*ServerManager) DelRTMPSubSessionCB

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

ServerObserver of rtmp.Server

func (*ServerManager) Dispose

func (sm *ServerManager) Dispose()

func (*ServerManager) NewHTTPFLVSubSessionCB

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

ServerObserver of httpflv.Server

func (*ServerManager) NewRTMPPubSessionCB

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

ServerObserver of rtmp.Server

func (*ServerManager) NewRTMPSubSessionCB

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

ServerObserver of rtmp.Server

func (*ServerManager) RunLoop

func (sm *ServerManager) RunLoop()