rpc

Oct 22, 2024

Changes in this version

type InternalCreateSIPParticipantRequest

+ PlayDialtone bool

+ func (x *InternalCreateSIPParticipantRequest) GetPlayDialtone() bool

type InternalTransferSIPParticipantRequest

+ PlayDialtone bool

+ func (x *InternalTransferSIPParticipantRequest) GetPlayDialtone() bool

type StartEgressRequest

+ CloudBackupEnabled bool

+ EstimatedCpu float64

+ func (x *StartEgressRequest) GetCloudBackupEnabled() bool

+ func (x *StartEgressRequest) GetEstimatedCpu() float64

Oct 15, 2024

Changes in this version

type EvaluateSIPDispatchRulesResponse

+ MaxCallDuration *durationpb.Duration

+ RingingTimeout *durationpb.Duration

+ func (x *EvaluateSIPDispatchRulesResponse) GetMaxCallDuration() *durationpb.Duration

+ func (x *EvaluateSIPDispatchRulesResponse) GetRingingTimeout() *durationpb.Duration

type IOInfoClient

+ UpdateSIPCallState func(ctx context.Context, req *UpdateSIPCallStateRequest, ...) (*google_protobuf.Empty, error)

type IOInfoServerImpl

+ UpdateSIPCallState func(context.Context, *UpdateSIPCallStateRequest) (*google_protobuf.Empty, error)

type InternalCreateSIPParticipantRequest

+ MaxCallDuration *durationpb.Duration

+ RingingTimeout *durationpb.Duration

+ func (x *InternalCreateSIPParticipantRequest) GetMaxCallDuration() *durationpb.Duration

+ func (x *InternalCreateSIPParticipantRequest) GetRingingTimeout() *durationpb.Duration

+ type UpdateSIPCallStateRequest struct

+ CallInfo *livekit.SIPCallInfo

+ func (*UpdateSIPCallStateRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSIPCallStateRequest) ProtoMessage()

+ func (x *UpdateSIPCallStateRequest) GetCallInfo() *livekit.SIPCallInfo

+ func (x *UpdateSIPCallStateRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateSIPCallStateRequest) Reset()

+ func (x *UpdateSIPCallStateRequest) String() string

Oct 8, 2024

Changes in this version

+ var SIPFeature_name = map[int32]string

+ var SIPFeature_value = map[string]int32

type EvaluateSIPDispatchRulesResponse

+ EnabledFeatures []SIPFeature

+ func (x *EvaluateSIPDispatchRulesResponse) GetEnabledFeatures() []SIPFeature

type JobTerminateReason

+ const JobTerminateReason_TERMINATION_REQUESTED

+ type SIPFeature int32

+ const SIPFeature_KRISP_ENABLED

+ const SIPFeature_NONE

+ func (SIPFeature) Descriptor() protoreflect.EnumDescriptor

+ func (SIPFeature) EnumDescriptor() ([]byte, []int)

+ func (SIPFeature) Type() protoreflect.EnumType

+ func (x SIPFeature) Enum() *SIPFeature

+ func (x SIPFeature) Number() protoreflect.EnumNumber

+ func (x SIPFeature) String() string

Sep 24, 2024

Changes in this version

type AgentDispatchInternalClient

+ Close func()

type AgentInternalClient

+ Close func()

type EgressHandlerClient

+ Close func()

type EgressInternalClient

+ Close func()

type IOInfoClient

+ Close func()

type IngressHandlerClient

+ Close func()

type IngressInternalClient

+ Close func()

+ type InternalTransferSIPParticipantRequest struct

+ SipCallId string

+ TransferTo string

+ func (*InternalTransferSIPParticipantRequest) Descriptor() ([]byte, []int)

+ func (*InternalTransferSIPParticipantRequest) ProtoMessage()

+ func (x *InternalTransferSIPParticipantRequest) GetSipCallId() string

+ func (x *InternalTransferSIPParticipantRequest) GetTransferTo() string

+ func (x *InternalTransferSIPParticipantRequest) ProtoReflect() protoreflect.Message

+ func (x *InternalTransferSIPParticipantRequest) Reset()

+ func (x *InternalTransferSIPParticipantRequest) String() string

type KeepaliveClient

+ Close func()

type ParticipantClient

+ Close func()

type RoomClient

+ Close func()

type RoomManagerClient

+ Close func()

type SIPInternalClient

+ Close func()

+ TransferSIPParticipant func(ctx context.Context, sipCallId string, ...) (*google_protobuf.Empty, error)

type SIPInternalServer

+ DeregisterTransferSIPParticipantTopic func(sipCallId string)

+ RegisterTransferSIPParticipantTopic func(sipCallId string) error

type SIPInternalServerImpl

+ TransferSIPParticipant func(context.Context, *InternalTransferSIPParticipantRequest) (*google_protobuf.Empty, error)

type SignalClient

+ Close func()

Sep 19, 2024

Changes in this version

+ func WithClientOptions(opts ...psrpc.ClientOption) psrpc.ClientOption

+ func WithDefaultServerOptions(psrpcConfig PSRPCConfig, logger logger.Logger) psrpc.ServerOption

+ func WithServerObservability(logger logger.Logger) psrpc.ServerOption

+ func WithServerOptions(opts ...psrpc.ServerOption) psrpc.ServerOption

type ClientParams

+ func (p *ClientParams) Args() (psrpc.MessageBus, psrpc.ClientOption)

type EvaluateSIPDispatchRulesRequest

+ SipTrunkId string

+ func (x *EvaluateSIPDispatchRulesRequest) GetSipTrunkId() string

type EvaluateSIPDispatchRulesResponse

+ Headers map[string]string

+ HeadersToAttributes map[string]string

+ ProjectId string

+ func (x *EvaluateSIPDispatchRulesResponse) GetHeaders() map[string]string

+ func (x *EvaluateSIPDispatchRulesResponse) GetHeadersToAttributes() map[string]string

+ func (x *EvaluateSIPDispatchRulesResponse) GetProjectId() string

type GetSIPTrunkAuthenticationResponse

+ ProjectId string

+ func (x *GetSIPTrunkAuthenticationResponse) GetProjectId() string

type InternalCreateSIPParticipantRequest

+ Headers map[string]string

+ HeadersToAttributes map[string]string

+ Hostname string

+ ProjectId string

+ SipTrunkId string

