pathmanager

Documentation

Index

• type AuthManager
• type HLSServer
• type Parent
• type PathManager
  • func New(logLevel conf.LogLevel, authManager AuthManager, rtspAddress string, ...) *PathManager
  • func (pm *PathManager) APIPathsGet(name string) (*defs.APIPath, error)
  • func (pm *PathManager) APIPathsList() (*defs.APIPathList, error)
  • func (pm *PathManager) AddPublisher(req defs.PathAddPublisherReq) (defs.Path, error)
  • func (pm *PathManager) AddReader(req defs.PathAddReaderReq) (defs.Path, *stream.Stream, error)
  • func (pm *PathManager) Close()
  • func (pm *PathManager) Describe(req defs.PathDescribeReq) defs.PathDescribeRes
  • func (pm *PathManager) FindPathConf(req defs.PathFindPathConfReq) (*conf.Path, error)
  • func (pm *PathManager) Initialize(ctx context.Context)
  • func (pm *PathManager) Log(level logger.Level, format string, args ...interface{})
  • func (pm *PathManager) ReloadPathConfs(pathConfs map[string]*conf.Path)
  • func (pm *PathManager) SetHLSServer(s HLSServer)

Types

type AuthManager

type AuthManager interface {
	Authenticate(req *auth.Request) error
}

type HLSServer

type HLSServer interface {
	PathReady(defs.Path)
	PathNotReady(defs.Path)
}

type Parent

type Parent interface {
	logger.Writer
}

type PathManager

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

func New

func New(
	logLevel conf.LogLevel,
	authManager AuthManager,
	rtspAddress string,
	readTimeout conf.StringDuration,
	writeTimeout conf.StringDuration,
	writeQueueSize int,
	udpMaxPayloadSize int,
	pathConfs map[string]*conf.Path,
	externalCmdPool *externalcmd.Pool,
	parent Parent,
) *PathManager

func (*PathManager) APIPathsGet

func (pm *PathManager) APIPathsGet(name string) (*defs.APIPath, error)

APIPathsGet is called by api.

func (*PathManager) APIPathsList

func (pm *PathManager) APIPathsList() (*defs.APIPathList, error)

APIPathsList is called by api.

func (*PathManager) AddPublisher

func (pm *PathManager) AddPublisher(req defs.PathAddPublisherReq) (defs.Path, error)

AddPublisher is called by a publisher.

func (*PathManager) AddReader

func (pm *PathManager) AddReader(req defs.PathAddReaderReq) (defs.Path, *stream.Stream, error)

AddReader is called by a reader.

func (*PathManager) Close

func (pm *PathManager) Close()

func (*PathManager) Describe

func (pm *PathManager) Describe(req defs.PathDescribeReq) defs.PathDescribeRes

Describe is called by a reader or publisher.

func (*PathManager) FindPathConf

func (pm *PathManager) FindPathConf(req defs.PathFindPathConfReq) (*conf.Path, error)

GetConfForPath is called by a reader or publisher.

func (*PathManager) Initialize

func (pm *PathManager) Initialize(ctx context.Context)

func (*PathManager) Log

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

Log implements logger.Writer.

func (*PathManager) ReloadPathConfs

func (pm *PathManager) ReloadPathConfs(pathConfs map[string]*conf.Path)

ReloadPathConfs is called by core.

func (*PathManager) SetHLSServer

func (pm *PathManager) SetHLSServer(s HLSServer)

SetHLSServer is called by hlsManager.