logic

package
v0.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2021 License: MIT Imports: 31 Imported by: 7

Documentation

Index

Constants

View Source 
const ConfVersion = "v0.2.2"

Variables

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

Functions

func Dispose added in v0.15.0 

func Dispose()

func Init added in v0.23.0 

func Init(confFile string)

func RunLoop added in v0.23.0 

func RunLoop()

Types

type CommonHttpAddrConfig added in v0.23.0 

type CommonHttpAddrConfig struct {
	HttpListenAddr  string `json:"http_listen_addr"`
	HttpsListenAddr string `json:"https_listen_addr"`
	HttpsCertFile   string `json:"https_cert_file"`
	HttpsKeyFile    string `json:"https_key_file"`
}

type CommonHttpServerConfig added in v0.23.0 

type CommonHttpServerConfig struct {
	CommonHttpAddrConfig

	Enable      bool   `json:"enable"`
	EnableHttps bool   `json:"enable_https"`
	UrlPattern  string `json:"url_pattern"`
}

type Config 

type Config struct {
	ConfVersion       string            `json:"conf_version"`
	RtmpConfig        RtmpConfig        `json:"rtmp"`
	DefaultHttpConfig DefaultHttpConfig `json:"default_http"`
	HttpflvConfig     HttpflvConfig     `json:"httpflv"`
	HlsConfig         HlsConfig         `json:"hls"`
	HttptsConfig      HttptsConfig      `json:"httpts"`
	RtspConfig        RtspConfig        `json:"rtsp"`
	RecordConfig      RecordConfig      `json:"record"`
	RelayPushConfig   RelayPushConfig   `json:"relay_push"`
	RelayPullConfig   RelayPullConfig   `json:"relay_pull"`

	HttpApiConfig    HttpApiConfig    `json:"http_api"`
	ServerId         string           `json:"server_id"`
	HttpNotifyConfig HttpNotifyConfig `json:"http_notify"`
	PprofConfig      PprofConfig      `json:"pprof"`
	LogConfig        nazalog.Option   `json:"log"`
}

func GetConfig added in v0.23.0 

func GetConfig() *Config

TODO(chef) 临时供innertest使用，后面应该重构

func LoadConfAndInitLog added in v0.21.0 

func LoadConfAndInitLog(confFile string) *Config

type DefaultHttpConfig added in v0.23.0 

type DefaultHttpConfig struct {
	CommonHttpAddrConfig
}

type Gop added in v0.23.0 

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

func (*Gop) Clear added in v0.23.0 

func (g *Gop) Clear()

func (*Gop) Feed added in v0.23.0 

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

type GopCache added in v0.23.0 

type GopCache struct {
	Metadata       []byte
	VideoSeqHeader []byte
	AacSeqHeader   []byte
	// contains filtered or unexported fields
}

提供两个功能:

  1. 缓存Metadata, VideoSeqHeader, AacSeqHeader
  2. 缓存音视频GOP数据

以下，只讨论GopCache的第2点功能

音频和视频都会缓存

GopCache也可能不缓存GOP数据，见NewGopCache函数的gopNum参数说明

以下，我们只讨论gopNum > 0(也即gopSize > 1)的情况

GopCache为空时，只有输入了关键帧，才能开启GOP缓存，非关键帧以及音频数据不会被缓存 因此，单音频的流是ok的，相当于不缓存任何数据

GopCache不为空时，输入关键帧触发生成新的GOP元素，其他情况则往最后一个GOP元素一直追加

first用于读取第一个GOP（可能不完整），last的前一个用于写入当前GOP

最近不完整的GOP也会被缓存，见NewGopCache函数的gopNum参数说明

----- gopNum = 1 gopSize = 2 

first     |   first       |       first   | 在后面两个状态间转换，就不画了
  |       |     |         |        |      |
  0   1   |     0   1	  |    0   1      |
  *   *   |     *   *	  |    *   *      |
  |       |         |	  |    |          |
last      |        last   |   last        |
          |               |               |
(empty)   |   (full)      |   (full)      |

GetGopCount: 0 | 1 | 1 | -----

func NewGopCache added in v0.7.0 

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