+ func (x *InternalCreateSIPParticipantRequest) GetHeaders() map[string]string

+ func (x *InternalCreateSIPParticipantRequest) GetHeadersToAttributes() map[string]string

+ func (x *InternalCreateSIPParticipantRequest) GetHostname() string

+ func (x *InternalCreateSIPParticipantRequest) GetProjectId() string

+ func (x *InternalCreateSIPParticipantRequest) GetSipTrunkId() string

Aug 28, 2024

Changes in this version

+ var File_rpc_roommanager_proto protoreflect.FileDescriptor

+ type RoomManagerClient interface

+ CreateRoom func(ctx context.Context, nodeId NodeIdTopicType, req *livekit6.CreateRoomRequest, ...) (*livekit1.Room, error)

+ func NewRoomManagerClient[NodeIdTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (RoomManagerClient[NodeIdTopicType], error)

+ type RoomManagerServer interface

+ DeregisterAllNodeTopics func(nodeId NodeIdTopicType)

+ DeregisterCreateRoomTopic func(nodeId NodeIdTopicType)

+ Kill func()

+ RegisterAllNodeTopics func(nodeId NodeIdTopicType) error

+ RegisterCreateRoomTopic func(nodeId NodeIdTopicType) error

+ Shutdown func()

+ func NewRoomManagerServer[NodeIdTopicType ~string](svc RoomManagerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (RoomManagerServer[NodeIdTopicType], error)

+ type RoomManagerServerImpl interface

+ CreateRoom func(context.Context, *livekit6.CreateRoomRequest) (*livekit1.Room, error)

type SignalServer

+ DeregisterAllNodeTopics func(nodeId NodeIdTopicType)

+ RegisterAllNodeTopics func(nodeId NodeIdTopicType) error

+ type TypedRoomManagerClient = RoomManagerClient[livekit.NodeID]

+ func NewTypedRoomManagerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedRoomManagerClient, error)

+ type TypedRoomManagerServer = RoomManagerServer[livekit.NodeID]

+ func NewTypedRoomManagerServer(svc RoomManagerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomManagerServer, error)

Aug 13, 2024

Changes in this version

+ var File_rpc_agent_dispatch_proto protoreflect.FileDescriptor

+ var JobTerminateReason_name = map[int32]string

+ var JobTerminateReason_value = map[string]int32

+ type AgentDispatchInternalClient interface

+ CreateDispatch func(ctx context.Context, room RoomTopicType, ...) (*livekit2.AgentDispatch, error)

+ DeleteDispatch func(ctx context.Context, room RoomTopicType, ...) (*livekit2.AgentDispatch, error)

+ ListDispatch func(ctx context.Context, room RoomTopicType, ...) (*livekit2.ListAgentDispatchResponse, error)

+ func NewAgentDispatchInternalClient[RoomTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (AgentDispatchInternalClient[RoomTopicType], error)

+ type AgentDispatchInternalServer interface

+ DeregisterAllRoomTopics func(room RoomTopicType)

+ DeregisterCreateDispatchTopic func(room RoomTopicType)

+ DeregisterDeleteDispatchTopic func(room RoomTopicType)

+ DeregisterListDispatchTopic func(room RoomTopicType)

+ Kill func()

+ RegisterAllRoomTopics func(room RoomTopicType) error

+ RegisterCreateDispatchTopic func(room RoomTopicType) error

+ RegisterDeleteDispatchTopic func(room RoomTopicType) error

+ RegisterListDispatchTopic func(room RoomTopicType) error

+ Shutdown func()

+ func NewAgentDispatchInternalServer[RoomTopicType ~string](svc AgentDispatchInternalServerImpl, bus psrpc.MessageBus, ...) (AgentDispatchInternalServer[RoomTopicType], error)

+ type AgentDispatchInternalServerImpl interface

+ CreateDispatch func(context.Context, *livekit2.CreateAgentDispatchRequest) (*livekit2.AgentDispatch, error)

+ DeleteDispatch func(context.Context, *livekit2.DeleteAgentDispatchRequest) (*livekit2.AgentDispatch, error)

+ ListDispatch func(context.Context, *livekit2.ListAgentDispatchRequest) (*livekit2.ListAgentDispatchResponse, error)

type AgentInternalClient

+ JobTerminate func(ctx context.Context, jobId string, req *JobTerminateRequest, ...) (*JobTerminateResponse, error)

type AgentInternalServer

+ DeregisterJobTerminateTopic func(jobId string)

+ RegisterJobTerminateTopic func(jobId string) error

type AgentInternalServerImpl

+ JobTerminate func(context.Context, *JobTerminateRequest) (*JobTerminateResponse, error)

+ type JobTerminateReason int32

+ const JobTerminateReason_AGENT_LEFT_ROOM

+ const JobTerminateReason_TERINATION_REQUESTED

+ func (JobTerminateReason) Descriptor() protoreflect.EnumDescriptor

+ func (JobTerminateReason) EnumDescriptor() ([]byte, []int)

+ func (JobTerminateReason) Type() protoreflect.EnumType

+ func (x JobTerminateReason) Enum() *JobTerminateReason

+ func (x JobTerminateReason) Number() protoreflect.EnumNumber

+ func (x JobTerminateReason) String() string

+ type JobTerminateRequest struct

+ JobId string

+ Reason JobTerminateReason

+ func (*JobTerminateRequest) Descriptor() ([]byte, []int)

+ func (*JobTerminateRequest) ProtoMessage()

+ func (x *JobTerminateRequest) GetJobId() string

+ func (x *JobTerminateRequest) GetReason() JobTerminateReason

+ func (x *JobTerminateRequest) ProtoReflect() protoreflect.Message

+ func (x *JobTerminateRequest) Reset()

+ func (x *JobTerminateRequest) String() string

+ type JobTerminateResponse struct

+ State *livekit.JobState

+ func (*JobTerminateResponse) Descriptor() ([]byte, []int)

+ func (*JobTerminateResponse) ProtoMessage()

+ func (x *JobTerminateResponse) GetState() *livekit.JobState

+ func (x *JobTerminateResponse) ProtoReflect() protoreflect.Message

+ func (x *JobTerminateResponse) Reset()

+ func (x *JobTerminateResponse) String() string

+ type TypedAgentDispatchInternalClient = AgentDispatchInternalClient[RoomTopic]

+ func NewTypedAgentDispatchInternalClient(params ClientParams) (TypedAgentDispatchInternalClient, error)

+ type TypedAgentDispatchInternalServer = AgentDispatchInternalServer[RoomTopic]

+ func NewTypedAgentDispatchInternalServer(svc AgentDispatchInternalServerImpl, bus psrpc.MessageBus, ...) (TypedAgentDispatchInternalServer, error)

Aug 2, 2024

Changes in this version

type CheckEnabledResponse

+ AgentNames []string

+ func (x *CheckEnabledResponse) GetAgentNames() []string

+ type JobRequestResponse struct

+ State *livekit.JobState

+ func (*JobRequestResponse) Descriptor() ([]byte, []int)

+ func (*JobRequestResponse) ProtoMessage()

+ func (x *JobRequestResponse) GetState() *livekit.JobState

+ func (x *JobRequestResponse) ProtoReflect() protoreflect.Message

+ func (x *JobRequestResponse) Reset()

+ func (x *JobRequestResponse) String() string

Jun 20, 2024

Changes in this version

+ const AnalyticsRecorderService_IngestEvents_FullMethodName

+ const AnalyticsRecorderService_IngestNodeRoomStates_FullMethodName

+ const AnalyticsRecorderService_IngestStats_FullMethodName

+ var AnalyticsRecorderService_ServiceDesc = grpc.ServiceDesc

+ var File_rpc_analytics_proto protoreflect.FileDescriptor

+ func RegisterAnalyticsRecorderServiceServer(s grpc.ServiceRegistrar, srv AnalyticsRecorderServiceServer)

+ type AnalyticsRecorderServiceClient interface

+ IngestEvents func(ctx context.Context, opts ...grpc.CallOption) (AnalyticsRecorderService_IngestEventsClient, error)

+ IngestNodeRoomStates func(ctx context.Context, opts ...grpc.CallOption) (AnalyticsRecorderService_IngestNodeRoomStatesClient, error)

+ IngestStats func(ctx context.Context, opts ...grpc.CallOption) (AnalyticsRecorderService_IngestStatsClient, error)

+ func NewAnalyticsRecorderServiceClient(cc grpc.ClientConnInterface) AnalyticsRecorderServiceClient

+ type AnalyticsRecorderServiceServer interface

+ IngestEvents func(AnalyticsRecorderService_IngestEventsServer) error

+ IngestNodeRoomStates func(AnalyticsRecorderService_IngestNodeRoomStatesServer) error

+ IngestStats func(AnalyticsRecorderService_IngestStatsServer) error

+ type AnalyticsRecorderService_IngestEventsClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*livekit.AnalyticsEvents) error

+ type AnalyticsRecorderService_IngestEventsServer interface

+ Recv func() (*livekit.AnalyticsEvents, error)

+ SendAndClose func(*emptypb.Empty) error

+ type AnalyticsRecorderService_IngestNodeRoomStatesClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*livekit.AnalyticsNodeRooms) error

