Versions in this module Expand all Collapse all v1 v1.5.1 May 26, 2023 Changes in this version + 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 + type DeleteWHIPResourceRequest struct + ResourceId string + func (*DeleteWHIPResourceRequest) Descriptor() ([]byte, []int) + func (*DeleteWHIPResourceRequest) ProtoMessage() + func (x *DeleteWHIPResourceRequest) GetResourceId() string + func (x *DeleteWHIPResourceRequest) ProtoReflect() protoreflect.Message + func (x *DeleteWHIPResourceRequest) Reset() + func (x *DeleteWHIPResourceRequest) String() string + type EgressClient interface + func NewEgressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (EgressClient, error) + type EgressHandlerClient interface + StopEgress func(ctx context.Context, topic string, req *livekit1.StopEgressRequest, ...) (*livekit1.EgressInfo, error) + UpdateStream func(ctx context.Context, topic string, req *livekit1.UpdateStreamRequest, ...) (*livekit1.EgressInfo, error) + func NewEgressHandlerClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressHandlerClient, error) + type EgressHandlerServer interface + DeregisterStopEgressTopic func(topic string) + DeregisterUpdateStreamTopic func(topic string) + Kill func() + RegisterStopEgressTopic func(topic string) error + RegisterUpdateStreamTopic func(topic string) error + Shutdown func() + func NewEgressHandlerServer(serverID string, svc EgressHandlerServerImpl, bus psrpc.MessageBus, ...) (EgressHandlerServer, error) + type EgressHandlerServerImpl interface + StopEgress func(context.Context, *livekit1.StopEgressRequest) (*livekit1.EgressInfo, error) + UpdateStream func(context.Context, *livekit1.UpdateStreamRequest) (*livekit1.EgressInfo, error) + type EgressInternalClient interface + ListActiveEgress func(ctx context.Context, req *ListActiveEgressRequest, opts ...psrpc.RequestOption) (<-chan *psrpc.Response[*ListActiveEgressResponse], error) + StartEgress func(ctx context.Context, topic string, req *StartEgressRequest, ...) (*livekit1.EgressInfo, error) + func NewEgressInternalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EgressInternalClient, error) + type EgressInternalServer interface + DeregisterStartEgressTopic func(topic string) + Kill func() + RegisterStartEgressTopic func(topic string) error + Shutdown func() + func NewEgressInternalServer(serverID string, svc EgressInternalServerImpl, bus psrpc.MessageBus, ...) (EgressInternalServer, error) + type EgressInternalServerImpl interface + ListActiveEgress func(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) + StartEgress func(context.Context, *StartEgressRequest) (*livekit1.EgressInfo, error) + StartEgressAffinity func(*StartEgressRequest) float32 + type GetIngressInfoRequest struct + IngressId string + StreamKey string + func (*GetIngressInfoRequest) Descriptor() ([]byte, []int) + func (*GetIngressInfoRequest) ProtoMessage() + func (x *GetIngressInfoRequest) GetIngressId() string + func (x *GetIngressInfoRequest) GetStreamKey() string + func (x *GetIngressInfoRequest) ProtoReflect() protoreflect.Message + func (x *GetIngressInfoRequest) Reset() + func (x *GetIngressInfoRequest) String() string + type GetIngressInfoResponse struct + Info *livekit.IngressInfo + Token string + WsUrl string + func (*GetIngressInfoResponse) Descriptor() ([]byte, []int) + func (*GetIngressInfoResponse) ProtoMessage() + func (x *GetIngressInfoResponse) GetInfo() *livekit.IngressInfo + func (x *GetIngressInfoResponse) GetToken() string + func (x *GetIngressInfoResponse) GetWsUrl() string + func (x *GetIngressInfoResponse) ProtoReflect() protoreflect.Message + func (x *GetIngressInfoResponse) Reset() + func (x *GetIngressInfoResponse) String() string + type IOInfoClient interface + GetIngressInfo func(ctx context.Context, req *GetIngressInfoRequest, opts ...psrpc.RequestOption) (*GetIngressInfoResponse, error) + UpdateEgressInfo func(ctx context.Context, req *livekit1.EgressInfo, opts ...psrpc.RequestOption) (*google_protobuf2.Empty, error) + UpdateIngressState func(ctx context.Context, req *UpdateIngressStateRequest, ...) (*google_protobuf2.Empty, error) + func NewIOInfoClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IOInfoClient, error) + type IOInfoServer interface + Kill func() + Shutdown func() + func NewIOInfoServer(serverID string, svc IOInfoServerImpl, bus psrpc.MessageBus, ...) (IOInfoServer, error) + type IOInfoServerImpl interface + GetIngressInfo func(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) + UpdateEgressInfo func(context.Context, *livekit1.EgressInfo) (*google_protobuf2.Empty, error) + UpdateIngressState func(context.Context, *UpdateIngressStateRequest) (*google_protobuf2.Empty, error) + type IngressClient interface + func NewIngressClient(nodeID livekit.NodeID, bus psrpc.MessageBus) (IngressClient, error) + type IngressHandlerClient interface + DeleteIngress func(ctx context.Context, topic string, req *livekit2.DeleteIngressRequest, ...) (*livekit2.IngressState, error) + DeleteWHIPResource func(ctx context.Context, topic string, req *DeleteWHIPResourceRequest, ...) (*google_protobuf2.Empty, error) + UpdateIngress func(ctx context.Context, topic string, req *livekit2.UpdateIngressRequest, ...) (*livekit2.IngressState, error) + func NewIngressHandlerClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressHandlerClient, error) + type IngressHandlerServer interface + DeregisterDeleteIngressTopic func(topic string) + DeregisterDeleteWHIPResourceTopic func(topic string) + DeregisterUpdateIngressTopic func(topic string) + Kill func() + RegisterDeleteIngressTopic func(topic string) error + RegisterDeleteWHIPResourceTopic func(topic string) error + RegisterUpdateIngressTopic func(topic string) error + Shutdown func() + func NewIngressHandlerServer(serverID string, svc IngressHandlerServerImpl, bus psrpc.MessageBus, ...) (IngressHandlerServer, error) + type IngressHandlerServerImpl interface + DeleteIngress func(context.Context, *livekit2.DeleteIngressRequest) (*livekit2.IngressState, error) + DeleteWHIPResource func(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf2.Empty, error) + UpdateIngress func(context.Context, *livekit2.UpdateIngressRequest) (*livekit2.IngressState, error) + type IngressInternalClient interface + ListActiveIngress func(ctx context.Context, req *ListActiveIngressRequest, ...) (<-chan *psrpc.Response[*ListActiveIngressResponse], error) + func NewIngressInternalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (IngressInternalClient, error) + type IngressInternalServer interface + Kill func() + Shutdown func() + func NewIngressInternalServer(serverID string, svc IngressInternalServerImpl, bus psrpc.MessageBus, ...) (IngressInternalServer, error) + type IngressInternalServerImpl interface + ListActiveIngress func(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) + type ListActiveEgressRequest struct + func (*ListActiveEgressRequest) Descriptor() ([]byte, []int) + func (*ListActiveEgressRequest) ProtoMessage() + func (x *ListActiveEgressRequest) ProtoReflect() protoreflect.Message + func (x *ListActiveEgressRequest) Reset() + func (x *ListActiveEgressRequest) String() string + type ListActiveEgressResponse struct + EgressIds []string + func (*ListActiveEgressResponse) Descriptor() ([]byte, []int) + func (*ListActiveEgressResponse) ProtoMessage() + func (x *ListActiveEgressResponse) GetEgressIds() []string + func (x *ListActiveEgressResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveEgressResponse) Reset() + func (x *ListActiveEgressResponse) String() string + type ListActiveIngressRequest struct + func (*ListActiveIngressRequest) Descriptor() ([]byte, []int) + func (*ListActiveIngressRequest) ProtoMessage() + func (x *ListActiveIngressRequest) ProtoReflect() protoreflect.Message + func (x *ListActiveIngressRequest) Reset() + func (x *ListActiveIngressRequest) String() string + type ListActiveIngressResponse struct + IngressIds []string + func (*ListActiveIngressResponse) Descriptor() ([]byte, []int) + func (*ListActiveIngressResponse) ProtoMessage() + func (x *ListActiveIngressResponse) GetIngressIds() []string + func (x *ListActiveIngressResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveIngressResponse) Reset() + func (x *ListActiveIngressResponse) String() string + type Race struct + func NewRace(ctx context.Context) *Race[T] + func (r *Race[T]) Go(fn func(ctx context.Context) (*T, error)) + func (r *Race[T]) Wait() (int, *T, error) + type RelaySignalRequest struct + Close bool + Requests []*livekit.SignalRequest + Seq uint64 + StartSession *livekit.StartSession + func (*RelaySignalRequest) Descriptor() ([]byte, []int) + func (*RelaySignalRequest) ProtoMessage() + func (x *RelaySignalRequest) GetClose() bool + func (x *RelaySignalRequest) GetRequests() []*livekit.SignalRequest + func (x *RelaySignalRequest) GetSeq() uint64 + func (x *RelaySignalRequest) GetStartSession() *livekit.StartSession + func (x *RelaySignalRequest) ProtoReflect() protoreflect.Message + func (x *RelaySignalRequest) Reset() + func (x *RelaySignalRequest) String() string + type RelaySignalResponse struct + Close bool + Responses []*livekit.SignalResponse + Seq uint64 + func (*RelaySignalResponse) Descriptor() ([]byte, []int) + func (*RelaySignalResponse) ProtoMessage() + func (x *RelaySignalResponse) GetClose() bool + func (x *RelaySignalResponse) GetResponses() []*livekit.SignalResponse + func (x *RelaySignalResponse) GetSeq() uint64 + func (x *RelaySignalResponse) ProtoReflect() protoreflect.Message + func (x *RelaySignalResponse) Reset() + func (x *RelaySignalResponse) String() string + type SignalClient interface + RelaySignal func(ctx context.Context, nodeId NodeIdTopicType, opts ...psrpc.RequestOption) (psrpc.ClientStream[*RelaySignalRequest, *RelaySignalResponse], error) + func NewSignalClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SignalClient[NodeIdTopicType], error) + type SignalServer interface + DeregisterRelaySignalTopic func(nodeId NodeIdTopicType) + Kill func() + RegisterRelaySignalTopic func(nodeId NodeIdTopicType) error + Shutdown func() + func NewSignalServer(serverID string, svc SignalServerImpl, bus psrpc.MessageBus, ...) (SignalServer[NodeIdTopicType], error) + type SignalServerImpl interface + RelaySignal func(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error + type StartEgressRequest struct + EgressId string + Request isStartEgressRequest_Request + RoomId string + Token string + WsUrl string + func (*StartEgressRequest) Descriptor() ([]byte, []int) + func (*StartEgressRequest) ProtoMessage() + func (m *StartEgressRequest) GetRequest() isStartEgressRequest_Request + func (x *StartEgressRequest) GetEgressId() string + 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 (x *StartEgressRequest) ProtoReflect() protoreflect.Message + func (x *StartEgressRequest) Reset() + func (x *StartEgressRequest) String() string + type StartEgressRequest_RoomComposite struct + RoomComposite *livekit.RoomCompositeEgressRequest + type StartEgressRequest_Track struct + Track *livekit.TrackEgressRequest + type StartEgressRequest_TrackComposite struct + TrackComposite *livekit.TrackCompositeEgressRequest + type StartEgressRequest_Web struct + Web *livekit.WebEgressRequest + type TypedSignalClient = SignalClient[livekit.NodeID] + func NewTypedSignalClient(nodeID livekit.NodeID, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (TypedSignalClient, error) + type TypedSignalServer = SignalServer[livekit.NodeID] + func NewTypedSignalServer(nodeID livekit.NodeID, svc SignalServerImpl, bus psrpc.MessageBus, ...) (TypedSignalServer, error) + type UpdateIngressStateRequest struct + IngressId string + State *livekit.IngressState + func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int) + func (*UpdateIngressStateRequest) ProtoMessage() + func (x *UpdateIngressStateRequest) GetIngressId() string + func (x *UpdateIngressStateRequest) GetState() *livekit.IngressState + func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message + func (x *UpdateIngressStateRequest) Reset() + func (x *UpdateIngressStateRequest) String() string
Go to main page