@param gopNum: gop缓存大小 

如果为0，则不缓存音频数据，也即GOP缓存功能不生效
如果>0，则缓存<gopNum>个完整GOP，另外还可能有半个最近不完整的GOP

func (*GopCache) Clear added in v0.23.0 

func (gc *GopCache) Clear()

func (*GopCache) Feed added in v0.23.0 

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

func (*GopCache) GetGopCount added in v0.23.0 

func (gc *GopCache) GetGopCount() int

获取GOP数量，注意，最后一个可能是不完整的

func (*GopCache) GetGopDataAt added in v0.23.0 

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

type Group 

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

func NewGroup 

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

func (*Group) AddHttpflvSubSession added in v0.23.0 

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

func (*Group) AddHttptsSubSession added in v0.23.0 

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

TODO chef: 

这里应该也要考虑触发hls muxer开启
也即HTTPTS sub需要使用hls muxer，hls muxer开启和关闭都要考虑HTTPTS sub

func (*Group) AddRtmpPubSession added in v0.23.0 

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

func (*Group) AddRtmpPullSession added in v0.23.0 

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

func (*Group) AddRtmpPushSession added in v0.23.0 

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

func (*Group) AddRtmpSubSession added in v0.23.0 

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

func (*Group) AddRtspPubSession added in v0.23.0 

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

TODO chef: rtsp package中，增加回调返回值判断，如果是false，将连接关掉

func (*Group) BroadcastByRtmpMsg added in v0.23.0 

func (group *Group) BroadcastByRtmpMsg(msg base.RtmpMsg)

func (*Group) DelHttpflvSubSession added in v0.23.0 

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

func (*Group) DelHttptsSubSession added in v0.23.0 

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

func (*Group) DelRtmpPubSession added in v0.23.0 

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

func (*Group) DelRtmpPullSession added in v0.23.0 

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

func (*Group) DelRtmpPushSession added in v0.23.0 

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

func (*Group) DelRtmpSubSession added in v0.23.0 

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

func (*Group) DelRtspPubSession added in v0.23.0 

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

func (*Group) DelRtspSubSession added in v0.23.0 

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

func (*Group) Dispose 

func (group *Group) Dispose()

主动释放所有资源。保证所有资源的生命周期逻辑上都在我们的控制中。降低出bug的几率，降低心智负担。 注意，Dispose后，不应再使用这个对象。 值得一提，如果是从其他协程回调回来的消息，在使用Group中的资源前，要判断资源是否存在以及可用。

TODO chef: 

后续弄个协程来替换掉目前锁的方式，来做消息同步。这样有个好处，就是不用写很多的资源有效判断。统一写一个就好了。
目前Dispose在IsTotalEmpty时调用，暂时没有这个问题。

func (*Group) GetStat added in v0.16.0 

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

func (*Group) HandleNewRtspSubSessionDescribe added in v0.23.0 

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

func (*Group) HandleNewRtspSubSessionPlay added in v0.23.0 

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

func (*Group) HasInSession added in v0.17.0 

func (group *Group) HasInSession() bool

func (*Group) HasOutSession added in v0.17.0 

func (group *Group) HasOutSession() bool

func (*Group) IsHlsMuxerAlive added in v0.23.0 

func (group *Group) IsHlsMuxerAlive() bool

func (*Group) IsTotalEmpty 

func (group *Group) IsTotalEmpty() bool

func (*Group) KickOutSession added in v0.17.0 

func (group *Group) KickOutSession(sessionId string) bool

func (*Group) OnAvPacket added in v0.23.0 

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

rtsp.PubSession

func (*Group) OnPatPmt added in v0.23.0 

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

hls.Muxer

func (*Group) OnReadRtmpAvMsg added in v0.23.0 

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

rtmp.PubSession or rtmp.PullSession

func (*Group) OnRtpPacket added in v0.23.0 

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

rtsp.PubSession

func (*Group) OnSdp added in v0.23.0 

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

rtsp.PubSession

func (*Group) OnTsPackets added in v0.23.0 

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

hls.Muxer

func (*Group) RunLoop 

func (group *Group) RunLoop()