+ type AnalyticsRecorderService_IngestNodeRoomStatesServer interface

+ Recv func() (*livekit.AnalyticsNodeRooms, error)

+ SendAndClose func(*emptypb.Empty) error

+ type AnalyticsRecorderService_IngestStatsClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*livekit.AnalyticsStats) error

+ type AnalyticsRecorderService_IngestStatsServer interface

+ Recv func() (*livekit.AnalyticsStats, error)

+ SendAndClose func(*emptypb.Empty) error

type EvaluateSIPDispatchRulesRequest

+ ExtraAttributes map[string]string

+ func (x *EvaluateSIPDispatchRulesRequest) GetExtraAttributes() map[string]string

type EvaluateSIPDispatchRulesResponse

+ ParticipantAttributes map[string]string

+ func (x *EvaluateSIPDispatchRulesResponse) GetParticipantAttributes() map[string]string

type IngressInternalClient

+ KillIngressSession func(ctx context.Context, ingressId string, resourceId string, ...) (*google_protobuf.Empty, error)

type IngressInternalServer

+ DeregisterKillIngressSessionTopic func(ingressId string, resourceId string)

+ RegisterKillIngressSessionTopic func(ingressId string, resourceId string) error

type IngressInternalServerImpl

+ KillIngressSession func(context.Context, *KillIngressSessionRequest) (*google_protobuf.Empty, error)

+ type IngressSession struct

+ IngressId string

+ ResourceId string

+ func (*IngressSession) Descriptor() ([]byte, []int)

+ func (*IngressSession) ProtoMessage()

+ func (x *IngressSession) GetIngressId() string

+ func (x *IngressSession) GetResourceId() string

+ func (x *IngressSession) ProtoReflect() protoreflect.Message

+ func (x *IngressSession) Reset()

+ func (x *IngressSession) String() string

type InternalCreateSIPParticipantRequest

+ ParticipantAttributes map[string]string

+ func (x *InternalCreateSIPParticipantRequest) GetParticipantAttributes() map[string]string

+ type KillIngressSessionRequest struct

+ Session *IngressSession

+ func (*KillIngressSessionRequest) Descriptor() ([]byte, []int)

+ func (*KillIngressSessionRequest) ProtoMessage()

+ func (x *KillIngressSessionRequest) GetSession() *IngressSession

+ func (x *KillIngressSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *KillIngressSessionRequest) Reset()

+ func (x *KillIngressSessionRequest) String() string

type ListActiveIngressResponse

+ IngressSessions []*IngressSession

+ func (x *ListActiveIngressResponse) GetIngressSessions() []*IngressSession

+ type UnimplementedAnalyticsRecorderServiceServer struct

+ func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents(AnalyticsRecorderService_IngestEventsServer) error

+ func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates(AnalyticsRecorderService_IngestNodeRoomStatesServer) error

+ func (UnimplementedAnalyticsRecorderServiceServer) IngestStats(AnalyticsRecorderService_IngestStatsServer) error

+ type UnsafeAnalyticsRecorderServiceServer interface

Jun 2, 2024

Changes in this version

+ type ICERestartWHIPResourceRequest struct

+ Candidates []string

+ Password string

+ ResourceId string

+ StreamKey string

+ UserFragment string

+ func (*ICERestartWHIPResourceRequest) Descriptor() ([]byte, []int)

+ func (*ICERestartWHIPResourceRequest) ProtoMessage()

+ func (x *ICERestartWHIPResourceRequest) GetCandidates() []string

