Versions in this module Expand all Collapse all v0 v0.0.2 Dec 29, 2024 v0.0.1 Dec 28, 2024 Changes in this version + const AnalyticsRecorderService_IngestEvents_FullMethodName + const AnalyticsRecorderService_IngestNodeRoomStates_FullMethodName + const AnalyticsRecorderService_IngestStats_FullMethodName + var AnalyticsRecorderService_ServiceDesc = grpc.ServiceDesc + var DefaultPSRPCConfig = PSRPCConfig + var File_rpc_agent_dispatch_proto protoreflect.FileDescriptor + var File_rpc_agent_proto protoreflect.FileDescriptor + var File_rpc_analytics_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_keepalive_proto protoreflect.FileDescriptor + var File_rpc_participant_proto protoreflect.FileDescriptor + var File_rpc_room_proto protoreflect.FileDescriptor + var File_rpc_roommanager_proto protoreflect.FileDescriptor + var File_rpc_signal_proto protoreflect.FileDescriptor + var File_rpc_sip_proto protoreflect.FileDescriptor + var JobTerminateReason_name = map[int32]string + var JobTerminateReason_value = map[string]int32 + var SIPDispatchResult_name = map[int32]string + var SIPDispatchResult_value = map[string]int32 + func CurryMetricLabels(labels prometheus.Labels) + func InitPSRPCStats(constLabels prometheus.Labels, opts ...PSRPCMetricsOption) + func RegisterAnalyticsRecorderServiceServer(s grpc.ServiceRegistrar, srv AnalyticsRecorderServiceServer) + func WithClientLogger(logger logger.Logger) psrpc.ClientOption + func WithDefaultServerOptions(psrpcConfig PSRPCConfig, logger logger.Logger) psrpc.ServerOption + func WithServerLogger(logger logger.Logger) psrpc.ServerOption + func WithServerObservability(logger logger.Logger) psrpc.ServerOption + type AgentDispatchInternalClient interface + Close func() + CreateDispatch func(ctx context.Context, room RoomTopicType, req *wirtual3.AgentDispatch, ...) (*wirtual3.AgentDispatch, error) + DeleteDispatch func(ctx context.Context, room RoomTopicType, ...) (*wirtual3.AgentDispatch, error) + ListDispatch func(ctx context.Context, room RoomTopicType, ...) (*wirtual3.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, *wirtual3.AgentDispatch) (*wirtual3.AgentDispatch, error) + DeleteDispatch func(context.Context, *wirtual3.DeleteAgentDispatchRequest) (*wirtual3.AgentDispatch, error) + ListDispatch func(context.Context, *wirtual3.ListAgentDispatchRequest) (*wirtual3.ListAgentDispatchResponse, error) + type AgentInternalClient interface + CheckEnabled func(ctx context.Context, req *CheckEnabledRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*CheckEnabledResponse], error) + Close func() + JobRequest func(ctx context.Context, namespace string, jobType string, req *wirtual2.Job, ...) (*JobRequestResponse, error) + JobTerminate func(ctx context.Context, jobId string, req *JobTerminateRequest, ...) (*JobTerminateResponse, error) + SubscribeWorkerRegistered func(ctx context.Context, handlerNamespace string) (psrpc.Subscription[*google_protobuf.Empty], error) + func NewAgentInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (AgentInternalClient, error) + type AgentInternalServer interface + DeregisterJobRequestTopic func(namespace string, jobType string) + DeregisterJobTerminateTopic func(jobId string) + Kill func() + PublishWorkerRegistered func(ctx context.Context, handlerNamespace string, msg *google_protobuf.Empty) error + RegisterJobRequestTopic func(namespace string, jobType string) error + RegisterJobTerminateTopic func(jobId 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, *wirtual2.Job) (*JobRequestResponse, error) + JobRequestAffinity func(context.Context, *wirtual2.Job) float32 + JobTerminate func(context.Context, *JobTerminateRequest) (*JobTerminateResponse, error) + type AnalyticsRecorderServiceClient interface + IngestEvents func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[wirtual.AnalyticsEvents, emptypb.Empty], error) + IngestNodeRoomStates func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[wirtual.AnalyticsNodeRooms, emptypb.Empty], error) + IngestStats func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[wirtual.AnalyticsStats, emptypb.Empty], error) + func NewAnalyticsRecorderServiceClient(cc grpc.ClientConnInterface) AnalyticsRecorderServiceClient + type AnalyticsRecorderServiceServer interface + IngestEvents func(grpc.ClientStreamingServer[wirtual.AnalyticsEvents, emptypb.Empty]) error + IngestNodeRoomStates func(grpc.ClientStreamingServer[wirtual.AnalyticsNodeRooms, emptypb.Empty]) error + IngestStats func(grpc.ClientStreamingServer[wirtual.AnalyticsStats, emptypb.Empty]) error + type AnalyticsRecorderService_IngestEventsClient = grpc.ClientStreamingClient[wirtual.AnalyticsEvents, emptypb.Empty] + type AnalyticsRecorderService_IngestEventsServer = grpc.ClientStreamingServer[wirtual.AnalyticsEvents, emptypb.Empty] + type AnalyticsRecorderService_IngestNodeRoomStatesClient = grpc.ClientStreamingClient[wirtual.AnalyticsNodeRooms, emptypb.Empty] + type AnalyticsRecorderService_IngestNodeRoomStatesServer = grpc.ClientStreamingServer[wirtual.AnalyticsNodeRooms, emptypb.Empty] + type AnalyticsRecorderService_IngestStatsClient = grpc.ClientStreamingClient[wirtual.AnalyticsStats, emptypb.Empty] + type AnalyticsRecorderService_IngestStatsServer = grpc.ClientStreamingServer[wirtual.AnalyticsStats, emptypb.Empty] + 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 + AgentNames []string + Namespaces []string + PublisherEnabled bool + RoomEnabled bool + func (*CheckEnabledResponse) Descriptor() ([]byte, []int) + func (*CheckEnabledResponse) ProtoMessage() + func (x *CheckEnabledResponse) GetAgentNames() []string + func (x *CheckEnabledResponse) GetNamespaces() []string + 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 + func (p *ClientParams) Args() (psrpc.MessageBus, psrpc.ClientOption) + func (p *ClientParams) Options() []psrpc.ClientOption + 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 + Close func() + StopEgress func(ctx context.Context, topic string, req *wirtual4.StopEgressRequest, ...) (*wirtual4.EgressInfo, error) + UpdateStream func(ctx context.Context, topic string, req *wirtual4.UpdateStreamRequest, ...) (*wirtual4.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, *wirtual4.StopEgressRequest) (*wirtual4.EgressInfo, error) + UpdateStream func(context.Context, *wirtual4.UpdateStreamRequest) (*wirtual4.EgressInfo, error) + type EgressInternalClient interface + Close func() + ListActiveEgress func(ctx context.Context, topic string, req *ListActiveEgressRequest, ...) (<-chan *psrpc.Response[*ListActiveEgressResponse], error) + StartEgress func(ctx context.Context, topic string, req *StartEgressRequest, ...) (*wirtual4.EgressInfo, error) + func NewEgressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressInternalClient, error) + type EgressInternalServer interface + DeregisterListActiveEgressTopic func(topic string) + DeregisterStartEgressTopic func(topic string) + Kill func() + RegisterListActiveEgressTopic func(topic string) error + 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) (*wirtual4.EgressInfo, error) + StartEgressAffinity func(context.Context, *StartEgressRequest) float32 + type EvaluateSIPDispatchRulesRequest struct + CalledHost string + CalledNumber string + CallingNumber string + ExtraAttributes map[string]string + NoPin bool + Pin string + SipCallId string + SipParticipantId string + SipTrunkId 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) GetExtraAttributes() map[string]string + func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool + func (x *EvaluateSIPDispatchRulesRequest) GetPin() string + func (x *EvaluateSIPDispatchRulesRequest) GetSipCallId() string + func (x *EvaluateSIPDispatchRulesRequest) GetSipParticipantId() string + func (x *EvaluateSIPDispatchRulesRequest) GetSipTrunkId() string + func (x *EvaluateSIPDispatchRulesRequest) GetSrcAddress() string + func (x *EvaluateSIPDispatchRulesRequest) ProtoReflect() protoreflect.Message + func (x *EvaluateSIPDispatchRulesRequest) Reset() + func (x *EvaluateSIPDispatchRulesRequest) String() string + type EvaluateSIPDispatchRulesResponse struct + AttributesToHeaders map[string]string + EnabledFeatures []wirtual.SIPFeature + Headers map[string]string + HeadersToAttributes map[string]string + IncludeHeaders wirtual.SIPHeaderOptions + MaxCallDuration *durationpb.Duration + MediaEncryption wirtual.SIPMediaEncryption + ParticipantAttributes map[string]string + ParticipantIdentity string + ParticipantMetadata string + ParticipantName string + ProjectId string + RequestPin bool + Result SIPDispatchResult + RingingTimeout *durationpb.Duration + RoomConfig *wirtual.RoomConfiguration + RoomName string + RoomPreset string + SipDispatchRuleId string + SipTrunkId string + Token string + WsUrl string + func (*EvaluateSIPDispatchRulesResponse) Descriptor() ([]byte, []int) + func (*EvaluateSIPDispatchRulesResponse) ProtoMessage() + func (x *EvaluateSIPDispatchRulesResponse) GetAttributesToHeaders() map[string]string + func (x *EvaluateSIPDispatchRulesResponse) GetEnabledFeatures() []wirtual.SIPFeature + func (x *EvaluateSIPDispatchRulesResponse) GetHeaders() map[string]string + func (x *EvaluateSIPDispatchRulesResponse) GetHeadersToAttributes() map[string]string + func (x *EvaluateSIPDispatchRulesResponse) GetIncludeHeaders() wirtual.SIPHeaderOptions + func (x *EvaluateSIPDispatchRulesResponse) GetMaxCallDuration() *durationpb.Duration + func (x *EvaluateSIPDispatchRulesResponse) GetMediaEncryption() wirtual.SIPMediaEncryption + func (x *EvaluateSIPDispatchRulesResponse) GetParticipantAttributes() map[string]string + func (x *EvaluateSIPDispatchRulesResponse) GetParticipantIdentity() string + func (x *EvaluateSIPDispatchRulesResponse) GetParticipantMetadata() string + func (x *EvaluateSIPDispatchRulesResponse) GetParticipantName() string + func (x *EvaluateSIPDispatchRulesResponse) GetProjectId() string + func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() bool + func (x *EvaluateSIPDispatchRulesResponse) GetResult() SIPDispatchResult + func (x *EvaluateSIPDispatchRulesResponse) GetRingingTimeout() *durationpb.Duration + func (x *EvaluateSIPDispatchRulesResponse) GetRoomConfig() *wirtual.RoomConfiguration + func (x *EvaluateSIPDispatchRulesResponse) GetRoomName() string + func (x *EvaluateSIPDispatchRulesResponse) GetRoomPreset() string + func (x *EvaluateSIPDispatchRulesResponse) GetSipDispatchRuleId() string + func (x *EvaluateSIPDispatchRulesResponse) GetSipTrunkId() 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 *wirtual.IngressInfo + LoggingFields map[string]string + Token string + WsUrl string + func (*GetIngressInfoResponse) Descriptor() ([]byte, []int) + func (*GetIngressInfoResponse) ProtoMessage() + func (x *GetIngressInfoResponse) GetInfo() *wirtual.IngressInfo + func (x *GetIngressInfoResponse) GetLoggingFields() map[string]string + 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 + SipCallId string + SrcAddress string + To string + ToHost string + func (*GetSIPTrunkAuthenticationRequest) Descriptor() ([]byte, []int) + func (*GetSIPTrunkAuthenticationRequest) ProtoMessage() + func (x *GetSIPTrunkAuthenticationRequest) GetFrom() string + func (x *GetSIPTrunkAuthenticationRequest) GetSipCallId() 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 + Drop bool + Password string + ProjectId string + SipTrunkId string + Username string + func (*GetSIPTrunkAuthenticationResponse) Descriptor() ([]byte, []int) + func (*GetSIPTrunkAuthenticationResponse) ProtoMessage() + func (x *GetSIPTrunkAuthenticationResponse) GetDrop() bool + func (x *GetSIPTrunkAuthenticationResponse) GetPassword() string + func (x *GetSIPTrunkAuthenticationResponse) GetProjectId() string + func (x *GetSIPTrunkAuthenticationResponse) GetSipTrunkId() string + func (x *GetSIPTrunkAuthenticationResponse) GetUsername() string + func (x *GetSIPTrunkAuthenticationResponse) ProtoReflect() protoreflect.Message + func (x *GetSIPTrunkAuthenticationResponse) Reset() + func (x *GetSIPTrunkAuthenticationResponse) String() string + 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 IOInfoClient interface + Close func() + CreateEgress func(ctx context.Context, req *wirtual4.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) + CreateIngress func(ctx context.Context, req *wirtual5.IngressInfo, 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) (*wirtual4.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 *wirtual4.ListEgressRequest, ...) (*wirtual4.ListEgressResponse, error) + UpdateEgress func(ctx context.Context, req *wirtual4.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) + UpdateSIPCallState func(ctx context.Context, req *UpdateSIPCallStateRequest, ...) (*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, *wirtual4.EgressInfo) (*google_protobuf.Empty, error) + CreateIngress func(context.Context, *wirtual5.IngressInfo) (*google_protobuf.Empty, error) + EvaluateSIPDispatchRules func(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error) + GetEgress func(context.Context, *GetEgressRequest) (*wirtual4.EgressInfo, error) + GetIngressInfo func(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) + GetSIPTrunkAuthentication func(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error) + ListEgress func(context.Context, *wirtual4.ListEgressRequest) (*wirtual4.ListEgressResponse, error) + UpdateEgress func(context.Context, *wirtual4.EgressInfo) (*google_protobuf.Empty, error) + UpdateIngressState func(context.Context, *UpdateIngressStateRequest) (*google_protobuf.Empty, error) + UpdateMetrics func(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error) + UpdateSIPCallState func(context.Context, *UpdateSIPCallStateRequest) (*google_protobuf.Empty, error) + type IngressClient interface + func NewIngressClient(params ClientParams) (IngressClient, error) + type IngressHandlerClient interface + Close func() + DeleteIngress func(ctx context.Context, topic string, req *wirtual5.DeleteIngressRequest, ...) (*wirtual5.IngressState, error) + DeleteWHIPResource func(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, ...) (*google_protobuf.Empty, error) + ICERestartWHIPResource func(ctx context.Context, topic string, req *ICERestartWHIPResourceRequest, ...) (*ICERestartWHIPResourceResponse, error) + UpdateIngress func(ctx context.Context, topic string, req *wirtual5.UpdateIngressRequest, ...) (*wirtual5.IngressState, error) + func NewIngressHandlerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error) + type IngressHandlerServer interface + DeregisterDeleteIngressTopic func(topic string) + DeregisterDeleteWHIPResourceTopic func(topic string) + DeregisterICERestartWHIPResourceTopic func(topic string) + DeregisterUpdateIngressTopic func(topic string) + Kill func() + RegisterDeleteIngressTopic func(topic string) error + RegisterDeleteWHIPResourceTopic func(topic string) error + RegisterICERestartWHIPResourceTopic 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, *wirtual5.DeleteIngressRequest) (*wirtual5.IngressState, error) + DeleteWHIPResource func(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error) + ICERestartWHIPResource func(context.Context, *ICERestartWHIPResourceRequest) (*ICERestartWHIPResourceResponse, error) + UpdateIngress func(context.Context, *wirtual5.UpdateIngressRequest) (*wirtual5.IngressState, error) + type IngressInternalClient interface + Close func() + KillIngressSession func(ctx context.Context, ingressId string, resourceId string, ...) (*google_protobuf.Empty, error) + ListActiveIngress func(ctx context.Context, topic string, req *ListActiveIngressRequest, ...) (<-chan *psrpc.Response[*ListActiveIngressResponse], error) + StartIngress func(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*wirtual5.IngressInfo, error) + func NewIngressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error) + type IngressInternalServer interface + DeregisterKillIngressSessionTopic func(ingressId string, resourceId string) + DeregisterListActiveIngressTopic func(topic string) + Kill func() + RegisterKillIngressSessionTopic func(ingressId string, resourceId string) error + RegisterListActiveIngressTopic func(topic string) error + Shutdown func() + func NewIngressInternalServer(svc IngressInternalServerImpl, bus psrpc.MessageBus, ...) (IngressInternalServer, error) + type IngressInternalServerImpl interface + KillIngressSession func(context.Context, *KillIngressSessionRequest) (*google_protobuf.Empty, error) + ListActiveIngress func(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) + StartIngress func(context.Context, *StartIngressRequest) (*wirtual5.IngressInfo, error) + StartIngressAffinity func(context.Context, *StartIngressRequest) float32 + 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 struct + Address string + AttributesToHeaders map[string]string + CallTo string + Dtmf string + EnabledFeatures []wirtual.SIPFeature + Headers map[string]string + HeadersToAttributes map[string]string + Hostname string + IncludeHeaders wirtual.SIPHeaderOptions + MaxCallDuration *durationpb.Duration + MediaEncryption wirtual.SIPMediaEncryption + Number string + ParticipantAttributes map[string]string + ParticipantIdentity string + ParticipantMetadata string + ParticipantName string + Password string + PlayDialtone bool + ProjectId string + RingingTimeout *durationpb.Duration + RoomName string + SipCallId string + SipTrunkId string + Token string + Transport wirtual.SIPTransport + Username string + WsUrl string + func NewCreateSIPParticipantRequest(projectID, callID, host, wsUrl, token string, ...) (*InternalCreateSIPParticipantRequest, error) + func (*InternalCreateSIPParticipantRequest) Descriptor() ([]byte, []int) + func (*InternalCreateSIPParticipantRequest) ProtoMessage() + func (x *InternalCreateSIPParticipantRequest) GetAddress() string + func (x *InternalCreateSIPParticipantRequest) GetAttributesToHeaders() map[string]string + func (x *InternalCreateSIPParticipantRequest) GetCallTo() string + func (x *InternalCreateSIPParticipantRequest) GetDtmf() string + func (x *InternalCreateSIPParticipantRequest) GetEnabledFeatures() []wirtual.SIPFeature + func (x *InternalCreateSIPParticipantRequest) GetHeaders() map[string]string + func (x *InternalCreateSIPParticipantRequest) GetHeadersToAttributes() map[string]string + func (x *InternalCreateSIPParticipantRequest) GetHostname() string + func (x *InternalCreateSIPParticipantRequest) GetIncludeHeaders() wirtual.SIPHeaderOptions + func (x *InternalCreateSIPParticipantRequest) GetMaxCallDuration() *durationpb.Duration + func (x *InternalCreateSIPParticipantRequest) GetMediaEncryption() wirtual.SIPMediaEncryption + func (x *InternalCreateSIPParticipantRequest) GetNumber() string + func (x *InternalCreateSIPParticipantRequest) GetParticipantAttributes() map[string]string + func (x *InternalCreateSIPParticipantRequest) GetParticipantIdentity() string + func (x *InternalCreateSIPParticipantRequest) GetParticipantMetadata() string + func (x *InternalCreateSIPParticipantRequest) GetParticipantName() string + func (x *InternalCreateSIPParticipantRequest) GetPassword() string + func (x *InternalCreateSIPParticipantRequest) GetPlayDialtone() bool + func (x *InternalCreateSIPParticipantRequest) GetProjectId() string + func (x *InternalCreateSIPParticipantRequest) GetRingingTimeout() *durationpb.Duration + func (x *InternalCreateSIPParticipantRequest) GetRoomName() string + func (x *InternalCreateSIPParticipantRequest) GetSipCallId() string + func (x *InternalCreateSIPParticipantRequest) GetSipTrunkId() string + func (x *InternalCreateSIPParticipantRequest) GetToken() string + func (x *InternalCreateSIPParticipantRequest) GetTransport() wirtual.SIPTransport + func (x *InternalCreateSIPParticipantRequest) GetUsername() string + func (x *InternalCreateSIPParticipantRequest) GetWsUrl() string + func (x *InternalCreateSIPParticipantRequest) ProtoReflect() protoreflect.Message + func (x *InternalCreateSIPParticipantRequest) Reset() + func (x *InternalCreateSIPParticipantRequest) String() string + type InternalCreateSIPParticipantResponse struct + ParticipantId string + ParticipantIdentity string + SipCallId string + func (*InternalCreateSIPParticipantResponse) Descriptor() ([]byte, []int) + func (*InternalCreateSIPParticipantResponse) ProtoMessage() + func (x *InternalCreateSIPParticipantResponse) GetParticipantId() string + func (x *InternalCreateSIPParticipantResponse) GetParticipantIdentity() string + func (x *InternalCreateSIPParticipantResponse) GetSipCallId() string + func (x *InternalCreateSIPParticipantResponse) ProtoReflect() protoreflect.Message + func (x *InternalCreateSIPParticipantResponse) Reset() + func (x *InternalCreateSIPParticipantResponse) String() string + type InternalTransferSIPParticipantRequest struct + Headers map[string]string + PlayDialtone bool + SipCallId string + TransferTo string + func NewTransferSIPParticipantRequest(callID string, req *wirtual.TransferSIPParticipantRequest) (*InternalTransferSIPParticipantRequest, error) + func (*InternalTransferSIPParticipantRequest) Descriptor() ([]byte, []int) + func (*InternalTransferSIPParticipantRequest) ProtoMessage() + func (x *InternalTransferSIPParticipantRequest) GetHeaders() map[string]string + func (x *InternalTransferSIPParticipantRequest) GetPlayDialtone() bool + 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 JobRequestResponse struct + State *wirtual.JobState + func (*JobRequestResponse) Descriptor() ([]byte, []int) + func (*JobRequestResponse) ProtoMessage() + func (x *JobRequestResponse) GetState() *wirtual.JobState + func (x *JobRequestResponse) ProtoReflect() protoreflect.Message + func (x *JobRequestResponse) Reset() + func (x *JobRequestResponse) String() string + type JobTerminateReason int32 + const JobTerminateReason_AGENT_LEFT_ROOM + const JobTerminateReason_TERMINATION_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 *wirtual.JobState + func (*JobTerminateResponse) Descriptor() ([]byte, []int) + func (*JobTerminateResponse) ProtoMessage() + func (x *JobTerminateResponse) GetState() *wirtual.JobState + func (x *JobTerminateResponse) ProtoReflect() protoreflect.Message + func (x *JobTerminateResponse) Reset() + func (x *JobTerminateResponse) String() string + type KeepaliveClient interface + Close func() + 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 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 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 + IngressSessions []*IngressSession + func (*ListActiveIngressResponse) Descriptor() ([]byte, []int) + func (*ListActiveIngressResponse) ProtoMessage() + func (x *ListActiveIngressResponse) GetIngressIds() []string + func (x *ListActiveIngressResponse) GetIngressSessions() []*IngressSession + func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveIngressResponse) Reset() + func (x *ListActiveIngressResponse) String() string + type PSRPCConfig struct + Backoff time.Duration + BufferSize int + MaxAttempts int + Timeout time.Duration + 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, bytes int) + 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 PSRPCMetricsOption func(*psrpcMetricsOptions) + func WithCurryLabels(labels prometheus.Labels) PSRPCMetricsOption + type ParticipantClient interface + Close func() + MutePublishedTrack func(ctx context.Context, participant ParticipantTopicType, ...) (*wirtual6.MuteRoomTrackResponse, error) + RemoveParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*wirtual6.RemoveParticipantResponse, error) + UpdateParticipant func(ctx context.Context, participant ParticipantTopicType, ...) (*wirtual1.ParticipantInfo, error) + UpdateSubscriptions func(ctx context.Context, participant ParticipantTopicType, ...) (*wirtual6.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, *wirtual6.MuteRoomTrackRequest) (*wirtual6.MuteRoomTrackResponse, error) + RemoveParticipant func(context.Context, *wirtual6.RoomParticipantIdentity) (*wirtual6.RemoveParticipantResponse, error) + UpdateParticipant func(context.Context, *wirtual6.UpdateParticipantRequest) (*wirtual1.ParticipantInfo, error) + UpdateSubscriptions func(context.Context, *wirtual6.UpdateSubscriptionsRequest) (*wirtual6.UpdateSubscriptionsResponse, error) + type ParticipantTopic string + func FormatParticipantTopic(roomName wirtual.RoomName, identity wirtual.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 []*wirtual.SignalRequest + Seq uint64 + StartSession *wirtual.StartSession + func (*RelaySignalRequest) Descriptor() ([]byte, []int) + func (*RelaySignalRequest) ProtoMessage() + func (x *RelaySignalRequest) GetClose() bool + func (x *RelaySignalRequest) GetRequests() []*wirtual.SignalRequest + func (x *RelaySignalRequest) GetSeq() uint64 + func (x *RelaySignalRequest) GetStartSession() *wirtual.StartSession + func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message + func (x *RelaySignalRequest) Reset() + func (x *RelaySignalRequest) String() string + type RelaySignalResponse struct + Close bool + Responses []*wirtual.SignalResponse + Seq uint64 + func (*RelaySignalResponse) Descriptor() ([]byte, []int) + func (*RelaySignalResponse) ProtoMessage() + func (x *RelaySignalResponse) GetClose() bool + func (x *RelaySignalResponse) GetResponses() []*wirtual.SignalResponse + func (x *RelaySignalResponse) GetSeq() uint64 + func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message + func (x *RelaySignalResponse) Reset() + func (x *RelaySignalResponse) String() string + type RoomClient interface + Close func() + DeleteRoom func(ctx context.Context, room RoomTopicType, req *wirtual6.DeleteRoomRequest, ...) (*wirtual6.DeleteRoomResponse, error) + SendData func(ctx context.Context, room RoomTopicType, req *wirtual6.SendDataRequest, ...) (*wirtual6.SendDataResponse, error) + UpdateRoomMetadata func(ctx context.Context, room RoomTopicType, ...) (*wirtual1.Room, error) + func NewRoomClient[RoomTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (RoomClient[RoomTopicType], error) + type RoomManagerClient interface + Close func() + CreateRoom func(ctx context.Context, nodeId NodeIdTopicType, req *wirtual6.CreateRoomRequest, ...) (*wirtual1.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, *wirtual6.CreateRoomRequest) (*wirtual1.Room, 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, *wirtual6.DeleteRoomRequest) (*wirtual6.DeleteRoomResponse, error) + SendData func(context.Context, *wirtual6.SendDataRequest) (*wirtual6.SendDataResponse, error) + UpdateRoomMetadata func(context.Context, *wirtual6.UpdateRoomMetadataRequest) (*wirtual1.Room, error) + type RoomTopic string + func FormatRoomTopic(roomName wirtual.RoomName) RoomTopic + type SIPClient interface + func NewSIPClient(bus psrpc.MessageBus) (SIPClient, 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 + type SIPInternalClient interface + Close func() + CreateSIPParticipant func(ctx context.Context, topic string, req *InternalCreateSIPParticipantRequest, ...) (*InternalCreateSIPParticipantResponse, error) + TransferSIPParticipant func(ctx context.Context, sipCallId string, ...) (*google_protobuf.Empty, error) + func NewSIPInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SIPInternalClient, error) + type SIPInternalServer interface + DeregisterCreateSIPParticipantTopic func(topic string) + DeregisterTransferSIPParticipantTopic func(sipCallId string) + Kill func() + RegisterCreateSIPParticipantTopic func(topic string) error + RegisterTransferSIPParticipantTopic func(sipCallId string) error + Shutdown func() + func NewSIPInternalServer(svc SIPInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SIPInternalServer, error) + type SIPInternalServerImpl interface + CreateSIPParticipant func(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error) + CreateSIPParticipantAffinity func(context.Context, *InternalCreateSIPParticipantRequest) float32 + TransferSIPParticipant func(context.Context, *InternalTransferSIPParticipantRequest) (*google_protobuf.Empty, error) + type SignalClient interface + Close func() + 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 + DeregisterAllNodeTopics func(nodeId NodeIdTopicType) + DeregisterRelaySignalTopic func(nodeId NodeIdTopicType) + Kill func() + RegisterAllNodeTopics func(nodeId NodeIdTopicType) error + 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 + CloudBackupEnabled bool + EgressId string + EstimatedCpu float64 + Request isStartEgressRequest_Request + RoomId string + Token string + WsUrl string + func (*StartEgressRequest) Descriptor() ([]byte, []int) + func (*StartEgressRequest) ProtoMessage() + func (x *StartEgressRequest) GetCloudBackupEnabled() bool + func (x *StartEgressRequest) GetEgressId() string + func (x *StartEgressRequest) GetEstimatedCpu() float64 + func (x *StartEgressRequest) GetParticipant() *wirtual.ParticipantEgressRequest + func (x *StartEgressRequest) GetRequest() isStartEgressRequest_Request + func (x *StartEgressRequest) GetRoomComposite() *wirtual.RoomCompositeEgressRequest + func (x *StartEgressRequest) GetRoomId() string + func (x *StartEgressRequest) GetToken() string + func (x *StartEgressRequest) GetTrack() *wirtual.TrackEgressRequest + func (x *StartEgressRequest) GetTrackComposite() *wirtual.TrackCompositeEgressRequest + func (x *StartEgressRequest) GetWeb() *wirtual.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 *wirtual.ParticipantEgressRequest + type StartEgressRequest_RoomComposite struct + RoomComposite *wirtual.RoomCompositeEgressRequest + type StartEgressRequest_Track struct + Track *wirtual.TrackEgressRequest + type StartEgressRequest_TrackComposite struct + TrackComposite *wirtual.TrackCompositeEgressRequest + type StartEgressRequest_Web struct + Web *wirtual.WebEgressRequest + type StartIngressRequest struct + Info *wirtual.IngressInfo + LoggingFields map[string]string + Token string + WsUrl string + func (*StartIngressRequest) Descriptor() ([]byte, []int) + func (*StartIngressRequest) ProtoMessage() + func (x *StartIngressRequest) GetInfo() *wirtual.IngressInfo + func (x *StartIngressRequest) GetLoggingFields() map[string]string + 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 wirtual.RoomName, ...) ParticipantTopic + RoomTopic func(ctx context.Context, roomName wirtual.RoomName) RoomTopic + func NewTopicFormatter() TopicFormatter + type TypedAgentDispatchInternalClient = AgentDispatchInternalClient[RoomTopic] + func NewTypedAgentDispatchInternalClient(params ClientParams) (TypedAgentDispatchInternalClient, error) + type TypedAgentDispatchInternalServer = AgentDispatchInternalServer[RoomTopic] + func NewTypedAgentDispatchInternalServer(svc AgentDispatchInternalServerImpl, bus psrpc.MessageBus, ...) (TypedAgentDispatchInternalServer, error) + 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 TypedRoomManagerClient = RoomManagerClient[wirtual.NodeID] + func NewTypedRoomManagerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedRoomManagerClient, error) + type TypedRoomManagerServer = RoomManagerServer[wirtual.NodeID] + func NewTypedRoomManagerServer(svc RoomManagerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomManagerServer, error) + type TypedRoomServer = RoomServer[RoomTopic] + func NewTypedRoomServer(svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomServer, error) + type TypedSignalClient = SignalClient[wirtual.NodeID] + func NewTypedSignalClient(nodeID wirtual.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error) + type TypedSignalServer = SignalServer[wirtual.NodeID] + func NewTypedSignalServer(nodeID wirtual.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, ...) (TypedSignalServer, error) + type UnimplementedAnalyticsRecorderServiceServer struct + func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents(grpc.ClientStreamingServer[wirtual.AnalyticsEvents, emptypb.Empty]) error + func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates(grpc.ClientStreamingServer[wirtual.AnalyticsNodeRooms, emptypb.Empty]) error + func (UnimplementedAnalyticsRecorderServiceServer) IngestStats(grpc.ClientStreamingServer[wirtual.AnalyticsStats, emptypb.Empty]) error + 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, bytes int) + 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, ...) + type UnsafeAnalyticsRecorderServiceServer interface + type UpdateIngressStateRequest struct + IngressId string + State *wirtual.IngressState + func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int) + func (*UpdateIngressStateRequest) ProtoMessage() + func (x *UpdateIngressStateRequest) GetIngressId() string + func (x *UpdateIngressStateRequest) GetState() *wirtual.IngressState + func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateIngressStateRequest) Reset() + func (x *UpdateIngressStateRequest) String() string + type UpdateMetricsRequest struct + AvgCpuUsage float32 + Info *wirtual.EgressInfo + MaxCpuUsage float32 + func (*UpdateMetricsRequest) Descriptor() ([]byte, []int) + func (*UpdateMetricsRequest) ProtoMessage() + func (x *UpdateMetricsRequest) GetAvgCpuUsage() float32 + func (x *UpdateMetricsRequest) GetInfo() *wirtual.EgressInfo + func (x *UpdateMetricsRequest) GetMaxCpuUsage() float32 + func (x *UpdateMetricsRequest) ProtoReflect() protoreflect.Message + func (x *UpdateMetricsRequest) Reset() + func (x *UpdateMetricsRequest) String() string + type UpdateSIPCallStateRequest struct + CallInfo *wirtual.SIPCallInfo + func (*UpdateSIPCallStateRequest) Descriptor() ([]byte, []int) + func (*UpdateSIPCallStateRequest) ProtoMessage() + func (x *UpdateSIPCallStateRequest) GetCallInfo() *wirtual.SIPCallInfo + func (x *UpdateSIPCallStateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateSIPCallStateRequest) Reset() + func (x *UpdateSIPCallStateRequest) String() string
Go to main page