Documentation
¶
Index ¶
- type HealthHandlers
- type RelayMediaSink
- type RelayWhipTrackHandler
- type WHIPHandler
- type WHIPInitResponse
- type WHIPRelayHandler
- type WHIPServer
- func (s *WHIPServer) AssociateRelay(resourceId string, kind types.StreamKind, token string, w io.WriteCloser) error
- func (s *WHIPServer) CloseHandler(resourceId string)
- func (s *WHIPServer) DissociateRelay(resourceId string, kind types.StreamKind)
- func (s *WHIPServer) IsIdle() bool
- func (s *WHIPServer) SetMonitor(monitor *stats.Monitor)
- func (s *WHIPServer) Start(conf *config.Config, ...) error
- func (s *WHIPServer) Stop()
- type WhipTrackHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HealthHandlers ¶ added in v1.2.2
type HealthHandlers map[string]http.HandlerFunc
type RelayMediaSink ¶
type RelayMediaSink struct {
// contains filtered or unexported fields
}
func NewRelayMediaSink ¶
func NewRelayMediaSink(logger logger.Logger) *RelayMediaSink
func (*RelayMediaSink) Close ¶
func (rs *RelayMediaSink) Close() error
func (*RelayMediaSink) PushSample ¶
func (*RelayMediaSink) SetWriter ¶
func (rs *RelayMediaSink) SetWriter(w io.WriteCloser) error
type RelayWhipTrackHandler ¶ added in v1.4.0
type RelayWhipTrackHandler struct {
// contains filtered or unexported fields
}
func NewRelayWhipTrackHandler ¶ added in v1.4.0
func NewRelayWhipTrackHandler( logger logger.Logger, track *webrtc.TrackRemote, sync *synchronizer.TrackSynchronizer, receiver *webrtc.RTPReceiver, writePLI func(ssrc webrtc.SSRC), onRTCP func(packet rtcp.Packet), ) (*RelayWhipTrackHandler, error)
func (*RelayWhipTrackHandler) Close ¶ added in v1.4.0
func (t *RelayWhipTrackHandler) Close()
func (*RelayWhipTrackHandler) SetMediaTrackStatsGatherer ¶ added in v1.4.0
func (t *RelayWhipTrackHandler) SetMediaTrackStatsGatherer(st *stats.LocalMediaStatsGatherer)
func (*RelayWhipTrackHandler) SetWriter ¶ added in v1.4.0
func (t *RelayWhipTrackHandler) SetWriter(w io.WriteCloser) error
func (*RelayWhipTrackHandler) Start ¶ added in v1.4.0
func (t *RelayWhipTrackHandler) Start(onDone func(err error)) (err error)
type WHIPHandler ¶ added in v1.5.0
type WHIPHandler interface {
Init(ctx context.Context, sdpOffer string) (*WHIPInitResponse, error)
SetMediaStatsGatherer(st *stats.LocalMediaStatsGatherer)
Start(ctx context.Context) (map[types.StreamKind]string, error)
WaitForSessionEnd(ctx context.Context) error
Close()
AssociateRelay(kind types.StreamKind, token string, w io.WriteCloser) error
DissociateRelay(kind types.StreamKind)
}
func NewProxyWHIPHandler ¶ added in v1.5.0
func NewProxyWHIPHandler(p *params.Params, bus psrpc.MessageBus, ua string) (WHIPHandler, error)
type WHIPInitResponse ¶ added in v1.6.0
type WHIPRelayHandler ¶
type WHIPRelayHandler struct {
// contains filtered or unexported fields
}
func NewWHIPRelayHandler ¶
func NewWHIPRelayHandler(whipServer *WHIPServer) *WHIPRelayHandler
func (*WHIPRelayHandler) ServeHTTP ¶
func (h *WHIPRelayHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type WHIPServer ¶
type WHIPServer struct {
// contains filtered or unexported fields
}
func NewWHIPServer ¶
func NewWHIPServer(bus psrpc.MessageBus) (*WHIPServer, error)
func (*WHIPServer) AssociateRelay ¶
func (s *WHIPServer) AssociateRelay(resourceId string, kind types.StreamKind, token string, w io.WriteCloser) error
func (*WHIPServer) CloseHandler ¶ added in v1.4.0
func (s *WHIPServer) CloseHandler(resourceId string)
func (*WHIPServer) DissociateRelay ¶ added in v1.4.0
func (s *WHIPServer) DissociateRelay(resourceId string, kind types.StreamKind)
func (*WHIPServer) IsIdle ¶
func (s *WHIPServer) IsIdle() bool
func (*WHIPServer) SetMonitor ¶ added in v1.6.0
func (s *WHIPServer) SetMonitor(monitor *stats.Monitor)
func (*WHIPServer) Start ¶
func (s *WHIPServer) Start( conf *config.Config, onPublish func(streamKey, resourceId string) (*params.Params, func(mimeTypes map[types.StreamKind]string, err error) *stats.LocalMediaStatsGatherer, func(error), error), healthHandlers HealthHandlers, ) error
func (*WHIPServer) Stop ¶
func (s *WHIPServer) Stop()
type WhipTrackHandler ¶ added in v1.4.0
type WhipTrackHandler interface {
Start(onDone func(err error)) (err error)
Close()
SetMediaTrackStatsGatherer(g *stats.LocalMediaStatsGatherer)
}
Click to show internal directories.
Click to hide internal directories.