Struct aws_sdk_appflow::Client
source · pub struct Client { /* private fields */ }
Expand description
Client for Amazon Appflow
Client for invoking operations on Amazon Appflow. Each operation on Amazon Appflow is a method on this
this struct. .send()
MUST be invoked on the generated operations to dispatch the request to the service.
Examples
Constructing a client and invoking an operation
// create a shared configuration. This can be used & shared between multiple service clients.
let shared_config = aws_config::load_from_env().await;
let client = aws_sdk_appflow::Client::new(&shared_config);
// invoke an operation
/* let rsp = client
.<operation_name>().
.<param>("some value")
.send().await; */
Constructing a client with custom configuration
use aws_config::retry::RetryConfig;
let shared_config = aws_config::load_from_env().await;
let config = aws_sdk_appflow::config::Builder::from(&shared_config)
.retry_config(RetryConfig::disabled())
.build();
let client = aws_sdk_appflow::Client::from_conf(config);
Implementations§
source§impl Client
impl Client
sourcepub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self
pub fn with_config(
client: Client<DynConnector, DynMiddleware<DynConnector>>,
conf: Config
) -> Self
Creates a client with the given service configuration.
source§impl Client
impl Client
sourcepub fn create_connector_profile(&self) -> CreateConnectorProfile
pub fn create_connector_profile(&self) -> CreateConnectorProfile
Constructs a fluent builder for the CreateConnectorProfile
operation.
- The fluent builder is configurable:
connector_profile_name(impl Into<String>)
/set_connector_profile_name(Option<String>)
:The name of the connector profile. The name is unique for each
ConnectorProfile
in your Amazon Web Services account.kms_arn(impl Into<String>)
/set_kms_arn(Option<String>)
:The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption. This is required if you do not want to use the Amazon AppFlow-managed KMS key. If you don’t provide anything here, Amazon AppFlow uses the Amazon AppFlow-managed KMS key.
connector_type(ConnectorType)
/set_connector_type(Option<ConnectorType>)
:The type of connector, such as Salesforce, Amplitude, and so on.
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The label of the connector. The label is unique for each
ConnectorRegistration
in your Amazon Web Services account. Only needed if calling for CUSTOMCONNECTOR connector type/.connection_mode(ConnectionMode)
/set_connection_mode(Option<ConnectionMode>)
:Indicates the connection mode and specifies whether it is public or private. Private flows use Amazon Web Services PrivateLink to route data over Amazon Web Services infrastructure without exposing it to the public internet.
connector_profile_config(ConnectorProfileConfig)
/set_connector_profile_config(Option<ConnectorProfileConfig>)
:Defines the connector-specific configuration and credentials.
- On success, responds with
CreateConnectorProfileOutput
with field(s):connector_profile_arn(Option<String>)
:The Amazon Resource Name (ARN) of the connector profile.
- On failure, responds with
SdkError<CreateConnectorProfileError>
sourcepub fn create_flow(&self) -> CreateFlow
pub fn create_flow(&self) -> CreateFlow
Constructs a fluent builder for the CreateFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
description(impl Into<String>)
/set_description(Option<String>)
:A description of the flow you want to create.
kms_arn(impl Into<String>)
/set_kms_arn(Option<String>)
:The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption. This is required if you do not want to use the Amazon AppFlow-managed KMS key. If you don’t provide anything here, Amazon AppFlow uses the Amazon AppFlow-managed KMS key.
trigger_config(TriggerConfig)
/set_trigger_config(Option<TriggerConfig>)
:The trigger settings that determine how and when the flow runs.
source_flow_config(SourceFlowConfig)
/set_source_flow_config(Option<SourceFlowConfig>)
:The configuration that controls how Amazon AppFlow retrieves data from the source connector.
destination_flow_config_list(Vec<DestinationFlowConfig>)
/set_destination_flow_config_list(Option<Vec<DestinationFlowConfig>>)
:The configuration that controls how Amazon AppFlow places data in the destination connector.
tasks(Vec<Task>)
/set_tasks(Option<Vec<Task>>)
:A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.
tags(HashMap<String, String>)
/set_tags(Option<HashMap<String, String>>)
:The tags used to organize, track, or control access for your flow.
metadata_catalog_config(MetadataCatalogConfig)
/set_metadata_catalog_config(Option<MetadataCatalogConfig>)
:Specifies the configuration that Amazon AppFlow uses when it catalogs the data that’s transferred by the associated flow. When Amazon AppFlow catalogs the data from a flow, it stores metadata in a data catalog.
- On success, responds with
CreateFlowOutput
with field(s):flow_arn(Option<String>)
:The flow’s Amazon Resource Name (ARN).
flow_status(Option<FlowStatus>)
:Indicates the current status of the flow.
- On failure, responds with
SdkError<CreateFlowError>
sourcepub fn delete_connector_profile(&self) -> DeleteConnectorProfile
pub fn delete_connector_profile(&self) -> DeleteConnectorProfile
Constructs a fluent builder for the DeleteConnectorProfile
operation.
- The fluent builder is configurable:
connector_profile_name(impl Into<String>)
/set_connector_profile_name(Option<String>)
:The name of the connector profile. The name is unique for each
ConnectorProfile
in your account.force_delete(bool)
/set_force_delete(bool)
:Indicates whether Amazon AppFlow should delete the profile, even if it is currently in use in one or more flows.
- On success, responds with
DeleteConnectorProfileOutput
- On failure, responds with
SdkError<DeleteConnectorProfileError>
sourcepub fn delete_flow(&self) -> DeleteFlow
pub fn delete_flow(&self) -> DeleteFlow
Constructs a fluent builder for the DeleteFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
force_delete(bool)
/set_force_delete(bool)
:Indicates whether Amazon AppFlow should delete the flow, even if it is currently in use.
- On success, responds with
DeleteFlowOutput
- On failure, responds with
SdkError<DeleteFlowError>
sourcepub fn describe_connector(&self) -> DescribeConnector
pub fn describe_connector(&self) -> DescribeConnector
Constructs a fluent builder for the DescribeConnector
operation.
- The fluent builder is configurable:
connector_type(ConnectorType)
/set_connector_type(Option<ConnectorType>)
:The connector type, such as CUSTOMCONNECTOR, Saleforce, Marketo. Please choose CUSTOMCONNECTOR for Lambda based custom connectors.
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The label of the connector. The label is unique for each
ConnectorRegistration
in your Amazon Web Services account. Only needed if calling for CUSTOMCONNECTOR connector type/.
- On success, responds with
DescribeConnectorOutput
with field(s):connector_configuration(Option<ConnectorConfiguration>)
:Configuration info of all the connectors that the user requested.
- On failure, responds with
SdkError<DescribeConnectorError>
sourcepub fn describe_connector_entity(&self) -> DescribeConnectorEntity
pub fn describe_connector_entity(&self) -> DescribeConnectorEntity
Constructs a fluent builder for the DescribeConnectorEntity
operation.
- The fluent builder is configurable:
connector_entity_name(impl Into<String>)
/set_connector_entity_name(Option<String>)
:The entity name for that connector.
connector_type(ConnectorType)
/set_connector_type(Option<ConnectorType>)
:The type of connector application, such as Salesforce, Amplitude, and so on.
connector_profile_name(impl Into<String>)
/set_connector_profile_name(Option<String>)
:The name of the connector profile. The name is unique for each
ConnectorProfile
in the Amazon Web Services account.api_version(impl Into<String>)
/set_api_version(Option<String>)
:The version of the API that’s used by the connector.
- On success, responds with
DescribeConnectorEntityOutput
with field(s):connector_entity_fields(Option<Vec<ConnectorEntityField>>)
:Describes the fields for that connector entity. For example, for an account entity, the fields would be account name, account ID, and so on.
- On failure, responds with
SdkError<DescribeConnectorEntityError>
sourcepub fn describe_connector_profiles(&self) -> DescribeConnectorProfiles
pub fn describe_connector_profiles(&self) -> DescribeConnectorProfiles
Constructs a fluent builder for the DescribeConnectorProfiles
operation.
This operation supports pagination; See into_paginator()
.
- The fluent builder is configurable:
connector_profile_names(Vec<String>)
/set_connector_profile_names(Option<Vec<String>>)
:The name of the connector profile. The name is unique for each
ConnectorProfile
in the Amazon Web Services account.connector_type(ConnectorType)
/set_connector_type(Option<ConnectorType>)
:The type of connector, such as Salesforce, Amplitude, and so on.
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The name of the connector. The name is unique for each
ConnectorRegistration
in your Amazon Web Services account. Only needed if calling for CUSTOMCONNECTOR connector type/.max_results(i32)
/set_max_results(Option<i32>)
:Specifies the maximum number of items that should be returned in the result set. The default for
maxResults
is 20 (for all paginated API operations).next_token(impl Into<String>)
/set_next_token(Option<String>)
:The pagination token for the next page of data.
- On success, responds with
DescribeConnectorProfilesOutput
with field(s):connector_profile_details(Option<Vec<ConnectorProfile>>)
:Returns information about the connector profiles associated with the flow.
next_token(Option<String>)
:The pagination token for the next page of data. If
nextToken=null
, this means that all records have been fetched.
- On failure, responds with
SdkError<DescribeConnectorProfilesError>
sourcepub fn describe_connectors(&self) -> DescribeConnectors
pub fn describe_connectors(&self) -> DescribeConnectors
Constructs a fluent builder for the DescribeConnectors
operation.
This operation supports pagination; See into_paginator()
.
- The fluent builder is configurable:
connector_types(Vec<ConnectorType>)
/set_connector_types(Option<Vec<ConnectorType>>)
:The type of connector, such as Salesforce, Amplitude, and so on.
max_results(i32)
/set_max_results(Option<i32>)
:The maximum number of items that should be returned in the result set. The default is 20.
next_token(impl Into<String>)
/set_next_token(Option<String>)
:The pagination token for the next page of data.
- On success, responds with
DescribeConnectorsOutput
with field(s):connector_configurations(Option<HashMap<ConnectorType, ConnectorConfiguration>>)
:The configuration that is applied to the connectors used in the flow.
connectors(Option<Vec<ConnectorDetail>>)
:Information about the connectors supported in Amazon AppFlow.
next_token(Option<String>)
:The pagination token for the next page of data.
- On failure, responds with
SdkError<DescribeConnectorsError>
sourcepub fn describe_flow(&self) -> DescribeFlow
pub fn describe_flow(&self) -> DescribeFlow
Constructs a fluent builder for the DescribeFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
- On success, responds with
DescribeFlowOutput
with field(s):flow_arn(Option<String>)
:The flow’s Amazon Resource Name (ARN).
description(Option<String>)
:A description of the flow.
flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
kms_arn(Option<String>)
:The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption. This is required if you do not want to use the Amazon AppFlow-managed KMS key. If you don’t provide anything here, Amazon AppFlow uses the Amazon AppFlow-managed KMS key.
flow_status(Option<FlowStatus>)
:Indicates the current status of the flow.
flow_status_message(Option<String>)
:Contains an error message if the flow status is in a suspended or error state. This applies only to scheduled or event-triggered flows.
source_flow_config(Option<SourceFlowConfig>)
:The configuration that controls how Amazon AppFlow retrieves data from the source connector.
destination_flow_config_list(Option<Vec<DestinationFlowConfig>>)
:The configuration that controls how Amazon AppFlow transfers data to the destination connector.
last_run_execution_details(Option<ExecutionDetails>)
:Describes the details of the most recent flow run.
trigger_config(Option<TriggerConfig>)
:The trigger settings that determine how and when the flow runs.
tasks(Option<Vec<Task>>)
:A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.
created_at(Option<DateTime>)
:Specifies when the flow was created.
last_updated_at(Option<DateTime>)
:Specifies when the flow was last updated.
created_by(Option<String>)
:The ARN of the user who created the flow.
last_updated_by(Option<String>)
:Specifies the user name of the account that performed the most recent update.
tags(Option<HashMap<String, String>>)
:The tags used to organize, track, or control access for your flow.
metadata_catalog_config(Option<MetadataCatalogConfig>)
:Specifies the configuration that Amazon AppFlow uses when it catalogs the data that’s transferred by the associated flow. When Amazon AppFlow catalogs the data from a flow, it stores metadata in a data catalog.
last_run_metadata_catalog_details(Option<Vec<MetadataCatalogDetail>>)
:Describes the metadata catalog, metadata table, and data partitions that Amazon AppFlow used for the associated flow run.
schema_version(Option<i64>)
:The version number of your data schema. Amazon AppFlow assigns this version number. The version number increases by one when you change any of the following settings in your flow configuration:
-
Source-to-destination field mappings
-
Field data types
-
Partition keys
-
- On failure, responds with
SdkError<DescribeFlowError>
sourcepub fn describe_flow_execution_records(&self) -> DescribeFlowExecutionRecords
pub fn describe_flow_execution_records(&self) -> DescribeFlowExecutionRecords
Constructs a fluent builder for the DescribeFlowExecutionRecords
operation.
This operation supports pagination; See into_paginator()
.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
max_results(i32)
/set_max_results(Option<i32>)
:Specifies the maximum number of items that should be returned in the result set. The default for
maxResults
is 20 (for all paginated API operations).next_token(impl Into<String>)
/set_next_token(Option<String>)
:The pagination token for the next page of data.
- On success, responds with
DescribeFlowExecutionRecordsOutput
with field(s):flow_executions(Option<Vec<ExecutionRecord>>)
:Returns a list of all instances when this flow was run.
next_token(Option<String>)
:The pagination token for the next page of data.
- On failure, responds with
SdkError<DescribeFlowExecutionRecordsError>
sourcepub fn list_connector_entities(&self) -> ListConnectorEntities
pub fn list_connector_entities(&self) -> ListConnectorEntities
Constructs a fluent builder for the ListConnectorEntities
operation.
- The fluent builder is configurable:
connector_profile_name(impl Into<String>)
/set_connector_profile_name(Option<String>)
:The name of the connector profile. The name is unique for each
ConnectorProfile
in the Amazon Web Services account, and is used to query the downstream connector.connector_type(ConnectorType)
/set_connector_type(Option<ConnectorType>)
:The type of connector, such as Salesforce, Amplitude, and so on.
entities_path(impl Into<String>)
/set_entities_path(Option<String>)
:This optional parameter is specific to connector implementation. Some connectors support multiple levels or categories of entities. You can find out the list of roots for such providers by sending a request without the
entitiesPath
parameter. If the connector supports entities at different roots, this initial request returns the list of roots. Otherwise, this request returns all entities supported by the provider.api_version(impl Into<String>)
/set_api_version(Option<String>)
:The version of the API that’s used by the connector.
max_results(i32)
/set_max_results(Option<i32>)
:The maximum number of items that the operation returns in the response.
next_token(impl Into<String>)
/set_next_token(Option<String>)
:A token that was provided by your prior
ListConnectorEntities
operation if the response was too big for the page size. You specify this token to get the next page of results in paginated response.
- On success, responds with
ListConnectorEntitiesOutput
with field(s):connector_entity_map(Option<HashMap<String, Vec<ConnectorEntity>>>)
:The response of
ListConnectorEntities
lists entities grouped by category. This map’s key represents the group name, and its value contains the list of entities belonging to that group.next_token(Option<String>)
:A token that you specify in your next
ListConnectorEntities
operation to get the next page of results in paginated response. TheListConnectorEntities
operation provides this token if the response is too big for the page size.
- On failure, responds with
SdkError<ListConnectorEntitiesError>
sourcepub fn list_connectors(&self) -> ListConnectors
pub fn list_connectors(&self) -> ListConnectors
Constructs a fluent builder for the ListConnectors
operation.
This operation supports pagination; See into_paginator()
.
- The fluent builder is configurable:
max_results(i32)
/set_max_results(Option<i32>)
:Specifies the maximum number of items that should be returned in the result set. The default for
maxResults
is 20 (for all paginated API operations).next_token(impl Into<String>)
/set_next_token(Option<String>)
:The pagination token for the next page of data.
- On success, responds with
ListConnectorsOutput
with field(s):connectors(Option<Vec<ConnectorDetail>>)
:Contains information about the connectors supported by Amazon AppFlow.
next_token(Option<String>)
:The pagination token for the next page of data. If nextToken=null, this means that all records have been fetched.
- On failure, responds with
SdkError<ListConnectorsError>
sourcepub fn list_flows(&self) -> ListFlows
pub fn list_flows(&self) -> ListFlows
Constructs a fluent builder for the ListFlows
operation.
This operation supports pagination; See into_paginator()
.
- The fluent builder is configurable:
max_results(i32)
/set_max_results(Option<i32>)
:Specifies the maximum number of items that should be returned in the result set.
next_token(impl Into<String>)
/set_next_token(Option<String>)
:The pagination token for next page of data.
- On success, responds with
ListFlowsOutput
with field(s):flows(Option<Vec<FlowDefinition>>)
:The list of flows associated with your account.
next_token(Option<String>)
:The pagination token for next page of data.
- On failure, responds with
SdkError<ListFlowsError>
Constructs a fluent builder for the ListTagsForResource
operation.
- The fluent builder is configurable:
resource_arn(impl Into<String>)
/set_resource_arn(Option<String>)
:The Amazon Resource Name (ARN) of the specified flow.
- On success, responds with
ListTagsForResourceOutput
with field(s):tags(Option<HashMap<String, String>>)
:The tags used to organize, track, or control access for your flow.
- On failure, responds with
SdkError<ListTagsForResourceError>
sourcepub fn register_connector(&self) -> RegisterConnector
pub fn register_connector(&self) -> RegisterConnector
Constructs a fluent builder for the RegisterConnector
operation.
- The fluent builder is configurable:
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The name of the connector. The name is unique for each
ConnectorRegistration
in your Amazon Web Services account.description(impl Into<String>)
/set_description(Option<String>)
:A description about the connector that’s being registered.
connector_provisioning_type(ConnectorProvisioningType)
/set_connector_provisioning_type(Option<ConnectorProvisioningType>)
:The provisioning type of the connector. Currently the only supported value is LAMBDA.
connector_provisioning_config(ConnectorProvisioningConfig)
/set_connector_provisioning_config(Option<ConnectorProvisioningConfig>)
:The provisioning type of the connector. Currently the only supported value is LAMBDA.
- On success, responds with
RegisterConnectorOutput
with field(s):connector_arn(Option<String>)
:The ARN of the connector being registered.
- On failure, responds with
SdkError<RegisterConnectorError>
sourcepub fn start_flow(&self) -> StartFlow
pub fn start_flow(&self) -> StartFlow
Constructs a fluent builder for the StartFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
- On success, responds with
StartFlowOutput
with field(s):flow_arn(Option<String>)
:The flow’s Amazon Resource Name (ARN).
flow_status(Option<FlowStatus>)
:Indicates the current status of the flow.
execution_id(Option<String>)
:Returns the internal execution ID of an on-demand flow when the flow is started. For scheduled or event-triggered flows, this value is null.
- On failure, responds with
SdkError<StartFlowError>
sourcepub fn stop_flow(&self) -> StopFlow
pub fn stop_flow(&self) -> StopFlow
Constructs a fluent builder for the StopFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
- On success, responds with
StopFlowOutput
with field(s):flow_arn(Option<String>)
:The flow’s Amazon Resource Name (ARN).
flow_status(Option<FlowStatus>)
:Indicates the current status of the flow.
- On failure, responds with
SdkError<StopFlowError>
sourcepub fn tag_resource(&self) -> TagResource
pub fn tag_resource(&self) -> TagResource
Constructs a fluent builder for the TagResource
operation.
- The fluent builder is configurable:
resource_arn(impl Into<String>)
/set_resource_arn(Option<String>)
:The Amazon Resource Name (ARN) of the flow that you want to tag.
tags(HashMap<String, String>)
/set_tags(Option<HashMap<String, String>>)
:The tags used to organize, track, or control access for your flow.
- On success, responds with
TagResourceOutput
- On failure, responds with
SdkError<TagResourceError>
sourcepub fn unregister_connector(&self) -> UnregisterConnector
pub fn unregister_connector(&self) -> UnregisterConnector
Constructs a fluent builder for the UnregisterConnector
operation.
- The fluent builder is configurable:
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The label of the connector. The label is unique for each
ConnectorRegistration
in your Amazon Web Services account.force_delete(bool)
/set_force_delete(bool)
:Indicates whether Amazon AppFlow should unregister the connector, even if it is currently in use in one or more connector profiles. The default value is false.
- On success, responds with
UnregisterConnectorOutput
- On failure, responds with
SdkError<UnregisterConnectorError>
sourcepub fn untag_resource(&self) -> UntagResource
pub fn untag_resource(&self) -> UntagResource
Constructs a fluent builder for the UntagResource
operation.
- The fluent builder is configurable:
resource_arn(impl Into<String>)
/set_resource_arn(Option<String>)
:The Amazon Resource Name (ARN) of the flow that you want to untag.
tag_keys(Vec<String>)
/set_tag_keys(Option<Vec<String>>)
:The tag keys associated with the tag that you want to remove from your flow.
- On success, responds with
UntagResourceOutput
- On failure, responds with
SdkError<UntagResourceError>
sourcepub fn update_connector_profile(&self) -> UpdateConnectorProfile
pub fn update_connector_profile(&self) -> UpdateConnectorProfile
Constructs a fluent builder for the UpdateConnectorProfile
operation.
- The fluent builder is configurable:
connector_profile_name(impl Into<String>)
/set_connector_profile_name(Option<String>)
:The name of the connector profile and is unique for each
ConnectorProfile
in the Amazon Web Services account.connection_mode(ConnectionMode)
/set_connection_mode(Option<ConnectionMode>)
:Indicates the connection mode and if it is public or private.
connector_profile_config(ConnectorProfileConfig)
/set_connector_profile_config(Option<ConnectorProfileConfig>)
:Defines the connector-specific profile configuration and credentials.
- On success, responds with
UpdateConnectorProfileOutput
with field(s):connector_profile_arn(Option<String>)
:The Amazon Resource Name (ARN) of the connector profile.
- On failure, responds with
SdkError<UpdateConnectorProfileError>
sourcepub fn update_connector_registration(&self) -> UpdateConnectorRegistration
pub fn update_connector_registration(&self) -> UpdateConnectorRegistration
Constructs a fluent builder for the UpdateConnectorRegistration
operation.
- The fluent builder is configurable:
connector_label(impl Into<String>)
/set_connector_label(Option<String>)
:The name of the connector. The name is unique for each connector registration in your AWS account.
description(impl Into<String>)
/set_description(Option<String>)
:A description about the update that you’re applying to the connector.
connector_provisioning_config(ConnectorProvisioningConfig)
/set_connector_provisioning_config(Option<ConnectorProvisioningConfig>)
:Contains information about the configuration of the connector being registered.
- On success, responds with
UpdateConnectorRegistrationOutput
with field(s):connector_arn(Option<String>)
:The ARN of the connector being updated.
- On failure, responds with
SdkError<UpdateConnectorRegistrationError>
sourcepub fn update_flow(&self) -> UpdateFlow
pub fn update_flow(&self) -> UpdateFlow
Constructs a fluent builder for the UpdateFlow
operation.
- The fluent builder is configurable:
flow_name(impl Into<String>)
/set_flow_name(Option<String>)
:The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.
description(impl Into<String>)
/set_description(Option<String>)
:A description of the flow.
trigger_config(TriggerConfig)
/set_trigger_config(Option<TriggerConfig>)
:The trigger settings that determine how and when the flow runs.
source_flow_config(SourceFlowConfig)
/set_source_flow_config(Option<SourceFlowConfig>)
:Contains information about the configuration of the source connector used in the flow.
destination_flow_config_list(Vec<DestinationFlowConfig>)
/set_destination_flow_config_list(Option<Vec<DestinationFlowConfig>>)
:The configuration that controls how Amazon AppFlow transfers data to the destination connector.
tasks(Vec<Task>)
/set_tasks(Option<Vec<Task>>)
:A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.
metadata_catalog_config(MetadataCatalogConfig)
/set_metadata_catalog_config(Option<MetadataCatalogConfig>)
:Specifies the configuration that Amazon AppFlow uses when it catalogs the data that’s transferred by the associated flow. When Amazon AppFlow catalogs the data from a flow, it stores metadata in a data catalog.
- On success, responds with
UpdateFlowOutput
with field(s):flow_status(Option<FlowStatus>)
:Indicates the current status of the flow.
- On failure, responds with
SdkError<UpdateFlowError>
source§impl Client
impl Client
sourcepub fn new(sdk_config: &SdkConfig) -> Self
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 thesleep_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 thehttp_connector
on the Config passed into this function to fix it.
sourcepub fn from_conf(conf: Config) -> Self
pub fn from_conf(conf: Config) -> Self
Creates a new client from the service Config
.
Panics
- This method will panic if the
conf
is missing an async sleep implementation. If you experience this panic, set thesleep_impl
on the Config passed into this function to fix it. - This method will panic if the
conf
is missing an HTTP connector. If you experience this panic, set thehttp_connector
on the Config passed into this function to fix it.