+ func (x *ICERestartWHIPResourceRequest) GetPassword() string

+ func (x *ICERestartWHIPResourceRequest) GetResourceId() string

+ func (x *ICERestartWHIPResourceRequest) GetStreamKey() string

+ func (x *ICERestartWHIPResourceRequest) GetUserFragment() string

+ func (x *ICERestartWHIPResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *ICERestartWHIPResourceRequest) Reset()

+ func (x *ICERestartWHIPResourceRequest) String() string

+ type ICERestartWHIPResourceResponse struct

+ TrickleIceSdpfrag string

+ func (*ICERestartWHIPResourceResponse) Descriptor() ([]byte, []int)

+ func (*ICERestartWHIPResourceResponse) ProtoMessage()

+ func (x *ICERestartWHIPResourceResponse) GetTrickleIceSdpfrag() string

+ func (x *ICERestartWHIPResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *ICERestartWHIPResourceResponse) Reset()

+ func (x *ICERestartWHIPResourceResponse) String() string

type IngressHandlerClient

+ ICERestartWHIPResource func(ctx context.Context, topic string, req *ICERestartWHIPResourceRequest, ...) (*ICERestartWHIPResourceResponse, error)

type IngressHandlerServer

+ DeregisterICERestartWHIPResourceTopic func(topic string)

+ RegisterICERestartWHIPResourceTopic func(topic string) error

type IngressHandlerServerImpl

+ ICERestartWHIPResource func(context.Context, *ICERestartWHIPResourceRequest) (*ICERestartWHIPResourceResponse, error)

type InternalCreateSIPParticipantRequest

+ Transport livekit.SIPTransport

+ func NewCreateSIPParticipantRequest(callID, wsUrl, token string, req *livekit.CreateSIPParticipantRequest, ...) *InternalCreateSIPParticipantRequest

+ func (x *InternalCreateSIPParticipantRequest) GetTransport() livekit.SIPTransport

May 2, 2024

Changes in this version

type EvaluateSIPDispatchRulesRequest

+ SipCallId string

+ func (x *EvaluateSIPDispatchRulesRequest) GetSipCallId() string

type EvaluateSIPDispatchRulesResponse

+ ParticipantMetadata string

+ ParticipantName string

+ SipDispatchRuleId string

+ SipTrunkId string

+ func (x *EvaluateSIPDispatchRulesResponse) GetParticipantMetadata() string

+ func (x *EvaluateSIPDispatchRulesResponse) GetParticipantName() string

+ func (x *EvaluateSIPDispatchRulesResponse) GetSipDispatchRuleId() string

+ func (x *EvaluateSIPDispatchRulesResponse) GetSipTrunkId() string

type GetSIPTrunkAuthenticationRequest

+ SipCallId string

+ func (x *GetSIPTrunkAuthenticationRequest) GetSipCallId() string

type GetSIPTrunkAuthenticationResponse

+ SipTrunkId string

+ func (x *GetSIPTrunkAuthenticationResponse) GetSipTrunkId() string

type InternalCreateSIPParticipantRequest

+ ParticipantMetadata string

+ ParticipantName string

+ SipCallId string

+ func (x *InternalCreateSIPParticipantRequest) GetParticipantMetadata() string

+ func (x *InternalCreateSIPParticipantRequest) GetParticipantName() string

+ func (x *InternalCreateSIPParticipantRequest) GetSipCallId() string

type InternalCreateSIPParticipantResponse

+ SipCallId string

+ func (x *InternalCreateSIPParticipantResponse) GetSipCallId() string

Apr 26, 2024

Changes in this version

+ func CurryMetricLabels(labels prometheus.Labels)

type AgentInternalClient

+ SubscribeWorkerRegistered func(ctx context.Context, handlerNamespace string) (psrpc.Subscription[*google_protobuf.Empty], error)

type AgentInternalServer

+ PublishWorkerRegistered func(ctx context.Context, handlerNamespace string, msg *google_protobuf.Empty) error

type CheckEnabledResponse

+ Namespaces []string

+ func (x *CheckEnabledResponse) GetNamespaces() []string

type ClientParams

+ func (p *ClientParams) Options() []psrpc.ClientOption

type InternalCreateSIPParticipantRequest

+ PlayRingtone bool

+ func (x *InternalCreateSIPParticipantRequest) GetPlayRingtone() bool

+ type PSRPCMetricsOption func(*psrpcMetricsOptions)

+ func WithCurryLabels(labels prometheus.Labels) PSRPCMetricsOption

Mar 19, 2024

Changes in this version

type InternalCreateSIPParticipantRequest

+ Dtmf string

+ func (x *InternalCreateSIPParticipantRequest) GetDtmf() string

Feb 27, 2024

Changes in this version

+ func InitPSRPCStats(constLabels prometheus.Labels)

+ func WithClientLogger(logger logger.Logger) psrpc.ClientOption

+ func WithServerLogger(logger logger.Logger) psrpc.ServerOption

type IOInfoClient

+ CreateIngress func(ctx context.Context, req *livekit3.IngressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

type IOInfoServerImpl

+ CreateIngress func(context.Context, *livekit3.IngressInfo) (*google_protobuf.Empty, error)

+ type PSRPCMetricsObserver struct

+ func (o PSRPCMetricsObserver) OnMultiRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)

+ func (o PSRPCMetricsObserver) OnStreamClose(role middleware.MetricRole, info psrpc.RPCInfo)

+ func (o PSRPCMetricsObserver) OnStreamOpen(role middleware.MetricRole, info psrpc.RPCInfo)

+ func (o PSRPCMetricsObserver) OnStreamRecv(role middleware.MetricRole, info psrpc.RPCInfo, err error)

+ func (o PSRPCMetricsObserver) OnStreamSend(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)

+ func (o PSRPCMetricsObserver) OnUnaryRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, ...)

+ type UnimplementedMetricsObserver struct

+ func (o UnimplementedMetricsObserver) OnMultiRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)

+ func (o UnimplementedMetricsObserver) OnStreamClose(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)

+ func (o UnimplementedMetricsObserver) OnStreamOpen(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)

+ func (o UnimplementedMetricsObserver) OnStreamRecv(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, err error)

+ func (o UnimplementedMetricsObserver) OnStreamSend(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)

+ func (o UnimplementedMetricsObserver) OnUnaryRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, ...)

