Documentation ¶
Index ¶
- Variables
- func CurryMetricLabels(labels prometheus.Labels)
- func InitPSRPCStats(constLabels prometheus.Labels, opts ...PSRPCMetricsOption)
- func WithClientLogger(logger logger.Logger) psrpc.ClientOption
- func WithServerLogger(logger logger.Logger) psrpc.ServerOption
- type AgentInternalClient
- type AgentInternalServer
- type AgentInternalServerImpl
- type CheckEnabledRequest
- type CheckEnabledResponse
- func (*CheckEnabledResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckEnabledResponse) GetNamespaces() []string
- func (x *CheckEnabledResponse) GetPublisherEnabled() bool
- func (x *CheckEnabledResponse) GetRoomEnabled() bool
- func (*CheckEnabledResponse) ProtoMessage()
- func (x *CheckEnabledResponse) ProtoReflect() protoreflect.Message
- func (x *CheckEnabledResponse) Reset()
- func (x *CheckEnabledResponse) String() string
- type ClientParams
- type DeleteWHIPResourceRequest
- func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWHIPResourceRequest) GetResourceId() string
- func (x *DeleteWHIPResourceRequest) GetStreamKey() string
- func (*DeleteWHIPResourceRequest) ProtoMessage()
- func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteWHIPResourceRequest) Reset()
- func (x *DeleteWHIPResourceRequest) String() string
- type EgressClient
- type EgressHandlerClient
- type EgressHandlerServer
- type EgressHandlerServerImpl
- type EgressInternalClient
- type EgressInternalServer
- type EgressInternalServerImpl
- type EvaluateSIPDispatchRulesRequest
- func (*EvaluateSIPDispatchRulesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EvaluateSIPDispatchRulesRequest) GetCalledHost() string
- func (x *EvaluateSIPDispatchRulesRequest) GetCalledNumber() string
- func (x *EvaluateSIPDispatchRulesRequest) GetCallingNumber() string
- func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool
- func (x *EvaluateSIPDispatchRulesRequest) GetPin() string
- func (x *EvaluateSIPDispatchRulesRequest) GetSipParticipantId() string
- func (x *EvaluateSIPDispatchRulesRequest) GetSrcAddress() string
- func (*EvaluateSIPDispatchRulesRequest) ProtoMessage()
- func (x *EvaluateSIPDispatchRulesRequest) ProtoReflect() protoreflect.Message
- func (x *EvaluateSIPDispatchRulesRequest) Reset()
- func (x *EvaluateSIPDispatchRulesRequest) String() string
- type EvaluateSIPDispatchRulesResponse
- func (*EvaluateSIPDispatchRulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EvaluateSIPDispatchRulesResponse) GetParticipantIdentity() string
- func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() booldeprecated
- func (x *EvaluateSIPDispatchRulesResponse) GetResult() SIPDispatchResult
- func (x *EvaluateSIPDispatchRulesResponse) GetRoomName() string
- func (x *EvaluateSIPDispatchRulesResponse) GetToken() string
- func (x *EvaluateSIPDispatchRulesResponse) GetWsUrl() string
- func (*EvaluateSIPDispatchRulesResponse) ProtoMessage()
- func (x *EvaluateSIPDispatchRulesResponse) ProtoReflect() protoreflect.Message
- func (x *EvaluateSIPDispatchRulesResponse) Reset()
- func (x *EvaluateSIPDispatchRulesResponse) String() string
- type GetEgressRequest
- type GetIngressInfoRequest
- func (*GetIngressInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressInfoRequest) GetIngressId() string
- func (x *GetIngressInfoRequest) GetStreamKey() string
- func (*GetIngressInfoRequest) ProtoMessage()
- func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetIngressInfoRequest) Reset()
- func (x *GetIngressInfoRequest) String() string
- type GetIngressInfoResponse
- func (*GetIngressInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo
- func (x *GetIngressInfoResponse) GetLoggingFields() map[string]string
- func (x *GetIngressInfoResponse) GetToken() string
- func (x *GetIngressInfoResponse) GetWsUrl() string
- func (*GetIngressInfoResponse) ProtoMessage()
- func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetIngressInfoResponse) Reset()
- func (x *GetIngressInfoResponse) String() string
- type GetSIPTrunkAuthenticationRequest
- func (*GetSIPTrunkAuthenticationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSIPTrunkAuthenticationRequest) GetFrom() string
- func (x *GetSIPTrunkAuthenticationRequest) GetSrcAddress() string
- func (x *GetSIPTrunkAuthenticationRequest) GetTo() string
- func (x *GetSIPTrunkAuthenticationRequest) GetToHost() string
- func (*GetSIPTrunkAuthenticationRequest) ProtoMessage()
- func (x *GetSIPTrunkAuthenticationRequest) ProtoReflect() protoreflect.Message
- func (x *GetSIPTrunkAuthenticationRequest) Reset()
- func (x *GetSIPTrunkAuthenticationRequest) String() string
- type GetSIPTrunkAuthenticationResponse
- func (*GetSIPTrunkAuthenticationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSIPTrunkAuthenticationResponse) GetDrop() bool
- func (x *GetSIPTrunkAuthenticationResponse) GetPassword() string
- func (x *GetSIPTrunkAuthenticationResponse) GetUsername() string
- func (*GetSIPTrunkAuthenticationResponse) ProtoMessage()
- func (x *GetSIPTrunkAuthenticationResponse) ProtoReflect() protoreflect.Message
- func (x *GetSIPTrunkAuthenticationResponse) Reset()
- func (x *GetSIPTrunkAuthenticationResponse) String() string
- type IOInfoClient
- type IOInfoServer
- type IOInfoServerImpl
- type IngressClient
- type IngressHandlerClient
- type IngressHandlerServer
- type IngressHandlerServerImpl
- type IngressInternalClient
- type IngressInternalServer
- type IngressInternalServerImpl
- type InternalCreateSIPParticipantRequest
- func (*InternalCreateSIPParticipantRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InternalCreateSIPParticipantRequest) GetAddress() string
- func (x *InternalCreateSIPParticipantRequest) GetCallTo() string
- func (x *InternalCreateSIPParticipantRequest) GetDtmf() string
- func (x *InternalCreateSIPParticipantRequest) GetNumber() string
- func (x *InternalCreateSIPParticipantRequest) GetParticipantIdentity() string
- func (x *InternalCreateSIPParticipantRequest) GetPassword() string
- func (x *InternalCreateSIPParticipantRequest) GetPlayRingtone() bool
- func (x *InternalCreateSIPParticipantRequest) GetRoomName() string
- func (x *InternalCreateSIPParticipantRequest) GetToken() string
- func (x *InternalCreateSIPParticipantRequest) GetUsername() string
- func (x *InternalCreateSIPParticipantRequest) GetWsUrl() string
- func (*InternalCreateSIPParticipantRequest) ProtoMessage()
- func (x *InternalCreateSIPParticipantRequest) ProtoReflect() protoreflect.Message
- func (x *InternalCreateSIPParticipantRequest) Reset()
- func (x *InternalCreateSIPParticipantRequest) String() string
- type InternalCreateSIPParticipantResponse
- func (*InternalCreateSIPParticipantResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InternalCreateSIPParticipantResponse) GetParticipantId() string
- func (x *InternalCreateSIPParticipantResponse) GetParticipantIdentity() string
- func (*InternalCreateSIPParticipantResponse) ProtoMessage()
- func (x *InternalCreateSIPParticipantResponse) ProtoReflect() protoreflect.Message
- func (x *InternalCreateSIPParticipantResponse) Reset()
- func (x *InternalCreateSIPParticipantResponse) String() string
- type KeepaliveClient
- type KeepalivePing
- type KeepalivePubSub
- type KeepaliveServer
- type KeepaliveServerImpl
- type ListActiveEgressRequest
- type ListActiveEgressResponse
- func (*ListActiveEgressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActiveEgressResponse) GetEgressIds() []string
- func (*ListActiveEgressResponse) ProtoMessage()
- func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message
- func (x *ListActiveEgressResponse) Reset()
- func (x *ListActiveEgressResponse) String() string
- type ListActiveIngressRequest
- type ListActiveIngressResponse
- func (*ListActiveIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActiveIngressResponse) GetIngressIds() []string
- func (*ListActiveIngressResponse) ProtoMessage()
- func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message
- func (x *ListActiveIngressResponse) Reset()
- func (x *ListActiveIngressResponse) String() string
- type PSRPCConfig
- type PSRPCMetricsObserver
- 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 PSRPCMetricsOption
- type ParticipantClient
- type ParticipantServer
- type ParticipantServerImpl
- type ParticipantTopic
- type Race
- type RelaySignalRequest
- func (*RelaySignalRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RelaySignalRequest) GetClose() bool
- func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest
- func (x *RelaySignalRequest) GetSeq() uint64
- func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession
- func (*RelaySignalRequest) ProtoMessage()
- func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message
- func (x *RelaySignalRequest) Reset()
- func (x *RelaySignalRequest) String() string
- type RelaySignalResponse
- func (*RelaySignalResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RelaySignalResponse) GetClose() bool
- func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse
- func (x *RelaySignalResponse) GetSeq() uint64
- func (*RelaySignalResponse) ProtoMessage()
- func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message
- func (x *RelaySignalResponse) Reset()
- func (x *RelaySignalResponse) String() string
- type RoomClient
- type RoomServer
- type RoomServerImpl
- type RoomTopic
- type SIPClient
- type SIPDispatchResult
- func (SIPDispatchResult) Descriptor() protoreflect.EnumDescriptor
- func (x SIPDispatchResult) Enum() *SIPDispatchResult
- func (SIPDispatchResult) EnumDescriptor() ([]byte, []int)deprecated
- func (x SIPDispatchResult) Number() protoreflect.EnumNumber
- func (x SIPDispatchResult) String() string
- func (SIPDispatchResult) Type() protoreflect.EnumType
- type SIPInternalClient
- type SIPInternalServer
- type SIPInternalServerImpl
- type SignalClient
- type SignalServer
- type SignalServerImpl
- type StartEgressRequest
- func (*StartEgressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartEgressRequest) GetEgressId() string
- func (x *StartEgressRequest) GetParticipant() *livekit.ParticipantEgressRequest
- func (m *StartEgressRequest) GetRequest() isStartEgressRequest_Request
- 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 (*StartEgressRequest) ProtoMessage()
- func (x *StartEgressRequest) ProtoReflect() protoreflect.Message
- func (x *StartEgressRequest) Reset()
- func (x *StartEgressRequest) String() string
- type StartEgressRequest_Participant
- type StartEgressRequest_RoomComposite
- type StartEgressRequest_Track
- type StartEgressRequest_TrackComposite
- type StartEgressRequest_Web
- type StartIngressRequest
- func (*StartIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo
- func (x *StartIngressRequest) GetLoggingFields() map[string]string
- func (x *StartIngressRequest) GetToken() string
- func (x *StartIngressRequest) GetWsUrl() string
- func (*StartIngressRequest) ProtoMessage()
- func (x *StartIngressRequest) ProtoReflect() protoreflect.Message
- func (x *StartIngressRequest) Reset()
- func (x *StartIngressRequest) String() string
- type TopicFormatter
- type TypedParticipantClient
- type TypedParticipantServer
- type TypedRoomClient
- type TypedRoomServer
- type TypedSignalClient
- type TypedSignalServer
- type UnimplementedMetricsObserver
- 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, ...)
- type UpdateIngressStateRequest
- func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIngressStateRequest) GetIngressId() string
- func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState
- func (*UpdateIngressStateRequest) ProtoMessage()
- func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateIngressStateRequest) Reset()
- func (x *UpdateIngressStateRequest) String() string
- type UpdateMetricsRequest
- func (*UpdateMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMetricsRequest) GetAvgCpuUsage() float32
- func (x *UpdateMetricsRequest) GetInfo() *livekit.EgressInfo
- func (x *UpdateMetricsRequest) GetMaxCpuUsage() float32
- func (*UpdateMetricsRequest) ProtoMessage()
- func (x *UpdateMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMetricsRequest) Reset()
- func (x *UpdateMetricsRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( SIPDispatchResult_name = map[int32]string{ 0: "LEGACY_ACCEPT_OR_PIN", 1: "ACCEPT", 2: "REQUEST_PIN", 3: "REJECT", 4: "DROP", } SIPDispatchResult_value = map[string]int32{ "LEGACY_ACCEPT_OR_PIN": 0, "ACCEPT": 1, "REQUEST_PIN": 2, "REJECT": 3, "DROP": 4, } )
Enum value maps for SIPDispatchResult.
var DefaultPSRPCConfig = PSRPCConfig{ MaxAttempts: 3, Timeout: 3 * time.Second, Backoff: 2 * time.Second, BufferSize: 1000, }
var File_rpc_agent_proto protoreflect.FileDescriptor
var File_rpc_egress_proto protoreflect.FileDescriptor
var File_rpc_ingress_proto protoreflect.FileDescriptor
var File_rpc_io_proto protoreflect.FileDescriptor
var File_rpc_keepalive_proto protoreflect.FileDescriptor
var File_rpc_participant_proto protoreflect.FileDescriptor
var File_rpc_room_proto protoreflect.FileDescriptor
var File_rpc_signal_proto protoreflect.FileDescriptor
var File_rpc_sip_proto protoreflect.FileDescriptor
Functions ¶
func CurryMetricLabels ¶ added in v1.14.0
func CurryMetricLabels(labels prometheus.Labels)
func InitPSRPCStats ¶ added in v1.10.0
func InitPSRPCStats(constLabels prometheus.Labels, opts ...PSRPCMetricsOption)
func WithClientLogger ¶ added in v1.10.0
func WithClientLogger(logger logger.Logger) psrpc.ClientOption
func WithServerLogger ¶ added in v1.10.0
func WithServerLogger(logger logger.Logger) psrpc.ServerOption
Types ¶
type AgentInternalClient ¶ added in v1.9.1
type AgentInternalClient interface { CheckEnabled(ctx context.Context, req *CheckEnabledRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*CheckEnabledResponse], error) JobRequest(ctx context.Context, namespace string, jobType string, req *livekit1.Job, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) SubscribeWorkerRegistered(ctx context.Context, handlerNamespace string) (psrpc.Subscription[*google_protobuf.Empty], error) }
func NewAgentInternalClient ¶ added in v1.9.1
func NewAgentInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (AgentInternalClient, error)
NewAgentInternalClient creates a psrpc client that implements the AgentInternalClient interface.
type AgentInternalServer ¶ added in v1.9.1
type AgentInternalServer interface { RegisterJobRequestTopic(namespace string, jobType string) error DeregisterJobRequestTopic(namespace string, jobType string) PublishWorkerRegistered(ctx context.Context, handlerNamespace string, msg *google_protobuf.Empty) error // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewAgentInternalServer ¶ added in v1.9.1
func NewAgentInternalServer(svc AgentInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (AgentInternalServer, error)
NewAgentInternalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type AgentInternalServerImpl ¶ added in v1.9.1
type CheckEnabledRequest ¶ added in v1.9.1
type CheckEnabledRequest struct {
// contains filtered or unexported fields
}
func (*CheckEnabledRequest) Descriptor
deprecated
added in
v1.9.1
func (*CheckEnabledRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckEnabledRequest.ProtoReflect.Descriptor instead.
func (*CheckEnabledRequest) ProtoMessage ¶ added in v1.9.1
func (*CheckEnabledRequest) ProtoMessage()
func (*CheckEnabledRequest) ProtoReflect ¶ added in v1.9.1
func (x *CheckEnabledRequest) ProtoReflect() protoreflect.Message
func (*CheckEnabledRequest) Reset ¶ added in v1.9.1
func (x *CheckEnabledRequest) Reset()
func (*CheckEnabledRequest) String ¶ added in v1.9.1
func (x *CheckEnabledRequest) String() string
type CheckEnabledResponse ¶ added in v1.9.1
type CheckEnabledResponse struct { RoomEnabled bool `protobuf:"varint,1,opt,name=room_enabled,json=roomEnabled,proto3" json:"room_enabled,omitempty"` PublisherEnabled bool `protobuf:"varint,2,opt,name=publisher_enabled,json=publisherEnabled,proto3" json:"publisher_enabled,omitempty"` Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"` // contains filtered or unexported fields }
func (*CheckEnabledResponse) Descriptor
deprecated
added in
v1.9.1
func (*CheckEnabledResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckEnabledResponse.ProtoReflect.Descriptor instead.
func (*CheckEnabledResponse) GetNamespaces ¶ added in v1.14.0
func (x *CheckEnabledResponse) GetNamespaces() []string
func (*CheckEnabledResponse) GetPublisherEnabled ¶ added in v1.9.1
func (x *CheckEnabledResponse) GetPublisherEnabled() bool
func (*CheckEnabledResponse) GetRoomEnabled ¶ added in v1.9.1
func (x *CheckEnabledResponse) GetRoomEnabled() bool
func (*CheckEnabledResponse) ProtoMessage ¶ added in v1.9.1
func (*CheckEnabledResponse) ProtoMessage()
func (*CheckEnabledResponse) ProtoReflect ¶ added in v1.9.1
func (x *CheckEnabledResponse) ProtoReflect() protoreflect.Message
func (*CheckEnabledResponse) Reset ¶ added in v1.9.1
func (x *CheckEnabledResponse) Reset()
func (*CheckEnabledResponse) String ¶ added in v1.9.1
func (x *CheckEnabledResponse) String() string
type ClientParams ¶ added in v1.9.0
type ClientParams struct { PSRPCConfig Bus psrpc.MessageBus Logger logger.Logger Observer middleware.MetricsObserver }
func NewClientParams ¶ added in v1.9.0
func NewClientParams( config PSRPCConfig, bus psrpc.MessageBus, logger logger.Logger, observer middleware.MetricsObserver, ) ClientParams
func (*ClientParams) Options ¶ added in v1.14.0
func (p *ClientParams) Options() []psrpc.ClientOption
type DeleteWHIPResourceRequest ¶ added in v1.5.6
type DeleteWHIPResourceRequest struct { ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` StreamKey string `protobuf:"bytes,2,opt,name=stream_key,json=streamKey,proto3" json:"stream_key,omitempty"` // contains filtered or unexported fields }
func (*DeleteWHIPResourceRequest) Descriptor
deprecated
added in
v1.5.6
func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWHIPResourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteWHIPResourceRequest) GetResourceId ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) GetResourceId() string
func (*DeleteWHIPResourceRequest) GetStreamKey ¶ added in v1.5.9
func (x *DeleteWHIPResourceRequest) GetStreamKey() string
func (*DeleteWHIPResourceRequest) ProtoMessage ¶ added in v1.5.6
func (*DeleteWHIPResourceRequest) ProtoMessage()
func (*DeleteWHIPResourceRequest) ProtoReflect ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message
func (*DeleteWHIPResourceRequest) Reset ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) Reset()
func (*DeleteWHIPResourceRequest) String ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) String() string
type EgressClient ¶
type EgressClient interface { EgressInternalClient EgressHandlerClient }
func NewEgressClient ¶
func NewEgressClient(params ClientParams) (EgressClient, error)
type EgressHandlerClient ¶
type EgressHandlerClient interface { UpdateStream(ctx context.Context, topic string, req *livekit2.UpdateStreamRequest, opts ...psrpc.RequestOption) (*livekit2.EgressInfo, error) StopEgress(ctx context.Context, topic string, req *livekit2.StopEgressRequest, opts ...psrpc.RequestOption) (*livekit2.EgressInfo, error) }
func NewEgressHandlerClient ¶
func NewEgressHandlerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressHandlerClient, error)
NewEgressHandlerClient creates a psrpc client that implements the EgressHandlerClient interface.
type EgressHandlerServer ¶
type EgressHandlerServer interface { RegisterUpdateStreamTopic(topic string) error DeregisterUpdateStreamTopic(topic string) RegisterStopEgressTopic(topic string) error DeregisterStopEgressTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewEgressHandlerServer ¶
func NewEgressHandlerServer(svc EgressHandlerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (EgressHandlerServer, error)
NewEgressHandlerServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type EgressHandlerServerImpl ¶
type EgressHandlerServerImpl interface { UpdateStream(context.Context, *livekit2.UpdateStreamRequest) (*livekit2.EgressInfo, error) StopEgress(context.Context, *livekit2.StopEgressRequest) (*livekit2.EgressInfo, error) }
type EgressInternalClient ¶
type EgressInternalClient interface { StartEgress(ctx context.Context, topic string, req *StartEgressRequest, opts ...psrpc.RequestOption) (*livekit2.EgressInfo, error) ListActiveEgress(ctx context.Context, topic string, req *ListActiveEgressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error) }
func NewEgressInternalClient ¶
func NewEgressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressInternalClient, error)
NewEgressInternalClient creates a psrpc client that implements the EgressInternalClient interface.
type EgressInternalServer ¶
type EgressInternalServer interface { RegisterStartEgressTopic(topic string) error DeregisterStartEgressTopic(topic string) RegisterListActiveEgressTopic(topic string) error DeregisterListActiveEgressTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewEgressInternalServer ¶
func NewEgressInternalServer(svc EgressInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (EgressInternalServer, error)
NewEgressInternalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type EgressInternalServerImpl ¶
type EgressInternalServerImpl interface { StartEgress(context.Context, *StartEgressRequest) (*livekit2.EgressInfo, error) StartEgressAffinity(context.Context, *StartEgressRequest) float32 ListActiveEgress(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) }
type EvaluateSIPDispatchRulesRequest ¶ added in v1.9.1
type EvaluateSIPDispatchRulesRequest struct { SipParticipantId string `protobuf:"bytes,1,opt,name=sip_participant_id,json=sipParticipantId,proto3" json:"sip_participant_id,omitempty"` // What Number is calling CallingNumber string `protobuf:"bytes,2,opt,name=calling_number,json=callingNumber,proto3" json:"calling_number,omitempty"` // What Number was called CalledNumber string `protobuf:"bytes,3,opt,name=called_number,json=calledNumber,proto3" json:"called_number,omitempty"` // What is the IP address of the called number SrcAddress string `protobuf:"bytes,4,opt,name=src_address,json=srcAddress,proto3" json:"src_address,omitempty"` // What pin has been entered if any Pin string `protobuf:"bytes,5,opt,name=pin,proto3" json:"pin,omitempty"` // Caller rejected pin prompt, only try public rooms NoPin bool `protobuf:"varint,6,opt,name=no_pin,json=noPin,proto3" json:"no_pin,omitempty"` // What Host was called CalledHost string `protobuf:"bytes,7,opt,name=called_host,json=calledHost,proto3" json:"called_host,omitempty"` // contains filtered or unexported fields }
func (*EvaluateSIPDispatchRulesRequest) Descriptor
deprecated
added in
v1.9.1
func (*EvaluateSIPDispatchRulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use EvaluateSIPDispatchRulesRequest.ProtoReflect.Descriptor instead.
func (*EvaluateSIPDispatchRulesRequest) GetCalledHost ¶ added in v1.9.4
func (x *EvaluateSIPDispatchRulesRequest) GetCalledHost() string
func (*EvaluateSIPDispatchRulesRequest) GetCalledNumber ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) GetCalledNumber() string
func (*EvaluateSIPDispatchRulesRequest) GetCallingNumber ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) GetCallingNumber() string
func (*EvaluateSIPDispatchRulesRequest) GetNoPin ¶ added in v1.9.2
func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool
func (*EvaluateSIPDispatchRulesRequest) GetPin ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) GetPin() string
func (*EvaluateSIPDispatchRulesRequest) GetSipParticipantId ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) GetSipParticipantId() string
func (*EvaluateSIPDispatchRulesRequest) GetSrcAddress ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) GetSrcAddress() string
func (*EvaluateSIPDispatchRulesRequest) ProtoMessage ¶ added in v1.9.1
func (*EvaluateSIPDispatchRulesRequest) ProtoMessage()
func (*EvaluateSIPDispatchRulesRequest) ProtoReflect ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) ProtoReflect() protoreflect.Message
func (*EvaluateSIPDispatchRulesRequest) Reset ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) Reset()
func (*EvaluateSIPDispatchRulesRequest) String ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesRequest) String() string
type EvaluateSIPDispatchRulesResponse ¶ added in v1.9.1
type EvaluateSIPDispatchRulesResponse struct { // non-empty string if SIPParticipant should be placed a room RoomName string `protobuf:"bytes,1,opt,name=room_name,json=roomName,proto3" json:"room_name,omitempty"` // What should be used for the LiveKit identity ParticipantIdentity string `protobuf:"bytes,2,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"` // Deprecated: Marked as deprecated in rpc/io.proto. RequestPin bool `protobuf:"varint,3,opt,name=request_pin,json=requestPin,proto3" json:"request_pin,omitempty"` // see result // optional token that should be used when creating LiveKit participant Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"` // optional websocket url that should be used when creating LiveKit participant WsUrl string `protobuf:"bytes,5,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` Result SIPDispatchResult `protobuf:"varint,6,opt,name=result,proto3,enum=rpc.SIPDispatchResult" json:"result,omitempty"` // contains filtered or unexported fields }
func (*EvaluateSIPDispatchRulesResponse) Descriptor
deprecated
added in
v1.9.1
func (*EvaluateSIPDispatchRulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use EvaluateSIPDispatchRulesResponse.ProtoReflect.Descriptor instead.
func (*EvaluateSIPDispatchRulesResponse) GetParticipantIdentity ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) GetParticipantIdentity() string
func (*EvaluateSIPDispatchRulesResponse) GetRequestPin
deprecated
added in
v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() bool
Deprecated: Marked as deprecated in rpc/io.proto.
func (*EvaluateSIPDispatchRulesResponse) GetResult ¶ added in v1.9.9
func (x *EvaluateSIPDispatchRulesResponse) GetResult() SIPDispatchResult
func (*EvaluateSIPDispatchRulesResponse) GetRoomName ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) GetRoomName() string
func (*EvaluateSIPDispatchRulesResponse) GetToken ¶ added in v1.9.4
func (x *EvaluateSIPDispatchRulesResponse) GetToken() string
func (*EvaluateSIPDispatchRulesResponse) GetWsUrl ¶ added in v1.9.4
func (x *EvaluateSIPDispatchRulesResponse) GetWsUrl() string
func (*EvaluateSIPDispatchRulesResponse) ProtoMessage ¶ added in v1.9.1
func (*EvaluateSIPDispatchRulesResponse) ProtoMessage()
func (*EvaluateSIPDispatchRulesResponse) ProtoReflect ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) ProtoReflect() protoreflect.Message
func (*EvaluateSIPDispatchRulesResponse) Reset ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) Reset()
func (*EvaluateSIPDispatchRulesResponse) String ¶ added in v1.9.1
func (x *EvaluateSIPDispatchRulesResponse) String() string
type GetEgressRequest ¶ added in v1.8.1
type GetEgressRequest struct { EgressId string `protobuf:"bytes,1,opt,name=egress_id,json=egressId,proto3" json:"egress_id,omitempty"` // contains filtered or unexported fields }
func (*GetEgressRequest) Descriptor
deprecated
added in
v1.8.1
func (*GetEgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEgressRequest.ProtoReflect.Descriptor instead.
func (*GetEgressRequest) GetEgressId ¶ added in v1.8.1
func (x *GetEgressRequest) GetEgressId() string
func (*GetEgressRequest) ProtoMessage ¶ added in v1.8.1
func (*GetEgressRequest) ProtoMessage()
func (*GetEgressRequest) ProtoReflect ¶ added in v1.8.1
func (x *GetEgressRequest) ProtoReflect() protoreflect.Message
func (*GetEgressRequest) Reset ¶ added in v1.8.1
func (x *GetEgressRequest) Reset()
func (*GetEgressRequest) String ¶ added in v1.8.1
func (x *GetEgressRequest) String() string
type GetIngressInfoRequest ¶
type GetIngressInfoRequest struct { IngressId string `protobuf:"bytes,1,opt,name=ingress_id,json=ingressId,proto3" json:"ingress_id,omitempty"` StreamKey string `protobuf:"bytes,2,opt,name=stream_key,json=streamKey,proto3" json:"stream_key,omitempty"` // contains filtered or unexported fields }
Query an ingress info from an ingress ID or stream key
func (*GetIngressInfoRequest) Descriptor
deprecated
func (*GetIngressInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIngressInfoRequest.ProtoReflect.Descriptor instead.
func (*GetIngressInfoRequest) GetIngressId ¶
func (x *GetIngressInfoRequest) GetIngressId() string
func (*GetIngressInfoRequest) GetStreamKey ¶
func (x *GetIngressInfoRequest) GetStreamKey() string
func (*GetIngressInfoRequest) ProtoMessage ¶
func (*GetIngressInfoRequest) ProtoMessage()
func (*GetIngressInfoRequest) ProtoReflect ¶
func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message
func (*GetIngressInfoRequest) Reset ¶
func (x *GetIngressInfoRequest) Reset()
func (*GetIngressInfoRequest) String ¶
func (x *GetIngressInfoRequest) String() string
type GetIngressInfoResponse ¶
type GetIngressInfoResponse struct { Info *livekit.IngressInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,3,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` LoggingFields map[string]string `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetIngressInfoResponse) Descriptor
deprecated
func (*GetIngressInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIngressInfoResponse.ProtoReflect.Descriptor instead.
func (*GetIngressInfoResponse) GetInfo ¶
func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo
func (*GetIngressInfoResponse) GetLoggingFields ¶ added in v1.9.8
func (x *GetIngressInfoResponse) GetLoggingFields() map[string]string
func (*GetIngressInfoResponse) GetToken ¶
func (x *GetIngressInfoResponse) GetToken() string
func (*GetIngressInfoResponse) GetWsUrl ¶
func (x *GetIngressInfoResponse) GetWsUrl() string
func (*GetIngressInfoResponse) ProtoMessage ¶
func (*GetIngressInfoResponse) ProtoMessage()
func (*GetIngressInfoResponse) ProtoReflect ¶
func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message
func (*GetIngressInfoResponse) Reset ¶
func (x *GetIngressInfoResponse) Reset()
func (*GetIngressInfoResponse) String ¶
func (x *GetIngressInfoResponse) String() string
type GetSIPTrunkAuthenticationRequest ¶ added in v1.9.1
type GetSIPTrunkAuthenticationRequest struct { // What Number is calling From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` // What Number was called To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"` // What is the IP address of the called number SrcAddress string `protobuf:"bytes,4,opt,name=src_address,json=srcAddress,proto3" json:"src_address,omitempty"` // What Host was called ToHost string `protobuf:"bytes,5,opt,name=to_host,json=toHost,proto3" json:"to_host,omitempty"` // contains filtered or unexported fields }
func (*GetSIPTrunkAuthenticationRequest) Descriptor
deprecated
added in
v1.9.1
func (*GetSIPTrunkAuthenticationRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSIPTrunkAuthenticationRequest.ProtoReflect.Descriptor instead.
func (*GetSIPTrunkAuthenticationRequest) GetFrom ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) GetFrom() string
func (*GetSIPTrunkAuthenticationRequest) GetSrcAddress ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) GetSrcAddress() string
func (*GetSIPTrunkAuthenticationRequest) GetTo ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) GetTo() string
func (*GetSIPTrunkAuthenticationRequest) GetToHost ¶ added in v1.9.4
func (x *GetSIPTrunkAuthenticationRequest) GetToHost() string
func (*GetSIPTrunkAuthenticationRequest) ProtoMessage ¶ added in v1.9.1
func (*GetSIPTrunkAuthenticationRequest) ProtoMessage()
func (*GetSIPTrunkAuthenticationRequest) ProtoReflect ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) ProtoReflect() protoreflect.Message
func (*GetSIPTrunkAuthenticationRequest) Reset ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) Reset()
func (*GetSIPTrunkAuthenticationRequest) String ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationRequest) String() string
type GetSIPTrunkAuthenticationResponse ¶ added in v1.9.1
type GetSIPTrunkAuthenticationResponse struct { // Expected username and password Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` Drop bool `protobuf:"varint,3,opt,name=drop,proto3" json:"drop,omitempty"` // contains filtered or unexported fields }
func (*GetSIPTrunkAuthenticationResponse) Descriptor
deprecated
added in
v1.9.1
func (*GetSIPTrunkAuthenticationResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSIPTrunkAuthenticationResponse.ProtoReflect.Descriptor instead.
func (*GetSIPTrunkAuthenticationResponse) GetDrop ¶ added in v1.9.9
func (x *GetSIPTrunkAuthenticationResponse) GetDrop() bool
func (*GetSIPTrunkAuthenticationResponse) GetPassword ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationResponse) GetPassword() string
func (*GetSIPTrunkAuthenticationResponse) GetUsername ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationResponse) GetUsername() string
func (*GetSIPTrunkAuthenticationResponse) ProtoMessage ¶ added in v1.9.1
func (*GetSIPTrunkAuthenticationResponse) ProtoMessage()
func (*GetSIPTrunkAuthenticationResponse) ProtoReflect ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationResponse) ProtoReflect() protoreflect.Message
func (*GetSIPTrunkAuthenticationResponse) Reset ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationResponse) Reset()
func (*GetSIPTrunkAuthenticationResponse) String ¶ added in v1.9.1
func (x *GetSIPTrunkAuthenticationResponse) String() string
type IOInfoClient ¶
type IOInfoClient interface { // egress CreateEgress(ctx context.Context, req *livekit2.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) UpdateEgress(ctx context.Context, req *livekit2.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) GetEgress(ctx context.Context, req *GetEgressRequest, opts ...psrpc.RequestOption) (*livekit2.EgressInfo, error) ListEgress(ctx context.Context, req *livekit2.ListEgressRequest, opts ...psrpc.RequestOption) (*livekit2.ListEgressResponse, error) UpdateMetrics(ctx context.Context, req *UpdateMetricsRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) // ingress CreateIngress(ctx context.Context, req *livekit3.IngressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) GetIngressInfo(ctx context.Context, req *GetIngressInfoRequest, opts ...psrpc.RequestOption) (*GetIngressInfoResponse, error) UpdateIngressState(ctx context.Context, req *UpdateIngressStateRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) // sip GetSIPTrunkAuthentication(ctx context.Context, req *GetSIPTrunkAuthenticationRequest, opts ...psrpc.RequestOption) (*GetSIPTrunkAuthenticationResponse, error) EvaluateSIPDispatchRules(ctx context.Context, req *EvaluateSIPDispatchRulesRequest, opts ...psrpc.RequestOption) (*EvaluateSIPDispatchRulesResponse, error) }
func NewIOInfoClient ¶
func NewIOInfoClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IOInfoClient, error)
NewIOInfoClient creates a psrpc client that implements the IOInfoClient interface.
type IOInfoServer ¶
type IOInfoServer interface { // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewIOInfoServer ¶
func NewIOInfoServer(svc IOInfoServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (IOInfoServer, error)
NewIOInfoServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type IOInfoServerImpl ¶
type IOInfoServerImpl interface { // egress CreateEgress(context.Context, *livekit2.EgressInfo) (*google_protobuf.Empty, error) UpdateEgress(context.Context, *livekit2.EgressInfo) (*google_protobuf.Empty, error) GetEgress(context.Context, *GetEgressRequest) (*livekit2.EgressInfo, error) ListEgress(context.Context, *livekit2.ListEgressRequest) (*livekit2.ListEgressResponse, error) UpdateMetrics(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error) // ingress CreateIngress(context.Context, *livekit3.IngressInfo) (*google_protobuf.Empty, error) GetIngressInfo(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*google_protobuf.Empty, error) // sip GetSIPTrunkAuthentication(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error) EvaluateSIPDispatchRules(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error) }
type IngressClient ¶
type IngressClient interface { IngressInternalClient IngressHandlerClient }
func NewIngressClient ¶
func NewIngressClient(params ClientParams) (IngressClient, error)
type IngressHandlerClient ¶
type IngressHandlerClient interface { UpdateIngress(ctx context.Context, topic string, req *livekit3.UpdateIngressRequest, opts ...psrpc.RequestOption) (*livekit3.IngressState, error) DeleteIngress(ctx context.Context, topic string, req *livekit3.DeleteIngressRequest, opts ...psrpc.RequestOption) (*livekit3.IngressState, error) DeleteWHIPResource(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error) }
func NewIngressHandlerClient ¶
func NewIngressHandlerClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error)
NewIngressHandlerClient creates a psrpc client that implements the IngressHandlerClient interface.
type IngressHandlerServer ¶
type IngressHandlerServer interface { RegisterUpdateIngressTopic(topic string) error DeregisterUpdateIngressTopic(topic string) RegisterDeleteIngressTopic(topic string) error DeregisterDeleteIngressTopic(topic string) RegisterDeleteWHIPResourceTopic(topic string) error DeregisterDeleteWHIPResourceTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewIngressHandlerServer ¶
func NewIngressHandlerServer(svc IngressHandlerServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (IngressHandlerServer, error)
NewIngressHandlerServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type IngressHandlerServerImpl ¶
type IngressHandlerServerImpl interface { UpdateIngress(context.Context, *livekit3.UpdateIngressRequest) (*livekit3.IngressState, error) DeleteIngress(context.Context, *livekit3.DeleteIngressRequest) (*livekit3.IngressState, error) DeleteWHIPResource(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error) }
type IngressInternalClient ¶
type IngressInternalClient interface { StartIngress(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*livekit3.IngressInfo, error) ListActiveIngress(ctx context.Context, topic string, req *ListActiveIngressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveIngressResponse], error) }
func NewIngressInternalClient ¶
func NewIngressInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error)
NewIngressInternalClient creates a psrpc client that implements the IngressInternalClient interface.
type IngressInternalServer ¶
type IngressInternalServer interface { RegisterListActiveIngressTopic(topic string) error DeregisterListActiveIngressTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewIngressInternalServer ¶
func NewIngressInternalServer(svc IngressInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (IngressInternalServer, error)
NewIngressInternalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type IngressInternalServerImpl ¶
type IngressInternalServerImpl interface { StartIngress(context.Context, *StartIngressRequest) (*livekit3.IngressInfo, error) StartIngressAffinity(context.Context, *StartIngressRequest) float32 ListActiveIngress(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) }
type InternalCreateSIPParticipantRequest ¶ added in v1.9.5
type InternalCreateSIPParticipantRequest struct { // IP that SIP INVITE is sent too Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // Number used to make the call Number string `protobuf:"bytes,3,opt,name=number,proto3" json:"number,omitempty"` // Number to call to CallTo string `protobuf:"bytes,4,opt,name=call_to,json=callTo,proto3" json:"call_to,omitempty"` Username string `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"` RoomName string `protobuf:"bytes,7,opt,name=room_name,json=roomName,proto3" json:"room_name,omitempty"` ParticipantIdentity string `protobuf:"bytes,8,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"` // optional token that should be used when creating LiveKit participant Token string `protobuf:"bytes,9,opt,name=token,proto3" json:"token,omitempty"` // optional websocket url that should be used when creating LiveKit participant WsUrl string `protobuf:"bytes,10,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` // Optionally send following DTMF digits (extension codes) when making a call. // Character 'w' can be used to add a 0.5 sec delay. Dtmf string `protobuf:"bytes,11,opt,name=dtmf,proto3" json:"dtmf,omitempty"` // Optionally play ringtone in the room as an audible indicator for existing participants PlayRingtone bool `protobuf:"varint,12,opt,name=play_ringtone,json=playRingtone,proto3" json:"play_ringtone,omitempty"` // contains filtered or unexported fields }
func (*InternalCreateSIPParticipantRequest) Descriptor
deprecated
added in
v1.9.5
func (*InternalCreateSIPParticipantRequest) Descriptor() ([]byte, []int)
Deprecated: Use InternalCreateSIPParticipantRequest.ProtoReflect.Descriptor instead.
func (*InternalCreateSIPParticipantRequest) GetAddress ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetAddress() string
func (*InternalCreateSIPParticipantRequest) GetCallTo ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetCallTo() string
func (*InternalCreateSIPParticipantRequest) GetDtmf ¶ added in v1.12.0
func (x *InternalCreateSIPParticipantRequest) GetDtmf() string
func (*InternalCreateSIPParticipantRequest) GetNumber ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetNumber() string
func (*InternalCreateSIPParticipantRequest) GetParticipantIdentity ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetParticipantIdentity() string
func (*InternalCreateSIPParticipantRequest) GetPassword ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetPassword() string
func (*InternalCreateSIPParticipantRequest) GetPlayRingtone ¶ added in v1.14.0
func (x *InternalCreateSIPParticipantRequest) GetPlayRingtone() bool
func (*InternalCreateSIPParticipantRequest) GetRoomName ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetRoomName() string
func (*InternalCreateSIPParticipantRequest) GetToken ¶ added in v1.9.8
func (x *InternalCreateSIPParticipantRequest) GetToken() string
func (*InternalCreateSIPParticipantRequest) GetUsername ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) GetUsername() string
func (*InternalCreateSIPParticipantRequest) GetWsUrl ¶ added in v1.9.8
func (x *InternalCreateSIPParticipantRequest) GetWsUrl() string
func (*InternalCreateSIPParticipantRequest) ProtoMessage ¶ added in v1.9.5
func (*InternalCreateSIPParticipantRequest) ProtoMessage()
func (*InternalCreateSIPParticipantRequest) ProtoReflect ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) ProtoReflect() protoreflect.Message
func (*InternalCreateSIPParticipantRequest) Reset ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) Reset()
func (*InternalCreateSIPParticipantRequest) String ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantRequest) String() string
type InternalCreateSIPParticipantResponse ¶ added in v1.9.5
type InternalCreateSIPParticipantResponse struct { ParticipantId string `protobuf:"bytes,1,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"` ParticipantIdentity string `protobuf:"bytes,2,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"` // contains filtered or unexported fields }
func (*InternalCreateSIPParticipantResponse) Descriptor
deprecated
added in
v1.9.5
func (*InternalCreateSIPParticipantResponse) Descriptor() ([]byte, []int)
Deprecated: Use InternalCreateSIPParticipantResponse.ProtoReflect.Descriptor instead.
func (*InternalCreateSIPParticipantResponse) GetParticipantId ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantResponse) GetParticipantId() string
func (*InternalCreateSIPParticipantResponse) GetParticipantIdentity ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantResponse) GetParticipantIdentity() string
func (*InternalCreateSIPParticipantResponse) ProtoMessage ¶ added in v1.9.5
func (*InternalCreateSIPParticipantResponse) ProtoMessage()
func (*InternalCreateSIPParticipantResponse) ProtoReflect ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantResponse) ProtoReflect() protoreflect.Message
func (*InternalCreateSIPParticipantResponse) Reset ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantResponse) Reset()
func (*InternalCreateSIPParticipantResponse) String ¶ added in v1.9.5
func (x *InternalCreateSIPParticipantResponse) String() string
type KeepaliveClient ¶ added in v1.9.5
type KeepaliveClient[NodeIDTopicType ~string] interface { SubscribePing(ctx context.Context, nodeID NodeIDTopicType) (psrpc.Subscription[*KeepalivePing], error) }
func NewKeepaliveClient ¶ added in v1.9.5
func NewKeepaliveClient[NodeIDTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (KeepaliveClient[NodeIDTopicType], error)
NewKeepaliveClient creates a psrpc client that implements the KeepaliveClient interface.
type KeepalivePing ¶ added in v1.9.5
type KeepalivePing struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*KeepalivePing) Descriptor
deprecated
added in
v1.9.5
func (*KeepalivePing) Descriptor() ([]byte, []int)
Deprecated: Use KeepalivePing.ProtoReflect.Descriptor instead.
func (*KeepalivePing) GetTimestamp ¶ added in v1.9.5
func (x *KeepalivePing) GetTimestamp() int64
func (*KeepalivePing) ProtoMessage ¶ added in v1.9.5
func (*KeepalivePing) ProtoMessage()
func (*KeepalivePing) ProtoReflect ¶ added in v1.9.5
func (x *KeepalivePing) ProtoReflect() protoreflect.Message
func (*KeepalivePing) Reset ¶ added in v1.9.5
func (x *KeepalivePing) Reset()
func (*KeepalivePing) String ¶ added in v1.9.5
func (x *KeepalivePing) String() string
type KeepalivePubSub ¶ added in v1.9.5
type KeepalivePubSub interface { KeepaliveClient[livekit.NodeID] KeepaliveServer[livekit.NodeID] }
func NewKeepalivePubSub ¶ added in v1.9.5
func NewKeepalivePubSub(params ClientParams) (KeepalivePubSub, error)
type KeepaliveServer ¶ added in v1.9.5
type KeepaliveServer[NodeIDTopicType ~string] interface { PublishPing(ctx context.Context, nodeID NodeIDTopicType, msg *KeepalivePing) error // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewKeepaliveServer ¶ added in v1.9.5
func NewKeepaliveServer[NodeIDTopicType ~string](svc KeepaliveServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (KeepaliveServer[NodeIDTopicType], error)
NewKeepaliveServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type KeepaliveServerImpl ¶ added in v1.9.5
type KeepaliveServerImpl interface { }
type ListActiveEgressRequest ¶
type ListActiveEgressRequest struct {
// contains filtered or unexported fields
}
func (*ListActiveEgressRequest) Descriptor
deprecated
func (*ListActiveEgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveEgressRequest.ProtoReflect.Descriptor instead.
func (*ListActiveEgressRequest) ProtoMessage ¶
func (*ListActiveEgressRequest) ProtoMessage()
func (*ListActiveEgressRequest) ProtoReflect ¶
func (x *ListActiveEgressRequest) ProtoReflect() protoreflect.Message
func (*ListActiveEgressRequest) Reset ¶
func (x *ListActiveEgressRequest) Reset()
func (*ListActiveEgressRequest) String ¶
func (x *ListActiveEgressRequest) String() string
type ListActiveEgressResponse ¶
type ListActiveEgressResponse struct { EgressIds []string `protobuf:"bytes,1,rep,name=egress_ids,json=egressIds,proto3" json:"egress_ids,omitempty"` // contains filtered or unexported fields }
func (*ListActiveEgressResponse) Descriptor
deprecated
func (*ListActiveEgressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveEgressResponse.ProtoReflect.Descriptor instead.
func (*ListActiveEgressResponse) GetEgressIds ¶
func (x *ListActiveEgressResponse) GetEgressIds() []string
func (*ListActiveEgressResponse) ProtoMessage ¶
func (*ListActiveEgressResponse) ProtoMessage()
func (*ListActiveEgressResponse) ProtoReflect ¶
func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message
func (*ListActiveEgressResponse) Reset ¶
func (x *ListActiveEgressResponse) Reset()
func (*ListActiveEgressResponse) String ¶
func (x *ListActiveEgressResponse) String() string
type ListActiveIngressRequest ¶
type ListActiveIngressRequest struct {
// contains filtered or unexported fields
}
func (*ListActiveIngressRequest) Descriptor
deprecated
func (*ListActiveIngressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveIngressRequest.ProtoReflect.Descriptor instead.
func (*ListActiveIngressRequest) ProtoMessage ¶
func (*ListActiveIngressRequest) ProtoMessage()
func (*ListActiveIngressRequest) ProtoReflect ¶
func (x *ListActiveIngressRequest) ProtoReflect() protoreflect.Message
func (*ListActiveIngressRequest) Reset ¶
func (x *ListActiveIngressRequest) Reset()
func (*ListActiveIngressRequest) String ¶
func (x *ListActiveIngressRequest) String() string
type ListActiveIngressResponse ¶
type ListActiveIngressResponse struct { IngressIds []string `protobuf:"bytes,1,rep,name=ingress_ids,json=ingressIds,proto3" json:"ingress_ids,omitempty"` // contains filtered or unexported fields }
func (*ListActiveIngressResponse) Descriptor
deprecated
func (*ListActiveIngressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveIngressResponse.ProtoReflect.Descriptor instead.
func (*ListActiveIngressResponse) GetIngressIds ¶
func (x *ListActiveIngressResponse) GetIngressIds() []string
func (*ListActiveIngressResponse) ProtoMessage ¶
func (*ListActiveIngressResponse) ProtoMessage()
func (*ListActiveIngressResponse) ProtoReflect ¶
func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message
func (*ListActiveIngressResponse) Reset ¶
func (x *ListActiveIngressResponse) Reset()
func (*ListActiveIngressResponse) String ¶
func (x *ListActiveIngressResponse) String() string
type PSRPCConfig ¶ added in v1.9.0
type PSRPCMetricsObserver ¶ added in v1.10.0
type PSRPCMetricsObserver struct{}
func (PSRPCMetricsObserver) OnMultiRequest ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnMultiRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, responseCount int, errorCount int)
func (PSRPCMetricsObserver) OnStreamClose ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnStreamClose(role middleware.MetricRole, info psrpc.RPCInfo)
func (PSRPCMetricsObserver) OnStreamOpen ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnStreamOpen(role middleware.MetricRole, info psrpc.RPCInfo)
func (PSRPCMetricsObserver) OnStreamRecv ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnStreamRecv(role middleware.MetricRole, info psrpc.RPCInfo, err error)
func (PSRPCMetricsObserver) OnStreamSend ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnStreamSend(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)
func (PSRPCMetricsObserver) OnUnaryRequest ¶ added in v1.10.0
func (o PSRPCMetricsObserver) OnUnaryRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)
type PSRPCMetricsOption ¶ added in v1.14.0
type PSRPCMetricsOption func(*psrpcMetricsOptions)
func WithCurryLabels ¶ added in v1.14.0
func WithCurryLabels(labels prometheus.Labels) PSRPCMetricsOption
type ParticipantClient ¶ added in v1.9.0
type ParticipantClient[ParticipantTopicType ~string] interface { RemoveParticipant(ctx context.Context, participant ParticipantTopicType, req *livekit4.RoomParticipantIdentity, opts ...psrpc.RequestOption) (*livekit4.RemoveParticipantResponse, error) MutePublishedTrack(ctx context.Context, participant ParticipantTopicType, req *livekit4.MuteRoomTrackRequest, opts ...psrpc.RequestOption) (*livekit4.MuteRoomTrackResponse, error) UpdateParticipant(ctx context.Context, participant ParticipantTopicType, req *livekit4.UpdateParticipantRequest, opts ...psrpc.RequestOption) (*livekit.ParticipantInfo, error) UpdateSubscriptions(ctx context.Context, participant ParticipantTopicType, req *livekit4.UpdateSubscriptionsRequest, opts ...psrpc.RequestOption) (*livekit4.UpdateSubscriptionsResponse, error) }
func NewParticipantClient ¶ added in v1.9.0
func NewParticipantClient[ParticipantTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (ParticipantClient[ParticipantTopicType], error)
NewParticipantClient creates a psrpc client that implements the ParticipantClient interface.
type ParticipantServer ¶ added in v1.9.0
type ParticipantServer[ParticipantTopicType ~string] interface { RegisterRemoveParticipantTopic(participant ParticipantTopicType) error DeregisterRemoveParticipantTopic(participant ParticipantTopicType) RegisterMutePublishedTrackTopic(participant ParticipantTopicType) error DeregisterMutePublishedTrackTopic(participant ParticipantTopicType) RegisterUpdateParticipantTopic(participant ParticipantTopicType) error DeregisterUpdateParticipantTopic(participant ParticipantTopicType) RegisterUpdateSubscriptionsTopic(participant ParticipantTopicType) error DeregisterUpdateSubscriptionsTopic(participant ParticipantTopicType) RegisterAllParticipantTopics(participant ParticipantTopicType) error DeregisterAllParticipantTopics(participant ParticipantTopicType) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewParticipantServer ¶ added in v1.9.0
func NewParticipantServer[ParticipantTopicType ~string](svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (ParticipantServer[ParticipantTopicType], error)
NewParticipantServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type ParticipantServerImpl ¶ added in v1.9.0
type ParticipantServerImpl interface { RemoveParticipant(context.Context, *livekit4.RoomParticipantIdentity) (*livekit4.RemoveParticipantResponse, error) MutePublishedTrack(context.Context, *livekit4.MuteRoomTrackRequest) (*livekit4.MuteRoomTrackResponse, error) UpdateParticipant(context.Context, *livekit4.UpdateParticipantRequest) (*livekit.ParticipantInfo, error) UpdateSubscriptions(context.Context, *livekit4.UpdateSubscriptionsRequest) (*livekit4.UpdateSubscriptionsResponse, error) }
type ParticipantTopic ¶ added in v1.8.1
type ParticipantTopic string
func FormatParticipantTopic ¶ added in v1.8.1
func FormatParticipantTopic(roomName livekit.RoomName, identity livekit.ParticipantIdentity) ParticipantTopic
type Race ¶
type Race[T any] struct { // contains filtered or unexported fields }
type RelaySignalRequest ¶ added in v1.4.3
type RelaySignalRequest struct { StartSession *livekit.StartSession `protobuf:"bytes,1,opt,name=start_session,json=startSession,proto3" json:"start_session,omitempty"` Requests []*livekit.SignalRequest `protobuf:"bytes,3,rep,name=requests,proto3" json:"requests,omitempty"` Seq uint64 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"` Close bool `protobuf:"varint,5,opt,name=close,proto3" json:"close,omitempty"` // contains filtered or unexported fields }
func (*RelaySignalRequest) Descriptor
deprecated
added in
v1.4.3
func (*RelaySignalRequest) Descriptor() ([]byte, []int)
Deprecated: Use RelaySignalRequest.ProtoReflect.Descriptor instead.
func (*RelaySignalRequest) GetClose ¶ added in v1.5.6
func (x *RelaySignalRequest) GetClose() bool
func (*RelaySignalRequest) GetRequests ¶ added in v1.5.3
func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest
func (*RelaySignalRequest) GetSeq ¶ added in v1.5.3
func (x *RelaySignalRequest) GetSeq() uint64
func (*RelaySignalRequest) GetStartSession ¶ added in v1.4.3
func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession
func (*RelaySignalRequest) ProtoMessage ¶ added in v1.4.3
func (*RelaySignalRequest) ProtoMessage()
func (*RelaySignalRequest) ProtoReflect ¶ added in v1.4.3
func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message
func (*RelaySignalRequest) Reset ¶ added in v1.4.3
func (x *RelaySignalRequest) Reset()
func (*RelaySignalRequest) String ¶ added in v1.4.3
func (x *RelaySignalRequest) String() string
type RelaySignalResponse ¶ added in v1.4.3
type RelaySignalResponse struct { Responses []*livekit.SignalResponse `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"` Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"` Close bool `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"` // contains filtered or unexported fields }
func (*RelaySignalResponse) Descriptor
deprecated
added in
v1.4.3
func (*RelaySignalResponse) Descriptor() ([]byte, []int)
Deprecated: Use RelaySignalResponse.ProtoReflect.Descriptor instead.
func (*RelaySignalResponse) GetClose ¶ added in v1.5.6
func (x *RelaySignalResponse) GetClose() bool
func (*RelaySignalResponse) GetResponses ¶ added in v1.5.2
func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse
func (*RelaySignalResponse) GetSeq ¶ added in v1.5.3
func (x *RelaySignalResponse) GetSeq() uint64
func (*RelaySignalResponse) ProtoMessage ¶ added in v1.4.3
func (*RelaySignalResponse) ProtoMessage()
func (*RelaySignalResponse) ProtoReflect ¶ added in v1.4.3
func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message
func (*RelaySignalResponse) Reset ¶ added in v1.4.3
func (x *RelaySignalResponse) Reset()
func (*RelaySignalResponse) String ¶ added in v1.4.3
func (x *RelaySignalResponse) String() string
type RoomClient ¶ added in v1.8.1
type RoomClient[RoomTopicType ~string] interface { DeleteRoom(ctx context.Context, room RoomTopicType, req *livekit4.DeleteRoomRequest, opts ...psrpc.RequestOption) (*livekit4.DeleteRoomResponse, error) SendData(ctx context.Context, room RoomTopicType, req *livekit4.SendDataRequest, opts ...psrpc.RequestOption) (*livekit4.SendDataResponse, error) UpdateRoomMetadata(ctx context.Context, room RoomTopicType, req *livekit4.UpdateRoomMetadataRequest, opts ...psrpc.RequestOption) (*livekit.Room, error) }
func NewRoomClient ¶ added in v1.8.1
func NewRoomClient[RoomTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (RoomClient[RoomTopicType], error)
NewRoomClient creates a psrpc client that implements the RoomClient interface.
type RoomServer ¶ added in v1.8.1
type RoomServer[RoomTopicType ~string] interface { RegisterDeleteRoomTopic(room RoomTopicType) error DeregisterDeleteRoomTopic(room RoomTopicType) RegisterSendDataTopic(room RoomTopicType) error DeregisterSendDataTopic(room RoomTopicType) RegisterUpdateRoomMetadataTopic(room RoomTopicType) error DeregisterUpdateRoomMetadataTopic(room RoomTopicType) RegisterAllRoomTopics(room RoomTopicType) error DeregisterAllRoomTopics(room RoomTopicType) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewRoomServer ¶ added in v1.8.1
func NewRoomServer[RoomTopicType ~string](svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (RoomServer[RoomTopicType], error)
NewRoomServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type RoomServerImpl ¶ added in v1.8.1
type RoomServerImpl interface { DeleteRoom(context.Context, *livekit4.DeleteRoomRequest) (*livekit4.DeleteRoomResponse, error) SendData(context.Context, *livekit4.SendDataRequest) (*livekit4.SendDataResponse, error) UpdateRoomMetadata(context.Context, *livekit4.UpdateRoomMetadataRequest) (*livekit.Room, error) }
type SIPClient ¶ added in v1.9.1
type SIPClient interface { SIPInternalClient }
func NewSIPClient ¶ added in v1.9.1
func NewSIPClient(bus psrpc.MessageBus) (SIPClient, error)
type SIPDispatchResult ¶ added in v1.9.9
type SIPDispatchResult int32
const ( SIPDispatchResult_LEGACY_ACCEPT_OR_PIN SIPDispatchResult = 0 // check request_pin field SIPDispatchResult_ACCEPT SIPDispatchResult = 1 SIPDispatchResult_REQUEST_PIN SIPDispatchResult = 2 SIPDispatchResult_REJECT SIPDispatchResult = 3 SIPDispatchResult_DROP SIPDispatchResult = 4 )
func (SIPDispatchResult) Descriptor ¶ added in v1.9.9
func (SIPDispatchResult) Descriptor() protoreflect.EnumDescriptor
func (SIPDispatchResult) Enum ¶ added in v1.9.9
func (x SIPDispatchResult) Enum() *SIPDispatchResult
func (SIPDispatchResult) EnumDescriptor
deprecated
added in
v1.9.9
func (SIPDispatchResult) EnumDescriptor() ([]byte, []int)
Deprecated: Use SIPDispatchResult.Descriptor instead.
func (SIPDispatchResult) Number ¶ added in v1.9.9
func (x SIPDispatchResult) Number() protoreflect.EnumNumber
func (SIPDispatchResult) String ¶ added in v1.9.9
func (x SIPDispatchResult) String() string
func (SIPDispatchResult) Type ¶ added in v1.9.9
func (SIPDispatchResult) Type() protoreflect.EnumType
type SIPInternalClient ¶ added in v1.9.1
type SIPInternalClient interface {
CreateSIPParticipant(ctx context.Context, topic string, req *InternalCreateSIPParticipantRequest, opts ...psrpc.RequestOption) (*InternalCreateSIPParticipantResponse, error)
}
func NewSIPInternalClient ¶ added in v1.9.1
func NewSIPInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SIPInternalClient, error)
NewSIPInternalClient creates a psrpc client that implements the SIPInternalClient interface.
type SIPInternalServer ¶ added in v1.9.1
type SIPInternalServer interface { RegisterCreateSIPParticipantTopic(topic string) error DeregisterCreateSIPParticipantTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewSIPInternalServer ¶ added in v1.9.1
func NewSIPInternalServer(svc SIPInternalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SIPInternalServer, error)
NewSIPInternalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type SIPInternalServerImpl ¶ added in v1.9.1
type SIPInternalServerImpl interface { CreateSIPParticipant(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error) CreateSIPParticipantAffinity(context.Context, *InternalCreateSIPParticipantRequest) float32 }
type SignalClient ¶ added in v1.4.3
type SignalClient[NodeIdTopicType ~string] interface { RelaySignal(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error) }
func NewSignalClient ¶ added in v1.4.3
func NewSignalClient[NodeIdTopicType ~string](bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SignalClient[NodeIdTopicType], error)
NewSignalClient creates a psrpc client that implements the SignalClient interface.
type SignalServer ¶ added in v1.4.3
type SignalServer[NodeIdTopicType ~string] interface { RegisterRelaySignalTopic(nodeId NodeIdTopicType) error DeregisterRelaySignalTopic(nodeId NodeIdTopicType) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewSignalServer ¶ added in v1.4.3
func NewSignalServer[NodeIdTopicType ~string](svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SignalServer[NodeIdTopicType], error)
NewSignalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type SignalServerImpl ¶ added in v1.4.3
type SignalServerImpl interface {
RelaySignal(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error
}
type StartEgressRequest ¶
type StartEgressRequest struct { // request metadata EgressId string `protobuf:"bytes,1,opt,name=egress_id,json=egressId,proto3" json:"egress_id,omitempty"` // request // // Types that are assignable to Request: // // *StartEgressRequest_RoomComposite // *StartEgressRequest_Web // *StartEgressRequest_Participant // *StartEgressRequest_TrackComposite // *StartEgressRequest_Track Request isStartEgressRequest_Request `protobuf_oneof:"request"` // connection info RoomId string `protobuf:"bytes,3,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` Token string `protobuf:"bytes,8,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,9,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` // contains filtered or unexported fields }
func (*StartEgressRequest) Descriptor
deprecated
func (*StartEgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartEgressRequest.ProtoReflect.Descriptor instead.
func (*StartEgressRequest) GetEgressId ¶
func (x *StartEgressRequest) GetEgressId() string
func (*StartEgressRequest) GetParticipant ¶ added in v1.7.0
func (x *StartEgressRequest) GetParticipant() *livekit.ParticipantEgressRequest
func (*StartEgressRequest) GetRequest ¶
func (m *StartEgressRequest) GetRequest() isStartEgressRequest_Request
func (*StartEgressRequest) GetRoomComposite ¶
func (x *StartEgressRequest) GetRoomComposite() *livekit.RoomCompositeEgressRequest
func (*StartEgressRequest) GetRoomId ¶
func (x *StartEgressRequest) GetRoomId() string
func (*StartEgressRequest) GetToken ¶
func (x *StartEgressRequest) GetToken() string
func (*StartEgressRequest) GetTrack ¶
func (x *StartEgressRequest) GetTrack() *livekit.TrackEgressRequest
func (*StartEgressRequest) GetTrackComposite ¶
func (x *StartEgressRequest) GetTrackComposite() *livekit.TrackCompositeEgressRequest
func (*StartEgressRequest) GetWeb ¶
func (x *StartEgressRequest) GetWeb() *livekit.WebEgressRequest
func (*StartEgressRequest) GetWsUrl ¶
func (x *StartEgressRequest) GetWsUrl() string
func (*StartEgressRequest) ProtoMessage ¶
func (*StartEgressRequest) ProtoMessage()
func (*StartEgressRequest) ProtoReflect ¶
func (x *StartEgressRequest) ProtoReflect() protoreflect.Message
func (*StartEgressRequest) Reset ¶
func (x *StartEgressRequest) Reset()
func (*StartEgressRequest) String ¶
func (x *StartEgressRequest) String() string
type StartEgressRequest_Participant ¶ added in v1.7.0
type StartEgressRequest_Participant struct {
Participant *livekit.ParticipantEgressRequest `protobuf:"bytes,13,opt,name=participant,proto3,oneof"`
}
type StartEgressRequest_RoomComposite ¶
type StartEgressRequest_RoomComposite struct {
RoomComposite *livekit.RoomCompositeEgressRequest `protobuf:"bytes,5,opt,name=room_composite,json=roomComposite,proto3,oneof"`
}
type StartEgressRequest_Track ¶
type StartEgressRequest_Track struct {
Track *livekit.TrackEgressRequest `protobuf:"bytes,7,opt,name=track,proto3,oneof"`
}
type StartEgressRequest_TrackComposite ¶
type StartEgressRequest_TrackComposite struct {
TrackComposite *livekit.TrackCompositeEgressRequest `protobuf:"bytes,6,opt,name=track_composite,json=trackComposite,proto3,oneof"`
}
type StartEgressRequest_Web ¶
type StartEgressRequest_Web struct {
Web *livekit.WebEgressRequest `protobuf:"bytes,11,opt,name=web,proto3,oneof"`
}
type StartIngressRequest ¶ added in v1.6.0
type StartIngressRequest struct { Info *livekit.IngressInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,3,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` LoggingFields map[string]string `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StartIngressRequest) Descriptor
deprecated
added in
v1.6.0
func (*StartIngressRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartIngressRequest.ProtoReflect.Descriptor instead.
func (*StartIngressRequest) GetInfo ¶ added in v1.6.0
func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo
func (*StartIngressRequest) GetLoggingFields ¶ added in v1.9.8
func (x *StartIngressRequest) GetLoggingFields() map[string]string
func (*StartIngressRequest) GetToken ¶ added in v1.6.0
func (x *StartIngressRequest) GetToken() string
func (*StartIngressRequest) GetWsUrl ¶ added in v1.6.0
func (x *StartIngressRequest) GetWsUrl() string
func (*StartIngressRequest) ProtoMessage ¶ added in v1.6.0
func (*StartIngressRequest) ProtoMessage()
func (*StartIngressRequest) ProtoReflect ¶ added in v1.6.0
func (x *StartIngressRequest) ProtoReflect() protoreflect.Message
func (*StartIngressRequest) Reset ¶ added in v1.6.0
func (x *StartIngressRequest) Reset()
func (*StartIngressRequest) String ¶ added in v1.6.0
func (x *StartIngressRequest) String() string
type TopicFormatter ¶ added in v1.8.1
type TopicFormatter interface { ParticipantTopic(ctx context.Context, roomName livekit.RoomName, identity livekit.ParticipantIdentity) ParticipantTopic RoomTopic(ctx context.Context, roomName livekit.RoomName) RoomTopic }
func NewTopicFormatter ¶ added in v1.9.0
func NewTopicFormatter() TopicFormatter
type TypedParticipantClient ¶ added in v1.9.0
type TypedParticipantClient = ParticipantClient[ParticipantTopic]
func NewTypedParticipantClient ¶ added in v1.9.0
func NewTypedParticipantClient(params ClientParams) (TypedParticipantClient, error)
type TypedParticipantServer ¶ added in v1.9.0
type TypedParticipantServer = ParticipantServer[ParticipantTopic]
func NewTypedParticipantServer ¶ added in v1.9.0
func NewTypedParticipantServer(svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedParticipantServer, error)
type TypedRoomClient ¶ added in v1.8.1
type TypedRoomClient = RoomClient[RoomTopic]
func NewTypedRoomClient ¶ added in v1.8.1
func NewTypedRoomClient(params ClientParams) (TypedRoomClient, error)
type TypedRoomServer ¶ added in v1.8.1
type TypedRoomServer = RoomServer[RoomTopic]
func NewTypedRoomServer ¶ added in v1.8.1
func NewTypedRoomServer(svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomServer, error)
type TypedSignalClient ¶ added in v1.4.3
type TypedSignalClient = SignalClient[livekit.NodeID]
func NewTypedSignalClient ¶ added in v1.4.3
func NewTypedSignalClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error)
type TypedSignalServer ¶ added in v1.4.3
type TypedSignalServer = SignalServer[livekit.NodeID]
func NewTypedSignalServer ¶ added in v1.4.3
func NewTypedSignalServer(nodeID livekit.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedSignalServer, error)
type UnimplementedMetricsObserver ¶ added in v1.10.0
type UnimplementedMetricsObserver struct{}
func (UnimplementedMetricsObserver) OnMultiRequest ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnMultiRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, responseCount int, errorCount int)
func (UnimplementedMetricsObserver) OnStreamClose ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnStreamClose(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)
func (UnimplementedMetricsObserver) OnStreamOpen ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnStreamOpen(role middleware.MetricRole, rpcInfo psrpc.RPCInfo)
func (UnimplementedMetricsObserver) OnStreamRecv ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnStreamRecv(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, err error)
func (UnimplementedMetricsObserver) OnStreamSend ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnStreamSend(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error)
func (UnimplementedMetricsObserver) OnUnaryRequest ¶ added in v1.10.0
func (o UnimplementedMetricsObserver) OnUnaryRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error)
type UpdateIngressStateRequest ¶
type UpdateIngressStateRequest struct { IngressId string `protobuf:"bytes,1,opt,name=ingress_id,json=ingressId,proto3" json:"ingress_id,omitempty"` State *livekit.IngressState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
Request to store an update to the ingress state ingress -> service
func (*UpdateIngressStateRequest) Descriptor
deprecated
func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateIngressStateRequest.ProtoReflect.Descriptor instead.
func (*UpdateIngressStateRequest) GetIngressId ¶
func (x *UpdateIngressStateRequest) GetIngressId() string
func (*UpdateIngressStateRequest) GetState ¶
func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState
func (*UpdateIngressStateRequest) ProtoMessage ¶
func (*UpdateIngressStateRequest) ProtoMessage()
func (*UpdateIngressStateRequest) ProtoReflect ¶
func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
func (*UpdateIngressStateRequest) Reset ¶
func (x *UpdateIngressStateRequest) Reset()
func (*UpdateIngressStateRequest) String ¶
func (x *UpdateIngressStateRequest) String() string
type UpdateMetricsRequest ¶ added in v1.9.4
type UpdateMetricsRequest struct { Info *livekit.EgressInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` AvgCpuUsage float32 `protobuf:"fixed32,3,opt,name=avg_cpu_usage,json=avgCpuUsage,proto3" json:"avg_cpu_usage,omitempty"` MaxCpuUsage float32 `protobuf:"fixed32,4,opt,name=max_cpu_usage,json=maxCpuUsage,proto3" json:"max_cpu_usage,omitempty"` // contains filtered or unexported fields }
func (*UpdateMetricsRequest) Descriptor
deprecated
added in
v1.9.4
func (*UpdateMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMetricsRequest.ProtoReflect.Descriptor instead.
func (*UpdateMetricsRequest) GetAvgCpuUsage ¶ added in v1.9.4
func (x *UpdateMetricsRequest) GetAvgCpuUsage() float32
func (*UpdateMetricsRequest) GetInfo ¶ added in v1.9.4
func (x *UpdateMetricsRequest) GetInfo() *livekit.EgressInfo
func (*UpdateMetricsRequest) GetMaxCpuUsage ¶ added in v1.9.4
func (x *UpdateMetricsRequest) GetMaxCpuUsage() float32
func (*UpdateMetricsRequest) ProtoMessage ¶ added in v1.9.4
func (*UpdateMetricsRequest) ProtoMessage()
func (*UpdateMetricsRequest) ProtoReflect ¶ added in v1.9.4
func (x *UpdateMetricsRequest) ProtoReflect() protoreflect.Message
func (*UpdateMetricsRequest) Reset ¶ added in v1.9.4
func (x *UpdateMetricsRequest) Reset()
func (*UpdateMetricsRequest) String ¶ added in v1.9.4
func (x *UpdateMetricsRequest) String() string
Source Files ¶
- agent.pb.go
- agent.psrpc.go
- egress.pb.go
- egress.psrpc.go
- egress_client.go
- ingress.pb.go
- ingress.psrpc.go
- ingress_client.go
- io.pb.go
- io.psrpc.go
- keepalive.pb.go
- keepalive.psrpc.go
- logging.go
- metrics.go
- participant.pb.go
- participant.psrpc.go
- race.go
- room.pb.go
- room.psrpc.go
- signal.pb.go
- signal.psrpc.go
- sip.pb.go
- sip.psrpc.go
- sip_client.go
- typed_api.go