Documentation ¶
Index ¶
- Variables
- type DeleteWHIPResourceRequest
- func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteWHIPResourceRequest) GetResourceId() string
- func (x *DeleteWHIPResourceRequest) GetStreamKey() string
- func (*DeleteWHIPResourceRequest) ProtoMessage()
- func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteWHIPResourceRequest) Reset()
- func (x *DeleteWHIPResourceRequest) String() string
- type EgressClient
- type EgressHandlerClient
- type EgressHandlerServer
- type EgressHandlerServerImpl
- type EgressInternalClient
- type EgressInternalServer
- type EgressInternalServerImpl
- type GetIngressInfoRequest
- func (*GetIngressInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressInfoRequest) GetIngressId() string
- func (x *GetIngressInfoRequest) GetStreamKey() string
- func (*GetIngressInfoRequest) ProtoMessage()
- func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetIngressInfoRequest) Reset()
- func (x *GetIngressInfoRequest) String() string
- type GetIngressInfoResponse
- func (*GetIngressInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo
- func (x *GetIngressInfoResponse) GetToken() string
- func (x *GetIngressInfoResponse) GetWsUrl() string
- func (*GetIngressInfoResponse) ProtoMessage()
- func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetIngressInfoResponse) Reset()
- func (x *GetIngressInfoResponse) String() string
- type IOInfoClient
- type IOInfoServer
- type IOInfoServerImpl
- type IngressClient
- type IngressHandlerClient
- type IngressHandlerServer
- type IngressHandlerServerImpl
- type IngressInternalClient
- type IngressInternalServer
- type IngressInternalServerImpl
- type ListActiveEgressRequest
- type ListActiveEgressResponse
- func (*ListActiveEgressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActiveEgressResponse) GetEgressIds() []string
- func (*ListActiveEgressResponse) ProtoMessage()
- func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message
- func (x *ListActiveEgressResponse) Reset()
- func (x *ListActiveEgressResponse) String() string
- type ListActiveIngressRequest
- type ListActiveIngressResponse
- func (*ListActiveIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActiveIngressResponse) GetIngressIds() []string
- func (*ListActiveIngressResponse) ProtoMessage()
- func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message
- func (x *ListActiveIngressResponse) Reset()
- func (x *ListActiveIngressResponse) String() string
- type Race
- type RelaySignalRequest
- func (*RelaySignalRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RelaySignalRequest) GetClose() bool
- func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest
- func (x *RelaySignalRequest) GetSeq() uint64
- func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession
- func (*RelaySignalRequest) ProtoMessage()
- func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message
- func (x *RelaySignalRequest) Reset()
- func (x *RelaySignalRequest) String() string
- type RelaySignalResponse
- func (*RelaySignalResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RelaySignalResponse) GetClose() bool
- func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse
- func (x *RelaySignalResponse) GetSeq() uint64
- func (*RelaySignalResponse) ProtoMessage()
- func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message
- func (x *RelaySignalResponse) Reset()
- func (x *RelaySignalResponse) String() string
- type SignalClient
- type SignalServer
- type SignalServerImpl
- type StartEgressRequest
- func (*StartEgressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartEgressRequest) GetEgressId() string
- func (x *StartEgressRequest) GetMetadata() map[string]*anypb.Any
- func (m *StartEgressRequest) GetRequest() isStartEgressRequest_Request
- func (x *StartEgressRequest) GetRoomComposite() *livekit.RoomCompositeEgressRequest
- func (x *StartEgressRequest) GetRoomId() string
- func (x *StartEgressRequest) GetToken() string
- func (x *StartEgressRequest) GetTrack() *livekit.TrackEgressRequest
- func (x *StartEgressRequest) GetTrackComposite() *livekit.TrackCompositeEgressRequest
- func (x *StartEgressRequest) GetWeb() *livekit.WebEgressRequest
- func (x *StartEgressRequest) GetWsUrl() string
- func (*StartEgressRequest) ProtoMessage()
- func (x *StartEgressRequest) ProtoReflect() protoreflect.Message
- func (x *StartEgressRequest) Reset()
- func (x *StartEgressRequest) String() string
- type StartEgressRequest_RoomComposite
- type StartEgressRequest_Track
- type StartEgressRequest_TrackComposite
- type StartEgressRequest_Web
- type StartIngressRequest
- func (*StartIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo
- func (x *StartIngressRequest) GetToken() string
- func (x *StartIngressRequest) GetWsUrl() string
- func (*StartIngressRequest) ProtoMessage()
- func (x *StartIngressRequest) ProtoReflect() protoreflect.Message
- func (x *StartIngressRequest) Reset()
- func (x *StartIngressRequest) String() string
- type TypedSignalClient
- type TypedSignalServer
- type UpdateIngressStateRequest
- func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIngressStateRequest) GetIngressId() string
- func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState
- func (*UpdateIngressStateRequest) ProtoMessage()
- func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateIngressStateRequest) Reset()
- func (x *UpdateIngressStateRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var File_rpc_egress_proto protoreflect.FileDescriptor
var File_rpc_ingress_proto protoreflect.FileDescriptor
var File_rpc_io_proto protoreflect.FileDescriptor
var File_rpc_signal_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type DeleteWHIPResourceRequest ¶ added in v1.5.6
type DeleteWHIPResourceRequest struct { ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` StreamKey string `protobuf:"bytes,2,opt,name=stream_key,json=streamKey,proto3" json:"stream_key,omitempty"` // contains filtered or unexported fields }
func (*DeleteWHIPResourceRequest) Descriptor
deprecated
added in
v1.5.6
func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteWHIPResourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteWHIPResourceRequest) GetResourceId ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) GetResourceId() string
func (*DeleteWHIPResourceRequest) GetStreamKey ¶ added in v1.5.9
func (x *DeleteWHIPResourceRequest) GetStreamKey() string
func (*DeleteWHIPResourceRequest) ProtoMessage ¶ added in v1.5.6
func (*DeleteWHIPResourceRequest) ProtoMessage()
func (*DeleteWHIPResourceRequest) ProtoReflect ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message
func (*DeleteWHIPResourceRequest) Reset ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) Reset()
func (*DeleteWHIPResourceRequest) String ¶ added in v1.5.6
func (x *DeleteWHIPResourceRequest) String() string
type EgressClient ¶
type EgressClient interface { EgressInternalClient EgressHandlerClient }
func NewEgressClient ¶
func NewEgressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (EgressClient, error)
type EgressHandlerClient ¶
type EgressHandlerClient interface { UpdateStream(ctx context.Context, topic string, req *livekit1.UpdateStreamRequest, opts ...psrpc.RequestOption) (*livekit1.EgressInfo, error) StopEgress(ctx context.Context, topic string, req *livekit1.StopEgressRequest, opts ...psrpc.RequestOption) (*livekit1.EgressInfo, error) }
func NewEgressHandlerClient ¶
func NewEgressHandlerClient(clientID string, 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(serverID string, 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, *livekit1.UpdateStreamRequest) (*livekit1.EgressInfo, error) StopEgress(context.Context, *livekit1.StopEgressRequest) (*livekit1.EgressInfo, error) }
type EgressInternalClient ¶
type EgressInternalClient interface { StartEgress(ctx context.Context, topic string, req *StartEgressRequest, opts ...psrpc.RequestOption) (*livekit1.EgressInfo, error) ListActiveEgress(ctx context.Context, req *ListActiveEgressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error) }
func NewEgressInternalClient ¶
func NewEgressInternalClient(clientID string, 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) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewEgressInternalServer ¶
func NewEgressInternalServer(serverID string, 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) (*livekit1.EgressInfo, error) StartEgressAffinity(*StartEgressRequest) float32 ListActiveEgress(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) }
type GetIngressInfoRequest ¶
type GetIngressInfoRequest struct { IngressId string `protobuf:"bytes,1,opt,name=ingress_id,json=ingressId,proto3" json:"ingress_id,omitempty"` StreamKey string `protobuf:"bytes,2,opt,name=stream_key,json=streamKey,proto3" json:"stream_key,omitempty"` // contains filtered or unexported fields }
Query an ingress info from an ingress ID or stream key
func (*GetIngressInfoRequest) Descriptor
deprecated
func (*GetIngressInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIngressInfoRequest.ProtoReflect.Descriptor instead.
func (*GetIngressInfoRequest) GetIngressId ¶
func (x *GetIngressInfoRequest) GetIngressId() string
func (*GetIngressInfoRequest) GetStreamKey ¶
func (x *GetIngressInfoRequest) GetStreamKey() string
func (*GetIngressInfoRequest) ProtoMessage ¶
func (*GetIngressInfoRequest) ProtoMessage()
func (*GetIngressInfoRequest) ProtoReflect ¶
func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message
func (*GetIngressInfoRequest) Reset ¶
func (x *GetIngressInfoRequest) Reset()
func (*GetIngressInfoRequest) String ¶
func (x *GetIngressInfoRequest) String() string
type GetIngressInfoResponse ¶
type GetIngressInfoResponse struct { Info *livekit.IngressInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,3,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` // contains filtered or unexported fields }
func (*GetIngressInfoResponse) Descriptor
deprecated
func (*GetIngressInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIngressInfoResponse.ProtoReflect.Descriptor instead.
func (*GetIngressInfoResponse) GetInfo ¶
func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo
func (*GetIngressInfoResponse) GetToken ¶
func (x *GetIngressInfoResponse) GetToken() string
func (*GetIngressInfoResponse) GetWsUrl ¶
func (x *GetIngressInfoResponse) GetWsUrl() string
func (*GetIngressInfoResponse) ProtoMessage ¶
func (*GetIngressInfoResponse) ProtoMessage()
func (*GetIngressInfoResponse) ProtoReflect ¶
func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message
func (*GetIngressInfoResponse) Reset ¶
func (x *GetIngressInfoResponse) Reset()
func (*GetIngressInfoResponse) String ¶
func (x *GetIngressInfoResponse) String() string
type IOInfoClient ¶
type IOInfoClient interface { UpdateEgressInfo(ctx context.Context, req *livekit1.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf3.Empty, error) GetIngressInfo(ctx context.Context, req *GetIngressInfoRequest, opts ...psrpc.RequestOption) (*GetIngressInfoResponse, error) UpdateIngressState(ctx context.Context, req *UpdateIngressStateRequest, opts ...psrpc.RequestOption) (*google_protobuf3.Empty, error) }
func NewIOInfoClient ¶
func NewIOInfoClient(clientID string, 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(serverID string, 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 { UpdateEgressInfo(context.Context, *livekit1.EgressInfo) (*google_protobuf3.Empty, error) GetIngressInfo(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*google_protobuf3.Empty, error) }
type IngressClient ¶
type IngressClient interface { IngressInternalClient IngressHandlerClient }
func NewIngressClient ¶
func NewIngressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (IngressClient, error)
type IngressHandlerClient ¶
type IngressHandlerClient interface { UpdateIngress(ctx context.Context, topic string, req *livekit2.UpdateIngressRequest, opts ...psrpc.RequestOption) (*livekit2.IngressState, error) DeleteIngress(ctx context.Context, topic string, req *livekit2.DeleteIngressRequest, opts ...psrpc.RequestOption) (*livekit2.IngressState, error) DeleteWHIPResource(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, opts ...psrpc.RequestOption) (*google_protobuf3.Empty, error) }
func NewIngressHandlerClient ¶
func NewIngressHandlerClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error)
NewIngressHandlerClient creates a psrpc client that implements the IngressHandlerClient interface.
type IngressHandlerServer ¶
type IngressHandlerServer interface { RegisterUpdateIngressTopic(topic string) error DeregisterUpdateIngressTopic(topic string) RegisterDeleteIngressTopic(topic string) error DeregisterDeleteIngressTopic(topic string) RegisterDeleteWHIPResourceTopic(topic string) error DeregisterDeleteWHIPResourceTopic(topic string) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewIngressHandlerServer ¶
func NewIngressHandlerServer(serverID string, 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, *livekit2.UpdateIngressRequest) (*livekit2.IngressState, error) DeleteIngress(context.Context, *livekit2.DeleteIngressRequest) (*livekit2.IngressState, error) DeleteWHIPResource(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf3.Empty, error) }
type IngressInternalClient ¶
type IngressInternalClient interface { StartIngress(ctx context.Context, req *StartIngressRequest, opts ...psrpc.RequestOption) (*livekit2.IngressInfo, error) ListActiveIngress(ctx context.Context, req *ListActiveIngressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveIngressResponse], error) }
func NewIngressInternalClient ¶
func NewIngressInternalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error)
NewIngressInternalClient creates a psrpc client that implements the IngressInternalClient interface.
type IngressInternalServer ¶
type IngressInternalServer interface { // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewIngressInternalServer ¶
func NewIngressInternalServer(serverID string, 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) (*livekit2.IngressInfo, error) StartIngressAffinity(*StartIngressRequest) float32 ListActiveIngress(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) }
type ListActiveEgressRequest ¶
type ListActiveEgressRequest struct {
// contains filtered or unexported fields
}
func (*ListActiveEgressRequest) Descriptor
deprecated
func (*ListActiveEgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveEgressRequest.ProtoReflect.Descriptor instead.
func (*ListActiveEgressRequest) ProtoMessage ¶
func (*ListActiveEgressRequest) ProtoMessage()
func (*ListActiveEgressRequest) ProtoReflect ¶
func (x *ListActiveEgressRequest) ProtoReflect() protoreflect.Message
func (*ListActiveEgressRequest) Reset ¶
func (x *ListActiveEgressRequest) Reset()
func (*ListActiveEgressRequest) String ¶
func (x *ListActiveEgressRequest) String() string
type ListActiveEgressResponse ¶
type ListActiveEgressResponse struct { EgressIds []string `protobuf:"bytes,1,rep,name=egress_ids,json=egressIds,proto3" json:"egress_ids,omitempty"` // contains filtered or unexported fields }
func (*ListActiveEgressResponse) Descriptor
deprecated
func (*ListActiveEgressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveEgressResponse.ProtoReflect.Descriptor instead.
func (*ListActiveEgressResponse) GetEgressIds ¶
func (x *ListActiveEgressResponse) GetEgressIds() []string
func (*ListActiveEgressResponse) ProtoMessage ¶
func (*ListActiveEgressResponse) ProtoMessage()
func (*ListActiveEgressResponse) ProtoReflect ¶
func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message
func (*ListActiveEgressResponse) Reset ¶
func (x *ListActiveEgressResponse) Reset()
func (*ListActiveEgressResponse) String ¶
func (x *ListActiveEgressResponse) String() string
type ListActiveIngressRequest ¶
type ListActiveIngressRequest struct {
// contains filtered or unexported fields
}
func (*ListActiveIngressRequest) Descriptor
deprecated
func (*ListActiveIngressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveIngressRequest.ProtoReflect.Descriptor instead.
func (*ListActiveIngressRequest) ProtoMessage ¶
func (*ListActiveIngressRequest) ProtoMessage()
func (*ListActiveIngressRequest) ProtoReflect ¶
func (x *ListActiveIngressRequest) ProtoReflect() protoreflect.Message
func (*ListActiveIngressRequest) Reset ¶
func (x *ListActiveIngressRequest) Reset()
func (*ListActiveIngressRequest) String ¶
func (x *ListActiveIngressRequest) String() string
type ListActiveIngressResponse ¶
type ListActiveIngressResponse struct { IngressIds []string `protobuf:"bytes,1,rep,name=ingress_ids,json=ingressIds,proto3" json:"ingress_ids,omitempty"` // contains filtered or unexported fields }
func (*ListActiveIngressResponse) Descriptor
deprecated
func (*ListActiveIngressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveIngressResponse.ProtoReflect.Descriptor instead.
func (*ListActiveIngressResponse) GetIngressIds ¶
func (x *ListActiveIngressResponse) GetIngressIds() []string
func (*ListActiveIngressResponse) ProtoMessage ¶
func (*ListActiveIngressResponse) ProtoMessage()
func (*ListActiveIngressResponse) ProtoReflect ¶
func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message
func (*ListActiveIngressResponse) Reset ¶
func (x *ListActiveIngressResponse) Reset()
func (*ListActiveIngressResponse) String ¶
func (x *ListActiveIngressResponse) String() string
type Race ¶
type Race[T any] struct { // contains filtered or unexported fields }
type RelaySignalRequest ¶ added in v1.4.3
type RelaySignalRequest struct { StartSession *livekit.StartSession `protobuf:"bytes,1,opt,name=start_session,json=startSession,proto3" json:"start_session,omitempty"` Requests []*livekit.SignalRequest `protobuf:"bytes,3,rep,name=requests,proto3" json:"requests,omitempty"` Seq uint64 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"` Close bool `protobuf:"varint,5,opt,name=close,proto3" json:"close,omitempty"` // contains filtered or unexported fields }
func (*RelaySignalRequest) Descriptor
deprecated
added in
v1.4.3
func (*RelaySignalRequest) Descriptor() ([]byte, []int)
Deprecated: Use RelaySignalRequest.ProtoReflect.Descriptor instead.
func (*RelaySignalRequest) GetClose ¶ added in v1.5.6
func (x *RelaySignalRequest) GetClose() bool
func (*RelaySignalRequest) GetRequests ¶ added in v1.5.3
func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest
func (*RelaySignalRequest) GetSeq ¶ added in v1.5.3
func (x *RelaySignalRequest) GetSeq() uint64
func (*RelaySignalRequest) GetStartSession ¶ added in v1.4.3
func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession
func (*RelaySignalRequest) ProtoMessage ¶ added in v1.4.3
func (*RelaySignalRequest) ProtoMessage()
func (*RelaySignalRequest) ProtoReflect ¶ added in v1.4.3
func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message
func (*RelaySignalRequest) Reset ¶ added in v1.4.3
func (x *RelaySignalRequest) Reset()
func (*RelaySignalRequest) String ¶ added in v1.4.3
func (x *RelaySignalRequest) String() string
type RelaySignalResponse ¶ added in v1.4.3
type RelaySignalResponse struct { Responses []*livekit.SignalResponse `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"` Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"` Close bool `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"` // contains filtered or unexported fields }
func (*RelaySignalResponse) Descriptor
deprecated
added in
v1.4.3
func (*RelaySignalResponse) Descriptor() ([]byte, []int)
Deprecated: Use RelaySignalResponse.ProtoReflect.Descriptor instead.
func (*RelaySignalResponse) GetClose ¶ added in v1.5.6
func (x *RelaySignalResponse) GetClose() bool
func (*RelaySignalResponse) GetResponses ¶ added in v1.5.2
func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse
func (*RelaySignalResponse) GetSeq ¶ added in v1.5.3
func (x *RelaySignalResponse) GetSeq() uint64
func (*RelaySignalResponse) ProtoMessage ¶ added in v1.4.3
func (*RelaySignalResponse) ProtoMessage()
func (*RelaySignalResponse) ProtoReflect ¶ added in v1.4.3
func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message
func (*RelaySignalResponse) Reset ¶ added in v1.4.3
func (x *RelaySignalResponse) Reset()
func (*RelaySignalResponse) String ¶ added in v1.4.3
func (x *RelaySignalResponse) String() string
type SignalClient ¶ added in v1.4.3
type SignalClient[NodeIdTopicType ~string] interface { RelaySignal(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error) }
func NewSignalClient ¶ added in v1.4.3
func NewSignalClient[NodeIdTopicType ~string](clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SignalClient[NodeIdTopicType], error)
NewSignalClient creates a psrpc client that implements the SignalClient interface.
type SignalServer ¶ added in v1.4.3
type SignalServer[NodeIdTopicType ~string] interface { RegisterRelaySignalTopic(nodeId NodeIdTopicType) error DeregisterRelaySignalTopic(nodeId NodeIdTopicType) // Close and wait for pending RPCs to complete Shutdown() // Close immediately, without waiting for pending RPCs Kill() }
func NewSignalServer ¶ added in v1.4.3
func NewSignalServer[NodeIdTopicType ~string](serverID string, svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SignalServer[NodeIdTopicType], error)
NewSignalServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type SignalServerImpl ¶ added in v1.4.3
type SignalServerImpl interface {
RelaySignal(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error
}
type StartEgressRequest ¶
type StartEgressRequest struct { // request metadata EgressId string `protobuf:"bytes,1,opt,name=egress_id,json=egressId,proto3" json:"egress_id,omitempty"` // request // // Types that are assignable to Request: // // *StartEgressRequest_RoomComposite // *StartEgressRequest_TrackComposite // *StartEgressRequest_Track // *StartEgressRequest_Web Request isStartEgressRequest_Request `protobuf_oneof:"request"` // connection info RoomId string `protobuf:"bytes,3,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` Token string `protobuf:"bytes,8,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,9,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` // metadata Metadata map[string]*anypb.Any `` /* 158-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StartEgressRequest) Descriptor
deprecated
func (*StartEgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartEgressRequest.ProtoReflect.Descriptor instead.
func (*StartEgressRequest) GetEgressId ¶
func (x *StartEgressRequest) GetEgressId() string
func (*StartEgressRequest) GetMetadata ¶ added in v1.5.10
func (x *StartEgressRequest) GetMetadata() map[string]*anypb.Any
func (*StartEgressRequest) 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_RoomComposite ¶
type StartEgressRequest_RoomComposite struct {
RoomComposite *livekit.RoomCompositeEgressRequest `protobuf:"bytes,5,opt,name=room_composite,json=roomComposite,proto3,oneof"`
}
type StartEgressRequest_Track ¶
type StartEgressRequest_Track struct {
Track *livekit.TrackEgressRequest `protobuf:"bytes,7,opt,name=track,proto3,oneof"`
}
type StartEgressRequest_TrackComposite ¶
type StartEgressRequest_TrackComposite struct {
TrackComposite *livekit.TrackCompositeEgressRequest `protobuf:"bytes,6,opt,name=track_composite,json=trackComposite,proto3,oneof"`
}
type StartEgressRequest_Web ¶
type StartEgressRequest_Web struct {
Web *livekit.WebEgressRequest `protobuf:"bytes,11,opt,name=web,proto3,oneof"`
}
type StartIngressRequest ¶ added in v1.6.0
type StartIngressRequest struct { Info *livekit.IngressInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` WsUrl string `protobuf:"bytes,3,opt,name=ws_url,json=wsUrl,proto3" json:"ws_url,omitempty"` // contains filtered or unexported fields }
func (*StartIngressRequest) Descriptor
deprecated
added in
v1.6.0
func (*StartIngressRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartIngressRequest.ProtoReflect.Descriptor instead.
func (*StartIngressRequest) GetInfo ¶ added in v1.6.0
func (x *StartIngressRequest) GetInfo() *livekit.IngressInfo
func (*StartIngressRequest) GetToken ¶ added in v1.6.0
func (x *StartIngressRequest) GetToken() string
func (*StartIngressRequest) GetWsUrl ¶ added in v1.6.0
func (x *StartIngressRequest) GetWsUrl() string
func (*StartIngressRequest) ProtoMessage ¶ added in v1.6.0
func (*StartIngressRequest) ProtoMessage()
func (*StartIngressRequest) ProtoReflect ¶ added in v1.6.0
func (x *StartIngressRequest) ProtoReflect() protoreflect.Message
func (*StartIngressRequest) Reset ¶ added in v1.6.0
func (x *StartIngressRequest) Reset()
func (*StartIngressRequest) String ¶ added in v1.6.0
func (x *StartIngressRequest) String() string
type TypedSignalClient ¶ added in v1.4.3
type TypedSignalClient = SignalClient[livekit.NodeID]
func NewTypedSignalClient ¶ added in v1.4.3
func NewTypedSignalClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error)
type TypedSignalServer ¶ added in v1.4.3
type TypedSignalServer = SignalServer[livekit.NodeID]
func NewTypedSignalServer ¶ added in v1.4.3
func NewTypedSignalServer(nodeID livekit.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (TypedSignalServer, error)
type UpdateIngressStateRequest ¶
type UpdateIngressStateRequest struct { IngressId string `protobuf:"bytes,1,opt,name=ingress_id,json=ingressId,proto3" json:"ingress_id,omitempty"` State *livekit.IngressState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
Request to store an update to the ingress state ingress -> service
func (*UpdateIngressStateRequest) Descriptor
deprecated
func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateIngressStateRequest.ProtoReflect.Descriptor instead.
func (*UpdateIngressStateRequest) GetIngressId ¶
func (x *UpdateIngressStateRequest) GetIngressId() string
func (*UpdateIngressStateRequest) GetState ¶
func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState
func (*UpdateIngressStateRequest) ProtoMessage ¶
func (*UpdateIngressStateRequest) ProtoMessage()
func (*UpdateIngressStateRequest) ProtoReflect ¶
func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
func (*UpdateIngressStateRequest) Reset ¶
func (x *UpdateIngressStateRequest) Reset()
func (*UpdateIngressStateRequest) String ¶
func (x *UpdateIngressStateRequest) String() string