Feb 8, 2024

Changes in this version

+ var SIPDispatchResult_name = map[int32]string

+ var SIPDispatchResult_value = map[string]int32

type EvaluateSIPDispatchRulesResponse

+ Result SIPDispatchResult

+ func (x *EvaluateSIPDispatchRulesResponse) GetResult() SIPDispatchResult

type GetSIPTrunkAuthenticationResponse

+ Drop bool

+ func (x *GetSIPTrunkAuthenticationResponse) GetDrop() bool

type IngressInternalServer

+ DeregisterListActiveIngressTopic func(topic string)

+ RegisterListActiveIngressTopic func(topic string) error

+ type SIPDispatchResult int32

+ const SIPDispatchResult_ACCEPT

+ const SIPDispatchResult_DROP

+ const SIPDispatchResult_LEGACY_ACCEPT_OR_PIN

+ const SIPDispatchResult_REJECT

+ const SIPDispatchResult_REQUEST_PIN

+ func (SIPDispatchResult) Descriptor() protoreflect.EnumDescriptor

+ func (SIPDispatchResult) EnumDescriptor() ([]byte, []int)

+ func (SIPDispatchResult) Type() protoreflect.EnumType

+ func (x SIPDispatchResult) Enum() *SIPDispatchResult

+ func (x SIPDispatchResult) Number() protoreflect.EnumNumber

+ func (x SIPDispatchResult) String() string

Feb 5, 2024

Changes in this version

type GetIngressInfoResponse

+ LoggingFields map[string]string

+ func (x *GetIngressInfoResponse) GetLoggingFields() map[string]string

type InternalCreateSIPParticipantRequest

+ Token string

+ WsUrl string

+ func (x *InternalCreateSIPParticipantRequest) GetToken() string

+ func (x *InternalCreateSIPParticipantRequest) GetWsUrl() string

type StartIngressRequest

+ LoggingFields map[string]string

+ func (x *StartIngressRequest) GetLoggingFields() map[string]string

Jan 24, 2024

Changes in this version

+ var File_rpc_keepalive_proto protoreflect.FileDescriptor

type EgressInternalServer

+ DeregisterListActiveEgressTopic func(topic string)

+ RegisterListActiveEgressTopic func(topic string) error

+ type InternalCreateSIPParticipantRequest struct

+ Address string

+ CallTo string

+ Number string

+ ParticipantIdentity string

+ Password string

+ RoomName string

+ Username string

+ func (*InternalCreateSIPParticipantRequest) Descriptor() ([]byte, []int)

+ func (*InternalCreateSIPParticipantRequest) ProtoMessage()

+ func (x *InternalCreateSIPParticipantRequest) GetAddress() string

+ func (x *InternalCreateSIPParticipantRequest) GetCallTo() string

+ func (x *InternalCreateSIPParticipantRequest) GetNumber() string

+ func (x *InternalCreateSIPParticipantRequest) GetParticipantIdentity() string

+ func (x *InternalCreateSIPParticipantRequest) GetPassword() string

+ func (x *InternalCreateSIPParticipantRequest) GetRoomName() string

+ func (x *InternalCreateSIPParticipantRequest) GetUsername() string

+ func (x *InternalCreateSIPParticipantRequest) ProtoReflect() protoreflect.Message

+ func (x *InternalCreateSIPParticipantRequest) Reset()

+ func (x *InternalCreateSIPParticipantRequest) String() string

+ type InternalCreateSIPParticipantResponse struct

+ ParticipantId string

+ ParticipantIdentity string

+ func (*InternalCreateSIPParticipantResponse) Descriptor() ([]byte, []int)

+ func (*InternalCreateSIPParticipantResponse) ProtoMessage()

+ func (x *InternalCreateSIPParticipantResponse) GetParticipantId() string

+ func (x *InternalCreateSIPParticipantResponse) GetParticipantIdentity() string

+ func (x *InternalCreateSIPParticipantResponse) ProtoReflect() protoreflect.Message

+ func (x *InternalCreateSIPParticipantResponse) Reset()

+ func (x *InternalCreateSIPParticipantResponse) String() string

+ type KeepaliveClient interface

+ SubscribePing func(ctx context.Context, nodeID NodeIDTopicType) (psrpc.Subscription[*KeepalivePing], error)