func (*Group) StartPull added in v0.17.0 

func (group *Group) StartPull(url string)

func (*Group) StringifyDebugStats added in v0.19.0 

func (group *Group) StringifyDebugStats() string

func (*Group) Tick added in v0.12.0 

func (group *Group) Tick()

TODO chef: 传入时间 目前每秒触发一次

type HlsConfig added in v0.23.0 

type HlsConfig struct {
	CommonHttpServerConfig

	UseMemoryAsDiskFlag bool `json:"use_memory_as_disk_flag"`
	hls.MuxerConfig
}

type HttpApiConfig added in v0.23.0 

type HttpApiConfig struct {
	Enable bool   `json:"enable"`
	Addr   string `json:"addr"`
}

type HttpApiServer added in v0.23.0 

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

func NewHttpApiServer added in v0.23.0 

func NewHttpApiServer(addr string, observer HttpApiServerObserver) *HttpApiServer

func (*HttpApiServer) Listen added in v0.23.0 

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

func (*HttpApiServer) Runloop added in v0.23.0 

func (h *HttpApiServer) Runloop() error

type HttpApiServerObserver added in v0.23.0 

type HttpApiServerObserver interface {
	OnStatAllGroup() []base.StatGroup
	OnStatGroup(streamName string) *base.StatGroup
	OnCtrlStartPull(info base.ApiCtrlStartPullReq)
	OnCtrlKickOutSession(info base.ApiCtrlKickOutSession) base.HttpResponseBasic
}

type HttpNotify added in v0.23.0 

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

func (*HttpNotify) OnPubStart added in v0.23.0 

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

func (*HttpNotify) OnPubStop added in v0.23.0 

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

func (*HttpNotify) OnRtmpConnect added in v0.23.0 

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

func (*HttpNotify) OnServerStart added in v0.23.0 

func (h *HttpNotify) OnServerStart()

注意，这里的函数命名以On开头并不是因为是回调函数，而是notify给业务方的接口叫做on_server_start

func (*HttpNotify) OnSubStart added in v0.23.0 

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

func (*HttpNotify) OnSubStop added in v0.23.0 

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

func (*HttpNotify) OnUpdate added in v0.23.0 

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

func (*HttpNotify) RunLoop added in v0.23.0 

func (h *HttpNotify) RunLoop()

type HttpNotifyConfig added in v0.23.0 

type HttpNotifyConfig struct {
	Enable            bool   `json:"enable"`
	UpdateIntervalSec int    `json:"update_interval_sec"`
	OnServerStart     string `json:"on_server_start"`
	OnUpdate          string `json:"on_update"`
	OnPubStart        string `json:"on_pub_start"`
	OnPubStop         string `json:"on_pub_stop"`
	OnSubStart        string `json:"on_sub_start"`
	OnSubStop         string `json:"on_sub_stop"`
	OnRtmpConnect     string `json:"on_rtmp_connect"`
}

type HttpServerHandler added in v0.23.0 

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

func NewHttpServerHandler added in v0.23.0 

func NewHttpServerHandler(observer HttpServerHandlerObserver) *HttpServerHandler

func (*HttpServerHandler) ServeSubSession added in v0.23.0 

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

type HttpServerHandlerObserver added in v0.23.0 

type HttpServerHandlerObserver interface {
	// 通知上层有新的拉流者
	// 返回值： true则允许拉流，false则关闭连接
	OnNewHttpflvSubSession(session *httpflv.SubSession) bool

	OnDelHttpflvSubSession(session *httpflv.SubSession)

	OnNewHttptsSubSession(session *httpts.SubSession) bool
	OnDelHttptsSubSession(session *httpts.SubSession)
}

type HttpflvConfig added in v0.23.0 

type HttpflvConfig struct {
	CommonHttpServerConfig

	GopNum int `json:"gop_num"`
}

type HttptsConfig added in v0.23.0 

type HttptsConfig struct {
	CommonHttpServerConfig
}

type LazyChunkDivider added in v0.7.0 

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

考虑以下两种场景： - 只有上行，没有下行，没有必要做rtmp chunk切片的操作 - 有多个下行，只需要做一次rtmp chunk切片 所以这一步做了懒处理

