rtmp

package

v0.9.0 Latest Latest Go to latest Published: Mar 31, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RTMPHandler struct {
	rtmp.DefaultHandler
	// contains filtered or unexported fields
}

func NewRTMPHandler() *RTMPHandler

func (h *RTMPHandler) OnAudio(timestamp uint32, payload io.Reader) error

func (h *RTMPHandler) OnClose()

func (h *RTMPHandler) OnCloseCallback(cb func(streamKey string))

func (h *RTMPHandler) OnPublish(_ *rtmp.StreamContext, timestamp uint32, cmd *rtmpmsg.NetStreamPublish) error

func (h *RTMPHandler) OnPublishCallback(cb func(streamKey string) error)

func (h *RTMPHandler) OnSetDataFrame(timestamp uint32, data *rtmpmsg.NetStreamSetDataFrame) error

func (h *RTMPHandler) OnVideo(timestamp uint32, payload io.Reader) error

func (h *RTMPHandler) SetWriter(w io.WriteCloser) error

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

func NewRTMPRelay(rtmpServer *RTMPServer) *RTMPRelay

func (r *RTMPRelay) Start(conf *config.Config) error

func (r *RTMPRelay) Stop() error

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

func NewRTMPRelayHandler(rtmpServer *RTMPServer) *RTMPRelayHandler

func (h *RTMPRelayHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

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

func NewRTMPServer() *RTMPServer

func (s *RTMPServer) AssociateRelay(streamKey string, w io.WriteCloser) error

func (s *RTMPServer) DissociateRelay(streamKey string) error

func (s *RTMPServer) Start(conf *config.Config, onPublish func(streamKey string) error) error

func (s *RTMPServer) Stop() error