pub struct Client { /* private fields */ }
Expand description

Client for AWS DataSync

Client for invoking operations on AWS DataSync. Each operation on AWS DataSync is a method on this this struct. .send() MUST be invoked on the generated operations to dispatch the request to the service.

Constructing a Client

A Config is required to construct a client. For most use cases, the aws-config crate should be used to automatically resolve this config using aws_config::load_from_env(), since this will resolve an SdkConfig which can be shared across multiple different AWS SDK clients. This config resolution process can be customized by calling aws_config::from_env() instead, which returns a ConfigLoader that uses the builder pattern to customize the default config.

In the simplest case, creating a client looks as follows:

let config = aws_config::load_from_env().await;
let client = aws_sdk_datasync::Client::new(&config);

Occasionally, SDKs may have additional service-specific that can be set on the Config that is absent from SdkConfig, or slightly different settings for a specific client may be desired. The Config struct implements From<&SdkConfig>, so setting these specific settings can be done as follows:

let sdk_config = ::aws_config::load_from_env().await;
let config = aws_sdk_datasync::config::Builder::from(&sdk_config)
    .some_service_specific_setting("value")
    .build();

See the aws-config docs and Config for more information on customizing configuration.

Note: Client construction is expensive due to connection thread pool initialization, and should be done once at application start-up.

Using the Client

A client has a function for every operation that can be performed by the service. For example, the AddStorageSystem operation has a Client::add_storage_system, function which returns a builder for that operation. The fluent builder ultimately has a send() function that returns an async future that returns a result, as illustrated below:

let result = client.add_storage_system()
    .system_type("example")
    .send()
    .await;

The underlying HTTP requests that get made by this can be modified with the customize_operation function on the fluent builder. See the customize module for more information.

Implementations§

source§

impl Client

source

pub fn add_storage_system(&self) -> AddStorageSystemFluentBuilder

Constructs a fluent builder for the AddStorageSystem operation.

source§

impl Client

source

pub fn cancel_task_execution(&self) -> CancelTaskExecutionFluentBuilder

Constructs a fluent builder for the CancelTaskExecution operation.

source§

impl Client

source

pub fn create_agent(&self) -> CreateAgentFluentBuilder

Constructs a fluent builder for the CreateAgent operation.

source§

impl Client

source

pub fn create_location_azure_blob(&self) -> CreateLocationAzureBlobFluentBuilder

Constructs a fluent builder for the CreateLocationAzureBlob operation.

source§

impl Client

source

pub fn create_location_efs(&self) -> CreateLocationEfsFluentBuilder

Constructs a fluent builder for the CreateLocationEfs operation.

source§

impl Client

source

pub fn create_location_fsx_lustre(&self) -> CreateLocationFsxLustreFluentBuilder

Constructs a fluent builder for the CreateLocationFsxLustre operation.

source§

impl Client

source

pub fn create_location_fsx_ontap(&self) -> CreateLocationFsxOntapFluentBuilder

Constructs a fluent builder for the CreateLocationFsxOntap operation.

source§

impl Client

source

pub fn create_location_fsx_open_zfs( &self ) -> CreateLocationFsxOpenZfsFluentBuilder

Constructs a fluent builder for the CreateLocationFsxOpenZfs operation.

source§

impl Client

source

pub fn create_location_fsx_windows( &self ) -> CreateLocationFsxWindowsFluentBuilder

Constructs a fluent builder for the CreateLocationFsxWindows operation.

source§

impl Client

source

pub fn create_location_hdfs(&self) -> CreateLocationHdfsFluentBuilder

Constructs a fluent builder for the CreateLocationHdfs operation.

source§

impl Client

source

pub fn create_location_nfs(&self) -> CreateLocationNfsFluentBuilder