func (*LazyChunkDivider) Get added in v0.7.0 

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

func (*LazyChunkDivider) Init added in v0.7.0 

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

type LazyGet added in v0.8.0 

type LazyGet func() []byte

type LazyRtmpMsg2FlvTag added in v0.23.0 

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

懒转换

func (*LazyRtmpMsg2FlvTag) Get added in v0.23.0 

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

func (*LazyRtmpMsg2FlvTag) Init added in v0.23.0 

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

type PostTask added in v0.17.0 

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

type PprofConfig added in v0.23.0 

type PprofConfig struct {
	Enable bool   `json:"enable"`
	Addr   string `json:"addr"`
}

type RecordConfig added in v0.22.0 

type RecordConfig struct {
	EnableFlv     bool   `json:"enable_flv"`
	FlvOutPath    string `json:"flv_out_path"`
	EnableMpegts  bool   `json:"enable_mpegts"`
	MpegtsOutPath string `json:"mpegts_out_path"`
}

type RelayPullConfig added in v0.12.0 

type RelayPullConfig struct {
	Enable bool   `json:"enable"`
	Addr   string `json:"addr"`
}

type RelayPushConfig added in v0.11.0 

type RelayPushConfig struct {
	Enable   bool     `json:"enable"`
	AddrList []string `json:"addr_list"`
}

type RtmpConfig added in v0.23.0 

type RtmpConfig struct {
	Enable         bool   `json:"enable"`
	Addr           string `json:"addr"`
	GopNum         int    `json:"gop_num"`
	MergeWriteSize int    `json:"merge_write_size"`
}

type RtspConfig added in v0.23.0 

type RtspConfig struct {
	Enable bool   `json:"enable"`
	Addr   string `json:"addr"`
}

type ServerManager 

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

func NewServerManager 

func NewServerManager() *ServerManager

func (*ServerManager) Dispose 

func (sm *ServerManager) Dispose()

func (*ServerManager) GetGroup added in v0.17.0 

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

func (*ServerManager) OnCtrlKickOutSession added in v0.17.0 

func (sm *ServerManager) OnCtrlKickOutSession(info base.ApiCtrlKickOutSession) base.HttpResponseBasic

HttpApiServerObserver

func (*ServerManager) OnCtrlStartPull added in v0.17.0 

func (sm *ServerManager) OnCtrlStartPull(info base.ApiCtrlStartPullReq)

HttpApiServerObserver

func (*ServerManager) OnDelHttpflvSubSession added in v0.23.0 

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

ServerObserver of httpflv.Server

func (*ServerManager) OnDelHttptsSubSession added in v0.23.0 

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

ServerObserver of httpts.Server

func (*ServerManager) OnDelRtmpPubSession added in v0.23.0 

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

ServerObserver of rtmp.Server

func (*ServerManager) OnDelRtmpSubSession added in v0.23.0 

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

ServerObserver of rtmp.Server

func (*ServerManager) OnDelRtspPubSession added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnDelRtspSession added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnDelRtspSubSession added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnNewHttpflvSubSession added in v0.23.0 

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

ServerObserver of httpflv.Server

func (*ServerManager) OnNewHttptsSubSession added in v0.23.0 

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

ServerObserver of httpts.Server

func (*ServerManager) OnNewRtmpPubSession added in v0.23.0 

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

ServerObserver of rtmp.Server

func (*ServerManager) OnNewRtmpSubSession added in v0.23.0 

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

ServerObserver of rtmp.Server

func (*ServerManager) OnNewRtspPubSession added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnNewRtspSessionConnect added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnNewRtspSubSessionDescribe added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnNewRtspSubSessionPlay added in v0.23.0 

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

ServerObserver of rtsp.Server

func (*ServerManager) OnRtmpConnect added in v0.23.0 

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

ServerObserver of rtmp.Server

func (*ServerManager) OnStatAllGroup added in v0.16.0 

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

HttpApiServerObserver

func (*ServerManager) OnStatGroup added in v0.16.0 

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

HttpApiServerObserver

func (*ServerManager) RunLoop 

func (sm *ServerManager) RunLoop() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.