Versions in this module Expand all Collapse all v1 v1.9.4 Dec 19, 2023 Changes in this version + var DefaultPSRPCConfig = PSRPCConfig + var File_rpc_agent_proto protoreflect.FileDescriptor + var File_rpc_egress_proto protoreflect.FileDescriptor + var File_rpc_ingress_proto protoreflect.FileDescriptor + var File_rpc_io_proto protoreflect.FileDescriptor + var File_rpc_participant_proto protoreflect.FileDescriptor + var File_rpc_room_proto protoreflect.FileDescriptor + var File_rpc_signal_proto protoreflect.FileDescriptor + var File_rpc_sip_proto protoreflect.FileDescriptor + type AgentInternalClient interface + CheckEnabled func(ctx context.Context, req *CheckEnabledRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*CheckEnabledResponse], error) + JobRequest func(ctx context.Context, topic string, req *livekit1.Job, ...) (*google_protobuf.Empty, error) + func NewAgentInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (AgentInternalClient, error) + type AgentInternalServer interface + DeregisterJobRequestTopic func(topic string) + Kill func() + RegisterJobRequestTopic func(topic string) error + Shutdown func() + func NewAgentInternalServer(svc AgentInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (AgentInternalServer, error) + type AgentInternalServerImpl interface + CheckEnabled func(context.Context, *CheckEnabledRequest) (*CheckEnabledResponse, error) + JobRequest func(context.Context, *livekit1.Job) (*google_protobuf.Empty, error) + JobRequestAffinity func(context.Context, *livekit1.Job) float32 + type CheckEnabledRequest struct + func (*CheckEnabledRequest) Descriptor() ([]byte, []int) + func (*CheckEnabledRequest) ProtoMessage() + func (x *CheckEnabledRequest) ProtoReflect() protoreflect.Message + func (x *CheckEnabledRequest) Reset() + func (x *CheckEnabledRequest) String() string + type CheckEnabledResponse struct + PublisherEnabled bool + RoomEnabled bool + func (*CheckEnabledResponse) Descriptor() ([]byte, []int) + func (*CheckEnabledResponse) ProtoMessage() + func (x *CheckEnabledResponse) GetPublisherEnabled() bool + func (x *CheckEnabledResponse) GetRoomEnabled() bool + func (x *CheckEnabledResponse) ProtoReflect() protoreflect.Message + func (x *CheckEnabledResponse) Reset() + func (x *CheckEnabledResponse) String() string + type ClientParams struct + Bus psrpc.MessageBus + Logger logger.Logger + Observer middleware.MetricsObserver + func NewClientParams(config PSRPCConfig, bus psrpc.MessageBus, logger logger.Logger, ...) ClientParams + type DeleteWHIPResourceRequest struct + ResourceId string + StreamKey string + func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int) + func (*DeleteWHIPResourceRequest) ProtoMessage() + func (x *DeleteWHIPResourceRequest) GetResourceId() string + func (x *DeleteWHIPResourceRequest) GetStreamKey() string + func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message + func (x *DeleteWHIPResourceRequest) Reset() + func (x *DeleteWHIPResourceRequest) String() string + type EgressClient interface + func NewEgressClient(params ClientParams) (EgressClient, error) + type EgressHandlerClient interface + StopEgress func(ctx context.Context, topic string, req *livekit2.StopEgressRequest, ...) (*livekit2.EgressInfo, error) + UpdateStream func(ctx context.Context, topic string, req *livekit2.UpdateStreamRequest, ...) (*livekit2.EgressInfo, error) + func NewEgressHandlerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressHandlerClient, error) + type EgressHandlerServer interface + DeregisterStopEgressTopic func(topic string) + DeregisterUpdateStreamTopic func(topic string) + Kill func() + RegisterStopEgressTopic func(topic string) error + RegisterUpdateStreamTopic func(topic string) error + Shutdown func() + func NewEgressHandlerServer(svc EgressHandlerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (EgressHandlerServer, error) + type EgressHandlerServerImpl interface + StopEgress func(context.Context, *livekit2.StopEgressRequest) (*livekit2.EgressInfo, error) + UpdateStream func(context.Context, *livekit2.UpdateStreamRequest) (*livekit2.EgressInfo, error) + type EgressInternalClient interface + ListActiveEgress func(ctx context.Context, req *ListActiveEgressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error) + StartEgress func(ctx context.Context, topic string, req *StartEgressRequest, ...) (*livekit2.EgressInfo, error) + func NewEgressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressInternalClient, error) + type EgressInternalServer interface + DeregisterStartEgressTopic func(topic string) + Kill func() + RegisterStartEgressTopic func(topic string) error + Shutdown func() + func NewEgressInternalServer(svc EgressInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (EgressInternalServer, error) + type EgressInternalServerImpl interface + ListActiveEgress func(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) + StartEgress func(context.Context, *StartEgressRequest) (*livekit2.EgressInfo, error) + StartEgressAffinity func(context.Context, *StartEgressRequest) float32 + type EvaluateSIPDispatchRulesRequest struct + CalledHost string + CalledNumber string + CallingNumber string + NoPin bool + Pin string + SipParticipantId string + SrcAddress string + func (*EvaluateSIPDispatchRulesRequest) Descriptor() ([]byte, []int) + func (*EvaluateSIPDispatchRulesRequest) ProtoMessage() + func (x *EvaluateSIPDispatchRulesRequest) GetCalledHost() string + func (x *EvaluateSIPDispatchRulesRequest) GetCalledNumber() string + func (x *EvaluateSIPDispatchRulesRequest) GetCallingNumber() string + func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool + func (x *EvaluateSIPDispatchRulesRequest) GetPin() string + func (x *EvaluateSIPDispatchRulesRequest) GetSipParticipantId() string + func (x *EvaluateSIPDispatchRulesRequest) GetSrcAddress() string + func (x *EvaluateSIPDispatchRulesRequest) ProtoReflect() protoreflect.Message + func (x *EvaluateSIPDispatchRulesRequest) Reset() + func (x *EvaluateSIPDispatchRulesRequest) String() string + type EvaluateSIPDispatchRulesResponse struct + ParticipantIdentity string + RequestPin bool + RoomName string + Token string + WsUrl string + func (*EvaluateSIPDispatchRulesResponse) Descriptor() ([]byte, []int) + func (*EvaluateSIPDispatchRulesResponse) ProtoMessage() + func (x *EvaluateSIPDispatchRulesResponse) GetParticipantIdentity() string + func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() bool + func (x *EvaluateSIPDispatchRulesResponse) GetRoomName() string + func (x *EvaluateSIPDispatchRulesResponse) GetToken() string + func (x *EvaluateSIPDispatchRulesResponse) GetWsUrl() string + func (x *EvaluateSIPDispatchRulesResponse) ProtoReflect() protoreflect.Message + func (x *EvaluateSIPDispatchRulesResponse) Reset() + func (x *EvaluateSIPDispatchRulesResponse) String() string + type GetEgressRequest struct + EgressId string + func (*GetEgressRequest) Descriptor() ([]byte, []int) + func (*GetEgressRequest) ProtoMessage() + func (x *GetEgressRequest) GetEgressId() string + func (x *GetEgressRequest) ProtoReflect() protoreflect.Message + func (x *GetEgressRequest) Reset() + func (x *GetEgressRequest) String() string + type GetIngressInfoRequest struct + IngressId string + StreamKey string + func (*GetIngressInfoRequest) Descriptor() ([]byte, []int) + func (*GetIngressInfoRequest) ProtoMessage() + func (x *GetIngressInfoRequest) GetIngressId() string + func (x *GetIngressInfoRequest) GetStreamKey() string + func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message + func (x *GetIngressInfoRequest) Reset() + func (x *GetIngressInfoRequest) String() string + type GetIngressInfoResponse struct + Info *livekit.IngressInfo + Token string + WsUrl string + func (*GetIngressInfoResponse) Descriptor() ([]byte, []int) + func (*GetIngressInfoResponse) ProtoMessage() + func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo + func (x *GetIngressInfoResponse) GetToken() string + func (x *GetIngressInfoResponse) GetWsUrl() string + func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message + func (x *GetIngressInfoResponse) Reset() + func (x *GetIngressInfoResponse) String() string + type GetSIPTrunkAuthenticationRequest struct + From string + SrcAddress string + To string + ToHost string + func (*GetSIPTrunkAuthenticationRequest) Descriptor() ([]byte, []int) + func (*GetSIPTrunkAuthenticationRequest) ProtoMessage() + func (x *GetSIPTrunkAuthenticationRequest) GetFrom() string + func (x *GetSIPTrunkAuthenticationRequest) GetSrcAddress() string + func (x *GetSIPTrunkAuthenticationRequest) GetTo() string + func (x *GetSIPTrunkAuthenticationRequest) GetToHost() string + func (x *GetSIPTrunkAuthenticationRequest) ProtoReflect() protoreflect.Message + func (x *GetSIPTrunkAuthenticationRequest) Reset() + func (x *GetSIPTrunkAuthenticationRequest) String() string + type GetSIPTrunkAuthenticationResponse struct + Password string + Username string + func (*GetSIPTrunkAuthenticationResponse) Descriptor() ([]byte, []int) + func (*GetSIPTrunkAuthenticationResponse) ProtoMessage() + func (x *GetSIPTrunkAuthenticationResponse) GetPassword() string + func (x *GetSIPTrunkAuthenticationResponse) GetUsername() string + func (x *GetSIPTrunkAuthenticationResponse) ProtoReflect() protoreflect.Message + func (x *GetSIPTrunkAuthenticationResponse) Reset() + func (x *GetSIPTrunkAuthenticationResponse) String() string + type IOInfoClient interface + CreateEgress func(ctx context.Context, req *livekit2.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) + EvaluateSIPDispatchRules func(ctx context.Context, req *EvaluateSIPDispatchRulesRequest, ...) (*EvaluateSIPDispatchRulesResponse, error) + GetEgress func(ctx context.Context, req *GetEgressRequest, opts ...psrpc.RequestOption) (*livekit2.EgressInfo, error) + GetIngressInfo func(ctx context.Context, req *GetIngressInfoRequest, opts ...psrpc.RequestOption) (*GetIngressInfoResponse, error) + GetSIPTrunkAuthentication func(ctx context.Context, req *GetSIPTrunkAuthenticationRequest, ...) (*GetSIPTrunkAuthenticationResponse, error) + ListEgress func(ctx context.Context, req *livekit2.ListEgressRequest, ...) (*livekit2.ListEgressResponse, error) + UpdateEgress func(ctx context.Context, req *livekit2.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) + UpdateIngressState func(ctx context.Context, req *UpdateIngressStateRequest, ...) (*google_protobuf.Empty, error) + UpdateMetrics func(ctx context.Context, req *UpdateMetricsRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) + func NewIOInfoClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IOInfoClient, error) + type IOInfoServer interface + Kill func() + Shutdown func() + func NewIOInfoServer(svc IOInfoServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (IOInfoServer, error) + type IOInfoServerImpl interface + CreateEgress func(context.Context, *livekit2.EgressInfo) (*google_protobuf.Empty, error) + EvaluateSIPDispatchRules func(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error) + GetEgress func(context.Context, *GetEgressRequest) (*livekit2.EgressInfo, error) + GetIngressInfo func(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) + GetSIPTrunkAuthentication func(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error) + ListEgress func(context.Context, *livekit2.ListEgressRequest) (*livekit2.ListEgressResponse, error) + UpdateEgress func(context.Context, *livekit2.EgressInfo) (*google_protobuf.Empty, error) + UpdateIngressState func(context.Context, *UpdateIngressStateRequest) (*google_protobuf.Empty, error) + UpdateMetrics func(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error) + type IngressClient interface + func NewIngressClient(params ClientParams) (IngressClient, error) + type IngressHandlerClient interface + DeleteIngress func(ctx context.Context, topic string, req *livekit3.DeleteIngressRequest, ...) (*livekit3.IngressState, error) + DeleteWHIPResource func(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, ...) (*google_protobuf.Empty, error) + UpdateIngress func(ctx context.Context, topic string, req *livekit3.UpdateIngressRequest, ...) (*livekit3.IngressState, error) + func NewIngressHandlerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error) + type IngressHandlerServer interface + DeregisterDeleteIngressTopic func(topic string) + DeregisterDeleteWHIPResourceTopic func(topic string) + DeregisterUpdateIngressTopic func(topic string) + Kill func() + RegisterDeleteIngressTopic func(topic string) error + RegisterDeleteWHIPResourceTopic func(topic string) error + RegisterUpdateIngressTopic func(topic string) error + Shutdown func() + func NewIngressHandlerServer(svc IngressHandlerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (IngressHandlerServer, error) + type IngressHandlerServerImpl interface + DeleteIngress func(context.Context, *livekit3.DeleteIngressRequest) (*livekit3.IngressState, error) + DeleteWHIPResource func(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error) + UpdateIngress func(context.Context, *livekit3.UpdateIngressRequest) (*livekit3.IngressState, error) + type IngressInternalClient interface + ListActiveIngress func(ctx context.Context, req *ListActiveIngressRequest, ...) (<-chan *psrpc.Response[*ListActiveIngressResponse], error) + StartIngress func(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*livekit3.IngressInfo, error) + func NewIngressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error) + type IngressInternalServer interface + Kill func() + Shutdown func() + func NewIngressInternalServer(svc IngressInternalServerImpl, bus psrpc.MessageBus, ...) (IngressInternalServer, error) + type IngressInternalServerImpl interface + ListActiveIngress func(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) + StartIngress func(context.Context, *StartIngressRequest) (*livekit3.IngressInfo, error) + StartIngressAffinity func(context.Context, *StartIngressRequest) float32 + type InternalSendSIPParticipantDTMFRequest struct + Digits string + ParticipantId string + func (*InternalSendSIPParticipantDTMFRequest) Descriptor() ([]byte, []int) + func (*InternalSendSIPParticipantDTMFRequest) ProtoMessage() + func (x *InternalSendSIPParticipantDTMFRequest) GetDigits() string + func (x *InternalSendSIPParticipantDTMFRequest) GetParticipantId() string + func (x *InternalSendSIPParticipantDTMFRequest) ProtoReflect() protoreflect.Message + func (x *InternalSendSIPParticipantDTMFRequest) Reset() + func (x *InternalSendSIPParticipantDTMFRequest) String() string + type InternalSendSIPParticipantDTMFResponse struct + func (*InternalSendSIPParticipantDTMFResponse) Descriptor() ([]byte, []int) + func (*InternalSendSIPParticipantDTMFResponse) ProtoMessage() + func (x *InternalSendSIPParticipantDTMFResponse) ProtoReflect() protoreflect.Message + func (x *InternalSendSIPParticipantDTMFResponse) Reset() + func (x *InternalSendSIPParticipantDTMFResponse) String() string + type InternalUpdateSIPParticipantRequest struct + Address string + CallTo string + Number string + ParticipantId string + ParticipantIdentity string + Password string + RoomName string + Username string + func (*InternalUpdateSIPParticipantRequest) Descriptor() ([]byte, []int) + func (*InternalUpdateSIPParticipantRequest) ProtoMessage() + func (x *InternalUpdateSIPParticipantRequest) GetAddress() string + func (x *InternalUpdateSIPParticipantRequest) GetCallTo() string + func (x *InternalUpdateSIPParticipantRequest) GetNumber() string + func (x *InternalUpdateSIPParticipantRequest) GetParticipantId() string + func (x *InternalUpdateSIPParticipantRequest) GetParticipantIdentity() string + func (x *InternalUpdateSIPParticipantRequest) GetPassword() string + func (x *InternalUpdateSIPParticipantRequest) GetRoomName() string + func (x *InternalUpdateSIPParticipantRequest) GetUsername() string + func (x *InternalUpdateSIPParticipantRequest) ProtoReflect() protoreflect.Message + func (x *InternalUpdateSIPParticipantRequest) Reset() + func (x *InternalUpdateSIPParticipantRequest) String() string + type InternalUpdateSIPParticipantResponse struct + func (*InternalUpdateSIPParticipantResponse) Descriptor() ([]byte, []int) + func (*InternalUpdateSIPParticipantResponse) ProtoMessage() + func (x *InternalUpdateSIPParticipantResponse) ProtoReflect() protoreflect.Message + func (x *InternalUpdateSIPParticipantResponse) Reset() + func (x *InternalUpdateSIPParticipantResponse) String() string + type ListActiveEgressRequest struct + func (*ListActiveEgressRequest) Descriptor() ([]byte, []int) + func (*ListActiveEgressRequest) ProtoMessage() + func (x *ListActiveEgressRequest) ProtoReflect() protoreflect.Message + func (x *ListActiveEgressRequest) Reset() + func (x *ListActiveEgressRequest) String() string + type ListActiveEgressResponse struct + EgressIds []string + func (*ListActiveEgressResponse) Descriptor() ([]byte, []int) + func (*ListActiveEgressResponse) ProtoMessage() + func (x *ListActiveEgressResponse) GetEgressIds() []string + func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveEgressResponse) Reset() + func (x *ListActiveEgressResponse) String() string + type ListActiveIngressRequest struct + func (*ListActiveIngressRequest) Descriptor() ([]byte, []int) + func (*ListActiveIngressRequest) ProtoMessage() + func (x *ListActiveIngressRequest) ProtoReflect() protoreflect.Message + func (x *ListActiveIngressRequest) Reset() + func (x *ListActiveIngressRequest) String() string + type ListActiveIngressResponse struct + IngressIds []string + func (*ListActiveIngressResponse) Descriptor() ([]byte, []int) + func (*ListActiveIngressResponse) ProtoMessage() + func (x *ListActiveIngressResponse) GetIngressIds() []string + func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveIngressResponse) Reset() + func (x *ListActiveIngressResponse) String() string + type PSRPCConfig struct + Backoff time.Duration + BufferSize int + Enabled bool + MaxAttempts int + Timeout time.Duration + type ParticipantClient interface + MutePublishedTrack func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit4.MuteRoomTrackResponse, error) + RemoveParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit4.RemoveParticipantResponse, error) + UpdateParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit.ParticipantInfo, error) + UpdateSubscriptions func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit4.UpdateSubscriptionsResponse, error) + func NewParticipantClient[ParticipantTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (ParticipantClient[ParticipantTopicType], error) + type ParticipantServer interface + DeregisterAllParticipantTopics func(participant ParticipantTopicType) + DeregisterMutePublishedTrackTopic func(participant ParticipantTopicType) + DeregisterRemoveParticipantTopic func(participant ParticipantTopicType) + DeregisterUpdateParticipantTopic func(participant ParticipantTopicType) + DeregisterUpdateSubscriptionsTopic func(participant ParticipantTopicType) + Kill func() + RegisterAllParticipantTopics func(participant ParticipantTopicType) error + RegisterMutePublishedTrackTopic func(participant ParticipantTopicType) error + RegisterRemoveParticipantTopic func(participant ParticipantTopicType) error + RegisterUpdateParticipantTopic func(participant ParticipantTopicType) error + RegisterUpdateSubscriptionsTopic func(participant ParticipantTopicType) error + Shutdown func() + func NewParticipantServer[ParticipantTopicType ~string](svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (ParticipantServer[ParticipantTopicType], error) + type ParticipantServerImpl interface + MutePublishedTrack func(context.Context, *livekit4.MuteRoomTrackRequest) (*livekit4.MuteRoomTrackResponse, error) + RemoveParticipant func(context.Context, *livekit4.RoomParticipantIdentity) (*livekit4.RemoveParticipantResponse, error) + UpdateParticipant func(context.Context, *livekit4.UpdateParticipantRequest) (*livekit.ParticipantInfo, error) + UpdateSubscriptions func(context.Context, *livekit4.UpdateSubscriptionsRequest) (*livekit4.UpdateSubscriptionsResponse, error) + type ParticipantTopic string + func FormatParticipantTopic(roomName livekit.RoomName, identity livekit.ParticipantIdentity) ParticipantTopic + type Race struct + func NewRace[T any](ctx context.Context) *Race[T] + func (r *Race[T]) Go(fn func(ctx context.Context) (*T, error)) + func (r *Race[T]) Wait() (int, *T, error) + type RelaySignalRequest struct + Close bool + Requests []*livekit.SignalRequest + Seq uint64 + StartSession *livekit.StartSession + func (*RelaySignalRequest) Descriptor() ([]byte, []int) + func (*RelaySignalRequest) ProtoMessage() + func (x *RelaySignalRequest) GetClose() bool + func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest + func (x *RelaySignalRequest) GetSeq() uint64 + func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession + func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message + func (x *RelaySignalRequest) Reset() + func (x *RelaySignalRequest) String() string + type RelaySignalResponse struct + Close bool + Responses []*livekit.SignalResponse + Seq uint64 + func (*RelaySignalResponse) Descriptor() ([]byte, []int) + func (*RelaySignalResponse) ProtoMessage() + func (x *RelaySignalResponse) GetClose() bool + func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse + func (x *RelaySignalResponse) GetSeq() uint64 + func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message + func (x *RelaySignalResponse) Reset() + func (x *RelaySignalResponse) String() string + type RoomClient interface + DeleteRoom func(ctx context.Context, room RoomTopicType, req *livekit4.DeleteRoomRequest, ...) (*livekit4.DeleteRoomResponse, error) + SendData func(ctx context.Context, room RoomTopicType, req *livekit4.SendDataRequest, ...) (*livekit4.SendDataResponse, error) + UpdateRoomMetadata func(ctx context.Context, room RoomTopicType, ...) (*livekit.Room, error) + func NewRoomClient[RoomTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (RoomClient[RoomTopicType], error) + type RoomServer interface + DeregisterAllRoomTopics func(room RoomTopicType) + DeregisterDeleteRoomTopic func(room RoomTopicType) + DeregisterSendDataTopic func(room RoomTopicType) + DeregisterUpdateRoomMetadataTopic func(room RoomTopicType) + Kill func() + RegisterAllRoomTopics func(room RoomTopicType) error + RegisterDeleteRoomTopic func(room RoomTopicType) error + RegisterSendDataTopic func(room RoomTopicType) error + RegisterUpdateRoomMetadataTopic func(room RoomTopicType) error + Shutdown func() + func NewRoomServer[RoomTopicType ~string](svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (RoomServer[RoomTopicType], error) + type RoomServerImpl interface + DeleteRoom func(context.Context, *livekit4.DeleteRoomRequest) (*livekit4.DeleteRoomResponse, error) + SendData func(context.Context, *livekit4.SendDataRequest) (*livekit4.SendDataResponse, error) + UpdateRoomMetadata func(context.Context, *livekit4.UpdateRoomMetadataRequest) (*livekit.Room, error) + type RoomTopic string + func FormatRoomTopic(roomName livekit.RoomName) RoomTopic + type SIPClient interface + func NewSIPClient(bus psrpc.MessageBus) (SIPClient, error) + type SIPInternalClient interface + SendSIPParticipantDTMF func(ctx context.Context, req *InternalSendSIPParticipantDTMFRequest, ...) (*InternalSendSIPParticipantDTMFResponse, error) + UpdateSIPParticipant func(ctx context.Context, req *InternalUpdateSIPParticipantRequest, ...) (*InternalUpdateSIPParticipantResponse, error) + func NewSIPInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SIPInternalClient, error) + type SIPInternalServer interface + Kill func() + Shutdown func() + func NewSIPInternalServer(svc SIPInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SIPInternalServer, error) + type SIPInternalServerImpl interface + SendSIPParticipantDTMF func(context.Context, *InternalSendSIPParticipantDTMFRequest) (*InternalSendSIPParticipantDTMFResponse, error) + SendSIPParticipantDTMFAffinity func(context.Context, *InternalSendSIPParticipantDTMFRequest) float32 + UpdateSIPParticipant func(context.Context, *InternalUpdateSIPParticipantRequest) (*InternalUpdateSIPParticipantResponse, error) + UpdateSIPParticipantAffinity func(context.Context, *InternalUpdateSIPParticipantRequest) float32 + type SignalClient interface + RelaySignal func(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error) + func NewSignalClient[NodeIdTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SignalClient[NodeIdTopicType], error) + type SignalServer interface + DeregisterRelaySignalTopic func(nodeId NodeIdTopicType) + Kill func() + RegisterRelaySignalTopic func(nodeId NodeIdTopicType) error + Shutdown func() + func NewSignalServer[NodeIdTopicType ~string](svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SignalServer[NodeIdTopicType], error) + type SignalServerImpl interface + RelaySignal func(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error + type StartEgressRequest struct + EgressId string + Metadata map[string]*anypb.Any + Request isStartEgressRequest_Request + RoomId string + Token string + WsUrl string + func (*StartEgressRequest) Descriptor() ([]byte, []int) + func (*StartEgressRequest) ProtoMessage() + func (m *StartEgressRequest) GetRequest() isStartEgressRequest_Request + func (x *StartEgressRequest) GetEgressId() string + func (x *StartEgressRequest) GetMetadata() map[string]*anypb.Any + func (x *StartEgressRequest) GetParticipant() *livekit.ParticipantEgressRequest + func (x *StartEgressRequest) GetRoomComposite() *livekit.RoomCompositeEgressRequest + func (x *StartEgressRequest) GetRoomId() string + func (x *StartEgressRequest) GetToken() string + func (x *StartEgressRequest) GetTrack() *livekit.TrackEgressRequest + func (x *StartEgressRequest) GetTrackComposite() *livekit.TrackCompositeEgressRequest + func (x *StartEgressRequest) GetWeb() *livekit.WebEgressRequest + func (x *StartEgressRequest) GetWsUrl() string + func (x *StartEgressRequest) ProtoReflect() protoreflect.Message + func (x *StartEgressRequest) Reset() + func (x *StartEgressRequest) String() string + type StartEgressRequest_Participant struct + Participant *livekit.ParticipantEgressRequest + type StartEgressRequest_RoomComposite struct + RoomComposite *livekit.RoomCompositeEgressRequest + type StartEgressRequest_Track struct + Track *livekit.TrackEgressRequest + type StartEgressRequest_TrackComposite struct + TrackComposite *livekit.TrackCompositeEgressRequest + type StartEgressRequest_Web struct + Web *livekit.WebEgressRequest + type StartIngressRequest struct + Info *livekit.IngressInfo + Token string + WsUrl string + func (*StartIngressRequest) Descriptor() ([]byte, []int) + func (*StartIngressRequest) ProtoMessage() + func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo + func (x *StartIngressRequest) GetToken() string + func (x *StartIngressRequest) GetWsUrl() string + func (x *StartIngressRequest) ProtoReflect() protoreflect.Message + func (x *StartIngressRequest) Reset() + func (x *StartIngressRequest) String() string + type TopicFormatter interface + ParticipantTopic func(ctx context.Context, roomName livekit.RoomName, ...) ParticipantTopic + RoomTopic func(ctx context.Context, roomName livekit.RoomName) RoomTopic + func NewTopicFormatter() TopicFormatter + type TypedParticipantClient = ParticipantClient[ParticipantTopic] + func NewTypedParticipantClient(params ClientParams) (TypedParticipantClient, error) + type TypedParticipantServer = ParticipantServer[ParticipantTopic] + func NewTypedParticipantServer(svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedParticipantServer, error) + type TypedRoomClient = RoomClient[RoomTopic] + func NewTypedRoomClient(params ClientParams) (TypedRoomClient, error) + type TypedRoomServer = RoomServer[RoomTopic] + func NewTypedRoomServer(svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomServer, error) + type TypedSignalClient = SignalClient[livekit.NodeID] + func NewTypedSignalClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error) + type TypedSignalServer = SignalServer[livekit.NodeID] + func NewTypedSignalServer(nodeID livekit.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, ...) (TypedSignalServer, error) + type UpdateIngressStateRequest struct + IngressId string + State *livekit.IngressState + func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int) + func (*UpdateIngressStateRequest) ProtoMessage() + func (x *UpdateIngressStateRequest) GetIngressId() string + func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState + func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateIngressStateRequest) Reset() + func (x *UpdateIngressStateRequest) String() string + type UpdateMetricsRequest struct + AvgCpuUsage float32 + Info *livekit.EgressInfo + MaxCpuUsage float32 + func (*UpdateMetricsRequest) Descriptor() ([]byte, []int) + func (*UpdateMetricsRequest) ProtoMessage() + func (x *UpdateMetricsRequest) GetAvgCpuUsage() float32 + func (x *UpdateMetricsRequest) GetInfo() *livekit.EgressInfo + func (x *UpdateMetricsRequest) GetMaxCpuUsage() float32 + func (x *UpdateMetricsRequest) ProtoReflect() protoreflect.Message + func (x *UpdateMetricsRequest) Reset() + func (x *UpdateMetricsRequest) String() string
Go to main page