#[derive(Debug)]
pub(crate) struct Handle {
pub(crate) client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
pub(crate) conf: crate::Config,
}
#[derive(std::fmt::Debug)]
pub struct Client {
handle: std::sync::Arc<Handle>,
}
impl std::clone::Clone for Client {
fn clone(&self) -> Self {
Self {
handle: self.handle.clone(),
}
}
}
impl
From<
aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
> for Client
{
fn from(
client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
) -> Self {
Self::with_config(client, crate::Config::builder().build())
}
}
impl Client {
pub fn with_config(
client: aws_smithy_client::Client<
aws_smithy_client::erase::DynConnector,
aws_smithy_client::erase::DynMiddleware<aws_smithy_client::erase::DynConnector>,
>,
conf: crate::Config,
) -> Self {
Self {
handle: std::sync::Arc::new(Handle { client, conf }),
}
}
pub fn conf(&self) -> &crate::Config {
&self.handle.conf
}
}
impl Client {
pub fn new(sdk_config: &aws_types::sdk_config::SdkConfig) -> Self {
Self::from_conf(sdk_config.into())
}
pub fn from_conf(conf: crate::Config) -> Self {
let retry_config = conf
.retry_config()
.cloned()
.unwrap_or_else(aws_smithy_types::retry::RetryConfig::disabled);
let timeout_config = conf
.timeout_config()
.cloned()
.unwrap_or_else(aws_smithy_types::timeout::TimeoutConfig::disabled);
let sleep_impl = conf.sleep_impl();
if (retry_config.has_retry() || timeout_config.has_timeouts()) && sleep_impl.is_none() {
panic!("An async sleep implementation is required for retries or timeouts to work. \
Set the `sleep_impl` on the Config passed into this function to fix this panic.");
}
let connector = conf.http_connector().and_then(|c| {
let timeout_config = conf
.timeout_config()
.cloned()
.unwrap_or_else(aws_smithy_types::timeout::TimeoutConfig::disabled);
let connector_settings =
aws_smithy_client::http_connector::ConnectorSettings::from_timeout_config(
&timeout_config,
);
c.connector(&connector_settings, conf.sleep_impl())
});
let builder = aws_smithy_client::Builder::new();
let builder = match connector {
Some(c) => builder.connector(c),
None => {
#[cfg(any(feature = "rustls", feature = "native-tls"))]
{
builder.dyn_https_connector(
aws_smithy_client::http_connector::ConnectorSettings::from_timeout_config(
&timeout_config,
),
)
}
#[cfg(not(any(feature = "rustls", feature = "native-tls")))]
{
panic!("No HTTP connector was available. Enable the `rustls` or `native-tls` crate feature or set a connector to fix this.");
}
}
};
let mut builder = builder
.middleware(aws_smithy_client::erase::DynMiddleware::new(
crate::middleware::DefaultMiddleware::new(),
))
.reconnect_mode(retry_config.reconnect_mode())
.retry_config(retry_config.into())
.operation_timeout_config(timeout_config.into());
builder.set_sleep_impl(sleep_impl);
let client = builder.build();
Self {
handle: std::sync::Arc::new(Handle { client, conf }),
}
}
}
mod accept_match;
mod claim_game_server;
mod create_alias;
mod create_build;
mod create_fleet;
mod create_fleet_locations;
mod create_game_server_group;
mod create_game_session;
mod create_game_session_queue;
mod create_location;
mod create_matchmaking_configuration;
mod create_matchmaking_rule_set;
mod create_player_session;
mod create_player_sessions;
mod create_script;
mod create_vpc_peering_authorization;
mod create_vpc_peering_connection;
pub mod customize;
mod delete_alias;
mod delete_build;
mod delete_fleet;
mod delete_fleet_locations;
mod delete_game_server_group;
mod delete_game_session_queue;
mod delete_location;
mod delete_matchmaking_configuration;
mod delete_matchmaking_rule_set;
mod delete_scaling_policy;
mod delete_script;
mod delete_vpc_peering_authorization;
mod delete_vpc_peering_connection;
mod deregister_compute;
mod deregister_game_server;
mod describe_alias;
mod describe_build;
mod describe_compute;
mod describe_ec2_instance_limits;
mod describe_fleet_attributes;
mod describe_fleet_capacity;
mod describe_fleet_events;
mod describe_fleet_location_attributes;
mod describe_fleet_location_capacity;
mod describe_fleet_location_utilization;
mod describe_fleet_port_settings;
mod describe_fleet_utilization;
mod describe_game_server;
mod describe_game_server_group;
mod describe_game_server_instances;
mod describe_game_session_details;
mod describe_game_session_placement;
mod describe_game_session_queues;
mod describe_game_sessions;
mod describe_instances;
mod describe_matchmaking;
mod describe_matchmaking_configurations;
mod describe_matchmaking_rule_sets;
mod describe_player_sessions;
mod describe_runtime_configuration;
mod describe_scaling_policies;
mod describe_script;
mod describe_vpc_peering_authorizations;
mod describe_vpc_peering_connections;
mod get_compute_access;
mod get_compute_auth_token;
mod get_game_session_log_url;
mod get_instance_access;
mod list_aliases;
mod list_builds;
mod list_compute;
mod list_fleets;
mod list_game_server_groups;
mod list_game_servers;
mod list_locations;
mod list_scripts;
mod list_tags_for_resource;
mod put_scaling_policy;
mod register_compute;
mod register_game_server;
mod request_upload_credentials;
mod resolve_alias;
mod resume_game_server_group;
mod search_game_sessions;
mod start_fleet_actions;
mod start_game_session_placement;
mod start_match_backfill;
mod start_matchmaking;
mod stop_fleet_actions;
mod stop_game_session_placement;
mod stop_matchmaking;
mod suspend_game_server_group;
mod tag_resource;
mod untag_resource;
mod update_alias;
mod update_build;
mod update_fleet_attributes;
mod update_fleet_capacity;
mod update_fleet_port_settings;
mod update_game_server;
mod update_game_server_group;
mod update_game_session;
mod update_game_session_queue;
mod update_matchmaking_configuration;
mod update_runtime_configuration;
mod update_script;
mod validate_matchmaking_rule_set;