#![allow(rustdoc::broken_intra_doc_links)]
use gax::error::Error;
use std::sync::Arc;
pub(crate) mod dynamic;
pub trait Connectors: std::fmt::Debug + Send + Sync {
fn list_connections(
&self,
_req: crate::model::ListConnectionsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::ListConnectionsResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListConnectionsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_connection(
&self,
_req: crate::model::GetConnectionRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::Connection>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::Connection>>>(Err(
Error::other("unimplemented"),
))
}
fn create_connection(
&self,
_req: crate::model::CreateConnectionRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<longrunning::model::Operation>>>(
Err(Error::other("unimplemented")),
)
}
fn update_connection(
&self,
_req: crate::model::UpdateConnectionRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<longrunning::model::Operation>>>(
Err(Error::other("unimplemented")),
)
}
fn delete_connection(
&self,
_req: crate::model::DeleteConnectionRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<longrunning::model::Operation>>>(
Err(Error::other("unimplemented")),
)
}
fn list_providers(
&self,
_req: crate::model::ListProvidersRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::ListProvidersResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListProvidersResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_provider(
&self,
_req: crate::model::GetProviderRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::Provider>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::Provider>>>(Err(
Error::other("unimplemented"),
))
}
fn list_connectors(
&self,
_req: crate::model::ListConnectorsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::ListConnectorsResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListConnectorsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_connector(
&self,
_req: crate::model::GetConnectorRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::Connector>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::Connector>>>(Err(
Error::other("unimplemented"),
))
}
fn list_connector_versions(
&self,
_req: crate::model::ListConnectorVersionsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<
gax::response::Response<crate::model::ListConnectorVersionsResponse>,
>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListConnectorVersionsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_connector_version(
&self,
_req: crate::model::GetConnectorVersionRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::ConnectorVersion>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::ConnectorVersion>>>(
Err(Error::other("unimplemented")),
)
}
fn get_connection_schema_metadata(
&self,
_req: crate::model::GetConnectionSchemaMetadataRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::ConnectionSchemaMetadata>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ConnectionSchemaMetadata>>,
>(Err(Error::other("unimplemented")))
}
fn refresh_connection_schema_metadata(
&self,
_req: crate::model::RefreshConnectionSchemaMetadataRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<longrunning::model::Operation>>>(
Err(Error::other("unimplemented")),
)
}
fn list_runtime_entity_schemas(
&self,
_req: crate::model::ListRuntimeEntitySchemasRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<
gax::response::Response<crate::model::ListRuntimeEntitySchemasResponse>,
>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListRuntimeEntitySchemasResponse>>,
>(Err(Error::other("unimplemented")))
}
fn list_runtime_action_schemas(
&self,
_req: crate::model::ListRuntimeActionSchemasRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<
gax::response::Response<crate::model::ListRuntimeActionSchemasResponse>,
>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<crate::model::ListRuntimeActionSchemasResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_runtime_config(
&self,
_req: crate::model::GetRuntimeConfigRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::RuntimeConfig>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::RuntimeConfig>>>(
Err(Error::other("unimplemented")),
)
}
fn get_global_settings(
&self,
_req: crate::model::GetGlobalSettingsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<crate::model::Settings>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<crate::model::Settings>>>(Err(
Error::other("unimplemented"),
))
}
fn list_locations(
&self,
_req: location::model::ListLocationsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<location::model::ListLocationsResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<location::model::ListLocationsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_location(
&self,
_req: location::model::GetLocationRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<location::model::Location>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<location::model::Location>>>(
Err(Error::other("unimplemented")),
)
}
fn set_iam_policy(
&self,
_req: iam_v1::model::SetIamPolicyRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<iam_v1::model::Policy>>>(Err(
Error::other("unimplemented"),
))
}
fn get_iam_policy(
&self,
_req: iam_v1::model::GetIamPolicyRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<iam_v1::model::Policy>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<iam_v1::model::Policy>>>(Err(
Error::other("unimplemented"),
))
}
fn test_iam_permissions(
&self,
_req: iam_v1::model::TestIamPermissionsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<iam_v1::model::TestIamPermissionsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn list_operations(
&self,
_req: longrunning::model::ListOperationsRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
> + Send {
std::future::ready::<
crate::Result<gax::response::Response<longrunning::model::ListOperationsResponse>>,
>(Err(Error::other("unimplemented")))
}
fn get_operation(
&self,
_req: longrunning::model::GetOperationRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<
Output = crate::Result<gax::response::Response<longrunning::model::Operation>>,
> + Send {
std::future::ready::<crate::Result<gax::response::Response<longrunning::model::Operation>>>(
Err(Error::other("unimplemented")),
)
}
fn delete_operation(
&self,
_req: longrunning::model::DeleteOperationRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
std::future::ready::<crate::Result<gax::response::Response<()>>>(Err(Error::other(
"unimplemented",
)))
}
fn cancel_operation(
&self,
_req: longrunning::model::CancelOperationRequest,
_options: gax::options::RequestOptions,
) -> impl std::future::Future<Output = crate::Result<gax::response::Response<()>>> + Send {
std::future::ready::<crate::Result<gax::response::Response<()>>>(Err(Error::other(
"unimplemented",
)))
}
fn get_polling_error_policy(
&self,
_options: &gax::options::RequestOptions,
) -> Arc<dyn gax::polling_error_policy::PollingErrorPolicy> {
Arc::new(gax::polling_error_policy::Aip194Strict)
}
fn get_polling_backoff_policy(
&self,
_options: &gax::options::RequestOptions,
) -> Arc<dyn gax::polling_backoff_policy::PollingBackoffPolicy> {
Arc::new(gax::exponential_backoff::ExponentialBackoff::default())
}
}