service

Oct 19, 2024

Changes in this version

+ func DispatchAgentWorkerSignal(c agent.SignalConn, h agent.WorkerSignalHandler, l logger.Logger) bool

+ func HandshakeAgentWorker(c agent.SignalConn, serverInfo *livekit.ServerInfo, ...) (r agent.WorkerRegistration, ok bool)

+ func RemoveDoubleSlashes(w http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ func WithAPIKey(ctx context.Context, grants *auth.ClaimGrants, apiKey string) context.Context

type IOInfoService

+ func (s *IOInfoService) UpdateSIPCallState(ctx context.Context, req *rpc.UpdateSIPCallStateRequest) (*emptypb.Empty, error)

type RoomAllocator

+ CreateRoomEnabled func() bool

+ SelectRoomNode func(ctx context.Context, roomName livekit.RoomName, nodeID livekit.NodeID) error

type SIPService

+ func (s *SIPService) CreateSIPParticipantRequest(ctx context.Context, req *livekit.CreateSIPParticipantRequest, ...) (*rpc.InternalCreateSIPParticipantRequest, error)

+ func (s *SIPService) GetSIPInboundTrunk(ctx context.Context, req *livekit.GetSIPInboundTrunkRequest) (*livekit.GetSIPInboundTrunkResponse, error)

+ func (s *SIPService) GetSIPOutboundTrunk(ctx context.Context, req *livekit.GetSIPOutboundTrunkRequest) (*livekit.GetSIPOutboundTrunkResponse, error)

+ func (s *SIPService) TransferSIPParticipant(ctx context.Context, req *livekit.TransferSIPParticipantRequest) (*emptypb.Empty, error)

type StandardRoomAllocator

+ func (r *StandardRoomAllocator) CreateRoomEnabled() bool

+ func (r *StandardRoomAllocator) SelectRoomNode(ctx context.Context, roomName livekit.RoomName, nodeID livekit.NodeID) error

type WSSignalConnection

+ func (c *WSSignalConnection) SetReadDeadline(deadline time.Time) error

Aug 11, 2024

Changes in this version

+ const AgentDispatchPrefix

+ const AgentJobPrefix

+ var ErrNameExceedsLimits = psrpc.NewErrorf(psrpc.InvalidArgument, "name length exceeds limits")

+ func GenBasicAuthMiddleware(username string, password string) func(http.ResponseWriter, *http.Request, http.HandlerFunc)

+ func GetRoomConfiguration(ctx context.Context) string

+ func IsWebSocketCloseError(err error) bool

+ type AgentDispatchService struct

+ func NewAgentDispatchService(agentDispatchClient rpc.TypedAgentDispatchInternalClient, ...) *AgentDispatchService

+ func (ag *AgentDispatchService) CreateDispatch(ctx context.Context, req *livekit.CreateAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (ag *AgentDispatchService) DeleteDispatch(ctx context.Context, req *livekit.DeleteAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (ag *AgentDispatchService) ListDispatch(ctx context.Context, req *livekit.ListAgentDispatchRequest) (*livekit.ListAgentDispatchResponse, error)

type AgentHandler

+ func (h *AgentHandler) DeleteWorker(w *agent.Worker)

+ func (h *AgentHandler) HandleWorkerDeregister(w *agent.Worker)

+ func (h *AgentHandler) HandleWorkerJobStatus(w *agent.Worker, status *livekit.UpdateJobStatus)

+ func (h *AgentHandler) HandleWorkerRegister(w *agent.Worker)

+ func (h *AgentHandler) InsertWorker(w *agent.Worker)

+ func (h *AgentHandler) JobTerminate(ctx context.Context, req *rpc.JobTerminateRequest) (*rpc.JobTerminateResponse, error)

+ func (h *AgentHandler) Workers() []*agent.Worker

+ type AgentSocketUpgrader struct

+ func (u AgentSocketUpgrader) Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (*websocket.Conn, agent.WorkerProtocolVersion, bool)

+ type AgentStore interface

+ DeleteAgentDispatch func(ctx context.Context, dispatch *livekit.AgentDispatch) error

+ DeleteAgentJob func(ctx context.Context, job *livekit.Job) error

+ ListAgentDispatches func(ctx context.Context, roomName livekit.RoomName) ([]*livekit.AgentDispatch, error)

+ StoreAgentDispatch func(ctx context.Context, dispatch *livekit.AgentDispatch) error

+ StoreAgentJob func(ctx context.Context, job *livekit.Job) error

type LocalStore

+ func (s *LocalStore) DeleteAgentDispatch(ctx context.Context, dispatch *livekit.AgentDispatch) error

+ func (s *LocalStore) DeleteAgentJob(ctx context.Context, job *livekit.Job) error

+ func (s *LocalStore) ListAgentDispatches(ctx context.Context, roomName livekit.RoomName) ([]*livekit.AgentDispatch, error)

+ func (s *LocalStore) StoreAgentDispatch(ctx context.Context, dispatch *livekit.AgentDispatch) error

+ func (s *LocalStore) StoreAgentJob(ctx context.Context, job *livekit.Job) error

type RedisStore

+ func (s *RedisStore) DeleteAgentDispatch(_ context.Context, dispatch *livekit.AgentDispatch) error

+ func (s *RedisStore) DeleteAgentJob(_ context.Context, job *livekit.Job) error

+ func (s *RedisStore) ListAgentDispatches(_ context.Context, roomName livekit.RoomName) ([]*livekit.AgentDispatch, error)

+ func (s *RedisStore) StoreAgentDispatch(_ context.Context, dispatch *livekit.AgentDispatch) error

+ func (s *RedisStore) StoreAgentJob(_ context.Context, job *livekit.Job) error

type RoomManager

+ func (r *RoomManager) CreateDispatch(ctx context.Context, req *livekit.CreateAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (r *RoomManager) DeleteDispatch(ctx context.Context, req *livekit.DeleteAgentDispatchRequest) (*livekit.AgentDispatch, error)

+ func (r *RoomManager) ListDispatch(ctx context.Context, req *livekit.ListAgentDispatchRequest) (*livekit.ListAgentDispatchResponse, error)

type WSSignalConnection

+ func (c *WSSignalConnection) Close() error

Jun 23, 2024

Changes in this version

+ const SIPInboundTrunkKey

+ const SIPOutboundTrunkKey

+ var ErrAttributeExceedsLimits = psrpc.NewErrorf(psrpc.InvalidArgument, "attribute size exceeds limits")

+ func EnsureSIPAdminPermission(ctx context.Context) error

+ func EnsureSIPCallPermission(ctx context.Context) error

type RedisStore

+ func (s *RedisStore) ListSIPInboundTrunk(ctx context.Context) (infos []*livekit.SIPInboundTrunkInfo, err error)

+ func (s *RedisStore) ListSIPOutboundTrunk(ctx context.Context) (infos []*livekit.SIPOutboundTrunkInfo, err error)

+ func (s *RedisStore) LoadSIPInboundTrunk(ctx context.Context, id string) (*livekit.SIPInboundTrunkInfo, error)

+ func (s *RedisStore) LoadSIPOutboundTrunk(ctx context.Context, id string) (*livekit.SIPOutboundTrunkInfo, error)

+ func (s *RedisStore) StoreSIPInboundTrunk(ctx context.Context, info *livekit.SIPInboundTrunkInfo) error

+ func (s *RedisStore) StoreSIPOutboundTrunk(ctx context.Context, info *livekit.SIPOutboundTrunkInfo) error

type SIPService

+ func (s *SIPService) CreateSIPInboundTrunk(ctx context.Context, req *livekit.CreateSIPInboundTrunkRequest) (*livekit.SIPInboundTrunkInfo, error)

+ func (s *SIPService) CreateSIPOutboundTrunk(ctx context.Context, req *livekit.CreateSIPOutboundTrunkRequest) (*livekit.SIPOutboundTrunkInfo, error)

+ func (s *SIPService) ListSIPInboundTrunk(ctx context.Context, req *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error)

+ func (s *SIPService) ListSIPOutboundTrunk(ctx context.Context, req *livekit.ListSIPOutboundTrunkRequest) (*livekit.ListSIPOutboundTrunkResponse, error)

type SIPStore

+ ListSIPInboundTrunk func(ctx context.Context) ([]*livekit.SIPInboundTrunkInfo, error)

+ ListSIPOutboundTrunk func(ctx context.Context) ([]*livekit.SIPOutboundTrunkInfo, error)

+ LoadSIPInboundTrunk func(ctx context.Context, sipTrunkID string) (*livekit.SIPInboundTrunkInfo, error)

+ LoadSIPOutboundTrunk func(ctx context.Context, sipTrunkID string) (*livekit.SIPOutboundTrunkInfo, error)

+ StoreSIPInboundTrunk func(ctx context.Context, info *livekit.SIPInboundTrunkInfo) error

+ StoreSIPOutboundTrunk func(ctx context.Context, info *livekit.SIPOutboundTrunkInfo) error

Jun 16, 2024

Changes in this version

+ var ErrParticipantIdentityExceedsLimits = psrpc.NewErrorf(psrpc.InvalidArgument, "participant identity length exceeds limits")

+ var ErrRoomNameExceedsLimits = psrpc.NewErrorf(psrpc.InvalidArgument, "room name length exceeds limits")

Apr 11, 2024

Changes in this version

+ func GetAPIKey(ctx context.Context) string

Feb 17, 2024

Changes in this version

type IOClient

+ CreateIngress func(ctx context.Context, req *livekit.IngressInfo) (*emptypb.Empty, error)

+ UpdateIngressState func(ctx context.Context, req *rpc.UpdateIngressStateRequest) (*emptypb.Empty, error)

type IOInfoService

+ func (s *IOInfoService) CreateIngress(ctx context.Context, info *livekit.IngressInfo) (*emptypb.Empty, error)

type SIPService

+ func (s *SIPService) CreateSIPParticipantWithToken(ctx context.Context, req *livekit.CreateSIPParticipantRequest, ...) (*livekit.SIPParticipantInfo, error)

type ServiceStore

+ DeleteRoom func(ctx context.Context, roomName livekit.RoomName) error

type SessionHandler

+ HandleSession func(ctx context.Context, roomName livekit.RoomName, pi routing.ParticipantInit, ...) error

+ Logger func(ctx context.Context) logger.Logger

Dec 22, 2023

Changes in this version

+ const SIPDispatchRuleKey

+ const SIPParticipantKey

+ const SIPTrunkKey

+ var ErrSIPDispatchRuleNotFound = psrpc.NewErrorf(psrpc.NotFound, "requested sip dispatch rule does not exist")

+ var ErrSIPNotConnected = psrpc.NewErrorf(psrpc.Internal, "sip not connected (redis required)")

+ var ErrSIPParticipantNotFound = psrpc.NewErrorf(psrpc.NotFound, "requested sip participant does not exist")

+ var ErrSIPTrunkNotFound = psrpc.NewErrorf(psrpc.NotFound, "requested sip trunk does not exist")

type AgentHandler

+ func (s *AgentHandler) OnWorkerRegistered(handler func(handler *AgentHandler))

type IOInfoService

+ func (s *IOInfoService) EvaluateSIPDispatchRules(ctx context.Context, req *rpc.EvaluateSIPDispatchRulesRequest) (*rpc.EvaluateSIPDispatchRulesResponse, error)

+ func (s *IOInfoService) GetSIPTrunkAuthentication(ctx context.Context, req *rpc.GetSIPTrunkAuthenticationRequest) (*rpc.GetSIPTrunkAuthenticationResponse, error)

+ func (s *IOInfoService) UpdateMetrics(ctx context.Context, req *rpc.UpdateMetricsRequest) (*emptypb.Empty, error)

type RedisStore

+ func (s *RedisStore) DeleteSIPDispatchRule(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error

+ func (s *RedisStore) DeleteSIPParticipant(ctx context.Context, info *livekit.SIPParticipantInfo) error

+ func (s *RedisStore) DeleteSIPTrunk(ctx context.Context, info *livekit.SIPTrunkInfo) error

+ func (s *RedisStore) ListSIPDispatchRule(ctx context.Context) (infos []*livekit.SIPDispatchRuleInfo, err error)

+ func (s *RedisStore) ListSIPParticipant(ctx context.Context) (infos []*livekit.SIPParticipantInfo, err error)

+ func (s *RedisStore) ListSIPTrunk(ctx context.Context) (infos []*livekit.SIPTrunkInfo, err error)

+ func (s *RedisStore) LoadSIPDispatchRule(ctx context.Context, sipDispatchRuleId string) (*livekit.SIPDispatchRuleInfo, error)

+ func (s *RedisStore) LoadSIPParticipant(ctx context.Context, sipParticipantId string) (*livekit.SIPParticipantInfo, error)

+ func (s *RedisStore) LoadSIPTrunk(ctx context.Context, sipTrunkId string) (*livekit.SIPTrunkInfo, error)

+ func (s *RedisStore) SendSIPParticipantDTMF(ctx context.Context, info *livekit.SendSIPParticipantDTMFRequest) (*livekit.SIPParticipantDTMFInfo, error)

+ func (s *RedisStore) StoreSIPDispatchRule(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error

+ func (s *RedisStore) StoreSIPParticipant(ctx context.Context, info *livekit.SIPParticipantInfo) error

+ func (s *RedisStore) StoreSIPTrunk(ctx context.Context, info *livekit.SIPTrunkInfo) error

+ type SIPService struct

+ func NewSIPService(conf *config.SIPConfig, nodeID livekit.NodeID, bus psrpc.MessageBus, ...) *SIPService

+ func (s *SIPService) CreateSIPDispatchRule(ctx context.Context, req *livekit.CreateSIPDispatchRuleRequest) (*livekit.SIPDispatchRuleInfo, error)

+ func (s *SIPService) CreateSIPParticipant(ctx context.Context, req *livekit.CreateSIPParticipantRequest) (*livekit.SIPParticipantInfo, error)

+ func (s *SIPService) CreateSIPTrunk(ctx context.Context, req *livekit.CreateSIPTrunkRequest) (*livekit.SIPTrunkInfo, error)

+ func (s *SIPService) DeleteSIPDispatchRule(ctx context.Context, req *livekit.DeleteSIPDispatchRuleRequest) (*livekit.SIPDispatchRuleInfo, error)

+ func (s *SIPService) DeleteSIPParticipant(ctx context.Context, req *livekit.DeleteSIPParticipantRequest) (*livekit.SIPParticipantInfo, error)

+ func (s *SIPService) DeleteSIPTrunk(ctx context.Context, req *livekit.DeleteSIPTrunkRequest) (*livekit.SIPTrunkInfo, error)

+ func (s *SIPService) ListSIPDispatchRule(ctx context.Context, req *livekit.ListSIPDispatchRuleRequest) (*livekit.ListSIPDispatchRuleResponse, error)

+ func (s *SIPService) ListSIPParticipant(ctx context.Context, req *livekit.ListSIPParticipantRequest) (*livekit.ListSIPParticipantResponse, error)

+ func (s *SIPService) ListSIPTrunk(ctx context.Context, req *livekit.ListSIPTrunkRequest) (*livekit.ListSIPTrunkResponse, error)

+ func (s *SIPService) SendSIPParticipantDTMF(ctx context.Context, req *livekit.SendSIPParticipantDTMFRequest) (*livekit.SIPParticipantDTMFInfo, error)

+ type SIPStore interface

+ DeleteSIPDispatchRule func(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error

+ DeleteSIPParticipant func(ctx context.Context, info *livekit.SIPParticipantInfo) error

+ DeleteSIPTrunk func(ctx context.Context, info *livekit.SIPTrunkInfo) error

+ ListSIPDispatchRule func(ctx context.Context) ([]*livekit.SIPDispatchRuleInfo, error)

+ ListSIPParticipant func(ctx context.Context) ([]*livekit.SIPParticipantInfo, error)

+ ListSIPTrunk func(ctx context.Context) ([]*livekit.SIPTrunkInfo, error)

+ LoadSIPDispatchRule func(ctx context.Context, sipDispatchRuleID string) (*livekit.SIPDispatchRuleInfo, error)

+ LoadSIPParticipant func(ctx context.Context, sipParticipantID string) (*livekit.SIPParticipantInfo, error)

+ LoadSIPTrunk func(ctx context.Context, sipTrunkID string) (*livekit.SIPTrunkInfo, error)

+ StoreSIPDispatchRule func(ctx context.Context, info *livekit.SIPDispatchRuleInfo) error

+ StoreSIPParticipant func(ctx context.Context, info *livekit.SIPParticipantInfo) error

+ StoreSIPTrunk func(ctx context.Context, info *livekit.SIPTrunkInfo) error

Nov 9, 2023

Changes in this version

+ const AgentServiceVersion

+ var ErrRemoteUnmuteNoteEnabled = psrpc.NewErrorf(psrpc.FailedPrecondition, "remote unmute not enabled")

+ type AgentHandler struct

+ func NewAgentHandler(agentServer rpc.AgentInternalServer, roomTopic, publisherTopic string) *AgentHandler

+ func (s *AgentHandler) CheckEnabled(_ context.Context, _ *rpc.CheckEnabledRequest) (*rpc.CheckEnabledResponse, error)

+ func (s *AgentHandler) DrainConnections(interval time.Duration)

+ func (s *AgentHandler) HandleConnection(conn *websocket.Conn)

+ func (s *AgentHandler) JobRequest(ctx context.Context, job *livekit.Job) (*emptypb.Empty, error)

+ func (s *AgentHandler) JobRequestAffinity(ctx context.Context, job *livekit.Job) float32

+ func (s *AgentHandler) NumConnections() int

+ type AgentService struct

+ func NewAgentService(bus psrpc.MessageBus) (*AgentService, error)

+ func (s *AgentService) ServeHTTP(writer http.ResponseWriter, r *http.Request)

+ type IOClient interface

+ CreateEgress func(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)

+ GetEgress func(ctx context.Context, req *rpc.GetEgressRequest) (*livekit.EgressInfo, error)

+ ListEgress func(ctx context.Context, req *livekit.ListEgressRequest) (*livekit.ListEgressResponse, error)

type IOInfoService

+ func (s *IOInfoService) CreateEgress(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)

+ func (s *IOInfoService) GetEgress(ctx context.Context, req *rpc.GetEgressRequest) (*livekit.EgressInfo, error)

+ func (s *IOInfoService) ListEgress(ctx context.Context, req *livekit.ListEgressRequest) (*livekit.ListEgressResponse, error)

+ func (s *IOInfoService) UpdateEgress(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)

type RoomManager

+ func (r *RoomManager) MutePublishedTrack(ctx context.Context, req *livekit.MuteRoomTrackRequest) (*livekit.MuteRoomTrackResponse, error)

+ func (r *RoomManager) RemoveParticipant(ctx context.Context, req *livekit.RoomParticipantIdentity) (*livekit.RemoveParticipantResponse, error)

+ func (r *RoomManager) SendData(ctx context.Context, req *livekit.SendDataRequest) (*livekit.SendDataResponse, error)

+ func (r *RoomManager) UpdateParticipant(ctx context.Context, req *livekit.UpdateParticipantRequest) (*livekit.ParticipantInfo, error)

+ func (r *RoomManager) UpdateRoomMetadata(ctx context.Context, req *livekit.UpdateRoomMetadataRequest) (*livekit.Room, error)

+ func (r *RoomManager) UpdateSubscriptions(ctx context.Context, req *livekit.UpdateSubscriptionsRequest) (*livekit.UpdateSubscriptionsResponse, error)

type WSSignalConnection

+ func (c *WSSignalConnection) ReadWorkerMessage() (*livekit.WorkerMessage, int, error)

+ func (c *WSSignalConnection) WriteServerMessage(msg *livekit.ServerMessage) (int, error)

Oct 16, 2023

Changes in this version

+ var ErrInvalidAPIKey = errors.New("invalid API key")

type EgressService

+ func (s *EgressService) StartParticipantEgress(ctx context.Context, req *livekit.ParticipantEgressRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) UpdateOutputs(ctx context.Context, req *livekit.UpdateOutputsRequest) (*livekit.EgressInfo, error)

+ type TURNAuthHandler struct

+ func NewTURNAuthHandler(keyProvider auth.KeyProvider) *TURNAuthHandler

+ func (h *TURNAuthHandler) CreatePassword(apiKey string, pID livekit.ParticipantID) (string, error)

+ func (h *TURNAuthHandler) CreateUsername(apiKey string, pID livekit.ParticipantID) string

+ func (h *TURNAuthHandler) HandleAuth(username, realm string, srcAddr net.Addr) (key []byte, ok bool)

Aug 23, 2023

Changes in this version

+ var ErrIngressNonReusable = psrpc.NewErrorf(psrpc.InvalidArgument, "ingress is not reusable and cannot be modified")

+ type IngressLauncher interface

+ LaunchPullIngress func(ctx context.Context, info *livekit.IngressInfo) (*livekit.IngressInfo, error)

type IngressService

+ func NewIngressServiceWithIngressLauncher(conf *config.IngressConfig, nodeID livekit.NodeID, bus psrpc.MessageBus, ...) *IngressService

+ func (s *IngressService) CreateIngressWithUrl(ctx context.Context, urlStr string, req *livekit.CreateIngressRequest) (*livekit.IngressInfo, error)

+ func (s *IngressService) LaunchPullIngress(ctx context.Context, info *livekit.IngressInfo) (*livekit.IngressInfo, error)

type SignalServer

+ func (s *SignalServer) Start() error

Jul 9, 2023

Changes in this version

type RTCService

+ func (s *RTCService) DrainConnections(interval time.Duration)

Apr 6, 2023

Changes in this version

+ func GetClientIP(r *http.Request) string

Mar 31, 2023

Changes in this version

+ type SessionHandler func(ctx context.Context, roomName livekit.RoomName, pi routing.ParticipantInit, ...) error

+ type SignalServer struct

+ func NewDefaultSignalServer(currentNode routing.LocalNode, bus psrpc.MessageBus, ...) (r *SignalServer, err error)

+ func NewSignalServer(nodeID livekit.NodeID, region string, bus psrpc.MessageBus, ...) (*SignalServer, error)

+ func (r *SignalServer) Stop()

Feb 10, 2023

Changes in this version

+ func TwirpRequestStatusReporter() *twirp.ServerHooks

+ type IOInfoService struct

+ func NewIOInfoService(nodeID livekit.NodeID, bus psrpc.MessageBus, es EgressStore, is IngressStore, ...) (*IOInfoService, error)

+ func (s *IOInfoService) GetIngressInfo(ctx context.Context, req *livekit.GetIngressInfoRequest) (*livekit.GetIngressInfoResponse, error)

+ func (s *IOInfoService) Start() error

+ func (s *IOInfoService) Stop()

+ func (s *IOInfoService) UpdateEgressInfo(ctx context.Context, info *livekit.EgressInfo) (*emptypb.Empty, error)

+ func (s *IOInfoService) UpdateIngressState(ctx context.Context, req *livekit.UpdateIngressStateRequest) (*emptypb.Empty, error)

type RoomAllocator

+ ValidateCreateRoom func(ctx context.Context, roomName livekit.RoomName) error

type StandardRoomAllocator

+ func (r *StandardRoomAllocator) ValidateCreateRoom(ctx context.Context, roomName livekit.RoomName) error

Dec 16, 2022

Changes in this version

+ func AppendLogFields(ctx context.Context, fields ...interface{})

Nov 8, 2022

Changes in this version

+ func EnsureIngressAdminPermission(ctx context.Context) error

type EgressService

+ func (s *EgressService) StartWebEgress(ctx context.Context, req *livekit.WebEgressRequest) (*livekit.EgressInfo, error)

Oct 20, 2022

Changes in this version

+ func TwirpLogger(logger logger.Logger) *twirp.ServerHooks

Oct 13, 2022

Changes in this version

+ const IngressStatePrefix

type IngressStore

+ UpdateIngressState func(ctx context.Context, ingressId string, state *livekit.IngressState) error

type RedisStore

+ func (s *RedisStore) UpdateIngressState(ctx context.Context, ingressId string, state *livekit.IngressState) error

Sep 26, 2022

Changes in this version

+ const RoomInternalKey

+ func NewEgressLauncher(rpcClient egress.RPCClient, es EgressStore, ts telemetry.TelemetryService) rtc.EgressLauncher

Sep 13, 2022

Changes in this version

type IngressService

+ func (s *IngressService) CreateIngressWithUrlPrefix(ctx context.Context, urlPrefix string, req *livekit.CreateIngressRequest) (*livekit.IngressInfo, error)

Aug 26, 2022

Changes in this version

+ const DeprecatedRoomEgressPrefix

+ const EndedEgressKey

+ const IngressKey

+ const RoomIngressPrefix

+ const StreamKeyKey

+ const VersionKey

+ var ErrIngressNotConnected = errors.New("ingress not connected (redis required)")

+ var ErrIngressNotFound = errors.New("ingress does not exist")

+ var ErrIngressOutOfDate = errors.New("trying to ovewrite an ingress with an older version")

+ var ErrInvalidAuthorizationToken = errors.New("invalid authorization token")

+ var ErrMissingAuthorization = errors.New("invalid authorization header. Must start with " + bearerPrefix)

+ type IngressService struct

+ func NewIngressService(conf *config.Config, rpc ingress.RPC, store IngressStore, ...) *IngressService

+ func (s *IngressService) CreateIngress(ctx context.Context, req *livekit.CreateIngressRequest) (*livekit.IngressInfo, error)

+ func (s *IngressService) DeleteIngress(ctx context.Context, req *livekit.DeleteIngressRequest) (*livekit.IngressInfo, error)

+ func (s *IngressService) ListIngress(ctx context.Context, req *livekit.ListIngressRequest) (*livekit.ListIngressResponse, error)

+ func (s *IngressService) Start()

+ func (s *IngressService) Stop()

+ func (s *IngressService) UpdateIngress(ctx context.Context, req *livekit.UpdateIngressRequest) (*livekit.IngressInfo, error)

+ type IngressStore interface

+ DeleteIngress func(ctx context.Context, info *livekit.IngressInfo) error

+ ListIngress func(ctx context.Context, roomName livekit.RoomName) ([]*livekit.IngressInfo, error)

+ LoadIngress func(ctx context.Context, ingressID string) (*livekit.IngressInfo, error)

+ LoadIngressFromStreamKey func(ctx context.Context, streamKey string) (*livekit.IngressInfo, error)

+ StoreIngress func(ctx context.Context, info *livekit.IngressInfo) error

+ UpdateIngress func(ctx context.Context, info *livekit.IngressInfo) error

type RedisStore

+ func (s *RedisStore) DeleteIngress(_ context.Context, info *livekit.IngressInfo) error

+ func (s *RedisStore) ListIngress(_ context.Context, roomName livekit.RoomName) ([]*livekit.IngressInfo, error)

+ func (s *RedisStore) LoadIngress(_ context.Context, ingressId string) (*livekit.IngressInfo, error)

+ func (s *RedisStore) LoadIngressFromStreamKey(_ context.Context, streamKey string) (*livekit.IngressInfo, error)

+ func (s *RedisStore) MigrateEgressInfo() (int, error)

+ func (s *RedisStore) Start() error

+ func (s *RedisStore) Stop()

+ func (s *RedisStore) StoreIngress(_ context.Context, info *livekit.IngressInfo) error

+ func (s *RedisStore) UpdateIngress(_ context.Context, info *livekit.IngressInfo) error

+ func (s RedisStore) CleanEndedEgress() error

May 1, 2022

Changes in this version

+ var ErrIdentityEmpty = errors.New("identity cannot be empty")

type EgressService

+ func (s *EgressService) StartRoomCompositeEgress(ctx context.Context, req *livekit.RoomCompositeEgressRequest) (*livekit.EgressInfo, error)

Mar 28, 2022

Changes in this version

+ var ErrEgressNotConnected = errors.New("egress not connected (redis required)")

+ var ErrMetadataExceedsLimits = errors.New("metadata size exceeds limits")

type ServiceStore

+ DeleteEgress func(ctx context.Context, info *livekit.EgressInfo) error

+ ListEgress func(ctx context.Context, roomID livekit.RoomID) ([]*livekit.EgressInfo, error)

+ LoadEgress func(ctx context.Context, egressID string) (*livekit.EgressInfo, error)

+ StoreEgress func(ctx context.Context, info *livekit.EgressInfo) error

+ UpdateEgress func(ctx context.Context, info *livekit.EgressInfo) error

Feb 28, 2022

Changes in this version

+ const EgressKey

+ const RoomEgressPrefix

+ var ErrEgressNotFound = errors.New("egress does not exist")

+ func WithGrants(ctx context.Context, grants *auth.ClaimGrants) context.Context

+ type EgressService struct

+ func NewEgressService(bus utils.MessageBus, es EgressStore, rs livekit.RoomService, ...) *EgressService

+ func (s *EgressService) ListEgress(ctx context.Context, req *livekit.ListEgressRequest) (*livekit.ListEgressResponse, error)

+ func (s *EgressService) Start()

+ func (s *EgressService) StartEgress(ctx context.Context, roomName livekit.RoomName, ...) (*livekit.EgressInfo, error)

+ func (s *EgressService) StartTrackCompositeEgress(ctx context.Context, req *livekit.TrackCompositeEgressRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) StartTrackEgress(ctx context.Context, req *livekit.TrackEgressRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) StartWebCompositeEgress(ctx context.Context, req *livekit.WebCompositeEgressRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) Stop()

+ func (s *EgressService) StopEgress(ctx context.Context, req *livekit.StopEgressRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) UpdateLayout(ctx context.Context, req *livekit.UpdateLayoutRequest) (*livekit.EgressInfo, error)

+ func (s *EgressService) UpdateStream(ctx context.Context, req *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)

+ type EgressStore interface

+ DeleteEgress func(ctx context.Context, info *livekit.EgressInfo) error

+ ListEgress func(ctx context.Context, roomID livekit.RoomID) ([]*livekit.EgressInfo, error)

+ LoadEgress func(ctx context.Context, egressID string) (*livekit.EgressInfo, error)

+ LoadRoom func(ctx context.Context, name livekit.RoomName) (*livekit.Room, error)

+ StoreEgress func(ctx context.Context, info *livekit.EgressInfo) error

+ UpdateEgress func(ctx context.Context, info *livekit.EgressInfo) error

+ type LayoutMetadata struct

+ Layout string

+ type LocalStore struct

+ func NewLocalStore() *LocalStore

+ func (s *LocalStore) DeleteEgress(_ context.Context, _ *livekit.EgressInfo) error

+ func (s *LocalStore) DeleteParticipant(_ context.Context, roomName livekit.RoomName, ...) error

+ func (s *LocalStore) DeleteRoom(ctx context.Context, name livekit.RoomName) error

+ func (s *LocalStore) ListEgress(_ context.Context, _ livekit.RoomID) ([]*livekit.EgressInfo, error)

+ func (s *LocalStore) ListParticipants(_ context.Context, roomName livekit.RoomName) ([]*livekit.ParticipantInfo, error)

+ func (s *LocalStore) ListRooms(_ context.Context, names []livekit.RoomName) ([]*livekit.Room, error)

+ func (s *LocalStore) LoadEgress(_ context.Context, _ string) (*livekit.EgressInfo, error)

+ func (s *LocalStore) LoadParticipant(_ context.Context, roomName livekit.RoomName, ...) (*livekit.ParticipantInfo, error)

+ func (s *LocalStore) LoadRoom(_ context.Context, name livekit.RoomName) (*livekit.Room, error)

+ func (s *LocalStore) LockRoom(_ context.Context, _ livekit.RoomName, _ time.Duration) (string, error)

+ func (s *LocalStore) StoreEgress(_ context.Context, _ *livekit.EgressInfo) error

+ func (s *LocalStore) StoreParticipant(_ context.Context, roomName livekit.RoomName, ...) error

+ func (s *LocalStore) StoreRoom(_ context.Context, room *livekit.Room) error

+ func (s *LocalStore) UnlockRoom(_ context.Context, _ livekit.RoomName, _ string) error

+ func (s *LocalStore) UpdateEgress(_ context.Context, _ *livekit.EgressInfo) error

+ type ObjectStore interface

+ DeleteParticipant func(ctx context.Context, roomName livekit.RoomName, ...) error

+ DeleteRoom func(ctx context.Context, name livekit.RoomName) error

+ LockRoom func(ctx context.Context, name livekit.RoomName, duration time.Duration) (string, error)

+ StoreParticipant func(ctx context.Context, roomName livekit.RoomName, ...) error

+ StoreRoom func(ctx context.Context, room *livekit.Room) error

+ UnlockRoom func(ctx context.Context, name livekit.RoomName, uid string) error

+ type RedisStore struct

+ func NewRedisStore(rc *redis.Client) *RedisStore

+ func (s *RedisStore) DeleteEgress(_ context.Context, info *livekit.EgressInfo) error

+ func (s *RedisStore) DeleteParticipant(_ context.Context, roomName livekit.RoomName, ...) error

+ func (s *RedisStore) DeleteRoom(ctx context.Context, name livekit.RoomName) error

+ func (s *RedisStore) ListEgress(_ context.Context, roomID livekit.RoomID) ([]*livekit.EgressInfo, error)

+ func (s *RedisStore) ListParticipants(_ context.Context, roomName livekit.RoomName) ([]*livekit.ParticipantInfo, error)

+ func (s *RedisStore) ListRooms(_ context.Context, names []livekit.RoomName) ([]*livekit.Room, error)

+ func (s *RedisStore) LoadEgress(_ context.Context, egressID string) (*livekit.EgressInfo, error)

+ func (s *RedisStore) LoadParticipant(_ context.Context, roomName livekit.RoomName, ...) (*livekit.ParticipantInfo, error)

+ func (s *RedisStore) LoadRoom(_ context.Context, name livekit.RoomName) (*livekit.Room, error)

+ func (s *RedisStore) LockRoom(_ context.Context, name livekit.RoomName, duration time.Duration) (string, error)

+ func (s *RedisStore) StoreEgress(_ context.Context, info *livekit.EgressInfo) error

+ func (s *RedisStore) StoreParticipant(_ context.Context, roomName livekit.RoomName, ...) error

+ func (s *RedisStore) StoreRoom(_ context.Context, room *livekit.Room) error

+ func (s *RedisStore) UnlockRoom(_ context.Context, name livekit.RoomName, uid string) error

+ func (s *RedisStore) UpdateEgress(_ context.Context, info *livekit.EgressInfo) error

+ type ServiceStore interface

+ ListParticipants func(ctx context.Context, roomName livekit.RoomName) ([]*livekit.ParticipantInfo, error)

+ ListRooms func(ctx context.Context, names []livekit.RoomName) ([]*livekit.Room, error)

+ LoadParticipant func(ctx context.Context, roomName livekit.RoomName, ...) (*livekit.ParticipantInfo, error)

+ LoadRoom func(ctx context.Context, name livekit.RoomName) (*livekit.Room, error)

Feb 9, 2022

Changes in this version

type RTCService

+ func (s *RTCService) ParseClientInfo(r *http.Request) *livekit.ClientInfo

Jan 29, 2022

Changes in this version

+ var ErrOperationFailed = errors.New("operation cannot be completed")

+ func ParseClientInfo(values url.Values) *livekit.ClientInfo

type LivekitServer

+ func (s *LivekitServer) HTTPPort() int

Nov 19, 2021

Changes in this version

+ type RORoomStore interface

+ ListParticipants func(ctx context.Context, roomName string) ([]*livekit.ParticipantInfo, error)

+ ListRooms func(ctx context.Context) ([]*livekit.Room, error)

+ LoadParticipant func(ctx context.Context, roomName, identity string) (*livekit.ParticipantInfo, error)

+ LoadRoom func(ctx context.Context, name string) (*livekit.Room, error)

Nov 1, 2021

Changes in this version

+ type StandardRoomAllocator struct

+ func (r *StandardRoomAllocator) CreateRoom(ctx context.Context, req *livekit.CreateRoomRequest) (*livekit.Room, error)

Oct 20, 2021

Changes in this version

+ const LivekitRealm

Oct 10, 2021

Changes in this version

+ var ErrUnsupportedSelector = errors.New("unsupported node selector")

type RecordingService

+ func (s *RecordingService) AddOutput(ctx context.Context, req *livekit.AddOutputRequest) (*emptypb.Empty, error)

+ func (s *RecordingService) RemoveOutput(ctx context.Context, req *livekit.RemoveOutputRequest) (*emptypb.Empty, error)

Oct 5, 2021

Changes in this version

type RoomService

+ func (s *RoomService) UpdateRoomMetadata(ctx context.Context, req *livekit.UpdateRoomMetadataRequest) (*livekit.Room, error)

Sep 22, 2021

Changes in this version

type LocalRoomManager

+ func (r *LocalRoomManager) HasParticipants() bool

type RecordingService

+ func (s *RecordingService) Start()

+ func (s *RecordingService) Stop()

+ type RoomAllocator struct

+ func NewRoomAllocator(conf *config.Config, router routing.Router, selector routing.NodeSelector, ...) *RoomAllocator

+ func (r *RoomAllocator) CreateRoom(ctx context.Context, req *livekit.CreateRoomRequest) (*livekit.Room, error)

type RoomManager

+ HasParticipants func() bool

Sep 2, 2021

Changes in this version

+ func CreateKeyProvider(conf *config.Config) (auth.KeyProvider, error)

+ func CreateNodeSelector(conf *config.Config) routing.NodeSelector

+ func CreateWebhookNotifier(conf *config.Config, provider auth.KeyProvider) (*webhook.Notifier, error)

Aug 30, 2021

Changes in this version

+ type LocalRoomManager struct

+ func NewLocalRoomManager(rp RoomStore, router routing.Router, currentNode routing.LocalNode, ...) (*LocalRoomManager, error)

+ func (r *LocalRoomManager) CleanupRooms() error

+ func (r *LocalRoomManager) CloseIdleRooms()

+ func (r *LocalRoomManager) CreateRoom(req *livekit.CreateRoomRequest) (*livekit.Room, error)

+ func (r *LocalRoomManager) DeleteRoom(roomName string) error

+ func (r *LocalRoomManager) GetRoom(roomName string) *rtc.Room

+ func (r *LocalRoomManager) StartSession(roomName string, pi routing.ParticipantInit, ...)

+ func (r *LocalRoomManager) Stop()

type LocalRoomStore

+ func (p *LocalRoomStore) LoadParticipant(roomName, identity string) (*livekit.ParticipantInfo, error)

+ func (p *LocalRoomStore) LoadRoom(idOrName string) (*livekit.Room, error)

+ func (p *LocalRoomStore) StoreParticipant(roomName string, participant *livekit.ParticipantInfo) error

+ func (p *LocalRoomStore) StoreRoom(room *livekit.Room) error

type RedisRoomStore

+ func (p *RedisRoomStore) LoadParticipant(roomName, identity string) (*livekit.ParticipantInfo, error)

+ func (p *RedisRoomStore) LoadRoom(idOrName string) (*livekit.Room, error)

+ func (p *RedisRoomStore) StoreParticipant(roomName string, participant *livekit.ParticipantInfo) error

+ func (p *RedisRoomStore) StoreRoom(room *livekit.Room) error

type RoomStore

+ LoadParticipant func(roomName, identity string) (*livekit.ParticipantInfo, error)

+ LoadRoom func(idOrName string) (*livekit.Room, error)

+ StoreParticipant func(roomName string, participant *livekit.ParticipantInfo) error

+ StoreRoom func(room *livekit.Room) error

Aug 25, 2021

Changes in this version

+ func InitializeRouter(conf *config.Config, currentNode routing.LocalNode) (routing.Router, error)

+ func IsValidDomain(domain string) bool

type RoomService

+ func (s *RoomService) SendData(ctx context.Context, req *livekit.SendDataRequest) (*livekit.SendDataResponse, error)

Aug 16, 2021

Changes in this version

+ var ErrWebHookMissingAPIKey = errors.New("api_key is required to use webhooks")

+ func EnsureRecordPermission(ctx context.Context) error

+ type RecordingService struct

+ func NewRecordingService(rc *redis.Client) *RecordingService

+ func (s *RecordingService) EndRecording(ctx context.Context, req *livekit.EndRecordingRequest) (*livekit.RecordingResponse, error)

+ func (s *RecordingService) StartRecording(ctx context.Context, req *livekit.StartRecordingRequest) (*livekit.RecordingResponse, error)

Jul 27, 2021

Changes in this version

type RoomService

+ func (s *RoomService) EndRoomRecording(ctx context.Context, req *livekit.EndRecordingRequest) (*livekit.RecordingResponse, error)

+ func (s *RoomService) RecordRoom(ctx context.Context, req *livekit.RecordRoomRequest) (*livekit.RecordingResponse, error)

Jul 16, 2021

Changes in this version

type RTCService

+ func (s *RTCService) Validate(w http.ResponseWriter, r *http.Request)

Jul 13, 2021

Changes in this version

+ const RoomLockPrefix

+ var ErrRoomLockFailed = errors.New("could not lock room")

+ var ErrRoomUnlockFailed = errors.New("could not unlock room, lock token does not match")

type LocalRoomStore

+ func (p *LocalRoomStore) LockRoom(name string, duration time.Duration) (string, error)

+ func (p *LocalRoomStore) UnlockRoom(name string, uid string) error

type RedisRoomStore

+ func (p *RedisRoomStore) LockRoom(name string, duration time.Duration) (string, error)

+ func (p *RedisRoomStore) UnlockRoom(name string, uid string) error

type RoomStore

+ LockRoom func(name string, duration time.Duration) (string, error)

+ UnlockRoom func(name string, uid string) error

Jun 26, 2021

Changes in this version

type RoomService

+ func (s *RoomService) UpdateSubscriptions(ctx context.Context, req *livekit.UpdateSubscriptionsRequest) (*livekit.UpdateSubscriptionsResponse, error)

May 15, 2021

Changes in this version

type LivekitServer

+ func (s *LivekitServer) RoomManager() *RoomManager

type RoomManager

+ func (r *RoomManager) GetRoom(roomName string) *rtc.Room

May 12, 2021

Changes in this version

+ const RoomIdMap

+ const RoomParticipantsPrefix

+ const RoomsKey

+ var ErrParticipantNotFound = errors.New("participant does not exist")

+ var ErrPermissionDenied = errors.New("permissions denied")

+ var ErrRoomNotFound = errors.New("requested room does not exist")

+ var ErrTrackNotFound = errors.New("track is not found")

+ var ServiceSet = wire.NewSet(NewRoomService, NewRTCService, NewLivekitServer, NewRoomManager, NewTurnServer, ...)

+ func EnsureAdminPermission(ctx context.Context, room string) error

+ func EnsureCreatePermission(ctx context.Context) error

+ func EnsureJoinPermission(ctx context.Context) (name string, err error)

+ func EnsureListPermission(ctx context.Context) error

+ func GetGrants(ctx context.Context) *auth.ClaimGrants

+ func NewTurnServer(conf *config.Config, roomStore RoomStore, node routing.LocalNode) (*turn.Server, error)

+ func SetAuthorizationToken(r *http.Request, token string)

+ type APIKeyAuthMiddleware struct

+ func NewAPIKeyAuthMiddleware(provider auth.KeyProvider) *APIKeyAuthMiddleware

+ func (m *APIKeyAuthMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ type LivekitServer struct

+ func InitializeServer(conf *config.Config, keyProvider auth.KeyProvider, roomStore RoomStore, ...) (*LivekitServer, error)

+ func NewLivekitServer(conf *config.Config, roomService livekit.RoomService, rtcService *RTCService, ...) (s *LivekitServer, err error)

+ func (s *LivekitServer) IsRunning() bool

+ func (s *LivekitServer) Node() *livekit.Node

+ func (s *LivekitServer) Start() error

+ func (s *LivekitServer) Stop()

+ type LocalRoomStore struct

+ func NewLocalRoomStore() *LocalRoomStore

+ func (p *LocalRoomStore) CreateRoom(room *livekit.Room) error

+ func (p *LocalRoomStore) DeleteParticipant(roomName, identity string) error

+ func (p *LocalRoomStore) DeleteRoom(idOrName string) error

+ func (p *LocalRoomStore) GetParticipant(roomName, identity string) (*livekit.ParticipantInfo, error)

+ func (p *LocalRoomStore) GetRoom(idOrName string) (*livekit.Room, error)

+ func (p *LocalRoomStore) ListParticipants(roomName string) ([]*livekit.ParticipantInfo, error)

+ func (p *LocalRoomStore) ListRooms() ([]*livekit.Room, error)

+ func (p *LocalRoomStore) PersistParticipant(roomName string, participant *livekit.ParticipantInfo) error

+ type RTCService struct

+ func NewRTCService(conf *config.Config, roomStore RoomStore, roomManager *RoomManager, ...) *RTCService

+ func (s *RTCService) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type RedisRoomStore struct

+ func NewRedisRoomStore(rc *redis.Client) *RedisRoomStore

+ func (p *RedisRoomStore) CreateRoom(room *livekit.Room) error

+ func (p *RedisRoomStore) DeleteParticipant(roomName, identity string) error

+ func (p *RedisRoomStore) DeleteRoom(idOrName string) error

+ func (p *RedisRoomStore) GetParticipant(roomName, identity string) (*livekit.ParticipantInfo, error)

+ func (p *RedisRoomStore) GetRoom(idOrName string) (*livekit.Room, error)

+ func (p *RedisRoomStore) ListParticipants(roomName string) ([]*livekit.ParticipantInfo, error)

+ func (p *RedisRoomStore) ListRooms() ([]*livekit.Room, error)

+ func (p *RedisRoomStore) PersistParticipant(roomName string, participant *livekit.ParticipantInfo) error

+ type RoomManager struct

+ func NewRoomManager(rp RoomStore, router routing.Router, currentNode routing.LocalNode, ...) (*RoomManager, error)

+ func (r *RoomManager) CleanupRooms() error

+ func (r *RoomManager) CloseIdleRooms()

+ func (r *RoomManager) CreateRoom(req *livekit.CreateRoomRequest) (*livekit.Room, error)

+ func (r *RoomManager) DeleteRoom(roomName string) error

+ func (r *RoomManager) StartSession(roomName string, pi routing.ParticipantInit, ...)

+ func (r *RoomManager) Stop()

+ type RoomService struct

+ func NewRoomService(roomManager *RoomManager) (svc *RoomService, err error)

+ func (s *RoomService) CreateRoom(ctx context.Context, req *livekit.CreateRoomRequest) (rm *livekit.Room, err error)

+ func (s *RoomService) DeleteRoom(ctx context.Context, req *livekit.DeleteRoomRequest) (*livekit.DeleteRoomResponse, error)

+ func (s *RoomService) GetParticipant(ctx context.Context, req *livekit.RoomParticipantIdentity) (res *livekit.ParticipantInfo, err error)

+ func (s *RoomService) ListParticipants(ctx context.Context, req *livekit.ListParticipantsRequest) (res *livekit.ListParticipantsResponse, err error)

+ func (s *RoomService) ListRooms(ctx context.Context, req *livekit.ListRoomsRequest) (res *livekit.ListRoomsResponse, err error)

+ func (s *RoomService) MutePublishedTrack(ctx context.Context, req *livekit.MuteRoomTrackRequest) (res *livekit.MuteRoomTrackResponse, err error)

+ func (s *RoomService) RemoveParticipant(ctx context.Context, req *livekit.RoomParticipantIdentity) (res *livekit.RemoveParticipantResponse, err error)

+ func (s *RoomService) UpdateParticipant(ctx context.Context, req *livekit.UpdateParticipantRequest) (*livekit.ParticipantInfo, error)

+ type RoomStore interface

+ CreateRoom func(room *livekit.Room) error

+ DeleteParticipant func(roomName, identity string) error

+ DeleteRoom func(idOrName string) error

+ GetParticipant func(roomName, identity string) (*livekit.ParticipantInfo, error)

+ GetRoom func(idOrName string) (*livekit.Room, error)

+ ListParticipants func(roomName string) ([]*livekit.ParticipantInfo, error)

+ ListRooms func() ([]*livekit.Room, error)

+ PersistParticipant func(roomName string, participant *livekit.ParticipantInfo) error

+ type WSSignalConnection struct

+ func NewWSSignalConnection(conn types.WebsocketClient) *WSSignalConnection

+ func (c *WSSignalConnection) ReadRequest() (*livekit.SignalRequest, error)

+ func (c *WSSignalConnection) WriteResponse(msg *livekit.SignalResponse) error