rpc

package
v1.27.2 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AnalyticsRecorderService_IngestStats_FullMethodName          = "/livekit.AnalyticsRecorderService/IngestStats"
	AnalyticsRecorderService_IngestEvents_FullMethodName         = "/livekit.AnalyticsRecorderService/IngestEvents"
	AnalyticsRecorderService_IngestNodeRoomStates_FullMethodName = "/livekit.AnalyticsRecorderService/IngestNodeRoomStates"
)

Variables

View Source 
var (
	JobTerminateReason_name = map[int32]string{
		0: "TERMINATION_REQUESTED",
		1: "AGENT_LEFT_ROOM",
	}
	JobTerminateReason_value = map[string]int32{
		"TERMINATION_REQUESTED": 0,
		"AGENT_LEFT_ROOM":       1,
	}
)

Enum value maps for JobTerminateReason.

View Source 
var (
	SIPFeature_name = map[int32]string{
		0: "NONE",
		1: "KRISP_ENABLED",
	}
	SIPFeature_value = map[string]int32{
		"NONE":          0,
		"KRISP_ENABLED": 1,
	}
)

Enum value maps for SIPFeature.

View Source 
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.

View Source 
var AnalyticsRecorderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "livekit.AnalyticsRecorderService",
	HandlerType: (*AnalyticsRecorderServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "IngestStats",
			Handler:       _AnalyticsRecorderService_IngestStats_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "IngestEvents",
			Handler:       _AnalyticsRecorderService_IngestEvents_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "IngestNodeRoomStates",
			Handler:       _AnalyticsRecorderService_IngestNodeRoomStates_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/analytics.proto",
}

AnalyticsRecorderService_ServiceDesc is the grpc.ServiceDesc for AnalyticsRecorderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DefaultPSRPCConfig = PSRPCConfig{
	MaxAttempts: 3,
	Timeout:     3 * time.Second,
	Backoff:     2 * time.Second,
	BufferSize:  1000,
}
View Source 
var File_rpc_agent_dispatch_proto protoreflect.FileDescriptor
View Source 
var File_rpc_agent_proto protoreflect.FileDescriptor
View Source 
var File_rpc_analytics_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_roommanager_proto protoreflect.FileDescriptor
View Source 
var File_rpc_signal_proto protoreflect.FileDescriptor
View Source 
var File_rpc_sip_proto protoreflect.FileDescriptor

Functions

func CurryMetricLabels 

func CurryMetricLabels(labels prometheus.Labels)

func InitPSRPCStats 

func InitPSRPCStats(constLabels prometheus.Labels, opts ...PSRPCMetricsOption)

func RegisterAnalyticsRecorderServiceServer 

func RegisterAnalyticsRecorderServiceServer(s grpc.ServiceRegistrar, srv AnalyticsRecorderServiceServer)

func WithClientLogger 

func WithClientLogger(logger logger.Logger) psrpc.ClientOption

func WithDefaultServerOptions 

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

func WithServerLogger 

func WithServerLogger(logger logger.Logger) psrpc.ServerOption

func WithServerObservability 

func WithServerObservability(logger logger.Logger) psrpc.ServerOption

Types

type AgentDispatchInternalClient 

