srt

Documentation

Index

• Variables
• func HandleEgressSocket(socket *srtgo.SrtSocket, addr *net.UDPAddr, streamId string)
• func HandleIngressSocket(socket *srtgo.SrtSocket, addr *net.UDPAddr)
• func ListenEgressSocket(port uint16, streamId string, latency uint16)
• func ListenIngressSocket(port uint16, latency uint16)
• func UpdateStats(socket *srtgo.SrtSocket, streamid string, streamType string, remoteAddr string)

Variables

var (
	SrtStats = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name: "srt_stats",
		Help: "SRT stats provided by the SRT library.",
	}, []string{"stream", "stat", "type", "remoteAddr"})
)

Functions

func HandleEgressSocket

func HandleEgressSocket(socket *srtgo.SrtSocket, addr *net.UDPAddr, streamId string)

func HandleIngressSocket

func HandleIngressSocket(socket *srtgo.SrtSocket, addr *net.UDPAddr)

func ListenEgressSocket

func ListenEgressSocket(port uint16, streamId string, latency uint16)

func ListenIngressSocket

func ListenIngressSocket(port uint16, latency uint16)

func UpdateStats

func UpdateStats(socket *srtgo.SrtSocket, streamid string, streamType string, remoteAddr string)