From 912b4385c8c90ce3a26fd79f07653b4ea8d2cfae Mon Sep 17 00:00:00 2001 From: Jacob Gelman <3182119+ladvoc@users.noreply.github.com> Date: Fri, 24 Apr 2026 15:00:22 +0900 Subject: [PATCH 1/2] Add data track schema fields --- protobufs/livekit_models.proto | 24 ++++++++++++++++++++++++ protobufs/livekit_rtc.proto | 4 ++++ 2 files changed, 28 insertions(+) diff --git a/protobufs/livekit_models.proto b/protobufs/livekit_models.proto index 6b98a008d..dc98fe158 100644 --- a/protobufs/livekit_models.proto +++ b/protobufs/livekit_models.proto @@ -282,6 +282,30 @@ message DataTrackInfo { // Method used for end-to-end encryption (E2EE) on packet payloads. Encryption.Type encryption = 4; + + // Schema describing frames published on the track. + optional DataTrackSchema schema = 5; +} + +message DataTrackSchema { + // Unique identifier of the schema within a room. + string name = 1; + + // Format the schema is defined in. + DataTrackSchemaType type = 2; + + // Schema definition. May be omitted if the name defines a well-known schema. + optional bytes data = 3; +} + +enum DataTrackSchemaType { + DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED = 0; + DATA_TRACK_SCHEMA_TYPE_PROTOBUF = 1; + DATA_TRACK_SCHEMA_TYPE_FLATBUFFER = 2; + DATA_TRACK_SCHEMA_TYPE_ROS1MSG = 3; + DATA_TRACK_SCHEMA_TYPE_ROS2IDL = 4; + DATA_TRACK_SCHEMA_TYPE_OMGIDL = 5; + DATA_TRACK_SCHEMA_TYPE_JSONSCHEMA = 6; } enum DataTrackExtensionID { diff --git a/protobufs/livekit_rtc.proto b/protobufs/livekit_rtc.proto index 31488daea..31857147d 100644 --- a/protobufs/livekit_rtc.proto +++ b/protobufs/livekit_rtc.proto @@ -187,6 +187,9 @@ message PublishDataTrackRequest { // Method used for end-to-end encryption (E2EE) on frame payloads. Encryption.Type encryption = 3; + + // Schema describing frames published on the track. + optional DataTrackSchema schema = 4; } message PublishDataTrackResponse { @@ -561,6 +564,7 @@ message RequestResponse { INVALID_NAME = 8; DUPLICATE_HANDLE = 9; DUPLICATE_NAME = 10; + INVALID_SCHEMA = 11; } uint32 request_id = 1 [(logger.name) = "requestID"]; From 64f12c0b6cf3789550363c9b01f0d4f40755d291 Mon Sep 17 00:00:00 2001 From: github-actions <41898282+github-actions[bot]@users.noreply.github.com> Date: Fri, 24 Apr 2026 06:05:58 +0000 Subject: [PATCH 2/2] generated protobuf --- livekit/livekit_models.pb.go | 852 +++++++++++++++++++++-------------- livekit/livekit_rtc.pb.go | 216 +++++---- 2 files changed, 620 insertions(+), 448 deletions(-) diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index d9cb42bc1..62cfa0a8e 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -348,6 +348,67 @@ func (TrackSource) EnumDescriptor() ([]byte, []int) { return file_livekit_models_proto_rawDescGZIP(), []int{5} } +type DataTrackSchemaType int32 + +const ( + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED DataTrackSchemaType = 0 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_PROTOBUF DataTrackSchemaType = 1 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_FLATBUFFER DataTrackSchemaType = 2 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_ROS1MSG DataTrackSchemaType = 3 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_ROS2IDL DataTrackSchemaType = 4 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_OMGIDL DataTrackSchemaType = 5 + DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_JSONSCHEMA DataTrackSchemaType = 6 +) + +// Enum value maps for DataTrackSchemaType. +var ( + DataTrackSchemaType_name = map[int32]string{ + 0: "DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED", + 1: "DATA_TRACK_SCHEMA_TYPE_PROTOBUF", + 2: "DATA_TRACK_SCHEMA_TYPE_FLATBUFFER", + 3: "DATA_TRACK_SCHEMA_TYPE_ROS1MSG", + 4: "DATA_TRACK_SCHEMA_TYPE_ROS2IDL", + 5: "DATA_TRACK_SCHEMA_TYPE_OMGIDL", + 6: "DATA_TRACK_SCHEMA_TYPE_JSONSCHEMA", + } + DataTrackSchemaType_value = map[string]int32{ + "DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED": 0, + "DATA_TRACK_SCHEMA_TYPE_PROTOBUF": 1, + "DATA_TRACK_SCHEMA_TYPE_FLATBUFFER": 2, + "DATA_TRACK_SCHEMA_TYPE_ROS1MSG": 3, + "DATA_TRACK_SCHEMA_TYPE_ROS2IDL": 4, + "DATA_TRACK_SCHEMA_TYPE_OMGIDL": 5, + "DATA_TRACK_SCHEMA_TYPE_JSONSCHEMA": 6, + } +) + +func (x DataTrackSchemaType) Enum() *DataTrackSchemaType { + p := new(DataTrackSchemaType) + *p = x + return p +} + +func (x DataTrackSchemaType) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (DataTrackSchemaType) Descriptor() protoreflect.EnumDescriptor { + return file_livekit_models_proto_enumTypes[6].Descriptor() +} + +func (DataTrackSchemaType) Type() protoreflect.EnumType { + return &file_livekit_models_proto_enumTypes[6] +} + +func (x DataTrackSchemaType) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use DataTrackSchemaType.Descriptor instead. +func (DataTrackSchemaType) EnumDescriptor() ([]byte, []int) { + return file_livekit_models_proto_rawDescGZIP(), []int{6} +} + type DataTrackExtensionID int32 const ( @@ -378,11 +439,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[7].Descriptor() } func (DataTrackExtensionID) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[6] + return &file_livekit_models_proto_enumTypes[7] } func (x DataTrackExtensionID) Number() protoreflect.EnumNumber { @@ -391,7 +452,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{7} } type VideoQuality int32 @@ -430,11 +491,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[8].Descriptor() } func (VideoQuality) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[7] + return &file_livekit_models_proto_enumTypes[8] } func (x VideoQuality) Number() protoreflect.EnumNumber { @@ -443,7 +504,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{8} } type ConnectionQuality int32 @@ -482,11 +543,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[9].Descriptor() } func (ConnectionQuality) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[8] + return &file_livekit_models_proto_enumTypes[9] } func (x ConnectionQuality) Number() protoreflect.EnumNumber { @@ -495,7 +556,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{9} } type ClientConfigSetting int32 @@ -531,11 +592,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[10].Descriptor() } func (ClientConfigSetting) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[9] + return &file_livekit_models_proto_enumTypes[10] } func (x ClientConfigSetting) Number() protoreflect.EnumNumber { @@ -544,7 +605,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{10} } type DisconnectReason int32 @@ -638,11 +699,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[11].Descriptor() } func (DisconnectReason) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[10] + return &file_livekit_models_proto_enumTypes[11] } func (x DisconnectReason) Number() protoreflect.EnumNumber { @@ -651,7 +712,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{11} } type ReconnectReason int32 @@ -693,11 +754,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[12].Descriptor() } func (ReconnectReason) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[11] + return &file_livekit_models_proto_enumTypes[12] } func (x ReconnectReason) Number() protoreflect.EnumNumber { @@ -706,7 +767,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{12} } type SubscriptionError int32 @@ -742,11 +803,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[13].Descriptor() } func (SubscriptionError) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[12] + return &file_livekit_models_proto_enumTypes[13] } func (x SubscriptionError) Number() protoreflect.EnumNumber { @@ -755,7 +816,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{13} } type AudioTrackFeature int32 @@ -803,11 +864,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[14].Descriptor() } func (AudioTrackFeature) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[13] + return &file_livekit_models_proto_enumTypes[14] } func (x AudioTrackFeature) Number() protoreflect.EnumNumber { @@ -816,7 +877,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{14} } type PacketTrailerFeature int32 @@ -849,11 +910,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[15].Descriptor() } func (PacketTrailerFeature) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[14] + return &file_livekit_models_proto_enumTypes[15] } func (x PacketTrailerFeature) Number() protoreflect.EnumNumber { @@ -862,7 +923,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{15} } type ParticipantInfo_State int32 @@ -905,11 +966,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[16].Descriptor() } func (ParticipantInfo_State) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[15] + return &file_livekit_models_proto_enumTypes[16] } func (x ParticipantInfo_State) Number() protoreflect.EnumNumber { @@ -973,11 +1034,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[17].Descriptor() } func (ParticipantInfo_Kind) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[16] + return &file_livekit_models_proto_enumTypes[17] } func (x ParticipantInfo_Kind) Number() protoreflect.EnumNumber { @@ -1028,11 +1089,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[18].Descriptor() } func (ParticipantInfo_KindDetail) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[17] + return &file_livekit_models_proto_enumTypes[18] } func (x ParticipantInfo_KindDetail) Number() protoreflect.EnumNumber { @@ -1077,11 +1138,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[19].Descriptor() } func (Encryption_Type) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[18] + return &file_livekit_models_proto_enumTypes[19] } func (x Encryption_Type) Number() protoreflect.EnumNumber { @@ -1129,11 +1190,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[20].Descriptor() } func (VideoLayer_Mode) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[19] + return &file_livekit_models_proto_enumTypes[20] } func (x VideoLayer_Mode) Number() protoreflect.EnumNumber { @@ -1142,7 +1203,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{14, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{15, 0} } type DataPacket_Kind int32 @@ -1175,11 +1236,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[21].Descriptor() } func (DataPacket_Kind) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[20] + return &file_livekit_models_proto_enumTypes[21] } func (x DataPacket_Kind) Number() protoreflect.EnumNumber { @@ -1188,7 +1249,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{15, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{16, 0} } type ServerInfo_Edition int32 @@ -1221,11 +1282,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[22].Descriptor() } func (ServerInfo_Edition) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[21] + return &file_livekit_models_proto_enumTypes[22] } func (x ServerInfo_Edition) Number() protoreflect.EnumNumber { @@ -1234,7 +1295,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{30, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{31, 0} } type ClientInfo_SDK int32 @@ -1306,11 +1367,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[23].Descriptor() } func (ClientInfo_SDK) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[22] + return &file_livekit_models_proto_enumTypes[23] } func (x ClientInfo_SDK) Number() protoreflect.EnumNumber { @@ -1319,7 +1380,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{31, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{32, 0} } // Optional capabilities advertised by the client at connect time. The SFU @@ -1356,11 +1417,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[24].Descriptor() } func (ClientInfo_Capability) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[23] + return &file_livekit_models_proto_enumTypes[24] } func (x ClientInfo_Capability) Number() protoreflect.EnumNumber { @@ -1369,7 +1430,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{31, 1} + return file_livekit_models_proto_rawDescGZIP(), []int{32, 1} } // enum for operation types (specific to TextHeader) @@ -1409,11 +1470,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[25].Descriptor() } func (DataStream_OperationType) Type() protoreflect.EnumType { - return &file_livekit_models_proto_enumTypes[24] + return &file_livekit_models_proto_enumTypes[25] } func (x DataStream_OperationType) Number() protoreflect.EnumNumber { @@ -1422,7 +1483,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{42, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 0} } type Pagination struct { @@ -2524,7 +2585,9 @@ 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"` + // Schema describing frames published on the track. + Schema *DataTrackSchema `protobuf:"bytes,5,opt,name=schema,proto3,oneof" json:"schema,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -2587,6 +2650,76 @@ func (x *DataTrackInfo) GetEncryption() Encryption_Type { return Encryption_NONE } +func (x *DataTrackInfo) GetSchema() *DataTrackSchema { + if x != nil { + return x.Schema + } + return nil +} + +type DataTrackSchema struct { + state protoimpl.MessageState `protogen:"open.v1"` + // Unique identifier of the schema within a room. + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + // Format the schema is defined in. + Type DataTrackSchemaType `protobuf:"varint,2,opt,name=type,proto3,enum=livekit.DataTrackSchemaType" json:"type,omitempty"` + // Schema definition. May be omitted if the name defines a well-known schema. + Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DataTrackSchema) Reset() { + *x = DataTrackSchema{} + mi := &file_livekit_models_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DataTrackSchema) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DataTrackSchema) ProtoMessage() {} + +func (x *DataTrackSchema) 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 DataTrackSchema.ProtoReflect.Descriptor instead. +func (*DataTrackSchema) Descriptor() ([]byte, []int) { + return file_livekit_models_proto_rawDescGZIP(), []int{12} +} + +func (x *DataTrackSchema) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *DataTrackSchema) GetType() DataTrackSchemaType { + if x != nil { + return x.Type + } + return DataTrackSchemaType_DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED +} + +func (x *DataTrackSchema) GetData() []byte { + if x != nil { + return x.Data + } + return nil +} + type DataTrackExtensionParticipantSid struct { state protoimpl.MessageState `protogen:"open.v1"` Id DataTrackExtensionID `protobuf:"varint,1,opt,name=id,proto3,enum=livekit.DataTrackExtensionID" json:"id,omitempty"` @@ -2597,7 +2730,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) } @@ -2609,7 +2742,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 { @@ -2622,7 +2755,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 { @@ -2650,7 +2783,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) } @@ -2662,7 +2795,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 { @@ -2675,7 +2808,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 { @@ -2704,7 +2837,7 @@ type VideoLayer struct { func (x *VideoLayer) Reset() { *x = VideoLayer{} - mi := &file_livekit_models_proto_msgTypes[14] + mi := &file_livekit_models_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2716,7 +2849,7 @@ func (x *VideoLayer) String() string { func (*VideoLayer) ProtoMessage() {} func (x *VideoLayer) 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 { @@ -2729,7 +2862,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{14} + return file_livekit_models_proto_rawDescGZIP(), []int{15} } func (x *VideoLayer) GetQuality() VideoQuality { @@ -2823,7 +2956,7 @@ type DataPacket struct { func (x *DataPacket) Reset() { *x = DataPacket{} - mi := &file_livekit_models_proto_msgTypes[15] + mi := &file_livekit_models_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2835,7 +2968,7 @@ func (x *DataPacket) String() string { func (*DataPacket) ProtoMessage() {} func (x *DataPacket) 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 { @@ -2848,7 +2981,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{15} + return file_livekit_models_proto_rawDescGZIP(), []int{16} } // Deprecated: Marked as deprecated in livekit_models.proto. @@ -3107,7 +3240,7 @@ type EncryptedPacket struct { func (x *EncryptedPacket) Reset() { *x = EncryptedPacket{} - mi := &file_livekit_models_proto_msgTypes[16] + mi := &file_livekit_models_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3119,7 +3252,7 @@ func (x *EncryptedPacket) String() string { func (*EncryptedPacket) ProtoMessage() {} func (x *EncryptedPacket) 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 { @@ -3132,7 +3265,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{16} + return file_livekit_models_proto_rawDescGZIP(), []int{17} } func (x *EncryptedPacket) GetEncryptionType() Encryption_Type { @@ -3182,7 +3315,7 @@ type EncryptedPacketPayload struct { func (x *EncryptedPacketPayload) Reset() { *x = EncryptedPacketPayload{} - mi := &file_livekit_models_proto_msgTypes[17] + mi := &file_livekit_models_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3194,7 +3327,7 @@ func (x *EncryptedPacketPayload) String() string { func (*EncryptedPacketPayload) ProtoMessage() {} func (x *EncryptedPacketPayload) 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 { @@ -3207,7 +3340,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{17} + return file_livekit_models_proto_rawDescGZIP(), []int{18} } func (x *EncryptedPacketPayload) GetValue() isEncryptedPacketPayload_Value { @@ -3351,7 +3484,7 @@ type ActiveSpeakerUpdate struct { func (x *ActiveSpeakerUpdate) Reset() { *x = ActiveSpeakerUpdate{} - mi := &file_livekit_models_proto_msgTypes[18] + mi := &file_livekit_models_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3363,7 +3496,7 @@ func (x *ActiveSpeakerUpdate) String() string { func (*ActiveSpeakerUpdate) ProtoMessage() {} func (x *ActiveSpeakerUpdate) 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 { @@ -3376,7 +3509,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{18} + return file_livekit_models_proto_rawDescGZIP(), []int{19} } func (x *ActiveSpeakerUpdate) GetSpeakers() []*SpeakerInfo { @@ -3399,7 +3532,7 @@ type SpeakerInfo struct { func (x *SpeakerInfo) Reset() { *x = SpeakerInfo{} - mi := &file_livekit_models_proto_msgTypes[19] + mi := &file_livekit_models_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3411,7 +3544,7 @@ func (x *SpeakerInfo) String() string { func (*SpeakerInfo) ProtoMessage() {} func (x *SpeakerInfo) 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 { @@ -3424,7 +3557,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{19} + return file_livekit_models_proto_rawDescGZIP(), []int{20} } func (x *SpeakerInfo) GetSid() string { @@ -3481,7 +3614,7 @@ type UserPacket struct { func (x *UserPacket) Reset() { *x = UserPacket{} - mi := &file_livekit_models_proto_msgTypes[20] + mi := &file_livekit_models_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3493,7 +3626,7 @@ func (x *UserPacket) String() string { func (*UserPacket) ProtoMessage() {} func (x *UserPacket) 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 { @@ -3506,7 +3639,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{20} + return file_livekit_models_proto_rawDescGZIP(), []int{21} } // Deprecated: Marked as deprecated in livekit_models.proto. @@ -3593,7 +3726,7 @@ type SipDTMF struct { func (x *SipDTMF) Reset() { *x = SipDTMF{} - mi := &file_livekit_models_proto_msgTypes[21] + mi := &file_livekit_models_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3605,7 +3738,7 @@ func (x *SipDTMF) String() string { func (*SipDTMF) ProtoMessage() {} func (x *SipDTMF) 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 { @@ -3618,7 +3751,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{21} + return file_livekit_models_proto_rawDescGZIP(), []int{22} } func (x *SipDTMF) GetCode() uint32 { @@ -3647,7 +3780,7 @@ type Transcription struct { func (x *Transcription) Reset() { *x = Transcription{} - mi := &file_livekit_models_proto_msgTypes[22] + mi := &file_livekit_models_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3659,7 +3792,7 @@ func (x *Transcription) String() string { func (*Transcription) ProtoMessage() {} func (x *Transcription) 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 { @@ -3672,7 +3805,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{22} + return file_livekit_models_proto_rawDescGZIP(), []int{23} } func (x *Transcription) GetTranscribedParticipantIdentity() string { @@ -3710,7 +3843,7 @@ type TranscriptionSegment struct { func (x *TranscriptionSegment) Reset() { *x = TranscriptionSegment{} - mi := &file_livekit_models_proto_msgTypes[23] + mi := &file_livekit_models_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3722,7 +3855,7 @@ func (x *TranscriptionSegment) String() string { func (*TranscriptionSegment) ProtoMessage() {} func (x *TranscriptionSegment) 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 { @@ -3735,7 +3868,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{23} + return file_livekit_models_proto_rawDescGZIP(), []int{24} } func (x *TranscriptionSegment) GetId() string { @@ -3794,7 +3927,7 @@ type ChatMessage struct { func (x *ChatMessage) Reset() { *x = ChatMessage{} - mi := &file_livekit_models_proto_msgTypes[24] + mi := &file_livekit_models_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3806,7 +3939,7 @@ func (x *ChatMessage) String() string { func (*ChatMessage) ProtoMessage() {} func (x *ChatMessage) 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 { @@ -3819,7 +3952,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{24} + return file_livekit_models_proto_rawDescGZIP(), []int{25} } func (x *ChatMessage) GetId() string { @@ -3879,7 +4012,7 @@ type RpcRequest struct { func (x *RpcRequest) Reset() { *x = RpcRequest{} - mi := &file_livekit_models_proto_msgTypes[25] + mi := &file_livekit_models_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3891,7 +4024,7 @@ func (x *RpcRequest) String() string { func (*RpcRequest) ProtoMessage() {} func (x *RpcRequest) 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 { @@ -3904,7 +4037,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{25} + return file_livekit_models_proto_rawDescGZIP(), []int{26} } func (x *RpcRequest) GetId() string { @@ -3958,7 +4091,7 @@ type RpcAck struct { func (x *RpcAck) Reset() { *x = RpcAck{} - mi := &file_livekit_models_proto_msgTypes[26] + mi := &file_livekit_models_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3970,7 +4103,7 @@ func (x *RpcAck) String() string { func (*RpcAck) ProtoMessage() {} func (x *RpcAck) 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 { @@ -3983,7 +4116,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{26} + return file_livekit_models_proto_rawDescGZIP(), []int{27} } func (x *RpcAck) GetRequestId() string { @@ -4008,7 +4141,7 @@ type RpcResponse struct { func (x *RpcResponse) Reset() { *x = RpcResponse{} - mi := &file_livekit_models_proto_msgTypes[27] + mi := &file_livekit_models_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4020,7 +4153,7 @@ func (x *RpcResponse) String() string { func (*RpcResponse) ProtoMessage() {} func (x *RpcResponse) 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 { @@ -4033,7 +4166,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{27} + return file_livekit_models_proto_rawDescGZIP(), []int{28} } func (x *RpcResponse) GetRequestId() string { @@ -4111,7 +4244,7 @@ type RpcError struct { func (x *RpcError) Reset() { *x = RpcError{} - mi := &file_livekit_models_proto_msgTypes[28] + mi := &file_livekit_models_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4123,7 +4256,7 @@ func (x *RpcError) String() string { func (*RpcError) ProtoMessage() {} func (x *RpcError) 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 { @@ -4136,7 +4269,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{28} + return file_livekit_models_proto_rawDescGZIP(), []int{29} } func (x *RpcError) GetCode() uint32 { @@ -4171,7 +4304,7 @@ type ParticipantTracks struct { func (x *ParticipantTracks) Reset() { *x = ParticipantTracks{} - mi := &file_livekit_models_proto_msgTypes[29] + mi := &file_livekit_models_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4183,7 +4316,7 @@ func (x *ParticipantTracks) String() string { func (*ParticipantTracks) ProtoMessage() {} func (x *ParticipantTracks) 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 { @@ -4196,7 +4329,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{29} + return file_livekit_models_proto_rawDescGZIP(), []int{30} } func (x *ParticipantTracks) GetParticipantSid() string { @@ -4230,7 +4363,7 @@ type ServerInfo struct { func (x *ServerInfo) Reset() { *x = ServerInfo{} - mi := &file_livekit_models_proto_msgTypes[30] + mi := &file_livekit_models_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4242,7 +4375,7 @@ func (x *ServerInfo) String() string { func (*ServerInfo) ProtoMessage() {} func (x *ServerInfo) 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 { @@ -4255,7 +4388,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{30} + return file_livekit_models_proto_rawDescGZIP(), []int{31} } func (x *ServerInfo) GetEdition() ServerInfo_Edition { @@ -4335,7 +4468,7 @@ type ClientInfo struct { func (x *ClientInfo) Reset() { *x = ClientInfo{} - mi := &file_livekit_models_proto_msgTypes[31] + mi := &file_livekit_models_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4347,7 +4480,7 @@ func (x *ClientInfo) String() string { func (*ClientInfo) ProtoMessage() {} func (x *ClientInfo) 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 { @@ -4360,7 +4493,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{31} + return file_livekit_models_proto_rawDescGZIP(), []int{32} } func (x *ClientInfo) GetSdk() ClientInfo_SDK { @@ -4468,7 +4601,7 @@ type ClientConfiguration struct { func (x *ClientConfiguration) Reset() { *x = ClientConfiguration{} - mi := &file_livekit_models_proto_msgTypes[32] + mi := &file_livekit_models_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4480,7 +4613,7 @@ func (x *ClientConfiguration) String() string { func (*ClientConfiguration) ProtoMessage() {} func (x *ClientConfiguration) 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 { @@ -4493,7 +4626,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{32} + return file_livekit_models_proto_rawDescGZIP(), []int{33} } func (x *ClientConfiguration) GetVideo() *VideoConfiguration { @@ -4540,7 +4673,7 @@ type VideoConfiguration struct { func (x *VideoConfiguration) Reset() { *x = VideoConfiguration{} - mi := &file_livekit_models_proto_msgTypes[33] + mi := &file_livekit_models_proto_msgTypes[34] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4552,7 +4685,7 @@ func (x *VideoConfiguration) String() string { func (*VideoConfiguration) ProtoMessage() {} func (x *VideoConfiguration) 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 { @@ -4565,7 +4698,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{33} + return file_livekit_models_proto_rawDescGZIP(), []int{34} } func (x *VideoConfiguration) GetHardwareEncoder() ClientConfigSetting { @@ -4587,7 +4720,7 @@ type DisabledCodecs struct { func (x *DisabledCodecs) Reset() { *x = DisabledCodecs{} - mi := &file_livekit_models_proto_msgTypes[34] + mi := &file_livekit_models_proto_msgTypes[35] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4599,7 +4732,7 @@ func (x *DisabledCodecs) String() string { func (*DisabledCodecs) ProtoMessage() {} func (x *DisabledCodecs) 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 { @@ -4612,7 +4745,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{34} + return file_livekit_models_proto_rawDescGZIP(), []int{35} } func (x *DisabledCodecs) GetCodecs() []*Codec { @@ -4646,7 +4779,7 @@ type RTPDrift struct { func (x *RTPDrift) Reset() { *x = RTPDrift{} - mi := &file_livekit_models_proto_msgTypes[35] + mi := &file_livekit_models_proto_msgTypes[36] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4658,7 +4791,7 @@ func (x *RTPDrift) String() string { func (*RTPDrift) ProtoMessage() {} func (x *RTPDrift) 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 { @@ -4671,7 +4804,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{35} + return file_livekit_models_proto_rawDescGZIP(), []int{36} } func (x *RTPDrift) GetStartTime() *timestamppb.Timestamp { @@ -4790,7 +4923,7 @@ type RTPStats struct { func (x *RTPStats) Reset() { *x = RTPStats{} - mi := &file_livekit_models_proto_msgTypes[36] + mi := &file_livekit_models_proto_msgTypes[37] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4802,7 +4935,7 @@ func (x *RTPStats) String() string { func (*RTPStats) ProtoMessage() {} func (x *RTPStats) 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 { @@ -4815,7 +4948,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{36} + return file_livekit_models_proto_rawDescGZIP(), []int{37} } func (x *RTPStats) GetStartTime() *timestamppb.Timestamp { @@ -5148,7 +5281,7 @@ type RTCPSenderReportState struct { func (x *RTCPSenderReportState) Reset() { *x = RTCPSenderReportState{} - mi := &file_livekit_models_proto_msgTypes[37] + mi := &file_livekit_models_proto_msgTypes[38] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5160,7 +5293,7 @@ func (x *RTCPSenderReportState) String() string { func (*RTCPSenderReportState) ProtoMessage() {} func (x *RTCPSenderReportState) 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 { @@ -5173,7 +5306,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{37} + return file_livekit_models_proto_rawDescGZIP(), []int{38} } func (x *RTCPSenderReportState) GetRtpTimestamp() uint32 { @@ -5244,7 +5377,7 @@ type RTPForwarderState struct { func (x *RTPForwarderState) Reset() { *x = RTPForwarderState{} - mi := &file_livekit_models_proto_msgTypes[38] + mi := &file_livekit_models_proto_msgTypes[39] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5256,7 +5389,7 @@ func (x *RTPForwarderState) String() string { func (*RTPForwarderState) ProtoMessage() {} func (x *RTPForwarderState) 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 { @@ -5269,7 +5402,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{38} + return file_livekit_models_proto_rawDescGZIP(), []int{39} } func (x *RTPForwarderState) GetStarted() bool { @@ -5361,7 +5494,7 @@ type RTPMungerState struct { func (x *RTPMungerState) Reset() { *x = RTPMungerState{} - mi := &file_livekit_models_proto_msgTypes[39] + mi := &file_livekit_models_proto_msgTypes[40] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5373,7 +5506,7 @@ func (x *RTPMungerState) String() string { func (*RTPMungerState) ProtoMessage() {} func (x *RTPMungerState) 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 { @@ -5386,7 +5519,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{39} + return file_livekit_models_proto_rawDescGZIP(), []int{40} } func (x *RTPMungerState) GetExtLastSequenceNumber() uint64 { @@ -5446,7 +5579,7 @@ type VP8MungerState struct { func (x *VP8MungerState) Reset() { *x = VP8MungerState{} - mi := &file_livekit_models_proto_msgTypes[40] + mi := &file_livekit_models_proto_msgTypes[41] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5458,7 +5591,7 @@ func (x *VP8MungerState) String() string { func (*VP8MungerState) ProtoMessage() {} func (x *VP8MungerState) 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 { @@ -5471,7 +5604,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{40} + return file_livekit_models_proto_rawDescGZIP(), []int{41} } func (x *VP8MungerState) GetExtLastPictureId() int32 { @@ -5533,7 +5666,7 @@ type TimedVersion struct { func (x *TimedVersion) Reset() { *x = TimedVersion{} - mi := &file_livekit_models_proto_msgTypes[41] + mi := &file_livekit_models_proto_msgTypes[42] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5545,7 +5678,7 @@ func (x *TimedVersion) String() string { func (*TimedVersion) ProtoMessage() {} func (x *TimedVersion) 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 { @@ -5558,7 +5691,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{41} + return file_livekit_models_proto_rawDescGZIP(), []int{42} } func (x *TimedVersion) GetUnixMicro() int64 { @@ -5583,7 +5716,7 @@ type DataStream struct { func (x *DataStream) Reset() { *x = DataStream{} - mi := &file_livekit_models_proto_msgTypes[42] + mi := &file_livekit_models_proto_msgTypes[43] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5595,7 +5728,7 @@ func (x *DataStream) String() string { func (*DataStream) ProtoMessage() {} func (x *DataStream) 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 { @@ -5608,7 +5741,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{42} + return file_livekit_models_proto_rawDescGZIP(), []int{43} } type FilterParams struct { @@ -5621,7 +5754,7 @@ type FilterParams struct { func (x *FilterParams) Reset() { *x = FilterParams{} - mi := &file_livekit_models_proto_msgTypes[43] + mi := &file_livekit_models_proto_msgTypes[44] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5633,7 +5766,7 @@ func (x *FilterParams) String() string { func (*FilterParams) ProtoMessage() {} func (x *FilterParams) 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 { @@ -5646,7 +5779,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{43} + return file_livekit_models_proto_rawDescGZIP(), []int{44} } func (x *FilterParams) GetIncludeEvents() []string { @@ -5674,7 +5807,7 @@ type WebhookConfig struct { func (x *WebhookConfig) Reset() { *x = WebhookConfig{} - mi := &file_livekit_models_proto_msgTypes[44] + mi := &file_livekit_models_proto_msgTypes[45] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5686,7 +5819,7 @@ func (x *WebhookConfig) String() string { func (*WebhookConfig) ProtoMessage() {} func (x *WebhookConfig) 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 { @@ -5699,7 +5832,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{44} + return file_livekit_models_proto_rawDescGZIP(), []int{45} } func (x *WebhookConfig) GetUrl() string { @@ -5733,7 +5866,7 @@ type SubscribedAudioCodec struct { func (x *SubscribedAudioCodec) Reset() { *x = SubscribedAudioCodec{} - mi := &file_livekit_models_proto_msgTypes[45] + mi := &file_livekit_models_proto_msgTypes[46] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5745,7 +5878,7 @@ func (x *SubscribedAudioCodec) String() string { func (*SubscribedAudioCodec) ProtoMessage() {} func (x *SubscribedAudioCodec) 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 { @@ -5758,7 +5891,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{45} + return file_livekit_models_proto_rawDescGZIP(), []int{46} } func (x *SubscribedAudioCodec) GetCodec() string { @@ -5789,7 +5922,7 @@ type DataStream_TextHeader struct { func (x *DataStream_TextHeader) Reset() { *x = DataStream_TextHeader{} - mi := &file_livekit_models_proto_msgTypes[48] + mi := &file_livekit_models_proto_msgTypes[49] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5801,7 +5934,7 @@ func (x *DataStream_TextHeader) String() string { func (*DataStream_TextHeader) ProtoMessage() {} func (x *DataStream_TextHeader) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[48] + mi := &file_livekit_models_proto_msgTypes[49] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5814,7 +5947,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{42, 0} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 0} } func (x *DataStream_TextHeader) GetOperationType() DataStream_OperationType { @@ -5862,7 +5995,7 @@ type DataStream_ByteHeader struct { func (x *DataStream_ByteHeader) Reset() { *x = DataStream_ByteHeader{} - mi := &file_livekit_models_proto_msgTypes[49] + mi := &file_livekit_models_proto_msgTypes[50] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5874,7 +6007,7 @@ func (x *DataStream_ByteHeader) String() string { func (*DataStream_ByteHeader) ProtoMessage() {} func (x *DataStream_ByteHeader) ProtoReflect() protoreflect.Message { - mi := &file_livekit_models_proto_msgTypes[49] + mi := &file_livekit_models_proto_msgTypes[50] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -5887,7 +6020,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{42, 1} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 1} } func (x *DataStream_ByteHeader) GetName() string { @@ -5921,7 +6054,7 @@ type DataStream_Header struct { func (x *DataStream_Header) Reset() { *x = DataStream_Header{} - mi := &file_livekit_models_proto_msgTypes[50] + mi := &file_livekit_models_proto_msgTypes[51] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -5933,7 +6066,7 @@ func (x *DataStream_Header) String() string { func (*DataStream_Header) ProtoMessage() {} func (x *DataStream_Header) 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 { @@ -5946,7 +6079,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{42, 2} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 2} } func (x *DataStream_Header) GetStreamId() string { @@ -6054,7 +6187,7 @@ type DataStream_Chunk struct { func (x *DataStream_Chunk) Reset() { *x = DataStream_Chunk{} - mi := &file_livekit_models_proto_msgTypes[51] + mi := &file_livekit_models_proto_msgTypes[52] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6066,7 +6199,7 @@ func (x *DataStream_Chunk) String() string { func (*DataStream_Chunk) ProtoMessage() {} func (x *DataStream_Chunk) 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 { @@ -6079,7 +6212,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{42, 3} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 3} } func (x *DataStream_Chunk) GetStreamId() string { @@ -6129,7 +6262,7 @@ type DataStream_Trailer struct { func (x *DataStream_Trailer) Reset() { *x = DataStream_Trailer{} - mi := &file_livekit_models_proto_msgTypes[52] + mi := &file_livekit_models_proto_msgTypes[53] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -6141,7 +6274,7 @@ func (x *DataStream_Trailer) String() string { func (*DataStream_Trailer) ProtoMessage() {} func (x *DataStream_Trailer) 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 { @@ -6154,7 +6287,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{42, 4} + return file_livekit_models_proto_rawDescGZIP(), []int{43, 4} } func (x *DataStream_Trailer) GetStreamId() string { @@ -6325,7 +6458,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\"\xd0\x01\n" + "\rDataTrackInfo\x12\x1d\n" + "\n" + "pub_handle\x18\x01 \x01(\rR\tpubHandle\x12\x10\n" + @@ -6333,7 +6466,14 @@ 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\x125\n" + + "\x06schema\x18\x05 \x01(\v2\x18.livekit.DataTrackSchemaH\x00R\x06schema\x88\x01\x01B\t\n" + + "\a_schema\"y\n" + + "\x0fDataTrackSchema\x12\x12\n" + + "\x04name\x18\x01 \x01(\tR\x04name\x120\n" + + "\x04type\x18\x02 \x01(\x0e2\x1c.livekit.DataTrackSchemaTypeR\x04type\x12\x17\n" + + "\x04data\x18\x03 \x01(\fH\x00R\x04data\x88\x01\x01B\a\n" + + "\x05_data\"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" + @@ -6758,7 +6898,15 @@ 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*\x9b\x02\n" + + "\x13DataTrackSchemaType\x12&\n" + + "\"DATA_TRACK_SCHEMA_TYPE_UNSPECIFIED\x10\x00\x12#\n" + + "\x1fDATA_TRACK_SCHEMA_TYPE_PROTOBUF\x10\x01\x12%\n" + + "!DATA_TRACK_SCHEMA_TYPE_FLATBUFFER\x10\x02\x12\"\n" + + "\x1eDATA_TRACK_SCHEMA_TYPE_ROS1MSG\x10\x03\x12\"\n" + + "\x1eDATA_TRACK_SCHEMA_TYPE_ROS2IDL\x10\x04\x12!\n" + + "\x1dDATA_TRACK_SCHEMA_TYPE_OMGIDL\x10\x05\x12%\n" + + "!DATA_TRACK_SCHEMA_TYPE_JSONSCHEMA\x10\x06*B\n" + "\x14DataTrackExtensionID\x12\x10\n" + "\fDTEI_INVALID\x10\x00\x12\x18\n" + "\x14DTEI_PARTICIPANT_SID\x10\x01*6\n" + @@ -6832,8 +6980,8 @@ func file_livekit_models_proto_rawDescGZIP() []byte { return file_livekit_models_proto_rawDescData } -var file_livekit_models_proto_enumTypes = make([]protoimpl.EnumInfo, 25) -var file_livekit_models_proto_msgTypes = make([]protoimpl.MessageInfo, 55) +var file_livekit_models_proto_enumTypes = make([]protoimpl.EnumInfo, 26) +var file_livekit_models_proto_msgTypes = make([]protoimpl.MessageInfo, 56) var file_livekit_models_proto_goTypes = []any{ (AudioCodec)(0), // 0: livekit.AudioCodec (VideoCodec)(0), // 1: livekit.VideoCodec @@ -6841,174 +6989,178 @@ 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 - (*Pagination)(nil), // 25: livekit.Pagination - (*TokenPagination)(nil), // 26: livekit.TokenPagination - (*ListUpdate)(nil), // 27: livekit.ListUpdate - (*Room)(nil), // 28: livekit.Room - (*Codec)(nil), // 29: livekit.Codec - (*PlayoutDelay)(nil), // 30: livekit.PlayoutDelay - (*ParticipantPermission)(nil), // 31: livekit.ParticipantPermission - (*ParticipantInfo)(nil), // 32: livekit.ParticipantInfo - (*Encryption)(nil), // 33: livekit.Encryption - (*SimulcastCodecInfo)(nil), // 34: livekit.SimulcastCodecInfo - (*TrackInfo)(nil), // 35: livekit.TrackInfo - (*DataTrackInfo)(nil), // 36: livekit.DataTrackInfo - (*DataTrackExtensionParticipantSid)(nil), // 37: livekit.DataTrackExtensionParticipantSid - (*DataTrackSubscriptionOptions)(nil), // 38: livekit.DataTrackSubscriptionOptions - (*VideoLayer)(nil), // 39: livekit.VideoLayer - (*DataPacket)(nil), // 40: livekit.DataPacket - (*EncryptedPacket)(nil), // 41: livekit.EncryptedPacket - (*EncryptedPacketPayload)(nil), // 42: livekit.EncryptedPacketPayload - (*ActiveSpeakerUpdate)(nil), // 43: livekit.ActiveSpeakerUpdate - (*SpeakerInfo)(nil), // 44: livekit.SpeakerInfo - (*UserPacket)(nil), // 45: livekit.UserPacket - (*SipDTMF)(nil), // 46: livekit.SipDTMF - (*Transcription)(nil), // 47: livekit.Transcription - (*TranscriptionSegment)(nil), // 48: livekit.TranscriptionSegment - (*ChatMessage)(nil), // 49: livekit.ChatMessage - (*RpcRequest)(nil), // 50: livekit.RpcRequest - (*RpcAck)(nil), // 51: livekit.RpcAck - (*RpcResponse)(nil), // 52: livekit.RpcResponse - (*RpcError)(nil), // 53: livekit.RpcError - (*ParticipantTracks)(nil), // 54: livekit.ParticipantTracks - (*ServerInfo)(nil), // 55: livekit.ServerInfo - (*ClientInfo)(nil), // 56: livekit.ClientInfo - (*ClientConfiguration)(nil), // 57: livekit.ClientConfiguration - (*VideoConfiguration)(nil), // 58: livekit.VideoConfiguration - (*DisabledCodecs)(nil), // 59: livekit.DisabledCodecs - (*RTPDrift)(nil), // 60: livekit.RTPDrift - (*RTPStats)(nil), // 61: livekit.RTPStats - (*RTCPSenderReportState)(nil), // 62: livekit.RTCPSenderReportState - (*RTPForwarderState)(nil), // 63: livekit.RTPForwarderState - (*RTPMungerState)(nil), // 64: livekit.RTPMungerState - (*VP8MungerState)(nil), // 65: livekit.VP8MungerState - (*TimedVersion)(nil), // 66: livekit.TimedVersion - (*DataStream)(nil), // 67: livekit.DataStream - (*FilterParams)(nil), // 68: livekit.FilterParams - (*WebhookConfig)(nil), // 69: livekit.WebhookConfig - (*SubscribedAudioCodec)(nil), // 70: livekit.SubscribedAudioCodec - nil, // 71: livekit.ParticipantInfo.AttributesEntry - nil, // 72: livekit.RTPStats.GapHistogramEntry - (*DataStream_TextHeader)(nil), // 73: livekit.DataStream.TextHeader - (*DataStream_ByteHeader)(nil), // 74: livekit.DataStream.ByteHeader - (*DataStream_Header)(nil), // 75: livekit.DataStream.Header - (*DataStream_Chunk)(nil), // 76: livekit.DataStream.Chunk - (*DataStream_Trailer)(nil), // 77: livekit.DataStream.Trailer - nil, // 78: livekit.DataStream.Header.AttributesEntry - nil, // 79: livekit.DataStream.Trailer.AttributesEntry - (*MetricsBatch)(nil), // 80: livekit.MetricsBatch - (*timestamppb.Timestamp)(nil), // 81: google.protobuf.Timestamp + (DataTrackSchemaType)(0), // 6: livekit.DataTrackSchemaType + (DataTrackExtensionID)(0), // 7: livekit.DataTrackExtensionID + (VideoQuality)(0), // 8: livekit.VideoQuality + (ConnectionQuality)(0), // 9: livekit.ConnectionQuality + (ClientConfigSetting)(0), // 10: livekit.ClientConfigSetting + (DisconnectReason)(0), // 11: livekit.DisconnectReason + (ReconnectReason)(0), // 12: livekit.ReconnectReason + (SubscriptionError)(0), // 13: livekit.SubscriptionError + (AudioTrackFeature)(0), // 14: livekit.AudioTrackFeature + (PacketTrailerFeature)(0), // 15: livekit.PacketTrailerFeature + (ParticipantInfo_State)(0), // 16: livekit.ParticipantInfo.State + (ParticipantInfo_Kind)(0), // 17: livekit.ParticipantInfo.Kind + (ParticipantInfo_KindDetail)(0), // 18: livekit.ParticipantInfo.KindDetail + (Encryption_Type)(0), // 19: livekit.Encryption.Type + (VideoLayer_Mode)(0), // 20: livekit.VideoLayer.Mode + (DataPacket_Kind)(0), // 21: livekit.DataPacket.Kind + (ServerInfo_Edition)(0), // 22: livekit.ServerInfo.Edition + (ClientInfo_SDK)(0), // 23: livekit.ClientInfo.SDK + (ClientInfo_Capability)(0), // 24: livekit.ClientInfo.Capability + (DataStream_OperationType)(0), // 25: livekit.DataStream.OperationType + (*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 + (*DataTrackSchema)(nil), // 38: livekit.DataTrackSchema + (*DataTrackExtensionParticipantSid)(nil), // 39: livekit.DataTrackExtensionParticipantSid + (*DataTrackSubscriptionOptions)(nil), // 40: livekit.DataTrackSubscriptionOptions + (*VideoLayer)(nil), // 41: livekit.VideoLayer + (*DataPacket)(nil), // 42: livekit.DataPacket + (*EncryptedPacket)(nil), // 43: livekit.EncryptedPacket + (*EncryptedPacketPayload)(nil), // 44: livekit.EncryptedPacketPayload + (*ActiveSpeakerUpdate)(nil), // 45: livekit.ActiveSpeakerUpdate + (*SpeakerInfo)(nil), // 46: livekit.SpeakerInfo + (*UserPacket)(nil), // 47: livekit.UserPacket + (*SipDTMF)(nil), // 48: livekit.SipDTMF + (*Transcription)(nil), // 49: livekit.Transcription + (*TranscriptionSegment)(nil), // 50: livekit.TranscriptionSegment + (*ChatMessage)(nil), // 51: livekit.ChatMessage + (*RpcRequest)(nil), // 52: livekit.RpcRequest + (*RpcAck)(nil), // 53: livekit.RpcAck + (*RpcResponse)(nil), // 54: livekit.RpcResponse + (*RpcError)(nil), // 55: livekit.RpcError + (*ParticipantTracks)(nil), // 56: livekit.ParticipantTracks + (*ServerInfo)(nil), // 57: livekit.ServerInfo + (*ClientInfo)(nil), // 58: livekit.ClientInfo + (*ClientConfiguration)(nil), // 59: livekit.ClientConfiguration + (*VideoConfiguration)(nil), // 60: livekit.VideoConfiguration + (*DisabledCodecs)(nil), // 61: livekit.DisabledCodecs + (*RTPDrift)(nil), // 62: livekit.RTPDrift + (*RTPStats)(nil), // 63: livekit.RTPStats + (*RTCPSenderReportState)(nil), // 64: livekit.RTCPSenderReportState + (*RTPForwarderState)(nil), // 65: livekit.RTPForwarderState + (*RTPMungerState)(nil), // 66: livekit.RTPMungerState + (*VP8MungerState)(nil), // 67: livekit.VP8MungerState + (*TimedVersion)(nil), // 68: livekit.TimedVersion + (*DataStream)(nil), // 69: livekit.DataStream + (*FilterParams)(nil), // 70: livekit.FilterParams + (*WebhookConfig)(nil), // 71: livekit.WebhookConfig + (*SubscribedAudioCodec)(nil), // 72: livekit.SubscribedAudioCodec + nil, // 73: livekit.ParticipantInfo.AttributesEntry + nil, // 74: livekit.RTPStats.GapHistogramEntry + (*DataStream_TextHeader)(nil), // 75: livekit.DataStream.TextHeader + (*DataStream_ByteHeader)(nil), // 76: livekit.DataStream.ByteHeader + (*DataStream_Header)(nil), // 77: livekit.DataStream.Header + (*DataStream_Chunk)(nil), // 78: livekit.DataStream.Chunk + (*DataStream_Trailer)(nil), // 79: livekit.DataStream.Trailer + nil, // 80: livekit.DataStream.Header.AttributesEntry + nil, // 81: livekit.DataStream.Trailer.AttributesEntry + (*MetricsBatch)(nil), // 82: livekit.MetricsBatch + (*timestamppb.Timestamp)(nil), // 83: google.protobuf.Timestamp } var file_livekit_models_proto_depIdxs = []int32{ - 29, // 0: livekit.Room.enabled_codecs:type_name -> livekit.Codec - 66, // 1: livekit.Room.version:type_name -> livekit.TimedVersion + 30, // 0: livekit.Room.enabled_codecs:type_name -> livekit.Codec + 68, // 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 - 35, // 4: livekit.ParticipantInfo.tracks:type_name -> livekit.TrackInfo - 31, // 5: livekit.ParticipantInfo.permission:type_name -> livekit.ParticipantPermission - 16, // 6: livekit.ParticipantInfo.kind:type_name -> livekit.ParticipantInfo.Kind - 71, // 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 - 36, // 10: livekit.ParticipantInfo.data_tracks:type_name -> livekit.DataTrackInfo - 39, // 11: livekit.SimulcastCodecInfo.layers:type_name -> livekit.VideoLayer - 19, // 12: livekit.SimulcastCodecInfo.video_layer_mode:type_name -> livekit.VideoLayer.Mode + 16, // 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 + 17, // 6: livekit.ParticipantInfo.kind:type_name -> livekit.ParticipantInfo.Kind + 73, // 7: livekit.ParticipantInfo.attributes:type_name -> livekit.ParticipantInfo.AttributesEntry + 11, // 8: livekit.ParticipantInfo.disconnect_reason:type_name -> livekit.DisconnectReason + 18, // 9: livekit.ParticipantInfo.kind_details:type_name -> livekit.ParticipantInfo.KindDetail + 37, // 10: livekit.ParticipantInfo.data_tracks:type_name -> livekit.DataTrackInfo + 41, // 11: livekit.SimulcastCodecInfo.layers:type_name -> livekit.VideoLayer + 20, // 12: livekit.SimulcastCodecInfo.video_layer_mode:type_name -> livekit.VideoLayer.Mode 4, // 13: livekit.TrackInfo.type:type_name -> livekit.TrackType 5, // 14: livekit.TrackInfo.source:type_name -> livekit.TrackSource - 39, // 15: livekit.TrackInfo.layers:type_name -> livekit.VideoLayer - 34, // 16: livekit.TrackInfo.codecs:type_name -> livekit.SimulcastCodecInfo - 18, // 17: livekit.TrackInfo.encryption:type_name -> livekit.Encryption.Type - 66, // 18: livekit.TrackInfo.version:type_name -> livekit.TimedVersion - 13, // 19: livekit.TrackInfo.audio_features:type_name -> livekit.AudioTrackFeature + 41, // 15: livekit.TrackInfo.layers:type_name -> livekit.VideoLayer + 35, // 16: livekit.TrackInfo.codecs:type_name -> livekit.SimulcastCodecInfo + 19, // 17: livekit.TrackInfo.encryption:type_name -> livekit.Encryption.Type + 68, // 18: livekit.TrackInfo.version:type_name -> livekit.TimedVersion + 14, // 19: livekit.TrackInfo.audio_features:type_name -> livekit.AudioTrackFeature 3, // 20: livekit.TrackInfo.backup_codec_policy:type_name -> livekit.BackupCodecPolicy - 14, // 21: livekit.TrackInfo.packet_trailer_features:type_name -> livekit.PacketTrailerFeature - 18, // 22: livekit.DataTrackInfo.encryption:type_name -> livekit.Encryption.Type - 6, // 23: livekit.DataTrackExtensionParticipantSid.id:type_name -> livekit.DataTrackExtensionID - 7, // 24: livekit.VideoLayer.quality:type_name -> livekit.VideoQuality - 20, // 25: livekit.DataPacket.kind:type_name -> livekit.DataPacket.Kind - 45, // 26: livekit.DataPacket.user:type_name -> livekit.UserPacket - 43, // 27: livekit.DataPacket.speaker:type_name -> livekit.ActiveSpeakerUpdate - 46, // 28: livekit.DataPacket.sip_dtmf:type_name -> livekit.SipDTMF - 47, // 29: livekit.DataPacket.transcription:type_name -> livekit.Transcription - 80, // 30: livekit.DataPacket.metrics:type_name -> livekit.MetricsBatch - 49, // 31: livekit.DataPacket.chat_message:type_name -> livekit.ChatMessage - 50, // 32: livekit.DataPacket.rpc_request:type_name -> livekit.RpcRequest - 51, // 33: livekit.DataPacket.rpc_ack:type_name -> livekit.RpcAck - 52, // 34: livekit.DataPacket.rpc_response:type_name -> livekit.RpcResponse - 75, // 35: livekit.DataPacket.stream_header:type_name -> livekit.DataStream.Header - 76, // 36: livekit.DataPacket.stream_chunk:type_name -> livekit.DataStream.Chunk - 77, // 37: livekit.DataPacket.stream_trailer:type_name -> livekit.DataStream.Trailer - 41, // 38: livekit.DataPacket.encrypted_packet:type_name -> livekit.EncryptedPacket - 18, // 39: livekit.EncryptedPacket.encryption_type:type_name -> livekit.Encryption.Type - 45, // 40: livekit.EncryptedPacketPayload.user:type_name -> livekit.UserPacket - 49, // 41: livekit.EncryptedPacketPayload.chat_message:type_name -> livekit.ChatMessage - 50, // 42: livekit.EncryptedPacketPayload.rpc_request:type_name -> livekit.RpcRequest - 51, // 43: livekit.EncryptedPacketPayload.rpc_ack:type_name -> livekit.RpcAck - 52, // 44: livekit.EncryptedPacketPayload.rpc_response:type_name -> livekit.RpcResponse - 75, // 45: livekit.EncryptedPacketPayload.stream_header:type_name -> livekit.DataStream.Header - 76, // 46: livekit.EncryptedPacketPayload.stream_chunk:type_name -> livekit.DataStream.Chunk - 77, // 47: livekit.EncryptedPacketPayload.stream_trailer:type_name -> livekit.DataStream.Trailer - 44, // 48: livekit.ActiveSpeakerUpdate.speakers:type_name -> livekit.SpeakerInfo - 48, // 49: livekit.Transcription.segments:type_name -> livekit.TranscriptionSegment - 53, // 50: livekit.RpcResponse.error:type_name -> livekit.RpcError - 21, // 51: livekit.ServerInfo.edition:type_name -> livekit.ServerInfo.Edition - 22, // 52: livekit.ClientInfo.sdk:type_name -> livekit.ClientInfo.SDK - 23, // 53: livekit.ClientInfo.capabilities:type_name -> livekit.ClientInfo.Capability - 58, // 54: livekit.ClientConfiguration.video:type_name -> livekit.VideoConfiguration - 58, // 55: livekit.ClientConfiguration.screen:type_name -> livekit.VideoConfiguration - 9, // 56: livekit.ClientConfiguration.resume_connection:type_name -> livekit.ClientConfigSetting - 59, // 57: livekit.ClientConfiguration.disabled_codecs:type_name -> livekit.DisabledCodecs - 9, // 58: livekit.ClientConfiguration.force_relay:type_name -> livekit.ClientConfigSetting - 9, // 59: livekit.VideoConfiguration.hardware_encoder:type_name -> livekit.ClientConfigSetting - 29, // 60: livekit.DisabledCodecs.codecs:type_name -> livekit.Codec - 29, // 61: livekit.DisabledCodecs.publish:type_name -> livekit.Codec - 81, // 62: livekit.RTPDrift.start_time:type_name -> google.protobuf.Timestamp - 81, // 63: livekit.RTPDrift.end_time:type_name -> google.protobuf.Timestamp - 81, // 64: livekit.RTPStats.start_time:type_name -> google.protobuf.Timestamp - 81, // 65: livekit.RTPStats.end_time:type_name -> google.protobuf.Timestamp - 72, // 66: livekit.RTPStats.gap_histogram:type_name -> livekit.RTPStats.GapHistogramEntry - 81, // 67: livekit.RTPStats.last_pli:type_name -> google.protobuf.Timestamp - 81, // 68: livekit.RTPStats.last_fir:type_name -> google.protobuf.Timestamp - 81, // 69: livekit.RTPStats.last_key_frame:type_name -> google.protobuf.Timestamp - 81, // 70: livekit.RTPStats.last_layer_lock_pli:type_name -> google.protobuf.Timestamp - 60, // 71: livekit.RTPStats.packet_drift:type_name -> livekit.RTPDrift - 60, // 72: livekit.RTPStats.ntp_report_drift:type_name -> livekit.RTPDrift - 60, // 73: livekit.RTPStats.rebased_report_drift:type_name -> livekit.RTPDrift - 60, // 74: livekit.RTPStats.received_report_drift:type_name -> livekit.RTPDrift - 64, // 75: livekit.RTPForwarderState.rtp_munger:type_name -> livekit.RTPMungerState - 65, // 76: livekit.RTPForwarderState.vp8_munger:type_name -> livekit.VP8MungerState - 62, // 77: livekit.RTPForwarderState.sender_report_state:type_name -> livekit.RTCPSenderReportState - 68, // 78: livekit.WebhookConfig.filter_params:type_name -> livekit.FilterParams - 24, // 79: livekit.DataStream.TextHeader.operation_type:type_name -> livekit.DataStream.OperationType - 18, // 80: livekit.DataStream.Header.encryption_type:type_name -> livekit.Encryption.Type - 78, // 81: livekit.DataStream.Header.attributes:type_name -> livekit.DataStream.Header.AttributesEntry - 73, // 82: livekit.DataStream.Header.text_header:type_name -> livekit.DataStream.TextHeader - 74, // 83: livekit.DataStream.Header.byte_header:type_name -> livekit.DataStream.ByteHeader - 79, // 84: livekit.DataStream.Trailer.attributes:type_name -> livekit.DataStream.Trailer.AttributesEntry - 85, // [85:85] is the sub-list for method output_type - 85, // [85:85] is the sub-list for method input_type - 85, // [85:85] is the sub-list for extension type_name - 85, // [85:85] is the sub-list for extension extendee - 0, // [0:85] is the sub-list for field type_name + 15, // 21: livekit.TrackInfo.packet_trailer_features:type_name -> livekit.PacketTrailerFeature + 19, // 22: livekit.DataTrackInfo.encryption:type_name -> livekit.Encryption.Type + 38, // 23: livekit.DataTrackInfo.schema:type_name -> livekit.DataTrackSchema + 6, // 24: livekit.DataTrackSchema.type:type_name -> livekit.DataTrackSchemaType + 7, // 25: livekit.DataTrackExtensionParticipantSid.id:type_name -> livekit.DataTrackExtensionID + 8, // 26: livekit.VideoLayer.quality:type_name -> livekit.VideoQuality + 21, // 27: livekit.DataPacket.kind:type_name -> livekit.DataPacket.Kind + 47, // 28: livekit.DataPacket.user:type_name -> livekit.UserPacket + 45, // 29: livekit.DataPacket.speaker:type_name -> livekit.ActiveSpeakerUpdate + 48, // 30: livekit.DataPacket.sip_dtmf:type_name -> livekit.SipDTMF + 49, // 31: livekit.DataPacket.transcription:type_name -> livekit.Transcription + 82, // 32: livekit.DataPacket.metrics:type_name -> livekit.MetricsBatch + 51, // 33: livekit.DataPacket.chat_message:type_name -> livekit.ChatMessage + 52, // 34: livekit.DataPacket.rpc_request:type_name -> livekit.RpcRequest + 53, // 35: livekit.DataPacket.rpc_ack:type_name -> livekit.RpcAck + 54, // 36: livekit.DataPacket.rpc_response:type_name -> livekit.RpcResponse + 77, // 37: livekit.DataPacket.stream_header:type_name -> livekit.DataStream.Header + 78, // 38: livekit.DataPacket.stream_chunk:type_name -> livekit.DataStream.Chunk + 79, // 39: livekit.DataPacket.stream_trailer:type_name -> livekit.DataStream.Trailer + 43, // 40: livekit.DataPacket.encrypted_packet:type_name -> livekit.EncryptedPacket + 19, // 41: livekit.EncryptedPacket.encryption_type:type_name -> livekit.Encryption.Type + 47, // 42: livekit.EncryptedPacketPayload.user:type_name -> livekit.UserPacket + 51, // 43: livekit.EncryptedPacketPayload.chat_message:type_name -> livekit.ChatMessage + 52, // 44: livekit.EncryptedPacketPayload.rpc_request:type_name -> livekit.RpcRequest + 53, // 45: livekit.EncryptedPacketPayload.rpc_ack:type_name -> livekit.RpcAck + 54, // 46: livekit.EncryptedPacketPayload.rpc_response:type_name -> livekit.RpcResponse + 77, // 47: livekit.EncryptedPacketPayload.stream_header:type_name -> livekit.DataStream.Header + 78, // 48: livekit.EncryptedPacketPayload.stream_chunk:type_name -> livekit.DataStream.Chunk + 79, // 49: livekit.EncryptedPacketPayload.stream_trailer:type_name -> livekit.DataStream.Trailer + 46, // 50: livekit.ActiveSpeakerUpdate.speakers:type_name -> livekit.SpeakerInfo + 50, // 51: livekit.Transcription.segments:type_name -> livekit.TranscriptionSegment + 55, // 52: livekit.RpcResponse.error:type_name -> livekit.RpcError + 22, // 53: livekit.ServerInfo.edition:type_name -> livekit.ServerInfo.Edition + 23, // 54: livekit.ClientInfo.sdk:type_name -> livekit.ClientInfo.SDK + 24, // 55: livekit.ClientInfo.capabilities:type_name -> livekit.ClientInfo.Capability + 60, // 56: livekit.ClientConfiguration.video:type_name -> livekit.VideoConfiguration + 60, // 57: livekit.ClientConfiguration.screen:type_name -> livekit.VideoConfiguration + 10, // 58: livekit.ClientConfiguration.resume_connection:type_name -> livekit.ClientConfigSetting + 61, // 59: livekit.ClientConfiguration.disabled_codecs:type_name -> livekit.DisabledCodecs + 10, // 60: livekit.ClientConfiguration.force_relay:type_name -> livekit.ClientConfigSetting + 10, // 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 + 83, // 64: livekit.RTPDrift.start_time:type_name -> google.protobuf.Timestamp + 83, // 65: livekit.RTPDrift.end_time:type_name -> google.protobuf.Timestamp + 83, // 66: livekit.RTPStats.start_time:type_name -> google.protobuf.Timestamp + 83, // 67: livekit.RTPStats.end_time:type_name -> google.protobuf.Timestamp + 74, // 68: livekit.RTPStats.gap_histogram:type_name -> livekit.RTPStats.GapHistogramEntry + 83, // 69: livekit.RTPStats.last_pli:type_name -> google.protobuf.Timestamp + 83, // 70: livekit.RTPStats.last_fir:type_name -> google.protobuf.Timestamp + 83, // 71: livekit.RTPStats.last_key_frame:type_name -> google.protobuf.Timestamp + 83, // 72: livekit.RTPStats.last_layer_lock_pli:type_name -> google.protobuf.Timestamp + 62, // 73: livekit.RTPStats.packet_drift:type_name -> livekit.RTPDrift + 62, // 74: livekit.RTPStats.ntp_report_drift:type_name -> livekit.RTPDrift + 62, // 75: livekit.RTPStats.rebased_report_drift:type_name -> livekit.RTPDrift + 62, // 76: livekit.RTPStats.received_report_drift:type_name -> livekit.RTPDrift + 66, // 77: livekit.RTPForwarderState.rtp_munger:type_name -> livekit.RTPMungerState + 67, // 78: livekit.RTPForwarderState.vp8_munger:type_name -> livekit.VP8MungerState + 64, // 79: livekit.RTPForwarderState.sender_report_state:type_name -> livekit.RTCPSenderReportState + 70, // 80: livekit.WebhookConfig.filter_params:type_name -> livekit.FilterParams + 25, // 81: livekit.DataStream.TextHeader.operation_type:type_name -> livekit.DataStream.OperationType + 19, // 82: livekit.DataStream.Header.encryption_type:type_name -> livekit.Encryption.Type + 80, // 83: livekit.DataStream.Header.attributes:type_name -> livekit.DataStream.Header.AttributesEntry + 75, // 84: livekit.DataStream.Header.text_header:type_name -> livekit.DataStream.TextHeader + 76, // 85: livekit.DataStream.Header.byte_header:type_name -> livekit.DataStream.ByteHeader + 81, // 86: livekit.DataStream.Trailer.attributes:type_name -> livekit.DataStream.Trailer.AttributesEntry + 87, // [87:87] is the sub-list for method output_type + 87, // [87:87] is the sub-list for method input_type + 87, // [87:87] is the sub-list for extension type_name + 87, // [87:87] is the sub-list for extension extendee + 0, // [0:87] is the sub-list for field type_name } func init() { file_livekit_models_proto_init() } @@ -7017,8 +7169,10 @@ 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[15].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[11].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[12].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[14].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[16].OneofWrappers = []any{ (*DataPacket_User)(nil), (*DataPacket_Speaker)(nil), (*DataPacket_SipDtmf)(nil), @@ -7033,7 +7187,7 @@ func file_livekit_models_proto_init() { (*DataPacket_StreamTrailer)(nil), (*DataPacket_EncryptedPacket)(nil), } - file_livekit_models_proto_msgTypes[17].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[18].OneofWrappers = []any{ (*EncryptedPacketPayload_User)(nil), (*EncryptedPacketPayload_ChatMessage)(nil), (*EncryptedPacketPayload_RpcRequest)(nil), @@ -7043,28 +7197,28 @@ func file_livekit_models_proto_init() { (*EncryptedPacketPayload_StreamChunk)(nil), (*EncryptedPacketPayload_StreamTrailer)(nil), } - file_livekit_models_proto_msgTypes[20].OneofWrappers = []any{} - file_livekit_models_proto_msgTypes[24].OneofWrappers = []any{} - file_livekit_models_proto_msgTypes[27].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[21].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[25].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[28].OneofWrappers = []any{ (*RpcResponse_Payload)(nil), (*RpcResponse_Error)(nil), (*RpcResponse_CompressedPayload)(nil), } - file_livekit_models_proto_msgTypes[38].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[39].OneofWrappers = []any{ (*RTPForwarderState_Vp8Munger)(nil), } - file_livekit_models_proto_msgTypes[50].OneofWrappers = []any{ + file_livekit_models_proto_msgTypes[51].OneofWrappers = []any{ (*DataStream_Header_TextHeader)(nil), (*DataStream_Header_ByteHeader)(nil), } - file_livekit_models_proto_msgTypes[51].OneofWrappers = []any{} + file_livekit_models_proto_msgTypes[52].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: 25, - NumMessages: 55, + NumEnums: 26, + NumMessages: 56, NumExtensions: 0, NumServices: 0, }, diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index f3fae5149..1d8469ab7 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -241,6 +241,7 @@ const ( RequestResponse_INVALID_NAME RequestResponse_Reason = 8 RequestResponse_DUPLICATE_HANDLE RequestResponse_Reason = 9 RequestResponse_DUPLICATE_NAME RequestResponse_Reason = 10 + RequestResponse_INVALID_SCHEMA RequestResponse_Reason = 11 ) // Enum value maps for RequestResponse_Reason. @@ -257,6 +258,7 @@ var ( 8: "INVALID_NAME", 9: "DUPLICATE_HANDLE", 10: "DUPLICATE_NAME", + 11: "INVALID_SCHEMA", } RequestResponse_Reason_value = map[string]int32{ "OK": 0, @@ -270,6 +272,7 @@ var ( "INVALID_NAME": 8, "DUPLICATE_HANDLE": 9, "DUPLICATE_NAME": 10, + "INVALID_SCHEMA": 11, } ) @@ -1533,7 +1536,9 @@ 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"` + // Schema describing frames published on the track. + Schema *DataTrackSchema `protobuf:"bytes,4,opt,name=schema,proto3,oneof" json:"schema,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -1589,6 +1594,13 @@ func (x *PublishDataTrackRequest) GetEncryption() Encryption_Type { return Encryption_NONE } +func (x *PublishDataTrackRequest) GetSchema() *DataTrackSchema { + if x != nil { + return x.Schema + } + return nil +} + type PublishDataTrackResponse struct { state protoimpl.MessageState `protogen:"open.v1"` // Information about the published track. @@ -5103,14 +5115,16 @@ 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\"\xc8\x01\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\x125\n" + + "\x06schema\x18\x04 \x01(\v2\x18.livekit.DataTrackSchemaH\x00R\x06schema\x88\x01\x01B\t\n" + + "\a_schema\"F\n" + "\x18PublishDataTrackResponse\x12*\n" + "\x04info\x18\x01 \x01(\v2\x16.livekit.DataTrackInfoR\x04info\":\n" + "\x19UnpublishDataTrackRequest\x12\x1d\n" + @@ -5327,7 +5341,7 @@ const file_livekit_rtc_proto_rawDesc = "" + "\bdistance\x18\x03 \x01(\x03R\bdistance\"a\n" + "\x14SubscriptionResponse\x12\x1b\n" + "\ttrack_sid\x18\x01 \x01(\tR\btrackSid\x12,\n" + - "\x03err\x18\x02 \x01(\x0e2\x1a.livekit.SubscriptionErrorR\x03err\"\xa5\a\n" + + "\x03err\x18\x02 \x01(\x0e2\x1a.livekit.SubscriptionErrorR\x03err\"\xb9\a\n" + "\x0fRequestResponse\x12+\n" + "\n" + "request_id\x18\x01 \x01(\rB\f\xbaP\trequestIDR\trequestId\x127\n" + @@ -5341,7 +5355,7 @@ const file_livekit_rtc_proto_rawDesc = "" + "\x12update_video_track\x18\t \x01(\v2\x1e.livekit.UpdateLocalVideoTrackH\x00R\x10updateVideoTrack\x12P\n" + "\x12publish_data_track\x18\n" + " \x01(\v2 .livekit.PublishDataTrackRequestH\x00R\x10publishDataTrack\x12V\n" + - "\x14unpublish_data_track\x18\v \x01(\v2\".livekit.UnpublishDataTrackRequestH\x00R\x12unpublishDataTrack\"\xce\x01\n" + + "\x14unpublish_data_track\x18\v \x01(\v2\".livekit.UnpublishDataTrackRequestH\x00R\x12unpublishDataTrack\"\xe2\x01\n" + "\x06Reason\x12\x06\n" + "\x02OK\x10\x00\x12\r\n" + "\tNOT_FOUND\x10\x01\x12\x0f\n" + @@ -5355,7 +5369,8 @@ const file_livekit_rtc_proto_rawDesc = "" + "\fINVALID_NAME\x10\b\x12\x14\n" + "\x10DUPLICATE_HANDLE\x10\t\x12\x12\n" + "\x0eDUPLICATE_NAME\x10\n" + - "B\t\n" + + "\x12\x12\n" + + "\x0eINVALID_SCHEMA\x10\vB\t\n" + "\arequest\".\n" + "\x0fTrackSubscribed\x12\x1b\n" + "\ttrack_sid\x18\x01 \x01(\tR\btrackSid\"\xc2\x02\n" + @@ -5499,23 +5514,24 @@ var file_livekit_rtc_proto_goTypes = []any{ (BackupCodecPolicy)(0), // 72: livekit.BackupCodecPolicy (AudioTrackFeature)(0), // 73: livekit.AudioTrackFeature (PacketTrailerFeature)(0), // 74: livekit.PacketTrailerFeature - (*DataTrackInfo)(nil), // 75: livekit.DataTrackInfo - (*Room)(nil), // 76: livekit.Room - (*ParticipantInfo)(nil), // 77: livekit.ParticipantInfo - (*ClientConfiguration)(nil), // 78: livekit.ClientConfiguration - (*ServerInfo)(nil), // 79: livekit.ServerInfo - (*Codec)(nil), // 80: livekit.Codec - (*TrackInfo)(nil), // 81: livekit.TrackInfo - (*ParticipantTracks)(nil), // 82: livekit.ParticipantTracks - (VideoQuality)(0), // 83: livekit.VideoQuality - (DisconnectReason)(0), // 84: livekit.DisconnectReason - (*SpeakerInfo)(nil), // 85: livekit.SpeakerInfo - (ConnectionQuality)(0), // 86: livekit.ConnectionQuality - (*SubscribedAudioCodec)(nil), // 87: livekit.SubscribedAudioCodec - (SubscriptionError)(0), // 88: livekit.SubscriptionError - (*ClientInfo)(nil), // 89: livekit.ClientInfo - (ReconnectReason)(0), // 90: livekit.ReconnectReason - (*DataTrackSubscriptionOptions)(nil), // 91: livekit.DataTrackSubscriptionOptions + (*DataTrackSchema)(nil), // 75: livekit.DataTrackSchema + (*DataTrackInfo)(nil), // 76: livekit.DataTrackInfo + (*Room)(nil), // 77: livekit.Room + (*ParticipantInfo)(nil), // 78: livekit.ParticipantInfo + (*ClientConfiguration)(nil), // 79: livekit.ClientConfiguration + (*ServerInfo)(nil), // 80: livekit.ServerInfo + (*Codec)(nil), // 81: livekit.Codec + (*TrackInfo)(nil), // 82: livekit.TrackInfo + (*ParticipantTracks)(nil), // 83: livekit.ParticipantTracks + (VideoQuality)(0), // 84: livekit.VideoQuality + (DisconnectReason)(0), // 85: livekit.DisconnectReason + (*SpeakerInfo)(nil), // 86: livekit.SpeakerInfo + (ConnectionQuality)(0), // 87: livekit.ConnectionQuality + (*SubscribedAudioCodec)(nil), // 88: livekit.SubscribedAudioCodec + (SubscriptionError)(0), // 89: livekit.SubscriptionError + (*ClientInfo)(nil), // 90: livekit.ClientInfo + (ReconnectReason)(0), // 91: livekit.ReconnectReason + (*DataTrackSubscriptionOptions)(nil), // 92: livekit.DataTrackSubscriptionOptions } var file_livekit_rtc_proto_depIdxs = []int32{ 21, // 0: livekit.SignalRequest.offer:type_name -> livekit.SessionDescription @@ -5574,82 +5590,83 @@ var file_livekit_rtc_proto_depIdxs = []int32{ 73, // 53: livekit.AddTrackRequest.audio_features:type_name -> livekit.AudioTrackFeature 74, // 54: livekit.AddTrackRequest.packet_trailer_features:type_name -> livekit.PacketTrailerFeature 71, // 55: livekit.PublishDataTrackRequest.encryption:type_name -> livekit.Encryption.Type - 75, // 56: livekit.PublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo - 75, // 57: livekit.UnpublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo - 62, // 58: livekit.DataTrackSubscriberHandles.sub_handles:type_name -> livekit.DataTrackSubscriberHandles.SubHandlesEntry - 0, // 59: livekit.TrickleRequest.target:type_name -> livekit.SignalTarget - 76, // 60: livekit.JoinResponse.room:type_name -> livekit.Room - 77, // 61: livekit.JoinResponse.participant:type_name -> livekit.ParticipantInfo - 77, // 62: livekit.JoinResponse.other_participants:type_name -> livekit.ParticipantInfo - 31, // 63: livekit.JoinResponse.ice_servers:type_name -> livekit.ICEServer - 78, // 64: livekit.JoinResponse.client_configuration:type_name -> livekit.ClientConfiguration - 79, // 65: livekit.JoinResponse.server_info:type_name -> livekit.ServerInfo - 80, // 66: livekit.JoinResponse.enabled_publish_codecs:type_name -> livekit.Codec - 31, // 67: livekit.ReconnectResponse.ice_servers:type_name -> livekit.ICEServer - 78, // 68: livekit.ReconnectResponse.client_configuration:type_name -> livekit.ClientConfiguration - 79, // 69: livekit.ReconnectResponse.server_info:type_name -> livekit.ServerInfo - 81, // 70: livekit.TrackPublishedResponse.track:type_name -> livekit.TrackInfo - 63, // 71: livekit.SessionDescription.mid_to_track_id:type_name -> livekit.SessionDescription.MidToTrackIdEntry - 77, // 72: livekit.ParticipantUpdate.participants:type_name -> livekit.ParticipantInfo - 82, // 73: livekit.UpdateSubscription.participant_tracks:type_name -> livekit.ParticipantTracks - 64, // 74: livekit.UpdateDataSubscription.updates:type_name -> livekit.UpdateDataSubscription.Update - 83, // 75: livekit.UpdateTrackSettings.quality:type_name -> livekit.VideoQuality - 73, // 76: livekit.UpdateLocalAudioTrack.features:type_name -> livekit.AudioTrackFeature - 84, // 77: livekit.LeaveRequest.reason:type_name -> livekit.DisconnectReason - 3, // 78: livekit.LeaveRequest.action:type_name -> livekit.LeaveRequest.Action - 52, // 79: livekit.LeaveRequest.regions:type_name -> livekit.RegionSettings - 67, // 80: livekit.UpdateVideoLayers.layers:type_name -> livekit.VideoLayer - 65, // 81: livekit.UpdateParticipantMetadata.attributes:type_name -> livekit.UpdateParticipantMetadata.AttributesEntry - 85, // 82: livekit.SpeakersChanged.speakers:type_name -> livekit.SpeakerInfo - 76, // 83: livekit.RoomUpdate.room:type_name -> livekit.Room - 86, // 84: livekit.ConnectionQualityInfo.quality:type_name -> livekit.ConnectionQuality - 34, // 85: livekit.ConnectionQualityUpdate.updates:type_name -> livekit.ConnectionQualityInfo - 1, // 86: livekit.StreamStateInfo.state:type_name -> livekit.StreamState - 36, // 87: livekit.StreamStateUpdate.stream_states:type_name -> livekit.StreamStateInfo - 83, // 88: livekit.SubscribedQuality.quality:type_name -> livekit.VideoQuality - 38, // 89: livekit.SubscribedCodec.qualities:type_name -> livekit.SubscribedQuality - 38, // 90: livekit.SubscribedQualityUpdate.subscribed_qualities:type_name -> livekit.SubscribedQuality - 39, // 91: livekit.SubscribedQualityUpdate.subscribed_codecs:type_name -> livekit.SubscribedCodec - 87, // 92: livekit.SubscribedAudioCodecUpdate.subscribed_audio_codecs:type_name -> livekit.SubscribedAudioCodec - 42, // 93: livekit.SubscriptionPermission.track_permissions:type_name -> livekit.TrackPermission - 76, // 94: livekit.RoomMovedResponse.room:type_name -> livekit.Room - 77, // 95: livekit.RoomMovedResponse.participant:type_name -> livekit.ParticipantInfo - 77, // 96: livekit.RoomMovedResponse.other_participants:type_name -> livekit.ParticipantInfo - 21, // 97: livekit.SyncState.answer:type_name -> livekit.SessionDescription - 23, // 98: livekit.SyncState.subscription:type_name -> livekit.UpdateSubscription - 19, // 99: livekit.SyncState.publish_tracks:type_name -> livekit.TrackPublishedResponse - 48, // 100: livekit.SyncState.data_channels:type_name -> livekit.DataChannelInfo - 21, // 101: livekit.SyncState.offer:type_name -> livekit.SessionDescription - 47, // 102: livekit.SyncState.datachannel_receive_states:type_name -> livekit.DataChannelReceiveState - 11, // 103: livekit.SyncState.publish_data_tracks:type_name -> livekit.PublishDataTrackResponse - 0, // 104: livekit.DataChannelInfo.target:type_name -> livekit.SignalTarget - 2, // 105: livekit.SimulateScenario.switch_candidate_protocol:type_name -> livekit.CandidateProtocol - 53, // 106: livekit.RegionSettings.regions:type_name -> livekit.RegionInfo - 88, // 107: livekit.SubscriptionResponse.err:type_name -> livekit.SubscriptionError - 4, // 108: livekit.RequestResponse.reason:type_name -> livekit.RequestResponse.Reason - 15, // 109: livekit.RequestResponse.trickle:type_name -> livekit.TrickleRequest - 9, // 110: livekit.RequestResponse.add_track:type_name -> livekit.AddTrackRequest - 16, // 111: livekit.RequestResponse.mute:type_name -> livekit.MuteTrackRequest - 30, // 112: livekit.RequestResponse.update_metadata:type_name -> livekit.UpdateParticipantMetadata - 26, // 113: livekit.RequestResponse.update_audio_track:type_name -> livekit.UpdateLocalAudioTrack - 27, // 114: livekit.RequestResponse.update_video_track:type_name -> livekit.UpdateLocalVideoTrack - 10, // 115: livekit.RequestResponse.publish_data_track:type_name -> livekit.PublishDataTrackRequest - 12, // 116: livekit.RequestResponse.unpublish_data_track:type_name -> livekit.UnpublishDataTrackRequest - 89, // 117: livekit.JoinRequest.client_info:type_name -> livekit.ClientInfo - 57, // 118: livekit.JoinRequest.connection_settings:type_name -> livekit.ConnectionSettings - 66, // 119: livekit.JoinRequest.participant_attributes:type_name -> livekit.JoinRequest.ParticipantAttributesEntry - 9, // 120: livekit.JoinRequest.add_track_requests:type_name -> livekit.AddTrackRequest - 21, // 121: livekit.JoinRequest.publisher_offer:type_name -> livekit.SessionDescription - 90, // 122: livekit.JoinRequest.reconnect_reason:type_name -> livekit.ReconnectReason - 46, // 123: livekit.JoinRequest.sync_state:type_name -> livekit.SyncState - 5, // 124: livekit.WrappedJoinRequest.compression:type_name -> livekit.WrappedJoinRequest.Compression - 61, // 125: livekit.DataTrackSubscriberHandles.SubHandlesEntry.value:type_name -> livekit.DataTrackSubscriberHandles.PublishedDataTrack - 91, // 126: livekit.UpdateDataSubscription.Update.options:type_name -> livekit.DataTrackSubscriptionOptions - 127, // [127:127] is the sub-list for method output_type - 127, // [127:127] is the sub-list for method input_type - 127, // [127:127] is the sub-list for extension type_name - 127, // [127:127] is the sub-list for extension extendee - 0, // [0:127] is the sub-list for field type_name + 75, // 56: livekit.PublishDataTrackRequest.schema:type_name -> livekit.DataTrackSchema + 76, // 57: livekit.PublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo + 76, // 58: livekit.UnpublishDataTrackResponse.info:type_name -> livekit.DataTrackInfo + 62, // 59: livekit.DataTrackSubscriberHandles.sub_handles:type_name -> livekit.DataTrackSubscriberHandles.SubHandlesEntry + 0, // 60: livekit.TrickleRequest.target:type_name -> livekit.SignalTarget + 77, // 61: livekit.JoinResponse.room:type_name -> livekit.Room + 78, // 62: livekit.JoinResponse.participant:type_name -> livekit.ParticipantInfo + 78, // 63: livekit.JoinResponse.other_participants:type_name -> livekit.ParticipantInfo + 31, // 64: livekit.JoinResponse.ice_servers:type_name -> livekit.ICEServer + 79, // 65: livekit.JoinResponse.client_configuration:type_name -> livekit.ClientConfiguration + 80, // 66: livekit.JoinResponse.server_info:type_name -> livekit.ServerInfo + 81, // 67: livekit.JoinResponse.enabled_publish_codecs:type_name -> livekit.Codec + 31, // 68: livekit.ReconnectResponse.ice_servers:type_name -> livekit.ICEServer + 79, // 69: livekit.ReconnectResponse.client_configuration:type_name -> livekit.ClientConfiguration + 80, // 70: livekit.ReconnectResponse.server_info:type_name -> livekit.ServerInfo + 82, // 71: livekit.TrackPublishedResponse.track:type_name -> livekit.TrackInfo + 63, // 72: livekit.SessionDescription.mid_to_track_id:type_name -> livekit.SessionDescription.MidToTrackIdEntry + 78, // 73: livekit.ParticipantUpdate.participants:type_name -> livekit.ParticipantInfo + 83, // 74: livekit.UpdateSubscription.participant_tracks:type_name -> livekit.ParticipantTracks + 64, // 75: livekit.UpdateDataSubscription.updates:type_name -> livekit.UpdateDataSubscription.Update + 84, // 76: livekit.UpdateTrackSettings.quality:type_name -> livekit.VideoQuality + 73, // 77: livekit.UpdateLocalAudioTrack.features:type_name -> livekit.AudioTrackFeature + 85, // 78: livekit.LeaveRequest.reason:type_name -> livekit.DisconnectReason + 3, // 79: livekit.LeaveRequest.action:type_name -> livekit.LeaveRequest.Action + 52, // 80: livekit.LeaveRequest.regions:type_name -> livekit.RegionSettings + 67, // 81: livekit.UpdateVideoLayers.layers:type_name -> livekit.VideoLayer + 65, // 82: livekit.UpdateParticipantMetadata.attributes:type_name -> livekit.UpdateParticipantMetadata.AttributesEntry + 86, // 83: livekit.SpeakersChanged.speakers:type_name -> livekit.SpeakerInfo + 77, // 84: livekit.RoomUpdate.room:type_name -> livekit.Room + 87, // 85: livekit.ConnectionQualityInfo.quality:type_name -> livekit.ConnectionQuality + 34, // 86: livekit.ConnectionQualityUpdate.updates:type_name -> livekit.ConnectionQualityInfo + 1, // 87: livekit.StreamStateInfo.state:type_name -> livekit.StreamState + 36, // 88: livekit.StreamStateUpdate.stream_states:type_name -> livekit.StreamStateInfo + 84, // 89: livekit.SubscribedQuality.quality:type_name -> livekit.VideoQuality + 38, // 90: livekit.SubscribedCodec.qualities:type_name -> livekit.SubscribedQuality + 38, // 91: livekit.SubscribedQualityUpdate.subscribed_qualities:type_name -> livekit.SubscribedQuality + 39, // 92: livekit.SubscribedQualityUpdate.subscribed_codecs:type_name -> livekit.SubscribedCodec + 88, // 93: livekit.SubscribedAudioCodecUpdate.subscribed_audio_codecs:type_name -> livekit.SubscribedAudioCodec + 42, // 94: livekit.SubscriptionPermission.track_permissions:type_name -> livekit.TrackPermission + 77, // 95: livekit.RoomMovedResponse.room:type_name -> livekit.Room + 78, // 96: livekit.RoomMovedResponse.participant:type_name -> livekit.ParticipantInfo + 78, // 97: livekit.RoomMovedResponse.other_participants:type_name -> livekit.ParticipantInfo + 21, // 98: livekit.SyncState.answer:type_name -> livekit.SessionDescription + 23, // 99: livekit.SyncState.subscription:type_name -> livekit.UpdateSubscription + 19, // 100: livekit.SyncState.publish_tracks:type_name -> livekit.TrackPublishedResponse + 48, // 101: livekit.SyncState.data_channels:type_name -> livekit.DataChannelInfo + 21, // 102: livekit.SyncState.offer:type_name -> livekit.SessionDescription + 47, // 103: livekit.SyncState.datachannel_receive_states:type_name -> livekit.DataChannelReceiveState + 11, // 104: livekit.SyncState.publish_data_tracks:type_name -> livekit.PublishDataTrackResponse + 0, // 105: livekit.DataChannelInfo.target:type_name -> livekit.SignalTarget + 2, // 106: livekit.SimulateScenario.switch_candidate_protocol:type_name -> livekit.CandidateProtocol + 53, // 107: livekit.RegionSettings.regions:type_name -> livekit.RegionInfo + 89, // 108: livekit.SubscriptionResponse.err:type_name -> livekit.SubscriptionError + 4, // 109: livekit.RequestResponse.reason:type_name -> livekit.RequestResponse.Reason + 15, // 110: livekit.RequestResponse.trickle:type_name -> livekit.TrickleRequest + 9, // 111: livekit.RequestResponse.add_track:type_name -> livekit.AddTrackRequest + 16, // 112: livekit.RequestResponse.mute:type_name -> livekit.MuteTrackRequest + 30, // 113: livekit.RequestResponse.update_metadata:type_name -> livekit.UpdateParticipantMetadata + 26, // 114: livekit.RequestResponse.update_audio_track:type_name -> livekit.UpdateLocalAudioTrack + 27, // 115: livekit.RequestResponse.update_video_track:type_name -> livekit.UpdateLocalVideoTrack + 10, // 116: livekit.RequestResponse.publish_data_track:type_name -> livekit.PublishDataTrackRequest + 12, // 117: livekit.RequestResponse.unpublish_data_track:type_name -> livekit.UnpublishDataTrackRequest + 90, // 118: livekit.JoinRequest.client_info:type_name -> livekit.ClientInfo + 57, // 119: livekit.JoinRequest.connection_settings:type_name -> livekit.ConnectionSettings + 66, // 120: livekit.JoinRequest.participant_attributes:type_name -> livekit.JoinRequest.ParticipantAttributesEntry + 9, // 121: livekit.JoinRequest.add_track_requests:type_name -> livekit.AddTrackRequest + 21, // 122: livekit.JoinRequest.publisher_offer:type_name -> livekit.SessionDescription + 91, // 123: livekit.JoinRequest.reconnect_reason:type_name -> livekit.ReconnectReason + 46, // 124: livekit.JoinRequest.sync_state:type_name -> livekit.SyncState + 5, // 125: livekit.WrappedJoinRequest.compression:type_name -> livekit.WrappedJoinRequest.Compression + 61, // 126: livekit.DataTrackSubscriberHandles.SubHandlesEntry.value:type_name -> livekit.DataTrackSubscriberHandles.PublishedDataTrack + 92, // 127: livekit.UpdateDataSubscription.Update.options:type_name -> livekit.DataTrackSubscriptionOptions + 128, // [128:128] is the sub-list for method output_type + 128, // [128:128] is the sub-list for method input_type + 128, // [128:128] is the sub-list for extension type_name + 128, // [128:128] is the sub-list for extension extendee + 0, // [0:128] is the sub-list for field type_name } func init() { file_livekit_rtc_proto_init() } @@ -5710,6 +5727,7 @@ func file_livekit_rtc_proto_init() { (*SignalResponse_UnpublishDataTrackResponse)(nil), (*SignalResponse_DataTrackSubscriberHandles)(nil), } + file_livekit_rtc_proto_msgTypes[4].OneofWrappers = []any{} file_livekit_rtc_proto_msgTypes[43].OneofWrappers = []any{ (*SimulateScenario_SpeakerUpdate)(nil), (*SimulateScenario_NodeFailure)(nil),