Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterIngressHandlerServer(s grpc.ServiceRegistrar, srv IngressHandlerServer)
- func RegisterIngressServiceServer(s grpc.ServiceRegistrar, srv IngressServiceServer)
- func StartHandlerServer(tmpDir string, h IngressHandlerServer) error
- func StartServiceServer(tmpDir string, h IngressServiceServer) (*grpc.Server, error)
- type GatherMediaStatsRequest
- type GatherMediaStatsResponse
- func (*GatherMediaStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GatherMediaStatsResponse) GetStats() *MediaStats
- func (*GatherMediaStatsResponse) ProtoMessage()
- func (x *GatherMediaStatsResponse) ProtoReflect() protoreflect.Message
- func (x *GatherMediaStatsResponse) Reset()
- func (x *GatherMediaStatsResponse) String() string
- type GstPipelineDebugDotRequest
- type GstPipelineDebugDotResponse
- func (*GstPipelineDebugDotResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GstPipelineDebugDotResponse) GetDotFile() string
- func (*GstPipelineDebugDotResponse) ProtoMessage()
- func (x *GstPipelineDebugDotResponse) ProtoReflect() protoreflect.Message
- func (x *GstPipelineDebugDotResponse) Reset()
- func (x *GstPipelineDebugDotResponse) String() string
- type IngressHandlerClient
- type IngressHandlerClientWrapper
- type IngressHandlerServer
- type IngressServiceClient
- type IngressServiceServer
- type JitterStats
- func (*JitterStats) Descriptor() ([]byte, []int)deprecated
- func (x *JitterStats) GetP50() float64
- func (x *JitterStats) GetP90() float64
- func (x *JitterStats) GetP99() float64
- func (*JitterStats) ProtoMessage()
- func (x *JitterStats) ProtoReflect() protoreflect.Message
- func (x *JitterStats) Reset()
- func (x *JitterStats) String() string
- type KillIngressRequest
- type KillIngressResponse
- func (*KillIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KillIngressResponse) GetState() *livekit.IngressState
- func (*KillIngressResponse) ProtoMessage()
- func (x *KillIngressResponse) ProtoReflect() protoreflect.Message
- func (x *KillIngressResponse) Reset()
- func (x *KillIngressResponse) String() string
- type MediaStats
- type PProfRequest
- func (*PProfRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PProfRequest) GetDebug() int32
- func (x *PProfRequest) GetProfileName() string
- func (x *PProfRequest) GetTimeout() int32
- func (*PProfRequest) ProtoMessage()
- func (x *PProfRequest) ProtoReflect() protoreflect.Message
- func (x *PProfRequest) Reset()
- func (x *PProfRequest) String() string
- type PProfResponse
- type TrackStats
- func (*TrackStats) Descriptor() ([]byte, []int)deprecated
- func (x *TrackStats) GetAverageBitrate() uint32
- func (x *TrackStats) GetCurrentBitrate() uint32
- func (x *TrackStats) GetCurrentLossRate() float64
- func (x *TrackStats) GetCurrentPackets() uint64
- func (x *TrackStats) GetCurrentPli() uint64
- func (x *TrackStats) GetJitter() *JitterStats
- func (x *TrackStats) GetPacketLatencySeconds() []float64
- func (x *TrackStats) GetTotalLossRate() float64
- func (x *TrackStats) GetTotalPackets() uint64
- func (x *TrackStats) GetTotalPli() uint64
- func (*TrackStats) ProtoMessage()
- func (x *TrackStats) ProtoReflect() protoreflect.Message
- func (x *TrackStats) Reset()
- func (x *TrackStats) String() string
- type UnimplementedIngressHandlerServer
- func (UnimplementedIngressHandlerServer) GatherMediaStats(context.Context, *GatherMediaStatsRequest) (*GatherMediaStatsResponse, error)
- func (UnimplementedIngressHandlerServer) GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)
- func (UnimplementedIngressHandlerServer) GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)
- func (UnimplementedIngressHandlerServer) KillIngress(context.Context, *KillIngressRequest) (*KillIngressResponse, error)
- func (UnimplementedIngressHandlerServer) UpdateMediaStats(context.Context, *UpdateMediaStatsRequest) (*emptypb.Empty, error)
- type UnimplementedIngressServiceServer
- type UnsafeIngressHandlerServer
- type UnsafeIngressServiceServer
- type UpdateIngressStateRequest
- func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIngressStateRequest) GetInfo() *livekit.IngressInfo
- func (x *UpdateIngressStateRequest) GetProjectId() string
- func (*UpdateIngressStateRequest) ProtoMessage()
- func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateIngressStateRequest) Reset()
- func (x *UpdateIngressStateRequest) String() string
- type UpdateMediaStatsRequest
- func (*UpdateMediaStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMediaStatsRequest) GetStats() *MediaStats
- func (*UpdateMediaStatsRequest) ProtoMessage()
- func (x *UpdateMediaStatsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMediaStatsRequest) Reset()
- func (x *UpdateMediaStatsRequest) String() string
Constants ¶
const ( IngressHandler_GetPipelineDot_FullMethodName = "/ipc.IngressHandler/GetPipelineDot" IngressHandler_GetPProf_FullMethodName = "/ipc.IngressHandler/GetPProf" IngressHandler_GatherMediaStats_FullMethodName = "/ipc.IngressHandler/GatherMediaStats" IngressHandler_UpdateMediaStats_FullMethodName = "/ipc.IngressHandler/UpdateMediaStats" IngressHandler_KillIngress_FullMethodName = "/ipc.IngressHandler/KillIngress" )
const (
IngressService_UpdateIngressState_FullMethodName = "/ipc.IngressService/UpdateIngressState"
)
Variables ¶
var File_ipc_proto protoreflect.FileDescriptor
var IngressHandler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ipc.IngressHandler", HandlerType: (*IngressHandlerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetPipelineDot", Handler: _IngressHandler_GetPipelineDot_Handler, }, { MethodName: "GetPProf", Handler: _IngressHandler_GetPProf_Handler, }, { MethodName: "GatherMediaStats", Handler: _IngressHandler_GatherMediaStats_Handler, }, { MethodName: "UpdateMediaStats", Handler: _IngressHandler_UpdateMediaStats_Handler, }, { MethodName: "KillIngress", Handler: _IngressHandler_KillIngress_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ipc.proto", }
IngressHandler_ServiceDesc is the grpc.ServiceDesc for IngressHandler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var IngressService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ipc.IngressService", HandlerType: (*IngressServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateIngressState", Handler: _IngressService_UpdateIngressState_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ipc.proto", }
IngressService_ServiceDesc is the grpc.ServiceDesc for IngressService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIngressHandlerServer ¶
func RegisterIngressHandlerServer(s grpc.ServiceRegistrar, srv IngressHandlerServer)
func RegisterIngressServiceServer ¶ added in v1.5.0
func RegisterIngressServiceServer(s grpc.ServiceRegistrar, srv IngressServiceServer)
func StartHandlerServer ¶ added in v1.5.0
func StartHandlerServer(tmpDir string, h IngressHandlerServer) error
func StartServiceServer ¶ added in v1.5.0
func StartServiceServer(tmpDir string, h IngressServiceServer) (*grpc.Server, error)
Types ¶
type GatherMediaStatsRequest ¶ added in v1.3.0
type GatherMediaStatsRequest struct {
// contains filtered or unexported fields
}
func (*GatherMediaStatsRequest) Descriptor
deprecated
added in
v1.3.0
func (*GatherMediaStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GatherMediaStatsRequest.ProtoReflect.Descriptor instead.
func (*GatherMediaStatsRequest) ProtoMessage ¶ added in v1.3.0
func (*GatherMediaStatsRequest) ProtoMessage()
func (*GatherMediaStatsRequest) ProtoReflect ¶ added in v1.3.0
func (x *GatherMediaStatsRequest) ProtoReflect() protoreflect.Message
func (*GatherMediaStatsRequest) Reset ¶ added in v1.3.0
func (x *GatherMediaStatsRequest) Reset()
func (*GatherMediaStatsRequest) String ¶ added in v1.3.0
func (x *GatherMediaStatsRequest) String() string
type GatherMediaStatsResponse ¶ added in v1.3.0
type GatherMediaStatsResponse struct {
Stats *MediaStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*GatherMediaStatsResponse) Descriptor
deprecated
added in
v1.3.0
func (*GatherMediaStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GatherMediaStatsResponse.ProtoReflect.Descriptor instead.
func (*GatherMediaStatsResponse) GetStats ¶ added in v1.3.0
func (x *GatherMediaStatsResponse) GetStats() *MediaStats
func (*GatherMediaStatsResponse) ProtoMessage ¶ added in v1.3.0
func (*GatherMediaStatsResponse) ProtoMessage()
func (*GatherMediaStatsResponse) ProtoReflect ¶ added in v1.3.0
func (x *GatherMediaStatsResponse) ProtoReflect() protoreflect.Message
func (*GatherMediaStatsResponse) Reset ¶ added in v1.3.0
func (x *GatherMediaStatsResponse) Reset()
func (*GatherMediaStatsResponse) String ¶ added in v1.3.0
func (x *GatherMediaStatsResponse) String() string
type GstPipelineDebugDotRequest ¶
type GstPipelineDebugDotRequest struct {
// contains filtered or unexported fields
}
func (*GstPipelineDebugDotRequest) Descriptor
deprecated
func (*GstPipelineDebugDotRequest) Descriptor() ([]byte, []int)
Deprecated: Use GstPipelineDebugDotRequest.ProtoReflect.Descriptor instead.
func (*GstPipelineDebugDotRequest) ProtoMessage ¶
func (*GstPipelineDebugDotRequest) ProtoMessage()
func (*GstPipelineDebugDotRequest) ProtoReflect ¶
func (x *GstPipelineDebugDotRequest) ProtoReflect() protoreflect.Message
func (*GstPipelineDebugDotRequest) Reset ¶
func (x *GstPipelineDebugDotRequest) Reset()
func (*GstPipelineDebugDotRequest) String ¶
func (x *GstPipelineDebugDotRequest) String() string
type GstPipelineDebugDotResponse ¶
type GstPipelineDebugDotResponse struct {
DotFile string `protobuf:"bytes,1,opt,name=dot_file,json=dotFile,proto3" json:"dot_file,omitempty"`
// contains filtered or unexported fields
}
func (*GstPipelineDebugDotResponse) Descriptor
deprecated
func (*GstPipelineDebugDotResponse) Descriptor() ([]byte, []int)
Deprecated: Use GstPipelineDebugDotResponse.ProtoReflect.Descriptor instead.
func (*GstPipelineDebugDotResponse) GetDotFile ¶
func (x *GstPipelineDebugDotResponse) GetDotFile() string
func (*GstPipelineDebugDotResponse) ProtoMessage ¶
func (*GstPipelineDebugDotResponse) ProtoMessage()
func (*GstPipelineDebugDotResponse) ProtoReflect ¶
func (x *GstPipelineDebugDotResponse) ProtoReflect() protoreflect.Message
func (*GstPipelineDebugDotResponse) Reset ¶
func (x *GstPipelineDebugDotResponse) Reset()
func (*GstPipelineDebugDotResponse) String ¶
func (x *GstPipelineDebugDotResponse) String() string
type IngressHandlerClient ¶
type IngressHandlerClient interface {
GetPipelineDot(ctx context.Context, in *GstPipelineDebugDotRequest, opts ...grpc.CallOption) (*GstPipelineDebugDotResponse, error)
GetPProf(ctx context.Context, in *PProfRequest, opts ...grpc.CallOption) (*PProfResponse, error)
GatherMediaStats(ctx context.Context, in *GatherMediaStatsRequest, opts ...grpc.CallOption) (*GatherMediaStatsResponse, error)
UpdateMediaStats(ctx context.Context, in *UpdateMediaStatsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
KillIngress(ctx context.Context, in *KillIngressRequest, opts ...grpc.CallOption) (*KillIngressResponse, error)
}
IngressHandlerClient is the client API for IngressHandler 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 NewIngressHandlerClient ¶
func NewIngressHandlerClient(cc grpc.ClientConnInterface) IngressHandlerClient
type IngressHandlerClientWrapper ¶ added in v1.5.0
type IngressHandlerClientWrapper struct {
IngressHandlerClient
// contains filtered or unexported fields
}
func GetHandlerClient ¶ added in v1.5.0
func GetHandlerClient(tmpDir string) (*IngressHandlerClientWrapper, error)
func (*IngressHandlerClientWrapper) Close ¶ added in v1.5.0
func (ihc *IngressHandlerClientWrapper) Close() error
type IngressHandlerServer ¶
type IngressHandlerServer interface {
GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)
GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)
GatherMediaStats(context.Context, *GatherMediaStatsRequest) (*GatherMediaStatsResponse, error)
UpdateMediaStats(context.Context, *UpdateMediaStatsRequest) (*emptypb.Empty, error)
KillIngress(context.Context, *KillIngressRequest) (*KillIngressResponse, error)
// contains filtered or unexported methods
}
IngressHandlerServer is the server API for IngressHandler service. All implementations must embed UnimplementedIngressHandlerServer for forward compatibility.
type IngressServiceClient ¶ added in v1.5.0
type IngressServiceClient interface {
UpdateIngressState(ctx context.Context, in *UpdateIngressStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
IngressServiceClient is the client API for IngressService 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 GetServiceClient ¶ added in v1.5.0
func GetServiceClient(tmpDir string) (IngressServiceClient, error)
func NewIngressServiceClient ¶ added in v1.5.0
func NewIngressServiceClient(cc grpc.ClientConnInterface) IngressServiceClient
type IngressServiceServer ¶ added in v1.5.0
type IngressServiceServer interface {
UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*emptypb.Empty, error)
// contains filtered or unexported methods
}
IngressServiceServer is the server API for IngressService service. All implementations must embed UnimplementedIngressServiceServer for forward compatibility.
type JitterStats ¶ added in v1.3.0
type JitterStats struct {
P50 float64 `protobuf:"fixed64,1,opt,name=p50,proto3" json:"p50,omitempty"` // in ms
P90 float64 `protobuf:"fixed64,2,opt,name=p90,proto3" json:"p90,omitempty"`
P99 float64 `protobuf:"fixed64,3,opt,name=p99,proto3" json:"p99,omitempty"`
// contains filtered or unexported fields
}
func (*JitterStats) Descriptor
deprecated
added in
v1.3.0
func (*JitterStats) Descriptor() ([]byte, []int)
Deprecated: Use JitterStats.ProtoReflect.Descriptor instead.
func (*JitterStats) GetP50 ¶ added in v1.3.0
func (x *JitterStats) GetP50() float64
func (*JitterStats) GetP90 ¶ added in v1.3.0
func (x *JitterStats) GetP90() float64
func (*JitterStats) GetP99 ¶ added in v1.3.0
func (x *JitterStats) GetP99() float64
func (*JitterStats) ProtoMessage ¶ added in v1.3.0
func (*JitterStats) ProtoMessage()
func (*JitterStats) ProtoReflect ¶ added in v1.3.0
func (x *JitterStats) ProtoReflect() protoreflect.Message
func (*JitterStats) Reset ¶ added in v1.3.0
func (x *JitterStats) Reset()
func (*JitterStats) String ¶ added in v1.3.0
func (x *JitterStats) String() string
type KillIngressRequest ¶ added in v1.5.0
type KillIngressRequest struct {
// contains filtered or unexported fields
}
func (*KillIngressRequest) Descriptor
deprecated
added in
v1.5.0
func (*KillIngressRequest) Descriptor() ([]byte, []int)
Deprecated: Use KillIngressRequest.ProtoReflect.Descriptor instead.
func (*KillIngressRequest) ProtoMessage ¶ added in v1.5.0
func (*KillIngressRequest) ProtoMessage()
func (*KillIngressRequest) ProtoReflect ¶ added in v1.5.0
func (x *KillIngressRequest) ProtoReflect() protoreflect.Message
func (*KillIngressRequest) Reset ¶ added in v1.5.0
func (x *KillIngressRequest) Reset()
func (*KillIngressRequest) String ¶ added in v1.5.0
func (x *KillIngressRequest) String() string
type KillIngressResponse ¶ added in v1.5.0
type KillIngressResponse struct {
State *livekit.IngressState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*KillIngressResponse) Descriptor
deprecated
added in
v1.5.0
func (*KillIngressResponse) Descriptor() ([]byte, []int)
Deprecated: Use KillIngressResponse.ProtoReflect.Descriptor instead.
func (*KillIngressResponse) GetState ¶ added in v1.5.0
func (x *KillIngressResponse) GetState() *livekit.IngressState
func (*KillIngressResponse) ProtoMessage ¶ added in v1.5.0
func (*KillIngressResponse) ProtoMessage()
func (*KillIngressResponse) ProtoReflect ¶ added in v1.5.0
func (x *KillIngressResponse) ProtoReflect() protoreflect.Message
func (*KillIngressResponse) Reset ¶ added in v1.5.0
func (x *KillIngressResponse) Reset()
func (*KillIngressResponse) String ¶ added in v1.5.0
func (x *KillIngressResponse) String() string
type MediaStats ¶ added in v1.3.0
type MediaStats struct {
TrackStats map[string]*TrackStats `` /* 165-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*MediaStats) Descriptor
deprecated
added in
v1.3.0
func (*MediaStats) Descriptor() ([]byte, []int)
Deprecated: Use MediaStats.ProtoReflect.Descriptor instead.
func (*MediaStats) GetTrackStats ¶ added in v1.3.0
func (x *MediaStats) GetTrackStats() map[string]*TrackStats
func (*MediaStats) ProtoMessage ¶ added in v1.3.0
func (*MediaStats) ProtoMessage()
func (*MediaStats) ProtoReflect ¶ added in v1.3.0
func (x *MediaStats) ProtoReflect() protoreflect.Message
func (*MediaStats) Reset ¶ added in v1.3.0
func (x *MediaStats) Reset()
func (*MediaStats) String ¶ added in v1.3.0
func (x *MediaStats) String() string
type PProfRequest ¶
type PProfRequest struct {
ProfileName string `protobuf:"bytes,1,opt,name=profile_name,json=profileName,proto3" json:"profile_name,omitempty"`
Timeout int32 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
Debug int32 `protobuf:"varint,3,opt,name=debug,proto3" json:"debug,omitempty"`
// contains filtered or unexported fields
}
func (*PProfRequest) Descriptor
deprecated
func (*PProfRequest) Descriptor() ([]byte, []int)
Deprecated: Use PProfRequest.ProtoReflect.Descriptor instead.
func (*PProfRequest) GetDebug ¶
func (x *PProfRequest) GetDebug() int32
func (*PProfRequest) GetProfileName ¶
func (x *PProfRequest) GetProfileName() string
func (*PProfRequest) GetTimeout ¶
func (x *PProfRequest) GetTimeout() int32
func (*PProfRequest) ProtoMessage ¶
func (*PProfRequest) ProtoMessage()
func (*PProfRequest) ProtoReflect ¶
func (x *PProfRequest) ProtoReflect() protoreflect.Message
func (*PProfRequest) Reset ¶
func (x *PProfRequest) Reset()
func (*PProfRequest) String ¶
func (x *PProfRequest) String() string
type PProfResponse ¶
type PProfResponse struct {
PprofFile []byte `protobuf:"bytes,1,opt,name=pprof_file,json=pprofFile,proto3" json:"pprof_file,omitempty"`
// contains filtered or unexported fields
}
func (*PProfResponse) Descriptor
deprecated
func (*PProfResponse) Descriptor() ([]byte, []int)
Deprecated: Use PProfResponse.ProtoReflect.Descriptor instead.
func (*PProfResponse) GetPprofFile ¶
func (x *PProfResponse) GetPprofFile() []byte
func (*PProfResponse) ProtoMessage ¶
func (*PProfResponse) ProtoMessage()
func (*PProfResponse) ProtoReflect ¶
func (x *PProfResponse) ProtoReflect() protoreflect.Message
func (*PProfResponse) Reset ¶
func (x *PProfResponse) Reset()
func (*PProfResponse) String ¶
func (x *PProfResponse) String() string
type TrackStats ¶ added in v1.3.0
type TrackStats struct {
AverageBitrate uint32 `protobuf:"varint,1,opt,name=average_bitrate,json=averageBitrate,proto3" json:"average_bitrate,omitempty"`
CurrentBitrate uint32 `protobuf:"varint,2,opt,name=current_bitrate,json=currentBitrate,proto3" json:"current_bitrate,omitempty"`
TotalPackets uint64 `protobuf:"varint,4,opt,name=total_packets,json=totalPackets,proto3" json:"total_packets,omitempty"`
CurrentPackets uint64 `protobuf:"varint,5,opt,name=current_packets,json=currentPackets,proto3" json:"current_packets,omitempty"`
TotalLossRate float64 `protobuf:"fixed64,6,opt,name=total_loss_rate,json=totalLossRate,proto3" json:"total_loss_rate,omitempty"`
CurrentLossRate float64 `protobuf:"fixed64,7,opt,name=current_loss_rate,json=currentLossRate,proto3" json:"current_loss_rate,omitempty"`
TotalPli uint64 `protobuf:"varint,8,opt,name=total_pli,json=totalPli,proto3" json:"total_pli,omitempty"`
CurrentPli uint64 `protobuf:"varint,9,opt,name=current_pli,json=currentPli,proto3" json:"current_pli,omitempty"`
Jitter *JitterStats `protobuf:"bytes,10,opt,name=jitter,proto3" json:"jitter,omitempty"`
PacketLatencySeconds []float64 `` /* 133-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*TrackStats) Descriptor
deprecated
added in
v1.3.0
func (*TrackStats) Descriptor() ([]byte, []int)
Deprecated: Use TrackStats.ProtoReflect.Descriptor instead.
func (*TrackStats) GetAverageBitrate ¶ added in v1.3.0
func (x *TrackStats) GetAverageBitrate() uint32
func (*TrackStats) GetCurrentBitrate ¶ added in v1.3.0
func (x *TrackStats) GetCurrentBitrate() uint32
func (*TrackStats) GetCurrentLossRate ¶ added in v1.3.0
func (x *TrackStats) GetCurrentLossRate() float64
func (*TrackStats) GetCurrentPackets ¶ added in v1.3.0
func (x *TrackStats) GetCurrentPackets() uint64
func (*TrackStats) GetCurrentPli ¶ added in v1.4.0
func (x *TrackStats) GetCurrentPli() uint64
func (*TrackStats) GetJitter ¶ added in v1.3.0
func (x *TrackStats) GetJitter() *JitterStats
func (*TrackStats) GetPacketLatencySeconds ¶ added in v1.5.0
func (x *TrackStats) GetPacketLatencySeconds() []float64
func (*TrackStats) GetTotalLossRate ¶ added in v1.3.0
func (x *TrackStats) GetTotalLossRate() float64
func (*TrackStats) GetTotalPackets ¶ added in v1.3.0
func (x *TrackStats) GetTotalPackets() uint64
func (*TrackStats) GetTotalPli ¶ added in v1.4.0
func (x *TrackStats) GetTotalPli() uint64
func (*TrackStats) ProtoMessage ¶ added in v1.3.0
func (*TrackStats) ProtoMessage()
func (*TrackStats) ProtoReflect ¶ added in v1.3.0
func (x *TrackStats) ProtoReflect() protoreflect.Message
func (*TrackStats) Reset ¶ added in v1.3.0
func (x *TrackStats) Reset()
func (*TrackStats) String ¶ added in v1.3.0
func (x *TrackStats) String() string
type UnimplementedIngressHandlerServer ¶
type UnimplementedIngressHandlerServer struct{}
UnimplementedIngressHandlerServer 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 (UnimplementedIngressHandlerServer) GatherMediaStats ¶ added in v1.3.0
func (UnimplementedIngressHandlerServer) GatherMediaStats(context.Context, *GatherMediaStatsRequest) (*GatherMediaStatsResponse, error)
func (UnimplementedIngressHandlerServer) GetPProf ¶
func (UnimplementedIngressHandlerServer) GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)
func (UnimplementedIngressHandlerServer) GetPipelineDot ¶
func (UnimplementedIngressHandlerServer) GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)
func (UnimplementedIngressHandlerServer) KillIngress ¶ added in v1.5.0
func (UnimplementedIngressHandlerServer) KillIngress(context.Context, *KillIngressRequest) (*KillIngressResponse, error)
func (UnimplementedIngressHandlerServer) UpdateMediaStats ¶
func (UnimplementedIngressHandlerServer) UpdateMediaStats(context.Context, *UpdateMediaStatsRequest) (*emptypb.Empty, error)
type UnimplementedIngressServiceServer ¶ added in v1.5.0
type UnimplementedIngressServiceServer struct{}
UnimplementedIngressServiceServer 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 (UnimplementedIngressServiceServer) UpdateIngressState ¶ added in v1.5.0
func (UnimplementedIngressServiceServer) UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*emptypb.Empty, error)
type UnsafeIngressHandlerServer ¶
type UnsafeIngressHandlerServer interface {
// contains filtered or unexported methods
}
UnsafeIngressHandlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressHandlerServer will result in compilation errors.
type UnsafeIngressServiceServer ¶ added in v1.5.0
type UnsafeIngressServiceServer interface {
// contains filtered or unexported methods
}
UnsafeIngressServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressServiceServer will result in compilation errors.
type UpdateIngressStateRequest ¶ added in v1.5.0
type UpdateIngressStateRequest struct {
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
Info *livekit.IngressInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateIngressStateRequest) Descriptor
deprecated
added in
v1.5.0
func (*UpdateIngressStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateIngressStateRequest.ProtoReflect.Descriptor instead.
func (*UpdateIngressStateRequest) GetInfo ¶ added in v1.5.0
func (x *UpdateIngressStateRequest) GetInfo() *livekit.IngressInfo
func (*UpdateIngressStateRequest) GetProjectId ¶ added in v1.5.0
func (x *UpdateIngressStateRequest) GetProjectId() string
func (*UpdateIngressStateRequest) ProtoMessage ¶ added in v1.5.0
func (*UpdateIngressStateRequest) ProtoMessage()
func (*UpdateIngressStateRequest) ProtoReflect ¶ added in v1.5.0
func (x *UpdateIngressStateRequest) ProtoReflect() protoreflect.Message
func (*UpdateIngressStateRequest) Reset ¶ added in v1.5.0
func (x *UpdateIngressStateRequest) Reset()
func (*UpdateIngressStateRequest) String ¶ added in v1.5.0
func (x *UpdateIngressStateRequest) String() string
type UpdateMediaStatsRequest ¶
type UpdateMediaStatsRequest struct {
Stats *MediaStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateMediaStatsRequest) Descriptor
deprecated
func (*UpdateMediaStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMediaStatsRequest.ProtoReflect.Descriptor instead.
func (*UpdateMediaStatsRequest) GetStats ¶ added in v1.3.0
func (x *UpdateMediaStatsRequest) GetStats() *MediaStats
func (*UpdateMediaStatsRequest) ProtoMessage ¶
func (*UpdateMediaStatsRequest) ProtoMessage()
func (*UpdateMediaStatsRequest) ProtoReflect ¶
func (x *UpdateMediaStatsRequest) ProtoReflect() protoreflect.Message
func (*UpdateMediaStatsRequest) Reset ¶
func (x *UpdateMediaStatsRequest) Reset()
func (*UpdateMediaStatsRequest) String ¶
func (x *UpdateMediaStatsRequest) String() string