type AgentDispatchInternalClient[RoomTopicType ~string] interface {
	CreateDispatch(ctx context.Context, room RoomTopicType, req *livekit3.AgentDispatch, opts ...psrpc.RequestOption) (*livekit3.AgentDispatch, error)

	DeleteDispatch(ctx context.Context, room RoomTopicType, req *livekit3.DeleteAgentDispatchRequest, opts ...psrpc.RequestOption) (*livekit3.AgentDispatch, error)

	ListDispatch(ctx context.Context, room RoomTopicType, req *livekit3.ListAgentDispatchRequest, opts ...psrpc.RequestOption) (*livekit3.ListAgentDispatchResponse, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewAgentDispatchInternalClient 

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

NewAgentDispatchInternalClient creates a psrpc client that implements the AgentDispatchInternalClient interface.

type AgentDispatchInternalServer 

type AgentDispatchInternalServer[RoomTopicType ~string] interface {
	RegisterCreateDispatchTopic(room RoomTopicType) error
	DeregisterCreateDispatchTopic(room RoomTopicType)
	RegisterDeleteDispatchTopic(room RoomTopicType) error
	DeregisterDeleteDispatchTopic(room RoomTopicType)
	RegisterListDispatchTopic(room RoomTopicType) error
	DeregisterListDispatchTopic(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 NewAgentDispatchInternalServer 

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

NewAgentDispatchInternalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.

type AgentDispatchInternalServerImpl 

type AgentDispatchInternalServerImpl interface {
	CreateDispatch(context.Context, *livekit3.AgentDispatch) (*livekit3.AgentDispatch, error)

	DeleteDispatch(context.Context, *livekit3.DeleteAgentDispatchRequest) (*livekit3.AgentDispatch, error)

	ListDispatch(context.Context, *livekit3.ListAgentDispatchRequest) (*livekit3.ListAgentDispatchResponse, error)
}

type AgentInternalClient 

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 *livekit2.Job, opts ...psrpc.RequestOption) (*JobRequestResponse, error)

	JobTerminate(ctx context.Context, jobId string, req *JobTerminateRequest, opts ...psrpc.RequestOption) (*JobTerminateResponse, error)

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

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewAgentInternalClient 

func NewAgentInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (AgentInternalClient, error)

NewAgentInternalClient creates a psrpc client that implements the AgentInternalClient interface.

type AgentInternalServer 

type AgentInternalServer interface {
	RegisterJobRequestTopic(namespace string, jobType string) error
	DeregisterJobRequestTopic(namespace string, jobType string)
	RegisterJobTerminateTopic(jobId string) error
	DeregisterJobTerminateTopic(jobId 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 

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 

type AgentInternalServerImpl interface {
	CheckEnabled(context.Context, *CheckEnabledRequest) (*CheckEnabledResponse, error)

	JobRequest(context.Context, *livekit2.Job) (*JobRequestResponse, error)
	JobRequestAffinity(context.Context, *livekit2.Job) float32

	JobTerminate(context.Context, *JobTerminateRequest) (*JobTerminateResponse, error)
}

type AnalyticsRecorderServiceClient 

type AnalyticsRecorderServiceClient interface {
	IngestStats(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[livekit.AnalyticsStats, emptypb.Empty], error)
	IngestEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[livekit.AnalyticsEvents, emptypb.Empty], error)
	IngestNodeRoomStates(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[livekit.AnalyticsNodeRooms, emptypb.Empty], error)
}

AnalyticsRecorderServiceClient is the client API for AnalyticsRecorderService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAnalyticsRecorderServiceClient 

func NewAnalyticsRecorderServiceClient(cc grpc.ClientConnInterface) AnalyticsRecorderServiceClient

type AnalyticsRecorderServiceServer 

type AnalyticsRecorderServiceServer interface {
	IngestStats(grpc.ClientStreamingServer[livekit.AnalyticsStats, emptypb.Empty]) error
	IngestEvents(grpc.ClientStreamingServer[livekit.AnalyticsEvents, emptypb.Empty]) error
	IngestNodeRoomStates(grpc.ClientStreamingServer[livekit.AnalyticsNodeRooms, emptypb.Empty]) error
	// contains filtered or unexported methods
}

AnalyticsRecorderServiceServer is the server API for AnalyticsRecorderService service. All implementations must embed UnimplementedAnalyticsRecorderServiceServer for forward compatibility.

type AnalyticsRecorderService_IngestEventsClient 

type AnalyticsRecorderService_IngestEventsClient = grpc.ClientStreamingClient[livekit.AnalyticsEvents, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AnalyticsRecorderService_IngestEventsServer 

type AnalyticsRecorderService_IngestEventsServer = grpc.ClientStreamingServer[livekit.AnalyticsEvents, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AnalyticsRecorderService_IngestNodeRoomStatesClient 

type AnalyticsRecorderService_IngestNodeRoomStatesClient = grpc.ClientStreamingClient[livekit.AnalyticsNodeRooms, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AnalyticsRecorderService_IngestNodeRoomStatesServer 

type AnalyticsRecorderService_IngestNodeRoomStatesServer = grpc.ClientStreamingServer[livekit.AnalyticsNodeRooms, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AnalyticsRecorderService_IngestStatsClient 

type AnalyticsRecorderService_IngestStatsClient = grpc.ClientStreamingClient[livekit.AnalyticsStats, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type AnalyticsRecorderService_IngestStatsServer 

type AnalyticsRecorderService_IngestStatsServer = grpc.ClientStreamingServer[livekit.AnalyticsStats, emptypb.Empty]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CheckEnabledRequest 

type CheckEnabledRequest struct {
	// contains filtered or unexported fields
}

func (*CheckEnabledRequest) Descriptor deprecated 

func (*CheckEnabledRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckEnabledRequest.ProtoReflect.Descriptor instead.

func (*CheckEnabledRequest) ProtoMessage 

func (*CheckEnabledRequest) ProtoMessage()

func (*CheckEnabledRequest) ProtoReflect 

func (x *CheckEnabledRequest) ProtoReflect() protoreflect.Message

func (*CheckEnabledRequest) Reset 

func (x *CheckEnabledRequest) Reset()

func (*CheckEnabledRequest) String 

func (x *CheckEnabledRequest) String() string

type CheckEnabledResponse 

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"`
	// Deprecated: Marked as deprecated in rpc/agent.proto.
	Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	AgentNames []string `protobuf:"bytes,4,rep,name=agent_names,json=agentNames,proto3" json:"agent_names,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckEnabledResponse) Descriptor deprecated 

func (*CheckEnabledResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckEnabledResponse.ProtoReflect.Descriptor instead.

func (*CheckEnabledResponse) GetAgentNames 

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

func (*CheckEnabledResponse) GetNamespaces deprecated 

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

Deprecated: Marked as deprecated in rpc/agent.proto.

func (*CheckEnabledResponse) GetPublisherEnabled 

func (x *CheckEnabledResponse) GetPublisherEnabled() bool

func (*CheckEnabledResponse) GetRoomEnabled 

func (x *CheckEnabledResponse) GetRoomEnabled() bool

func (*CheckEnabledResponse) ProtoMessage 

func (*CheckEnabledResponse) ProtoMessage()

func (*CheckEnabledResponse) ProtoReflect 

func (x *CheckEnabledResponse) ProtoReflect() protoreflect.Message

func (*CheckEnabledResponse) Reset 

func (x *CheckEnabledResponse) Reset()

func (*CheckEnabledResponse) String 

func (x *CheckEnabledResponse) String() string

type ClientParams 

type ClientParams struct {
	PSRPCConfig
	Bus      psrpc.MessageBus
	Logger   logger.Logger
	Observer middleware.MetricsObserver
}

func NewClientParams 

func NewClientParams(
	config PSRPCConfig,
	bus psrpc.MessageBus,
	logger logger.Logger,
	observer middleware.MetricsObserver,
) ClientParams

func (*ClientParams) Args 

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

func (*ClientParams) Options 

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

type DeleteWHIPResourceRequest 

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 

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

Deprecated: Use DeleteWHIPResourceRequest.ProtoReflect.Descriptor instead.

func (*DeleteWHIPResourceRequest) GetResourceId 

func (x *DeleteWHIPResourceRequest) GetResourceId() string

func (*DeleteWHIPResourceRequest) GetStreamKey 

func (x *DeleteWHIPResourceRequest) GetStreamKey() string

func (*DeleteWHIPResourceRequest) ProtoMessage 

func (*DeleteWHIPResourceRequest) ProtoMessage()

func (*DeleteWHIPResourceRequest) ProtoReflect 

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

func (*DeleteWHIPResourceRequest) Reset 

func (x *DeleteWHIPResourceRequest) Reset()

func (*DeleteWHIPResourceRequest) String 

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 *livekit4.UpdateStreamRequest, opts ...psrpc.RequestOption) (*livekit4.EgressInfo, error)

	StopEgress(ctx context.Context, topic string, req *livekit4.StopEgressRequest, opts ...psrpc.RequestOption) (*livekit4.EgressInfo, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

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, *livekit4.UpdateStreamRequest) (*livekit4.EgressInfo, error)

	StopEgress(context.Context, *livekit4.StopEgressRequest) (*livekit4.EgressInfo, error)
}

type EgressInternalClient 

type EgressInternalClient interface {
	StartEgress(ctx context.Context, topic string, req *StartEgressRequest, opts ...psrpc.RequestOption) (*livekit4.EgressInfo, error)

	ListActiveEgress(ctx context.Context, topic string, req *ListActiveEgressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

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) (*livekit4.EgressInfo, error)
	StartEgressAffinity(context.Context, *StartEgressRequest) float32

	ListActiveEgress(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error)
}

type EvaluateSIPDispatchRulesRequest 

type EvaluateSIPDispatchRulesRequest struct {
	SipCallId string `protobuf:"bytes,8,opt,name=sip_call_id,json=sipCallId,proto3" json:"sip_call_id,omitempty"`
	// Deprecated: Marked as deprecated in rpc/io.proto.
	SipParticipantId string `protobuf:"bytes,1,opt,name=sip_participant_id,json=sipParticipantId,proto3" json:"sip_participant_id,omitempty"`
	// Trunk from the auth response, if any
	SipTrunkId string `protobuf:"bytes,10,opt,name=sip_trunk_id,json=sipTrunkId,proto3" json:"sip_trunk_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"`
	// Extra participant attributes added for this call.
	// Usually include provider-specific metadata.
	ExtraAttributes map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EvaluateSIPDispatchRulesRequest) Descriptor deprecated 

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

Deprecated: Use EvaluateSIPDispatchRulesRequest.ProtoReflect.Descriptor instead.

func (*EvaluateSIPDispatchRulesRequest) GetCalledHost 

func (x *EvaluateSIPDispatchRulesRequest) GetCalledHost() string

func (*EvaluateSIPDispatchRulesRequest) GetCalledNumber 

func (x *EvaluateSIPDispatchRulesRequest) GetCalledNumber() string

func (*EvaluateSIPDispatchRulesRequest) GetCallingNumber 

func (x *EvaluateSIPDispatchRulesRequest) GetCallingNumber() string

func (*EvaluateSIPDispatchRulesRequest) GetExtraAttributes 

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

func (*EvaluateSIPDispatchRulesRequest) GetNoPin 

func (x *EvaluateSIPDispatchRulesRequest) GetNoPin() bool

func (*EvaluateSIPDispatchRulesRequest) GetPin 

func (x *EvaluateSIPDispatchRulesRequest) GetPin() string

func (*EvaluateSIPDispatchRulesRequest) GetSipCallId 

func (x *EvaluateSIPDispatchRulesRequest) GetSipCallId() string

func (*EvaluateSIPDispatchRulesRequest) GetSipParticipantId deprecated 

func (x *EvaluateSIPDispatchRulesRequest) GetSipParticipantId() string

Deprecated: Marked as deprecated in rpc/io.proto.

func (*EvaluateSIPDispatchRulesRequest) GetSipTrunkId 

func (x *EvaluateSIPDispatchRulesRequest) GetSipTrunkId() string

func (*EvaluateSIPDispatchRulesRequest) GetSrcAddress 

func (x *EvaluateSIPDispatchRulesRequest) GetSrcAddress() string

func (*EvaluateSIPDispatchRulesRequest) ProtoMessage 

func (*EvaluateSIPDispatchRulesRequest) ProtoMessage()

func (*EvaluateSIPDispatchRulesRequest) ProtoReflect 

func (x *EvaluateSIPDispatchRulesRequest) ProtoReflect() protoreflect.Message

func (*EvaluateSIPDispatchRulesRequest) Reset 

func (x *EvaluateSIPDispatchRulesRequest) Reset()

func (*EvaluateSIPDispatchRulesRequest) String 

func (x *EvaluateSIPDispatchRulesRequest) String() string

type EvaluateSIPDispatchRulesResponse 

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 participant identity
	ParticipantIdentity string `protobuf:"bytes,2,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"`
	// What should be used for the LiveKit participant name
	ParticipantName string `protobuf:"bytes,7,opt,name=participant_name,json=participantName,proto3" json:"participant_name,omitempty"`
	// What should be used for the LiveKit participant metadata
	ParticipantMetadata string `protobuf:"bytes,8,opt,name=participant_metadata,json=participantMetadata,proto3" json:"participant_metadata,omitempty"`
	// What should be used for the LiveKit participant attributes
	ParticipantAttributes map[string]string `` /* 213-byte string literal not displayed */
	// 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"`
	// Trunk used to fulfill this request
	SipTrunkId string `protobuf:"bytes,9,opt,name=sip_trunk_id,json=sipTrunkId,proto3" json:"sip_trunk_id,omitempty"`
	// Dispatch Rule used to fulfill this request
	SipDispatchRuleId string `protobuf:"bytes,10,opt,name=sip_dispatch_rule_id,json=sipDispatchRuleId,proto3" json:"sip_dispatch_rule_id,omitempty"`
	// Used in Cloud only
	ProjectId string `protobuf:"bytes,12,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Include these SIP X-* headers in 200 OK response to INVITE.
	// These headers are included as-is and may help identify triggered LiveKit Dispatch Rule for the other SIP endpoint.
	Headers map[string]string `` /* 156-byte string literal not displayed */
	// Map SIP X-* headers from INVITE to SIP participant attributes.
	// Keys are the names of X-* headers and values are the names of attributes they will be mapped to.
	HeadersToAttributes map[string]string `` /* 209-byte string literal not displayed */
	EnabledFeatures     []SIPFeature      `` /* 135-byte string literal not displayed */
	// Max time for the caller to wait for track subscription.
	RingingTimeout *durationpb.Duration `protobuf:"bytes,16,opt,name=ringing_timeout,json=ringingTimeout,proto3" json:"ringing_timeout,omitempty"`
	// Max call duration.
	MaxCallDuration *durationpb.Duration `protobuf:"bytes,17,opt,name=max_call_duration,json=maxCallDuration,proto3" json:"max_call_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*EvaluateSIPDispatchRulesResponse) Descriptor deprecated 

func (*EvaluateSIPDispatchRulesResponse) Descriptor() ([]byte, []int)

Deprecated: Use EvaluateSIPDispatchRulesResponse.ProtoReflect.Descriptor instead.

func (*EvaluateSIPDispatchRulesResponse) GetEnabledFeatures 

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

func (*EvaluateSIPDispatchRulesResponse) GetHeaders 

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

func (*EvaluateSIPDispatchRulesResponse) GetHeadersToAttributes 

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

func (*EvaluateSIPDispatchRulesResponse) GetMaxCallDuration 

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

func (*EvaluateSIPDispatchRulesResponse) GetParticipantAttributes 

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

func (*EvaluateSIPDispatchRulesResponse) GetParticipantIdentity 

func (x *EvaluateSIPDispatchRulesResponse) GetParticipantIdentity() string

func (*EvaluateSIPDispatchRulesResponse) GetParticipantMetadata 

func (x *EvaluateSIPDispatchRulesResponse) GetParticipantMetadata() string

func (*EvaluateSIPDispatchRulesResponse) GetParticipantName 

func (x *EvaluateSIPDispatchRulesResponse) GetParticipantName() string

func (*EvaluateSIPDispatchRulesResponse) GetProjectId 

func (x *EvaluateSIPDispatchRulesResponse) GetProjectId() string

func (*EvaluateSIPDispatchRulesResponse) GetRequestPin deprecated 

func (x *EvaluateSIPDispatchRulesResponse) GetRequestPin() bool

Deprecated: Marked as deprecated in rpc/io.proto.

func (*EvaluateSIPDispatchRulesResponse) GetResult 

func (x *EvaluateSIPDispatchRulesResponse) GetResult() SIPDispatchResult

func (*EvaluateSIPDispatchRulesResponse) GetRingingTimeout 

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

func (*EvaluateSIPDispatchRulesResponse) GetRoomName 

func (x *EvaluateSIPDispatchRulesResponse) GetRoomName() string

func (*EvaluateSIPDispatchRulesResponse) GetSipDispatchRuleId 

func (x *EvaluateSIPDispatchRulesResponse) GetSipDispatchRuleId() string

func (*EvaluateSIPDispatchRulesResponse) GetSipTrunkId 

func (x *EvaluateSIPDispatchRulesResponse) GetSipTrunkId() string

func (*EvaluateSIPDispatchRulesResponse) GetToken 

func (x *EvaluateSIPDispatchRulesResponse) GetToken() string

func (*EvaluateSIPDispatchRulesResponse) GetWsUrl 

func (x *EvaluateSIPDispatchRulesResponse) GetWsUrl() string

func (*EvaluateSIPDispatchRulesResponse) ProtoMessage 

func (*EvaluateSIPDispatchRulesResponse) ProtoMessage()

func (*EvaluateSIPDispatchRulesResponse) ProtoReflect 

func (x *EvaluateSIPDispatchRulesResponse) ProtoReflect() protoreflect.Message

func (*EvaluateSIPDispatchRulesResponse) Reset 

func (x *EvaluateSIPDispatchRulesResponse) Reset()

func (*EvaluateSIPDispatchRulesResponse) String 

func (x *EvaluateSIPDispatchRulesResponse) String() string

type GetEgressRequest 

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 

func (*GetEgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEgressRequest.ProtoReflect.Descriptor instead.

func (*GetEgressRequest) GetEgressId 

func (x *GetEgressRequest) GetEgressId() string

func (*GetEgressRequest) ProtoMessage 

func (*GetEgressRequest) ProtoMessage()

func (*GetEgressRequest) ProtoReflect 

func (x *GetEgressRequest) ProtoReflect() protoreflect.Message

func (*GetEgressRequest) Reset 

func (x *GetEgressRequest) Reset()

func (*GetEgressRequest) String 

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 

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 

type GetSIPTrunkAuthenticationRequest struct {
	SipCallId string `protobuf:"bytes,6,opt,name=sip_call_id,json=sipCallId,proto3" json:"sip_call_id,omitempty"`
	// 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 

func (*GetSIPTrunkAuthenticationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSIPTrunkAuthenticationRequest.ProtoReflect.Descriptor instead.

func (*GetSIPTrunkAuthenticationRequest) GetFrom 

func (x *GetSIPTrunkAuthenticationRequest) GetFrom() string

func (*GetSIPTrunkAuthenticationRequest) GetSipCallId 

func (x *GetSIPTrunkAuthenticationRequest) GetSipCallId() string

func (*GetSIPTrunkAuthenticationRequest) GetSrcAddress 

func (x *GetSIPTrunkAuthenticationRequest) GetSrcAddress() string

func (*GetSIPTrunkAuthenticationRequest) GetTo 

func (x *GetSIPTrunkAuthenticationRequest) GetTo() string

func (*GetSIPTrunkAuthenticationRequest) GetToHost 

func (x *GetSIPTrunkAuthenticationRequest) GetToHost() string

func (*GetSIPTrunkAuthenticationRequest) ProtoMessage 

func (*GetSIPTrunkAuthenticationRequest) ProtoMessage()

func (*GetSIPTrunkAuthenticationRequest) ProtoReflect 

func (x *GetSIPTrunkAuthenticationRequest) ProtoReflect() protoreflect.Message

func (*GetSIPTrunkAuthenticationRequest) Reset 

func (x *GetSIPTrunkAuthenticationRequest) Reset()

func (*GetSIPTrunkAuthenticationRequest) String 

func (x *GetSIPTrunkAuthenticationRequest) String() string

type GetSIPTrunkAuthenticationResponse 

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"`
	// Trunk used to fulfill this request
	SipTrunkId string `protobuf:"bytes,4,opt,name=sip_trunk_id,json=sipTrunkId,proto3" json:"sip_trunk_id,omitempty"`
	// Used in Cloud only
	ProjectId string `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSIPTrunkAuthenticationResponse) Descriptor deprecated 

func (*GetSIPTrunkAuthenticationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSIPTrunkAuthenticationResponse.ProtoReflect.Descriptor instead.

func (*GetSIPTrunkAuthenticationResponse) GetDrop 

func (x *GetSIPTrunkAuthenticationResponse) GetDrop() bool

func (*GetSIPTrunkAuthenticationResponse) GetPassword 

func (x *GetSIPTrunkAuthenticationResponse) GetPassword() string

func (*GetSIPTrunkAuthenticationResponse) GetProjectId 

func (x *GetSIPTrunkAuthenticationResponse) GetProjectId() string

func (*GetSIPTrunkAuthenticationResponse) GetSipTrunkId 

func (x *GetSIPTrunkAuthenticationResponse) GetSipTrunkId() string

func (*GetSIPTrunkAuthenticationResponse) GetUsername 

func (x *GetSIPTrunkAuthenticationResponse) GetUsername() string

func (*GetSIPTrunkAuthenticationResponse) ProtoMessage 

func (*GetSIPTrunkAuthenticationResponse) ProtoMessage()

func (*GetSIPTrunkAuthenticationResponse) ProtoReflect 

func (x *GetSIPTrunkAuthenticationResponse) ProtoReflect() protoreflect.Message

func (*GetSIPTrunkAuthenticationResponse) Reset 

func (x *GetSIPTrunkAuthenticationResponse) Reset()

func (*GetSIPTrunkAuthenticationResponse) String 

func (x *GetSIPTrunkAuthenticationResponse) String() string

type ICERestartWHIPResourceRequest 

type ICERestartWHIPResourceRequest 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"`
	UserFragment string   `protobuf:"bytes,3,opt,name=user_fragment,json=userFragment,proto3" json:"user_fragment,omitempty"`
	Password     string   `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Candidates   []string `protobuf:"bytes,5,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*ICERestartWHIPResourceRequest) Descriptor deprecated 

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

Deprecated: Use ICERestartWHIPResourceRequest.ProtoReflect.Descriptor instead.

func (*ICERestartWHIPResourceRequest) GetCandidates 

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

func (*ICERestartWHIPResourceRequest) GetPassword 

func (x *ICERestartWHIPResourceRequest) GetPassword() string

func (*ICERestartWHIPResourceRequest) GetResourceId 

func (x *ICERestartWHIPResourceRequest) GetResourceId() string

func (*ICERestartWHIPResourceRequest) GetStreamKey 

func (x *ICERestartWHIPResourceRequest) GetStreamKey() string

func (*ICERestartWHIPResourceRequest) GetUserFragment 

func (x *ICERestartWHIPResourceRequest) GetUserFragment() string

func (*ICERestartWHIPResourceRequest) ProtoMessage 

func (*ICERestartWHIPResourceRequest) ProtoMessage()

func (*ICERestartWHIPResourceRequest) ProtoReflect 

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

func (*ICERestartWHIPResourceRequest) Reset 

func (x *ICERestartWHIPResourceRequest) Reset()

func (*ICERestartWHIPResourceRequest) String 

func (x *ICERestartWHIPResourceRequest) String() string

type ICERestartWHIPResourceResponse 

type ICERestartWHIPResourceResponse struct {
	TrickleIceSdpfrag string `protobuf:"bytes,1,opt,name=trickle_ice_sdpfrag,json=trickleIceSdpfrag,proto3" json:"trickle_ice_sdpfrag,omitempty"`
	// contains filtered or unexported fields
}

func (*ICERestartWHIPResourceResponse) Descriptor deprecated 

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

Deprecated: Use ICERestartWHIPResourceResponse.ProtoReflect.Descriptor instead.

func (*ICERestartWHIPResourceResponse) GetTrickleIceSdpfrag 

func (x *ICERestartWHIPResourceResponse) GetTrickleIceSdpfrag() string

func (*ICERestartWHIPResourceResponse) ProtoMessage 

func (*ICERestartWHIPResourceResponse) ProtoMessage()

func (*ICERestartWHIPResourceResponse) ProtoReflect 

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

func (*ICERestartWHIPResourceResponse) Reset 

func (x *ICERestartWHIPResourceResponse) Reset()

func (*ICERestartWHIPResourceResponse) String 

func (x *ICERestartWHIPResourceResponse) String() string

type IOInfoClient 

type IOInfoClient interface {
	// egress
	CreateEgress(ctx context.Context, req *livekit4.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	UpdateEgress(ctx context.Context, req *livekit4.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

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

	ListEgress(ctx context.Context, req *livekit4.ListEgressRequest, opts ...psrpc.RequestOption) (*livekit4.ListEgressResponse, error)

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

	// ingress
	CreateIngress(ctx context.Context, req *livekit5.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)

	UpdateSIPCallState(ctx context.Context, req *UpdateSIPCallStateRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

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, *livekit4.EgressInfo) (*google_protobuf.Empty, error)

	UpdateEgress(context.Context, *livekit4.EgressInfo) (*google_protobuf.Empty, error)

	GetEgress(context.Context, *GetEgressRequest) (*livekit4.EgressInfo, error)

	ListEgress(context.Context, *livekit4.ListEgressRequest) (*livekit4.ListEgressResponse, error)

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

	// ingress
	CreateIngress(context.Context, *livekit5.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)

	UpdateSIPCallState(context.Context, *UpdateSIPCallStateRequest) (*google_protobuf.Empty, 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 *livekit5.UpdateIngressRequest, opts ...psrpc.RequestOption) (*livekit5.IngressState, error)

	DeleteIngress(ctx context.Context, topic string, req *livekit5.DeleteIngressRequest, opts ...psrpc.RequestOption) (*livekit5.IngressState, error)

	DeleteWHIPResource(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	ICERestartWHIPResource(ctx context.Context, topic string, req *ICERestartWHIPResourceRequest, opts ...psrpc.RequestOption) (*ICERestartWHIPResourceResponse, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

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)
	RegisterICERestartWHIPResourceTopic(topic string) error
	DeregisterICERestartWHIPResourceTopic(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, *livekit5.UpdateIngressRequest) (*livekit5.IngressState, error)

	DeleteIngress(context.Context, *livekit5.DeleteIngressRequest) (*livekit5.IngressState, error)

	DeleteWHIPResource(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error)

	ICERestartWHIPResource(context.Context, *ICERestartWHIPResourceRequest) (*ICERestartWHIPResourceResponse, error)
}

type IngressInternalClient 

type IngressInternalClient interface {
	StartIngress(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*livekit5.IngressInfo, error)

	ListActiveIngress(ctx context.Context, topic string, req *ListActiveIngressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveIngressResponse], error)

	KillIngressSession(ctx context.Context, ingressId string, resourceId string, req *KillIngressSessionRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

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)
	RegisterKillIngressSessionTopic(ingressId string, resourceId string) error
	DeregisterKillIngressSessionTopic(ingressId string, resourceId 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) (*livekit5.IngressInfo, error)
	StartIngressAffinity(context.Context, *StartIngressRequest) float32

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

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

type IngressSession 

type IngressSession struct {
	IngressId  string `protobuf:"bytes,1,opt,name=ingress_id,json=ingressId,proto3" json:"ingress_id,omitempty"`
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressSession) Descriptor deprecated 

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

Deprecated: Use IngressSession.ProtoReflect.Descriptor instead.

func (*IngressSession) GetIngressId 

func (x *IngressSession) GetIngressId() string

func (*IngressSession) GetResourceId 

func (x *IngressSession) GetResourceId() string

func (*IngressSession) ProtoMessage 

func (*IngressSession) ProtoMessage()

func (*IngressSession) ProtoReflect 

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

func (*IngressSession) Reset 

func (x *IngressSession) Reset()

func (*IngressSession) String 

func (x *IngressSession) String() string

type InternalCreateSIPParticipantRequest 

type InternalCreateSIPParticipantRequest struct {

	// Used in Cloud only
	ProjectId  string `protobuf:"bytes,18,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	SipCallId  string `protobuf:"bytes,13,opt,name=sip_call_id,json=sipCallId,proto3" json:"sip_call_id,omitempty"`
	SipTrunkId string `protobuf:"bytes,19,opt,name=sip_trunk_id,json=sipTrunkId,proto3" json:"sip_trunk_id,omitempty"`
	// IP or hostname that SIP INVITE is sent too
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Hostname for the 'From' SIP address in INVITE
	Hostname  string               `protobuf:"bytes,20,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Transport livekit.SIPTransport `protobuf:"varint,16,opt,name=transport,proto3,enum=livekit.SIPTransport" json:"transport,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"`
	ParticipantName       string            `protobuf:"bytes,14,opt,name=participant_name,json=participantName,proto3" json:"participant_name,omitempty"`
	ParticipantMetadata   string            `protobuf:"bytes,15,opt,name=participant_metadata,json=participantMetadata,proto3" json:"participant_metadata,omitempty"`
	ParticipantAttributes map[string]string `` /* 213-byte string literal not displayed */
	// 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 dialtone in the room as an audible indicator for existing participants
	PlayDialtone        bool              `protobuf:"varint,12,opt,name=play_dialtone,json=playDialtone,proto3" json:"play_dialtone,omitempty"`
	Headers             map[string]string `` /* 156-byte string literal not displayed */
	HeadersToAttributes map[string]string `` /* 209-byte string literal not displayed */
	// Max time for the callee to answer the call.
	RingingTimeout *durationpb.Duration `protobuf:"bytes,23,opt,name=ringing_timeout,json=ringingTimeout,proto3" json:"ringing_timeout,omitempty"`
	// Max call duration.
	MaxCallDuration *durationpb.Duration `protobuf:"bytes,24,opt,name=max_call_duration,json=maxCallDuration,proto3" json:"max_call_duration,omitempty"`
	// contains filtered or unexported fields
}

func NewCreateSIPParticipantRequest 

func NewCreateSIPParticipantRequest(
	projectID, callID, host, wsUrl, token string,
	req *livekit.CreateSIPParticipantRequest,
	trunk *livekit.SIPOutboundTrunkInfo,
) (*InternalCreateSIPParticipantRequest, error)

NewCreateSIPParticipantRequest fills InternalCreateSIPParticipantRequest from livekit.CreateSIPParticipantRequest and livekit.SIPTrunkInfo.

func (*InternalCreateSIPParticipantRequest) Descriptor deprecated 

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

Deprecated: Use InternalCreateSIPParticipantRequest.ProtoReflect.Descriptor instead.

func (*InternalCreateSIPParticipantRequest) GetAddress 

func (x *InternalCreateSIPParticipantRequest) GetAddress() string

func (*InternalCreateSIPParticipantRequest) GetCallTo 

func (x *InternalCreateSIPParticipantRequest) GetCallTo() string

func (*InternalCreateSIPParticipantRequest) GetDtmf 

func (x *InternalCreateSIPParticipantRequest) GetDtmf() string

func (*InternalCreateSIPParticipantRequest) GetHeaders 

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

func (*InternalCreateSIPParticipantRequest) GetHeadersToAttributes 

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

func (*InternalCreateSIPParticipantRequest) GetHostname 

func (x *InternalCreateSIPParticipantRequest) GetHostname() string

func (*InternalCreateSIPParticipantRequest) GetMaxCallDuration 

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

func (*InternalCreateSIPParticipantRequest) GetNumber 

func (x *InternalCreateSIPParticipantRequest) GetNumber() string

func (*InternalCreateSIPParticipantRequest) GetParticipantAttributes 

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

func (*InternalCreateSIPParticipantRequest) GetParticipantIdentity 

func (x *InternalCreateSIPParticipantRequest) GetParticipantIdentity() string

func (*InternalCreateSIPParticipantRequest) GetParticipantMetadata 

func (x *InternalCreateSIPParticipantRequest) GetParticipantMetadata() string

func (*InternalCreateSIPParticipantRequest) GetParticipantName 

func (x *InternalCreateSIPParticipantRequest) GetParticipantName() string

func (*InternalCreateSIPParticipantRequest) GetPassword 

func (x *InternalCreateSIPParticipantRequest) GetPassword() string

func (*InternalCreateSIPParticipantRequest) GetPlayDialtone 

func (x *InternalCreateSIPParticipantRequest) GetPlayDialtone() bool

func (*InternalCreateSIPParticipantRequest) GetProjectId 

func (x *InternalCreateSIPParticipantRequest) GetProjectId() string

func (*InternalCreateSIPParticipantRequest) GetRingingTimeout 

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

func (*InternalCreateSIPParticipantRequest) GetRoomName 

func (x *InternalCreateSIPParticipantRequest) GetRoomName() string

func (*InternalCreateSIPParticipantRequest) GetSipCallId 

func (x *InternalCreateSIPParticipantRequest) GetSipCallId() string

func (*InternalCreateSIPParticipantRequest) GetSipTrunkId 

func (x *InternalCreateSIPParticipantRequest) GetSipTrunkId() string

func (*InternalCreateSIPParticipantRequest) GetToken 

func (x *InternalCreateSIPParticipantRequest) GetToken() string

func (*InternalCreateSIPParticipantRequest) GetTransport 

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

func (*InternalCreateSIPParticipantRequest) GetUsername 

func (x *InternalCreateSIPParticipantRequest) GetUsername() string

func (*InternalCreateSIPParticipantRequest) GetWsUrl 

func (x *InternalCreateSIPParticipantRequest) GetWsUrl() string

func (*InternalCreateSIPParticipantRequest) ProtoMessage 

func (*InternalCreateSIPParticipantRequest) ProtoMessage()

func (*InternalCreateSIPParticipantRequest) ProtoReflect 

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

func (*InternalCreateSIPParticipantRequest) Reset 

func (x *InternalCreateSIPParticipantRequest) Reset()

func (*InternalCreateSIPParticipantRequest) String 

func (x *InternalCreateSIPParticipantRequest) String() string

type InternalCreateSIPParticipantResponse 

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"`
	SipCallId           string `protobuf:"bytes,3,opt,name=sip_call_id,json=sipCallId,proto3" json:"sip_call_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalCreateSIPParticipantResponse) Descriptor deprecated 

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

Deprecated: Use InternalCreateSIPParticipantResponse.ProtoReflect.Descriptor instead.

func (*InternalCreateSIPParticipantResponse) GetParticipantId 

func (x *InternalCreateSIPParticipantResponse) GetParticipantId() string

func (*InternalCreateSIPParticipantResponse) GetParticipantIdentity 

func (x *InternalCreateSIPParticipantResponse) GetParticipantIdentity() string

func (*InternalCreateSIPParticipantResponse) GetSipCallId 

func (x *InternalCreateSIPParticipantResponse) GetSipCallId() string

func (*InternalCreateSIPParticipantResponse) ProtoMessage 

func (*InternalCreateSIPParticipantResponse) ProtoMessage()

func (*InternalCreateSIPParticipantResponse) ProtoReflect 

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

func (*InternalCreateSIPParticipantResponse) Reset 

func (x *InternalCreateSIPParticipantResponse) Reset()

func (*InternalCreateSIPParticipantResponse) String 

func (x *InternalCreateSIPParticipantResponse) String() string

type InternalTransferSIPParticipantRequest 

type InternalTransferSIPParticipantRequest struct {
	SipCallId  string `protobuf:"bytes,1,opt,name=sip_call_id,json=sipCallId,proto3" json:"sip_call_id,omitempty"`
	TransferTo string `protobuf:"bytes,2,opt,name=transfer_to,json=transferTo,proto3" json:"transfer_to,omitempty"`
	// Optionally play dialtone to the SIP participant as an audible indicator of being transferred
	PlayDialtone bool `protobuf:"varint,3,opt,name=play_dialtone,json=playDialtone,proto3" json:"play_dialtone,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalTransferSIPParticipantRequest) Descriptor deprecated 

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

Deprecated: Use InternalTransferSIPParticipantRequest.ProtoReflect.Descriptor instead.

func (*InternalTransferSIPParticipantRequest) GetPlayDialtone 

func (x *InternalTransferSIPParticipantRequest) GetPlayDialtone() bool

func (*InternalTransferSIPParticipantRequest) GetSipCallId 

func (x *InternalTransferSIPParticipantRequest) GetSipCallId() string

func (*InternalTransferSIPParticipantRequest) GetTransferTo 

func (x *InternalTransferSIPParticipantRequest) GetTransferTo() string

func (*InternalTransferSIPParticipantRequest) ProtoMessage 

func (*InternalTransferSIPParticipantRequest) ProtoMessage()

func (*InternalTransferSIPParticipantRequest) ProtoReflect 

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

func (*InternalTransferSIPParticipantRequest) Reset 

func (x *InternalTransferSIPParticipantRequest) Reset()

func (*InternalTransferSIPParticipantRequest) String 

func (x *InternalTransferSIPParticipantRequest) String() string

type JobRequestResponse 

type JobRequestResponse struct {
	State *livekit.JobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRequestResponse) Descriptor deprecated 

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

Deprecated: Use JobRequestResponse.ProtoReflect.Descriptor instead.

func (*JobRequestResponse) GetState 

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

func (*JobRequestResponse) ProtoMessage 

func (*JobRequestResponse) ProtoMessage()

func (*JobRequestResponse) ProtoReflect 

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

func (*JobRequestResponse) Reset 

func (x *JobRequestResponse) Reset()

func (*JobRequestResponse) String 

func (x *JobRequestResponse) String() string

type JobTerminateReason 

type JobTerminateReason int32
const (
	JobTerminateReason_TERMINATION_REQUESTED JobTerminateReason = 0
	JobTerminateReason_AGENT_LEFT_ROOM       JobTerminateReason = 1
)

func (JobTerminateReason) Descriptor 

func (JobTerminateReason) Descriptor() protoreflect.EnumDescriptor

func (JobTerminateReason) Enum 

func (x JobTerminateReason) Enum() *JobTerminateReason

func (JobTerminateReason) EnumDescriptor deprecated 

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

Deprecated: Use JobTerminateReason.Descriptor instead.

func (JobTerminateReason) Number 

func (x JobTerminateReason) Number() protoreflect.EnumNumber

func (JobTerminateReason) String 

func (x JobTerminateReason) String() string

func (JobTerminateReason) Type 

func (JobTerminateReason) Type() protoreflect.EnumType

type JobTerminateRequest 

type JobTerminateRequest struct {
	JobId  string             `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Reason JobTerminateReason `protobuf:"varint,2,opt,name=reason,proto3,enum=rpc.JobTerminateReason" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*JobTerminateRequest) Descriptor deprecated 

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

Deprecated: Use JobTerminateRequest.ProtoReflect.Descriptor instead.

func (*JobTerminateRequest) GetJobId 

func (x *JobTerminateRequest) GetJobId() string

func (*JobTerminateRequest) GetReason 

func (x *JobTerminateRequest) GetReason() JobTerminateReason

func (*JobTerminateRequest) ProtoMessage 

func (*JobTerminateRequest) ProtoMessage()

func (*JobTerminateRequest) ProtoReflect 

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

func (*JobTerminateRequest) Reset 

func (x *JobTerminateRequest) Reset()

func (*JobTerminateRequest) String 

func (x *JobTerminateRequest) String() string

type JobTerminateResponse 

type JobTerminateResponse struct {
	State *livekit.JobState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*JobTerminateResponse) Descriptor deprecated 

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

Deprecated: Use JobTerminateResponse.ProtoReflect.Descriptor instead.

func (*JobTerminateResponse) GetState 

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

func (*JobTerminateResponse) ProtoMessage 

func (*JobTerminateResponse) ProtoMessage()

func (*JobTerminateResponse) ProtoReflect 

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

func (*JobTerminateResponse) Reset 

func (x *JobTerminateResponse) Reset()

func (*JobTerminateResponse) String 

func (x *JobTerminateResponse) String() string

type KeepaliveClient 

type KeepaliveClient[NodeIDTopicType ~string] interface {
	SubscribePing(ctx context.Context, nodeID NodeIDTopicType) (psrpc.Subscription[*KeepalivePing], error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewKeepaliveClient 

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 

type KeepalivePing struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*KeepalivePing) Descriptor deprecated 

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

Deprecated: Use KeepalivePing.ProtoReflect.Descriptor instead.

func (*KeepalivePing) GetTimestamp 

func (x *KeepalivePing) GetTimestamp() int64

func (*KeepalivePing) ProtoMessage 

func (*KeepalivePing) ProtoMessage()

func (*KeepalivePing) ProtoReflect 

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

func (*KeepalivePing) Reset 

func (x *KeepalivePing) Reset()

func (*KeepalivePing) String 

func (x *KeepalivePing) String() string

type KeepalivePubSub 

type KeepalivePubSub interface {
	KeepaliveClient[livekit.NodeID]
	KeepaliveServer[livekit.NodeID]
}

func NewKeepalivePubSub 

func NewKeepalivePubSub(params ClientParams) (KeepalivePubSub, error)

type KeepaliveServer 

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 

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 

type KeepaliveServerImpl interface {
}

type KillIngressSessionRequest 

type KillIngressSessionRequest struct {
	Session *IngressSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*KillIngressSessionRequest) Descriptor deprecated 

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

Deprecated: Use KillIngressSessionRequest.ProtoReflect.Descriptor instead.

func (*KillIngressSessionRequest) GetSession 

func (x *KillIngressSessionRequest) GetSession() *IngressSession

func (*KillIngressSessionRequest) ProtoMessage 

func (*KillIngressSessionRequest) ProtoMessage()

func (*KillIngressSessionRequest) ProtoReflect 

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

func (*KillIngressSessionRequest) Reset 

func (x *KillIngressSessionRequest) Reset()

func (*KillIngressSessionRequest) String 

func (x *KillIngressSessionRequest) String() string

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 {

	// Deprecated: Marked as deprecated in rpc/ingress.proto.
	IngressIds      []string          `protobuf:"bytes,1,rep,name=ingress_ids,json=ingressIds,proto3" json:"ingress_ids,omitempty"`
	IngressSessions []*IngressSession `protobuf:"bytes,2,rep,name=ingress_sessions,json=ingressSessions,proto3" json:"ingress_sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListActiveIngressResponse) Descriptor deprecated 

func (*ListActiveIngressResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListActiveIngressResponse.ProtoReflect.Descriptor instead.

func (*ListActiveIngressResponse) GetIngressIds deprecated 

func (x *ListActiveIngressResponse) GetIngressIds() []string

Deprecated: Marked as deprecated in rpc/ingress.proto.

func (*ListActiveIngressResponse) GetIngressSessions 

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

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 

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 PSRPCMetricsObserver 

type PSRPCMetricsObserver struct{}

func (PSRPCMetricsObserver) OnMultiRequest 

func (o PSRPCMetricsObserver) OnMultiRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, responseCount, errorCount, rxBytes, txBytes int)

func (PSRPCMetricsObserver) OnStreamClose 

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

func (PSRPCMetricsObserver) OnStreamOpen 

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

func (PSRPCMetricsObserver) OnStreamRecv 

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

func (PSRPCMetricsObserver) OnStreamSend 

func (o PSRPCMetricsObserver) OnStreamSend(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error, bytes int)

func (PSRPCMetricsObserver) OnUnaryRequest 

func (o PSRPCMetricsObserver) OnUnaryRequest(role middleware.MetricRole, info psrpc.RPCInfo, duration time.Duration, err error, rxBytes, txBytes int)

type PSRPCMetricsOption 

type PSRPCMetricsOption func(*psrpcMetricsOptions)

func WithCurryLabels 

func WithCurryLabels(labels prometheus.Labels) PSRPCMetricsOption

type ParticipantClient 

type ParticipantClient[ParticipantTopicType ~string] interface {
	RemoveParticipant(ctx context.Context, participant ParticipantTopicType, req *livekit7.RoomParticipantIdentity, opts ...psrpc.RequestOption) (*livekit7.RemoveParticipantResponse, error)

	MutePublishedTrack(ctx context.Context, participant ParticipantTopicType, req *livekit7.MuteRoomTrackRequest, opts ...psrpc.RequestOption) (*livekit7.MuteRoomTrackResponse, error)

	UpdateParticipant(ctx context.Context, participant ParticipantTopicType, req *livekit7.UpdateParticipantRequest, opts ...psrpc.RequestOption) (*livekit1.ParticipantInfo, error)

	UpdateSubscriptions(ctx context.Context, participant ParticipantTopicType, req *livekit7.UpdateSubscriptionsRequest, opts ...psrpc.RequestOption) (*livekit7.UpdateSubscriptionsResponse, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewParticipantClient 

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 

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 

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 

type ParticipantServerImpl interface {
	RemoveParticipant(context.Context, *livekit7.RoomParticipantIdentity) (*livekit7.RemoveParticipantResponse, error)

	MutePublishedTrack(context.Context, *livekit7.MuteRoomTrackRequest) (*livekit7.MuteRoomTrackResponse, error)

	UpdateParticipant(context.Context, *livekit7.UpdateParticipantRequest) (*livekit1.ParticipantInfo, error)

	UpdateSubscriptions(context.Context, *livekit7.UpdateSubscriptionsRequest) (*livekit7.UpdateSubscriptionsResponse, error)
}

type ParticipantTopic 

type ParticipantTopic string

func FormatParticipantTopic 

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 

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 

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

Deprecated: Use RelaySignalRequest.ProtoReflect.Descriptor instead.

func (*RelaySignalRequest) GetClose 

func (x *RelaySignalRequest) GetClose() bool

func (*RelaySignalRequest) GetRequests 

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

func (*RelaySignalRequest) GetSeq 

func (x *RelaySignalRequest) GetSeq() uint64

func (*RelaySignalRequest) GetStartSession 

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

func (*RelaySignalRequest) ProtoMessage 

func (*RelaySignalRequest) ProtoMessage()

func (*RelaySignalRequest) ProtoReflect 

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

func (*RelaySignalRequest) Reset 

func (x *RelaySignalRequest) Reset()

func (*RelaySignalRequest) String 

func (x *RelaySignalRequest) String() string

type RelaySignalResponse 

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 

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

Deprecated: Use RelaySignalResponse.ProtoReflect.Descriptor instead.

func (*RelaySignalResponse) GetClose 

func (x *RelaySignalResponse) GetClose() bool

func (*RelaySignalResponse) GetResponses 

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

func (*RelaySignalResponse) GetSeq 

func (x *RelaySignalResponse) GetSeq() uint64

func (*RelaySignalResponse) ProtoMessage 

func (*RelaySignalResponse) ProtoMessage()

func (*RelaySignalResponse) ProtoReflect 

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

func (*RelaySignalResponse) Reset 

func (x *RelaySignalResponse) Reset()

func (*RelaySignalResponse) String 

func (x *RelaySignalResponse) String() string

type RoomClient 

type RoomClient[RoomTopicType ~string] interface {
	DeleteRoom(ctx context.Context, room RoomTopicType, req *livekit7.DeleteRoomRequest, opts ...psrpc.RequestOption) (*livekit7.DeleteRoomResponse, error)

	SendData(ctx context.Context, room RoomTopicType, req *livekit7.SendDataRequest, opts ...psrpc.RequestOption) (*livekit7.SendDataResponse, error)

	UpdateRoomMetadata(ctx context.Context, room RoomTopicType, req *livekit7.UpdateRoomMetadataRequest, opts ...psrpc.RequestOption) (*livekit1.Room, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewRoomClient 

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

NewRoomClient creates a psrpc client that implements the RoomClient interface.

type RoomManagerClient 

type RoomManagerClient[NodeIdTopicType ~string] interface {
	CreateRoom(ctx context.Context, nodeId NodeIdTopicType, req *livekit7.CreateRoomRequest, opts ...psrpc.RequestOption) (*livekit1.Room, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewRoomManagerClient 

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

NewRoomManagerClient creates a psrpc client that implements the RoomManagerClient interface.

type RoomManagerServer 

type RoomManagerServer[NodeIdTopicType ~string] interface {
	RegisterCreateRoomTopic(nodeId NodeIdTopicType) error
	DeregisterCreateRoomTopic(nodeId NodeIdTopicType)
	RegisterAllNodeTopics(nodeId NodeIdTopicType) error
	DeregisterAllNodeTopics(nodeId NodeIdTopicType)

	// Close and wait for pending RPCs to complete
	Shutdown()

	// Close immediately, without waiting for pending RPCs
	Kill()
}

func NewRoomManagerServer 

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

NewRoomManagerServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.

type RoomManagerServerImpl 

type RoomManagerServerImpl interface {
	CreateRoom(context.Context, *livekit7.CreateRoomRequest) (*livekit1.Room, error)
}

type RoomServer 

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 

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 

type RoomServerImpl interface {
	DeleteRoom(context.Context, *livekit7.DeleteRoomRequest) (*livekit7.DeleteRoomResponse, error)

	SendData(context.Context, *livekit7.SendDataRequest) (*livekit7.SendDataResponse, error)

	UpdateRoomMetadata(context.Context, *livekit7.UpdateRoomMetadataRequest) (*livekit1.Room, error)
}

type RoomTopic 

type RoomTopic string

func FormatRoomTopic 

func FormatRoomTopic(roomName livekit.RoomName) RoomTopic

type SIPClient 

type SIPClient interface {
	SIPInternalClient
}

func NewSIPClient 

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

type SIPDispatchResult 

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 

func (SIPDispatchResult) Descriptor() protoreflect.EnumDescriptor

func (SIPDispatchResult) Enum 

func (x SIPDispatchResult) Enum() *SIPDispatchResult

func (SIPDispatchResult) EnumDescriptor deprecated 

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

Deprecated: Use SIPDispatchResult.Descriptor instead.

func (SIPDispatchResult) Number 

func (x SIPDispatchResult) Number() protoreflect.EnumNumber

func (SIPDispatchResult) String 

func (x SIPDispatchResult) String() string

func (SIPDispatchResult) Type 

func (SIPDispatchResult) Type() protoreflect.EnumType

type SIPFeature 

type SIPFeature int32
const (
	SIPFeature_NONE          SIPFeature = 0
	SIPFeature_KRISP_ENABLED SIPFeature = 1
)

func (SIPFeature) Descriptor 

func (SIPFeature) Descriptor() protoreflect.EnumDescriptor

func (SIPFeature) Enum 

func (x SIPFeature) Enum() *SIPFeature

func (SIPFeature) EnumDescriptor deprecated 

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

Deprecated: Use SIPFeature.Descriptor instead.

func (SIPFeature) Number 

func (x SIPFeature) Number() protoreflect.EnumNumber

func (SIPFeature) String 

func (x SIPFeature) String() string

func (SIPFeature) Type 

func (SIPFeature) Type() protoreflect.EnumType

type SIPInternalClient 

type SIPInternalClient interface {
	CreateSIPParticipant(ctx context.Context, topic string, req *InternalCreateSIPParticipantRequest, opts ...psrpc.RequestOption) (*InternalCreateSIPParticipantResponse, error)

	TransferSIPParticipant(ctx context.Context, sipCallId string, req *InternalTransferSIPParticipantRequest, opts ...psrpc.RequestOption) (*google_protobuf.Empty, error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewSIPInternalClient 

func NewSIPInternalClient(bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SIPInternalClient, error)

NewSIPInternalClient creates a psrpc client that implements the SIPInternalClient interface.

type SIPInternalServer 

type SIPInternalServer interface {
	RegisterCreateSIPParticipantTopic(topic string) error
	DeregisterCreateSIPParticipantTopic(topic string)
	RegisterTransferSIPParticipantTopic(sipCallId string) error
	DeregisterTransferSIPParticipantTopic(sipCallId string)

	// Close and wait for pending RPCs to complete
	Shutdown()

	// Close immediately, without waiting for pending RPCs
	Kill()
}

func NewSIPInternalServer 

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 

type SIPInternalServerImpl interface {
	CreateSIPParticipant(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error)
	CreateSIPParticipantAffinity(context.Context, *InternalCreateSIPParticipantRequest) float32

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

type SignalClient 

type SignalClient[NodeIdTopicType ~string] interface {
	RelaySignal(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error)

	// Close immediately, without waiting for pending RPCs
	Close()
}

func NewSignalClient 

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 

type SignalServer[NodeIdTopicType ~string] interface {
	RegisterRelaySignalTopic(nodeId NodeIdTopicType) error
	DeregisterRelaySignalTopic(nodeId NodeIdTopicType)
	RegisterAllNodeTopics(nodeId NodeIdTopicType) error
	DeregisterAllNodeTopics(nodeId NodeIdTopicType)

	// Close and wait for pending RPCs to complete
	Shutdown()

	// Close immediately, without waiting for pending RPCs
	Kill()
}

func NewSignalServer 

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 

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"`
	// cloud only
	CloudBackupEnabled bool    `protobuf:"varint,10,opt,name=cloud_backup_enabled,json=cloudBackupEnabled,proto3" json:"cloud_backup_enabled,omitempty"`
	EstimatedCpu       float64 `protobuf:"fixed64,14,opt,name=estimated_cpu,json=estimatedCpu,proto3" json:"estimated_cpu,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEgressRequest) Descriptor deprecated 

func (*StartEgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartEgressRequest.ProtoReflect.Descriptor instead.

func (*StartEgressRequest) GetCloudBackupEnabled 

func (x *StartEgressRequest) GetCloudBackupEnabled() bool

func (*StartEgressRequest) GetEgressId 

func (x *StartEgressRequest) GetEgressId() string

func (*StartEgressRequest) GetEstimatedCpu 

func (x *StartEgressRequest) GetEstimatedCpu() float64

func (*StartEgressRequest) GetParticipant 

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 

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 

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 

func (*StartIngressRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartIngressRequest.ProtoReflect.Descriptor instead.

func (*StartIngressRequest) GetInfo 

func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo

func (*StartIngressRequest) GetLoggingFields 

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

func (*StartIngressRequest) GetToken 

func (x *StartIngressRequest) GetToken() string

func (*StartIngressRequest) GetWsUrl 

func (x *StartIngressRequest) GetWsUrl() string

func (*StartIngressRequest) ProtoMessage 

func (*StartIngressRequest) ProtoMessage()

func (*StartIngressRequest) ProtoReflect 

func (x *StartIngressRequest) ProtoReflect() protoreflect.Message

func (*StartIngressRequest) Reset 

func (x *StartIngressRequest) Reset()

func (*StartIngressRequest) String 

func (x *StartIngressRequest) String() string

type TopicFormatter 

type TopicFormatter interface {
	ParticipantTopic(ctx context.Context, roomName livekit.RoomName, identity livekit.ParticipantIdentity) ParticipantTopic
	RoomTopic(ctx context.Context, roomName livekit.RoomName) RoomTopic
}

func NewTopicFormatter 

func NewTopicFormatter() TopicFormatter

type TypedAgentDispatchInternalClient 

type TypedAgentDispatchInternalClient = AgentDispatchInternalClient[RoomTopic]

func NewTypedAgentDispatchInternalClient 

func NewTypedAgentDispatchInternalClient(params ClientParams) (TypedAgentDispatchInternalClient, error)

type TypedAgentDispatchInternalServer 

type TypedAgentDispatchInternalServer = AgentDispatchInternalServer[RoomTopic]

func NewTypedAgentDispatchInternalServer 

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

type TypedParticipantClient 

type TypedParticipantClient = ParticipantClient[ParticipantTopic]

func NewTypedParticipantClient 

func NewTypedParticipantClient(params ClientParams) (TypedParticipantClient, error)

type TypedParticipantServer 

type TypedParticipantServer = ParticipantServer[ParticipantTopic]

func NewTypedParticipantServer 

func NewTypedParticipantServer(svc ParticipantServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedParticipantServer, error)

type TypedRoomClient 

type TypedRoomClient = RoomClient[RoomTopic]

func NewTypedRoomClient 

func NewTypedRoomClient(params ClientParams) (TypedRoomClient, error)

type TypedRoomManagerClient 

type TypedRoomManagerClient = RoomManagerClient[livekit.NodeID]

func NewTypedRoomManagerClient 

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

type TypedRoomManagerServer 

type TypedRoomManagerServer = RoomManagerServer[livekit.NodeID]

func NewTypedRoomManagerServer 

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

type TypedRoomServer 

type TypedRoomServer = RoomServer[RoomTopic]

func NewTypedRoomServer 

func NewTypedRoomServer(svc RoomServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedRoomServer, error)

type TypedSignalClient 

type TypedSignalClient = SignalClient[livekit.NodeID]

func NewTypedSignalClient 

func NewTypedSignalClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error)

type TypedSignalServer 

type TypedSignalServer = SignalServer[livekit.NodeID]

func NewTypedSignalServer 

func NewTypedSignalServer(nodeID livekit.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedSignalServer, error)

type UnimplementedAnalyticsRecorderServiceServer 

type UnimplementedAnalyticsRecorderServiceServer struct{}

UnimplementedAnalyticsRecorderServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents 

func (UnimplementedAnalyticsRecorderServiceServer) IngestEvents(grpc.ClientStreamingServer[livekit.AnalyticsEvents, emptypb.Empty]) error

func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates 

func (UnimplementedAnalyticsRecorderServiceServer) IngestNodeRoomStates(grpc.ClientStreamingServer[livekit.AnalyticsNodeRooms, emptypb.Empty]) error

func (UnimplementedAnalyticsRecorderServiceServer) IngestStats 

func (UnimplementedAnalyticsRecorderServiceServer) IngestStats(grpc.ClientStreamingServer[livekit.AnalyticsStats, emptypb.Empty]) error

type UnimplementedMetricsObserver 

type UnimplementedMetricsObserver struct{}

func (UnimplementedMetricsObserver) OnMultiRequest 

func (o UnimplementedMetricsObserver) OnMultiRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, responseCount, errorCount, reqBytes, txBytes int)

func (UnimplementedMetricsObserver) OnStreamClose 

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

func (UnimplementedMetricsObserver) OnStreamOpen 

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

func (UnimplementedMetricsObserver) OnStreamRecv 

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

func (UnimplementedMetricsObserver) OnStreamSend 

func (o UnimplementedMetricsObserver) OnStreamSend(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error, bytes int)

func (UnimplementedMetricsObserver) OnUnaryRequest 

func (o UnimplementedMetricsObserver) OnUnaryRequest(role middleware.MetricRole, rpcInfo psrpc.RPCInfo, duration time.Duration, err error, rxBytes, txBytes int)

type UnsafeAnalyticsRecorderServiceServer 

type UnsafeAnalyticsRecorderServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAnalyticsRecorderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnalyticsRecorderServiceServer will result in compilation errors.

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 

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 

func (*UpdateMetricsRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateMetricsRequest.ProtoReflect.Descriptor instead.

func (*UpdateMetricsRequest) GetAvgCpuUsage 

func (x *UpdateMetricsRequest) GetAvgCpuUsage() float32

func (*UpdateMetricsRequest) GetInfo 

func (x *UpdateMetricsRequest) GetInfo() *livekit.EgressInfo

func (*UpdateMetricsRequest) GetMaxCpuUsage 

func (x *UpdateMetricsRequest) GetMaxCpuUsage() float32

func (*UpdateMetricsRequest) ProtoMessage 

func (*UpdateMetricsRequest) ProtoMessage()

func (*UpdateMetricsRequest) ProtoReflect 

func (x *UpdateMetricsRequest) ProtoReflect() protoreflect.Message

func (*UpdateMetricsRequest) Reset 

func (x *UpdateMetricsRequest) Reset()

func (*UpdateMetricsRequest) String 

func (x *UpdateMetricsRequest) String() string

type UpdateSIPCallStateRequest 

type UpdateSIPCallStateRequest struct {
	CallInfo *livekit.SIPCallInfo `protobuf:"bytes,1,opt,name=call_info,json=callInfo,proto3" json:"call_info,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSIPCallStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSIPCallStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateSIPCallStateRequest) GetCallInfo 

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

func (*UpdateSIPCallStateRequest) ProtoMessage 

func (*UpdateSIPCallStateRequest) ProtoMessage()

func (*UpdateSIPCallStateRequest) ProtoReflect 

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

func (*UpdateSIPCallStateRequest) Reset 

func (x *UpdateSIPCallStateRequest) Reset()

func (*UpdateSIPCallStateRequest) String 

func (x *UpdateSIPCallStateRequest) 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.