1#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
4pub struct OperationMetadata {
5 #[prost(message, optional, tag = "1")]
7 pub create_time: ::core::option::Option<::prost_types::Timestamp>,
8 #[prost(message, optional, tag = "2")]
10 pub end_time: ::core::option::Option<::prost_types::Timestamp>,
11 #[prost(string, tag = "3")]
13 pub target: ::prost::alloc::string::String,
14 #[prost(string, tag = "4")]
16 pub verb: ::prost::alloc::string::String,
17 #[prost(string, tag = "5")]
19 pub status_message: ::prost::alloc::string::String,
20 #[prost(bool, tag = "6")]
26 pub requested_cancellation: bool,
27 #[prost(string, tag = "7")]
29 pub api_version: ::prost::alloc::string::String,
30}
31#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
33pub struct RunWorkflowCustomOperationMetadata {
34 #[prost(message, optional, tag = "1")]
36 pub create_time: ::core::option::Option<::prost_types::Timestamp>,
37 #[prost(message, optional, tag = "2")]
39 pub end_time: ::core::option::Option<::prost_types::Timestamp>,
40 #[prost(string, tag = "3")]
42 pub verb: ::prost::alloc::string::String,
43 #[prost(bool, tag = "4")]
49 pub requested_cancellation: bool,
50 #[prost(string, tag = "5")]
52 pub api_version: ::prost::alloc::string::String,
53 #[prost(string, tag = "6")]
55 pub target: ::prost::alloc::string::String,
56 #[prost(string, tag = "7")]
58 pub pipeline_run_id: ::prost::alloc::string::String,
59}
60#[derive(Clone, PartialEq, ::prost::Message)]
63pub struct Connection {
64 #[prost(string, tag = "1")]
67 pub name: ::prost::alloc::string::String,
68 #[prost(message, optional, tag = "3")]
70 pub create_time: ::core::option::Option<::prost_types::Timestamp>,
71 #[prost(message, optional, tag = "4")]
73 pub update_time: ::core::option::Option<::prost_types::Timestamp>,
74 #[prost(message, optional, tag = "12")]
76 pub installation_state: ::core::option::Option<InstallationState>,
77 #[prost(bool, tag = "13")]
81 pub disabled: bool,
82 #[prost(bool, tag = "14")]
85 pub reconciling: bool,
86 #[prost(map = "string, string", tag = "15")]
88 pub annotations: ::std::collections::HashMap<
89 ::prost::alloc::string::String,
90 ::prost::alloc::string::String,
91 >,
92 #[prost(string, tag = "16")]
96 pub etag: ::prost::alloc::string::String,
97 #[prost(oneof = "connection::ConnectionConfig", tags = "5, 6, 7, 8, 9")]
99 pub connection_config: ::core::option::Option<connection::ConnectionConfig>,
100}
101pub mod connection {
103 #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
105 pub enum ConnectionConfig {
106 #[prost(message, tag = "5")]
108 GithubConfig(super::GitHubConfig),
109 #[prost(message, tag = "6")]
111 GithubEnterpriseConfig(super::GitHubEnterpriseConfig),
112 #[prost(message, tag = "7")]
115 GitlabConfig(super::GitLabConfig),
116 #[prost(message, tag = "8")]
118 BitbucketDataCenterConfig(super::BitbucketDataCenterConfig),
119 #[prost(message, tag = "9")]
121 BitbucketCloudConfig(super::BitbucketCloudConfig),
122 }
123}
124#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
128pub struct InstallationState {
129 #[prost(enumeration = "installation_state::Stage", tag = "1")]
131 pub stage: i32,
132 #[prost(string, tag = "2")]
135 pub message: ::prost::alloc::string::String,
136 #[prost(string, tag = "3")]
139 pub action_uri: ::prost::alloc::string::String,
140}
141pub mod installation_state {
143 #[derive(
145 Clone,
146 Copy,
147 Debug,
148 PartialEq,
149 Eq,
150 Hash,
151 PartialOrd,
152 Ord,
153 ::prost::Enumeration
154 )]
155 #[repr(i32)]
156 pub enum Stage {
157 Unspecified = 0,
159 PendingCreateApp = 1,
162 PendingUserOauth = 2,
164 PendingInstallApp = 3,
166 Complete = 10,
168 }
169 impl Stage {
170 pub fn as_str_name(&self) -> &'static str {
175 match self {
176 Self::Unspecified => "STAGE_UNSPECIFIED",
177 Self::PendingCreateApp => "PENDING_CREATE_APP",
178 Self::PendingUserOauth => "PENDING_USER_OAUTH",
179 Self::PendingInstallApp => "PENDING_INSTALL_APP",
180 Self::Complete => "COMPLETE",
181 }
182 }
183 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
185 match value {
186 "STAGE_UNSPECIFIED" => Some(Self::Unspecified),
187 "PENDING_CREATE_APP" => Some(Self::PendingCreateApp),
188 "PENDING_USER_OAUTH" => Some(Self::PendingUserOauth),
189 "PENDING_INSTALL_APP" => Some(Self::PendingInstallApp),
190 "COMPLETE" => Some(Self::Complete),
191 _ => None,
192 }
193 }
194 }
195}
196#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
198pub struct FetchLinkableRepositoriesRequest {
199 #[prost(string, tag = "1")]
202 pub connection: ::prost::alloc::string::String,
203 #[prost(int32, tag = "2")]
205 pub page_size: i32,
206 #[prost(string, tag = "3")]
208 pub page_token: ::prost::alloc::string::String,
209}
210#[derive(Clone, PartialEq, ::prost::Message)]
212pub struct FetchLinkableRepositoriesResponse {
213 #[prost(message, repeated, tag = "1")]
215 pub repositories: ::prost::alloc::vec::Vec<Repository>,
216 #[prost(string, tag = "2")]
218 pub next_page_token: ::prost::alloc::string::String,
219}
220#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
222pub struct GitHubConfig {
223 #[prost(message, optional, tag = "1")]
227 pub authorizer_credential: ::core::option::Option<OAuthCredential>,
228 #[prost(int64, tag = "2")]
230 pub app_installation_id: i64,
231}
232#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
234pub struct GitHubEnterpriseConfig {
235 #[prost(string, tag = "1")]
237 pub host_uri: ::prost::alloc::string::String,
238 #[prost(string, tag = "12")]
240 pub api_key: ::prost::alloc::string::String,
241 #[prost(int64, tag = "2")]
243 pub app_id: i64,
244 #[prost(string, tag = "13")]
246 pub app_slug: ::prost::alloc::string::String,
247 #[prost(string, tag = "4")]
250 pub private_key_secret_version: ::prost::alloc::string::String,
251 #[prost(string, tag = "5")]
254 pub webhook_secret_secret_version: ::prost::alloc::string::String,
255 #[prost(int64, tag = "9")]
257 pub app_installation_id: i64,
258 #[prost(message, optional, tag = "10")]
264 pub service_directory_config: ::core::option::Option<ServiceDirectoryConfig>,
265 #[prost(string, tag = "11")]
267 pub ssl_ca: ::prost::alloc::string::String,
268 #[prost(string, tag = "14")]
270 pub server_version: ::prost::alloc::string::String,
271}
272#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
275pub struct GitLabConfig {
276 #[prost(string, tag = "1")]
279 pub host_uri: ::prost::alloc::string::String,
280 #[prost(string, tag = "2")]
284 pub webhook_secret_secret_version: ::prost::alloc::string::String,
285 #[prost(message, optional, tag = "3")]
288 pub read_authorizer_credential: ::core::option::Option<UserCredential>,
289 #[prost(message, optional, tag = "4")]
291 pub authorizer_credential: ::core::option::Option<UserCredential>,
292 #[prost(message, optional, tag = "5")]
298 pub service_directory_config: ::core::option::Option<ServiceDirectoryConfig>,
299 #[prost(string, tag = "6")]
301 pub ssl_ca: ::prost::alloc::string::String,
302 #[prost(string, tag = "7")]
305 pub server_version: ::prost::alloc::string::String,
306}
307#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
309pub struct BitbucketDataCenterConfig {
310 #[prost(string, tag = "1")]
313 pub host_uri: ::prost::alloc::string::String,
314 #[prost(string, tag = "2")]
318 pub webhook_secret_secret_version: ::prost::alloc::string::String,
319 #[prost(message, optional, tag = "3")]
321 pub read_authorizer_credential: ::core::option::Option<UserCredential>,
322 #[prost(message, optional, tag = "4")]
324 pub authorizer_credential: ::core::option::Option<UserCredential>,
325 #[prost(message, optional, tag = "5")]
331 pub service_directory_config: ::core::option::Option<ServiceDirectoryConfig>,
332 #[prost(string, tag = "6")]
334 pub ssl_ca: ::prost::alloc::string::String,
335 #[prost(string, tag = "7")]
338 pub server_version: ::prost::alloc::string::String,
339}
340#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
342pub struct BitbucketCloudConfig {
343 #[prost(string, tag = "1")]
346 pub workspace: ::prost::alloc::string::String,
347 #[prost(string, tag = "2")]
350 pub webhook_secret_secret_version: ::prost::alloc::string::String,
351 #[prost(message, optional, tag = "3")]
355 pub read_authorizer_credential: ::core::option::Option<UserCredential>,
356 #[prost(message, optional, tag = "4")]
361 pub authorizer_credential: ::core::option::Option<UserCredential>,
362}
363#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
366pub struct ServiceDirectoryConfig {
367 #[prost(string, tag = "1")]
371 pub service: ::prost::alloc::string::String,
372}
373#[derive(Clone, PartialEq, ::prost::Message)]
375pub struct Repository {
376 #[prost(string, tag = "1")]
379 pub name: ::prost::alloc::string::String,
380 #[prost(string, tag = "2")]
382 pub remote_uri: ::prost::alloc::string::String,
383 #[prost(message, optional, tag = "4")]
385 pub create_time: ::core::option::Option<::prost_types::Timestamp>,
386 #[prost(message, optional, tag = "5")]
388 pub update_time: ::core::option::Option<::prost_types::Timestamp>,
389 #[prost(map = "string, string", tag = "6")]
391 pub annotations: ::std::collections::HashMap<
392 ::prost::alloc::string::String,
393 ::prost::alloc::string::String,
394 >,
395 #[prost(string, tag = "7")]
399 pub etag: ::prost::alloc::string::String,
400 #[prost(string, tag = "8")]
402 pub webhook_id: ::prost::alloc::string::String,
403}
404#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
407pub struct OAuthCredential {
408 #[prost(string, tag = "1")]
411 pub oauth_token_secret_version: ::prost::alloc::string::String,
412 #[prost(string, tag = "2")]
414 pub username: ::prost::alloc::string::String,
415}
416#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
419pub struct UserCredential {
420 #[prost(string, tag = "1")]
424 pub user_token_secret_version: ::prost::alloc::string::String,
425 #[prost(string, tag = "2")]
427 pub username: ::prost::alloc::string::String,
428}
429#[derive(Clone, PartialEq, ::prost::Message)]
431pub struct CreateConnectionRequest {
432 #[prost(string, tag = "1")]
435 pub parent: ::prost::alloc::string::String,
436 #[prost(message, optional, tag = "2")]
438 pub connection: ::core::option::Option<Connection>,
439 #[prost(string, tag = "3")]
444 pub connection_id: ::prost::alloc::string::String,
445}
446#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
448pub struct GetConnectionRequest {
449 #[prost(string, tag = "1")]
452 pub name: ::prost::alloc::string::String,
453}
454#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
456pub struct ListConnectionsRequest {
457 #[prost(string, tag = "1")]
460 pub parent: ::prost::alloc::string::String,
461 #[prost(int32, tag = "2")]
463 pub page_size: i32,
464 #[prost(string, tag = "3")]
466 pub page_token: ::prost::alloc::string::String,
467}
468#[derive(Clone, PartialEq, ::prost::Message)]
470pub struct ListConnectionsResponse {
471 #[prost(message, repeated, tag = "1")]
473 pub connections: ::prost::alloc::vec::Vec<Connection>,
474 #[prost(string, tag = "2")]
476 pub next_page_token: ::prost::alloc::string::String,
477}
478#[derive(Clone, PartialEq, ::prost::Message)]
480pub struct UpdateConnectionRequest {
481 #[prost(message, optional, tag = "1")]
483 pub connection: ::core::option::Option<Connection>,
484 #[prost(message, optional, tag = "2")]
486 pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
487 #[prost(bool, tag = "3")]
493 pub allow_missing: bool,
494 #[prost(string, tag = "4")]
498 pub etag: ::prost::alloc::string::String,
499}
500#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
502pub struct DeleteConnectionRequest {
503 #[prost(string, tag = "1")]
506 pub name: ::prost::alloc::string::String,
507 #[prost(string, tag = "2")]
511 pub etag: ::prost::alloc::string::String,
512 #[prost(bool, tag = "3")]
514 pub validate_only: bool,
515}
516#[derive(Clone, PartialEq, ::prost::Message)]
518pub struct CreateRepositoryRequest {
519 #[prost(string, tag = "1")]
523 pub parent: ::prost::alloc::string::String,
524 #[prost(message, optional, tag = "2")]
526 pub repository: ::core::option::Option<Repository>,
527 #[prost(string, tag = "3")]
532 pub repository_id: ::prost::alloc::string::String,
533}
534#[derive(Clone, PartialEq, ::prost::Message)]
536pub struct BatchCreateRepositoriesRequest {
537 #[prost(string, tag = "1")]
542 pub parent: ::prost::alloc::string::String,
543 #[prost(message, repeated, tag = "2")]
545 pub requests: ::prost::alloc::vec::Vec<CreateRepositoryRequest>,
546}
547#[derive(Clone, PartialEq, ::prost::Message)]
549pub struct BatchCreateRepositoriesResponse {
550 #[prost(message, repeated, tag = "1")]
552 pub repositories: ::prost::alloc::vec::Vec<Repository>,
553}
554#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
556pub struct GetRepositoryRequest {
557 #[prost(string, tag = "1")]
560 pub name: ::prost::alloc::string::String,
561}
562#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
564pub struct ListRepositoriesRequest {
565 #[prost(string, tag = "1")]
568 pub parent: ::prost::alloc::string::String,
569 #[prost(int32, tag = "2")]
571 pub page_size: i32,
572 #[prost(string, tag = "3")]
574 pub page_token: ::prost::alloc::string::String,
575 #[prost(string, tag = "4")]
580 pub filter: ::prost::alloc::string::String,
581}
582#[derive(Clone, PartialEq, ::prost::Message)]
584pub struct ListRepositoriesResponse {
585 #[prost(message, repeated, tag = "1")]
587 pub repositories: ::prost::alloc::vec::Vec<Repository>,
588 #[prost(string, tag = "2")]
590 pub next_page_token: ::prost::alloc::string::String,
591}
592#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
594pub struct DeleteRepositoryRequest {
595 #[prost(string, tag = "1")]
598 pub name: ::prost::alloc::string::String,
599 #[prost(string, tag = "2")]
603 pub etag: ::prost::alloc::string::String,
604 #[prost(bool, tag = "3")]
606 pub validate_only: bool,
607}
608#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
610pub struct FetchReadWriteTokenRequest {
611 #[prost(string, tag = "1")]
614 pub repository: ::prost::alloc::string::String,
615}
616#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
618pub struct FetchReadTokenRequest {
619 #[prost(string, tag = "1")]
622 pub repository: ::prost::alloc::string::String,
623}
624#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
626pub struct FetchReadTokenResponse {
627 #[prost(string, tag = "1")]
629 pub token: ::prost::alloc::string::String,
630 #[prost(message, optional, tag = "2")]
632 pub expiration_time: ::core::option::Option<::prost_types::Timestamp>,
633}
634#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
636pub struct FetchReadWriteTokenResponse {
637 #[prost(string, tag = "1")]
639 pub token: ::prost::alloc::string::String,
640 #[prost(message, optional, tag = "2")]
642 pub expiration_time: ::core::option::Option<::prost_types::Timestamp>,
643}
644#[derive(Clone, PartialEq, ::prost::Message)]
646pub struct ProcessWebhookRequest {
647 #[prost(string, tag = "1")]
650 pub parent: ::prost::alloc::string::String,
651 #[prost(message, optional, tag = "2")]
653 pub body: ::core::option::Option<super::super::super::api::HttpBody>,
654 #[prost(string, tag = "3")]
657 pub webhook_key: ::prost::alloc::string::String,
658}
659#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
661pub struct FetchGitRefsRequest {
662 #[prost(string, tag = "1")]
665 pub repository: ::prost::alloc::string::String,
666 #[prost(enumeration = "fetch_git_refs_request::RefType", tag = "2")]
668 pub ref_type: i32,
669}
670pub mod fetch_git_refs_request {
672 #[derive(
674 Clone,
675 Copy,
676 Debug,
677 PartialEq,
678 Eq,
679 Hash,
680 PartialOrd,
681 Ord,
682 ::prost::Enumeration
683 )]
684 #[repr(i32)]
685 pub enum RefType {
686 Unspecified = 0,
688 Tag = 1,
690 Branch = 2,
692 }
693 impl RefType {
694 pub fn as_str_name(&self) -> &'static str {
699 match self {
700 Self::Unspecified => "REF_TYPE_UNSPECIFIED",
701 Self::Tag => "TAG",
702 Self::Branch => "BRANCH",
703 }
704 }
705 pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
707 match value {
708 "REF_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
709 "TAG" => Some(Self::Tag),
710 "BRANCH" => Some(Self::Branch),
711 _ => None,
712 }
713 }
714 }
715}
716#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
718pub struct FetchGitRefsResponse {
719 #[prost(string, repeated, tag = "1")]
721 pub ref_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
722}
723pub mod repository_manager_client {
725 #![allow(
726 unused_variables,
727 dead_code,
728 missing_docs,
729 clippy::wildcard_imports,
730 clippy::let_unit_value,
731 )]
732 use tonic::codegen::*;
733 use tonic::codegen::http::Uri;
734 #[derive(Debug, Clone)]
736 pub struct RepositoryManagerClient<T> {
737 inner: tonic::client::Grpc<T>,
738 }
739 impl<T> RepositoryManagerClient<T>
740 where
741 T: tonic::client::GrpcService<tonic::body::Body>,
742 T::Error: Into<StdError>,
743 T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
744 <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
745 {
746 pub fn new(inner: T) -> Self {
747 let inner = tonic::client::Grpc::new(inner);
748 Self { inner }
749 }
750 pub fn with_origin(inner: T, origin: Uri) -> Self {
751 let inner = tonic::client::Grpc::with_origin(inner, origin);
752 Self { inner }
753 }
754 pub fn with_interceptor<F>(
755 inner: T,
756 interceptor: F,
757 ) -> RepositoryManagerClient<InterceptedService<T, F>>
758 where
759 F: tonic::service::Interceptor,
760 T::ResponseBody: Default,
761 T: tonic::codegen::Service<
762 http::Request<tonic::body::Body>,
763 Response = http::Response<
764 <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
765 >,
766 >,
767 <T as tonic::codegen::Service<
768 http::Request<tonic::body::Body>,
769 >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
770 {
771 RepositoryManagerClient::new(InterceptedService::new(inner, interceptor))
772 }
773 #[must_use]
778 pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
779 self.inner = self.inner.send_compressed(encoding);
780 self
781 }
782 #[must_use]
784 pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
785 self.inner = self.inner.accept_compressed(encoding);
786 self
787 }
788 #[must_use]
792 pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
793 self.inner = self.inner.max_decoding_message_size(limit);
794 self
795 }
796 #[must_use]
800 pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
801 self.inner = self.inner.max_encoding_message_size(limit);
802 self
803 }
804 pub async fn create_connection(
806 &mut self,
807 request: impl tonic::IntoRequest<super::CreateConnectionRequest>,
808 ) -> std::result::Result<
809 tonic::Response<super::super::super::super::longrunning::Operation>,
810 tonic::Status,
811 > {
812 self.inner
813 .ready()
814 .await
815 .map_err(|e| {
816 tonic::Status::unknown(
817 format!("Service was not ready: {}", e.into()),
818 )
819 })?;
820 let codec = tonic_prost::ProstCodec::default();
821 let path = http::uri::PathAndQuery::from_static(
822 "/google.devtools.cloudbuild.v2.RepositoryManager/CreateConnection",
823 );
824 let mut req = request.into_request();
825 req.extensions_mut()
826 .insert(
827 GrpcMethod::new(
828 "google.devtools.cloudbuild.v2.RepositoryManager",
829 "CreateConnection",
830 ),
831 );
832 self.inner.unary(req, path, codec).await
833 }
834 pub async fn get_connection(
836 &mut self,
837 request: impl tonic::IntoRequest<super::GetConnectionRequest>,
838 ) -> std::result::Result<tonic::Response<super::Connection>, tonic::Status> {
839 self.inner
840 .ready()
841 .await
842 .map_err(|e| {
843 tonic::Status::unknown(
844 format!("Service was not ready: {}", e.into()),
845 )
846 })?;
847 let codec = tonic_prost::ProstCodec::default();
848 let path = http::uri::PathAndQuery::from_static(
849 "/google.devtools.cloudbuild.v2.RepositoryManager/GetConnection",
850 );
851 let mut req = request.into_request();
852 req.extensions_mut()
853 .insert(
854 GrpcMethod::new(
855 "google.devtools.cloudbuild.v2.RepositoryManager",
856 "GetConnection",
857 ),
858 );
859 self.inner.unary(req, path, codec).await
860 }
861 pub async fn list_connections(
863 &mut self,
864 request: impl tonic::IntoRequest<super::ListConnectionsRequest>,
865 ) -> std::result::Result<
866 tonic::Response<super::ListConnectionsResponse>,
867 tonic::Status,
868 > {
869 self.inner
870 .ready()
871 .await
872 .map_err(|e| {
873 tonic::Status::unknown(
874 format!("Service was not ready: {}", e.into()),
875 )
876 })?;
877 let codec = tonic_prost::ProstCodec::default();
878 let path = http::uri::PathAndQuery::from_static(
879 "/google.devtools.cloudbuild.v2.RepositoryManager/ListConnections",
880 );
881 let mut req = request.into_request();
882 req.extensions_mut()
883 .insert(
884 GrpcMethod::new(
885 "google.devtools.cloudbuild.v2.RepositoryManager",
886 "ListConnections",
887 ),
888 );
889 self.inner.unary(req, path, codec).await
890 }
891 pub async fn update_connection(
893 &mut self,
894 request: impl tonic::IntoRequest<super::UpdateConnectionRequest>,
895 ) -> std::result::Result<
896 tonic::Response<super::super::super::super::longrunning::Operation>,
897 tonic::Status,
898 > {
899 self.inner
900 .ready()
901 .await
902 .map_err(|e| {
903 tonic::Status::unknown(
904 format!("Service was not ready: {}", e.into()),
905 )
906 })?;
907 let codec = tonic_prost::ProstCodec::default();
908 let path = http::uri::PathAndQuery::from_static(
909 "/google.devtools.cloudbuild.v2.RepositoryManager/UpdateConnection",
910 );
911 let mut req = request.into_request();
912 req.extensions_mut()
913 .insert(
914 GrpcMethod::new(
915 "google.devtools.cloudbuild.v2.RepositoryManager",
916 "UpdateConnection",
917 ),
918 );
919 self.inner.unary(req, path, codec).await
920 }
921 pub async fn delete_connection(
923 &mut self,
924 request: impl tonic::IntoRequest<super::DeleteConnectionRequest>,
925 ) -> std::result::Result<
926 tonic::Response<super::super::super::super::longrunning::Operation>,
927 tonic::Status,
928 > {
929 self.inner
930 .ready()
931 .await
932 .map_err(|e| {
933 tonic::Status::unknown(
934 format!("Service was not ready: {}", e.into()),
935 )
936 })?;
937 let codec = tonic_prost::ProstCodec::default();
938 let path = http::uri::PathAndQuery::from_static(
939 "/google.devtools.cloudbuild.v2.RepositoryManager/DeleteConnection",
940 );
941 let mut req = request.into_request();
942 req.extensions_mut()
943 .insert(
944 GrpcMethod::new(
945 "google.devtools.cloudbuild.v2.RepositoryManager",
946 "DeleteConnection",
947 ),
948 );
949 self.inner.unary(req, path, codec).await
950 }
951 pub async fn create_repository(
953 &mut self,
954 request: impl tonic::IntoRequest<super::CreateRepositoryRequest>,
955 ) -> std::result::Result<
956 tonic::Response<super::super::super::super::longrunning::Operation>,
957 tonic::Status,
958 > {
959 self.inner
960 .ready()
961 .await
962 .map_err(|e| {
963 tonic::Status::unknown(
964 format!("Service was not ready: {}", e.into()),
965 )
966 })?;
967 let codec = tonic_prost::ProstCodec::default();
968 let path = http::uri::PathAndQuery::from_static(
969 "/google.devtools.cloudbuild.v2.RepositoryManager/CreateRepository",
970 );
971 let mut req = request.into_request();
972 req.extensions_mut()
973 .insert(
974 GrpcMethod::new(
975 "google.devtools.cloudbuild.v2.RepositoryManager",
976 "CreateRepository",
977 ),
978 );
979 self.inner.unary(req, path, codec).await
980 }
981 pub async fn batch_create_repositories(
983 &mut self,
984 request: impl tonic::IntoRequest<super::BatchCreateRepositoriesRequest>,
985 ) -> std::result::Result<
986 tonic::Response<super::super::super::super::longrunning::Operation>,
987 tonic::Status,
988 > {
989 self.inner
990 .ready()
991 .await
992 .map_err(|e| {
993 tonic::Status::unknown(
994 format!("Service was not ready: {}", e.into()),
995 )
996 })?;
997 let codec = tonic_prost::ProstCodec::default();
998 let path = http::uri::PathAndQuery::from_static(
999 "/google.devtools.cloudbuild.v2.RepositoryManager/BatchCreateRepositories",
1000 );
1001 let mut req = request.into_request();
1002 req.extensions_mut()
1003 .insert(
1004 GrpcMethod::new(
1005 "google.devtools.cloudbuild.v2.RepositoryManager",
1006 "BatchCreateRepositories",
1007 ),
1008 );
1009 self.inner.unary(req, path, codec).await
1010 }
1011 pub async fn get_repository(
1013 &mut self,
1014 request: impl tonic::IntoRequest<super::GetRepositoryRequest>,
1015 ) -> std::result::Result<tonic::Response<super::Repository>, tonic::Status> {
1016 self.inner
1017 .ready()
1018 .await
1019 .map_err(|e| {
1020 tonic::Status::unknown(
1021 format!("Service was not ready: {}", e.into()),
1022 )
1023 })?;
1024 let codec = tonic_prost::ProstCodec::default();
1025 let path = http::uri::PathAndQuery::from_static(
1026 "/google.devtools.cloudbuild.v2.RepositoryManager/GetRepository",
1027 );
1028 let mut req = request.into_request();
1029 req.extensions_mut()
1030 .insert(
1031 GrpcMethod::new(
1032 "google.devtools.cloudbuild.v2.RepositoryManager",
1033 "GetRepository",
1034 ),
1035 );
1036 self.inner.unary(req, path, codec).await
1037 }
1038 pub async fn list_repositories(
1040 &mut self,
1041 request: impl tonic::IntoRequest<super::ListRepositoriesRequest>,
1042 ) -> std::result::Result<
1043 tonic::Response<super::ListRepositoriesResponse>,
1044 tonic::Status,
1045 > {
1046 self.inner
1047 .ready()
1048 .await
1049 .map_err(|e| {
1050 tonic::Status::unknown(
1051 format!("Service was not ready: {}", e.into()),
1052 )
1053 })?;
1054 let codec = tonic_prost::ProstCodec::default();
1055 let path = http::uri::PathAndQuery::from_static(
1056 "/google.devtools.cloudbuild.v2.RepositoryManager/ListRepositories",
1057 );
1058 let mut req = request.into_request();
1059 req.extensions_mut()
1060 .insert(
1061 GrpcMethod::new(
1062 "google.devtools.cloudbuild.v2.RepositoryManager",
1063 "ListRepositories",
1064 ),
1065 );
1066 self.inner.unary(req, path, codec).await
1067 }
1068 pub async fn delete_repository(
1070 &mut self,
1071 request: impl tonic::IntoRequest<super::DeleteRepositoryRequest>,
1072 ) -> std::result::Result<
1073 tonic::Response<super::super::super::super::longrunning::Operation>,
1074 tonic::Status,
1075 > {
1076 self.inner
1077 .ready()
1078 .await
1079 .map_err(|e| {
1080 tonic::Status::unknown(
1081 format!("Service was not ready: {}", e.into()),
1082 )
1083 })?;
1084 let codec = tonic_prost::ProstCodec::default();
1085 let path = http::uri::PathAndQuery::from_static(
1086 "/google.devtools.cloudbuild.v2.RepositoryManager/DeleteRepository",
1087 );
1088 let mut req = request.into_request();
1089 req.extensions_mut()
1090 .insert(
1091 GrpcMethod::new(
1092 "google.devtools.cloudbuild.v2.RepositoryManager",
1093 "DeleteRepository",
1094 ),
1095 );
1096 self.inner.unary(req, path, codec).await
1097 }
1098 pub async fn fetch_read_write_token(
1100 &mut self,
1101 request: impl tonic::IntoRequest<super::FetchReadWriteTokenRequest>,
1102 ) -> std::result::Result<
1103 tonic::Response<super::FetchReadWriteTokenResponse>,
1104 tonic::Status,
1105 > {
1106 self.inner
1107 .ready()
1108 .await
1109 .map_err(|e| {
1110 tonic::Status::unknown(
1111 format!("Service was not ready: {}", e.into()),
1112 )
1113 })?;
1114 let codec = tonic_prost::ProstCodec::default();
1115 let path = http::uri::PathAndQuery::from_static(
1116 "/google.devtools.cloudbuild.v2.RepositoryManager/FetchReadWriteToken",
1117 );
1118 let mut req = request.into_request();
1119 req.extensions_mut()
1120 .insert(
1121 GrpcMethod::new(
1122 "google.devtools.cloudbuild.v2.RepositoryManager",
1123 "FetchReadWriteToken",
1124 ),
1125 );
1126 self.inner.unary(req, path, codec).await
1127 }
1128 pub async fn fetch_read_token(
1130 &mut self,
1131 request: impl tonic::IntoRequest<super::FetchReadTokenRequest>,
1132 ) -> std::result::Result<
1133 tonic::Response<super::FetchReadTokenResponse>,
1134 tonic::Status,
1135 > {
1136 self.inner
1137 .ready()
1138 .await
1139 .map_err(|e| {
1140 tonic::Status::unknown(
1141 format!("Service was not ready: {}", e.into()),
1142 )
1143 })?;
1144 let codec = tonic_prost::ProstCodec::default();
1145 let path = http::uri::PathAndQuery::from_static(
1146 "/google.devtools.cloudbuild.v2.RepositoryManager/FetchReadToken",
1147 );
1148 let mut req = request.into_request();
1149 req.extensions_mut()
1150 .insert(
1151 GrpcMethod::new(
1152 "google.devtools.cloudbuild.v2.RepositoryManager",
1153 "FetchReadToken",
1154 ),
1155 );
1156 self.inner.unary(req, path, codec).await
1157 }
1158 pub async fn fetch_linkable_repositories(
1161 &mut self,
1162 request: impl tonic::IntoRequest<super::FetchLinkableRepositoriesRequest>,
1163 ) -> std::result::Result<
1164 tonic::Response<super::FetchLinkableRepositoriesResponse>,
1165 tonic::Status,
1166 > {
1167 self.inner
1168 .ready()
1169 .await
1170 .map_err(|e| {
1171 tonic::Status::unknown(
1172 format!("Service was not ready: {}", e.into()),
1173 )
1174 })?;
1175 let codec = tonic_prost::ProstCodec::default();
1176 let path = http::uri::PathAndQuery::from_static(
1177 "/google.devtools.cloudbuild.v2.RepositoryManager/FetchLinkableRepositories",
1178 );
1179 let mut req = request.into_request();
1180 req.extensions_mut()
1181 .insert(
1182 GrpcMethod::new(
1183 "google.devtools.cloudbuild.v2.RepositoryManager",
1184 "FetchLinkableRepositories",
1185 ),
1186 );
1187 self.inner.unary(req, path, codec).await
1188 }
1189 pub async fn fetch_git_refs(
1191 &mut self,
1192 request: impl tonic::IntoRequest<super::FetchGitRefsRequest>,
1193 ) -> std::result::Result<
1194 tonic::Response<super::FetchGitRefsResponse>,
1195 tonic::Status,
1196 > {
1197 self.inner
1198 .ready()
1199 .await
1200 .map_err(|e| {
1201 tonic::Status::unknown(
1202 format!("Service was not ready: {}", e.into()),
1203 )
1204 })?;
1205 let codec = tonic_prost::ProstCodec::default();
1206 let path = http::uri::PathAndQuery::from_static(
1207 "/google.devtools.cloudbuild.v2.RepositoryManager/FetchGitRefs",
1208 );
1209 let mut req = request.into_request();
1210 req.extensions_mut()
1211 .insert(
1212 GrpcMethod::new(
1213 "google.devtools.cloudbuild.v2.RepositoryManager",
1214 "FetchGitRefs",
1215 ),
1216 );
1217 self.inner.unary(req, path, codec).await
1218 }
1219 }
1220}