fc7b4fa301
* chore(deps): update actions/cache action to v5 Generated by renovateBot * generated protobuf --------- Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
658 lines
26 KiB
Go
658 lines
26 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.36.11
|
|
// protoc v4.23.4
|
|
// source: livekit_metrics.proto
|
|
|
|
package livekit
|
|
|
|
import (
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// index from [0: MAX_LABEL_PREDEFINED_MAX_VALUE) are for predefined labels (`MetricLabel`)
|
|
type MetricLabel int32
|
|
|
|
const (
|
|
MetricLabel_AGENTS_LLM_TTFT MetricLabel = 0 // time to first token from LLM
|
|
MetricLabel_AGENTS_STT_TTFT MetricLabel = 1 // time to final transcription
|
|
MetricLabel_AGENTS_TTS_TTFB MetricLabel = 2 // time to first byte
|
|
MetricLabel_CLIENT_VIDEO_SUBSCRIBER_FREEZE_COUNT MetricLabel = 3 // Number of video freezes
|
|
MetricLabel_CLIENT_VIDEO_SUBSCRIBER_TOTAL_FREEZE_DURATION MetricLabel = 4 // total duration of freezes
|
|
MetricLabel_CLIENT_VIDEO_SUBSCRIBER_PAUSE_COUNT MetricLabel = 5 // number of video pauses
|
|
MetricLabel_CLIENT_VIDEO_SUBSCRIBER_TOTAL_PAUSES_DURATION MetricLabel = 6 // total duration of pauses
|
|
MetricLabel_CLIENT_AUDIO_SUBSCRIBER_CONCEALED_SAMPLES MetricLabel = 7 // number of concealed (synthesized) audio samples
|
|
MetricLabel_CLIENT_AUDIO_SUBSCRIBER_SILENT_CONCEALED_SAMPLES MetricLabel = 8 // number of silent concealed samples
|
|
MetricLabel_CLIENT_AUDIO_SUBSCRIBER_CONCEALMENT_EVENTS MetricLabel = 9 // number of concealment events
|
|
MetricLabel_CLIENT_AUDIO_SUBSCRIBER_INTERRUPTION_COUNT MetricLabel = 10 // number of interruptions
|
|
MetricLabel_CLIENT_AUDIO_SUBSCRIBER_TOTAL_INTERRUPTION_DURATION MetricLabel = 11 // total duration of interruptions
|
|
MetricLabel_CLIENT_SUBSCRIBER_JITTER_BUFFER_DELAY MetricLabel = 12 // total time spent in jitter buffer
|
|
MetricLabel_CLIENT_SUBSCRIBER_JITTER_BUFFER_EMITTED_COUNT MetricLabel = 13 // total time spent in jitter buffer
|
|
MetricLabel_CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_BANDWIDTH MetricLabel = 14 // total duration spent in bandwidth quality limitation
|
|
MetricLabel_CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_CPU MetricLabel = 15 // total duration spent in cpu quality limitation
|
|
MetricLabel_CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_OTHER MetricLabel = 16 // total duration spent in other quality limitation
|
|
MetricLabel_PUBLISHER_RTT MetricLabel = 17 // Publisher RTT (participant -> server)
|
|
MetricLabel_SERVER_MESH_RTT MetricLabel = 18 // RTT between publisher node and subscriber node (could involve intermedia node(s))
|
|
MetricLabel_SUBSCRIBER_RTT MetricLabel = 19 // Subscribe RTT (server -> participant)
|
|
MetricLabel_METRIC_LABEL_PREDEFINED_MAX_VALUE MetricLabel = 4096
|
|
)
|
|
|
|
// Enum value maps for MetricLabel.
|
|
var (
|
|
MetricLabel_name = map[int32]string{
|
|
0: "AGENTS_LLM_TTFT",
|
|
1: "AGENTS_STT_TTFT",
|
|
2: "AGENTS_TTS_TTFB",
|
|
3: "CLIENT_VIDEO_SUBSCRIBER_FREEZE_COUNT",
|
|
4: "CLIENT_VIDEO_SUBSCRIBER_TOTAL_FREEZE_DURATION",
|
|
5: "CLIENT_VIDEO_SUBSCRIBER_PAUSE_COUNT",
|
|
6: "CLIENT_VIDEO_SUBSCRIBER_TOTAL_PAUSES_DURATION",
|
|
7: "CLIENT_AUDIO_SUBSCRIBER_CONCEALED_SAMPLES",
|
|
8: "CLIENT_AUDIO_SUBSCRIBER_SILENT_CONCEALED_SAMPLES",
|
|
9: "CLIENT_AUDIO_SUBSCRIBER_CONCEALMENT_EVENTS",
|
|
10: "CLIENT_AUDIO_SUBSCRIBER_INTERRUPTION_COUNT",
|
|
11: "CLIENT_AUDIO_SUBSCRIBER_TOTAL_INTERRUPTION_DURATION",
|
|
12: "CLIENT_SUBSCRIBER_JITTER_BUFFER_DELAY",
|
|
13: "CLIENT_SUBSCRIBER_JITTER_BUFFER_EMITTED_COUNT",
|
|
14: "CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_BANDWIDTH",
|
|
15: "CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_CPU",
|
|
16: "CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_OTHER",
|
|
17: "PUBLISHER_RTT",
|
|
18: "SERVER_MESH_RTT",
|
|
19: "SUBSCRIBER_RTT",
|
|
4096: "METRIC_LABEL_PREDEFINED_MAX_VALUE",
|
|
}
|
|
MetricLabel_value = map[string]int32{
|
|
"AGENTS_LLM_TTFT": 0,
|
|
"AGENTS_STT_TTFT": 1,
|
|
"AGENTS_TTS_TTFB": 2,
|
|
"CLIENT_VIDEO_SUBSCRIBER_FREEZE_COUNT": 3,
|
|
"CLIENT_VIDEO_SUBSCRIBER_TOTAL_FREEZE_DURATION": 4,
|
|
"CLIENT_VIDEO_SUBSCRIBER_PAUSE_COUNT": 5,
|
|
"CLIENT_VIDEO_SUBSCRIBER_TOTAL_PAUSES_DURATION": 6,
|
|
"CLIENT_AUDIO_SUBSCRIBER_CONCEALED_SAMPLES": 7,
|
|
"CLIENT_AUDIO_SUBSCRIBER_SILENT_CONCEALED_SAMPLES": 8,
|
|
"CLIENT_AUDIO_SUBSCRIBER_CONCEALMENT_EVENTS": 9,
|
|
"CLIENT_AUDIO_SUBSCRIBER_INTERRUPTION_COUNT": 10,
|
|
"CLIENT_AUDIO_SUBSCRIBER_TOTAL_INTERRUPTION_DURATION": 11,
|
|
"CLIENT_SUBSCRIBER_JITTER_BUFFER_DELAY": 12,
|
|
"CLIENT_SUBSCRIBER_JITTER_BUFFER_EMITTED_COUNT": 13,
|
|
"CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_BANDWIDTH": 14,
|
|
"CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_CPU": 15,
|
|
"CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_OTHER": 16,
|
|
"PUBLISHER_RTT": 17,
|
|
"SERVER_MESH_RTT": 18,
|
|
"SUBSCRIBER_RTT": 19,
|
|
"METRIC_LABEL_PREDEFINED_MAX_VALUE": 4096,
|
|
}
|
|
)
|
|
|
|
func (x MetricLabel) Enum() *MetricLabel {
|
|
p := new(MetricLabel)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x MetricLabel) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (MetricLabel) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_livekit_metrics_proto_enumTypes[0].Descriptor()
|
|
}
|
|
|
|
func (MetricLabel) Type() protoreflect.EnumType {
|
|
return &file_livekit_metrics_proto_enumTypes[0]
|
|
}
|
|
|
|
func (x MetricLabel) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use MetricLabel.Descriptor instead.
|
|
func (MetricLabel) EnumDescriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
type MetricsBatch struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TimestampMs int64 `protobuf:"varint,1,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"` // time at which this batch is sent based on a monotonic clock (millisecond resolution)
|
|
NormalizedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=normalized_timestamp,json=normalizedTimestamp,proto3" json:"normalized_timestamp,omitempty"`
|
|
// To avoid repeating string values, we store them in a separate list and reference them by index
|
|
// This is useful for storing participant identities, track names, etc.
|
|
// There is also a predefined list of labels that can be used to reference common metrics.
|
|
// They have reserved indices from 0 to (METRIC_LABEL_PREDEFINED_MAX_VALUE - 1).
|
|
// Indexes pointing at str_data should start from METRIC_LABEL_PREDEFINED_MAX_VALUE,
|
|
// such that str_data[0] == index of METRIC_LABEL_PREDEFINED_MAX_VALUE.
|
|
StrData []string `protobuf:"bytes,3,rep,name=str_data,json=strData,proto3" json:"str_data,omitempty"`
|
|
TimeSeries []*TimeSeriesMetric `protobuf:"bytes,4,rep,name=time_series,json=timeSeries,proto3" json:"time_series,omitempty"`
|
|
Events []*EventMetric `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *MetricsBatch) Reset() {
|
|
*x = MetricsBatch{}
|
|
mi := &file_livekit_metrics_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *MetricsBatch) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*MetricsBatch) ProtoMessage() {}
|
|
|
|
func (x *MetricsBatch) ProtoReflect() protoreflect.Message {
|
|
mi := &file_livekit_metrics_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use MetricsBatch.ProtoReflect.Descriptor instead.
|
|
func (*MetricsBatch) Descriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *MetricsBatch) GetTimestampMs() int64 {
|
|
if x != nil {
|
|
return x.TimestampMs
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *MetricsBatch) GetNormalizedTimestamp() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.NormalizedTimestamp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *MetricsBatch) GetStrData() []string {
|
|
if x != nil {
|
|
return x.StrData
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *MetricsBatch) GetTimeSeries() []*TimeSeriesMetric {
|
|
if x != nil {
|
|
return x.TimeSeries
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *MetricsBatch) GetEvents() []*EventMetric {
|
|
if x != nil {
|
|
return x.Events
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type TimeSeriesMetric struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Metric name e.g "speech_probablity". The string value is not directly stored in the message, but referenced by index
|
|
// in the `str_data` field of `MetricsBatch`
|
|
Label uint32 `protobuf:"varint,1,opt,name=label,proto3" json:"label,omitempty"`
|
|
ParticipantIdentity uint32 `protobuf:"varint,2,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"` // index into `str_data`
|
|
TrackSid uint32 `protobuf:"varint,3,opt,name=track_sid,json=trackSid,proto3" json:"track_sid,omitempty"` // index into `str_data`
|
|
Samples []*MetricSample `protobuf:"bytes,4,rep,name=samples,proto3" json:"samples,omitempty"`
|
|
Rid uint32 `protobuf:"varint,5,opt,name=rid,proto3" json:"rid,omitempty"` // index into 'str_data'
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) Reset() {
|
|
*x = TimeSeriesMetric{}
|
|
mi := &file_livekit_metrics_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TimeSeriesMetric) ProtoMessage() {}
|
|
|
|
func (x *TimeSeriesMetric) ProtoReflect() protoreflect.Message {
|
|
mi := &file_livekit_metrics_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TimeSeriesMetric.ProtoReflect.Descriptor instead.
|
|
func (*TimeSeriesMetric) Descriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) GetLabel() uint32 {
|
|
if x != nil {
|
|
return x.Label
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) GetParticipantIdentity() uint32 {
|
|
if x != nil {
|
|
return x.ParticipantIdentity
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) GetTrackSid() uint32 {
|
|
if x != nil {
|
|
return x.TrackSid
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) GetSamples() []*MetricSample {
|
|
if x != nil {
|
|
return x.Samples
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *TimeSeriesMetric) GetRid() uint32 {
|
|
if x != nil {
|
|
return x.Rid
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type MetricSample struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TimestampMs int64 `protobuf:"varint,1,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"` // time of metric based on a monotonic clock (in milliseconds)
|
|
NormalizedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=normalized_timestamp,json=normalizedTimestamp,proto3" json:"normalized_timestamp,omitempty"`
|
|
Value float32 `protobuf:"fixed32,3,opt,name=value,proto3" json:"value,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *MetricSample) Reset() {
|
|
*x = MetricSample{}
|
|
mi := &file_livekit_metrics_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *MetricSample) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*MetricSample) ProtoMessage() {}
|
|
|
|
func (x *MetricSample) ProtoReflect() protoreflect.Message {
|
|
mi := &file_livekit_metrics_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use MetricSample.ProtoReflect.Descriptor instead.
|
|
func (*MetricSample) Descriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *MetricSample) GetTimestampMs() int64 {
|
|
if x != nil {
|
|
return x.TimestampMs
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *MetricSample) GetNormalizedTimestamp() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.NormalizedTimestamp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *MetricSample) GetValue() float32 {
|
|
if x != nil {
|
|
return x.Value
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type EventMetric struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Label uint32 `protobuf:"varint,1,opt,name=label,proto3" json:"label,omitempty"`
|
|
ParticipantIdentity uint32 `protobuf:"varint,2,opt,name=participant_identity,json=participantIdentity,proto3" json:"participant_identity,omitempty"` // index into `str_data`
|
|
TrackSid uint32 `protobuf:"varint,3,opt,name=track_sid,json=trackSid,proto3" json:"track_sid,omitempty"` // index into `str_data`
|
|
StartTimestampMs int64 `protobuf:"varint,4,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"` // start time of event based on a monotonic clock (in milliseconds)
|
|
EndTimestampMs *int64 `protobuf:"varint,5,opt,name=end_timestamp_ms,json=endTimestampMs,proto3,oneof" json:"end_timestamp_ms,omitempty"` // end time of event based on a monotonic clock (in milliseconds), if needed
|
|
NormalizedStartTimestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=normalized_start_timestamp,json=normalizedStartTimestamp,proto3" json:"normalized_start_timestamp,omitempty"`
|
|
NormalizedEndTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=normalized_end_timestamp,json=normalizedEndTimestamp,proto3,oneof" json:"normalized_end_timestamp,omitempty"`
|
|
Metadata string `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
Rid uint32 `protobuf:"varint,9,opt,name=rid,proto3" json:"rid,omitempty"` // index into 'str_data'
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *EventMetric) Reset() {
|
|
*x = EventMetric{}
|
|
mi := &file_livekit_metrics_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *EventMetric) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*EventMetric) ProtoMessage() {}
|
|
|
|
func (x *EventMetric) ProtoReflect() protoreflect.Message {
|
|
mi := &file_livekit_metrics_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use EventMetric.ProtoReflect.Descriptor instead.
|
|
func (*EventMetric) Descriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *EventMetric) GetLabel() uint32 {
|
|
if x != nil {
|
|
return x.Label
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *EventMetric) GetParticipantIdentity() uint32 {
|
|
if x != nil {
|
|
return x.ParticipantIdentity
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *EventMetric) GetTrackSid() uint32 {
|
|
if x != nil {
|
|
return x.TrackSid
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *EventMetric) GetStartTimestampMs() int64 {
|
|
if x != nil {
|
|
return x.StartTimestampMs
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *EventMetric) GetEndTimestampMs() int64 {
|
|
if x != nil && x.EndTimestampMs != nil {
|
|
return *x.EndTimestampMs
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *EventMetric) GetNormalizedStartTimestamp() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.NormalizedStartTimestamp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *EventMetric) GetNormalizedEndTimestamp() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.NormalizedEndTimestamp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *EventMetric) GetMetadata() string {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *EventMetric) GetRid() uint32 {
|
|
if x != nil {
|
|
return x.Rid
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type MetricsRecordingHeader struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"`
|
|
Duration uint64 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"` // milliseconds
|
|
StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
|
|
RoomTags map[string]string `protobuf:"bytes,5,rep,name=room_tags,json=roomTags,proto3" json:"room_tags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) Reset() {
|
|
*x = MetricsRecordingHeader{}
|
|
mi := &file_livekit_metrics_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*MetricsRecordingHeader) ProtoMessage() {}
|
|
|
|
func (x *MetricsRecordingHeader) ProtoReflect() protoreflect.Message {
|
|
mi := &file_livekit_metrics_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use MetricsRecordingHeader.ProtoReflect.Descriptor instead.
|
|
func (*MetricsRecordingHeader) Descriptor() ([]byte, []int) {
|
|
return file_livekit_metrics_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) GetRoomId() string {
|
|
if x != nil {
|
|
return x.RoomId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) GetDuration() uint64 {
|
|
if x != nil {
|
|
return x.Duration
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) GetStartTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.StartTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *MetricsRecordingHeader) GetRoomTags() map[string]string {
|
|
if x != nil {
|
|
return x.RoomTags
|
|
}
|
|
return nil
|
|
}
|
|
|
|
var File_livekit_metrics_proto protoreflect.FileDescriptor
|
|
|
|
const file_livekit_metrics_proto_rawDesc = "" +
|
|
"\n" +
|
|
"\x15livekit_metrics.proto\x12\alivekit\x1a\x1fgoogle/protobuf/timestamp.proto\"\x85\x02\n" +
|
|
"\fMetricsBatch\x12!\n" +
|
|
"\ftimestamp_ms\x18\x01 \x01(\x03R\vtimestampMs\x12M\n" +
|
|
"\x14normalized_timestamp\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x13normalizedTimestamp\x12\x19\n" +
|
|
"\bstr_data\x18\x03 \x03(\tR\astrData\x12:\n" +
|
|
"\vtime_series\x18\x04 \x03(\v2\x19.livekit.TimeSeriesMetricR\n" +
|
|
"timeSeries\x12,\n" +
|
|
"\x06events\x18\x05 \x03(\v2\x14.livekit.EventMetricR\x06events\"\xbb\x01\n" +
|
|
"\x10TimeSeriesMetric\x12\x14\n" +
|
|
"\x05label\x18\x01 \x01(\rR\x05label\x121\n" +
|
|
"\x14participant_identity\x18\x02 \x01(\rR\x13participantIdentity\x12\x1b\n" +
|
|
"\ttrack_sid\x18\x03 \x01(\rR\btrackSid\x12/\n" +
|
|
"\asamples\x18\x04 \x03(\v2\x15.livekit.MetricSampleR\asamples\x12\x10\n" +
|
|
"\x03rid\x18\x05 \x01(\rR\x03rid\"\x96\x01\n" +
|
|
"\fMetricSample\x12!\n" +
|
|
"\ftimestamp_ms\x18\x01 \x01(\x03R\vtimestampMs\x12M\n" +
|
|
"\x14normalized_timestamp\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x13normalizedTimestamp\x12\x14\n" +
|
|
"\x05value\x18\x03 \x01(\x02R\x05value\"\xe5\x03\n" +
|
|
"\vEventMetric\x12\x14\n" +
|
|
"\x05label\x18\x01 \x01(\rR\x05label\x121\n" +
|
|
"\x14participant_identity\x18\x02 \x01(\rR\x13participantIdentity\x12\x1b\n" +
|
|
"\ttrack_sid\x18\x03 \x01(\rR\btrackSid\x12,\n" +
|
|
"\x12start_timestamp_ms\x18\x04 \x01(\x03R\x10startTimestampMs\x12-\n" +
|
|
"\x10end_timestamp_ms\x18\x05 \x01(\x03H\x00R\x0eendTimestampMs\x88\x01\x01\x12X\n" +
|
|
"\x1anormalized_start_timestamp\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\x18normalizedStartTimestamp\x12Y\n" +
|
|
"\x18normalized_end_timestamp\x18\a \x01(\v2\x1a.google.protobuf.TimestampH\x01R\x16normalizedEndTimestamp\x88\x01\x01\x12\x1a\n" +
|
|
"\bmetadata\x18\b \x01(\tR\bmetadata\x12\x10\n" +
|
|
"\x03rid\x18\t \x01(\rR\x03ridB\x13\n" +
|
|
"\x11_end_timestamp_msB\x1b\n" +
|
|
"\x19_normalized_end_timestamp\"\x91\x02\n" +
|
|
"\x16MetricsRecordingHeader\x12\x17\n" +
|
|
"\aroom_id\x18\x01 \x01(\tR\x06roomId\x12\x1a\n" +
|
|
"\bduration\x18\x03 \x01(\x04R\bduration\x129\n" +
|
|
"\n" +
|
|
"start_time\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\tstartTime\x12J\n" +
|
|
"\troom_tags\x18\x05 \x03(\v2-.livekit.MetricsRecordingHeader.RoomTagsEntryR\broomTags\x1a;\n" +
|
|
"\rRoomTagsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01*\x81\a\n" +
|
|
"\vMetricLabel\x12\x13\n" +
|
|
"\x0fAGENTS_LLM_TTFT\x10\x00\x12\x13\n" +
|
|
"\x0fAGENTS_STT_TTFT\x10\x01\x12\x13\n" +
|
|
"\x0fAGENTS_TTS_TTFB\x10\x02\x12(\n" +
|
|
"$CLIENT_VIDEO_SUBSCRIBER_FREEZE_COUNT\x10\x03\x121\n" +
|
|
"-CLIENT_VIDEO_SUBSCRIBER_TOTAL_FREEZE_DURATION\x10\x04\x12'\n" +
|
|
"#CLIENT_VIDEO_SUBSCRIBER_PAUSE_COUNT\x10\x05\x121\n" +
|
|
"-CLIENT_VIDEO_SUBSCRIBER_TOTAL_PAUSES_DURATION\x10\x06\x12-\n" +
|
|
")CLIENT_AUDIO_SUBSCRIBER_CONCEALED_SAMPLES\x10\a\x124\n" +
|
|
"0CLIENT_AUDIO_SUBSCRIBER_SILENT_CONCEALED_SAMPLES\x10\b\x12.\n" +
|
|
"*CLIENT_AUDIO_SUBSCRIBER_CONCEALMENT_EVENTS\x10\t\x12.\n" +
|
|
"*CLIENT_AUDIO_SUBSCRIBER_INTERRUPTION_COUNT\x10\n" +
|
|
"\x127\n" +
|
|
"3CLIENT_AUDIO_SUBSCRIBER_TOTAL_INTERRUPTION_DURATION\x10\v\x12)\n" +
|
|
"%CLIENT_SUBSCRIBER_JITTER_BUFFER_DELAY\x10\f\x121\n" +
|
|
"-CLIENT_SUBSCRIBER_JITTER_BUFFER_EMITTED_COUNT\x10\r\x12@\n" +
|
|
"<CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_BANDWIDTH\x10\x0e\x12:\n" +
|
|
"6CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_CPU\x10\x0f\x12<\n" +
|
|
"8CLIENT_VIDEO_PUBLISHER_QUALITY_LIMITATION_DURATION_OTHER\x10\x10\x12\x11\n" +
|
|
"\rPUBLISHER_RTT\x10\x11\x12\x13\n" +
|
|
"\x0fSERVER_MESH_RTT\x10\x12\x12\x12\n" +
|
|
"\x0eSUBSCRIBER_RTT\x10\x13\x12&\n" +
|
|
"!METRIC_LABEL_PREDEFINED_MAX_VALUE\x10\x80 BFZ#github.com/livekit/protocol/livekit\xaa\x02\rLiveKit.Proto\xea\x02\x0eLiveKit::Protob\x06proto3"
|
|
|
|
var (
|
|
file_livekit_metrics_proto_rawDescOnce sync.Once
|
|
file_livekit_metrics_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_livekit_metrics_proto_rawDescGZIP() []byte {
|
|
file_livekit_metrics_proto_rawDescOnce.Do(func() {
|
|
file_livekit_metrics_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_livekit_metrics_proto_rawDesc), len(file_livekit_metrics_proto_rawDesc)))
|
|
})
|
|
return file_livekit_metrics_proto_rawDescData
|
|
}
|
|
|
|
var file_livekit_metrics_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
|
|
var file_livekit_metrics_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
|
|
var file_livekit_metrics_proto_goTypes = []any{
|
|
(MetricLabel)(0), // 0: livekit.MetricLabel
|
|
(*MetricsBatch)(nil), // 1: livekit.MetricsBatch
|
|
(*TimeSeriesMetric)(nil), // 2: livekit.TimeSeriesMetric
|
|
(*MetricSample)(nil), // 3: livekit.MetricSample
|
|
(*EventMetric)(nil), // 4: livekit.EventMetric
|
|
(*MetricsRecordingHeader)(nil), // 5: livekit.MetricsRecordingHeader
|
|
nil, // 6: livekit.MetricsRecordingHeader.RoomTagsEntry
|
|
(*timestamppb.Timestamp)(nil), // 7: google.protobuf.Timestamp
|
|
}
|
|
var file_livekit_metrics_proto_depIdxs = []int32{
|
|
7, // 0: livekit.MetricsBatch.normalized_timestamp:type_name -> google.protobuf.Timestamp
|
|
2, // 1: livekit.MetricsBatch.time_series:type_name -> livekit.TimeSeriesMetric
|
|
4, // 2: livekit.MetricsBatch.events:type_name -> livekit.EventMetric
|
|
3, // 3: livekit.TimeSeriesMetric.samples:type_name -> livekit.MetricSample
|
|
7, // 4: livekit.MetricSample.normalized_timestamp:type_name -> google.protobuf.Timestamp
|
|
7, // 5: livekit.EventMetric.normalized_start_timestamp:type_name -> google.protobuf.Timestamp
|
|
7, // 6: livekit.EventMetric.normalized_end_timestamp:type_name -> google.protobuf.Timestamp
|
|
7, // 7: livekit.MetricsRecordingHeader.start_time:type_name -> google.protobuf.Timestamp
|
|
6, // 8: livekit.MetricsRecordingHeader.room_tags:type_name -> livekit.MetricsRecordingHeader.RoomTagsEntry
|
|
9, // [9:9] is the sub-list for method output_type
|
|
9, // [9:9] is the sub-list for method input_type
|
|
9, // [9:9] is the sub-list for extension type_name
|
|
9, // [9:9] is the sub-list for extension extendee
|
|
0, // [0:9] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_livekit_metrics_proto_init() }
|
|
func file_livekit_metrics_proto_init() {
|
|
if File_livekit_metrics_proto != nil {
|
|
return
|
|
}
|
|
file_livekit_metrics_proto_msgTypes[3].OneofWrappers = []any{}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_metrics_proto_rawDesc), len(file_livekit_metrics_proto_rawDesc)),
|
|
NumEnums: 1,
|
|
NumMessages: 6,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_livekit_metrics_proto_goTypes,
|
|
DependencyIndexes: file_livekit_metrics_proto_depIdxs,
|
|
EnumInfos: file_livekit_metrics_proto_enumTypes,
|
|
MessageInfos: file_livekit_metrics_proto_msgTypes,
|
|
}.Build()
|
|
File_livekit_metrics_proto = out.File
|
|
file_livekit_metrics_proto_goTypes = nil
|
|
file_livekit_metrics_proto_depIdxs = nil
|
|
}
|