hook

Documentation

Index

• type Gop
• type GopCache
  • func NewGopCache(gopSize, singleGopMaxFrameNum int) *GopCache
  • func (c *GopCache) Clear()
  • func (c *GopCache) Feed(msg base.RtmpMsg)
  • func (c *GopCache) GetGopCount() int
  • func (c *GopCache) GetGopDataAt(pos int) []base.RtmpMsg
• type HookSession
  • func NewHookSession(uniqueKey, streamName string, hlssvr *hls.HlsServer, ...) *HookSession
  • func (session *HookSession) AddConsumer(consumerId string, subscriber IHookSessionSubscriber)
  • func (session *HookSession) GetAllConsumer() []base.StatSub
  • func (session *HookSession) GetAudioSeqHeaderMsg() *base.RtmpMsg
  • func (session *HookSession) GetVideoSeqHeaderMsg() *base.RtmpMsg
  • func (session *HookSession) OnMsg(msg base.RtmpMsg)
  • func (session *HookSession) OnStop()
  • func (session *HookSession) RemoveConsumer(consumerId string)
• type HookSessionMangaer
  • func GetHookSessionManagerInstance() *HookSessionMangaer
  • func (m *HookSessionMangaer) GetHookSession(streamName string) (bool, *HookSession)
  • func (m *HookSessionMangaer) RemoveHookSession(streamName string)
  • func (m *HookSessionMangaer) SetHookSession(streamName string, session *HookSession)
• type IHookSessionSubscriber

Types

type Gop

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

type GopCache

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

GopCache gop cache

func NewGopCache

func NewGopCache(gopSize, singleGopMaxFrameNum int) *GopCache

NewGopCache 创建 gop 缓存

func (*GopCache) Clear

func (c *GopCache) Clear()

func (*GopCache) Feed

func (c *GopCache) Feed(msg base.RtmpMsg)

Feed 写入缓存

func (*GopCache) GetGopCount

func (c *GopCache) GetGopCount() int

func (*GopCache) GetGopDataAt

func (c *GopCache) GetGopDataAt(pos int) []base.RtmpMsg

type HookSession

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

func NewHookSession

func NewHookSession(uniqueKey, streamName string, hlssvr *hls.HlsServer, gopNum, singleGopMaxFrameNum int) *HookSession

func (*HookSession) AddConsumer

func (session *HookSession) AddConsumer(consumerId string, subscriber IHookSessionSubscriber)

func (*HookSession) GetAllConsumer

func (session *HookSession) GetAllConsumer() []base.StatSub

func (*HookSession) GetAudioSeqHeaderMsg

func (session *HookSession) GetAudioSeqHeaderMsg() *base.RtmpMsg

func (*HookSession) GetVideoSeqHeaderMsg

func (session *HookSession) GetVideoSeqHeaderMsg() *base.RtmpMsg

func (*HookSession) OnMsg

func (session *HookSession) OnMsg(msg base.RtmpMsg)

func (*HookSession) OnStop

func (session *HookSession) OnStop()

func (*HookSession) RemoveConsumer

func (session *HookSession) RemoveConsumer(consumerId string)

type HookSessionMangaer

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

func GetHookSessionManagerInstance

func GetHookSessionManagerInstance() *HookSessionMangaer

func (*HookSessionMangaer) GetHookSession

func (m *HookSessionMangaer) GetHookSession(streamName string) (bool, *HookSession)

func (*HookSessionMangaer) RemoveHookSession

func (m *HookSessionMangaer) RemoveHookSession(streamName string)

func (*HookSessionMangaer) SetHookSession

func (m *HookSessionMangaer) SetHookSession(streamName string, session *HookSession)

type IHookSessionSubscriber

type IHookSessionSubscriber interface {
	OnMsg(msg base.RtmpMsg)
	OnStop()
}