Documentation
¶
Index ¶
- func DeregisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo, ep any)
- func RegisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo, ep any) error
- type Handler
- func (h *Handler) DeleteIngress(ctx context.Context, req *livekit.DeleteIngressRequest) (*livekit.IngressState, error)
- func (h *Handler) DeleteWHIPResource(ctx context.Context, req *rpc.DeleteWHIPResourceRequest) (*google_protobuf2.Empty, error)
- func (h *Handler) HandleIngress(ctx context.Context, info *livekit.IngressInfo, wsUrl, token string, ...)
- func (h *Handler) Kill()
- func (h *Handler) UpdateIngress(ctx context.Context, req *livekit.UpdateIngressRequest) (*livekit.IngressState, error)
- type ProcessManager
- type Relay
- type Service
- func (s *Service) AvailabilityHandler(w http.ResponseWriter, r *http.Request)
- func (s *Service) CanAccept() bool
- func (s *Service) HandleRTMPPublishRequest(streamKey string) error
- func (s *Service) HandleWHIPPublishRequest(streamKey, resourceId string, ihs rpc.IngressHandlerServerImpl) (p *params.Params, ready func(mimeTypes map[types.StreamKind]string, err error), ...)
- func (s *Service) HealthHandler(w http.ResponseWriter, r *http.Request)
- func (s *Service) ListActiveIngress(ctx context.Context, _ *rpc.ListActiveIngressRequest) (*rpc.ListActiveIngressResponse, error)
- func (s *Service) ListIngress() []string
- func (s *Service) Run() error
- func (s *Service) Stop(kill bool)
- type SessionManager
- type SessionType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeregisterIngressRpcHandlers ¶ added in v1.0.0
func DeregisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo, ep any)
func RegisterIngressRpcHandlers ¶ added in v1.0.0
func RegisterIngressRpcHandlers(server rpc.IngressHandlerServer, info *livekit.IngressInfo, ep any) error
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(conf *config.Config, rpcClient rpc.IOInfoClient) *Handler
func (*Handler) DeleteIngress ¶
func (h *Handler) DeleteIngress(ctx context.Context, req *livekit.DeleteIngressRequest) (*livekit.IngressState, error)
func (*Handler) DeleteWHIPResource ¶ added in v1.0.0
func (h *Handler) DeleteWHIPResource(ctx context.Context, req *rpc.DeleteWHIPResourceRequest) (*google_protobuf2.Empty, error)
func (*Handler) HandleIngress ¶
func (*Handler) UpdateIngress ¶
func (h *Handler) UpdateIngress(ctx context.Context, req *livekit.UpdateIngressRequest) (*livekit.IngressState, error)
type ProcessManager ¶
type ProcessManager struct {
// contains filtered or unexported fields
}
func NewProcessManager ¶
func NewProcessManager(conf *config.Config, sm *SessionManager) *ProcessManager
type Relay ¶ added in v1.0.0
type Relay struct {
// contains filtered or unexported fields
}
func NewRelay ¶ added in v1.0.0
func NewRelay(rtmpServer *rtmp.RTMPServer, whipServer *whip.WHIPServer) *Relay
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(conf *config.Config, psrpcClient rpc.IOInfoClient, bus psrpc.MessageBus, whipSrv *whip.WHIPServer) *Service
func (*Service) AvailabilityHandler ¶ added in v1.0.0
func (s *Service) AvailabilityHandler(w http.ResponseWriter, r *http.Request)
func (*Service) HandleRTMPPublishRequest ¶
func (*Service) HandleWHIPPublishRequest ¶ added in v1.0.0
func (*Service) HealthHandler ¶ added in v1.0.0
func (s *Service) HealthHandler(w http.ResponseWriter, r *http.Request)
func (*Service) ListActiveIngress ¶
func (s *Service) ListActiveIngress(ctx context.Context, _ *rpc.ListActiveIngressRequest) (*rpc.ListActiveIngressResponse, error)
func (*Service) ListIngress ¶
type SessionManager ¶ added in v1.0.0
type SessionManager struct {
// contains filtered or unexported fields
}
func NewSessionManager ¶ added in v1.0.0
func NewSessionManager(monitor *stats.Monitor) *SessionManager
func (*SessionManager) IngressEnded ¶ added in v1.0.0
func (sm *SessionManager) IngressEnded(info *livekit.IngressInfo)
func (*SessionManager) IngressStarted ¶ added in v1.0.0
func (sm *SessionManager) IngressStarted(info *livekit.IngressInfo, t SessionType)
func (*SessionManager) IsIdle ¶ added in v1.0.0
func (sm *SessionManager) IsIdle() bool
func (*SessionManager) ListIngress ¶ added in v1.0.0
func (sm *SessionManager) ListIngress() []string
type SessionType ¶ added in v1.0.0
type SessionType string
const ( SessionType_HandlerProcess SessionType = "HandlerProcess" SessionType_Service = "Service" )
Source Files
Click to show internal directories.
Click to hide internal directories.