clientman

Documentation

Index

• type ClientManager
  • func New(rtspPort int, readTimeout time.Duration, writeTimeout time.Duration, ...) *ClientManager
  • func (cm *ClientManager) Close()
  • func (cm *ClientManager) Log(level logger.Level, format string, args ...interface{})
  • func (cm *ClientManager) OnClientClose(c client.Client)
• type Parent
• type PathManager

Types

type ClientManager

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

ClientManager is a client manager.

func New

func New(
	rtspPort int,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	readBufferCount int,
	runOnConnect string,
	runOnConnectRestart bool,
	protocols map[base.StreamProtocol]struct{},
	stats *stats.Stats,
	pathMan PathManager,
	serverPlain *serverrtsp.Server,
	serverTLS *serverrtsp.Server,
	serverRTMP *serverrtmp.Server,
	parent Parent) *ClientManager

New allocates a ClientManager.

func (*ClientManager) Close

func (cm *ClientManager) Close()

Close closes a ClientManager.

func (*ClientManager) Log

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

Log is the main logging function.

func (*ClientManager) OnClientClose

func (cm *ClientManager) OnClientClose(c client.Client)

OnClientClose is called by a client.

type Parent

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

Parent is implemented by program.

type PathManager

type PathManager interface {
	ClientClose() chan client.Client
	OnClientDescribe(client.DescribeReq)
	OnClientAnnounce(client.AnnounceReq)
	OnClientSetupPlay(client.SetupPlayReq)
}

PathManager is implemented by pathman.PathManager.