+ func NewKeepaliveClient[NodeIDTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (KeepaliveClient[NodeIDTopicType], error)

+ type KeepalivePing struct

+ Timestamp int64

+ func (*KeepalivePing) Descriptor() ([]byte, []int)

+ func (*KeepalivePing) ProtoMessage()

+ func (x *KeepalivePing) GetTimestamp() int64

+ func (x *KeepalivePing) ProtoReflect() protoreflect.Message

+ func (x *KeepalivePing) Reset()

+ func (x *KeepalivePing) String() string

+ type KeepalivePubSub interface

+ func NewKeepalivePubSub(params ClientParams) (KeepalivePubSub, error)

+ type KeepaliveServer interface

+ Kill func()

+ PublishPing func(ctx context.Context, nodeID NodeIDTopicType, msg *KeepalivePing) error

+ Shutdown func()

+ func NewKeepaliveServer[NodeIDTopicType ~string](svc KeepaliveServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (KeepaliveServer[NodeIDTopicType], error)

+ type KeepaliveServerImpl interface

type SIPInternalClient

+ CreateSIPParticipant func(ctx context.Context, topic string, req *InternalCreateSIPParticipantRequest, ...) (*InternalCreateSIPParticipantResponse, error)

type SIPInternalServer

+ DeregisterCreateSIPParticipantTopic func(topic string)

+ RegisterCreateSIPParticipantTopic func(topic string) error

type SIPInternalServerImpl

+ CreateSIPParticipant func(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error)

+ CreateSIPParticipantAffinity func(context.Context, *InternalCreateSIPParticipantRequest) float32

Jan 16, 2024

Changes in this version

type AgentInternalClient

+ SubscribeAgentRegistered func(ctx context.Context, projectId string) (psrpc.Subscription[*CheckEnabledResponse], error)

type AgentInternalServer

+ PublishAgentRegistered func(ctx context.Context, projectId string, msg *CheckEnabledResponse) error

type EvaluateSIPDispatchRulesRequest

+ CalledHost string

+ func (x *EvaluateSIPDispatchRulesRequest) GetCalledHost() string

type EvaluateSIPDispatchRulesResponse

+ Token string

+ WsUrl string

+ func (x *EvaluateSIPDispatchRulesResponse) GetToken() string

+ func (x *EvaluateSIPDispatchRulesResponse) GetWsUrl() string

type GetSIPTrunkAuthenticationRequest

+ ToHost string

+ func (x *GetSIPTrunkAuthenticationRequest) GetToHost() string

type IOInfoClient

+ UpdateMetrics func(ctx context.Context, req *UpdateMetricsRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

type IOInfoServerImpl

+ UpdateMetrics func(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error)

type SIPInternalServer

+ DeregisterUpdateSIPParticipantTopic func(topic string)

+ RegisterUpdateSIPParticipantTopic func(topic string) error

+ 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

Nov 28, 2023

Changes in this version

type EvaluateSIPDispatchRulesRequest

+ NoPin bool

+ func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool

+ 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

+ Address string

+ CallTo string

+ Number string

+ ParticipantId string

+ ParticipantIdentity string

+ Password string

+ RoomName string

+ Username string

+ 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

type SIPInternalClient

+ SendSIPParticipantDTMF func(ctx context.Context, req *InternalSendSIPParticipantDTMFRequest, ...) (*InternalSendSIPParticipantDTMFResponse, error)

type SIPInternalServerImpl

+ SendSIPParticipantDTMF func(context.Context, *InternalSendSIPParticipantDTMFRequest) (*InternalSendSIPParticipantDTMFResponse, error)

+ SendSIPParticipantDTMFAffinity func(context.Context, *InternalSendSIPParticipantDTMFRequest) float32

Nov 14, 2023

Changes in this version

+ var File_rpc_agent_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 EvaluateSIPDispatchRulesRequest struct

+ CalledNumber string

+ CallingNumber string

+ Pin string

+ SipParticipantId string

+ SrcAddress string

+ func (*EvaluateSIPDispatchRulesRequest) Descriptor() ([]byte, []int)

+ func (*EvaluateSIPDispatchRulesRequest) ProtoMessage()

+ func (x *EvaluateSIPDispatchRulesRequest) GetCalledNumber() string

+ func (x *EvaluateSIPDispatchRulesRequest) GetCallingNumber() string

+ 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

+ 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) ProtoReflect() protoreflect.Message

+ func (x *EvaluateSIPDispatchRulesResponse) Reset()

+ func (x *EvaluateSIPDispatchRulesResponse) String() string

+ type GetSIPTrunkAuthenticationRequest struct

+ From string

+ SrcAddress string

+ To 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) 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

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

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

type IOInfoServerImpl

+ EvaluateSIPDispatchRules func(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error)

+ GetSIPTrunkAuthentication func(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error)

+ type InternalUpdateSIPParticipantRequest struct

+ func (*InternalUpdateSIPParticipantRequest) Descriptor() ([]byte, []int)

+ func (*InternalUpdateSIPParticipantRequest) ProtoMessage()

+ 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 SIPClient interface

+ func NewSIPClient(bus psrpc.MessageBus) (SIPClient, error)

+ type SIPInternalClient interface

+ 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

+ UpdateSIPParticipant func(context.Context, *InternalUpdateSIPParticipantRequest) (*InternalUpdateSIPParticipantResponse, error)

+ UpdateSIPParticipantAffinity func(context.Context, *InternalUpdateSIPParticipantRequest) float32

Nov 2, 2023

Changes in this version

+ var DefaultPSRPCConfig = PSRPCConfig

+ var File_rpc_participant_proto protoreflect.FileDescriptor

+ type ClientParams struct

+ Bus psrpc.MessageBus

+ Logger logger.Logger

+ Observer middleware.MetricsObserver

+ func NewClientParams(config PSRPCConfig, bus psrpc.MessageBus, logger logger.Logger, ...) ClientParams

+ 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, ...) (*livekit3.MuteRoomTrackResponse, error)

+ RemoveParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit3.RemoveParticipantResponse, error)

+ UpdateParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit.ParticipantInfo, error)

+ UpdateSubscriptions func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit3.UpdateSubscriptionsResponse, error)

+ func NewParticipantClient(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(svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (ParticipantServer[ParticipantTopicType], error)

+ type ParticipantServerImpl interface

+ MutePublishedTrack func(context.Context, *livekit3.MuteRoomTrackRequest) (*livekit3.MuteRoomTrackResponse, error)

+ RemoveParticipant func(context.Context, *livekit3.RoomParticipantIdentity) (*livekit3.RemoveParticipantResponse, error)

+ UpdateParticipant func(context.Context, *livekit3.UpdateParticipantRequest) (*livekit.ParticipantInfo, error)

+ UpdateSubscriptions func(context.Context, *livekit3.UpdateSubscriptionsRequest) (*livekit3.UpdateSubscriptionsResponse, error)

type TopicFormatter

+ 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)

Oct 24, 2023

Changes in this version

+ var File_rpc_room_proto protoreflect.FileDescriptor

+ 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 IOInfoClient

+ CreateEgress func(ctx context.Context, req *livekit1.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf3.Empty, error)

+ GetEgress func(ctx context.Context, req *GetEgressRequest, opts ...psrpc.RequestOption) (*livekit1.EgressInfo, error)

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

+ UpdateEgress func(ctx context.Context, req *livekit1.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf3.Empty, error)

type IOInfoServerImpl

+ CreateEgress func(context.Context, *livekit1.EgressInfo) (*google_protobuf3.Empty, error)

+ GetEgress func(context.Context, *GetEgressRequest) (*livekit1.EgressInfo, error)

+ ListEgress func(context.Context, *livekit1.ListEgressRequest) (*livekit1.ListEgressResponse, error)

+ UpdateEgress func(context.Context, *livekit1.EgressInfo) (*google_protobuf3.Empty, error)

+ type ParticipantTopic string

+ func FormatParticipantTopic(roomName livekit.RoomName, identity livekit.ParticipantIdentity) ParticipantTopic

+ type RoomClient interface

+ DeleteRoom func(ctx context.Context, room RoomTopicType, req *livekit3.DeleteRoomRequest, ...) (*livekit3.DeleteRoomResponse, error)

+ MutePublishedTrack func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit3.MuteRoomTrackResponse, error)

+ RemoveParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit3.RemoveParticipantResponse, error)