Constructs a fluent builder for the CreateLocationNfs operation.

  • The fluent builder is configurable:
    • subdirectory(impl Into<String>) / set_subdirectory(Option<String>):

      Specifies the subdirectory in the NFS file server that DataSync transfers to or from. The NFS path should be a path that’s exported by the NFS server, or a subdirectory of that path. The path should be such that it can be mounted by other NFS clients in your network.

      To see all the paths exported by your NFS server, run “showmount -e nfs-server-name” from an NFS client that has access to your server. You can specify any directory that appears in the results, and any subdirectory of that directory. Ensure that the NFS export is accessible without Kerberos authentication.

      To transfer all the data in the folder you specified, DataSync needs to have permissions to read all the data. To ensure this, either configure the NFS export with no_root_squash, or ensure that the permissions for all of the files that you want DataSync allow read access for all users. Doing either enables the agent to read the files. For the agent to access directories, you must additionally enable all execute access.

      If you are copying data to or from your Snowcone device, see NFS Server on Snowcone for more information.

    • server_hostname(impl Into<String>) / set_server_hostname(Option<String>):

      Specifies the IP address or domain name of your NFS file server. An agent that is installed on-premises uses this hostname to mount the NFS server in a network.

      If you are copying data to or from your Snowcone device, see NFS Server on Snowcone for more information.

      You must specify be an IP version 4 address or Domain Name System (DNS)-compliant name.

    • on_prem_config(OnPremConfig) / set_on_prem_config(Option<OnPremConfig>):

      Specifies the Amazon Resource Names (ARNs) of agents that DataSync uses to connect to your NFS file server.

      If you are copying data to or from your Snowcone device, see NFS Server on Snowcone for more information.

    • mount_options(NfsMountOptions) / set_mount_options(Option<NfsMountOptions>):

      Specifies the mount options that DataSync can use to mount your NFS share.

    • tags(TagListEntry) / set_tags(Option<Vec<TagListEntry>>):

      Specifies labels that help you categorize, filter, and search for your Amazon Web Services resources. We recommend creating at least a name tag for your location.

  • On success, responds with CreateLocationNfsOutput with field(s):
  • On failure, responds with SdkError<CreateLocationNfsError>
source§

impl Client

source

pub fn create_location_object_storage( &self ) -> CreateLocationObjectStorageFluentBuilder

Constructs a fluent builder for the CreateLocationObjectStorage operation.

source§

impl Client

source

pub fn create_location_s3(&self) -> CreateLocationS3FluentBuilder

Constructs a fluent builder for the CreateLocationS3 operation.

source§

impl Client

source

pub fn create_location_smb(&self) -> CreateLocationSmbFluentBuilder

Constructs a fluent builder for the CreateLocationSmb operation.

source§

impl Client

source

pub fn create_task(&self) -> CreateTaskFluentBuilder

Constructs a fluent builder for the CreateTask operation.

source§

impl Client

source

pub fn delete_agent(&self) -> DeleteAgentFluentBuilder

Constructs a fluent builder for the DeleteAgent operation.

source§

impl Client

source

pub fn delete_location(&self) -> DeleteLocationFluentBuilder

Constructs a fluent builder for the DeleteLocation operation.

source§

impl Client

source

pub fn delete_task(&self) -> DeleteTaskFluentBuilder

Constructs a fluent builder for the DeleteTask operation.

source§

impl Client

source

pub fn describe_agent(&self) -> DescribeAgentFluentBuilder

Constructs a fluent builder for the DescribeAgent operation.

source§

impl Client

source

pub fn describe_discovery_job(&self) -> DescribeDiscoveryJobFluentBuilder

Constructs a fluent builder for the DescribeDiscoveryJob operation.

source§

impl Client

source

pub fn describe_location_azure_blob( &self ) -> DescribeLocationAzureBlobFluentBuilder

Constructs a fluent builder for the DescribeLocationAzureBlob operation.

source§

impl Client

source

pub fn describe_location_efs(&self) -> DescribeLocationEfsFluentBuilder

Constructs a fluent builder for the DescribeLocationEfs operation.

source§

impl Client

source

pub fn describe_location_fsx_lustre( &self ) -> DescribeLocationFsxLustreFluentBuilder

