generated protobuf

Author: github-actions[bot]

livekit-protocol/src/livekit.rs

@@ -946,6 +946,9 @@ pub struct RpcRequest {
     pub response_timeout_ms: u32,
     #[prost(uint32, tag="5")]
     pub version: u32,
+    /// Compressed payload data. When set, this field is used instead of `payload`.
+    #[prost(bytes="vec", tag="6")]
+    pub compressed_payload: ::prost::alloc::vec::Vec<u8>,
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -958,7 +961,7 @@ pub struct RpcAck {
 pub struct RpcResponse {
     #[prost(string, tag="1")]
     pub request_id: ::prost::alloc::string::String,
-    #[prost(oneof="rpc_response::Value", tags="2, 3")]
+    #[prost(oneof="rpc_response::Value", tags="2, 3, 4")]
     pub value: ::core::option::Option<rpc_response::Value>,
 }
 /// Nested message and enum types in `RpcResponse`.
@@ -970,6 +973,9 @@ pub mod rpc_response {
         Payload(::prost::alloc::string::String),
         #[prost(message, tag="3")]
         Error(super::RpcError),
+        /// Compressed payload data. When set, this field is used instead of `payload`.
+        #[prost(bytes, tag="4")]
+        CompressedPayload(::prost::alloc::vec::Vec<u8>),
     }
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
@@ -2635,9 +2641,11 @@ pub struct EgressInfo {
     pub image_results: ::prost::alloc::vec::Vec<ImagesInfo>,
     #[prost(string, tag="23")]
     pub manifest_location: ::prost::alloc::string::String,
-    /// next ID: 27
     #[prost(bool, tag="25")]
     pub backup_storage_used: bool,
+    /// next ID: 28
+    #[prost(int32, tag="27")]
+    pub retry_count: i32,
     #[prost(oneof="egress_info::Request", tags="4, 14, 19, 5, 6")]
     pub request: ::core::option::Option<egress_info::Request>,
     /// deprecated (use _result fields)
@@ -4247,7 +4255,7 @@ pub struct JobState {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct WorkerMessage {
-    #[prost(oneof="worker_message::Message", tags="1, 2, 3, 4, 5, 6, 7, 8, 9")]
+    #[prost(oneof="worker_message::Message", tags="1, 2, 3, 4, 5, 6, 7")]
     pub message: ::core::option::Option<worker_message::Message>,
 }
 /// Nested message and enum types in `WorkerMessage`.
@@ -4273,17 +4281,13 @@ pub mod worker_message {
         SimulateJob(super::SimulateJobRequest),
         #[prost(message, tag="7")]
         MigrateJob(super::MigrateJobRequest),
-        #[prost(message, tag="8")]
-        TextResponse(super::TextMessageResponse),
-        #[prost(message, tag="9")]
-        PushText(super::PushTextRequest),
     }
 }
 /// from Server to Worker
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct ServerMessage {
-    #[prost(oneof="server_message::Message", tags="1, 2, 3, 5, 4, 6")]
+    #[prost(oneof="server_message::Message", tags="1, 2, 3, 5, 4")]
     pub message: ::core::option::Option<server_message::Message>,
 }
 /// Nested message and enum types in `ServerMessage`.
@@ -4303,8 +4307,6 @@ pub mod server_message {
         Termination(super::JobTermination),
         #[prost(message, tag="4")]
         Pong(super::WorkerPong),
-        #[prost(message, tag="6")]
-        TextRequest(super::TextMessageRequest),
     }
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
@@ -4434,61 +4436,6 @@ pub struct JobTermination {
     #[prost(string, tag="1")]
     pub job_id: ::prost::alloc::string::String,
 }
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct AgentSessionState {
-    #[prost(uint64, tag="1")]
-    pub version: u64,
-    #[prost(oneof="agent_session_state::Data", tags="2, 3")]
-    pub data: ::core::option::Option<agent_session_state::Data>,
-}
-/// Nested message and enum types in `AgentSessionState`.
-pub mod agent_session_state {
-    #[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Oneof)]
-    pub enum Data {
-        #[prost(bytes, tag="2")]
-        Snapshot(::prost::alloc::vec::Vec<u8>),
-        #[prost(bytes, tag="3")]
-        Delta(::prost::alloc::vec::Vec<u8>),
-    }
-}
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct TextMessageRequest {
-    #[prost(string, tag="1")]
-    pub message_id: ::prost::alloc::string::String,
-    #[prost(string, tag="2")]
-    pub session_id: ::prost::alloc::string::String,
-    #[prost(string, tag="3")]
-    pub agent_name: ::prost::alloc::string::String,
-    #[prost(string, tag="4")]
-    pub metadata: ::prost::alloc::string::String,
-    #[prost(message, optional, tag="5")]
-    pub session_state: ::core::option::Option<AgentSessionState>,
-    #[prost(string, tag="6")]
-    pub text: ::prost::alloc::string::String,
-}
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct PushTextRequest {
-    /// The message_id of the TextMessageRequest that this push is for
-    #[prost(string, tag="1")]
-    pub message_id: ::prost::alloc::string::String,
-    #[prost(string, tag="2")]
-    pub content: ::prost::alloc::string::String,
-}
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct TextMessageResponse {
-    /// Indicate the request is completed
-    #[prost(string, tag="1")]
-    pub message_id: ::prost::alloc::string::String,
-    #[prost(message, optional, tag="2")]
-    pub session_state: ::core::option::Option<AgentSessionState>,
-    #[prost(string, tag="3")]
-    pub error: ::prost::alloc::string::String,
-}
 #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
 #[repr(i32)]
 pub enum JobType {
@@ -5831,6 +5778,9 @@ pub struct SipDispatchRuleIndividual {
     /// Optional pin required to enter room
     #[prost(string, tag="2")]
     pub pin: ::prost::alloc::string::String,
+    /// Optionally append random suffix
+    #[prost(bool, tag="3")]
+    pub no_randomness: bool,
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]