AWS SDK

[[bench]]

name = "async_instruments"

harness = false

[package]

name = "aws-smithy-observability-otel"

version = "0.1.3"

authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>"]

description = "Smithy OpenTelemetry observability implementation."

edition = "2021"

license = "Apache-2.0"

repository = "https://github.com/awslabs/smithy-rs"

rust-version = "1.88"

[package.metadata.docs.rs]

all-features = true

targets = ["x86_64-unknown-linux-gnu"]

cargo-args = ["-Zunstable-options", "-Zrustdoc-scrape-examples"]

rustdoc-args = ["--cfg", "docsrs"]

features = ["async_tokio"]

}

/// An OpenTelemetry based implementation of the AWS SDK's [ProvideMeter] trait

#[non_exhaustive]

#[derive(Debug)]

pub struct OtelMeterProvider {

    meter_provider: OtelSdkMeterProvider,

}

impl OtelMeterProvider {

    /// Create a new [OtelMeterProvider] from an [OtelSdkMeterProvider].

    pub fn new(otel_meter_provider: OtelSdkMeterProvider) -> Self {

        Self {

            meter_provider: otel_meter_provider,

        }

    }

    /// Flush the metric pipeline.

    pub fn flush(&self) -> Result<(), ObservabilityError> {

        match self.meter_provider.force_flush() {

        data::{Gauge, Histogram, Sum},

        PeriodicReader, SdkMeterProvider,

    };

    use opentelemetry_sdk::runtime::Tokio;

    use opentelemetry_sdk::testing::metrics::InMemoryMetricsExporter;

    use super::OtelMeterProvider;

    // Without these tokio settings this test just stalls forever on flushing the metrics pipeline

    #[tokio::test(flavor = "multi_thread", worker_threads = 1)]

    async fn sync_instruments_work() {

        // Create the OTel metrics objects

        let exporter = InMemoryMetricsExporter::default();

        let reader = PeriodicReader::builder(exporter.clone(), Tokio).build();

        let otel_mp = SdkMeterProvider::builder().with_reader(reader).build();

        // Create the SDK metrics types from the OTel objects

        let sdk_mp = Arc::new(OtelMeterProvider::new(otel_mp));

        let sdk_ref = sdk_mp.clone();

        let sdk_tp = TelemetryProvider::builder().meter_provider(sdk_mp).build();

/*

 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.

 * SPDX-License-Identifier: Apache-2.0

 */

//! Metrics are used to gain insight into the operational performance and health of a system in

//! real time.

use crate::instruments::{

    pub fn new(instrument_provider: Arc<dyn ProvideInstrument + Send + Sync>) -> Self {

        Meter {

            instrument_provider,

        }

    }

    /// Create a new Gauge.

    #[allow(clippy::type_complexity)]

    pub fn create_gauge<F>(

        &self,

        name: impl Into<Cow<'static, str>>,

        callback: F,

    ) -> AsyncInstrumentBuilder<'_, Arc<dyn AsyncMeasure<Value = f64>>, f64>

    where

        F: Fn(&dyn AsyncMeasure<Value = f64>) + Send + Sync + 'static,

    {

        AsyncInstrumentBuilder::new(self, name.into(), Arc::new(callback))

    }

    /// Create a new [UpDownCounter].

/*

 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.

 * SPDX-License-Identifier: Apache-2.0

 */

//! An noop implementation of the Meter traits

use std::marker::PhantomData;

use std::{fmt::Debug, sync::Arc};

use crate::instruments::{

    AsyncInstrumentBuilder, AsyncMeasure, Histogram, InstrumentBuilder, MonotonicCounter,

    ProvideInstrument, UpDownCounter,

};

use crate::{

    attributes::Attributes,

    }

    fn create_up_down_counter(

        &self,

        _builder: InstrumentBuilder<'_, Arc<dyn UpDownCounter>>,

    ) -> Arc<dyn UpDownCounter> {

        Arc::new(NoopUpDownCounter)

    }

    fn create_async_up_down_counter(

        &self,

        _builder: AsyncInstrumentBuilder<'_, Arc<dyn AsyncMeasure<Value = i64>>, i64>,

    ) -> Arc<dyn AsyncMeasure<Value = i64>> {

        Arc::new(NoopAsyncMeasurement(PhantomData::<i64>))

    }

    fn create_monotonic_counter(

        &self,

        _builder: InstrumentBuilder<'_, Arc<dyn MonotonicCounter>>,

    ) -> Arc<dyn MonotonicCounter> {

/*

 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.

 * SPDX-License-Identifier: Apache-2.0

 */

use aws_smithy_types::config_bag::{Storable, StoreAppend};

#[non_exhaustive]

#[derive(Clone, Debug, Eq, PartialEq)]

pub enum SmithySdkFeature {

    Waiter,

    Paginator,

    GzipRequestCompression,

    ProtocolRpcV2Cbor,

    RetryModeStandard,

# Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

[package]

name = "aws-sdk-bedrockruntime"

version = "0.0.0-local"

authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]

description = "AWS SDK for Amazon Bedrock Runtime"

edition = "2021"

license = "Apache-2.0"

repository = "https://github.com/awslabs/aws-sdk-rust"

rust-version = "1.88.0"

readme = "README.md"

[package.metadata.smithy]

codegen-version = "ci"

protocol = "aws.protocols#restJson1"

[dev-dependencies.aws-smithy-http-client]

path = "../aws-smithy-http-client"

features = ["test-util", "wire-mock"]

version = "1.1.5"

[dev-dependencies.aws-smithy-protocol-test]

path = "../aws-smithy-protocol-test"

version = "0.63.7"

[dev-dependencies.aws-smithy-runtime]

path = "../aws-smithy-runtime"

features = ["test-util"]

version = "1.9.5"

[dev-dependencies.aws-smithy-runtime-api]

path = "../aws-smithy-runtime-api"

features = ["test-util"]

version = "1.9.3"

    pub fn new(_service_config: crate::config::Config) -> Self {

        let config = {

            let mut cfg = ::aws_smithy_types::config_bag::Layer::new("AmazonBedrockFrontendService");

            cfg.store_put(crate::idempotency_token::default_provider());

            cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);

            ::std::option::Option::Some(cfg.freeze())

        };

        let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");

        runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(

            ::aws_smithy_runtime::client::auth::http::BearerAuthScheme::new(),

        ));

        runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({

            use crate::config::auth::ResolveAuthScheme;

            crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()

        }));

        runtime_components.set_endpoint_resolver(::std::option::Option::Some({

            use crate::config::endpoint::ResolveEndpoint;

            crate::config::endpoint::DefaultResolver::new().into_shared_resolver()

        }));

        runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());

        ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults

    }

