rtmp

Apr 5, 2024

Changes in this version

type RTMPHandler

+ func (h *RTMPHandler) Close()

type RTMPServer

+ func (s *RTMPServer) CloseHandler(resourceId string)

Feb 28, 2023

Changes in this version

+ type RTMPHandler struct

+ 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

+ func NewRTMPRelay(rtmpServer *RTMPServer) *RTMPRelay

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

+ func (r *RTMPRelay) Stop() error

+ type RTMPRelayHandler struct

+ func NewRTMPRelayHandler(rtmpServer *RTMPServer) *RTMPRelayHandler

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

+ type RTMPServer struct

+ 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