path

Documentation

Index

• type Parent
• type Path
  • func New(rtspPort int, readTimeout time.Duration, writeTimeout time.Duration, ...) *Path
  • func (pa *Path) Close()
  • func (pa *Path) Conf() *conf.PathConf
  • func (pa *Path) ConfName() string
  • func (pa *Path) Log(level logger.Level, format string, args ...interface{})
  • func (pa *Path) Name() string
  • func (pa *Path) OnClientPause(req client.PauseReq)
  • func (pa *Path) OnClientPlay(req client.PlayReq)
  • func (pa *Path) OnClientRecord(req client.RecordReq)
  • func (pa *Path) OnClientRemove(req client.RemoveReq)
  • func (pa *Path) OnClientStartingPoint(req client.StartingPointReq)
  • func (pa *Path) OnExtSourceSetNotReady()
  • func (pa *Path) OnExtSourceSetReady(tracks gortsplib.Tracks, startingPoints []*client.TrackStartingPoint)
  • func (pa *Path) OnFrame(trackID int, streamType gortsplib.StreamType, payload []byte)
  • func (pa *Path) OnPathManAnnounce(req client.AnnounceReq)
  • func (pa *Path) OnPathManDescribe(req client.DescribeReq)
  • func (pa *Path) OnPathManSetupPlay(req client.SetupPlayReq)

Types

type Parent

type Parent interface {
	Log(logger.Level, string, ...interface{})
	OnPathClose(*Path)
	OnPathClientClose(client.Client)
}

Parent is implemented by pathman.PathMan.

type Path

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

Path is a path.

func New

func New(
	rtspPort int,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	readBufferCount int,
	readBufferSize int,
	confName string,
	conf *conf.PathConf,
	name string,
	wg *sync.WaitGroup,
	stats *stats.Stats,
	parent Parent) *Path

New allocates a Path.

func (*Path) Close

func (pa *Path) Close()

Close closes a path.

func (*Path) Conf

func (pa *Path) Conf() *conf.PathConf

Conf returns the configuration of this path.

func (*Path) ConfName

func (pa *Path) ConfName() string

ConfName returns the configuration name of this path.

func (*Path) Log

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

Log is the main logging function.

func (*Path) Name

func (pa *Path) Name() string

Name returns the name of this path.

func (*Path) OnClientPause

func (pa *Path) OnClientPause(req client.PauseReq)

OnClientPause is called by clientrtsp.Client.

func (*Path) OnClientPlay

func (pa *Path) OnClientPlay(req client.PlayReq)

OnClientPlay is called by clientrtsp.Client.

func (*Path) OnClientRecord

func (pa *Path) OnClientRecord(req client.RecordReq)

OnClientRecord is called by clientrtsp.Client.

func (*Path) OnClientRemove

func (pa *Path) OnClientRemove(req client.RemoveReq)

OnClientRemove is called by clientrtsp.Client.

func (*Path) OnClientStartingPoint

func (pa *Path) OnClientStartingPoint(req client.StartingPointReq)

OnClientStartingPoint is called by clientrtsp.Client.

func (*Path) OnExtSourceSetNotReady

func (pa *Path) OnExtSourceSetNotReady()

OnExtSourceSetNotReady is called by a external source.

func (*Path) OnExtSourceSetReady

func (pa *Path) OnExtSourceSetReady(tracks gortsplib.Tracks,
	startingPoints []*client.TrackStartingPoint)

OnExtSourceSetReady is called by a external source.

func (*Path) OnFrame

func (pa *Path) OnFrame(trackID int, streamType gortsplib.StreamType, payload []byte)

OnFrame is called by a source or by a clientrtsp.Client.

func (*Path) OnPathManAnnounce

func (pa *Path) OnPathManAnnounce(req client.AnnounceReq)

OnPathManAnnounce is called by pathman.PathMan.

func (*Path) OnPathManDescribe

func (pa *Path) OnPathManDescribe(req client.DescribeReq)

OnPathManDescribe is called by pathman.PathMan.

func (*Path) OnPathManSetupPlay

func (pa *Path) OnPathManSetupPlay(req client.SetupPlayReq)

OnPathManSetupPlay is called by pathman.PathMan.