Skip to content

Upgrade tonic #234

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Upgrade tonic #234

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
c7db330
Upgrade tonic
tinco Jul 28, 2025
41642ae
Update Cargo.toml
tinco Jul 28, 2025
9f43963
upgrade protos
tinco Jul 28, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ categories = ["database", "api-bindings"]
keywords = ["qdrant", "vector-search", "search-engine", "client", "grpc"]

[dependencies]
tonic = { version = "0.12.3", features = ["tls", "tls-roots", "gzip"] }
tonic = { version = "0.13.1", features = ["tls-webpki-roots", "transport", "gzip"] }
prost = "0.13.3"
prost-types = "0.13.3"
anyhow = "1.0.89"
Expand All @@ -29,7 +29,7 @@ semver = "1.0.24"
uuid = { version = "1.8.2", optional = true }

[dev-dependencies]
tonic-build = { version = "0.12.3", features = ["prost"] }
tonic-build = { version = "0.13.1", features = ["prost"] }

[features]
default = ["download_snapshots", "serde", "generate-snippets"]
Expand Down
2 changes: 1 addition & 1 deletion src/channel_pool.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ impl ChannelPool {
.expect("Version info should be a valid header value");

let endpoint = if tls {
let tls_config = ClientTlsConfig::new().with_native_roots();
let tls_config = ClientTlsConfig::new().with_enabled_roots();
endpoint
.tls_config(tls_config)
.map_err(|e| Status::internal(format!("Failed to create TLS config: {e}")))?
Expand Down
60 changes: 35 additions & 25 deletions src/qdrant.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -284,6 +284,8 @@ pub struct OptimizersConfigDiff {
#[prost(uint64, optional, tag = "3")]
pub default_segment_number: ::core::option::Option<u64>,
///
/// Deprecated:
///
/// Do not create segments larger this size (in kilobytes).
/// Large segments might require disproportionately long indexation times,
/// therefore it makes sense to limit the size of segments.
Expand Down Expand Up @@ -557,7 +559,7 @@ pub struct CreateCollection {
/// How many replicas should apply the operation for us to consider it successful, default = 1
#[prost(uint32, optional, tag = "12")]
pub write_consistency_factor: ::core::option::Option<u32>,
/// Specify name of the other collection to copy data from
/// Deprecated: specify name of the other collection to copy data from
#[prost(string, optional, tag = "13")]
pub init_from_collection: ::core::option::Option<::prost::alloc::string::String>,
/// Quantization configuration of vector
Expand Down Expand Up @@ -1721,7 +1723,7 @@ pub mod collections_client {
}
impl<T> CollectionsClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
Expand All @@ -1742,13 +1744,13 @@ pub mod collections_client {
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
CollectionsClient::new(InterceptedService::new(inner, interceptor))
Expand Down Expand Up @@ -2313,7 +2315,7 @@ pub mod collections_server {
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::BoxBody>;
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
Expand Down Expand Up @@ -2920,7 +2922,9 @@ pub mod collections_server {
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(empty_body());
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
Expand Down Expand Up @@ -5549,7 +5553,7 @@ pub mod points_client {
}
impl<T> PointsClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
Expand All @@ -5570,13 +5574,13 @@ pub mod points_client {
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
PointsClient::new(InterceptedService::new(inner, interceptor))
Expand Down Expand Up @@ -6626,7 +6630,7 @@ pub mod points_server {
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::BoxBody>;
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
Expand Down Expand Up @@ -7865,7 +7869,9 @@ pub mod points_server {
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(empty_body());
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
Expand Down Expand Up @@ -7997,7 +8003,7 @@ pub mod snapshots_client {
}
impl<T> SnapshotsClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
Expand All @@ -8018,13 +8024,13 @@ pub mod snapshots_client {
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
SnapshotsClient::new(InterceptedService::new(inner, interceptor))
Expand Down Expand Up @@ -8341,7 +8347,7 @@ pub mod snapshots_server {
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::BoxBody>;
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
Expand Down Expand Up @@ -8624,7 +8630,9 @@ pub mod snapshots_server {
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(empty_body());
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
Expand Down Expand Up @@ -8699,7 +8707,7 @@ pub mod qdrant_client {
}
impl<T> QdrantClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T: tonic::client::GrpcService<tonic::body::Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
Expand All @@ -8720,13 +8728,13 @@ pub mod qdrant_client {
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
http::Request<tonic::body::Body>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
QdrantClient::new(InterceptedService::new(inner, interceptor))
Expand Down Expand Up @@ -8873,7 +8881,7 @@ pub mod qdrant_server {
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::BoxBody>;
type Response = http::Response<tonic::body::Body>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
Expand Down Expand Up @@ -8931,7 +8939,9 @@ pub mod qdrant_server {
}
_ => {
Box::pin(async move {
let mut response = http::Response::new(empty_body());
let mut response = http::Response::new(
tonic::body::Body::default(),
);
let headers = response.headers_mut();
headers
.insert(
Expand Down