rpc

package
v1.9.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 24 Imported by: 25

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultPSRPCConfig = PSRPCConfig{
	MaxAttempts: 3,
	Timeout:     3 * time.Second,
	Backoff:     2 * time.Second,
	BufferSize:  1000,
}
View Source 
var File_rpc_agent_proto protoreflect.FileDescriptor
View Source 
var File_rpc_egress_proto protoreflect.FileDescriptor
View Source 
var File_rpc_ingress_proto protoreflect.FileDescriptor
View Source 
var File_rpc_io_proto protoreflect.FileDescriptor
View Source 
var File_rpc_keepalive_proto protoreflect.FileDescriptor
View Source 
var File_rpc_participant_proto protoreflect.FileDescriptor
View Source 
var File_rpc_room_proto protoreflect.FileDescriptor
View Source 
var File_rpc_signal_proto protoreflect.FileDescriptor
View Source 
var File_rpc_sip_proto protoreflect.FileDescriptor

Functions

This section is empty.

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, topic string, req *livekit1.Job, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	SubscribeAgentRegistered(ctx context.Context, projectId string) (psrpc.Subscription[*CheckEnabledResponse], 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(topic string) error
	DeregisterJobRequestTopic(topic string)
	PublishAgentRegistered(ctx context.Context, projectId string, msg *CheckEnabledResponse) 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 AgentInternalServerImpl interface {
	CheckEnabled(context.Context, *CheckEnabledRequest) (*CheckEnabledResponse, error)

	JobRequest(context.Context, *livekit1.Job) (*google_protobuf.Empty, error)
	JobRequestAffinity(context.Context, *livekit1.Job) float32
}

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"`
	// 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) 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

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"`
	// Pin should be requested from SIPParticipant
	RequestPin bool `protobuf:"varint,3,opt,name=request_pin,json=requestPin,proto3" json:"request_pin,omitempty"`
	// 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"`
	// 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 added in v1.9.1 

func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() bool

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"`
	// 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) 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"`
	// 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) 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
	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
	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, 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 {

	// 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"`
	// 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) 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) GetRoomName added in v1.9.5 

func (x *InternalCreateSIPParticipantRequest) GetRoomName() string

func (*InternalCreateSIPParticipantRequest) GetUsername added in v1.9.5 

func (x *InternalCreateSIPParticipantRequest) GetUsername() 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 PSRPCConfig struct {
	MaxAttempts int           `yaml:"max_attempts,omitempty"`
	Timeout     time.Duration `yaml:"timeout,omitempty"`
	Backoff     time.Duration `yaml:"backoff,omitempty"`
	BufferSize  int           `yaml:"buffer_size,omitempty"`
}

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
}

func NewRace 

func NewRace[T any](ctx context.Context) *Race[T]

NewRace creates a race to yield the result from one or more candidate functions

func (*Race[T]) Go 

func (r *Race[T]) Go(fn func(ctx context.Context) (*T, error))

Go adds a candidate function to the race by running it in a new goroutine

func (*Race[T]) Wait 

func (r *Race[T]) Wait() (int, *T, error)

Wait awaits the first complete function and returns the index and results or -1 if the context is cancelled before any candidate finishes.

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 RoomTopic added in v1.8.1 

type RoomTopic string

func FormatRoomTopic added in v1.8.1 

func FormatRoomTopic(roomName livekit.RoomName) RoomTopic

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 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"`
	// metadata
	Metadata map[string]*anypb.Any `` /* 158-byte string literal not displayed */
	// 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) GetMetadata added in v1.5.10 

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

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"`
	// 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) 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 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

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.