Constructs a fluent builder for the DescribeLocationFsxLustre operation.

source§

impl Client

source

pub fn describe_location_fsx_ontap( &self ) -> DescribeLocationFsxOntapFluentBuilder

Constructs a fluent builder for the DescribeLocationFsxOntap operation.

source§

impl Client

source

pub fn describe_location_fsx_open_zfs( &self ) -> DescribeLocationFsxOpenZfsFluentBuilder

Constructs a fluent builder for the DescribeLocationFsxOpenZfs operation.

source§

impl Client

source

pub fn describe_location_fsx_windows( &self ) -> DescribeLocationFsxWindowsFluentBuilder

Constructs a fluent builder for the DescribeLocationFsxWindows operation.

source§

impl Client

source

pub fn describe_location_hdfs(&self) -> DescribeLocationHdfsFluentBuilder

Constructs a fluent builder for the DescribeLocationHdfs operation.

source§

impl Client

source

pub fn describe_location_nfs(&self) -> DescribeLocationNfsFluentBuilder

Constructs a fluent builder for the DescribeLocationNfs operation.

source§

impl Client

source

pub fn describe_location_object_storage( &self ) -> DescribeLocationObjectStorageFluentBuilder

Constructs a fluent builder for the DescribeLocationObjectStorage operation.

source§

impl Client

source

pub fn describe_location_s3(&self) -> DescribeLocationS3FluentBuilder

Constructs a fluent builder for the DescribeLocationS3 operation.

source§

impl Client

source

pub fn describe_location_smb(&self) -> DescribeLocationSmbFluentBuilder

Constructs a fluent builder for the DescribeLocationSmb operation.

source§

impl Client

source

pub fn describe_storage_system(&self) -> DescribeStorageSystemFluentBuilder

Constructs a fluent builder for the DescribeStorageSystem operation.

source§

impl Client

source

pub fn describe_storage_system_resource_metrics( &self ) -> DescribeStorageSystemResourceMetricsFluentBuilder

Constructs a fluent builder for the DescribeStorageSystemResourceMetrics operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn describe_storage_system_resources( &self ) -> DescribeStorageSystemResourcesFluentBuilder

Constructs a fluent builder for the DescribeStorageSystemResources operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn describe_task(&self) -> DescribeTaskFluentBuilder

Constructs a fluent builder for the DescribeTask operation.

source§

impl Client

source

pub fn describe_task_execution(&self) -> DescribeTaskExecutionFluentBuilder

Constructs a fluent builder for the DescribeTaskExecution operation.

  • The fluent builder is configurable:
  • On success, responds with DescribeTaskExecutionOutput with field(s):
    • task_execution_arn(Option<String>):

      The Amazon Resource Name (ARN) of the task execution that was described. TaskExecutionArn is hierarchical and includes TaskArn for the task that was executed.

      For example, a TaskExecution value with the ARN arn:aws:datasync:us-east-1:111222333444:task/task-0208075f79cedf4a2/execution/exec-08ef1e88ec491019b executed the task with the ARN arn:aws:datasync:us-east-1:111222333444:task/task-0208075f79cedf4a2.

    • status(Option<TaskExecutionStatus>):

      The status of the task execution.

      For detailed information about task execution statuses, see Understanding Task Statuses in the DataSync User Guide.

    • options(Option<Options>):

      Configures your DataSync task settings. These options include how DataSync handles files, objects, and their associated metadata. You also can specify how DataSync verifies data integrity, set bandwidth limits for your task, among other options.

      Each task setting has a default value. Unless you need to, you don’t have to configure any of these Options before starting your task.

    • excludes(Option<Vec<FilterRule>>):

      A list of filter rules that exclude specific data during your transfer. For more information and examples, see Filtering data transferred by DataSync.

    • includes(Option<Vec<FilterRule>>):

      A list of filter rules that include specific data during your transfer. For more information and examples, see Filtering data transferred by DataSync.

    • start_time(Option<DateTime>):

      The time that the task execution was started.

    • estimated_files_to_transfer(i64):

      The expected number of files that is to be transferred over the network. This value is calculated during the PREPARING phase before the TRANSFERRING phase of the task execution. This value is the expected number of files to be transferred. It’s calculated based on comparing the content of the source and destination locations and finding the delta that needs to be transferred.

    • estimated_bytes_to_transfer(i64):

      The estimated physical number of bytes that is to be transferred over the network.

    • files_transferred(i64):

      The actual number of files that was transferred over the network. This value is calculated and updated on an ongoing basis during the TRANSFERRING phase of the task execution. It’s updated periodically when each file is read from the source and sent over the network.

      If failures occur during a transfer, this value can be less than EstimatedFilesToTransfer. In some cases, this value can also be greater than EstimatedFilesToTransfer. This element is implementation-specific for some location types, so don’t use it as an indicator for a correct file number or to monitor your task execution.

    • bytes_written(i64):

      The number of logical bytes written to the destination Amazon Web Services storage resource.

    • bytes_transferred(i64):

      The total number of bytes that are involved in the transfer. For the number of bytes sent over the network, see BytesCompressed.

    • result(Option<TaskExecutionResultDetail>):

      The result of the task execution.

    • bytes_compressed(i64):

      The physical number of bytes transferred over the network after compression was applied. In most cases, this number is less than BytesTransferred unless the data isn’t compressible.

  • On failure, responds with SdkError<DescribeTaskExecutionError>
