Skip to content

Commit 6149514

Browse files
evansimsevansims
committed
ci: linter warning fixes
1 parent 28291b5 commit 6149514

File tree

1 file changed

+66
-126
lines changed

1 file changed

+66
-126
lines changed

‎src/transport/proto/inferadb.v1.rs‎

Lines changed: 66 additions & 126 deletions
Original file line numberDiff line numberDiff line change
@@ -546,10 +546,10 @@ pub mod inferadb_service_client {
546546
dead_code,
547547
missing_docs,
548548
clippy::wildcard_imports,
549-
clippy::let_unit_value,
549+
clippy::let_unit_value
550550
)]
551-
use tonic::codegen::*;
552551
use tonic::codegen::http::Uri;
552+
use tonic::codegen::*;
553553
/// The main Infera authorization service
554554
#[derive(Debug, Clone)]
555555
pub struct InferadbServiceClient<T> {
@@ -594,9 +594,8 @@ pub mod inferadb_service_client {
594594
<T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
595595
>,
596596
>,
597-
<T as tonic::codegen::Service<
598-
http::Request<tonic::body::Body>,
599-
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
597+
<T as tonic::codegen::Service<http::Request<tonic::body::Body>>>::Error:
598+
Into<StdError> + std::marker::Send + std::marker::Sync,
600599
{
601600
InferadbServiceClient::new(InterceptedService::new(inner, interceptor))
602601
}
@@ -640,18 +639,12 @@ pub mod inferadb_service_client {
640639
tonic::Response<tonic::codec::Streaming<super::EvaluateResponse>>,
641640
tonic::Status,
642641
> {
643-
self.inner
644-
.ready()
645-
.await
646-
.map_err(|e| {
647-
tonic::Status::unknown(
648-
format!("Service was not ready: {}", e.into()),
649-
)
650-
})?;
642+
self.inner.ready().await.map_err(|e| {
643+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
644+
})?;
651645
let codec = tonic_prost::ProstCodec::default();
652-
let path = http::uri::PathAndQuery::from_static(
653-
"/inferadb.v1.InferadbService/Evaluate",
654-
);
646+
let path =
647+
http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/Evaluate");
655648
let mut req = request.into_streaming_request();
656649
req.extensions_mut()
657650
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "Evaluate"));
@@ -665,18 +658,11 @@ pub mod inferadb_service_client {
665658
tonic::Response<tonic::codec::Streaming<super::ExpandResponse>>,
666659
tonic::Status,
667660
> {
668-
self.inner
669-
.ready()
670-
.await
671-
.map_err(|e| {
672-
tonic::Status::unknown(
673-
format!("Service was not ready: {}", e.into()),
674-
)
675-
})?;
661+
self.inner.ready().await.map_err(|e| {
662+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
663+
})?;
676664
let codec = tonic_prost::ProstCodec::default();
677-
let path = http::uri::PathAndQuery::from_static(
678-
"/inferadb.v1.InferadbService/Expand",
679-
);
665+
let path = http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/Expand");
680666
let mut req = request.into_request();
681667
req.extensions_mut()
682668
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "Expand"));
@@ -687,66 +673,49 @@ pub mod inferadb_service_client {
687673
&mut self,
688674
request: impl tonic::IntoStreamingRequest<Message = super::WriteRequest>,
689675
) -> std::result::Result<tonic::Response<super::WriteResponse>, tonic::Status> {
690-
self.inner
691-
.ready()
692-
.await
693-
.map_err(|e| {
694-
tonic::Status::unknown(
695-
format!("Service was not ready: {}", e.into()),
696-
)
697-
})?;
676+
self.inner.ready().await.map_err(|e| {
677+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
678+
})?;
698679
let codec = tonic_prost::ProstCodec::default();
699680
let path = http::uri::PathAndQuery::from_static(
700681
"/inferadb.v1.InferadbService/WriteRelationships",
701682
);
702683
let mut req = request.into_streaming_request();
703-
req.extensions_mut()
704-
.insert(
705-
GrpcMethod::new("inferadb.v1.InferadbService", "WriteRelationships"),
706-
);
684+
req.extensions_mut().insert(GrpcMethod::new(
685+
"inferadb.v1.InferadbService",
686+
"WriteRelationships",
687+
));
707688
self.inner.client_streaming(req, path, codec).await
708689
}
709690
/// Delete relationships from the store
710691
pub async fn delete_relationships(
711692
&mut self,
712693
request: impl tonic::IntoStreamingRequest<Message = super::DeleteRequest>,
713694
) -> std::result::Result<tonic::Response<super::DeleteResponse>, tonic::Status> {
714-
self.inner
715-
.ready()
716-
.await
717-
.map_err(|e| {
718-
tonic::Status::unknown(
719-
format!("Service was not ready: {}", e.into()),
720-
)
721-
})?;
695+
self.inner.ready().await.map_err(|e| {
696+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
697+
})?;
722698
let codec = tonic_prost::ProstCodec::default();
723699
let path = http::uri::PathAndQuery::from_static(
724700
"/inferadb.v1.InferadbService/DeleteRelationships",
725701
);
726702
let mut req = request.into_streaming_request();
727-
req.extensions_mut()
728-
.insert(
729-
GrpcMethod::new("inferadb.v1.InferadbService", "DeleteRelationships"),
730-
);
703+
req.extensions_mut().insert(GrpcMethod::new(
704+
"inferadb.v1.InferadbService",
705+
"DeleteRelationships",
706+
));
731707
self.inner.client_streaming(req, path, codec).await
732708
}
733709
/// Health check
734710
pub async fn health(
735711
&mut self,
736712
request: impl tonic::IntoRequest<super::HealthRequest>,
737713
) -> std::result::Result<tonic::Response<super::HealthResponse>, tonic::Status> {
738-
self.inner
739-
.ready()
740-
.await
741-
.map_err(|e| {
742-
tonic::Status::unknown(
743-
format!("Service was not ready: {}", e.into()),
744-
)
745-
})?;
714+
self.inner.ready().await.map_err(|e| {
715+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
716+
})?;
746717
let codec = tonic_prost::ProstCodec::default();
747-
let path = http::uri::PathAndQuery::from_static(
748-
"/inferadb.v1.InferadbService/Health",
749-
);
718+
let path = http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/Health");
750719
let mut req = request.into_request();
751720
req.extensions_mut()
752721
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "Health"));
@@ -760,21 +729,17 @@ pub mod inferadb_service_client {
760729
tonic::Response<tonic::codec::Streaming<super::ListResourcesResponse>>,
761730
tonic::Status,
762731
> {
763-
self.inner
764-
.ready()
765-
.await
766-
.map_err(|e| {
767-
tonic::Status::unknown(
768-
format!("Service was not ready: {}", e.into()),
769-
)
770-
})?;
732+
self.inner.ready().await.map_err(|e| {
733+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
734+
})?;
771735
let codec = tonic_prost::ProstCodec::default();
772-
let path = http::uri::PathAndQuery::from_static(
773-
"/inferadb.v1.InferadbService/ListResources",
774-
);
736+
let path =
737+
http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/ListResources");
775738
let mut req = request.into_request();
776-
req.extensions_mut()
777-
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "ListResources"));
739+
req.extensions_mut().insert(GrpcMethod::new(
740+
"inferadb.v1.InferadbService",
741+
"ListResources",
742+
));
778743
self.inner.server_streaming(req, path, codec).await
779744
}
780745
/// List relationships (relationships) with optional filtering
@@ -785,23 +750,18 @@ pub mod inferadb_service_client {
785750
tonic::Response<tonic::codec::Streaming<super::ListRelationshipsResponse>>,
786751
tonic::Status,
787752
> {
788-
self.inner
789-
.ready()
790-
.await
791-
.map_err(|e| {
792-
tonic::Status::unknown(
793-
format!("Service was not ready: {}", e.into()),
794-
)
795-
})?;
753+
self.inner.ready().await.map_err(|e| {
754+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
755+
})?;
796756
let codec = tonic_prost::ProstCodec::default();
797757
let path = http::uri::PathAndQuery::from_static(
798758
"/inferadb.v1.InferadbService/ListRelationships",
799759
);
800760
let mut req = request.into_request();
801-
req.extensions_mut()
802-
.insert(
803-
GrpcMethod::new("inferadb.v1.InferadbService", "ListRelationships"),
804-
);
761+
req.extensions_mut().insert(GrpcMethod::new(
762+
"inferadb.v1.InferadbService",
763+
"ListRelationships",
764+
));
805765
self.inner.server_streaming(req, path, codec).await
806766
}
807767
/// List subjects that have a specific relation to a resource
@@ -812,21 +772,17 @@ pub mod inferadb_service_client {
812772
tonic::Response<tonic::codec::Streaming<super::ListSubjectsResponse>>,
813773
tonic::Status,
814774
> {
815-
self.inner
816-
.ready()
817-
.await
818-
.map_err(|e| {
819-
tonic::Status::unknown(
820-
format!("Service was not ready: {}", e.into()),
821-
)
822-
})?;
775+
self.inner.ready().await.map_err(|e| {
776+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
777+
})?;
823778
let codec = tonic_prost::ProstCodec::default();
824-
let path = http::uri::PathAndQuery::from_static(
825-
"/inferadb.v1.InferadbService/ListSubjects",
826-
);
779+
let path =
780+
http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/ListSubjects");
827781
let mut req = request.into_request();
828-
req.extensions_mut()
829-
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "ListSubjects"));
782+
req.extensions_mut().insert(GrpcMethod::new(
783+
"inferadb.v1.InferadbService",
784+
"ListSubjects",
785+
));
830786
self.inner.server_streaming(req, path, codec).await
831787
}
832788
/// Watch for real-time relationship changes
@@ -837,18 +793,11 @@ pub mod inferadb_service_client {
837793
tonic::Response<tonic::codec::Streaming<super::WatchResponse>>,
838794
tonic::Status,
839795
> {
840-
self.inner
841-
.ready()
842-
.await
843-
.map_err(|e| {
844-
tonic::Status::unknown(
845-
format!("Service was not ready: {}", e.into()),
846-
)
847-
})?;
796+
self.inner.ready().await.map_err(|e| {
797+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
798+
})?;
848799
let codec = tonic_prost::ProstCodec::default();
849-
let path = http::uri::PathAndQuery::from_static(
850-
"/inferadb.v1.InferadbService/Watch",
851-
);
800+
let path = http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/Watch");
852801
let mut req = request.into_request();
853802
req.extensions_mut()
854803
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "Watch"));
@@ -858,22 +807,13 @@ pub mod inferadb_service_client {
858807
pub async fn simulate(
859808
&mut self,
860809
request: impl tonic::IntoRequest<super::SimulateRequest>,
861-
) -> std::result::Result<
862-
tonic::Response<super::SimulateResponse>,
863-
tonic::Status,
864-
> {
865-
self.inner
866-
.ready()
867-
.await
868-
.map_err(|e| {
869-
tonic::Status::unknown(
870-
format!("Service was not ready: {}", e.into()),
871-
)
872-
})?;
810+
) -> std::result::Result<tonic::Response<super::SimulateResponse>, tonic::Status> {
811+
self.inner.ready().await.map_err(|e| {
812+
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
813+
})?;
873814
let codec = tonic_prost::ProstCodec::default();
874-
let path = http::uri::PathAndQuery::from_static(
875-
"/inferadb.v1.InferadbService/Simulate",
876-
);
815+
let path =
816+
http::uri::PathAndQuery::from_static("/inferadb.v1.InferadbService/Simulate");
877817
let mut req = request.into_request();
878818
req.extensions_mut()
879819
.insert(GrpcMethod::new("inferadb.v1.InferadbService", "Simulate"));

0 commit comments

Comments
 (0)