Documentation
¶
Index ¶
- Variables
- func Receive(streamPath, dump, port string, ssrc uint32, reuse bool) (err error)deprecated
- type MediaPort
- type PSConfig
- func (c *PSConfig) API_receive(w http.ResponseWriter, r *http.Request)
- func (c *PSConfig) API_replay(w http.ResponseWriter, r *http.Request)
- func (c *PSConfig) OnEvent(event any)
- func (c *PSConfig) ServeHTTP(w http.ResponseWriter, r *http.Request)
- func (c *PSConfig) ServeTCP(conn net.Conn)
- func (c *PSConfig) ServeUDP(conn *net.UDPConn)
- type PSPublisher
- func (p *PSPublisher) OnEvent(event any)
- func (p *PSPublisher) OnFrame(frame []byte, cid mpeg2.PS_STREAM_TYPE, pts uint64, dts uint64)
- func (p *PSPublisher) OnPacket(pkg mpeg2.Display, decodeResult error)
- func (p *PSPublisher) PushPS(ps util.Buffer) (err error)
- func (p *PSPublisher) Receive(streamPath, dump, port string, ssrc uint32, reuse bool) (err error)
- func (p *PSPublisher) ReceiveAudio(es mpegps.MpegPsEsStream)
- func (p *PSPublisher) ReceivePSM(buf util.Buffer, hasAudio bool, hasVideo bool)
- func (p *PSPublisher) ReceiveVideo(es mpegps.MpegPsEsStream)
- func (p *PSPublisher) Replay(f *os.File) (err error)
- func (p *PSPublisher) ServeTCP(conn net.Conn)
- func (p *PSPublisher) ServeUDP(conn *net.UDPConn)
- type PSStream
- type PSSubscriber
- type PSTrack
- type TCPRTP
Constants ¶
This section is empty.
Variables ¶
View Source
var PSPlugin = InstallPlugin(conf)
Functions ¶
Types ¶
type PSConfig ¶
type PSConfig struct {
config.HTTP
config.Publish
config.Subscribe
RelayMode int `desc:"转发模式" enum:"0:只转协议,1:只转发,2:转协议+转发"` // 转发模式,0:转协议+不转发,1:不转协议+转发,2:转协议+转发
// contains filtered or unexported fields
}
func (*PSConfig) API_receive ¶
func (c *PSConfig) API_receive(w http.ResponseWriter, r *http.Request)
收流
func (*PSConfig) API_replay ¶
func (c *PSConfig) API_replay(w http.ResponseWriter, r *http.Request)
type PSPublisher ¶
type PSPublisher struct {
Publisher
rtp.Packet `json:"-" yaml:"-"`
DisableReorder bool //是否禁用rtp重排序,TCP模式下应当禁用
// mpegps.MpegPsStream `json:"-" yaml:"-"`
// *mpegps.PSDemuxer `json:"-" yaml:"-"`
mpegps.DecPSPackage `json:"-" yaml:"-"`
// contains filtered or unexported fields
}
func (*PSPublisher) OnEvent ¶
func (p *PSPublisher) OnEvent(event any)
func (*PSPublisher) OnFrame ¶
func (p *PSPublisher) OnFrame(frame []byte, cid mpeg2.PS_STREAM_TYPE, pts uint64, dts uint64)
func (*PSPublisher) OnPacket ¶
func (p *PSPublisher) OnPacket(pkg mpeg2.Display, decodeResult error)
func (*PSPublisher) Receive ¶ added in v4.1.3
func (p *PSPublisher) Receive(streamPath, dump, port string, ssrc uint32, reuse bool) (err error)
func (*PSPublisher) ReceiveAudio ¶
func (p *PSPublisher) ReceiveAudio(es mpegps.MpegPsEsStream)
func (*PSPublisher) ReceivePSM ¶ added in v4.0.1
func (p *PSPublisher) ReceivePSM(buf util.Buffer, hasAudio bool, hasVideo bool)
func (*PSPublisher) ReceiveVideo ¶
func (p *PSPublisher) ReceiveVideo(es mpegps.MpegPsEsStream)
func (*PSPublisher) ServeTCP ¶
func (p *PSPublisher) ServeTCP(conn net.Conn)
func (*PSPublisher) ServeUDP ¶
func (p *PSPublisher) ServeUDP(conn *net.UDPConn)
type PSSubscriber ¶ added in v4.0.1
type PSSubscriber struct {
Subscriber
}
func (*PSSubscriber) OnEvent ¶ added in v4.0.1
func (ps *PSSubscriber) OnEvent(event any)
Click to show internal directories.
Click to hide internal directories.