clientrtmp

Documentation

Index

• type Client
  • func New(rtspPort int, readTimeout time.Duration, writeTimeout time.Duration, ...) *Client
  • func (c *Client) Authenticate(authMethods []headers.AuthMethod, pathName string, ips []interface{}, ...) error
  • func (c *Client) Close()
  • func (c *Client) IsClient()
  • func (c *Client) IsSource()
  • func (c *Client) OnIncomingFrame(trackID int, streamType gortsplib.StreamType, buf []byte)
• type Parent

Types

type Client

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

Client is a RTMP client.

func New

func New(
	rtspPort int,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	readBufferCount int,
	runOnConnect string,
	runOnConnectRestart bool,
	wg *sync.WaitGroup,
	stats *stats.Stats,
	conn *rtmputils.Conn,
	parent Parent) *Client

New allocates a Client.

func (*Client) Authenticate

func (c *Client) Authenticate(authMethods []headers.AuthMethod,
	pathName string, ips []interface{},
	user string, pass string, req interface{}) error

Authenticate performs an authentication.

func (*Client) Close

func (c *Client) Close()

Close closes a Client.

func (*Client) IsClient

func (c *Client) IsClient()

IsClient implements client.Client.

func (*Client) IsSource

func (c *Client) IsSource()

IsSource implements path.source.

func (*Client) OnIncomingFrame

func (c *Client) OnIncomingFrame(trackID int, streamType gortsplib.StreamType, buf []byte)

OnIncomingFrame implements path.Reader.

type Parent

type Parent interface {
	Log(logger.Level, string, ...interface{})
	OnClientClose(client.Client)
	OnClientSetupPlay(client.SetupPlayReq)
	OnClientAnnounce(client.AnnounceReq)
}

Parent is implemented by clientman.ClientMan.