source§

impl Client

source

pub fn generate_recommendations(&self) -> GenerateRecommendationsFluentBuilder

Constructs a fluent builder for the GenerateRecommendations operation.

source§

impl Client

source

pub fn list_agents(&self) -> ListAgentsFluentBuilder

Constructs a fluent builder for the ListAgents operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_discovery_jobs(&self) -> ListDiscoveryJobsFluentBuilder

Constructs a fluent builder for the ListDiscoveryJobs operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_locations(&self) -> ListLocationsFluentBuilder

Constructs a fluent builder for the ListLocations operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_storage_systems(&self) -> ListStorageSystemsFluentBuilder

Constructs a fluent builder for the ListStorageSystems operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_tags_for_resource(&self) -> ListTagsForResourceFluentBuilder

Constructs a fluent builder for the ListTagsForResource operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_task_executions(&self) -> ListTaskExecutionsFluentBuilder

Constructs a fluent builder for the ListTaskExecutions operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn list_tasks(&self) -> ListTasksFluentBuilder

Constructs a fluent builder for the ListTasks operation. This operation supports pagination; See into_paginator().

source§

impl Client

source

pub fn remove_storage_system(&self) -> RemoveStorageSystemFluentBuilder

Constructs a fluent builder for the RemoveStorageSystem operation.

source§

impl Client

source

pub fn start_discovery_job(&self) -> StartDiscoveryJobFluentBuilder

Constructs a fluent builder for the StartDiscoveryJob operation.

source§

impl Client

source

pub fn start_task_execution(&self) -> StartTaskExecutionFluentBuilder

Constructs a fluent builder for the StartTaskExecution operation.

source§

impl Client

source

pub fn stop_discovery_job(&self) -> StopDiscoveryJobFluentBuilder

Constructs a fluent builder for the StopDiscoveryJob operation.

source§

impl Client

source

pub fn tag_resource(&self) -> TagResourceFluentBuilder

Constructs a fluent builder for the TagResource operation.

source§

impl Client

source

pub fn untag_resource(&self) -> UntagResourceFluentBuilder

Constructs a fluent builder for the UntagResource operation.

source§

impl Client

source

pub fn update_agent(&self) -> UpdateAgentFluentBuilder

Constructs a fluent builder for the UpdateAgent operation.

source§

impl Client

source

pub fn update_discovery_job(&self) -> UpdateDiscoveryJobFluentBuilder

Constructs a fluent builder for the UpdateDiscoveryJob operation.

source§

impl Client

source

pub fn update_location_azure_blob(&self) -> UpdateLocationAzureBlobFluentBuilder

