rtpClient

Documentation

Index

• Variables
• func CtrlEventString(event *rtp.CtrlEvent) string
• func StartRtspClient(rtspUrl string, port int, logfile string) (*golib.Command, error)
• type RtpClient
  • func NewRtpClient(listenIP string, listenPort int) (*RtpClient, error)
  • func (client *RtpClient) Start(wg *sync.WaitGroup) golib.StopChan
  • func (client *RtpClient) Stop()
  • func (client *RtpClient) String() string

Variables

var CtrlEvents = map[int]string{
	rtp.NewStreamData:             "new stream (data)",
	rtp.NewStreamCtrl:             "new stream (ctrl)",
	rtp.MaxNumInStreamReachedData: "max number of streams (data)",
	rtp.MaxNumInStreamReachedCtrl: "max number of streams (ctrl)",
	rtp.WrongStreamStatusData:     "wrong stream status (data)",
	rtp.WrongStreamStatusCtrl:     "wrong stream status (ctrl)",
	rtp.StreamCollisionLoopData:   "stream collision or loop (data)",
	rtp.StreamCollisionLoopCtrl:   "stream collision or loop (ctrl)",

	rtp.RtcpSR:    "sender report",
	rtp.RtcpRR:    "receiver report",
	rtp.RtcpSdes:  "source description",
	rtp.RtcpBye:   "goodbye",
	rtp.RtcpApp:   "application defined",
	rtp.RtcpRtpfb: "generic RTP feedback",
	rtp.RtcpPsfb:  "payload specific",
	rtp.RtcpXr:    "extended report",
}

Functions

func CtrlEventString

func CtrlEventString(event *rtp.CtrlEvent) string

func StartRtspClient

func StartRtspClient(rtspUrl string, port int, logfile string) (*golib.Command, error)

Types

type RtpClient

type RtpClient struct {
	RtpSession *rtp.Session

	ReceiveStats *stats.Stats
	CtrlStats    *stats.Stats
	MissedStats  *stats.Stats
	DataHandler  func(packet *rtp.DataPacket)
	CtrlHandler  func(packet *rtp.CtrlEvent)
	// contains filtered or unexported fields
}

func NewRtpClient

func NewRtpClient(listenIP string, listenPort int) (*RtpClient, error)

func (*RtpClient) Start

func (client *RtpClient) Start(wg *sync.WaitGroup) golib.StopChan

func (*RtpClient) Stop

func (client *RtpClient) Stop()

func (*RtpClient) String

func (client *RtpClient) String() string