pub fn client(config: &AwsConfig) -> Result<Client, anyhow::Error> {
    let mut builder = aws_sdk_kinesis::config::Builder::from(config.inner());
    if let Some(endpoint) = config.endpoint() {
        builder = builder.endpoint_resolver(endpoint.clone());
    }
    let conn = util::connector()?;
    Ok(Client::from_conf_conn(builder.build(), conn))
}
/// Constructs a new AWS Kinesis client that respects the
/// [system proxy configuration](mz_http_proxy#system-proxy-configuration).
Constructs a new AWS Kinesis client that respects the
[system proxy configuration](mz_http_proxy#system-proxy-configuration).
Constructs a new AWS Kinesis client that respects the [ system proxy configuration ] ( mz_http_proxy#system - proxy - configuration ) .
pub fn client(config: &AwsConfig) -> Result<Client, anyhow::Error> {
    let mut builder = aws_sdk_kinesis::config::Builder::from(config.inner());
    if let Some(endpoint) = config.endpoint() {
        builder = builder.endpoint_resolver(endpoint.clone());
    }
    let conn = util::connector()?;
    Ok(Client::from_conf_conn(builder.build(), conn))
}
pub fn client ( config : & AwsConfig ) -> Result < Client , anyhow :: Error > { let mut builder = aws_sdk_kinesis :: config :: Builder :: from ( config . inner ( ) ) ; if let Some ( endpoint ) = config . endpoint ( ) { builder = builder . endpoint_resolver ( endpoint . clone ( ) ) ; } let conn = util :: connector ( ) ? ; Ok ( Client :: from_conf_conn ( builder . build ( ) , conn ) ) }
Constructs a new AWS Kinesis client that respects the
[system proxy configuration](mz_http_proxy#system-proxy-configuration).
Constructs a new AWS Kinesis client that respects the [ system proxy configuration ] ( mz_http_proxy#system - proxy - configuration ) .
config
&AwsConfig
config
&AwsConfig