diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index ad5cc22fe..06397c266 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -348,6 +348,156 @@ func (TrackSource) EnumDescriptor() ([]byte, []int) { return file_livekit_models_proto_rawDescGZIP(), []int{5} } +// Encoding for frame payloads. +// +// Mirrors the well-known message encodings from the MCAP spec: +// https://mcap.dev/spec/registry#message-encodings +type DataTrackFrameEncoding int32 + +const ( + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_UNSPECIFIED DataTrackFrameEncoding = 0 + // ROS 1: must be described by `ROS1_MSG` schema encoding. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_ROS1 DataTrackFrameEncoding = 1 + // CDR: must be described by `ROS2_MSG`, `ROS2_IDL`, or `OMG_IDL` schema encoding. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_CDR DataTrackFrameEncoding = 2 + // Protocol Buffer: must be described by `PROTOBUF` schema encoding. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_PROTOBUF DataTrackFrameEncoding = 3 + // FlatBuffer: must be described by `FLATBUFFER` schema encoding. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_FLATBUFFER DataTrackFrameEncoding = 4 + // CBOR: self-describing. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_CBOR DataTrackFrameEncoding = 5 + // MessagePack: self-describing. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_MSGPACK DataTrackFrameEncoding = 6 + // JSON: self-describing or described by `JSON_SCHEMA` schema encoding. + DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_JSON DataTrackFrameEncoding = 7 +) + +// Enum value maps for DataTrackFrameEncoding. +var ( + DataTrackFrameEncoding_name = map[int32]string{ + 0: "DATA_TRACK_FRAME_ENCODING_UNSPECIFIED", + 1: "DATA_TRACK_FRAME_ENCODING_ROS1", + 2: "DATA_TRACK_FRAME_ENCODING_CDR", + 3: "DATA_TRACK_FRAME_ENCODING_PROTOBUF", + 4: "DATA_TRACK_FRAME_ENCODING_FLATBUFFER", + 5: "DATA_TRACK_FRAME_ENCODING_CBOR", + 6: "DATA_TRACK_FRAME_ENCODING_MSGPACK", + 7: "DATA_TRACK_FRAME_ENCODING_JSON", + } + DataTrackFrameEncoding_value = map[string]int32{ + "DATA_TRACK_FRAME_ENCODING_UNSPECIFIED": 0, + "DATA_TRACK_FRAME_ENCODING_ROS1": 1, + "DATA_TRACK_FRAME_ENCODING_CDR": 2, + "DATA_TRACK_FRAME_ENCODING_PROTOBUF": 3, + "DATA_TRACK_FRAME_ENCODING_FLATBUFFER": 4, + "DATA_TRACK_FRAME_ENCODING_CBOR": 5, + "DATA_TRACK_FRAME_ENCODING_MSGPACK": 6, + "DATA_TRACK_FRAME_ENCODING_JSON": 7, + } +) + +func (x DataTrackFrameEncoding) Enum() *DataTrackFrameEncoding { + p := new(DataTrackFrameEncoding) + *p = x + return p +} + +func (x DataTrackFrameEncoding) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (DataTrackFrameEncoding) Descriptor() protoreflect.EnumDescriptor { + return file_livekit_models_proto_enumTypes[6].Descriptor() +} + +func (DataTrackFrameEncoding) Type() protoreflect.EnumType { + return &file_livekit_models_proto_enumTypes[6] +} + +func (x DataTrackFrameEncoding) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use DataTrackFrameEncoding.Descriptor instead. +func (DataTrackFrameEncoding) EnumDescriptor() ([]byte, []int) { + return file_livekit_models_proto_rawDescGZIP(), []int{6} +} + +// Encoding for schema definitions. +// +// Mirrors the well-known schema encodings from the MCAP spec: +// https://mcap.dev/spec/registry#schema-encodings +type DataTrackSchemaEncoding int32 + +const ( + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED DataTrackSchemaEncoding = 0 + // Protocol Buffer IDL: describes `PROTOBUF` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_PROTOBUF DataTrackSchemaEncoding = 1 + // FlatBuffer IDL: describes `FLATBUFFER` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_FLATBUFFER DataTrackSchemaEncoding = 2 + // ROS 1 Message: describes `ROS1` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_ROS1_MSG DataTrackSchemaEncoding = 3 + // ROS 2 Message: describes `CDR` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_ROS2_MSG DataTrackSchemaEncoding = 4 + // ROS 2 IDL: describes `CDR` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_ROS2_IDL DataTrackSchemaEncoding = 5 + // OMG IDL: describes `CDR` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_OMG_IDL DataTrackSchemaEncoding = 6 + // JSON Schema: describes `JSON` frame encoding. + DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_JSON_SCHEMA DataTrackSchemaEncoding = 7 +) + +// Enum value maps for DataTrackSchemaEncoding. +var ( + DataTrackSchemaEncoding_name = map[int32]string{ + 0: "DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED", + 1: "DATA_TRACK_SCHEMA_ENCODING_PROTOBUF", + 2: "DATA_TRACK_SCHEMA_ENCODING_FLATBUFFER", + 3: "DATA_TRACK_SCHEMA_ENCODING_ROS1_MSG", + 4: "DATA_TRACK_SCHEMA_ENCODING_ROS2_MSG", + 5: "DATA_TRACK_SCHEMA_ENCODING_ROS2_IDL", + 6: "DATA_TRACK_SCHEMA_ENCODING_OMG_IDL", + 7: "DATA_TRACK_SCHEMA_ENCODING_JSON_SCHEMA", + } + DataTrackSchemaEncoding_value = map[string]int32{ + "DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED": 0, + "DATA_TRACK_SCHEMA_ENCODING_PROTOBUF": 1, + "DATA_TRACK_SCHEMA_ENCODING_FLATBUFFER": 2, + "DATA_TRACK_SCHEMA_ENCODING_ROS1_MSG": 3, + "DATA_TRACK_SCHEMA_ENCODING_ROS2_MSG": 4, + "DATA_TRACK_SCHEMA_ENCODING_ROS2_IDL": 5, + "DATA_TRACK_SCHEMA_ENCODING_OMG_IDL": 6, + "DATA_TRACK_SCHEMA_ENCODING_JSON_SCHEMA": 7, + } +) + +func (x DataTrackSchemaEncoding) Enum() *DataTrackSchemaEncoding { + p := new(DataTrackSchemaEncoding) + *p = x + return p +} + +func (x DataTrackSchemaEncoding) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (DataTrackSchemaEncoding) Descriptor() protoreflect.EnumDescriptor { + return file_livekit_models_proto_enumTypes[7].Descriptor() +} + +func (DataTrackSchemaEncoding) Type() protoreflect.EnumType { + return &file_livekit_models_proto_enumTypes[7] +} + +func (x DataTrackSchemaEncoding) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use DataTrackSchemaEncoding.Descriptor instead. +func (DataTrackSchemaEncoding) EnumDescriptor() ([]byte, []int) { + return file_livekit_models_proto_rawDescGZIP(), []int{7} +} + type DataTrackExtensionID int32 const ( @@ -378,11 +528,11 @@ func (x DataTrackExtensionID) String() string { } func (DataTrackExtensionID) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[6].Descriptor() + return file_livekit_models_proto_enumTypes[8].Descriptor() } func (DataTrackExtensionID) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[6] + return &file_livekit_models_proto_enumTypes[8] } func (x DataTrackExtensionID) Number() protoreflect.EnumNumber { @@ -391,7 +541,7 @@ func (x DataTrackExtensionID) Number() protoreflect.EnumNumber { // Deprecated: Use DataTrackExtensionID.Descriptor instead. func (DataTrackExtensionID) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{6} + return file_livekit_models_proto_rawDescGZIP(), []int{8} } type VideoQuality int32 @@ -430,11 +580,11 @@ func (x VideoQuality) String() string { } func (VideoQuality) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[7].Descriptor() + return file_livekit_models_proto_enumTypes[9].Descriptor() } func (VideoQuality) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[7] + return &file_livekit_models_proto_enumTypes[9] } func (x VideoQuality) Number() protoreflect.EnumNumber { @@ -443,7 +593,7 @@ func (x VideoQuality) Number() protoreflect.EnumNumber { // Deprecated: Use VideoQuality.Descriptor instead. func (VideoQuality) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{7} + return file_livekit_models_proto_rawDescGZIP(), []int{9} } type ConnectionQuality int32 @@ -482,11 +632,11 @@ func (x ConnectionQuality) String() string { } func (ConnectionQuality) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[8].Descriptor() + return file_livekit_models_proto_enumTypes[10].Descriptor() } func (ConnectionQuality) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[8] + return &file_livekit_models_proto_enumTypes[10] } func (x ConnectionQuality) Number() protoreflect.EnumNumber { @@ -495,7 +645,7 @@ func (x ConnectionQuality) Number() protoreflect.EnumNumber { // Deprecated: Use ConnectionQuality.Descriptor instead. func (ConnectionQuality) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{8} + return file_livekit_models_proto_rawDescGZIP(), []int{10} } type ClientConfigSetting int32 @@ -531,11 +681,11 @@ func (x ClientConfigSetting) String() string { } func (ClientConfigSetting) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[9].Descriptor() + return file_livekit_models_proto_enumTypes[11].Descriptor() } func (ClientConfigSetting) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[9] + return &file_livekit_models_proto_enumTypes[11] } func (x ClientConfigSetting) Number() protoreflect.EnumNumber { @@ -544,7 +694,7 @@ func (x ClientConfigSetting) Number() protoreflect.EnumNumber { // Deprecated: Use ClientConfigSetting.Descriptor instead. func (ClientConfigSetting) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{9} + return file_livekit_models_proto_rawDescGZIP(), []int{11} } type DisconnectReason int32 @@ -638,11 +788,11 @@ func (x DisconnectReason) String() string { } func (DisconnectReason) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[10].Descriptor() + return file_livekit_models_proto_enumTypes[12].Descriptor() } func (DisconnectReason) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[10] + return &file_livekit_models_proto_enumTypes[12] } func (x DisconnectReason) Number() protoreflect.EnumNumber { @@ -651,7 +801,7 @@ func (x DisconnectReason) Number() protoreflect.EnumNumber { // Deprecated: Use DisconnectReason.Descriptor instead. func (DisconnectReason) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{10} + return file_livekit_models_proto_rawDescGZIP(), []int{12} } type ReconnectReason int32 @@ -693,11 +843,11 @@ func (x ReconnectReason) String() string { } func (ReconnectReason) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[11].Descriptor() + return file_livekit_models_proto_enumTypes[13].Descriptor() } func (ReconnectReason) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[11] + return &file_livekit_models_proto_enumTypes[13] } func (x ReconnectReason) Number() protoreflect.EnumNumber { @@ -706,7 +856,7 @@ func (x ReconnectReason) Number() protoreflect.EnumNumber { // Deprecated: Use ReconnectReason.Descriptor instead. func (ReconnectReason) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{11} + return file_livekit_models_proto_rawDescGZIP(), []int{13} } type SubscriptionError int32 @@ -742,11 +892,11 @@ func (x SubscriptionError) String() string { } func (SubscriptionError) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[12].Descriptor() + return file_livekit_models_proto_enumTypes[14].Descriptor() } func (SubscriptionError) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[12] + return &file_livekit_models_proto_enumTypes[14] } func (x SubscriptionError) Number() protoreflect.EnumNumber { @@ -755,7 +905,7 @@ func (x SubscriptionError) Number() protoreflect.EnumNumber { // Deprecated: Use SubscriptionError.Descriptor instead. func (SubscriptionError) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{12} + return file_livekit_models_proto_rawDescGZIP(), []int{14} } type AudioTrackFeature int32 @@ -803,11 +953,11 @@ func (x AudioTrackFeature) String() string { } func (AudioTrackFeature) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[13].Descriptor() + return file_livekit_models_proto_enumTypes[15].Descriptor() } func (AudioTrackFeature) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[13] + return &file_livekit_models_proto_enumTypes[15] } func (x AudioTrackFeature) Number() protoreflect.EnumNumber { @@ -816,7 +966,7 @@ func (x AudioTrackFeature) Number() protoreflect.EnumNumber { // Deprecated: Use AudioTrackFeature.Descriptor instead. func (AudioTrackFeature) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{13} + return file_livekit_models_proto_rawDescGZIP(), []int{15} } type PacketTrailerFeature int32 @@ -852,11 +1002,11 @@ func (x PacketTrailerFeature) String() string { } func (PacketTrailerFeature) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[14].Descriptor() + return file_livekit_models_proto_enumTypes[16].Descriptor() } func (PacketTrailerFeature) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[14] + return &file_livekit_models_proto_enumTypes[16] } func (x PacketTrailerFeature) Number() protoreflect.EnumNumber { @@ -865,7 +1015,7 @@ func (x PacketTrailerFeature) Number() protoreflect.EnumNumber { // Deprecated: Use PacketTrailerFeature.Descriptor instead. func (PacketTrailerFeature) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{14} + return file_livekit_models_proto_rawDescGZIP(), []int{16} } type ParticipantInfo_State int32 @@ -908,11 +1058,11 @@ func (x ParticipantInfo_State) String() string { } func (ParticipantInfo_State) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[15].Descriptor() + return file_livekit_models_proto_enumTypes[17].Descriptor() } func (ParticipantInfo_State) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[15] + return &file_livekit_models_proto_enumTypes[17] } func (x ParticipantInfo_State) Number() protoreflect.EnumNumber { @@ -976,11 +1126,11 @@ func (x ParticipantInfo_Kind) String() string { } func (ParticipantInfo_Kind) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[16].Descriptor() + return file_livekit_models_proto_enumTypes[18].Descriptor() } func (ParticipantInfo_Kind) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[16] + return &file_livekit_models_proto_enumTypes[18] } func (x ParticipantInfo_Kind) Number() protoreflect.EnumNumber { @@ -1031,11 +1181,11 @@ func (x ParticipantInfo_KindDetail) String() string { } func (ParticipantInfo_KindDetail) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[17].Descriptor() + return file_livekit_models_proto_enumTypes[19].Descriptor() } func (ParticipantInfo_KindDetail) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[17] + return &file_livekit_models_proto_enumTypes[19] } func (x ParticipantInfo_KindDetail) Number() protoreflect.EnumNumber { @@ -1080,11 +1230,11 @@ func (x Encryption_Type) String() string { } func (Encryption_Type) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[18].Descriptor() + return file_livekit_models_proto_enumTypes[20].Descriptor() } func (Encryption_Type) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[18] + return &file_livekit_models_proto_enumTypes[20] } func (x Encryption_Type) Number() protoreflect.EnumNumber { @@ -1132,11 +1282,11 @@ func (x VideoLayer_Mode) String() string { } func (VideoLayer_Mode) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[19].Descriptor() + return file_livekit_models_proto_enumTypes[21].Descriptor() } func (VideoLayer_Mode) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[19] + return &file_livekit_models_proto_enumTypes[21] } func (x VideoLayer_Mode) Number() protoreflect.EnumNumber { @@ -1145,7 +1295,7 @@ func (x VideoLayer_Mode) Number() protoreflect.EnumNumber { // Deprecated: Use VideoLayer_Mode.Descriptor instead. func (VideoLayer_Mode) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{16, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{17, 0} } type DataPacket_Kind int32 @@ -1178,11 +1328,11 @@ func (x DataPacket_Kind) String() string { } func (DataPacket_Kind) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[20].Descriptor() + return file_livekit_models_proto_enumTypes[22].Descriptor() } func (DataPacket_Kind) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[20] + return &file_livekit_models_proto_enumTypes[22] } func (x DataPacket_Kind) Number() protoreflect.EnumNumber { @@ -1191,7 +1341,7 @@ func (x DataPacket_Kind) Number() protoreflect.EnumNumber { // Deprecated: Use DataPacket_Kind.Descriptor instead. func (DataPacket_Kind) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{17, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{18, 0} } type ServerInfo_Edition int32 @@ -1224,11 +1374,11 @@ func (x ServerInfo_Edition) String() string { } func (ServerInfo_Edition) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[21].Descriptor() + return file_livekit_models_proto_enumTypes[23].Descriptor() } func (ServerInfo_Edition) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[21] + return &file_livekit_models_proto_enumTypes[23] } func (x ServerInfo_Edition) Number() protoreflect.EnumNumber { @@ -1237,7 +1387,7 @@ func (x ServerInfo_Edition) Number() protoreflect.EnumNumber { // Deprecated: Use ServerInfo_Edition.Descriptor instead. func (ServerInfo_Edition) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{32, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{33, 0} } type ClientInfo_SDK int32 @@ -1309,11 +1459,11 @@ func (x ClientInfo_SDK) String() string { } func (ClientInfo_SDK) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[22].Descriptor() + return file_livekit_models_proto_enumTypes[24].Descriptor() } func (ClientInfo_SDK) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[22] + return &file_livekit_models_proto_enumTypes[24] } func (x ClientInfo_SDK) Number() protoreflect.EnumNumber { @@ -1322,7 +1472,7 @@ func (x ClientInfo_SDK) Number() protoreflect.EnumNumber { // Deprecated: Use ClientInfo_SDK.Descriptor instead. func (ClientInfo_SDK) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{33, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{34, 0} } // Optional capabilities advertised by the client at connect time. The SFU @@ -1362,11 +1512,11 @@ func (x ClientInfo_Capability) String() string { } func (ClientInfo_Capability) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[23].Descriptor() + return file_livekit_models_proto_enumTypes[25].Descriptor() } func (ClientInfo_Capability) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[23] + return &file_livekit_models_proto_enumTypes[25] } func (x ClientInfo_Capability) Number() protoreflect.EnumNumber { @@ -1375,7 +1525,7 @@ func (x ClientInfo_Capability) Number() protoreflect.EnumNumber { // Deprecated: Use ClientInfo_Capability.Descriptor instead. func (ClientInfo_Capability) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{33, 1} + return file_livekit_models_proto_rawDescGZIP(), []int{34, 1} } // enum for operation types (specific to TextHeader) @@ -1415,11 +1565,11 @@ func (x DataStream_OperationType) String() string { } func (DataStream_OperationType) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[24].Descriptor() + return file_livekit_models_proto_enumTypes[26].Descriptor() } func (DataStream_OperationType) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[24] + return &file_livekit_models_proto_enumTypes[26] } func (x DataStream_OperationType) Number() protoreflect.EnumNumber { @@ -1428,7 +1578,7 @@ func (x DataStream_OperationType) Number() protoreflect.EnumNumber { // Deprecated: Use DataStream_OperationType.Descriptor instead. func (DataStream_OperationType) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 0} } // The compression type of the whole data stream @@ -1465,11 +1615,11 @@ func (x DataStream_CompressionType) String() string { } func (DataStream_CompressionType) Descriptor() protoreflect.EnumDescriptor { - return file_livekit_models_proto_enumTypes[25].Descriptor() + return file_livekit_models_proto_enumTypes[27].Descriptor() } func (DataStream_CompressionType) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[25] + return &file_livekit_models_proto_enumTypes[27] } func (x DataStream_CompressionType) Number() protoreflect.EnumNumber { @@ -1478,7 +1628,7 @@ func (x DataStream_CompressionType) Number() protoreflect.EnumNumber { // Deprecated: Use DataStream_CompressionType.Descriptor instead. func (DataStream_CompressionType) EnumDescriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 1} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 1} } type Pagination struct { @@ -2590,7 +2740,11 @@ type DataTrackInfo struct { // Human-readable identifier (e.g., `geoLocation`, `servoPosition.x`, etc.), unique per publisher. Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // Method used for end-to-end encryption (E2EE) on packet payloads. - Encryption Encryption_Type `protobuf:"varint,4,opt,name=encryption,proto3,enum=livekit.Encryption_Type" json:"encryption,omitempty"` + Encryption Encryption_Type `protobuf:"varint,4,opt,name=encryption,proto3,enum=livekit.Encryption_Type" json:"encryption,omitempty"` + // Encoding for frame payloads on this track. If unspecified, the track is untyped. + FrameEncoding *DataTrackFrameEncoding `protobuf:"varint,5,opt,name=frame_encoding,json=frameEncoding,proto3,enum=livekit.DataTrackFrameEncoding,oneof" json:"frame_encoding,omitempty"` + // ID of the schema used by frames on this track if the track is typed. + Schema *DataTrackSchemaId `protobuf:"bytes,6,opt,name=schema,proto3,oneof" json:"schema,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -2653,6 +2807,76 @@ func (x *DataTrackInfo) GetEncryption() Encryption_Type { return Encryption_NONE } +func (x *DataTrackInfo) GetFrameEncoding() DataTrackFrameEncoding { + if x != nil && x.FrameEncoding != nil { + return *x.FrameEncoding + } + return DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_UNSPECIFIED +} + +func (x *DataTrackInfo) GetSchema() *DataTrackSchemaId { + if x != nil { + return x.Schema + } + return nil +} + +// Identifier for a data track schema. +// +// Schemas with the same name but different encodings are distinct. +type DataTrackSchemaId struct { + state protoimpl.MessageState `protogen:"open.v1"` + // This must be non-empty and no longer than 256 characters. + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Encoding DataTrackSchemaEncoding `protobuf:"varint,2,opt,name=encoding,proto3,enum=livekit.DataTrackSchemaEncoding" json:"encoding,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DataTrackSchemaId) Reset() { + *x = DataTrackSchemaId{} + mi := &file_livekit_models_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DataTrackSchemaId) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DataTrackSchemaId) ProtoMessage() {} + +func (x *DataTrackSchemaId) ProtoReflect() protoreflect.Message { + mi := &file_livekit_models_proto_msgTypes[12] + 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 DataTrackSchemaId.ProtoReflect.Descriptor instead. +func (*DataTrackSchemaId) Descriptor() ([]byte, []int) { + return file_livekit_models_proto_rawDescGZIP(), []int{12} +} + +func (x *DataTrackSchemaId) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *DataTrackSchemaId) GetEncoding() DataTrackSchemaEncoding { + if x != nil { + return x.Encoding + } + return DataTrackSchemaEncoding_DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED +} + type DataTrackExtensionParticipantSid struct { state protoimpl.MessageState `protogen:"open.v1"` Id DataTrackExtensionID `protobuf:"varint,1,opt,name=id,proto3,enum=livekit.DataTrackExtensionID" json:"id,omitempty"` @@ -2663,7 +2887,7 @@ type DataTrackExtensionParticipantSid struct { func (x *DataTrackExtensionParticipantSid) Reset() { *x = DataTrackExtensionParticipantSid{} - mi := &file_livekit_models_proto_msgTypes[12] + mi := &file_livekit_models_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2675,7 +2899,7 @@ func (x *DataTrackExtensionParticipantSid) String() string { func (*DataTrackExtensionParticipantSid) ProtoMessage() {} func (x *DataTrackExtensionParticipantSid) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[12] + mi := &file_livekit_models_proto_msgTypes[13] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2688,7 +2912,7 @@ func (x *DataTrackExtensionParticipantSid) ProtoReflect() protoreflect.Message { // Deprecated: Use DataTrackExtensionParticipantSid.ProtoReflect.Descriptor instead. func (*DataTrackExtensionParticipantSid) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{12} + return file_livekit_models_proto_rawDescGZIP(), []int{13} } func (x *DataTrackExtensionParticipantSid) GetId() DataTrackExtensionID { @@ -2716,7 +2940,7 @@ type DataTrackSubscriptionOptions struct { func (x *DataTrackSubscriptionOptions) Reset() { *x = DataTrackSubscriptionOptions{} - mi := &file_livekit_models_proto_msgTypes[13] + mi := &file_livekit_models_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2728,7 +2952,7 @@ func (x *DataTrackSubscriptionOptions) String() string { func (*DataTrackSubscriptionOptions) ProtoMessage() {} func (x *DataTrackSubscriptionOptions) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[13] + mi := &file_livekit_models_proto_msgTypes[14] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2741,7 +2965,7 @@ func (x *DataTrackSubscriptionOptions) ProtoReflect() protoreflect.Message { // Deprecated: Use DataTrackSubscriptionOptions.ProtoReflect.Descriptor instead. func (*DataTrackSubscriptionOptions) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{13} + return file_livekit_models_proto_rawDescGZIP(), []int{14} } func (x *DataTrackSubscriptionOptions) GetTargetFps() uint32 { @@ -2757,6 +2981,7 @@ type DataBlobKey struct { // Types that are valid to be assigned to Key: // // *DataBlobKey_Generic + // *DataBlobKey_SchemaId Key isDataBlobKey_Key `protobuf_oneof:"key"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache @@ -2764,7 +2989,7 @@ type DataBlobKey struct { func (x *DataBlobKey) Reset() { *x = DataBlobKey{} - mi := &file_livekit_models_proto_msgTypes[14] + mi := &file_livekit_models_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2776,7 +3001,7 @@ func (x *DataBlobKey) String() string { func (*DataBlobKey) ProtoMessage() {} func (x *DataBlobKey) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[14] + mi := &file_livekit_models_proto_msgTypes[15] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2789,7 +3014,7 @@ func (x *DataBlobKey) ProtoReflect() protoreflect.Message { // Deprecated: Use DataBlobKey.ProtoReflect.Descriptor instead. func (*DataBlobKey) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{14} + return file_livekit_models_proto_rawDescGZIP(), []int{15} } func (x *DataBlobKey) GetKey() isDataBlobKey_Key { @@ -2808,17 +3033,33 @@ func (x *DataBlobKey) GetGeneric() string { return "" } +func (x *DataBlobKey) GetSchemaId() *DataTrackSchemaId { + if x != nil { + if x, ok := x.Key.(*DataBlobKey_SchemaId); ok { + return x.SchemaId + } + } + return nil +} + type isDataBlobKey_Key interface { isDataBlobKey_Key() } type DataBlobKey_Generic struct { // Generic string key, blob contains arbitrary data. - Generic string `protobuf:"bytes,1,opt,name=generic,proto3,oneof"` // Add additional key types here for storing specific types of blobs. + Generic string `protobuf:"bytes,1,opt,name=generic,proto3,oneof"` +} + +type DataBlobKey_SchemaId struct { + // Data track schema identifier, blob contains schema definition. + SchemaId *DataTrackSchemaId `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3,oneof"` } func (*DataBlobKey_Generic) isDataBlobKey_Key() {} +func (*DataBlobKey_SchemaId) isDataBlobKey_Key() {} + // A blob of data stored in a room identified by a unique key. type DataBlob struct { state protoimpl.MessageState `protogen:"open.v1"` @@ -2832,7 +3073,7 @@ type DataBlob struct { func (x *DataBlob) Reset() { *x = DataBlob{} - mi := &file_livekit_models_proto_msgTypes[15] + mi := &file_livekit_models_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2844,7 +3085,7 @@ func (x *DataBlob) String() string { func (*DataBlob) ProtoMessage() {} func (x *DataBlob) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[15] + mi := &file_livekit_models_proto_msgTypes[16] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2857,7 +3098,7 @@ func (x *DataBlob) ProtoReflect() protoreflect.Message { // Deprecated: Use DataBlob.ProtoReflect.Descriptor instead. func (*DataBlob) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{15} + return file_livekit_models_proto_rawDescGZIP(), []int{16} } func (x *DataBlob) GetKey() *DataBlobKey { @@ -2893,7 +3134,7 @@ type VideoLayer struct { func (x *VideoLayer) Reset() { *x = VideoLayer{} - mi := &file_livekit_models_proto_msgTypes[16] + mi := &file_livekit_models_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2905,7 +3146,7 @@ func (x *VideoLayer) String() string { func (*VideoLayer) ProtoMessage() {} func (x *VideoLayer) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[16] + mi := &file_livekit_models_proto_msgTypes[17] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2918,7 +3159,7 @@ func (x *VideoLayer) ProtoReflect() protoreflect.Message { // Deprecated: Use VideoLayer.ProtoReflect.Descriptor instead. func (*VideoLayer) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{16} + return file_livekit_models_proto_rawDescGZIP(), []int{17} } func (x *VideoLayer) GetQuality() VideoQuality { @@ -3012,7 +3253,7 @@ type DataPacket struct { func (x *DataPacket) Reset() { *x = DataPacket{} - mi := &file_livekit_models_proto_msgTypes[17] + mi := &file_livekit_models_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3024,7 +3265,7 @@ func (x *DataPacket) String() string { func (*DataPacket) ProtoMessage() {} func (x *DataPacket) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[17] + mi := &file_livekit_models_proto_msgTypes[18] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3037,7 +3278,7 @@ func (x *DataPacket) ProtoReflect() protoreflect.Message { // Deprecated: Use DataPacket.ProtoReflect.Descriptor instead. func (*DataPacket) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{17} + return file_livekit_models_proto_rawDescGZIP(), []int{18} } // Deprecated: Marked as deprecated in livekit_models.proto. @@ -3296,7 +3537,7 @@ type EncryptedPacket struct { func (x *EncryptedPacket) Reset() { *x = EncryptedPacket{} - mi := &file_livekit_models_proto_msgTypes[18] + mi := &file_livekit_models_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3308,7 +3549,7 @@ func (x *EncryptedPacket) String() string { func (*EncryptedPacket) ProtoMessage() {} func (x *EncryptedPacket) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[18] + mi := &file_livekit_models_proto_msgTypes[19] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3321,7 +3562,7 @@ func (x *EncryptedPacket) ProtoReflect() protoreflect.Message { // Deprecated: Use EncryptedPacket.ProtoReflect.Descriptor instead. func (*EncryptedPacket) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{18} + return file_livekit_models_proto_rawDescGZIP(), []int{19} } func (x *EncryptedPacket) GetEncryptionType() Encryption_Type { @@ -3371,7 +3612,7 @@ type EncryptedPacketPayload struct { func (x *EncryptedPacketPayload) Reset() { *x = EncryptedPacketPayload{} - mi := &file_livekit_models_proto_msgTypes[19] + mi := &file_livekit_models_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3383,7 +3624,7 @@ func (x *EncryptedPacketPayload) String() string { func (*EncryptedPacketPayload) ProtoMessage() {} func (x *EncryptedPacketPayload) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[19] + mi := &file_livekit_models_proto_msgTypes[20] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3396,7 +3637,7 @@ func (x *EncryptedPacketPayload) ProtoReflect() protoreflect.Message { // Deprecated: Use EncryptedPacketPayload.ProtoReflect.Descriptor instead. func (*EncryptedPacketPayload) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{19} + return file_livekit_models_proto_rawDescGZIP(), []int{20} } func (x *EncryptedPacketPayload) GetValue() isEncryptedPacketPayload_Value { @@ -3540,7 +3781,7 @@ type ActiveSpeakerUpdate struct { func (x *ActiveSpeakerUpdate) Reset() { *x = ActiveSpeakerUpdate{} - mi := &file_livekit_models_proto_msgTypes[20] + mi := &file_livekit_models_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3552,7 +3793,7 @@ func (x *ActiveSpeakerUpdate) String() string { func (*ActiveSpeakerUpdate) ProtoMessage() {} func (x *ActiveSpeakerUpdate) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[20] + mi := &file_livekit_models_proto_msgTypes[21] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3565,7 +3806,7 @@ func (x *ActiveSpeakerUpdate) ProtoReflect() protoreflect.Message { // Deprecated: Use ActiveSpeakerUpdate.ProtoReflect.Descriptor instead. func (*ActiveSpeakerUpdate) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{20} + return file_livekit_models_proto_rawDescGZIP(), []int{21} } func (x *ActiveSpeakerUpdate) GetSpeakers() []*SpeakerInfo { @@ -3588,7 +3829,7 @@ type SpeakerInfo struct { func (x *SpeakerInfo) Reset() { *x = SpeakerInfo{} - mi := &file_livekit_models_proto_msgTypes[21] + mi := &file_livekit_models_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3600,7 +3841,7 @@ func (x *SpeakerInfo) String() string { func (*SpeakerInfo) ProtoMessage() {} func (x *SpeakerInfo) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[21] + mi := &file_livekit_models_proto_msgTypes[22] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3613,7 +3854,7 @@ func (x *SpeakerInfo) ProtoReflect() protoreflect.Message { // Deprecated: Use SpeakerInfo.ProtoReflect.Descriptor instead. func (*SpeakerInfo) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{21} + return file_livekit_models_proto_rawDescGZIP(), []int{22} } func (x *SpeakerInfo) GetSid() string { @@ -3670,7 +3911,7 @@ type UserPacket struct { func (x *UserPacket) Reset() { *x = UserPacket{} - mi := &file_livekit_models_proto_msgTypes[22] + mi := &file_livekit_models_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3682,7 +3923,7 @@ func (x *UserPacket) String() string { func (*UserPacket) ProtoMessage() {} func (x *UserPacket) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[22] + mi := &file_livekit_models_proto_msgTypes[23] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3695,7 +3936,7 @@ func (x *UserPacket) ProtoReflect() protoreflect.Message { // Deprecated: Use UserPacket.ProtoReflect.Descriptor instead. func (*UserPacket) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{22} + return file_livekit_models_proto_rawDescGZIP(), []int{23} } // Deprecated: Marked as deprecated in livekit_models.proto. @@ -3782,7 +4023,7 @@ type SipDTMF struct { func (x *SipDTMF) Reset() { *x = SipDTMF{} - mi := &file_livekit_models_proto_msgTypes[23] + mi := &file_livekit_models_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3794,7 +4035,7 @@ func (x *SipDTMF) String() string { func (*SipDTMF) ProtoMessage() {} func (x *SipDTMF) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[23] + mi := &file_livekit_models_proto_msgTypes[24] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3807,7 +4048,7 @@ func (x *SipDTMF) ProtoReflect() protoreflect.Message { // Deprecated: Use SipDTMF.ProtoReflect.Descriptor instead. func (*SipDTMF) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{23} + return file_livekit_models_proto_rawDescGZIP(), []int{24} } func (x *SipDTMF) GetCode() uint32 { @@ -3836,7 +4077,7 @@ type Transcription struct { func (x *Transcription) Reset() { *x = Transcription{} - mi := &file_livekit_models_proto_msgTypes[24] + mi := &file_livekit_models_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3848,7 +4089,7 @@ func (x *Transcription) String() string { func (*Transcription) ProtoMessage() {} func (x *Transcription) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[24] + mi := &file_livekit_models_proto_msgTypes[25] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3861,7 +4102,7 @@ func (x *Transcription) ProtoReflect() protoreflect.Message { // Deprecated: Use Transcription.ProtoReflect.Descriptor instead. func (*Transcription) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{24} + return file_livekit_models_proto_rawDescGZIP(), []int{25} } func (x *Transcription) GetTranscribedParticipantIdentity() string { @@ -3899,7 +4140,7 @@ type TranscriptionSegment struct { func (x *TranscriptionSegment) Reset() { *x = TranscriptionSegment{} - mi := &file_livekit_models_proto_msgTypes[25] + mi := &file_livekit_models_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3911,7 +4152,7 @@ func (x *TranscriptionSegment) String() string { func (*TranscriptionSegment) ProtoMessage() {} func (x *TranscriptionSegment) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[25] + mi := &file_livekit_models_proto_msgTypes[26] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3924,7 +4165,7 @@ func (x *TranscriptionSegment) ProtoReflect() protoreflect.Message { // Deprecated: Use TranscriptionSegment.ProtoReflect.Descriptor instead. func (*TranscriptionSegment) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{25} + return file_livekit_models_proto_rawDescGZIP(), []int{26} } func (x *TranscriptionSegment) GetId() string { @@ -3983,7 +4224,7 @@ type ChatMessage struct { func (x *ChatMessage) Reset() { *x = ChatMessage{} - mi := &file_livekit_models_proto_msgTypes[26] + mi := &file_livekit_models_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3995,7 +4236,7 @@ func (x *ChatMessage) String() string { func (*ChatMessage) ProtoMessage() {} func (x *ChatMessage) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[26] + mi := &file_livekit_models_proto_msgTypes[27] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4008,7 +4249,7 @@ func (x *ChatMessage) ProtoReflect() protoreflect.Message { // Deprecated: Use ChatMessage.ProtoReflect.Descriptor instead. func (*ChatMessage) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{26} + return file_livekit_models_proto_rawDescGZIP(), []int{27} } func (x *ChatMessage) GetId() string { @@ -4068,7 +4309,7 @@ type RpcRequest struct { func (x *RpcRequest) Reset() { *x = RpcRequest{} - mi := &file_livekit_models_proto_msgTypes[27] + mi := &file_livekit_models_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4080,7 +4321,7 @@ func (x *RpcRequest) String() string { func (*RpcRequest) ProtoMessage() {} func (x *RpcRequest) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[27] + mi := &file_livekit_models_proto_msgTypes[28] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4093,7 +4334,7 @@ func (x *RpcRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use RpcRequest.ProtoReflect.Descriptor instead. func (*RpcRequest) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{27} + return file_livekit_models_proto_rawDescGZIP(), []int{28} } func (x *RpcRequest) GetId() string { @@ -4147,7 +4388,7 @@ type RpcAck struct { func (x *RpcAck) Reset() { *x = RpcAck{} - mi := &file_livekit_models_proto_msgTypes[28] + mi := &file_livekit_models_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4159,7 +4400,7 @@ func (x *RpcAck) String() string { func (*RpcAck) ProtoMessage() {} func (x *RpcAck) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[28] + mi := &file_livekit_models_proto_msgTypes[29] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4172,7 +4413,7 @@ func (x *RpcAck) ProtoReflect() protoreflect.Message { // Deprecated: Use RpcAck.ProtoReflect.Descriptor instead. func (*RpcAck) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{28} + return file_livekit_models_proto_rawDescGZIP(), []int{29} } func (x *RpcAck) GetRequestId() string { @@ -4197,7 +4438,7 @@ type RpcResponse struct { func (x *RpcResponse) Reset() { *x = RpcResponse{} - mi := &file_livekit_models_proto_msgTypes[29] + mi := &file_livekit_models_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4209,7 +4450,7 @@ func (x *RpcResponse) String() string { func (*RpcResponse) ProtoMessage() {} func (x *RpcResponse) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[29] + mi := &file_livekit_models_proto_msgTypes[30] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4222,7 +4463,7 @@ func (x *RpcResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use RpcResponse.ProtoReflect.Descriptor instead. func (*RpcResponse) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{29} + return file_livekit_models_proto_rawDescGZIP(), []int{30} } func (x *RpcResponse) GetRequestId() string { @@ -4300,7 +4541,7 @@ type RpcError struct { func (x *RpcError) Reset() { *x = RpcError{} - mi := &file_livekit_models_proto_msgTypes[30] + mi := &file_livekit_models_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4312,7 +4553,7 @@ func (x *RpcError) String() string { func (*RpcError) ProtoMessage() {} func (x *RpcError) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[30] + mi := &file_livekit_models_proto_msgTypes[31] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4325,7 +4566,7 @@ func (x *RpcError) ProtoReflect() protoreflect.Message { // Deprecated: Use RpcError.ProtoReflect.Descriptor instead. func (*RpcError) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{30} + return file_livekit_models_proto_rawDescGZIP(), []int{31} } func (x *RpcError) GetCode() uint32 { @@ -4360,7 +4601,7 @@ type ParticipantTracks struct { func (x *ParticipantTracks) Reset() { *x = ParticipantTracks{} - mi := &file_livekit_models_proto_msgTypes[31] + mi := &file_livekit_models_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4372,7 +4613,7 @@ func (x *ParticipantTracks) String() string { func (*ParticipantTracks) ProtoMessage() {} func (x *ParticipantTracks) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[31] + mi := &file_livekit_models_proto_msgTypes[32] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4385,7 +4626,7 @@ func (x *ParticipantTracks) ProtoReflect() protoreflect.Message { // Deprecated: Use ParticipantTracks.ProtoReflect.Descriptor instead. func (*ParticipantTracks) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{31} + return file_livekit_models_proto_rawDescGZIP(), []int{32} } func (x *ParticipantTracks) GetParticipantSid() string { @@ -4419,7 +4660,7 @@ type ServerInfo struct { func (x *ServerInfo) Reset() { *x = ServerInfo{} - mi := &file_livekit_models_proto_msgTypes[32] + mi := &file_livekit_models_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4431,7 +4672,7 @@ func (x *ServerInfo) String() string { func (*ServerInfo) ProtoMessage() {} func (x *ServerInfo) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[32] + mi := &file_livekit_models_proto_msgTypes[33] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4444,7 +4685,7 @@ func (x *ServerInfo) ProtoReflect() protoreflect.Message { // Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead. func (*ServerInfo) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{32} + return file_livekit_models_proto_rawDescGZIP(), []int{33} } func (x *ServerInfo) GetEdition() ServerInfo_Edition { @@ -4524,7 +4765,7 @@ type ClientInfo struct { func (x *ClientInfo) Reset() { *x = ClientInfo{} - mi := &file_livekit_models_proto_msgTypes[33] + mi := &file_livekit_models_proto_msgTypes[34] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4536,7 +4777,7 @@ func (x *ClientInfo) String() string { func (*ClientInfo) ProtoMessage() {} func (x *ClientInfo) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[33] + mi := &file_livekit_models_proto_msgTypes[34] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4549,7 +4790,7 @@ func (x *ClientInfo) ProtoReflect() protoreflect.Message { // Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead. func (*ClientInfo) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{33} + return file_livekit_models_proto_rawDescGZIP(), []int{34} } func (x *ClientInfo) GetSdk() ClientInfo_SDK { @@ -4657,7 +4898,7 @@ type ClientConfiguration struct { func (x *ClientConfiguration) Reset() { *x = ClientConfiguration{} - mi := &file_livekit_models_proto_msgTypes[34] + mi := &file_livekit_models_proto_msgTypes[35] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4669,7 +4910,7 @@ func (x *ClientConfiguration) String() string { func (*ClientConfiguration) ProtoMessage() {} func (x *ClientConfiguration) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[34] + mi := &file_livekit_models_proto_msgTypes[35] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4682,7 +4923,7 @@ func (x *ClientConfiguration) ProtoReflect() protoreflect.Message { // Deprecated: Use ClientConfiguration.ProtoReflect.Descriptor instead. func (*ClientConfiguration) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{34} + return file_livekit_models_proto_rawDescGZIP(), []int{35} } func (x *ClientConfiguration) GetVideo() *VideoConfiguration { @@ -4729,7 +4970,7 @@ type VideoConfiguration struct { func (x *VideoConfiguration) Reset() { *x = VideoConfiguration{} - mi := &file_livekit_models_proto_msgTypes[35] + mi := &file_livekit_models_proto_msgTypes[36] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4741,7 +4982,7 @@ func (x *VideoConfiguration) String() string { func (*VideoConfiguration) ProtoMessage() {} func (x *VideoConfiguration) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[35] + mi := &file_livekit_models_proto_msgTypes[36] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4754,7 +4995,7 @@ func (x *VideoConfiguration) ProtoReflect() protoreflect.Message { // Deprecated: Use VideoConfiguration.ProtoReflect.Descriptor instead. func (*VideoConfiguration) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{35} + return file_livekit_models_proto_rawDescGZIP(), []int{36} } func (x *VideoConfiguration) GetHardwareEncoder() ClientConfigSetting { @@ -4776,7 +5017,7 @@ type DisabledCodecs struct { func (x *DisabledCodecs) Reset() { *x = DisabledCodecs{} - mi := &file_livekit_models_proto_msgTypes[36] + mi := &file_livekit_models_proto_msgTypes[37] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4788,7 +5029,7 @@ func (x *DisabledCodecs) String() string { func (*DisabledCodecs) ProtoMessage() {} func (x *DisabledCodecs) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[36] + mi := &file_livekit_models_proto_msgTypes[37] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4801,7 +5042,7 @@ func (x *DisabledCodecs) ProtoReflect() protoreflect.Message { // Deprecated: Use DisabledCodecs.ProtoReflect.Descriptor instead. func (*DisabledCodecs) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{36} + return file_livekit_models_proto_rawDescGZIP(), []int{37} } func (x *DisabledCodecs) GetCodecs() []*Codec { @@ -4835,7 +5076,7 @@ type RTPDrift struct { func (x *RTPDrift) Reset() { *x = RTPDrift{} - mi := &file_livekit_models_proto_msgTypes[37] + mi := &file_livekit_models_proto_msgTypes[38] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4847,7 +5088,7 @@ func (x *RTPDrift) String() string { func (*RTPDrift) ProtoMessage() {} func (x *RTPDrift) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[37] + mi := &file_livekit_models_proto_msgTypes[38] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4860,7 +5101,7 @@ func (x *RTPDrift) ProtoReflect() protoreflect.Message { // Deprecated: Use RTPDrift.ProtoReflect.Descriptor instead. func (*RTPDrift) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{37} + return file_livekit_models_proto_rawDescGZIP(), []int{38} } func (x *RTPDrift) GetStartTime() *timestamppb.Timestamp { @@ -4979,7 +5220,7 @@ type RTPStats struct { func (x *RTPStats) Reset() { *x = RTPStats{} - mi := &file_livekit_models_proto_msgTypes[38] + mi := &file_livekit_models_proto_msgTypes[39] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4991,7 +5232,7 @@ func (x *RTPStats) String() string { func (*RTPStats) ProtoMessage() {} func (x *RTPStats) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[38] + mi := &file_livekit_models_proto_msgTypes[39] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5004,7 +5245,7 @@ func (x *RTPStats) ProtoReflect() protoreflect.Message { // Deprecated: Use RTPStats.ProtoReflect.Descriptor instead. func (*RTPStats) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{38} + return file_livekit_models_proto_rawDescGZIP(), []int{39} } func (x *RTPStats) GetStartTime() *timestamppb.Timestamp { @@ -5337,7 +5578,7 @@ type RTCPSenderReportState struct { func (x *RTCPSenderReportState) Reset() { *x = RTCPSenderReportState{} - mi := &file_livekit_models_proto_msgTypes[39] + mi := &file_livekit_models_proto_msgTypes[40] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5349,7 +5590,7 @@ func (x *RTCPSenderReportState) String() string { func (*RTCPSenderReportState) ProtoMessage() {} func (x *RTCPSenderReportState) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[39] + mi := &file_livekit_models_proto_msgTypes[40] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5362,7 +5603,7 @@ func (x *RTCPSenderReportState) ProtoReflect() protoreflect.Message { // Deprecated: Use RTCPSenderReportState.ProtoReflect.Descriptor instead. func (*RTCPSenderReportState) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{39} + return file_livekit_models_proto_rawDescGZIP(), []int{40} } func (x *RTCPSenderReportState) GetRtpTimestamp() uint32 { @@ -5433,7 +5674,7 @@ type RTPForwarderState struct { func (x *RTPForwarderState) Reset() { *x = RTPForwarderState{} - mi := &file_livekit_models_proto_msgTypes[40] + mi := &file_livekit_models_proto_msgTypes[41] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5445,7 +5686,7 @@ func (x *RTPForwarderState) String() string { func (*RTPForwarderState) ProtoMessage() {} func (x *RTPForwarderState) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[40] + mi := &file_livekit_models_proto_msgTypes[41] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5458,7 +5699,7 @@ func (x *RTPForwarderState) ProtoReflect() protoreflect.Message { // Deprecated: Use RTPForwarderState.ProtoReflect.Descriptor instead. func (*RTPForwarderState) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{40} + return file_livekit_models_proto_rawDescGZIP(), []int{41} } func (x *RTPForwarderState) GetStarted() bool { @@ -5550,7 +5791,7 @@ type RTPMungerState struct { func (x *RTPMungerState) Reset() { *x = RTPMungerState{} - mi := &file_livekit_models_proto_msgTypes[41] + mi := &file_livekit_models_proto_msgTypes[42] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5562,7 +5803,7 @@ func (x *RTPMungerState) String() string { func (*RTPMungerState) ProtoMessage() {} func (x *RTPMungerState) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[41] + mi := &file_livekit_models_proto_msgTypes[42] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5575,7 +5816,7 @@ func (x *RTPMungerState) ProtoReflect() protoreflect.Message { // Deprecated: Use RTPMungerState.ProtoReflect.Descriptor instead. func (*RTPMungerState) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{41} + return file_livekit_models_proto_rawDescGZIP(), []int{42} } func (x *RTPMungerState) GetExtLastSequenceNumber() uint64 { @@ -5635,7 +5876,7 @@ type VP8MungerState struct { func (x *VP8MungerState) Reset() { *x = VP8MungerState{} - mi := &file_livekit_models_proto_msgTypes[42] + mi := &file_livekit_models_proto_msgTypes[43] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5647,7 +5888,7 @@ func (x *VP8MungerState) String() string { func (*VP8MungerState) ProtoMessage() {} func (x *VP8MungerState) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[42] + mi := &file_livekit_models_proto_msgTypes[43] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5660,7 +5901,7 @@ func (x *VP8MungerState) ProtoReflect() protoreflect.Message { // Deprecated: Use VP8MungerState.ProtoReflect.Descriptor instead. func (*VP8MungerState) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{42} + return file_livekit_models_proto_rawDescGZIP(), []int{43} } func (x *VP8MungerState) GetExtLastPictureId() int32 { @@ -5722,7 +5963,7 @@ type TimedVersion struct { func (x *TimedVersion) Reset() { *x = TimedVersion{} - mi := &file_livekit_models_proto_msgTypes[43] + mi := &file_livekit_models_proto_msgTypes[44] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5734,7 +5975,7 @@ func (x *TimedVersion) String() string { func (*TimedVersion) ProtoMessage() {} func (x *TimedVersion) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[43] + mi := &file_livekit_models_proto_msgTypes[44] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5747,7 +5988,7 @@ func (x *TimedVersion) ProtoReflect() protoreflect.Message { // Deprecated: Use TimedVersion.ProtoReflect.Descriptor instead. func (*TimedVersion) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{43} + return file_livekit_models_proto_rawDescGZIP(), []int{44} } func (x *TimedVersion) GetUnixMicro() int64 { @@ -5772,7 +6013,7 @@ type DataStream struct { func (x *DataStream) Reset() { *x = DataStream{} - mi := &file_livekit_models_proto_msgTypes[44] + mi := &file_livekit_models_proto_msgTypes[45] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5784,7 +6025,7 @@ func (x *DataStream) String() string { func (*DataStream) ProtoMessage() {} func (x *DataStream) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[44] + mi := &file_livekit_models_proto_msgTypes[45] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5797,7 +6038,7 @@ func (x *DataStream) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream.ProtoReflect.Descriptor instead. func (*DataStream) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44} + return file_livekit_models_proto_rawDescGZIP(), []int{45} } type FilterParams struct { @@ -5810,7 +6051,7 @@ type FilterParams struct { func (x *FilterParams) Reset() { *x = FilterParams{} - mi := &file_livekit_models_proto_msgTypes[45] + mi := &file_livekit_models_proto_msgTypes[46] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5822,7 +6063,7 @@ func (x *FilterParams) String() string { func (*FilterParams) ProtoMessage() {} func (x *FilterParams) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[45] + mi := &file_livekit_models_proto_msgTypes[46] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5835,7 +6076,7 @@ func (x *FilterParams) ProtoReflect() protoreflect.Message { // Deprecated: Use FilterParams.ProtoReflect.Descriptor instead. func (*FilterParams) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{45} + return file_livekit_models_proto_rawDescGZIP(), []int{46} } func (x *FilterParams) GetIncludeEvents() []string { @@ -5863,7 +6104,7 @@ type WebhookConfig struct { func (x *WebhookConfig) Reset() { *x = WebhookConfig{} - mi := &file_livekit_models_proto_msgTypes[46] + mi := &file_livekit_models_proto_msgTypes[47] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5875,7 +6116,7 @@ func (x *WebhookConfig) String() string { func (*WebhookConfig) ProtoMessage() {} func (x *WebhookConfig) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[46] + mi := &file_livekit_models_proto_msgTypes[47] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5888,7 +6129,7 @@ func (x *WebhookConfig) ProtoReflect() protoreflect.Message { // Deprecated: Use WebhookConfig.ProtoReflect.Descriptor instead. func (*WebhookConfig) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{46} + return file_livekit_models_proto_rawDescGZIP(), []int{47} } func (x *WebhookConfig) GetUrl() string { @@ -5922,7 +6163,7 @@ type SubscribedAudioCodec struct { func (x *SubscribedAudioCodec) Reset() { *x = SubscribedAudioCodec{} - mi := &file_livekit_models_proto_msgTypes[47] + mi := &file_livekit_models_proto_msgTypes[48] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5934,7 +6175,7 @@ func (x *SubscribedAudioCodec) String() string { func (*SubscribedAudioCodec) ProtoMessage() {} func (x *SubscribedAudioCodec) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[47] + mi := &file_livekit_models_proto_msgTypes[48] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5947,7 +6188,7 @@ func (x *SubscribedAudioCodec) ProtoReflect() protoreflect.Message { // Deprecated: Use SubscribedAudioCodec.ProtoReflect.Descriptor instead. func (*SubscribedAudioCodec) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{47} + return file_livekit_models_proto_rawDescGZIP(), []int{48} } func (x *SubscribedAudioCodec) GetCodec() string { @@ -5978,7 +6219,7 @@ type DataStream_TextHeader struct { func (x *DataStream_TextHeader) Reset() { *x = DataStream_TextHeader{} - mi := &file_livekit_models_proto_msgTypes[50] + mi := &file_livekit_models_proto_msgTypes[51] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5990,7 +6231,7 @@ func (x *DataStream_TextHeader) String() string { func (*DataStream_TextHeader) ProtoMessage() {} func (x *DataStream_TextHeader) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[50] + mi := &file_livekit_models_proto_msgTypes[51] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -6003,7 +6244,7 @@ func (x *DataStream_TextHeader) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream_TextHeader.ProtoReflect.Descriptor instead. func (*DataStream_TextHeader) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 0} } func (x *DataStream_TextHeader) GetOperationType() DataStream_OperationType { @@ -6051,7 +6292,7 @@ type DataStream_ByteHeader struct { func (x *DataStream_ByteHeader) Reset() { *x = DataStream_ByteHeader{} - mi := &file_livekit_models_proto_msgTypes[51] + mi := &file_livekit_models_proto_msgTypes[52] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6063,7 +6304,7 @@ func (x *DataStream_ByteHeader) String() string { func (*DataStream_ByteHeader) ProtoMessage() {} func (x *DataStream_ByteHeader) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[51] + mi := &file_livekit_models_proto_msgTypes[52] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -6076,7 +6317,7 @@ func (x *DataStream_ByteHeader) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream_ByteHeader.ProtoReflect.Descriptor instead. func (*DataStream_ByteHeader) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 1} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 1} } func (x *DataStream_ByteHeader) GetName() string { @@ -6113,7 +6354,7 @@ type DataStream_Header struct { func (x *DataStream_Header) Reset() { *x = DataStream_Header{} - mi := &file_livekit_models_proto_msgTypes[52] + mi := &file_livekit_models_proto_msgTypes[53] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6125,7 +6366,7 @@ func (x *DataStream_Header) String() string { func (*DataStream_Header) ProtoMessage() {} func (x *DataStream_Header) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[52] + mi := &file_livekit_models_proto_msgTypes[53] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -6138,7 +6379,7 @@ func (x *DataStream_Header) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream_Header.ProtoReflect.Descriptor instead. func (*DataStream_Header) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 2} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 2} } func (x *DataStream_Header) GetStreamId() string { @@ -6260,7 +6501,7 @@ type DataStream_Chunk struct { func (x *DataStream_Chunk) Reset() { *x = DataStream_Chunk{} - mi := &file_livekit_models_proto_msgTypes[53] + mi := &file_livekit_models_proto_msgTypes[54] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6272,7 +6513,7 @@ func (x *DataStream_Chunk) String() string { func (*DataStream_Chunk) ProtoMessage() {} func (x *DataStream_Chunk) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[53] + mi := &file_livekit_models_proto_msgTypes[54] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -6285,7 +6526,7 @@ func (x *DataStream_Chunk) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream_Chunk.ProtoReflect.Descriptor instead. func (*DataStream_Chunk) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 3} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 3} } func (x *DataStream_Chunk) GetStreamId() string { @@ -6335,7 +6576,7 @@ type DataStream_Trailer struct { func (x *DataStream_Trailer) Reset() { *x = DataStream_Trailer{} - mi := &file_livekit_models_proto_msgTypes[54] + mi := &file_livekit_models_proto_msgTypes[55] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6347,7 +6588,7 @@ func (x *DataStream_Trailer) String() string { func (*DataStream_Trailer) ProtoMessage() {} func (x *DataStream_Trailer) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[54] + mi := &file_livekit_models_proto_msgTypes[55] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -6360,7 +6601,7 @@ func (x *DataStream_Trailer) ProtoReflect() protoreflect.Message { // Deprecated: Use DataStream_Trailer.ProtoReflect.Descriptor instead. func (*DataStream_Trailer) Descriptor() ([]byte, []int) { - return file_livekit_models_proto_rawDescGZIP(), []int{44, 4} + return file_livekit_models_proto_rawDescGZIP(), []int{45, 4} } func (x *DataStream_Trailer) GetStreamId() string { @@ -6532,7 +6773,7 @@ const file_livekit_models_proto_rawDesc = "" + "\aversion\x18\x12 \x01(\v2\x15.livekit.TimedVersionR\aversion\x12A\n" + "\x0eaudio_features\x18\x13 \x03(\x0e2\x1a.livekit.AudioTrackFeatureR\raudioFeatures\x12J\n" + "\x13backup_codec_policy\x18\x14 \x01(\x0e2\x1a.livekit.BackupCodecPolicyR\x11backupCodecPolicy\x12U\n" + - "\x17packet_trailer_features\x18\x15 \x03(\x0e2\x1d.livekit.PacketTrailerFeatureR\x15packetTrailerFeatures\"\x8e\x01\n" + + "\x17packet_trailer_features\x18\x15 \x03(\x0e2\x1d.livekit.PacketTrailerFeatureR\x15packetTrailerFeatures\"\xb2\x02\n" + "\rDataTrackInfo\x12\x1d\n" + "\n" + "pub_handle\x18\x01 \x01(\rR\tpubHandle\x12\x10\n" + @@ -6540,16 +6781,24 @@ const file_livekit_models_proto_rawDesc = "" + "\x04name\x18\x03 \x01(\tR\x04name\x128\n" + "\n" + "encryption\x18\x04 \x01(\x0e2\x18.livekit.Encryption.TypeR\n" + - "encryption\"z\n" + + "encryption\x12K\n" + + "\x0eframe_encoding\x18\x05 \x01(\x0e2\x1f.livekit.DataTrackFrameEncodingH\x00R\rframeEncoding\x88\x01\x01\x127\n" + + "\x06schema\x18\x06 \x01(\v2\x1a.livekit.DataTrackSchemaIdH\x01R\x06schema\x88\x01\x01B\x11\n" + + "\x0f_frame_encodingB\t\n" + + "\a_schema\"e\n" + + "\x11DataTrackSchemaId\x12\x12\n" + + "\x04name\x18\x01 \x01(\tR\x04name\x12<\n" + + "\bencoding\x18\x02 \x01(\x0e2 .livekit.DataTrackSchemaEncodingR\bencoding\"z\n" + " DataTrackExtensionParticipantSid\x12-\n" + "\x02id\x18\x01 \x01(\x0e2\x1d.livekit.DataTrackExtensionIDR\x02id\x12'\n" + "\x0fparticipant_sid\x18\x02 \x01(\tR\x0eparticipantSid\"Q\n" + "\x1cDataTrackSubscriptionOptions\x12\"\n" + "\n" + "target_fps\x18\x01 \x01(\rH\x00R\ttargetFps\x88\x01\x01B\r\n" + - "\v_target_fps\"0\n" + + "\v_target_fps\"k\n" + "\vDataBlobKey\x12\x1a\n" + - "\ageneric\x18\x01 \x01(\tH\x00R\agenericB\x05\n" + + "\ageneric\x18\x01 \x01(\tH\x00R\ageneric\x129\n" + + "\tschema_id\x18\x02 \x01(\v2\x1a.livekit.DataTrackSchemaIdH\x00R\bschemaIdB\x05\n" + "\x03key\"t\n" + "\bDataBlob\x12&\n" + "\x03key\x18\x01 \x01(\v2\x14.livekit.DataBlobKeyR\x03key\x12@\n" + @@ -6977,7 +7226,25 @@ const file_livekit_models_proto_rawDesc = "" + "\n" + "MICROPHONE\x10\x02\x12\x10\n" + "\fSCREEN_SHARE\x10\x03\x12\x16\n" + - "\x12SCREEN_SHARE_AUDIO\x10\x04*B\n" + + "\x12SCREEN_SHARE_AUDIO\x10\x04*\xcb\x02\n" + + "\x16DataTrackFrameEncoding\x12)\n" + + "%DATA_TRACK_FRAME_ENCODING_UNSPECIFIED\x10\x00\x12\"\n" + + "\x1eDATA_TRACK_FRAME_ENCODING_ROS1\x10\x01\x12!\n" + + "\x1dDATA_TRACK_FRAME_ENCODING_CDR\x10\x02\x12&\n" + + "\"DATA_TRACK_FRAME_ENCODING_PROTOBUF\x10\x03\x12(\n" + + "$DATA_TRACK_FRAME_ENCODING_FLATBUFFER\x10\x04\x12\"\n" + + "\x1eDATA_TRACK_FRAME_ENCODING_CBOR\x10\x05\x12%\n" + + "!DATA_TRACK_FRAME_ENCODING_MSGPACK\x10\x06\x12\"\n" + + "\x1eDATA_TRACK_FRAME_ENCODING_JSON\x10\a*\xe8\x02\n" + + "\x17DataTrackSchemaEncoding\x12*\n" + + "&DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED\x10\x00\x12'\n" + + "#DATA_TRACK_SCHEMA_ENCODING_PROTOBUF\x10\x01\x12)\n" + + "%DATA_TRACK_SCHEMA_ENCODING_FLATBUFFER\x10\x02\x12'\n" + + "#DATA_TRACK_SCHEMA_ENCODING_ROS1_MSG\x10\x03\x12'\n" + + "#DATA_TRACK_SCHEMA_ENCODING_ROS2_MSG\x10\x04\x12'\n" + + "#DATA_TRACK_SCHEMA_ENCODING_ROS2_IDL\x10\x05\x12&\n" + + "\"DATA_TRACK_SCHEMA_ENCODING_OMG_IDL\x10\x06\x12*\n" + + "&DATA_TRACK_SCHEMA_ENCODING_JSON_SCHEMA\x10\a*B\n" + "\x14DataTrackExtensionID\x12\x10\n" + "\fDTEI_INVALID\x10\x00\x12\x18\n" + "\x14DTEI_PARTICIPANT_SID\x10\x01*6\n" + @@ -7052,8 +7319,8 @@ func file_livekit_models_proto_rawDescGZIP() []byte { return file_livekit_models_proto_rawDescData } -var file_livekit_models_proto_enumTypes = make([]protoimpl.EnumInfo, 26) -var file_livekit_models_proto_msgTypes = make([]protoimpl.MessageInfo, 57) +var file_livekit_models_proto_enumTypes = make([]protoimpl.EnumInfo, 28) +var file_livekit_models_proto_msgTypes = make([]protoimpl.MessageInfo, 58) var file_livekit_models_proto_goTypes = []any{ (AudioCodec)(0), // 0: livekit.AudioCodec (VideoCodec)(0), // 1: livekit.VideoCodec @@ -7061,180 +7328,187 @@ var file_livekit_models_proto_goTypes = []any{ (BackupCodecPolicy)(0), // 3: livekit.BackupCodecPolicy (TrackType)(0), // 4: livekit.TrackType (TrackSource)(0), // 5: livekit.TrackSource - (DataTrackExtensionID)(0), // 6: livekit.DataTrackExtensionID - (VideoQuality)(0), // 7: livekit.VideoQuality - (ConnectionQuality)(0), // 8: livekit.ConnectionQuality - (ClientConfigSetting)(0), // 9: livekit.ClientConfigSetting - (DisconnectReason)(0), // 10: livekit.DisconnectReason - (ReconnectReason)(0), // 11: livekit.ReconnectReason - (SubscriptionError)(0), // 12: livekit.SubscriptionError - (AudioTrackFeature)(0), // 13: livekit.AudioTrackFeature - (PacketTrailerFeature)(0), // 14: livekit.PacketTrailerFeature - (ParticipantInfo_State)(0), // 15: livekit.ParticipantInfo.State - (ParticipantInfo_Kind)(0), // 16: livekit.ParticipantInfo.Kind - (ParticipantInfo_KindDetail)(0), // 17: livekit.ParticipantInfo.KindDetail - (Encryption_Type)(0), // 18: livekit.Encryption.Type - (VideoLayer_Mode)(0), // 19: livekit.VideoLayer.Mode - (DataPacket_Kind)(0), // 20: livekit.DataPacket.Kind - (ServerInfo_Edition)(0), // 21: livekit.ServerInfo.Edition - (ClientInfo_SDK)(0), // 22: livekit.ClientInfo.SDK - (ClientInfo_Capability)(0), // 23: livekit.ClientInfo.Capability - (DataStream_OperationType)(0), // 24: livekit.DataStream.OperationType - (DataStream_CompressionType)(0), // 25: livekit.DataStream.CompressionType - (*Pagination)(nil), // 26: livekit.Pagination - (*TokenPagination)(nil), // 27: livekit.TokenPagination - (*ListUpdate)(nil), // 28: livekit.ListUpdate - (*Room)(nil), // 29: livekit.Room - (*Codec)(nil), // 30: livekit.Codec - (*PlayoutDelay)(nil), // 31: livekit.PlayoutDelay - (*ParticipantPermission)(nil), // 32: livekit.ParticipantPermission - (*ParticipantInfo)(nil), // 33: livekit.ParticipantInfo - (*Encryption)(nil), // 34: livekit.Encryption - (*SimulcastCodecInfo)(nil), // 35: livekit.SimulcastCodecInfo - (*TrackInfo)(nil), // 36: livekit.TrackInfo - (*DataTrackInfo)(nil), // 37: livekit.DataTrackInfo - (*DataTrackExtensionParticipantSid)(nil), // 38: livekit.DataTrackExtensionParticipantSid - (*DataTrackSubscriptionOptions)(nil), // 39: livekit.DataTrackSubscriptionOptions - (*DataBlobKey)(nil), // 40: livekit.DataBlobKey - (*DataBlob)(nil), // 41: livekit.DataBlob - (*VideoLayer)(nil), // 42: livekit.VideoLayer - (*DataPacket)(nil), // 43: livekit.DataPacket - (*EncryptedPacket)(nil), // 44: livekit.EncryptedPacket - (*EncryptedPacketPayload)(nil), // 45: livekit.EncryptedPacketPayload - (*ActiveSpeakerUpdate)(nil), // 46: livekit.ActiveSpeakerUpdate - (*SpeakerInfo)(nil), // 47: livekit.SpeakerInfo - (*UserPacket)(nil), // 48: livekit.UserPacket - (*SipDTMF)(nil), // 49: livekit.SipDTMF - (*Transcription)(nil), // 50: livekit.Transcription - (*TranscriptionSegment)(nil), // 51: livekit.TranscriptionSegment - (*ChatMessage)(nil), // 52: livekit.ChatMessage - (*RpcRequest)(nil), // 53: livekit.RpcRequest - (*RpcAck)(nil), // 54: livekit.RpcAck - (*RpcResponse)(nil), // 55: livekit.RpcResponse - (*RpcError)(nil), // 56: livekit.RpcError - (*ParticipantTracks)(nil), // 57: livekit.ParticipantTracks - (*ServerInfo)(nil), // 58: livekit.ServerInfo - (*ClientInfo)(nil), // 59: livekit.ClientInfo - (*ClientConfiguration)(nil), // 60: livekit.ClientConfiguration - (*VideoConfiguration)(nil), // 61: livekit.VideoConfiguration - (*DisabledCodecs)(nil), // 62: livekit.DisabledCodecs - (*RTPDrift)(nil), // 63: livekit.RTPDrift - (*RTPStats)(nil), // 64: livekit.RTPStats - (*RTCPSenderReportState)(nil), // 65: livekit.RTCPSenderReportState - (*RTPForwarderState)(nil), // 66: livekit.RTPForwarderState - (*RTPMungerState)(nil), // 67: livekit.RTPMungerState - (*VP8MungerState)(nil), // 68: livekit.VP8MungerState - (*TimedVersion)(nil), // 69: livekit.TimedVersion - (*DataStream)(nil), // 70: livekit.DataStream - (*FilterParams)(nil), // 71: livekit.FilterParams - (*WebhookConfig)(nil), // 72: livekit.WebhookConfig - (*SubscribedAudioCodec)(nil), // 73: livekit.SubscribedAudioCodec - nil, // 74: livekit.ParticipantInfo.AttributesEntry - nil, // 75: livekit.RTPStats.GapHistogramEntry - (*DataStream_TextHeader)(nil), // 76: livekit.DataStream.TextHeader - (*DataStream_ByteHeader)(nil), // 77: livekit.DataStream.ByteHeader - (*DataStream_Header)(nil), // 78: livekit.DataStream.Header - (*DataStream_Chunk)(nil), // 79: livekit.DataStream.Chunk - (*DataStream_Trailer)(nil), // 80: livekit.DataStream.Trailer - nil, // 81: livekit.DataStream.Header.AttributesEntry - nil, // 82: livekit.DataStream.Trailer.AttributesEntry - (*MetricsBatch)(nil), // 83: livekit.MetricsBatch - (*timestamppb.Timestamp)(nil), // 84: google.protobuf.Timestamp + (DataTrackFrameEncoding)(0), // 6: livekit.DataTrackFrameEncoding + (DataTrackSchemaEncoding)(0), // 7: livekit.DataTrackSchemaEncoding + (DataTrackExtensionID)(0), // 8: livekit.DataTrackExtensionID + (VideoQuality)(0), // 9: livekit.VideoQuality + (ConnectionQuality)(0), // 10: livekit.ConnectionQuality + (ClientConfigSetting)(0), // 11: livekit.ClientConfigSetting + (DisconnectReason)(0), // 12: livekit.DisconnectReason + (ReconnectReason)(0), // 13: livekit.ReconnectReason + (SubscriptionError)(0), // 14: livekit.SubscriptionError + (AudioTrackFeature)(0), // 15: livekit.AudioTrackFeature + (PacketTrailerFeature)(0), // 16: livekit.PacketTrailerFeature + (ParticipantInfo_State)(0), // 17: livekit.ParticipantInfo.State + (ParticipantInfo_Kind)(0), // 18: livekit.ParticipantInfo.Kind + (ParticipantInfo_KindDetail)(0), // 19: livekit.ParticipantInfo.KindDetail + (Encryption_Type)(0), // 20: livekit.Encryption.Type + (VideoLayer_Mode)(0), // 21: livekit.VideoLayer.Mode + (DataPacket_Kind)(0), // 22: livekit.DataPacket.Kind + (ServerInfo_Edition)(0), // 23: livekit.ServerInfo.Edition + (ClientInfo_SDK)(0), // 24: livekit.ClientInfo.SDK + (ClientInfo_Capability)(0), // 25: livekit.ClientInfo.Capability + (DataStream_OperationType)(0), // 26: livekit.DataStream.OperationType + (DataStream_CompressionType)(0), // 27: livekit.DataStream.CompressionType + (*Pagination)(nil), // 28: livekit.Pagination + (*TokenPagination)(nil), // 29: livekit.TokenPagination + (*ListUpdate)(nil), // 30: livekit.ListUpdate + (*Room)(nil), // 31: livekit.Room + (*Codec)(nil), // 32: livekit.Codec + (*PlayoutDelay)(nil), // 33: livekit.PlayoutDelay + (*ParticipantPermission)(nil), // 34: livekit.ParticipantPermission + (*ParticipantInfo)(nil), // 35: livekit.ParticipantInfo + (*Encryption)(nil), // 36: livekit.Encryption + (*SimulcastCodecInfo)(nil), // 37: livekit.SimulcastCodecInfo + (*TrackInfo)(nil), // 38: livekit.TrackInfo + (*DataTrackInfo)(nil), // 39: livekit.DataTrackInfo + (*DataTrackSchemaId)(nil), // 40: livekit.DataTrackSchemaId + (*DataTrackExtensionParticipantSid)(nil), // 41: livekit.DataTrackExtensionParticipantSid + (*DataTrackSubscriptionOptions)(nil), // 42: livekit.DataTrackSubscriptionOptions + (*DataBlobKey)(nil), // 43: livekit.DataBlobKey + (*DataBlob)(nil), // 44: livekit.DataBlob + (*VideoLayer)(nil), // 45: livekit.VideoLayer + (*DataPacket)(nil), // 46: livekit.DataPacket + (*EncryptedPacket)(nil), // 47: livekit.EncryptedPacket + (*EncryptedPacketPayload)(nil), // 48: livekit.EncryptedPacketPayload + (*ActiveSpeakerUpdate)(nil), // 49: livekit.ActiveSpeakerUpdate + (*SpeakerInfo)(nil), // 50: livekit.SpeakerInfo + (*UserPacket)(nil), // 51: livekit.UserPacket + (*SipDTMF)(nil), // 52: livekit.SipDTMF + (*Transcription)(nil), // 53: livekit.Transcription + (*TranscriptionSegment)(nil), // 54: livekit.TranscriptionSegment + (*ChatMessage)(nil), // 55: livekit.ChatMessage + (*RpcRequest)(nil), // 56: livekit.RpcRequest + (*RpcAck)(nil), // 57: livekit.RpcAck + (*RpcResponse)(nil), // 58: livekit.RpcResponse + (*RpcError)(nil), // 59: livekit.RpcError + (*ParticipantTracks)(nil), // 60: livekit.ParticipantTracks + (*ServerInfo)(nil), // 61: livekit.ServerInfo + (*ClientInfo)(nil), // 62: livekit.ClientInfo + (*ClientConfiguration)(nil), // 63: livekit.ClientConfiguration + (*VideoConfiguration)(nil), // 64: livekit.VideoConfiguration + (*DisabledCodecs)(nil), // 65: livekit.DisabledCodecs + (*RTPDrift)(nil), // 66: livekit.RTPDrift + (*RTPStats)(nil), // 67: livekit.RTPStats + (*RTCPSenderReportState)(nil), // 68: livekit.RTCPSenderReportState + (*RTPForwarderState)(nil), // 69: livekit.RTPForwarderState + (*RTPMungerState)(nil), // 70: livekit.RTPMungerState + (*VP8MungerState)(nil), // 71: livekit.VP8MungerState + (*TimedVersion)(nil), // 72: livekit.TimedVersion + (*DataStream)(nil), // 73: livekit.DataStream + (*FilterParams)(nil), // 74: livekit.FilterParams + (*WebhookConfig)(nil), // 75: livekit.WebhookConfig + (*SubscribedAudioCodec)(nil), // 76: livekit.SubscribedAudioCodec + nil, // 77: livekit.ParticipantInfo.AttributesEntry + nil, // 78: livekit.RTPStats.GapHistogramEntry + (*DataStream_TextHeader)(nil), // 79: livekit.DataStream.TextHeader + (*DataStream_ByteHeader)(nil), // 80: livekit.DataStream.ByteHeader + (*DataStream_Header)(nil), // 81: livekit.DataStream.Header + (*DataStream_Chunk)(nil), // 82: livekit.DataStream.Chunk + (*DataStream_Trailer)(nil), // 83: livekit.DataStream.Trailer + nil, // 84: livekit.DataStream.Header.AttributesEntry + nil, // 85: livekit.DataStream.Trailer.AttributesEntry + (*MetricsBatch)(nil), // 86: livekit.MetricsBatch + (*timestamppb.Timestamp)(nil), // 87: google.protobuf.Timestamp } var file_livekit_models_proto_depIdxs = []int32{ - 30, // 0: livekit.Room.enabled_codecs:type_name -> livekit.Codec - 69, // 1: livekit.Room.version:type_name -> livekit.TimedVersion + 32, // 0: livekit.Room.enabled_codecs:type_name -> livekit.Codec + 72, // 1: livekit.Room.version:type_name -> livekit.TimedVersion 5, // 2: livekit.ParticipantPermission.can_publish_sources:type_name -> livekit.TrackSource - 15, // 3: livekit.ParticipantInfo.state:type_name -> livekit.ParticipantInfo.State - 36, // 4: livekit.ParticipantInfo.tracks:type_name -> livekit.TrackInfo - 32, // 5: livekit.ParticipantInfo.permission:type_name -> livekit.ParticipantPermission - 16, // 6: livekit.ParticipantInfo.kind:type_name -> livekit.ParticipantInfo.Kind - 74, // 7: livekit.ParticipantInfo.attributes:type_name -> livekit.ParticipantInfo.AttributesEntry - 10, // 8: livekit.ParticipantInfo.disconnect_reason:type_name -> livekit.DisconnectReason - 17, // 9: livekit.ParticipantInfo.kind_details:type_name -> livekit.ParticipantInfo.KindDetail - 37, // 10: livekit.ParticipantInfo.data_tracks:type_name -> livekit.DataTrackInfo - 23, // 11: livekit.ParticipantInfo.capabilities:type_name -> livekit.ClientInfo.Capability - 42, // 12: livekit.SimulcastCodecInfo.layers:type_name -> livekit.VideoLayer - 19, // 13: livekit.SimulcastCodecInfo.video_layer_mode:type_name -> livekit.VideoLayer.Mode + 17, // 3: livekit.ParticipantInfo.state:type_name -> livekit.ParticipantInfo.State + 38, // 4: livekit.ParticipantInfo.tracks:type_name -> livekit.TrackInfo + 34, // 5: livekit.ParticipantInfo.permission:type_name -> livekit.ParticipantPermission + 18, // 6: livekit.ParticipantInfo.kind:type_name -> livekit.ParticipantInfo.Kind + 77, // 7: livekit.ParticipantInfo.attributes:type_name -> livekit.ParticipantInfo.AttributesEntry + 12, // 8: livekit.ParticipantInfo.disconnect_reason:type_name -> livekit.DisconnectReason + 19, // 9: livekit.ParticipantInfo.kind_details:type_name -> livekit.ParticipantInfo.KindDetail + 39, // 10: livekit.ParticipantInfo.data_tracks:type_name -> livekit.DataTrackInfo + 25, // 11: livekit.ParticipantInfo.capabilities:type_name -> livekit.ClientInfo.Capability + 45, // 12: livekit.SimulcastCodecInfo.layers:type_name -> livekit.VideoLayer + 21, // 13: livekit.SimulcastCodecInfo.video_layer_mode:type_name -> livekit.VideoLayer.Mode 4, // 14: livekit.TrackInfo.type:type_name -> livekit.TrackType 5, // 15: livekit.TrackInfo.source:type_name -> livekit.TrackSource - 42, // 16: livekit.TrackInfo.layers:type_name -> livekit.VideoLayer - 35, // 17: livekit.TrackInfo.codecs:type_name -> livekit.SimulcastCodecInfo - 18, // 18: livekit.TrackInfo.encryption:type_name -> livekit.Encryption.Type - 69, // 19: livekit.TrackInfo.version:type_name -> livekit.TimedVersion - 13, // 20: livekit.TrackInfo.audio_features:type_name -> livekit.AudioTrackFeature + 45, // 16: livekit.TrackInfo.layers:type_name -> livekit.VideoLayer + 37, // 17: livekit.TrackInfo.codecs:type_name -> livekit.SimulcastCodecInfo + 20, // 18: livekit.TrackInfo.encryption:type_name -> livekit.Encryption.Type + 72, // 19: livekit.TrackInfo.version:type_name -> livekit.TimedVersion + 15, // 20: livekit.TrackInfo.audio_features:type_name -> livekit.AudioTrackFeature 3, // 21: livekit.TrackInfo.backup_codec_policy:type_name -> livekit.BackupCodecPolicy - 14, // 22: livekit.TrackInfo.packet_trailer_features:type_name -> livekit.PacketTrailerFeature - 18, // 23: livekit.DataTrackInfo.encryption:type_name -> livekit.Encryption.Type - 6, // 24: livekit.DataTrackExtensionParticipantSid.id:type_name -> livekit.DataTrackExtensionID - 40, // 25: livekit.DataBlob.key:type_name -> livekit.DataBlobKey - 7, // 26: livekit.VideoLayer.quality:type_name -> livekit.VideoQuality - 20, // 27: livekit.DataPacket.kind:type_name -> livekit.DataPacket.Kind - 48, // 28: livekit.DataPacket.user:type_name -> livekit.UserPacket - 46, // 29: livekit.DataPacket.speaker:type_name -> livekit.ActiveSpeakerUpdate - 49, // 30: livekit.DataPacket.sip_dtmf:type_name -> livekit.SipDTMF - 50, // 31: livekit.DataPacket.transcription:type_name -> livekit.Transcription - 83, // 32: livekit.DataPacket.metrics:type_name -> livekit.MetricsBatch - 52, // 33: livekit.DataPacket.chat_message:type_name -> livekit.ChatMessage - 53, // 34: livekit.DataPacket.rpc_request:type_name -> livekit.RpcRequest - 54, // 35: livekit.DataPacket.rpc_ack:type_name -> livekit.RpcAck - 55, // 36: livekit.DataPacket.rpc_response:type_name -> livekit.RpcResponse - 78, // 37: livekit.DataPacket.stream_header:type_name -> livekit.DataStream.Header - 79, // 38: livekit.DataPacket.stream_chunk:type_name -> livekit.DataStream.Chunk - 80, // 39: livekit.DataPacket.stream_trailer:type_name -> livekit.DataStream.Trailer - 44, // 40: livekit.DataPacket.encrypted_packet:type_name -> livekit.EncryptedPacket - 18, // 41: livekit.EncryptedPacket.encryption_type:type_name -> livekit.Encryption.Type - 48, // 42: livekit.EncryptedPacketPayload.user:type_name -> livekit.UserPacket - 52, // 43: livekit.EncryptedPacketPayload.chat_message:type_name -> livekit.ChatMessage - 53, // 44: livekit.EncryptedPacketPayload.rpc_request:type_name -> livekit.RpcRequest - 54, // 45: livekit.EncryptedPacketPayload.rpc_ack:type_name -> livekit.RpcAck - 55, // 46: livekit.EncryptedPacketPayload.rpc_response:type_name -> livekit.RpcResponse - 78, // 47: livekit.EncryptedPacketPayload.stream_header:type_name -> livekit.DataStream.Header - 79, // 48: livekit.EncryptedPacketPayload.stream_chunk:type_name -> livekit.DataStream.Chunk - 80, // 49: livekit.EncryptedPacketPayload.stream_trailer:type_name -> livekit.DataStream.Trailer - 47, // 50: livekit.ActiveSpeakerUpdate.speakers:type_name -> livekit.SpeakerInfo - 51, // 51: livekit.Transcription.segments:type_name -> livekit.TranscriptionSegment - 56, // 52: livekit.RpcResponse.error:type_name -> livekit.RpcError - 21, // 53: livekit.ServerInfo.edition:type_name -> livekit.ServerInfo.Edition - 22, // 54: livekit.ClientInfo.sdk:type_name -> livekit.ClientInfo.SDK - 23, // 55: livekit.ClientInfo.capabilities:type_name -> livekit.ClientInfo.Capability - 61, // 56: livekit.ClientConfiguration.video:type_name -> livekit.VideoConfiguration - 61, // 57: livekit.ClientConfiguration.screen:type_name -> livekit.VideoConfiguration - 9, // 58: livekit.ClientConfiguration.resume_connection:type_name -> livekit.ClientConfigSetting - 62, // 59: livekit.ClientConfiguration.disabled_codecs:type_name -> livekit.DisabledCodecs - 9, // 60: livekit.ClientConfiguration.force_relay:type_name -> livekit.ClientConfigSetting - 9, // 61: livekit.VideoConfiguration.hardware_encoder:type_name -> livekit.ClientConfigSetting - 30, // 62: livekit.DisabledCodecs.codecs:type_name -> livekit.Codec - 30, // 63: livekit.DisabledCodecs.publish:type_name -> livekit.Codec - 84, // 64: livekit.RTPDrift.start_time:type_name -> google.protobuf.Timestamp - 84, // 65: livekit.RTPDrift.end_time:type_name -> google.protobuf.Timestamp - 84, // 66: livekit.RTPStats.start_time:type_name -> google.protobuf.Timestamp - 84, // 67: livekit.RTPStats.end_time:type_name -> google.protobuf.Timestamp - 75, // 68: livekit.RTPStats.gap_histogram:type_name -> livekit.RTPStats.GapHistogramEntry - 84, // 69: livekit.RTPStats.last_pli:type_name -> google.protobuf.Timestamp - 84, // 70: livekit.RTPStats.last_fir:type_name -> google.protobuf.Timestamp - 84, // 71: livekit.RTPStats.last_key_frame:type_name -> google.protobuf.Timestamp - 84, // 72: livekit.RTPStats.last_layer_lock_pli:type_name -> google.protobuf.Timestamp - 63, // 73: livekit.RTPStats.packet_drift:type_name -> livekit.RTPDrift - 63, // 74: livekit.RTPStats.ntp_report_drift:type_name -> livekit.RTPDrift - 63, // 75: livekit.RTPStats.rebased_report_drift:type_name -> livekit.RTPDrift - 63, // 76: livekit.RTPStats.received_report_drift:type_name -> livekit.RTPDrift - 67, // 77: livekit.RTPForwarderState.rtp_munger:type_name -> livekit.RTPMungerState - 68, // 78: livekit.RTPForwarderState.vp8_munger:type_name -> livekit.VP8MungerState - 65, // 79: livekit.RTPForwarderState.sender_report_state:type_name -> livekit.RTCPSenderReportState - 71, // 80: livekit.WebhookConfig.filter_params:type_name -> livekit.FilterParams - 24, // 81: livekit.DataStream.TextHeader.operation_type:type_name -> livekit.DataStream.OperationType - 18, // 82: livekit.DataStream.Header.encryption_type:type_name -> livekit.Encryption.Type - 81, // 83: livekit.DataStream.Header.attributes:type_name -> livekit.DataStream.Header.AttributesEntry - 76, // 84: livekit.DataStream.Header.text_header:type_name -> livekit.DataStream.TextHeader - 77, // 85: livekit.DataStream.Header.byte_header:type_name -> livekit.DataStream.ByteHeader - 25, // 86: livekit.DataStream.Header.compression:type_name -> livekit.DataStream.CompressionType - 82, // 87: livekit.DataStream.Trailer.attributes:type_name -> livekit.DataStream.Trailer.AttributesEntry - 88, // [88:88] is the sub-list for method output_type - 88, // [88:88] is the sub-list for method input_type - 88, // [88:88] is the sub-list for extension type_name - 88, // [88:88] is the sub-list for extension extendee - 0, // [0:88] is the sub-list for field type_name + 16, // 22: livekit.TrackInfo.packet_trailer_features:type_name -> livekit.PacketTrailerFeature + 20, // 23: livekit.DataTrackInfo.encryption:type_name -> livekit.Encryption.Type + 6, // 24: livekit.DataTrackInfo.frame_encoding:type_name -> livekit.DataTrackFrameEncoding + 40, // 25: livekit.DataTrackInfo.schema:type_name -> livekit.DataTrackSchemaId + 7, // 26: livekit.DataTrackSchemaId.encoding:type_name -> livekit.DataTrackSchemaEncoding + 8, // 27: livekit.DataTrackExtensionParticipantSid.id:type_name -> livekit.DataTrackExtensionID + 40, // 28: livekit.DataBlobKey.schema_id:type_name -> livekit.DataTrackSchemaId + 43, // 29: livekit.DataBlob.key:type_name -> livekit.DataBlobKey + 9, // 30: livekit.VideoLayer.quality:type_name -> livekit.VideoQuality + 22, // 31: livekit.DataPacket.kind:type_name -> livekit.DataPacket.Kind + 51, // 32: livekit.DataPacket.user:type_name -> livekit.UserPacket + 49, // 33: livekit.DataPacket.speaker:type_name -> livekit.ActiveSpeakerUpdate + 52, // 34: livekit.DataPacket.sip_dtmf:type_name -> livekit.SipDTMF + 53, // 35: livekit.DataPacket.transcription:type_name -> livekit.Transcription + 86, // 36: livekit.DataPacket.metrics:type_name -> livekit.MetricsBatch + 55, // 37: livekit.DataPacket.chat_message:type_name -> livekit.ChatMessage + 56, // 38: livekit.DataPacket.rpc_request:type_name -> livekit.RpcRequest + 57, // 39: livekit.DataPacket.rpc_ack:type_name -> livekit.RpcAck + 58, // 40: livekit.DataPacket.rpc_response:type_name -> livekit.RpcResponse + 81, // 41: livekit.DataPacket.stream_header:type_name -> livekit.DataStream.Header + 82, // 42: livekit.DataPacket.stream_chunk:type_name -> livekit.DataStream.Chunk + 83, // 43: livekit.DataPacket.stream_trailer:type_name -> livekit.DataStream.Trailer + 47, // 44: livekit.DataPacket.encrypted_packet:type_name -> livekit.EncryptedPacket + 20, // 45: livekit.EncryptedPacket.encryption_type:type_name -> livekit.Encryption.Type + 51, // 46: livekit.EncryptedPacketPayload.user:type_name -> livekit.UserPacket + 55, // 47: livekit.EncryptedPacketPayload.chat_message:type_name -> livekit.ChatMessage + 56, // 48: livekit.EncryptedPacketPayload.rpc_request:type_name -> livekit.RpcRequest + 57, // 49: livekit.EncryptedPacketPayload.rpc_ack:type_name -> livekit.RpcAck + 58, // 50: livekit.EncryptedPacketPayload.rpc_response:type_name -> livekit.RpcResponse + 81, // 51: livekit.EncryptedPacketPayload.stream_header:type_name -> livekit.DataStream.Header + 82, // 52: livekit.EncryptedPacketPayload.stream_chunk:type_name -> livekit.DataStream.Chunk + 83, // 53: livekit.EncryptedPacketPayload.stream_trailer:type_name -> livekit.DataStream.Trailer + 50, // 54: livekit.ActiveSpeakerUpdate.speakers:type_name -> livekit.SpeakerInfo + 54, // 55: livekit.Transcription.segments:type_name -> livekit.TranscriptionSegment + 59, // 56: livekit.RpcResponse.error:type_name -> livekit.RpcError + 23, // 57: livekit.ServerInfo.edition:type_name -> livekit.ServerInfo.Edition + 24, // 58: livekit.ClientInfo.sdk:type_name -> livekit.ClientInfo.SDK + 25, // 59: livekit.ClientInfo.capabilities:type_name -> livekit.ClientInfo.Capability + 64, // 60: livekit.ClientConfiguration.video:type_name -> livekit.VideoConfiguration + 64, // 61: livekit.ClientConfiguration.screen:type_name -> livekit.VideoConfiguration + 11, // 62: livekit.ClientConfiguration.resume_connection:type_name -> livekit.ClientConfigSetting + 65, // 63: livekit.ClientConfiguration.disabled_codecs:type_name -> livekit.DisabledCodecs + 11, // 64: livekit.ClientConfiguration.force_relay:type_name -> livekit.ClientConfigSetting + 11, // 65: livekit.VideoConfiguration.hardware_encoder:type_name -> livekit.ClientConfigSetting + 32, // 66: livekit.DisabledCodecs.codecs:type_name -> livekit.Codec + 32, // 67: livekit.DisabledCodecs.publish:type_name -> livekit.Codec + 87, // 68: livekit.RTPDrift.start_time:type_name -> google.protobuf.Timestamp + 87, // 69: livekit.RTPDrift.end_time:type_name -> google.protobuf.Timestamp + 87, // 70: livekit.RTPStats.start_time:type_name -> google.protobuf.Timestamp + 87, // 71: livekit.RTPStats.end_time:type_name -> google.protobuf.Timestamp + 78, // 72: livekit.RTPStats.gap_histogram:type_name -> livekit.RTPStats.GapHistogramEntry + 87, // 73: livekit.RTPStats.last_pli:type_name -> google.protobuf.Timestamp + 87, // 74: livekit.RTPStats.last_fir:type_name -> google.protobuf.Timestamp + 87, // 75: livekit.RTPStats.last_key_frame:type_name -> google.protobuf.Timestamp + 87, // 76: livekit.RTPStats.last_layer_lock_pli:type_name -> google.protobuf.Timestamp + 66, // 77: livekit.RTPStats.packet_drift:type_name -> livekit.RTPDrift + 66, // 78: livekit.RTPStats.ntp_report_drift:type_name -> livekit.RTPDrift + 66, // 79: livekit.RTPStats.rebased_report_drift:type_name -> livekit.RTPDrift + 66, // 80: livekit.RTPStats.received_report_drift:type_name -> livekit.RTPDrift + 70, // 81: livekit.RTPForwarderState.rtp_munger:type_name -> livekit.RTPMungerState + 71, // 82: livekit.RTPForwarderState.vp8_munger:type_name -> livekit.VP8MungerState + 68, // 83: livekit.RTPForwarderState.sender_report_state:type_name -> livekit.RTCPSenderReportState + 74, // 84: livekit.WebhookConfig.filter_params:type_name -> livekit.FilterParams + 26, // 85: livekit.DataStream.TextHeader.operation_type:type_name -> livekit.DataStream.OperationType + 20, // 86: livekit.DataStream.Header.encryption_type:type_name -> livekit.Encryption.Type + 84, // 87: livekit.DataStream.Header.attributes:type_name -> livekit.DataStream.Header.AttributesEntry + 79, // 88: livekit.DataStream.Header.text_header:type_name -> livekit.DataStream.TextHeader + 80, // 89: livekit.DataStream.Header.byte_header:type_name -> livekit.DataStream.ByteHeader + 27, // 90: livekit.DataStream.Header.compression:type_name -> livekit.DataStream.CompressionType + 85, // 91: livekit.DataStream.Trailer.attributes:type_name -> livekit.DataStream.Trailer.AttributesEntry + 92, // [92:92] is the sub-list for method output_type + 92, // [92:92] is the sub-list for method input_type + 92, // [92:92] is the sub-list for extension type_name + 92, // [92:92] is the sub-list for extension extendee + 0, // [0:92] is the sub-list for field type_name } func init() { file_livekit_models_proto_init() } @@ -7243,11 +7517,13 @@ func file_livekit_models_proto_init() { return } file_livekit_metrics_proto_init() - file_livekit_models_proto_msgTypes[13].OneofWrappers = []any{} - file_livekit_models_proto_msgTypes[14].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[11].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[14].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[15].OneofWrappers = []any{ (*DataBlobKey_Generic)(nil), + (*DataBlobKey_SchemaId)(nil), } - file_livekit_models_proto_msgTypes[17].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[18].OneofWrappers = []any{ (*DataPacket_User)(nil), (*DataPacket_Speaker)(nil), (*DataPacket_SipDtmf)(nil), @@ -7262,7 +7538,7 @@ func file_livekit_models_proto_init() { (*DataPacket_StreamTrailer)(nil), (*DataPacket_EncryptedPacket)(nil), } - file_livekit_models_proto_msgTypes[19].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[20].OneofWrappers = []any{ (*EncryptedPacketPayload_User)(nil), (*EncryptedPacketPayload_ChatMessage)(nil), (*EncryptedPacketPayload_RpcRequest)(nil), @@ -7272,28 +7548,28 @@ func file_livekit_models_proto_init() { (*EncryptedPacketPayload_StreamChunk)(nil), (*EncryptedPacketPayload_StreamTrailer)(nil), } - file_livekit_models_proto_msgTypes[22].OneofWrappers = []any{} - file_livekit_models_proto_msgTypes[26].OneofWrappers = []any{} - file_livekit_models_proto_msgTypes[29].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[23].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[27].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[30].OneofWrappers = []any{ (*RpcResponse_Payload)(nil), (*RpcResponse_Error)(nil), (*RpcResponse_CompressedPayload)(nil), } - file_livekit_models_proto_msgTypes[40].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[41].OneofWrappers = []any{ (*RTPForwarderState_Vp8Munger)(nil), } - file_livekit_models_proto_msgTypes[52].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[53].OneofWrappers = []any{ (*DataStream_Header_TextHeader)(nil), (*DataStream_Header_ByteHeader)(nil), } - file_livekit_models_proto_msgTypes[53].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[54].OneofWrappers = []any{} type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_models_proto_rawDesc), len(file_livekit_models_proto_rawDesc)), - NumEnums: 26, - NumMessages: 57, + NumEnums: 28, + NumMessages: 58, NumExtensions: 0, NumServices: 0, }, diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index 1ee246122..68251dde2 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -1604,7 +1604,12 @@ type PublishDataTrackRequest struct { // This must be non-empty and no longer than 256 characters. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Method used for end-to-end encryption (E2EE) on frame payloads. - Encryption Encryption_Type `protobuf:"varint,3,opt,name=encryption,proto3,enum=livekit.Encryption_Type" json:"encryption,omitempty"` + Encryption Encryption_Type `protobuf:"varint,3,opt,name=encryption,proto3,enum=livekit.Encryption_Type" json:"encryption,omitempty"` + // Encoding for frame payloads on this track. If unspecified, the track is untyped. + FrameEncoding *DataTrackFrameEncoding `protobuf:"varint,4,opt,name=frame_encoding,json=frameEncoding,proto3,enum=livekit.DataTrackFrameEncoding,oneof" json:"frame_encoding,omitempty"` + // ID of the schema used by frames on this track if the track is typed. + // If set, the associated schema must be stored with `StoreDataBlobRequest`. + Schema *DataTrackSchemaId `protobuf:"bytes,5,opt,name=schema,proto3,oneof" json:"schema,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -1660,6 +1665,20 @@ func (x *PublishDataTrackRequest) GetEncryption() Encryption_Type { return Encryption_NONE } +func (x *PublishDataTrackRequest) GetFrameEncoding() DataTrackFrameEncoding { + if x != nil && x.FrameEncoding != nil { + return *x.FrameEncoding + } + return DataTrackFrameEncoding_DATA_TRACK_FRAME_ENCODING_UNSPECIFIED +} + +func (x *PublishDataTrackRequest) GetSchema() *DataTrackSchemaId { + if x != nil { + return x.Schema + } + return nil +} + type PublishDataTrackResponse struct { state protoimpl.MessageState `protogen:"open.v1"` // Information about the published track. @@ -5396,14 +5415,18 @@ const file_livekit_rtc_proto_rawDesc = "" + "\x06stream\x18\x0f \x01(\tR\x06stream\x12J\n" + "\x13backup_codec_policy\x18\x10 \x01(\x0e2\x1a.livekit.BackupCodecPolicyR\x11backupCodecPolicy\x12A\n" + "\x0eaudio_features\x18\x11 \x03(\x0e2\x1a.livekit.AudioTrackFeatureR\raudioFeatures\x12U\n" + - "\x17packet_trailer_features\x18\x12 \x03(\x0e2\x1d.livekit.PacketTrailerFeatureR\x15packetTrailerFeatures\"\x86\x01\n" + + "\x17packet_trailer_features\x18\x12 \x03(\x0e2\x1d.livekit.PacketTrailerFeatureR\x15packetTrailerFeatures\"\xaa\x02\n" + "\x17PublishDataTrackRequest\x12\x1d\n" + "\n" + "pub_handle\x18\x01 \x01(\rR\tpubHandle\x12\x12\n" + "\x04name\x18\x02 \x01(\tR\x04name\x128\n" + "\n" + "encryption\x18\x03 \x01(\x0e2\x18.livekit.Encryption.TypeR\n" + - "encryption\"F\n" + + "encryption\x12K\n" + + "\x0eframe_encoding\x18\x04 \x01(\x0e2\x1f.livekit.DataTrackFrameEncodingH\x00R\rframeEncoding\x88\x01\x01\x127\n" + + "\x06schema\x18\x05 \x01(\v2\x1a.livekit.DataTrackSchemaIdH\x01R\x06schema\x88\x01\x01B\x11\n" + + "\x0f_frame_encodingB\t\n" + + "\a_schema\"F\n" + "\x18PublishDataTrackResponse\x12*\n" + "\x04info\x18\x01 \x01(\v2\x16.livekit.DataTrackInfoR\x04info\":\n" + "\x19UnpublishDataTrackRequest\x12\x1d\n" + @@ -5814,25 +5837,27 @@ var file_livekit_rtc_proto_goTypes = []any{ (BackupCodecPolicy)(0), // 76: livekit.BackupCodecPolicy (AudioTrackFeature)(0), // 77: livekit.AudioTrackFeature (PacketTrailerFeature)(0), // 78: livekit.PacketTrailerFeature - (*DataTrackInfo)(nil), // 79: livekit.DataTrackInfo - (*Room)(nil), // 80: livekit.Room - (*ParticipantInfo)(nil), // 81: livekit.ParticipantInfo - (*ClientConfiguration)(nil), // 82: livekit.ClientConfiguration - (*ServerInfo)(nil), // 83: livekit.ServerInfo - (*Codec)(nil), // 84: livekit.Codec - (*TrackInfo)(nil), // 85: livekit.TrackInfo - (*ParticipantTracks)(nil), // 86: livekit.ParticipantTracks - (*DataBlob)(nil), // 87: livekit.DataBlob - (*DataBlobKey)(nil), // 88: livekit.DataBlobKey - (VideoQuality)(0), // 89: livekit.VideoQuality - (DisconnectReason)(0), // 90: livekit.DisconnectReason - (*SpeakerInfo)(nil), // 91: livekit.SpeakerInfo - (ConnectionQuality)(0), // 92: livekit.ConnectionQuality - (*SubscribedAudioCodec)(nil), // 93: livekit.SubscribedAudioCodec - (SubscriptionError)(0), // 94: livekit.SubscriptionError - (*ClientInfo)(nil), // 95: livekit.ClientInfo - (ReconnectReason)(0), // 96: livekit.ReconnectReason - (*DataTrackSubscriptionOptions)(nil), // 97: livekit.DataTrackSubscriptionOptions + (DataTrackFrameEncoding)(0), // 79: livekit.DataTrackFrameEncoding + (*DataTrackSchemaId)(nil), // 80: livekit.DataTrackSchemaId + (*DataTrackInfo)(nil), // 81: livekit.DataTrackInfo + (*Room)(nil), // 82: livekit.Room + (*ParticipantInfo)(nil), // 83: livekit.ParticipantInfo + (*ClientConfiguration)(nil), // 84: livekit.ClientConfiguration + (*ServerInfo)(nil), // 85: livekit.ServerInfo + (*Codec)(nil), // 86: livekit.Codec + (*TrackInfo)(nil), // 87: livekit.TrackInfo + (*ParticipantTracks)(nil), // 88: livekit.ParticipantTracks + (*DataBlob)(nil), // 89: livekit.DataBlob + (*DataBlobKey)(nil), // 90: livekit.DataBlobKey + (VideoQuality)(0), // 91: livekit.VideoQuality + (DisconnectReason)(0), // 92: livekit.DisconnectReason + (*SpeakerInfo)(nil), // 93: livekit.SpeakerInfo + (ConnectionQuality)(0), // 94: livekit.ConnectionQuality + (*SubscribedAudioCodec)(nil), // 95: livekit.SubscribedAudioCodec + (SubscriptionError)(0), // 96: livekit.SubscriptionError + (*ClientInfo)(nil), // 97: livekit.ClientInfo + (ReconnectReason)(0), // 98: livekit.ReconnectReason + (*DataTrackSubscriptionOptions)(nil), // 99: livekit.DataTrackSubscriptionOptions } var file_livekit_rtc_proto_depIdxs = []int32{ 21, // 0: livekit.SignalRequest.offer:type_name -> livekit.SessionDescription @@ -5895,86 +5920,88 @@ var file_livekit_rtc_proto_depIdxs = []int32{ 77, // 57: livekit.AddTrackRequest.audio_features:type_name -> livekit.AudioTrackFeature 78, // 58: livekit.AddTrackRequest.packet_trailer_features:type_name -> livekit.PacketTrailerFeature 75, // 59: livekit.PublishDataTrackRequest.encryption:type_name -> livekit.Encryption.Type - 79, // 60: livekit.PublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo - 79, // 61: livekit.UnpublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo - 66, // 62: livekit.DataTrackSubscriberHandles.sub_handles:type_name -> livekit.DataTrackSubscriberHandles.SubHandlesEntry - 0, // 63: livekit.TrickleRequest.target:type_name -> livekit.SignalTarget - 80, // 64: livekit.JoinResponse.room:type_name -> livekit.Room - 81, // 65: livekit.JoinResponse.participant:type_name -> livekit.ParticipantInfo - 81, // 66: livekit.JoinResponse.other_participants:type_name -> livekit.ParticipantInfo - 35, // 67: livekit.JoinResponse.ice_servers:type_name -> livekit.ICEServer - 82, // 68: livekit.JoinResponse.client_configuration:type_name -> livekit.ClientConfiguration - 83, // 69: livekit.JoinResponse.server_info:type_name -> livekit.ServerInfo - 84, // 70: livekit.JoinResponse.enabled_publish_codecs:type_name -> livekit.Codec - 35, // 71: livekit.ReconnectResponse.ice_servers:type_name -> livekit.ICEServer - 82, // 72: livekit.ReconnectResponse.client_configuration:type_name -> livekit.ClientConfiguration - 83, // 73: livekit.ReconnectResponse.server_info:type_name -> livekit.ServerInfo - 85, // 74: livekit.TrackPublishedResponse.track:type_name -> livekit.TrackInfo - 67, // 75: livekit.SessionDescription.mid_to_track_id:type_name -> livekit.SessionDescription.MidToTrackIdEntry - 81, // 76: livekit.ParticipantUpdate.participants:type_name -> livekit.ParticipantInfo - 86, // 77: livekit.UpdateSubscription.participant_tracks:type_name -> livekit.ParticipantTracks - 68, // 78: livekit.UpdateDataSubscription.updates:type_name -> livekit.UpdateDataSubscription.Update - 87, // 79: livekit.StoreDataBlobRequest.blob:type_name -> livekit.DataBlob - 88, // 80: livekit.StoreDataBlobResponse.key:type_name -> livekit.DataBlobKey - 88, // 81: livekit.GetDataBlobRequest.key:type_name -> livekit.DataBlobKey - 87, // 82: livekit.GetDataBlobResponse.blob:type_name -> livekit.DataBlob - 89, // 83: livekit.UpdateTrackSettings.quality:type_name -> livekit.VideoQuality - 77, // 84: livekit.UpdateLocalAudioTrack.features:type_name -> livekit.AudioTrackFeature - 90, // 85: livekit.LeaveRequest.reason:type_name -> livekit.DisconnectReason - 3, // 86: livekit.LeaveRequest.action:type_name -> livekit.LeaveRequest.Action - 56, // 87: livekit.LeaveRequest.regions:type_name -> livekit.RegionSettings - 71, // 88: livekit.UpdateVideoLayers.layers:type_name -> livekit.VideoLayer - 69, // 89: livekit.UpdateParticipantMetadata.attributes:type_name -> livekit.UpdateParticipantMetadata.AttributesEntry - 91, // 90: livekit.SpeakersChanged.speakers:type_name -> livekit.SpeakerInfo - 80, // 91: livekit.RoomUpdate.room:type_name -> livekit.Room - 92, // 92: livekit.ConnectionQualityInfo.quality:type_name -> livekit.ConnectionQuality - 38, // 93: livekit.ConnectionQualityUpdate.updates:type_name -> livekit.ConnectionQualityInfo - 1, // 94: livekit.StreamStateInfo.state:type_name -> livekit.StreamState - 40, // 95: livekit.StreamStateUpdate.stream_states:type_name -> livekit.StreamStateInfo - 89, // 96: livekit.SubscribedQuality.quality:type_name -> livekit.VideoQuality - 42, // 97: livekit.SubscribedCodec.qualities:type_name -> livekit.SubscribedQuality - 42, // 98: livekit.SubscribedQualityUpdate.subscribed_qualities:type_name -> livekit.SubscribedQuality - 43, // 99: livekit.SubscribedQualityUpdate.subscribed_codecs:type_name -> livekit.SubscribedCodec - 93, // 100: livekit.SubscribedAudioCodecUpdate.subscribed_audio_codecs:type_name -> livekit.SubscribedAudioCodec - 46, // 101: livekit.SubscriptionPermission.track_permissions:type_name -> livekit.TrackPermission - 80, // 102: livekit.RoomMovedResponse.room:type_name -> livekit.Room - 81, // 103: livekit.RoomMovedResponse.participant:type_name -> livekit.ParticipantInfo - 81, // 104: livekit.RoomMovedResponse.other_participants:type_name -> livekit.ParticipantInfo - 21, // 105: livekit.SyncState.answer:type_name -> livekit.SessionDescription - 23, // 106: livekit.SyncState.subscription:type_name -> livekit.UpdateSubscription - 19, // 107: livekit.SyncState.publish_tracks:type_name -> livekit.TrackPublishedResponse - 52, // 108: livekit.SyncState.data_channels:type_name -> livekit.DataChannelInfo - 21, // 109: livekit.SyncState.offer:type_name -> livekit.SessionDescription - 51, // 110: livekit.SyncState.datachannel_receive_states:type_name -> livekit.DataChannelReceiveState - 11, // 111: livekit.SyncState.publish_data_tracks:type_name -> livekit.PublishDataTrackResponse - 0, // 112: livekit.DataChannelInfo.target:type_name -> livekit.SignalTarget - 2, // 113: livekit.SimulateScenario.switch_candidate_protocol:type_name -> livekit.CandidateProtocol - 57, // 114: livekit.RegionSettings.regions:type_name -> livekit.RegionInfo - 94, // 115: livekit.SubscriptionResponse.err:type_name -> livekit.SubscriptionError - 4, // 116: livekit.RequestResponse.reason:type_name -> livekit.RequestResponse.Reason - 15, // 117: livekit.RequestResponse.trickle:type_name -> livekit.TrickleRequest - 9, // 118: livekit.RequestResponse.add_track:type_name -> livekit.AddTrackRequest - 16, // 119: livekit.RequestResponse.mute:type_name -> livekit.MuteTrackRequest - 34, // 120: livekit.RequestResponse.update_metadata:type_name -> livekit.UpdateParticipantMetadata - 30, // 121: livekit.RequestResponse.update_audio_track:type_name -> livekit.UpdateLocalAudioTrack - 31, // 122: livekit.RequestResponse.update_video_track:type_name -> livekit.UpdateLocalVideoTrack - 10, // 123: livekit.RequestResponse.publish_data_track:type_name -> livekit.PublishDataTrackRequest - 12, // 124: livekit.RequestResponse.unpublish_data_track:type_name -> livekit.UnpublishDataTrackRequest - 95, // 125: livekit.JoinRequest.client_info:type_name -> livekit.ClientInfo - 61, // 126: livekit.JoinRequest.connection_settings:type_name -> livekit.ConnectionSettings - 70, // 127: livekit.JoinRequest.participant_attributes:type_name -> livekit.JoinRequest.ParticipantAttributesEntry - 9, // 128: livekit.JoinRequest.add_track_requests:type_name -> livekit.AddTrackRequest - 21, // 129: livekit.JoinRequest.publisher_offer:type_name -> livekit.SessionDescription - 96, // 130: livekit.JoinRequest.reconnect_reason:type_name -> livekit.ReconnectReason - 50, // 131: livekit.JoinRequest.sync_state:type_name -> livekit.SyncState - 5, // 132: livekit.WrappedJoinRequest.compression:type_name -> livekit.WrappedJoinRequest.Compression - 65, // 133: livekit.DataTrackSubscriberHandles.SubHandlesEntry.value:type_name -> livekit.DataTrackSubscriberHandles.PublishedDataTrack - 97, // 134: livekit.UpdateDataSubscription.Update.options:type_name -> livekit.DataTrackSubscriptionOptions - 135, // [135:135] is the sub-list for method output_type - 135, // [135:135] is the sub-list for method input_type - 135, // [135:135] is the sub-list for extension type_name - 135, // [135:135] is the sub-list for extension extendee - 0, // [0:135] is the sub-list for field type_name + 79, // 60: livekit.PublishDataTrackRequest.frame_encoding:type_name -> livekit.DataTrackFrameEncoding + 80, // 61: livekit.PublishDataTrackRequest.schema:type_name -> livekit.DataTrackSchemaId + 81, // 62: livekit.PublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo + 81, // 63: livekit.UnpublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo + 66, // 64: livekit.DataTrackSubscriberHandles.sub_handles:type_name -> livekit.DataTrackSubscriberHandles.SubHandlesEntry + 0, // 65: livekit.TrickleRequest.target:type_name -> livekit.SignalTarget + 82, // 66: livekit.JoinResponse.room:type_name -> livekit.Room + 83, // 67: livekit.JoinResponse.participant:type_name -> livekit.ParticipantInfo + 83, // 68: livekit.JoinResponse.other_participants:type_name -> livekit.ParticipantInfo + 35, // 69: livekit.JoinResponse.ice_servers:type_name -> livekit.ICEServer + 84, // 70: livekit.JoinResponse.client_configuration:type_name -> livekit.ClientConfiguration + 85, // 71: livekit.JoinResponse.server_info:type_name -> livekit.ServerInfo + 86, // 72: livekit.JoinResponse.enabled_publish_codecs:type_name -> livekit.Codec + 35, // 73: livekit.ReconnectResponse.ice_servers:type_name -> livekit.ICEServer + 84, // 74: livekit.ReconnectResponse.client_configuration:type_name -> livekit.ClientConfiguration + 85, // 75: livekit.ReconnectResponse.server_info:type_name -> livekit.ServerInfo + 87, // 76: livekit.TrackPublishedResponse.track:type_name -> livekit.TrackInfo + 67, // 77: livekit.SessionDescription.mid_to_track_id:type_name -> livekit.SessionDescription.MidToTrackIdEntry + 83, // 78: livekit.ParticipantUpdate.participants:type_name -> livekit.ParticipantInfo + 88, // 79: livekit.UpdateSubscription.participant_tracks:type_name -> livekit.ParticipantTracks + 68, // 80: livekit.UpdateDataSubscription.updates:type_name -> livekit.UpdateDataSubscription.Update + 89, // 81: livekit.StoreDataBlobRequest.blob:type_name -> livekit.DataBlob + 90, // 82: livekit.StoreDataBlobResponse.key:type_name -> livekit.DataBlobKey + 90, // 83: livekit.GetDataBlobRequest.key:type_name -> livekit.DataBlobKey + 89, // 84: livekit.GetDataBlobResponse.blob:type_name -> livekit.DataBlob + 91, // 85: livekit.UpdateTrackSettings.quality:type_name -> livekit.VideoQuality + 77, // 86: livekit.UpdateLocalAudioTrack.features:type_name -> livekit.AudioTrackFeature + 92, // 87: livekit.LeaveRequest.reason:type_name -> livekit.DisconnectReason + 3, // 88: livekit.LeaveRequest.action:type_name -> livekit.LeaveRequest.Action + 56, // 89: livekit.LeaveRequest.regions:type_name -> livekit.RegionSettings + 71, // 90: livekit.UpdateVideoLayers.layers:type_name -> livekit.VideoLayer + 69, // 91: livekit.UpdateParticipantMetadata.attributes:type_name -> livekit.UpdateParticipantMetadata.AttributesEntry + 93, // 92: livekit.SpeakersChanged.speakers:type_name -> livekit.SpeakerInfo + 82, // 93: livekit.RoomUpdate.room:type_name -> livekit.Room + 94, // 94: livekit.ConnectionQualityInfo.quality:type_name -> livekit.ConnectionQuality + 38, // 95: livekit.ConnectionQualityUpdate.updates:type_name -> livekit.ConnectionQualityInfo + 1, // 96: livekit.StreamStateInfo.state:type_name -> livekit.StreamState + 40, // 97: livekit.StreamStateUpdate.stream_states:type_name -> livekit.StreamStateInfo + 91, // 98: livekit.SubscribedQuality.quality:type_name -> livekit.VideoQuality + 42, // 99: livekit.SubscribedCodec.qualities:type_name -> livekit.SubscribedQuality + 42, // 100: livekit.SubscribedQualityUpdate.subscribed_qualities:type_name -> livekit.SubscribedQuality + 43, // 101: livekit.SubscribedQualityUpdate.subscribed_codecs:type_name -> livekit.SubscribedCodec + 95, // 102: livekit.SubscribedAudioCodecUpdate.subscribed_audio_codecs:type_name -> livekit.SubscribedAudioCodec + 46, // 103: livekit.SubscriptionPermission.track_permissions:type_name -> livekit.TrackPermission + 82, // 104: livekit.RoomMovedResponse.room:type_name -> livekit.Room + 83, // 105: livekit.RoomMovedResponse.participant:type_name -> livekit.ParticipantInfo + 83, // 106: livekit.RoomMovedResponse.other_participants:type_name -> livekit.ParticipantInfo + 21, // 107: livekit.SyncState.answer:type_name -> livekit.SessionDescription + 23, // 108: livekit.SyncState.subscription:type_name -> livekit.UpdateSubscription + 19, // 109: livekit.SyncState.publish_tracks:type_name -> livekit.TrackPublishedResponse + 52, // 110: livekit.SyncState.data_channels:type_name -> livekit.DataChannelInfo + 21, // 111: livekit.SyncState.offer:type_name -> livekit.SessionDescription + 51, // 112: livekit.SyncState.datachannel_receive_states:type_name -> livekit.DataChannelReceiveState + 11, // 113: livekit.SyncState.publish_data_tracks:type_name -> livekit.PublishDataTrackResponse + 0, // 114: livekit.DataChannelInfo.target:type_name -> livekit.SignalTarget + 2, // 115: livekit.SimulateScenario.switch_candidate_protocol:type_name -> livekit.CandidateProtocol + 57, // 116: livekit.RegionSettings.regions:type_name -> livekit.RegionInfo + 96, // 117: livekit.SubscriptionResponse.err:type_name -> livekit.SubscriptionError + 4, // 118: livekit.RequestResponse.reason:type_name -> livekit.RequestResponse.Reason + 15, // 119: livekit.RequestResponse.trickle:type_name -> livekit.TrickleRequest + 9, // 120: livekit.RequestResponse.add_track:type_name -> livekit.AddTrackRequest + 16, // 121: livekit.RequestResponse.mute:type_name -> livekit.MuteTrackRequest + 34, // 122: livekit.RequestResponse.update_metadata:type_name -> livekit.UpdateParticipantMetadata + 30, // 123: livekit.RequestResponse.update_audio_track:type_name -> livekit.UpdateLocalAudioTrack + 31, // 124: livekit.RequestResponse.update_video_track:type_name -> livekit.UpdateLocalVideoTrack + 10, // 125: livekit.RequestResponse.publish_data_track:type_name -> livekit.PublishDataTrackRequest + 12, // 126: livekit.RequestResponse.unpublish_data_track:type_name -> livekit.UnpublishDataTrackRequest + 97, // 127: livekit.JoinRequest.client_info:type_name -> livekit.ClientInfo + 61, // 128: livekit.JoinRequest.connection_settings:type_name -> livekit.ConnectionSettings + 70, // 129: livekit.JoinRequest.participant_attributes:type_name -> livekit.JoinRequest.ParticipantAttributesEntry + 9, // 130: livekit.JoinRequest.add_track_requests:type_name -> livekit.AddTrackRequest + 21, // 131: livekit.JoinRequest.publisher_offer:type_name -> livekit.SessionDescription + 98, // 132: livekit.JoinRequest.reconnect_reason:type_name -> livekit.ReconnectReason + 50, // 133: livekit.JoinRequest.sync_state:type_name -> livekit.SyncState + 5, // 134: livekit.WrappedJoinRequest.compression:type_name -> livekit.WrappedJoinRequest.Compression + 65, // 135: livekit.DataTrackSubscriberHandles.SubHandlesEntry.value:type_name -> livekit.DataTrackSubscriberHandles.PublishedDataTrack + 99, // 136: livekit.UpdateDataSubscription.Update.options:type_name -> livekit.DataTrackSubscriptionOptions + 137, // [137:137] is the sub-list for method output_type + 137, // [137:137] is the sub-list for method input_type + 137, // [137:137] is the sub-list for extension type_name + 137, // [137:137] is the sub-list for extension extendee + 0, // [0:137] is the sub-list for field type_name } func init() { file_livekit_rtc_proto_init() } @@ -6039,6 +6066,7 @@ func file_livekit_rtc_proto_init() { (*SignalResponse_StoreDataBlobResponse)(nil), (*SignalResponse_GetDataBlobResponse)(nil), } + file_livekit_rtc_proto_msgTypes[4].OneofWrappers = []any{} file_livekit_rtc_proto_msgTypes[47].OneofWrappers = []any{ (*SimulateScenario_SpeakerUpdate)(nil), (*SimulateScenario_NodeFailure)(nil), diff --git a/protobufs/livekit_models.proto b/protobufs/livekit_models.proto index 6dc488737..2e25ac751 100644 --- a/protobufs/livekit_models.proto +++ b/protobufs/livekit_models.proto @@ -286,6 +286,68 @@ message DataTrackInfo { // Method used for end-to-end encryption (E2EE) on packet payloads. Encryption.Type encryption = 4; + + // Encoding for frame payloads on this track. If unspecified, the track is untyped. + optional DataTrackFrameEncoding frame_encoding = 5; + + // ID of the schema used by frames on this track if the track is typed. + optional DataTrackSchemaId schema = 6; +} + +// Encoding for frame payloads. +// +// Mirrors the well-known message encodings from the MCAP spec: +// https://mcap.dev/spec/registry#message-encodings +// +enum DataTrackFrameEncoding { + DATA_TRACK_FRAME_ENCODING_UNSPECIFIED = 0; + // ROS 1: must be described by `ROS1_MSG` schema encoding. + DATA_TRACK_FRAME_ENCODING_ROS1 = 1; + // CDR: must be described by `ROS2_MSG`, `ROS2_IDL`, or `OMG_IDL` schema encoding. + DATA_TRACK_FRAME_ENCODING_CDR = 2; + // Protocol Buffer: must be described by `PROTOBUF` schema encoding. + DATA_TRACK_FRAME_ENCODING_PROTOBUF = 3; + // FlatBuffer: must be described by `FLATBUFFER` schema encoding. + DATA_TRACK_FRAME_ENCODING_FLATBUFFER = 4; + // CBOR: self-describing. + DATA_TRACK_FRAME_ENCODING_CBOR = 5; + // MessagePack: self-describing. + DATA_TRACK_FRAME_ENCODING_MSGPACK = 6; + // JSON: self-describing or described by `JSON_SCHEMA` schema encoding. + DATA_TRACK_FRAME_ENCODING_JSON = 7; +} + +// Encoding for schema definitions. +// +// Mirrors the well-known schema encodings from the MCAP spec: +// https://mcap.dev/spec/registry#schema-encodings +// +enum DataTrackSchemaEncoding { + DATA_TRACK_SCHEMA_ENCODING_UNSPECIFIED = 0; + // Protocol Buffer IDL: describes `PROTOBUF` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_PROTOBUF = 1; + // FlatBuffer IDL: describes `FLATBUFFER` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_FLATBUFFER = 2; + // ROS 1 Message: describes `ROS1` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_ROS1_MSG = 3; + // ROS 2 Message: describes `CDR` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_ROS2_MSG = 4; + // ROS 2 IDL: describes `CDR` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_ROS2_IDL = 5; + // OMG IDL: describes `CDR` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_OMG_IDL = 6; + // JSON Schema: describes `JSON` frame encoding. + DATA_TRACK_SCHEMA_ENCODING_JSON_SCHEMA = 7; +} + +// Identifier for a data track schema. +// +// Schemas with the same name but different encodings are distinct. +// +message DataTrackSchemaId { + // This must be non-empty and no longer than 256 characters. + string name = 1; + DataTrackSchemaEncoding encoding = 2; } enum DataTrackExtensionID { @@ -309,7 +371,8 @@ message DataBlobKey { oneof key { // Generic string key, blob contains arbitrary data. string generic = 1; - // Add additional key types here for storing specific types of blobs. + // Data track schema identifier, blob contains schema definition. + DataTrackSchemaId schema_id = 2; } } diff --git a/protobufs/livekit_rtc.proto b/protobufs/livekit_rtc.proto index faf224add..b3eeafe0e 100644 --- a/protobufs/livekit_rtc.proto +++ b/protobufs/livekit_rtc.proto @@ -195,6 +195,13 @@ message PublishDataTrackRequest { // Method used for end-to-end encryption (E2EE) on frame payloads. Encryption.Type encryption = 3; + + // Encoding for frame payloads on this track. If unspecified, the track is untyped. + optional DataTrackFrameEncoding frame_encoding = 4; + + // ID of the schema used by frames on this track if the track is typed. + // If set, the associated schema must be stored with `StoreDataBlobRequest`. + optional DataTrackSchemaId schema = 5; } message PublishDataTrackResponse {