pathman

Documentation

Index

• type Parent
• type PathManager
  • func New(rtspPort int, readTimeout time.Duration, writeTimeout time.Duration, ...) *PathManager
  • func (pm *PathManager) ClientClose() chan client.Client
  • func (pm *PathManager) Close()
  • func (pm *PathManager) Log(level logger.Level, format string, args ...interface{})
  • func (pm *PathManager) OnClientAnnounce(req client.AnnounceReq)
  • func (pm *PathManager) OnClientDescribe(req client.DescribeReq)
  • func (pm *PathManager) OnClientSetupPlay(req client.SetupPlayReq)
  • func (pm *PathManager) OnPathClientClose(c client.Client)
  • func (pm *PathManager) OnPathClose(pa *path.Path)
  • func (pm *PathManager) OnProgramConfReload(pathConfs map[string]*conf.PathConf)

Types

type Parent

type Parent interface {
	Log(logger.Level, string, ...interface{})
}

Parent is implemented by program.

type PathManager

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

PathManager is a path.Path manager.

func New

func New(
	rtspPort int,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	readBufferCount int,
	readBufferSize int,
	authMethods []headers.AuthMethod,
	pathConfs map[string]*conf.PathConf,
	stats *stats.Stats,
	parent Parent) *PathManager

New allocates a PathManager.

func (*PathManager) ClientClose

func (pm *PathManager) ClientClose() chan client.Client

ClientClose is called by clientman.ClientMan.

func (*PathManager) Close

func (pm *PathManager) Close()

Close closes a PathManager.

func (*PathManager) Log

func (pm *PathManager) Log(level logger.Level, format string, args ...interface{})

Log is the main logging function.

func (*PathManager) OnClientAnnounce

func (pm *PathManager) OnClientAnnounce(req client.AnnounceReq)

OnClientAnnounce is called by clientman.ClientMan.

func (*PathManager) OnClientDescribe

func (pm *PathManager) OnClientDescribe(req client.DescribeReq)

OnClientDescribe is called by clientman.ClientMan.

func (*PathManager) OnClientSetupPlay

func (pm *PathManager) OnClientSetupPlay(req client.SetupPlayReq)

OnClientSetupPlay is called by clientman.ClientMan.

func (*PathManager) OnPathClientClose

func (pm *PathManager) OnPathClientClose(c client.Client)

OnPathClientClose is called by path.Path.

func (*PathManager) OnPathClose

func (pm *PathManager) OnPathClose(pa *path.Path)

OnPathClose is called by path.Path.

func (*PathManager) OnProgramConfReload

func (pm *PathManager) OnProgramConfReload(pathConfs map[string]*conf.PathConf)

OnProgramConfReload is called by program.