+ SendData func(ctx context.Context, room RoomTopicType, req *livekit3.SendDataRequest, ...) (*livekit3.SendDataResponse, error)

+ UpdateParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit.ParticipantInfo, error)

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

+ UpdateSubscriptions func(ctx context.Context, participant ParticipantTopicType, ...) (*livekit3.UpdateSubscriptionsResponse, error)

+ func NewRoomClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (RoomClient[ParticipantTopicType, RoomTopicType], error)

+ type RoomServer interface

+ DeregisterAllParticipantTopics func(participant ParticipantTopicType)

+ DeregisterAllRoomTopics func(room RoomTopicType)

+ DeregisterDeleteRoomTopic func(room RoomTopicType)

+ DeregisterMutePublishedTrackTopic func(participant ParticipantTopicType)

+ DeregisterRemoveParticipantTopic func(participant ParticipantTopicType)

+ DeregisterSendDataTopic func(room RoomTopicType)

+ DeregisterUpdateParticipantTopic func(participant ParticipantTopicType)

+ DeregisterUpdateRoomMetadataTopic func(room RoomTopicType)

+ DeregisterUpdateSubscriptionsTopic func(participant ParticipantTopicType)

+ Kill func()

+ RegisterAllParticipantTopics func(participant ParticipantTopicType) error

+ RegisterAllRoomTopics func(room RoomTopicType) error

+ RegisterDeleteRoomTopic func(room RoomTopicType) error

+ RegisterMutePublishedTrackTopic func(participant ParticipantTopicType) error

+ RegisterRemoveParticipantTopic func(participant ParticipantTopicType) error

+ RegisterSendDataTopic func(room RoomTopicType) error

+ RegisterUpdateParticipantTopic func(participant ParticipantTopicType) error

+ RegisterUpdateRoomMetadataTopic func(room RoomTopicType) error

+ RegisterUpdateSubscriptionsTopic func(participant ParticipantTopicType) error

+ Shutdown func()

+ func NewRoomServer(serverID string, svc RoomServerImpl, bus psrpc.MessageBus, ...) (RoomServer[ParticipantTopicType, RoomTopicType], error)

+ type RoomServerImpl interface

+ DeleteRoom func(context.Context, *livekit3.DeleteRoomRequest) (*livekit3.DeleteRoomResponse, error)

+ MutePublishedTrack func(context.Context, *livekit3.MuteRoomTrackRequest) (*livekit3.MuteRoomTrackResponse, error)

+ RemoveParticipant func(context.Context, *livekit3.RoomParticipantIdentity) (*livekit3.RemoveParticipantResponse, error)

+ SendData func(context.Context, *livekit3.SendDataRequest) (*livekit3.SendDataResponse, error)

+ UpdateParticipant func(context.Context, *livekit3.UpdateParticipantRequest) (*livekit.ParticipantInfo, error)

+ UpdateRoomMetadata func(context.Context, *livekit3.UpdateRoomMetadataRequest) (*livekit.Room, error)

+ UpdateSubscriptions func(context.Context, *livekit3.UpdateSubscriptionsRequest) (*livekit3.UpdateSubscriptionsResponse, error)

+ type RoomTopic string

+ func FormatRoomTopic(roomName livekit.RoomName) RoomTopic

+ type TopicFormatter interface

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

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

+ type TypedRoomClient = RoomClient[ParticipantTopic, RoomTopic]

+ func NewTypedRoomClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedRoomClient, error)

+ type TypedRoomServer = RoomServer[ParticipantTopic, RoomTopic]

+ func NewTypedRoomServer(nodeID livekit.NodeID, svc RoomServerImpl, bus psrpc.MessageBus, ...) (TypedRoomServer, error)

Sep 7, 2023

Changes in this version

type StartEgressRequest

+ func (x *StartEgressRequest) GetParticipant() *livekit.ParticipantEgressRequest

+ type StartEgressRequest_Participant struct

+ Participant *livekit.ParticipantEgressRequest

Aug 3, 2023

Changes in this version

type IngressInternalClient

+ StartIngress func(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*livekit2.IngressInfo, error)

type IngressInternalServerImpl

+ StartIngress func(context.Context, *StartIngressRequest) (*livekit2.IngressInfo, error)

+ StartIngressAffinity func(*StartIngressRequest) float32

+ 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

Jul 15, 2023

Changes in this version

type StartEgressRequest

+ Metadata map[string]*anypb.Any

+ func (x *StartEgressRequest) GetMetadata() map[string]*anypb.Any

Jul 9, 2023

Changes in this version

type DeleteWHIPResourceRequest

+ StreamKey string

+ func (x *DeleteWHIPResourceRequest) GetStreamKey() string

May 5, 2023

Changes in this version

+ type DeleteWHIPResourceRequest struct

+ IngressId string

+ ResourceId string

+ func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWHIPResourceRequest) ProtoMessage()

+ func (x *DeleteWHIPResourceRequest) GetIngressId() string

+ func (x *DeleteWHIPResourceRequest) GetResourceId() string

+ func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWHIPResourceRequest) Reset()

+ func (x *DeleteWHIPResourceRequest) String() string

type IngressHandlerClient

+ DeleteWHIPResource func(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, ...) (*google_protobuf2.Empty, error)

type IngressHandlerServer

+ DeregisterDeleteWHIPResourceTopic func(topic string)

+ RegisterDeleteWHIPResourceTopic func(topic string) error

type IngressHandlerServerImpl

+ DeleteWHIPResource func(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf2.Empty, error)

type RelaySignalRequest

+ Close bool

+ func (x *RelaySignalRequest) GetClose() bool

type RelaySignalResponse

+ Close bool

+ func (x *RelaySignalResponse) GetClose() bool

Apr 12, 2023

Changes in this version

type RelaySignalRequest

+ Requests []*livekit.SignalRequest

+ Seq uint64

+ func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest

+ func (x *RelaySignalRequest) GetSeq() uint64

type RelaySignalResponse

+ Seq uint64

+ func (x *RelaySignalResponse) GetSeq() uint64

Apr 8, 2023

Changes in this version

type RelaySignalResponse

+ Responses []*livekit.SignalResponse

+ func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse

Mar 9, 2023

Changes in this version

+ var File_rpc_signal_proto protoreflect.FileDescriptor

+ type RelaySignalRequest struct

+ Request *livekit.SignalRequest

+ StartSession *livekit.StartSession