Constructs a fluent builder for the UpdateLocationAzureBlob operation.

source§

impl Client

source

pub fn update_location_hdfs(&self) -> UpdateLocationHdfsFluentBuilder

Constructs a fluent builder for the UpdateLocationHdfs operation.

source§

impl Client

source

pub fn update_location_nfs(&self) -> UpdateLocationNfsFluentBuilder

Constructs a fluent builder for the UpdateLocationNfs operation.

  • The fluent builder is configurable:
    • location_arn(impl Into<String>) / set_location_arn(Option<String>):

      Specifies the Amazon Resource Name (ARN) of the NFS location that you want to update.

    • subdirectory(impl Into<String>) / set_subdirectory(Option<String>):

      Specifies the subdirectory in your NFS file system that DataSync uses to read from or write to during a transfer. The NFS path should be exported by the NFS server, or a subdirectory of that path. The path should be such that it can be mounted by other NFS clients in your network.

      To see all the paths exported by your NFS server, run “showmount -e nfs-server-name” from an NFS client that has access to your server. You can specify any directory that appears in the results, and any subdirectory of that directory. Ensure that the NFS export is accessible without Kerberos authentication.

      To transfer all the data in the folder that you specified, DataSync must have permissions to read all the data. To ensure this, either configure the NFS export with no_root_squash, or ensure that the files you want DataSync to access have permissions that allow read access for all users. Doing either option enables the agent to read the files. For the agent to access directories, you must additionally enable all execute access.

      If you are copying data to or from your Snowcone device, see NFS Server on Snowcone for more information.

    • on_prem_config(OnPremConfig) / set_on_prem_config(Option<OnPremConfig>):

      A list of Amazon Resource Names (ARNs) of agents to use for a Network File System (NFS) location.

    • mount_options(NfsMountOptions) / set_mount_options(Option<NfsMountOptions>):

      Specifies how DataSync can access a location using the NFS protocol.

  • On success, responds with UpdateLocationNfsOutput
  • On failure, responds with SdkError<UpdateLocationNfsError>
source§

impl Client

source

pub fn update_location_object_storage( &self ) -> UpdateLocationObjectStorageFluentBuilder

Constructs a fluent builder for the UpdateLocationObjectStorage operation.

source§

impl Client

source

pub fn update_location_smb(&self) -> UpdateLocationSmbFluentBuilder

Constructs a fluent builder for the UpdateLocationSmb operation.

source§

impl Client

source

pub fn update_storage_system(&self) -> UpdateStorageSystemFluentBuilder

Constructs a fluent builder for the UpdateStorageSystem operation.

source§

impl Client

source

pub fn update_task(&self) -> UpdateTaskFluentBuilder

Constructs a fluent builder for the UpdateTask operation.

source§

impl Client

source

pub fn update_task_execution(&self) -> UpdateTaskExecutionFluentBuilder

Constructs a fluent builder for the UpdateTaskExecution operation.

source§

impl Client

source

pub fn from_conf(conf: Config) -> Self

Creates a new client from the service Config.

Panics

This method will panic if the conf has retry or timeouts enabled without a sleep_impl. If you experience this panic, it can be fixed by setting the sleep_impl, or by disabling retries and timeouts.

source

pub fn config(&self) -> &Config

Returns the client’s configuration.

source§

impl Client

source

pub fn new(sdk_config: &SdkConfig) -> Self

Creates a new client from an SDK Config.

Panics
  • This method will panic if the sdk_config is missing an async sleep implementation. If you experience this panic, set the sleep_impl on the Config passed into this function to fix it.
  • This method will panic if the sdk_config is missing an HTTP connector. If you experience this panic, set the http_connector on the Config passed into this function to fix it.

Trait Implementations§

source§

impl Clone for Client

source§

fn clone(&self) -> Client

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for Client

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl !RefUnwindSafe for Client

§

impl Send for Client

§

impl Sync for Client

§

impl Unpin for Client

§

impl !UnwindSafe for Client

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more