    fn runtime_components(

        &self,

        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,

    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {

        ::std::borrow::Cow::Borrowed(&self.runtime_components)

    }

}

// Cross-operation shared-state singletons

/// A plugin that enables configuration for a single operation invocation

///

/// The `config` method will return a `FrozenLayer` by storing values from `config_override`.

/// In the case of default values requested, they will be obtained from `client_config`.

#[derive(Debug)]

pub(crate) struct ConfigOverrideRuntimePlugin {

    pub(crate) config: ::aws_smithy_types::config_bag::FrozenLayer,

pub mod client;

/// Configuration for Amazon Bedrock Runtime.

pub mod config;

/// Common errors and error handling utilities.

pub mod error;

mod error_meta;

/// Information about this crate.

pub mod meta;

/// All operations that this crate can perform.

pub mod operation;

/// Primitives such as `Blob` or `DateTime` used by other types.

pub mod primitives;

/// Data structures used by operation inputs/outputs.

mod serde_util;

mod json_errors;

#[doc(inline)]

pub use client::Client;

# Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

[package]

name = "aws-sdk-cloudwatchlogs"

version = "0.0.0-local"

authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]

description = "AWS SDK for Amazon CloudWatch Logs"

edition = "2021"

license = "Apache-2.0"

repository = "https://github.com/awslabs/aws-sdk-rust"

rust-version = "1.88.0"

readme = "README.md"

[package.metadata.smithy]

codegen-version = "ci"

protocol = "aws.protocols#awsJson1_1"

[dev-dependencies.aws-smithy-http-client]

path = "../aws-smithy-http-client"

features = ["test-util", "wire-mock"]

version = "1.1.5"

[dev-dependencies.aws-smithy-protocol-test]

path = "../aws-smithy-protocol-test"

version = "0.63.7"

[dev-dependencies.aws-smithy-runtime]

path = "../aws-smithy-runtime"

features = ["test-util"]

version = "1.9.5"

[dev-dependencies.aws-smithy-runtime-api]

path = "../aws-smithy-runtime-api"

features = ["test-util"]

version = "1.9.3"

}

