Compare commits

...

2 Commits

Author SHA1 Message Date
github-actions
7cada635eb generated protobuf
Some checks failed
Generate / generate (push) Has been cancelled
2022-12-22 00:27:03 +00:00
danm
9472a418a7 adding node stats 2022-12-21 17:23:53 -07:00
2 changed files with 227 additions and 4 deletions

View File

@@ -308,8 +308,28 @@ type NodeStats struct {
RetransmitBytesOutPerSec float32 `protobuf:"fixed32,24,opt,name=retransmit_bytes_out_per_sec,json=retransmitBytesOutPerSec,proto3" json:"retransmit_bytes_out_per_sec,omitempty"`
RetransmitPacketsOutPerSec float32 `protobuf:"fixed32,25,opt,name=retransmit_packets_out_per_sec,json=retransmitPacketsOutPerSec,proto3" json:"retransmit_packets_out_per_sec,omitempty"`
// participant joins
ParticipantJoin uint64 `protobuf:"varint,26,opt,name=participant_join,json=participantJoin,proto3" json:"participant_join,omitempty"`
ParticipantJoinPerSec float32 `protobuf:"fixed32,27,opt,name=participant_join_per_sec,json=participantJoinPerSec,proto3" json:"participant_join_per_sec,omitempty"`
ParticipantJoin uint64 `protobuf:"varint,26,opt,name=participant_join,json=participantJoin,proto3" json:"participant_join,omitempty"`
ParticipantJoinPerSec float32 `protobuf:"fixed32,27,opt,name=participant_join_per_sec,json=participantJoinPerSec,proto3" json:"participant_join_per_sec,omitempty"`
ParticipantJoinFailures uint64 `protobuf:"varint,34,opt,name=participant_join_failures,json=participantJoinFailures,proto3" json:"participant_join_failures,omitempty"`
ParticipantJoinFailurePerSec float32 `protobuf:"fixed32,35,opt,name=participant_join_failure_per_sec,json=participantJoinFailurePerSec,proto3" json:"participant_join_failure_per_sec,omitempty"`
// connections
ConnectionSuccess uint64 `protobuf:"varint,36,opt,name=connection_success,json=connectionSuccess,proto3" json:"connection_success,omitempty"`
ConnectionFailures uint64 `protobuf:"varint,37,opt,name=connection_failures,json=connectionFailures,proto3" json:"connection_failures,omitempty"`
ConnectionSuccessPerSec float32 `protobuf:"fixed32,38,opt,name=connection_success_per_sec,json=connectionSuccessPerSec,proto3" json:"connection_success_per_sec,omitempty"`
ConnectionFailuresPerSec float32 `protobuf:"fixed32,39,opt,name=connection_failures_per_sec,json=connectionFailuresPerSec,proto3" json:"connection_failures_per_sec,omitempty"`
// signaling
SignalSuccess uint64 `protobuf:"varint,40,opt,name=signal_success,json=signalSuccess,proto3" json:"signal_success,omitempty"`
SignalFailures uint64 `protobuf:"varint,41,opt,name=signal_failures,json=signalFailures,proto3" json:"signal_failures,omitempty"`
SignalSuccessPerSec float32 `protobuf:"fixed32,42,opt,name=signal_success_per_sec,json=signalSuccessPerSec,proto3" json:"signal_success_per_sec,omitempty"`
SignalFailuresPerSec float32 `protobuf:"fixed32,43,opt,name=signal_failures_per_sec,json=signalFailuresPerSec,proto3" json:"signal_failures_per_sec,omitempty"`
// tracks
TrackPublishedFailures uint64 `protobuf:"varint,44,opt,name=track_published_failures,json=trackPublishedFailures,proto3" json:"track_published_failures,omitempty"`
TrackSubscribedFailures uint64 `protobuf:"varint,45,opt,name=track_subscribed_failures,json=trackSubscribedFailures,proto3" json:"track_subscribed_failures,omitempty"`
ParticipantJoinedFailures uint64 `protobuf:"varint,46,opt,name=participant_joined_failures,json=participantJoinedFailures,proto3" json:"participant_joined_failures,omitempty"`
TrackPublishedPerSec float32 `protobuf:"fixed32,47,opt,name=track_published_per_sec,json=trackPublishedPerSec,proto3" json:"track_published_per_sec,omitempty"`
TrackSubscribedPerSec float32 `protobuf:"fixed32,48,opt,name=track_subscribed_per_sec,json=trackSubscribedPerSec,proto3" json:"track_subscribed_per_sec,omitempty"`
TrackPublishedFailurePerSec float32 `protobuf:"fixed32,49,opt,name=track_published_failure_per_sec,json=trackPublishedFailurePerSec,proto3" json:"track_published_failure_per_sec,omitempty"`
TrackSubscribedFailurePerSec float32 `protobuf:"fixed32,50,opt,name=track_subscribed_failure_per_sec,json=trackSubscribedFailurePerSec,proto3" json:"track_subscribed_failure_per_sec,omitempty"`
}
func (x *NodeStats) Reset() {
@@ -575,6 +595,125 @@ func (x *NodeStats) GetParticipantJoinPerSec() float32 {
return 0
}
func (x *NodeStats) GetParticipantJoinFailures() uint64 {
if x != nil {
return x.ParticipantJoinFailures
}
return 0
}
func (x *NodeStats) GetParticipantJoinFailurePerSec() float32 {
if x != nil {
return x.ParticipantJoinFailurePerSec
}
return 0
}
func (x *NodeStats) GetConnectionSuccess() uint64 {
if x != nil {
return x.ConnectionSuccess
}
return 0
}
func (x *NodeStats) GetConnectionFailures() uint64 {
if x != nil {
return x.ConnectionFailures
}
return 0
}
func (x *NodeStats) GetConnectionSuccessPerSec() float32 {
if x != nil {
return x.ConnectionSuccessPerSec
}
return 0
}
func (x *NodeStats) GetConnectionFailuresPerSec() float32 {
if x != nil {
return x.ConnectionFailuresPerSec
}
return 0
}
func (x *NodeStats) GetSignalSuccess() uint64 {
if x != nil {
return x.SignalSuccess
}
return 0
}
func (x *NodeStats) GetSignalFailures() uint64 {
if x != nil {
return x.SignalFailures
}
return 0
}
func (x *NodeStats) GetSignalSuccessPerSec() float32 {
if x != nil {
return x.SignalSuccessPerSec
}
return 0
}
func (x *NodeStats) GetSignalFailuresPerSec() float32 {
if x != nil {
return x.SignalFailuresPerSec
}
return 0
}
func (x *NodeStats) GetTrackPublishedFailures() uint64 {
if x != nil {
return x.TrackPublishedFailures
}
return 0
}
func (x *NodeStats) GetTrackSubscribedFailures() uint64 {
if x != nil {
return x.TrackSubscribedFailures
}
return 0
}
func (x *NodeStats) GetParticipantJoinedFailures() uint64 {
if x != nil {
return x.ParticipantJoinedFailures
}
return 0
}
func (x *NodeStats) GetTrackPublishedPerSec() float32 {
if x != nil {
return x.TrackPublishedPerSec
}
return 0
}
func (x *NodeStats) GetTrackSubscribedPerSec() float32 {
if x != nil {
return x.TrackSubscribedPerSec
}
return 0
}
func (x *NodeStats) GetTrackPublishedFailurePerSec() float32 {
if x != nil {
return x.TrackPublishedFailurePerSec
}
return 0
}
func (x *NodeStats) GetTrackSubscribedFailurePerSec() float32 {
if x != nil {
return x.TrackSubscribedFailurePerSec
}
return 0
}
// message to RTC nodes
type RTCNodeMessage struct {
state protoimpl.MessageState
@@ -1279,7 +1418,7 @@ var file_livekit_internal_proto_rawDesc = []byte{
0x74, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x12, 0x2e, 0x6c, 0x69, 0x76, 0x65, 0x6b,
0x69, 0x74, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x53, 0x74, 0x61, 0x74, 0x65, 0x52, 0x05, 0x73, 0x74,
0x61, 0x74, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x18, 0x07, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0xf8, 0x0a, 0x0a, 0x09,
0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x22, 0xc8, 0x12, 0x0a, 0x09,
0x4e, 0x6f, 0x64, 0x65, 0x53, 0x74, 0x61, 0x74, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x73, 0x74, 0x61,
0x72, 0x74, 0x65, 0x64, 0x5f, 0x61, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x73,
0x74, 0x61, 0x72, 0x74, 0x65, 0x64, 0x41, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x75, 0x70, 0x64, 0x61,
@@ -1367,6 +1506,67 @@ var file_livekit_internal_proto_rawDesc = []byte{
0x18, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x5f, 0x6a, 0x6f, 0x69,
0x6e, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x1b, 0x20, 0x01, 0x28, 0x02, 0x52,
0x15, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x4a, 0x6f, 0x69, 0x6e,
0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x3a, 0x0a, 0x19, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63,
0x69, 0x70, 0x61, 0x6e, 0x74, 0x5f, 0x6a, 0x6f, 0x69, 0x6e, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75,
0x72, 0x65, 0x73, 0x18, 0x22, 0x20, 0x01, 0x28, 0x04, 0x52, 0x17, 0x70, 0x61, 0x72, 0x74, 0x69,
0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x4a, 0x6f, 0x69, 0x6e, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72,
0x65, 0x73, 0x12, 0x46, 0x0a, 0x20, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e,
0x74, 0x5f, 0x6a, 0x6f, 0x69, 0x6e, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x5f, 0x70,
0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x23, 0x20, 0x01, 0x28, 0x02, 0x52, 0x1c, 0x70, 0x61,
0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x4a, 0x6f, 0x69, 0x6e, 0x46, 0x61, 0x69,
0x6c, 0x75, 0x72, 0x65, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x2d, 0x0a, 0x12, 0x63, 0x6f,
0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73,
0x18, 0x24, 0x20, 0x01, 0x28, 0x04, 0x52, 0x11, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
0x6f, 0x6e, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x2f, 0x0a, 0x13, 0x63, 0x6f, 0x6e,
0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73,
0x18, 0x25, 0x20, 0x01, 0x28, 0x04, 0x52, 0x12, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
0x6f, 0x6e, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x12, 0x3b, 0x0a, 0x1a, 0x63, 0x6f,
0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73,
0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x26, 0x20, 0x01, 0x28, 0x02, 0x52, 0x17,
0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73,
0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x3d, 0x0a, 0x1b, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x5f, 0x70,
0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x27, 0x20, 0x01, 0x28, 0x02, 0x52, 0x18, 0x63, 0x6f,
0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73,
0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c,
0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x28, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0d,
0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x27, 0x0a,
0x0f, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73,
0x18, 0x29, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0e, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c, 0x46, 0x61,
0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x12, 0x33, 0x0a, 0x16, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c,
0x5f, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63,
0x18, 0x2a, 0x20, 0x01, 0x28, 0x02, 0x52, 0x13, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x6c, 0x53, 0x75,
0x63, 0x63, 0x65, 0x73, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x35, 0x0a, 0x17, 0x73,
0x69, 0x67, 0x6e, 0x61, 0x6c, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x5f, 0x70,
0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x2b, 0x20, 0x01, 0x28, 0x02, 0x52, 0x14, 0x73, 0x69,
0x67, 0x6e, 0x61, 0x6c, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53,
0x65, 0x63, 0x12, 0x38, 0x0a, 0x18, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x5f, 0x70, 0x75, 0x62, 0x6c,
0x69, 0x73, 0x68, 0x65, 0x64, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x18, 0x2c,
0x20, 0x01, 0x28, 0x04, 0x52, 0x16, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x50, 0x75, 0x62, 0x6c, 0x69,
0x73, 0x68, 0x65, 0x64, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x12, 0x3a, 0x0a, 0x19,
0x74, 0x72, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x64,
0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x18, 0x2d, 0x20, 0x01, 0x28, 0x04, 0x52,
0x17, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x64,
0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x12, 0x3e, 0x0a, 0x1b, 0x70, 0x61, 0x72, 0x74,
0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x5f, 0x6a, 0x6f, 0x69, 0x6e, 0x65, 0x64, 0x5f, 0x66,
0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x18, 0x2e, 0x20, 0x01, 0x28, 0x04, 0x52, 0x19, 0x70,
0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x4a, 0x6f, 0x69, 0x6e, 0x65, 0x64,
0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x73, 0x12, 0x35, 0x0a, 0x17, 0x74, 0x72, 0x61, 0x63,
0x6b, 0x5f, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x64, 0x5f, 0x70, 0x65, 0x72, 0x5f,
0x73, 0x65, 0x63, 0x18, 0x2f, 0x20, 0x01, 0x28, 0x02, 0x52, 0x14, 0x74, 0x72, 0x61, 0x63, 0x6b,
0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x64, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12,
0x37, 0x0a, 0x18, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69,
0x62, 0x65, 0x64, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x30, 0x20, 0x01, 0x28,
0x02, 0x52, 0x15, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62,
0x65, 0x64, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x44, 0x0a, 0x1f, 0x74, 0x72, 0x61, 0x63,
0x6b, 0x5f, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x64, 0x5f, 0x66, 0x61, 0x69, 0x6c,
0x75, 0x72, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x31, 0x20, 0x01, 0x28,
0x02, 0x52, 0x1b, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65,
0x64, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x12, 0x46,
0x0a, 0x20, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x5f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62,
0x65, 0x64, 0x5f, 0x66, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73,
0x65, 0x63, 0x18, 0x32, 0x20, 0x01, 0x28, 0x02, 0x52, 0x1c, 0x74, 0x72, 0x61, 0x63, 0x6b, 0x53,
0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x64, 0x46, 0x61, 0x69, 0x6c, 0x75, 0x72, 0x65,
0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x22, 0xf2, 0x06, 0x0a, 0x0e, 0x52, 0x54, 0x43, 0x4e, 0x6f,
0x64, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x61, 0x72,
0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01,

View File

@@ -80,8 +80,31 @@ message NodeStats {
// participant joins
uint64 participant_join = 26;
float participant_join_per_sec = 27;
uint64 participant_join_failures = 34;
float participant_join_failure_per_sec = 35;
// NEXT ID: 34
// connections
uint64 connection_success = 36;
uint64 connection_failures = 37;
float connection_success_per_sec = 38;
float connection_failures_per_sec = 39;
// signaling
uint64 signal_success = 40;
uint64 signal_failures = 41;
float signal_success_per_sec = 42;
float signal_failures_per_sec = 43;
// tracks
uint64 track_published_failures = 44;
uint64 track_subscribed_failures = 45;
uint64 participant_joined_failures = 46;
float track_published_per_sec = 47;
float track_subscribed_per_sec = 48;
float track_published_failure_per_sec = 49;
float track_subscribed_failure_per_sec = 50;
// NEXT ID: 51
}
// message to RTC nodes