+ func (*RelaySignalRequest) Descriptor() ([]byte, []int)

+ func (*RelaySignalRequest) ProtoMessage()

+ func (x *RelaySignalRequest) GetRequest() *livekit.SignalRequest

+ func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession

+ func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message

+ func (x *RelaySignalRequest) Reset()

+ func (x *RelaySignalRequest) String() string

+ type RelaySignalResponse struct

+ Response *livekit.SignalResponse

+ func (*RelaySignalResponse) Descriptor() ([]byte, []int)

+ func (*RelaySignalResponse) ProtoMessage()

+ func (x *RelaySignalResponse) GetResponse() *livekit.SignalResponse

+ func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message

+ func (x *RelaySignalResponse) Reset()

+ func (x *RelaySignalResponse) String() string

+ type SignalClient interface

+ RelaySignal func(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error)

+ func NewSignalClient(clientID 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(serverID string, svc SignalServerImpl, bus psrpc.MessageBus, ...) (SignalServer[NodeIdTopicType], error)

+ type SignalServerImpl interface

+ RelaySignal func(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) 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)

Feb 18, 2023

Changes in this version

+ var File_rpc_egress_proto protoreflect.FileDescriptor

+ var File_rpc_ingress_proto protoreflect.FileDescriptor

+ var File_rpc_io_proto protoreflect.FileDescriptor

+ type EgressClient interface

+ func NewEgressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (EgressClient, error)

+ type EgressHandlerClient interface

+ StopEgress func(context.Context, string, *livekit.StopEgressRequest, ...psrpc.RequestOption) (*livekit.EgressInfo, error)

+ UpdateStream func(context.Context, string, *livekit.UpdateStreamRequest, ...psrpc.RequestOption) (*livekit.EgressInfo, error)

+ func NewEgressHandlerClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressHandlerClient, error)

+ type EgressHandlerServer interface

+ DeregisterStopEgressTopic func(string)

+ DeregisterUpdateStreamTopic func(string)

+ Kill func()

+ RegisterStopEgressTopic func(string) error

+ RegisterUpdateStreamTopic func(string) error

+ Shutdown func()

+ func NewEgressHandlerServer(serverID string, svc EgressHandlerServerImpl, bus psrpc.MessageBus, ...) (EgressHandlerServer, error)

+ type EgressHandlerServerImpl interface

+ StopEgress func(context.Context, *livekit.StopEgressRequest) (*livekit.EgressInfo, error)

+ UpdateStream func(context.Context, *livekit.UpdateStreamRequest) (*livekit.EgressInfo, error)

+ type EgressInternalClient interface

+ ListActiveEgress func(context.Context, *ListActiveEgressRequest, ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error)

+ StartEgress func(context.Context, string, *StartEgressRequest, ...psrpc.RequestOption) (*livekit.EgressInfo, error)

+ func NewEgressInternalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressInternalClient, error)

+ type EgressInternalServer interface

+ DeregisterStartEgressTopic func(string)

+ Kill func()

+ RegisterStartEgressTopic func(string) error

+ Shutdown func()

+ func NewEgressInternalServer(serverID string, svc EgressInternalServerImpl, bus psrpc.MessageBus, ...) (EgressInternalServer, error)

+ type EgressInternalServerImpl interface

+ ListActiveEgress func(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error)

+ StartEgress func(context.Context, *StartEgressRequest) (*livekit.EgressInfo, error)

+ StartEgressAffinity func(*StartEgressRequest) float32

+ 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 IOInfoClient interface

+ GetIngressInfo func(context.Context, *GetIngressInfoRequest, ...psrpc.RequestOption) (*GetIngressInfoResponse, error)

+ UpdateEgressInfo func(context.Context, *livekit.EgressInfo, ...psrpc.RequestOption) (*google_protobuf2.Empty, error)

+ UpdateIngressState func(context.Context, *UpdateIngressStateRequest, ...psrpc.RequestOption) (*google_protobuf2.Empty, error)

+ func NewIOInfoClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IOInfoClient, error)

+ type IOInfoServer interface

+ Kill func()

+ Shutdown func()

+ func NewIOInfoServer(serverID string, svc IOInfoServerImpl, bus psrpc.MessageBus, ...) (IOInfoServer, error)

+ type IOInfoServerImpl interface

+ GetIngressInfo func(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error)

+ UpdateEgressInfo func(context.Context, *livekit.EgressInfo) (*google_protobuf2.Empty, error)

+ UpdateIngressState func(context.Context, *UpdateIngressStateRequest) (*google_protobuf2.Empty, error)

+ type IngressClient interface

+ func NewIngressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (IngressClient, error)

+ type IngressHandlerClient interface

+ DeleteIngress func(context.Context, string, *livekit2.DeleteIngressRequest, ...) (*livekit2.IngressState, error)

+ UpdateIngress func(context.Context, string, *livekit2.UpdateIngressRequest, ...) (*livekit2.IngressState, error)

+ func NewIngressHandlerClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error)

+ type IngressHandlerServer interface

+ DeregisterDeleteIngressTopic func(string)

+ DeregisterUpdateIngressTopic func(string)

+ Kill func()

+ RegisterDeleteIngressTopic func(string) error

+ RegisterUpdateIngressTopic func(string) error

+ Shutdown func()

+ func NewIngressHandlerServer(serverID string, svc IngressHandlerServerImpl, bus psrpc.MessageBus, ...) (IngressHandlerServer, error)

+ type IngressHandlerServerImpl interface

+ DeleteIngress func(context.Context, *livekit2.DeleteIngressRequest) (*livekit2.IngressState, error)

+ UpdateIngress func(context.Context, *livekit2.UpdateIngressRequest) (*livekit2.IngressState, error)

+ type IngressInternalClient interface

+ ListActiveIngress func(context.Context, *ListActiveIngressRequest, ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveIngressResponse], error)

+ func NewIngressInternalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error)

+ type IngressInternalServer interface

+ Kill func()

+ Shutdown func()

+ func NewIngressInternalServer(serverID string, svc IngressInternalServerImpl, bus psrpc.MessageBus, ...) (IngressInternalServer, error)

+ type IngressInternalServerImpl interface

+ ListActiveIngress func(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error)

+ 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 Race struct

+ func NewRace(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 StartEgressRequest struct

+ EgressId string

+ 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) 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_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 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