impl ServiceRuntimePlugin {

    pub fn new(_service_config: crate::config::Config) -> Self {

        let config = {

            let mut cfg = ::aws_smithy_types::config_bag::Layer::new("Logs_20140328");

            cfg.store_put(crate::idempotency_token::default_provider());

            cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);

            ::std::option::Option::Some(cfg.freeze())

        };

        let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");

        runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({

            use crate::config::auth::ResolveAuthScheme;

            crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()

        }));

        runtime_components.set_endpoint_resolver(::std::option::Option::Some({

            use crate::config::endpoint::ResolveEndpoint;

            crate::config::endpoint::DefaultResolver::new().into_shared_resolver()

        }));

        runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());

        ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults

    }

    fn runtime_components(

        &self,

        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,

    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {

        ::std::borrow::Cow::Borrowed(&self.runtime_components)

    }

}

// Cross-operation shared-state singletons

/// A plugin that enables configuration for a single operation invocation

///

/// The `config` method will return a `FrozenLayer` by storing values from `config_override`.

/// In the case of default values requested, they will be obtained from `client_config`.

#[derive(Debug)]

pub(crate) struct ConfigOverrideRuntimePlugin {

    pub(crate) config: ::aws_smithy_types::config_bag::FrozenLayer,

/// function on the fluent builder. See the [`customize`](crate::client::customize) module for more

/// information.

pub mod client;

/// Configuration for Amazon CloudWatch Logs.

pub mod config;

/// Common errors and error handling utilities.

pub mod error;

mod error_meta;

/// Information about this crate.

pub mod meta;

/// All operations that this crate can perform.

pub mod operation;

/// Primitives such as `Blob` or `DateTime` used by other types.

pub mod primitives;

mod event_stream_serde;

mod json_errors;

mod serde_util;

#[doc(inline)]

pub use client::Client;

# Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

[package]

name = "aws-sdk-codecatalyst"

version = "0.0.0-local"

authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]

description = "AWS SDK for Amazon CodeCatalyst"

edition = "2021"

license = "Apache-2.0"

repository = "https://github.com/awslabs/aws-sdk-rust"

rust-version = "1.88.0"

readme = "README.md"

[package.metadata.smithy]

codegen-version = "ci"

[dev-dependencies.aws-smithy-protocol-test]

path = "../aws-smithy-protocol-test"

version = "0.63.7"

[dev-dependencies.aws-smithy-runtime]

path = "../aws-smithy-runtime"

features = ["test-util"]

version = "1.9.5"

[dev-dependencies.aws-smithy-runtime-api]

path = "../aws-smithy-runtime-api"

features = ["test-util"]

version = "1.9.3"

[dev-dependencies.aws-smithy-types]

path = "../aws-smithy-types"

features = ["test-util"]

version = "1.3.5"

}

impl ServiceRuntimePlugin {

    pub fn new(_service_config: crate::config::Config) -> Self {

        let config = {

            let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CodeCatalyst");

            cfg.store_put(crate::idempotency_token::default_provider());

            cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);

            ::std::option::Option::Some(cfg.freeze())

        };

        let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");

        runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(

            ::aws_smithy_runtime::client::auth::http::BearerAuthScheme::new(),

        ));

        runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({

            use crate::config::auth::ResolveAuthScheme;

            crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()

        }));

        runtime_components.set_endpoint_resolver(::std::option::Option::Some({

            use crate::config::endpoint::ResolveEndpoint;

        ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults

    }

    fn runtime_components(

        &self,

        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,

    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {

        ::std::borrow::Cow::Borrowed(&self.runtime_components)

    }

}

// Cross-operation shared-state singletons

/// A plugin that enables configuration for a single operation invocation

///

/// The `config` method will return a `FrozenLayer` by storing values from `config_override`.

/// In the case of default values requested, they will be obtained from `client_config`.

#[derive(Debug)]

pub(crate) struct ConfigOverrideRuntimePlugin {

    pub(crate) config: ::aws_smithy_types::config_bag::FrozenLayer,