appflow

package
v1.40.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 10 Imported by: 18

Documentation

Overview

Package appflow provides the client and types for making API requests to Amazon Appflow.

Welcome to the Amazon AppFlow API reference. This guide is for developers who need detailed information about the Amazon AppFlow API operations, data types, and errors.

Amazon AppFlow is a fully managed integration service that enables you to securely transfer data between software as a service (SaaS) applications like Salesforce, Marketo, Slack, and ServiceNow, and AWS services like Amazon S3 and Amazon Redshift.

Use the following links to get started on the Amazon AppFlow API:

If you're new to Amazon AppFlow, we recommend that you review the Amazon AppFlow User Guide (https://docs.aws.amazon.com/appflow/latest/userguide/what-is-appflow.html).

Amazon AppFlow API users can use vendor-specific mechanisms for OAuth, and include applicable OAuth attributes (such as auth-code and redirecturi) with the connector-specific ConnectorProfileProperties when creating a new connector profile using Amazon AppFlow API operations. For example, Salesforce users can refer to the Authorize Apps with OAuth (https://help.salesforce.com/articleView?id=remoteaccess_authenticate.htm) documentation.

See https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23 for more information on this service.

See appflow package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/appflow/

Using the Client

To contact Amazon Appflow with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the Amazon Appflow client Appflow for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/appflow/#New

Index

Constants

View Source 
const (
	// AggregationTypeNone is a AggregationType enum value
	AggregationTypeNone = "None"

	// AggregationTypeSingleFile is a AggregationType enum value
	AggregationTypeSingleFile = "SingleFile"
)
View Source 
const (
	// ConnectionModePublic is a ConnectionMode enum value
	ConnectionModePublic = "Public"

	// ConnectionModePrivate is a ConnectionMode enum value
	ConnectionModePrivate = "Private"
)
View Source 
const (
	// ConnectorTypeSalesforce is a ConnectorType enum value
	ConnectorTypeSalesforce = "Salesforce"

	// ConnectorTypeSingular is a ConnectorType enum value
	ConnectorTypeSingular = "Singular"

	// ConnectorTypeSlack is a ConnectorType enum value
	ConnectorTypeSlack = "Slack"

	// ConnectorTypeRedshift is a ConnectorType enum value
	ConnectorTypeRedshift = "Redshift"

	// ConnectorTypeS3 is a ConnectorType enum value
	ConnectorTypeS3 = "S3"

	// ConnectorTypeMarketo is a ConnectorType enum value
	ConnectorTypeMarketo = "Marketo"

	// ConnectorTypeGoogleanalytics is a ConnectorType enum value
	ConnectorTypeGoogleanalytics = "Googleanalytics"

	// ConnectorTypeZendesk is a ConnectorType enum value
	ConnectorTypeZendesk = "Zendesk"

	// ConnectorTypeServicenow is a ConnectorType enum value
	ConnectorTypeServicenow = "Servicenow"

	// ConnectorTypeDatadog is a ConnectorType enum value
	ConnectorTypeDatadog = "Datadog"

	// ConnectorTypeTrendmicro is a ConnectorType enum value
	ConnectorTypeTrendmicro = "Trendmicro"

	// ConnectorTypeSnowflake is a ConnectorType enum value
	ConnectorTypeSnowflake = "Snowflake"

	// ConnectorTypeDynatrace is a ConnectorType enum value
	ConnectorTypeDynatrace = "Dynatrace"

	// ConnectorTypeInfornexus is a ConnectorType enum value
	ConnectorTypeInfornexus = "Infornexus"

	// ConnectorTypeAmplitude is a ConnectorType enum value
	ConnectorTypeAmplitude = "Amplitude"

	// ConnectorTypeVeeva is a ConnectorType enum value
	ConnectorTypeVeeva = "Veeva"

	// ConnectorTypeEventBridge is a ConnectorType enum value
	ConnectorTypeEventBridge = "EventBridge"

	// ConnectorTypeLookoutMetrics is a ConnectorType enum value
	ConnectorTypeLookoutMetrics = "LookoutMetrics"

	// ConnectorTypeUpsolver is a ConnectorType enum value
	ConnectorTypeUpsolver = "Upsolver"

	// ConnectorTypeHoneycode is a ConnectorType enum value
	ConnectorTypeHoneycode = "Honeycode"

	// ConnectorTypeCustomerProfiles is a ConnectorType enum value
	ConnectorTypeCustomerProfiles = "CustomerProfiles"
)
View Source 
const (
	// DataPullModeIncremental is a DataPullMode enum value
	DataPullModeIncremental = "Incremental"

	// DataPullModeComplete is a DataPullMode enum value
	DataPullModeComplete = "Complete"
)
View Source 
const (
	// DatadogConnectorOperatorProjection is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorProjection = "PROJECTION"

	// DatadogConnectorOperatorBetween is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorBetween = "BETWEEN"

	// DatadogConnectorOperatorEqualTo is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorEqualTo = "EQUAL_TO"

	// DatadogConnectorOperatorAddition is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorAddition = "ADDITION"

	// DatadogConnectorOperatorMultiplication is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorMultiplication = "MULTIPLICATION"

	// DatadogConnectorOperatorDivision is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorDivision = "DIVISION"

	// DatadogConnectorOperatorSubtraction is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorSubtraction = "SUBTRACTION"

	// DatadogConnectorOperatorMaskAll is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorMaskAll = "MASK_ALL"

	// DatadogConnectorOperatorMaskFirstN is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// DatadogConnectorOperatorMaskLastN is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorMaskLastN = "MASK_LAST_N"

	// DatadogConnectorOperatorValidateNonNull is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// DatadogConnectorOperatorValidateNonZero is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// DatadogConnectorOperatorValidateNonNegative is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// DatadogConnectorOperatorValidateNumeric is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// DatadogConnectorOperatorNoOp is a DatadogConnectorOperator enum value
	DatadogConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// DynatraceConnectorOperatorProjection is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorProjection = "PROJECTION"

	// DynatraceConnectorOperatorBetween is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorBetween = "BETWEEN"

	// DynatraceConnectorOperatorEqualTo is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorEqualTo = "EQUAL_TO"

	// DynatraceConnectorOperatorAddition is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorAddition = "ADDITION"

	// DynatraceConnectorOperatorMultiplication is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorMultiplication = "MULTIPLICATION"

	// DynatraceConnectorOperatorDivision is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorDivision = "DIVISION"

	// DynatraceConnectorOperatorSubtraction is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorSubtraction = "SUBTRACTION"

	// DynatraceConnectorOperatorMaskAll is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorMaskAll = "MASK_ALL"

	// DynatraceConnectorOperatorMaskFirstN is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// DynatraceConnectorOperatorMaskLastN is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorMaskLastN = "MASK_LAST_N"

	// DynatraceConnectorOperatorValidateNonNull is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// DynatraceConnectorOperatorValidateNonZero is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// DynatraceConnectorOperatorValidateNonNegative is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// DynatraceConnectorOperatorValidateNumeric is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// DynatraceConnectorOperatorNoOp is a DynatraceConnectorOperator enum value
	DynatraceConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// ExecutionStatusInProgress is a ExecutionStatus enum value
	ExecutionStatusInProgress = "InProgress"

	// ExecutionStatusSuccessful is a ExecutionStatus enum value
	ExecutionStatusSuccessful = "Successful"

	// ExecutionStatusError is a ExecutionStatus enum value
	ExecutionStatusError = "Error"
)
View Source 
const (
	// FileTypeCsv is a FileType enum value
	FileTypeCsv = "CSV"

	// FileTypeJson is a FileType enum value
	FileTypeJson = "JSON"

	// FileTypeParquet is a FileType enum value
	FileTypeParquet = "PARQUET"
)
View Source 
const (
	// FlowStatusActive is a FlowStatus enum value
	FlowStatusActive = "Active"

	// FlowStatusDeprecated is a FlowStatus enum value
	FlowStatusDeprecated = "Deprecated"

	// FlowStatusDeleted is a FlowStatus enum value
	FlowStatusDeleted = "Deleted"

	// FlowStatusDraft is a FlowStatus enum value
	FlowStatusDraft = "Draft"

	// FlowStatusErrored is a FlowStatus enum value
	FlowStatusErrored = "Errored"

	// FlowStatusSuspended is a FlowStatus enum value
	FlowStatusSuspended = "Suspended"
)
View Source 
const (
	// GoogleAnalyticsConnectorOperatorProjection is a GoogleAnalyticsConnectorOperator enum value
	GoogleAnalyticsConnectorOperatorProjection = "PROJECTION"

	// GoogleAnalyticsConnectorOperatorBetween is a GoogleAnalyticsConnectorOperator enum value
	GoogleAnalyticsConnectorOperatorBetween = "BETWEEN"
)
View Source 
const (
	// InforNexusConnectorOperatorProjection is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorProjection = "PROJECTION"

	// InforNexusConnectorOperatorBetween is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorBetween = "BETWEEN"

	// InforNexusConnectorOperatorEqualTo is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorEqualTo = "EQUAL_TO"

	// InforNexusConnectorOperatorAddition is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorAddition = "ADDITION"

	// InforNexusConnectorOperatorMultiplication is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorMultiplication = "MULTIPLICATION"

	// InforNexusConnectorOperatorDivision is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorDivision = "DIVISION"

	// InforNexusConnectorOperatorSubtraction is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorSubtraction = "SUBTRACTION"

	// InforNexusConnectorOperatorMaskAll is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorMaskAll = "MASK_ALL"

	// InforNexusConnectorOperatorMaskFirstN is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// InforNexusConnectorOperatorMaskLastN is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorMaskLastN = "MASK_LAST_N"

	// InforNexusConnectorOperatorValidateNonNull is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// InforNexusConnectorOperatorValidateNonZero is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// InforNexusConnectorOperatorValidateNonNegative is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// InforNexusConnectorOperatorValidateNumeric is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// InforNexusConnectorOperatorNoOp is a InforNexusConnectorOperator enum value
	InforNexusConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// MarketoConnectorOperatorProjection is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorProjection = "PROJECTION"

	// MarketoConnectorOperatorLessThan is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorLessThan = "LESS_THAN"

	// MarketoConnectorOperatorGreaterThan is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorGreaterThan = "GREATER_THAN"

	// MarketoConnectorOperatorBetween is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorBetween = "BETWEEN"

	// MarketoConnectorOperatorAddition is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorAddition = "ADDITION"

	// MarketoConnectorOperatorMultiplication is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorMultiplication = "MULTIPLICATION"

	// MarketoConnectorOperatorDivision is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorDivision = "DIVISION"

	// MarketoConnectorOperatorSubtraction is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorSubtraction = "SUBTRACTION"

	// MarketoConnectorOperatorMaskAll is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorMaskAll = "MASK_ALL"

	// MarketoConnectorOperatorMaskFirstN is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// MarketoConnectorOperatorMaskLastN is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorMaskLastN = "MASK_LAST_N"

	// MarketoConnectorOperatorValidateNonNull is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// MarketoConnectorOperatorValidateNonZero is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// MarketoConnectorOperatorValidateNonNegative is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// MarketoConnectorOperatorValidateNumeric is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// MarketoConnectorOperatorNoOp is a MarketoConnectorOperator enum value
	MarketoConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// OperatorProjection is a Operator enum value
	OperatorProjection = "PROJECTION"

	// OperatorLessThan is a Operator enum value
	OperatorLessThan = "LESS_THAN"

	// OperatorGreaterThan is a Operator enum value
	OperatorGreaterThan = "GREATER_THAN"

	// OperatorContains is a Operator enum value
	OperatorContains = "CONTAINS"

	// OperatorBetween is a Operator enum value
	OperatorBetween = "BETWEEN"

	// OperatorLessThanOrEqualTo is a Operator enum value
	OperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// OperatorGreaterThanOrEqualTo is a Operator enum value
	OperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// OperatorEqualTo is a Operator enum value
	OperatorEqualTo = "EQUAL_TO"

	// OperatorNotEqualTo is a Operator enum value
	OperatorNotEqualTo = "NOT_EQUAL_TO"

	// OperatorAddition is a Operator enum value
	OperatorAddition = "ADDITION"

	// OperatorMultiplication is a Operator enum value
	OperatorMultiplication = "MULTIPLICATION"

	// OperatorDivision is a Operator enum value
	OperatorDivision = "DIVISION"

	// OperatorSubtraction is a Operator enum value
	OperatorSubtraction = "SUBTRACTION"

	// OperatorMaskAll is a Operator enum value
	OperatorMaskAll = "MASK_ALL"

	// OperatorMaskFirstN is a Operator enum value
	OperatorMaskFirstN = "MASK_FIRST_N"

	// OperatorMaskLastN is a Operator enum value
	OperatorMaskLastN = "MASK_LAST_N"

	// OperatorValidateNonNull is a Operator enum value
	OperatorValidateNonNull = "VALIDATE_NON_NULL"

	// OperatorValidateNonZero is a Operator enum value
	OperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// OperatorValidateNonNegative is a Operator enum value
	OperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// OperatorValidateNumeric is a Operator enum value
	OperatorValidateNumeric = "VALIDATE_NUMERIC"

	// OperatorNoOp is a Operator enum value
	OperatorNoOp = "NO_OP"
)
View Source 
const (
	// OperatorPropertiesKeysValue is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysValue = "VALUE"

	// OperatorPropertiesKeysValues is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysValues = "VALUES"

	// OperatorPropertiesKeysDataType is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysDataType = "DATA_TYPE"

	// OperatorPropertiesKeysUpperBound is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysUpperBound = "UPPER_BOUND"

	// OperatorPropertiesKeysLowerBound is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysLowerBound = "LOWER_BOUND"

	// OperatorPropertiesKeysSourceDataType is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysSourceDataType = "SOURCE_DATA_TYPE"

	// OperatorPropertiesKeysDestinationDataType is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysDestinationDataType = "DESTINATION_DATA_TYPE"

	// OperatorPropertiesKeysValidationAction is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysValidationAction = "VALIDATION_ACTION"

	// OperatorPropertiesKeysMaskValue is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysMaskValue = "MASK_VALUE"

	// OperatorPropertiesKeysMaskLength is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysMaskLength = "MASK_LENGTH"

	// OperatorPropertiesKeysTruncateLength is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysTruncateLength = "TRUNCATE_LENGTH"

	// OperatorPropertiesKeysMathOperationFieldsOrder is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysMathOperationFieldsOrder = "MATH_OPERATION_FIELDS_ORDER"

	// OperatorPropertiesKeysConcatFormat is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysConcatFormat = "CONCAT_FORMAT"

	// OperatorPropertiesKeysSubfieldCategoryMap is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysSubfieldCategoryMap = "SUBFIELD_CATEGORY_MAP"

	// OperatorPropertiesKeysExcludeSourceFieldsList is a OperatorPropertiesKeys enum value
	OperatorPropertiesKeysExcludeSourceFieldsList = "EXCLUDE_SOURCE_FIELDS_LIST"
)
View Source 
const (
	// PrefixFormatYear is a PrefixFormat enum value
	PrefixFormatYear = "YEAR"

	// PrefixFormatMonth is a PrefixFormat enum value
	PrefixFormatMonth = "MONTH"

	// PrefixFormatDay is a PrefixFormat enum value
	PrefixFormatDay = "DAY"

	// PrefixFormatHour is a PrefixFormat enum value
	PrefixFormatHour = "HOUR"

	// PrefixFormatMinute is a PrefixFormat enum value
	PrefixFormatMinute = "MINUTE"
)
View Source 
const (
	// PrefixTypeFilename is a PrefixType enum value
	PrefixTypeFilename = "FILENAME"

	// PrefixTypePath is a PrefixType enum value
	PrefixTypePath = "PATH"

	// PrefixTypePathAndFilename is a PrefixType enum value
	PrefixTypePathAndFilename = "PATH_AND_FILENAME"
)
View Source 
const (
	// S3ConnectorOperatorProjection is a S3ConnectorOperator enum value
	S3ConnectorOperatorProjection = "PROJECTION"

	// S3ConnectorOperatorLessThan is a S3ConnectorOperator enum value
	S3ConnectorOperatorLessThan = "LESS_THAN"

	// S3ConnectorOperatorGreaterThan is a S3ConnectorOperator enum value
	S3ConnectorOperatorGreaterThan = "GREATER_THAN"

	// S3ConnectorOperatorBetween is a S3ConnectorOperator enum value
	S3ConnectorOperatorBetween = "BETWEEN"

	// S3ConnectorOperatorLessThanOrEqualTo is a S3ConnectorOperator enum value
	S3ConnectorOperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// S3ConnectorOperatorGreaterThanOrEqualTo is a S3ConnectorOperator enum value
	S3ConnectorOperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// S3ConnectorOperatorEqualTo is a S3ConnectorOperator enum value
	S3ConnectorOperatorEqualTo = "EQUAL_TO"

	// S3ConnectorOperatorNotEqualTo is a S3ConnectorOperator enum value
	S3ConnectorOperatorNotEqualTo = "NOT_EQUAL_TO"

	// S3ConnectorOperatorAddition is a S3ConnectorOperator enum value
	S3ConnectorOperatorAddition = "ADDITION"

	// S3ConnectorOperatorMultiplication is a S3ConnectorOperator enum value
	S3ConnectorOperatorMultiplication = "MULTIPLICATION"

	// S3ConnectorOperatorDivision is a S3ConnectorOperator enum value
	S3ConnectorOperatorDivision = "DIVISION"

	// S3ConnectorOperatorSubtraction is a S3ConnectorOperator enum value
	S3ConnectorOperatorSubtraction = "SUBTRACTION"

	// S3ConnectorOperatorMaskAll is a S3ConnectorOperator enum value
	S3ConnectorOperatorMaskAll = "MASK_ALL"

	// S3ConnectorOperatorMaskFirstN is a S3ConnectorOperator enum value
	S3ConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// S3ConnectorOperatorMaskLastN is a S3ConnectorOperator enum value
	S3ConnectorOperatorMaskLastN = "MASK_LAST_N"

	// S3ConnectorOperatorValidateNonNull is a S3ConnectorOperator enum value
	S3ConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// S3ConnectorOperatorValidateNonZero is a S3ConnectorOperator enum value
	S3ConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// S3ConnectorOperatorValidateNonNegative is a S3ConnectorOperator enum value
	S3ConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// S3ConnectorOperatorValidateNumeric is a S3ConnectorOperator enum value
	S3ConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// S3ConnectorOperatorNoOp is a S3ConnectorOperator enum value
	S3ConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// SalesforceConnectorOperatorProjection is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorProjection = "PROJECTION"

	// SalesforceConnectorOperatorLessThan is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorLessThan = "LESS_THAN"

	// SalesforceConnectorOperatorContains is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorContains = "CONTAINS"

	// SalesforceConnectorOperatorGreaterThan is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorGreaterThan = "GREATER_THAN"

	// SalesforceConnectorOperatorBetween is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorBetween = "BETWEEN"

	// SalesforceConnectorOperatorLessThanOrEqualTo is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// SalesforceConnectorOperatorGreaterThanOrEqualTo is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// SalesforceConnectorOperatorEqualTo is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorEqualTo = "EQUAL_TO"

	// SalesforceConnectorOperatorNotEqualTo is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorNotEqualTo = "NOT_EQUAL_TO"

	// SalesforceConnectorOperatorAddition is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorAddition = "ADDITION"

	// SalesforceConnectorOperatorMultiplication is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorMultiplication = "MULTIPLICATION"

	// SalesforceConnectorOperatorDivision is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorDivision = "DIVISION"

	// SalesforceConnectorOperatorSubtraction is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorSubtraction = "SUBTRACTION"

	// SalesforceConnectorOperatorMaskAll is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorMaskAll = "MASK_ALL"

	// SalesforceConnectorOperatorMaskFirstN is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// SalesforceConnectorOperatorMaskLastN is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorMaskLastN = "MASK_LAST_N"

	// SalesforceConnectorOperatorValidateNonNull is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// SalesforceConnectorOperatorValidateNonZero is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// SalesforceConnectorOperatorValidateNonNegative is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// SalesforceConnectorOperatorValidateNumeric is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// SalesforceConnectorOperatorNoOp is a SalesforceConnectorOperator enum value
	SalesforceConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// ScheduleFrequencyTypeByminute is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeByminute = "BYMINUTE"

	// ScheduleFrequencyTypeHourly is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeHourly = "HOURLY"

	// ScheduleFrequencyTypeDaily is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeDaily = "DAILY"

	// ScheduleFrequencyTypeWeekly is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeWeekly = "WEEKLY"

	// ScheduleFrequencyTypeMonthly is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeMonthly = "MONTHLY"

	// ScheduleFrequencyTypeOnce is a ScheduleFrequencyType enum value
	ScheduleFrequencyTypeOnce = "ONCE"
)
View Source 
const (
	// ServiceNowConnectorOperatorProjection is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorProjection = "PROJECTION"

	// ServiceNowConnectorOperatorContains is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorContains = "CONTAINS"

	// ServiceNowConnectorOperatorLessThan is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorLessThan = "LESS_THAN"

	// ServiceNowConnectorOperatorGreaterThan is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorGreaterThan = "GREATER_THAN"

	// ServiceNowConnectorOperatorBetween is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorBetween = "BETWEEN"

	// ServiceNowConnectorOperatorLessThanOrEqualTo is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// ServiceNowConnectorOperatorGreaterThanOrEqualTo is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// ServiceNowConnectorOperatorEqualTo is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorEqualTo = "EQUAL_TO"

	// ServiceNowConnectorOperatorNotEqualTo is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorNotEqualTo = "NOT_EQUAL_TO"

	// ServiceNowConnectorOperatorAddition is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorAddition = "ADDITION"

	// ServiceNowConnectorOperatorMultiplication is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorMultiplication = "MULTIPLICATION"

	// ServiceNowConnectorOperatorDivision is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorDivision = "DIVISION"

	// ServiceNowConnectorOperatorSubtraction is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorSubtraction = "SUBTRACTION"

	// ServiceNowConnectorOperatorMaskAll is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorMaskAll = "MASK_ALL"

	// ServiceNowConnectorOperatorMaskFirstN is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// ServiceNowConnectorOperatorMaskLastN is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorMaskLastN = "MASK_LAST_N"

	// ServiceNowConnectorOperatorValidateNonNull is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// ServiceNowConnectorOperatorValidateNonZero is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// ServiceNowConnectorOperatorValidateNonNegative is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// ServiceNowConnectorOperatorValidateNumeric is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// ServiceNowConnectorOperatorNoOp is a ServiceNowConnectorOperator enum value
	ServiceNowConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// SingularConnectorOperatorProjection is a SingularConnectorOperator enum value
	SingularConnectorOperatorProjection = "PROJECTION"

	// SingularConnectorOperatorEqualTo is a SingularConnectorOperator enum value
	SingularConnectorOperatorEqualTo = "EQUAL_TO"

	// SingularConnectorOperatorAddition is a SingularConnectorOperator enum value
	SingularConnectorOperatorAddition = "ADDITION"

	// SingularConnectorOperatorMultiplication is a SingularConnectorOperator enum value
	SingularConnectorOperatorMultiplication = "MULTIPLICATION"

	// SingularConnectorOperatorDivision is a SingularConnectorOperator enum value
	SingularConnectorOperatorDivision = "DIVISION"

	// SingularConnectorOperatorSubtraction is a SingularConnectorOperator enum value
	SingularConnectorOperatorSubtraction = "SUBTRACTION"

	// SingularConnectorOperatorMaskAll is a SingularConnectorOperator enum value
	SingularConnectorOperatorMaskAll = "MASK_ALL"

	// SingularConnectorOperatorMaskFirstN is a SingularConnectorOperator enum value
	SingularConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// SingularConnectorOperatorMaskLastN is a SingularConnectorOperator enum value
	SingularConnectorOperatorMaskLastN = "MASK_LAST_N"

	// SingularConnectorOperatorValidateNonNull is a SingularConnectorOperator enum value
	SingularConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// SingularConnectorOperatorValidateNonZero is a SingularConnectorOperator enum value
	SingularConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// SingularConnectorOperatorValidateNonNegative is a SingularConnectorOperator enum value
	SingularConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// SingularConnectorOperatorValidateNumeric is a SingularConnectorOperator enum value
	SingularConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// SingularConnectorOperatorNoOp is a SingularConnectorOperator enum value
	SingularConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// SlackConnectorOperatorProjection is a SlackConnectorOperator enum value
	SlackConnectorOperatorProjection = "PROJECTION"

	// SlackConnectorOperatorLessThan is a SlackConnectorOperator enum value
	SlackConnectorOperatorLessThan = "LESS_THAN"

	// SlackConnectorOperatorGreaterThan is a SlackConnectorOperator enum value
	SlackConnectorOperatorGreaterThan = "GREATER_THAN"

	// SlackConnectorOperatorBetween is a SlackConnectorOperator enum value
	SlackConnectorOperatorBetween = "BETWEEN"

	// SlackConnectorOperatorLessThanOrEqualTo is a SlackConnectorOperator enum value
	SlackConnectorOperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// SlackConnectorOperatorGreaterThanOrEqualTo is a SlackConnectorOperator enum value
	SlackConnectorOperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// SlackConnectorOperatorEqualTo is a SlackConnectorOperator enum value
	SlackConnectorOperatorEqualTo = "EQUAL_TO"

	// SlackConnectorOperatorAddition is a SlackConnectorOperator enum value
	SlackConnectorOperatorAddition = "ADDITION"

	// SlackConnectorOperatorMultiplication is a SlackConnectorOperator enum value
	SlackConnectorOperatorMultiplication = "MULTIPLICATION"

	// SlackConnectorOperatorDivision is a SlackConnectorOperator enum value
	SlackConnectorOperatorDivision = "DIVISION"

	// SlackConnectorOperatorSubtraction is a SlackConnectorOperator enum value
	SlackConnectorOperatorSubtraction = "SUBTRACTION"

	// SlackConnectorOperatorMaskAll is a SlackConnectorOperator enum value
	SlackConnectorOperatorMaskAll = "MASK_ALL"

	// SlackConnectorOperatorMaskFirstN is a SlackConnectorOperator enum value
	SlackConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// SlackConnectorOperatorMaskLastN is a SlackConnectorOperator enum value
	SlackConnectorOperatorMaskLastN = "MASK_LAST_N"

	// SlackConnectorOperatorValidateNonNull is a SlackConnectorOperator enum value
	SlackConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// SlackConnectorOperatorValidateNonZero is a SlackConnectorOperator enum value
	SlackConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// SlackConnectorOperatorValidateNonNegative is a SlackConnectorOperator enum value
	SlackConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// SlackConnectorOperatorValidateNumeric is a SlackConnectorOperator enum value
	SlackConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// SlackConnectorOperatorNoOp is a SlackConnectorOperator enum value
	SlackConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// TaskTypeArithmetic is a TaskType enum value
	TaskTypeArithmetic = "Arithmetic"

	// TaskTypeFilter is a TaskType enum value
	TaskTypeFilter = "Filter"

	// TaskTypeMap is a TaskType enum value
	TaskTypeMap = "Map"

	// TaskTypeMapAll is a TaskType enum value
	TaskTypeMapAll = "Map_all"

	// TaskTypeMask is a TaskType enum value
	TaskTypeMask = "Mask"

	// TaskTypeMerge is a TaskType enum value
	TaskTypeMerge = "Merge"

	// TaskTypeTruncate is a TaskType enum value
	TaskTypeTruncate = "Truncate"

	// TaskTypeValidate is a TaskType enum value
	TaskTypeValidate = "Validate"
)
View Source 
const (
	// TrendmicroConnectorOperatorProjection is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorProjection = "PROJECTION"

	// TrendmicroConnectorOperatorEqualTo is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorEqualTo = "EQUAL_TO"

	// TrendmicroConnectorOperatorAddition is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorAddition = "ADDITION"

	// TrendmicroConnectorOperatorMultiplication is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorMultiplication = "MULTIPLICATION"

	// TrendmicroConnectorOperatorDivision is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorDivision = "DIVISION"

	// TrendmicroConnectorOperatorSubtraction is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorSubtraction = "SUBTRACTION"

	// TrendmicroConnectorOperatorMaskAll is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorMaskAll = "MASK_ALL"

	// TrendmicroConnectorOperatorMaskFirstN is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// TrendmicroConnectorOperatorMaskLastN is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorMaskLastN = "MASK_LAST_N"

	// TrendmicroConnectorOperatorValidateNonNull is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// TrendmicroConnectorOperatorValidateNonZero is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// TrendmicroConnectorOperatorValidateNonNegative is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// TrendmicroConnectorOperatorValidateNumeric is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// TrendmicroConnectorOperatorNoOp is a TrendmicroConnectorOperator enum value
	TrendmicroConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// TriggerTypeScheduled is a TriggerType enum value
	TriggerTypeScheduled = "Scheduled"

	// TriggerTypeEvent is a TriggerType enum value
	TriggerTypeEvent = "Event"

	// TriggerTypeOnDemand is a TriggerType enum value
	TriggerTypeOnDemand = "OnDemand"
)
View Source 
const (
	// VeevaConnectorOperatorProjection is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorProjection = "PROJECTION"

	// VeevaConnectorOperatorLessThan is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorLessThan = "LESS_THAN"

	// VeevaConnectorOperatorGreaterThan is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorGreaterThan = "GREATER_THAN"

	// VeevaConnectorOperatorContains is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorContains = "CONTAINS"

	// VeevaConnectorOperatorBetween is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorBetween = "BETWEEN"

	// VeevaConnectorOperatorLessThanOrEqualTo is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorLessThanOrEqualTo = "LESS_THAN_OR_EQUAL_TO"

	// VeevaConnectorOperatorGreaterThanOrEqualTo is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorGreaterThanOrEqualTo = "GREATER_THAN_OR_EQUAL_TO"

	// VeevaConnectorOperatorEqualTo is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorEqualTo = "EQUAL_TO"

	// VeevaConnectorOperatorNotEqualTo is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorNotEqualTo = "NOT_EQUAL_TO"

	// VeevaConnectorOperatorAddition is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorAddition = "ADDITION"

	// VeevaConnectorOperatorMultiplication is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorMultiplication = "MULTIPLICATION"

	// VeevaConnectorOperatorDivision is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorDivision = "DIVISION"

	// VeevaConnectorOperatorSubtraction is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorSubtraction = "SUBTRACTION"

	// VeevaConnectorOperatorMaskAll is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorMaskAll = "MASK_ALL"

	// VeevaConnectorOperatorMaskFirstN is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// VeevaConnectorOperatorMaskLastN is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorMaskLastN = "MASK_LAST_N"

	// VeevaConnectorOperatorValidateNonNull is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// VeevaConnectorOperatorValidateNonZero is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// VeevaConnectorOperatorValidateNonNegative is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// VeevaConnectorOperatorValidateNumeric is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// VeevaConnectorOperatorNoOp is a VeevaConnectorOperator enum value
	VeevaConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (
	// WriteOperationTypeInsert is a WriteOperationType enum value
	WriteOperationTypeInsert = "INSERT"

	// WriteOperationTypeUpsert is a WriteOperationType enum value
	WriteOperationTypeUpsert = "UPSERT"

	// WriteOperationTypeUpdate is a WriteOperationType enum value
	WriteOperationTypeUpdate = "UPDATE"
)

The possible write operations in the destination connector. When this value is not provided, this defaults to the INSERT operation.

View Source 
const (
	// ZendeskConnectorOperatorProjection is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorProjection = "PROJECTION"

	// ZendeskConnectorOperatorGreaterThan is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorGreaterThan = "GREATER_THAN"

	// ZendeskConnectorOperatorAddition is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorAddition = "ADDITION"

	// ZendeskConnectorOperatorMultiplication is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorMultiplication = "MULTIPLICATION"

	// ZendeskConnectorOperatorDivision is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorDivision = "DIVISION"

	// ZendeskConnectorOperatorSubtraction is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorSubtraction = "SUBTRACTION"

	// ZendeskConnectorOperatorMaskAll is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorMaskAll = "MASK_ALL"

	// ZendeskConnectorOperatorMaskFirstN is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorMaskFirstN = "MASK_FIRST_N"

	// ZendeskConnectorOperatorMaskLastN is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorMaskLastN = "MASK_LAST_N"

	// ZendeskConnectorOperatorValidateNonNull is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorValidateNonNull = "VALIDATE_NON_NULL"

	// ZendeskConnectorOperatorValidateNonZero is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorValidateNonZero = "VALIDATE_NON_ZERO"

	// ZendeskConnectorOperatorValidateNonNegative is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorValidateNonNegative = "VALIDATE_NON_NEGATIVE"

	// ZendeskConnectorOperatorValidateNumeric is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorValidateNumeric = "VALIDATE_NUMERIC"

	// ZendeskConnectorOperatorNoOp is a ZendeskConnectorOperator enum value
	ZendeskConnectorOperatorNoOp = "NO_OP"
)
View Source 
const (

	// ErrCodeConflictException for service response error code
	// "ConflictException".
	//
	// There was a conflict when processing the request (for example, a flow with
	// the given name already exists within the account. Check for conflicting resource
	// names and try again.
	ErrCodeConflictException = "ConflictException"

	// ErrCodeConnectorAuthenticationException for service response error code
	// "ConnectorAuthenticationException".
	//
	// An error occurred when authenticating with the connector endpoint.
	ErrCodeConnectorAuthenticationException = "ConnectorAuthenticationException"

	// ErrCodeConnectorServerException for service response error code
	// "ConnectorServerException".
	//
	// An error occurred when retrieving data from the connector endpoint.
	ErrCodeConnectorServerException = "ConnectorServerException"

	// ErrCodeInternalServerException for service response error code
	// "InternalServerException".
	//
	// An internal service error occurred during the processing of your request.
	// Try again later.
	ErrCodeInternalServerException = "InternalServerException"

	// ErrCodeResourceNotFoundException for service response error code
	// "ResourceNotFoundException".
	//
	// The resource specified in the request (such as the source or destination
	// connector profile) is not found.
	ErrCodeResourceNotFoundException = "ResourceNotFoundException"

	// ErrCodeServiceQuotaExceededException for service response error code
	// "ServiceQuotaExceededException".
	//
	// The request would cause a service quota (such as the number of flows) to
	// be exceeded.
	ErrCodeServiceQuotaExceededException = "ServiceQuotaExceededException"

	// ErrCodeUnsupportedOperationException for service response error code
	// "UnsupportedOperationException".
	//
	// The requested operation is not supported for the current flow.
	ErrCodeUnsupportedOperationException = "UnsupportedOperationException"

	// ErrCodeValidationException for service response error code
	// "ValidationException".
	//
	// The request has invalid or missing parameters.
	ErrCodeValidationException = "ValidationException"
)
View Source 
const (
	ServiceName = "Appflow" // Name of service.
	EndpointsID = "appflow" // ID to lookup a service endpoint with.
	ServiceID   = "Appflow" // ServiceID is a unique identifier of a specific service.
)

Service information constants

View Source 
const (
	// AmplitudeConnectorOperatorBetween is a AmplitudeConnectorOperator enum value
	AmplitudeConnectorOperatorBetween = "BETWEEN"
)

Variables

This section is empty.

Functions

func AggregationType_Values 

func AggregationType_Values() []string

AggregationType_Values returns all elements of the AggregationType enum

func AmplitudeConnectorOperator_Values 

func AmplitudeConnectorOperator_Values() []string

AmplitudeConnectorOperator_Values returns all elements of the AmplitudeConnectorOperator enum

func ConnectionMode_Values 

func ConnectionMode_Values() []string

ConnectionMode_Values returns all elements of the ConnectionMode enum

func ConnectorType_Values 

func ConnectorType_Values() []string

ConnectorType_Values returns all elements of the ConnectorType enum

func DataPullMode_Values 

func DataPullMode_Values() []string

DataPullMode_Values returns all elements of the DataPullMode enum

func DatadogConnectorOperator_Values 

func DatadogConnectorOperator_Values() []string

DatadogConnectorOperator_Values returns all elements of the DatadogConnectorOperator enum

func DynatraceConnectorOperator_Values 

func DynatraceConnectorOperator_Values() []string

DynatraceConnectorOperator_Values returns all elements of the DynatraceConnectorOperator enum

func ExecutionStatus_Values 

func ExecutionStatus_Values() []string

ExecutionStatus_Values returns all elements of the ExecutionStatus enum

func FileType_Values 

func FileType_Values() []string

FileType_Values returns all elements of the FileType enum

func FlowStatus_Values 

func FlowStatus_Values() []string

FlowStatus_Values returns all elements of the FlowStatus enum

func GoogleAnalyticsConnectorOperator_Values 

func GoogleAnalyticsConnectorOperator_Values() []string

GoogleAnalyticsConnectorOperator_Values returns all elements of the GoogleAnalyticsConnectorOperator enum

func InforNexusConnectorOperator_Values 

func InforNexusConnectorOperator_Values() []string

InforNexusConnectorOperator_Values returns all elements of the InforNexusConnectorOperator enum

func MarketoConnectorOperator_Values 

func MarketoConnectorOperator_Values() []string

MarketoConnectorOperator_Values returns all elements of the MarketoConnectorOperator enum

func OperatorPropertiesKeys_Values 

func OperatorPropertiesKeys_Values() []string

OperatorPropertiesKeys_Values returns all elements of the OperatorPropertiesKeys enum

func Operator_Values 

func Operator_Values() []string

Operator_Values returns all elements of the Operator enum

func PrefixFormat_Values 

func PrefixFormat_Values() []string

PrefixFormat_Values returns all elements of the PrefixFormat enum

func PrefixType_Values 

func PrefixType_Values() []string

PrefixType_Values returns all elements of the PrefixType enum

func S3ConnectorOperator_Values 

func S3ConnectorOperator_Values() []string

S3ConnectorOperator_Values returns all elements of the S3ConnectorOperator enum

func SalesforceConnectorOperator_Values 

func SalesforceConnectorOperator_Values() []string

SalesforceConnectorOperator_Values returns all elements of the SalesforceConnectorOperator enum

func ScheduleFrequencyType_Values 

func ScheduleFrequencyType_Values() []string

ScheduleFrequencyType_Values returns all elements of the ScheduleFrequencyType enum

func ServiceNowConnectorOperator_Values 

func ServiceNowConnectorOperator_Values() []string

ServiceNowConnectorOperator_Values returns all elements of the ServiceNowConnectorOperator enum

func SingularConnectorOperator_Values 

func SingularConnectorOperator_Values() []string

SingularConnectorOperator_Values returns all elements of the SingularConnectorOperator enum

func SlackConnectorOperator_Values 

func SlackConnectorOperator_Values() []string

SlackConnectorOperator_Values returns all elements of the SlackConnectorOperator enum

func TaskType_Values 

func TaskType_Values() []string

TaskType_Values returns all elements of the TaskType enum

func TrendmicroConnectorOperator_Values 

func TrendmicroConnectorOperator_Values() []string

TrendmicroConnectorOperator_Values returns all elements of the TrendmicroConnectorOperator enum

func TriggerType_Values 

func TriggerType_Values() []string

TriggerType_Values returns all elements of the TriggerType enum

func VeevaConnectorOperator_Values 

func VeevaConnectorOperator_Values() []string

VeevaConnectorOperator_Values returns all elements of the VeevaConnectorOperator enum

func WriteOperationType_Values added in v1.35.13 

func WriteOperationType_Values() []string

WriteOperationType_Values returns all elements of the WriteOperationType enum

func ZendeskConnectorOperator_Values 

func ZendeskConnectorOperator_Values() []string

ZendeskConnectorOperator_Values returns all elements of the ZendeskConnectorOperator enum

Types

type AggregationConfig 

type AggregationConfig struct {

	// Specifies whether Amazon AppFlow aggregates the flow records into a single
	// file, or leave them unaggregated.
	AggregationType *string `locationName:"aggregationType" type:"string" enum:"AggregationType"`
	// contains filtered or unexported fields
}

The aggregation settings that you can use to customize the output format of your flow data.

func (AggregationConfig) GoString 

func (s AggregationConfig) GoString() string

GoString returns the string representation

func (*AggregationConfig) SetAggregationType 

func (s *AggregationConfig) SetAggregationType(v string) *AggregationConfig

SetAggregationType sets the AggregationType field's value.

func (AggregationConfig) String 

func (s AggregationConfig) String() string

String returns the string representation

type AmplitudeConnectorProfileCredentials 

type AmplitudeConnectorProfileCredentials struct {

	// A unique alphanumeric identifier used to authenticate a user, developer,
	// or calling program to your API.
	//
	// ApiKey is a required field
	ApiKey *string `locationName:"apiKey" type:"string" required:"true"`

	// The Secret Access Key portion of the credentials.
	//
	// SecretKey is a required field
	SecretKey *string `locationName:"secretKey" type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

The connector-specific credentials required when using Amplitude.

func (AmplitudeConnectorProfileCredentials) GoString 

func (s AmplitudeConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*AmplitudeConnectorProfileCredentials) SetApiKey 

func (s *AmplitudeConnectorProfileCredentials) SetApiKey(v string) *AmplitudeConnectorProfileCredentials

SetApiKey sets the ApiKey field's value.

func (*AmplitudeConnectorProfileCredentials) SetSecretKey 

func (s *AmplitudeConnectorProfileCredentials) SetSecretKey(v string) *AmplitudeConnectorProfileCredentials

SetSecretKey sets the SecretKey field's value.

func (AmplitudeConnectorProfileCredentials) String 

func (s AmplitudeConnectorProfileCredentials) String() string

String returns the string representation

func (*AmplitudeConnectorProfileCredentials) Validate 

func (s *AmplitudeConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type AmplitudeConnectorProfileProperties 

type AmplitudeConnectorProfileProperties struct {
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Amplitude.

func (AmplitudeConnectorProfileProperties) GoString 

func (s AmplitudeConnectorProfileProperties) GoString() string

GoString returns the string representation

func (AmplitudeConnectorProfileProperties) String 

func (s AmplitudeConnectorProfileProperties) String() string

String returns the string representation

type AmplitudeMetadata 

type AmplitudeMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Amplitude.

func (AmplitudeMetadata) GoString 

func (s AmplitudeMetadata) GoString() string

GoString returns the string representation

func (AmplitudeMetadata) String 

func (s AmplitudeMetadata) String() string

String returns the string representation

type AmplitudeSourceProperties 

type AmplitudeSourceProperties struct {

	// The object specified in the Amplitude flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Amplitude is being used as a source.

func (AmplitudeSourceProperties) GoString 

func (s AmplitudeSourceProperties) GoString() string

GoString returns the string representation

func (*AmplitudeSourceProperties) SetObject 

func (s *AmplitudeSourceProperties) SetObject(v string) *AmplitudeSourceProperties

SetObject sets the Object field's value.

func (AmplitudeSourceProperties) String 

func (s AmplitudeSourceProperties) String() string

String returns the string representation

func (*AmplitudeSourceProperties) Validate 

func (s *AmplitudeSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type Appflow 

type Appflow struct {
	*client.Client
}

Appflow provides the API operation methods for making requests to Amazon Appflow. See this package's package overview docs for details on the service.

Appflow methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New 

func New(p client.ConfigProvider, cfgs ...*aws.Config) *Appflow

New creates a new instance of the Appflow client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example: 

mySession := session.Must(session.NewSession())

// Create a Appflow client from just a session.
svc := appflow.New(mySession)

// Create a Appflow client with additional configuration
svc := appflow.New(mySession, aws.NewConfig().WithRegion("us-west-2"))

func (*Appflow) CreateConnectorProfile 

func (c *Appflow) CreateConnectorProfile(input *CreateConnectorProfileInput) (*CreateConnectorProfileOutput, error)

CreateConnectorProfile API operation for Amazon Appflow.

Creates a new connector profile associated with your AWS account. There is a soft quota of 100 connector profiles per AWS account. If you need more connector profiles than this quota allows, you can submit a request to the Amazon AppFlow team through the Amazon AppFlow support channel.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation CreateConnectorProfile for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • ServiceQuotaExceededException The request would cause a service quota (such as the number of flows) to be exceeded.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/CreateConnectorProfile

func (*Appflow) CreateConnectorProfileRequest 

func (c *Appflow) CreateConnectorProfileRequest(input *CreateConnectorProfileInput) (req *request.Request, output *CreateConnectorProfileOutput)

CreateConnectorProfileRequest generates a "aws/request.Request" representing the client's request for the CreateConnectorProfile operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateConnectorProfile for more information on using the CreateConnectorProfile API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the CreateConnectorProfileRequest method.
req, resp := client.CreateConnectorProfileRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/CreateConnectorProfile

func (*Appflow) CreateConnectorProfileWithContext 

func (c *Appflow) CreateConnectorProfileWithContext(ctx aws.Context, input *CreateConnectorProfileInput, opts ...request.Option) (*CreateConnectorProfileOutput, error)

CreateConnectorProfileWithContext is the same as CreateConnectorProfile with the addition of the ability to pass a context and additional request options.

See CreateConnectorProfile for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) CreateFlow 

func (c *Appflow) CreateFlow(input *CreateFlowInput) (*CreateFlowOutput, error)

CreateFlow API operation for Amazon Appflow.

Enables your application to create a new flow using Amazon AppFlow. You must create a connector profile before calling this API. Please note that the Request Syntax below shows syntax for multiple destinations, however, you can only transfer data to one item in this list at a time. Amazon AppFlow does not currently support flows to multiple destinations at once.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation CreateFlow for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ServiceQuotaExceededException The request would cause a service quota (such as the number of flows) to be exceeded.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • ConnectorServerException An error occurred when retrieving data from the connector endpoint.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/CreateFlow

func (*Appflow) CreateFlowRequest 

func (c *Appflow) CreateFlowRequest(input *CreateFlowInput) (req *request.Request, output *CreateFlowOutput)

CreateFlowRequest generates a "aws/request.Request" representing the client's request for the CreateFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateFlow for more information on using the CreateFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the CreateFlowRequest method.
req, resp := client.CreateFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/CreateFlow

func (*Appflow) CreateFlowWithContext 

func (c *Appflow) CreateFlowWithContext(ctx aws.Context, input *CreateFlowInput, opts ...request.Option) (*CreateFlowOutput, error)

CreateFlowWithContext is the same as CreateFlow with the addition of the ability to pass a context and additional request options.

See CreateFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DeleteConnectorProfile 

func (c *Appflow) DeleteConnectorProfile(input *DeleteConnectorProfileInput) (*DeleteConnectorProfileOutput, error)

DeleteConnectorProfile API operation for Amazon Appflow.

Enables you to delete an existing connector profile.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DeleteConnectorProfile for usage and error information.

Returned Error Types:

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DeleteConnectorProfile

func (*Appflow) DeleteConnectorProfileRequest 

func (c *Appflow) DeleteConnectorProfileRequest(input *DeleteConnectorProfileInput) (req *request.Request, output *DeleteConnectorProfileOutput)

DeleteConnectorProfileRequest generates a "aws/request.Request" representing the client's request for the DeleteConnectorProfile operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteConnectorProfile for more information on using the DeleteConnectorProfile API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DeleteConnectorProfileRequest method.
req, resp := client.DeleteConnectorProfileRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DeleteConnectorProfile

func (*Appflow) DeleteConnectorProfileWithContext 

func (c *Appflow) DeleteConnectorProfileWithContext(ctx aws.Context, input *DeleteConnectorProfileInput, opts ...request.Option) (*DeleteConnectorProfileOutput, error)

DeleteConnectorProfileWithContext is the same as DeleteConnectorProfile with the addition of the ability to pass a context and additional request options.

See DeleteConnectorProfile for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DeleteFlow 

func (c *Appflow) DeleteFlow(input *DeleteFlowInput) (*DeleteFlowOutput, error)

DeleteFlow API operation for Amazon Appflow.

Enables your application to delete an existing flow. Before deleting the flow, Amazon AppFlow validates the request by checking the flow configuration and status. You can delete flows one at a time.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DeleteFlow for usage and error information.

Returned Error Types:

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DeleteFlow

func (*Appflow) DeleteFlowRequest 

func (c *Appflow) DeleteFlowRequest(input *DeleteFlowInput) (req *request.Request, output *DeleteFlowOutput)

DeleteFlowRequest generates a "aws/request.Request" representing the client's request for the DeleteFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteFlow for more information on using the DeleteFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DeleteFlowRequest method.
req, resp := client.DeleteFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DeleteFlow

func (*Appflow) DeleteFlowWithContext 

func (c *Appflow) DeleteFlowWithContext(ctx aws.Context, input *DeleteFlowInput, opts ...request.Option) (*DeleteFlowOutput, error)

DeleteFlowWithContext is the same as DeleteFlow with the addition of the ability to pass a context and additional request options.

See DeleteFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeConnectorEntity 

func (c *Appflow) DescribeConnectorEntity(input *DescribeConnectorEntityInput) (*DescribeConnectorEntityOutput, error)

DescribeConnectorEntity API operation for Amazon Appflow.

Provides details regarding the entity used with the connector, with a description of the data model for each entity.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DescribeConnectorEntity for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • ConnectorServerException An error occurred when retrieving data from the connector endpoint.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectorEntity

func (*Appflow) DescribeConnectorEntityRequest 

func (c *Appflow) DescribeConnectorEntityRequest(input *DescribeConnectorEntityInput) (req *request.Request, output *DescribeConnectorEntityOutput)

DescribeConnectorEntityRequest generates a "aws/request.Request" representing the client's request for the DescribeConnectorEntity operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeConnectorEntity for more information on using the DescribeConnectorEntity API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeConnectorEntityRequest method.
req, resp := client.DescribeConnectorEntityRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectorEntity

func (*Appflow) DescribeConnectorEntityWithContext 

func (c *Appflow) DescribeConnectorEntityWithContext(ctx aws.Context, input *DescribeConnectorEntityInput, opts ...request.Option) (*DescribeConnectorEntityOutput, error)

DescribeConnectorEntityWithContext is the same as DescribeConnectorEntity with the addition of the ability to pass a context and additional request options.

See DescribeConnectorEntity for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeConnectorProfiles 

func (c *Appflow) DescribeConnectorProfiles(input *DescribeConnectorProfilesInput) (*DescribeConnectorProfilesOutput, error)

DescribeConnectorProfiles API operation for Amazon Appflow.

Returns a list of connector-profile details matching the provided connector-profile names and connector-types. Both input lists are optional, and you can use them to filter the result.

If no names or connector-types are provided, returns all connector profiles in a paginated form. If there is no match, this operation returns an empty list.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DescribeConnectorProfiles for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectorProfiles

func (*Appflow) DescribeConnectorProfilesPages 

func (c *Appflow) DescribeConnectorProfilesPages(input *DescribeConnectorProfilesInput, fn func(*DescribeConnectorProfilesOutput, bool) bool) error

DescribeConnectorProfilesPages iterates over the pages of a DescribeConnectorProfiles operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeConnectorProfiles method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a DescribeConnectorProfiles operation.
pageNum := 0
err := client.DescribeConnectorProfilesPages(params,
    func(page *appflow.DescribeConnectorProfilesOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Appflow) DescribeConnectorProfilesPagesWithContext 

func (c *Appflow) DescribeConnectorProfilesPagesWithContext(ctx aws.Context, input *DescribeConnectorProfilesInput, fn func(*DescribeConnectorProfilesOutput, bool) bool, opts ...request.Option) error

DescribeConnectorProfilesPagesWithContext same as DescribeConnectorProfilesPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeConnectorProfilesRequest 

func (c *Appflow) DescribeConnectorProfilesRequest(input *DescribeConnectorProfilesInput) (req *request.Request, output *DescribeConnectorProfilesOutput)

DescribeConnectorProfilesRequest generates a "aws/request.Request" representing the client's request for the DescribeConnectorProfiles operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeConnectorProfiles for more information on using the DescribeConnectorProfiles API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeConnectorProfilesRequest method.
req, resp := client.DescribeConnectorProfilesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectorProfiles

func (*Appflow) DescribeConnectorProfilesWithContext 

func (c *Appflow) DescribeConnectorProfilesWithContext(ctx aws.Context, input *DescribeConnectorProfilesInput, opts ...request.Option) (*DescribeConnectorProfilesOutput, error)

DescribeConnectorProfilesWithContext is the same as DescribeConnectorProfiles with the addition of the ability to pass a context and additional request options.

See DescribeConnectorProfiles for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeConnectors 

func (c *Appflow) DescribeConnectors(input *DescribeConnectorsInput) (*DescribeConnectorsOutput, error)

DescribeConnectors API operation for Amazon Appflow.

Describes the connectors vended by Amazon AppFlow for specified connector types. If you don't specify a connector type, this operation describes all connectors vended by Amazon AppFlow. If there are more connectors than can be returned in one page, the response contains a nextToken object, which can be be passed in to the next call to the DescribeConnectors API operation to retrieve the next page.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DescribeConnectors for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectors

func (*Appflow) DescribeConnectorsPages 

func (c *Appflow) DescribeConnectorsPages(input *DescribeConnectorsInput, fn func(*DescribeConnectorsOutput, bool) bool) error

DescribeConnectorsPages iterates over the pages of a DescribeConnectors operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeConnectors method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a DescribeConnectors operation.
pageNum := 0
err := client.DescribeConnectorsPages(params,
    func(page *appflow.DescribeConnectorsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Appflow) DescribeConnectorsPagesWithContext 

func (c *Appflow) DescribeConnectorsPagesWithContext(ctx aws.Context, input *DescribeConnectorsInput, fn func(*DescribeConnectorsOutput, bool) bool, opts ...request.Option) error

DescribeConnectorsPagesWithContext same as DescribeConnectorsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeConnectorsRequest 

func (c *Appflow) DescribeConnectorsRequest(input *DescribeConnectorsInput) (req *request.Request, output *DescribeConnectorsOutput)

DescribeConnectorsRequest generates a "aws/request.Request" representing the client's request for the DescribeConnectors operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeConnectors for more information on using the DescribeConnectors API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeConnectorsRequest method.
req, resp := client.DescribeConnectorsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeConnectors

func (*Appflow) DescribeConnectorsWithContext 

func (c *Appflow) DescribeConnectorsWithContext(ctx aws.Context, input *DescribeConnectorsInput, opts ...request.Option) (*DescribeConnectorsOutput, error)

DescribeConnectorsWithContext is the same as DescribeConnectors with the addition of the ability to pass a context and additional request options.

See DescribeConnectors for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeFlow 

func (c *Appflow) DescribeFlow(input *DescribeFlowInput) (*DescribeFlowOutput, error)

DescribeFlow API operation for Amazon Appflow.

Provides a description of the specified flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DescribeFlow for usage and error information.

Returned Error Types:

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeFlow

func (*Appflow) DescribeFlowExecutionRecords 

func (c *Appflow) DescribeFlowExecutionRecords(input *DescribeFlowExecutionRecordsInput) (*DescribeFlowExecutionRecordsOutput, error)

DescribeFlowExecutionRecords API operation for Amazon Appflow.

Fetches the execution history of the flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation DescribeFlowExecutionRecords for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeFlowExecutionRecords

func (*Appflow) DescribeFlowExecutionRecordsPages 

func (c *Appflow) DescribeFlowExecutionRecordsPages(input *DescribeFlowExecutionRecordsInput, fn func(*DescribeFlowExecutionRecordsOutput, bool) bool) error

DescribeFlowExecutionRecordsPages iterates over the pages of a DescribeFlowExecutionRecords operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See DescribeFlowExecutionRecords method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a DescribeFlowExecutionRecords operation.
pageNum := 0
err := client.DescribeFlowExecutionRecordsPages(params,
    func(page *appflow.DescribeFlowExecutionRecordsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Appflow) DescribeFlowExecutionRecordsPagesWithContext 

func (c *Appflow) DescribeFlowExecutionRecordsPagesWithContext(ctx aws.Context, input *DescribeFlowExecutionRecordsInput, fn func(*DescribeFlowExecutionRecordsOutput, bool) bool, opts ...request.Option) error

DescribeFlowExecutionRecordsPagesWithContext same as DescribeFlowExecutionRecordsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeFlowExecutionRecordsRequest 

func (c *Appflow) DescribeFlowExecutionRecordsRequest(input *DescribeFlowExecutionRecordsInput) (req *request.Request, output *DescribeFlowExecutionRecordsOutput)

DescribeFlowExecutionRecordsRequest generates a "aws/request.Request" representing the client's request for the DescribeFlowExecutionRecords operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeFlowExecutionRecords for more information on using the DescribeFlowExecutionRecords API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeFlowExecutionRecordsRequest method.
req, resp := client.DescribeFlowExecutionRecordsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeFlowExecutionRecords

func (*Appflow) DescribeFlowExecutionRecordsWithContext 

func (c *Appflow) DescribeFlowExecutionRecordsWithContext(ctx aws.Context, input *DescribeFlowExecutionRecordsInput, opts ...request.Option) (*DescribeFlowExecutionRecordsOutput, error)

DescribeFlowExecutionRecordsWithContext is the same as DescribeFlowExecutionRecords with the addition of the ability to pass a context and additional request options.

See DescribeFlowExecutionRecords for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) DescribeFlowRequest 

func (c *Appflow) DescribeFlowRequest(input *DescribeFlowInput) (req *request.Request, output *DescribeFlowOutput)

DescribeFlowRequest generates a "aws/request.Request" representing the client's request for the DescribeFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeFlow for more information on using the DescribeFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeFlowRequest method.
req, resp := client.DescribeFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/DescribeFlow

func (*Appflow) DescribeFlowWithContext 

func (c *Appflow) DescribeFlowWithContext(ctx aws.Context, input *DescribeFlowInput, opts ...request.Option) (*DescribeFlowOutput, error)

DescribeFlowWithContext is the same as DescribeFlow with the addition of the ability to pass a context and additional request options.

See DescribeFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) ListConnectorEntities 

func (c *Appflow) ListConnectorEntities(input *ListConnectorEntitiesInput) (*ListConnectorEntitiesOutput, error)

ListConnectorEntities API operation for Amazon Appflow.

Returns the list of available connector entities supported by Amazon AppFlow. For example, you can query Salesforce for Account and Opportunity entities, or query ServiceNow for the Incident entity.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation ListConnectorEntities for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • ConnectorServerException An error occurred when retrieving data from the connector endpoint.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListConnectorEntities

func (*Appflow) ListConnectorEntitiesRequest 

func (c *Appflow) ListConnectorEntitiesRequest(input *ListConnectorEntitiesInput) (req *request.Request, output *ListConnectorEntitiesOutput)

ListConnectorEntitiesRequest generates a "aws/request.Request" representing the client's request for the ListConnectorEntities operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListConnectorEntities for more information on using the ListConnectorEntities API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListConnectorEntitiesRequest method.
req, resp := client.ListConnectorEntitiesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListConnectorEntities

func (*Appflow) ListConnectorEntitiesWithContext 

func (c *Appflow) ListConnectorEntitiesWithContext(ctx aws.Context, input *ListConnectorEntitiesInput, opts ...request.Option) (*ListConnectorEntitiesOutput, error)

ListConnectorEntitiesWithContext is the same as ListConnectorEntities with the addition of the ability to pass a context and additional request options.

See ListConnectorEntities for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) ListFlows 

func (c *Appflow) ListFlows(input *ListFlowsInput) (*ListFlowsOutput, error)

ListFlows API operation for Amazon Appflow.

Lists all of the flows associated with your account.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation ListFlows for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListFlows

func (*Appflow) ListFlowsPages 

func (c *Appflow) ListFlowsPages(input *ListFlowsInput, fn func(*ListFlowsOutput, bool) bool) error

ListFlowsPages iterates over the pages of a ListFlows operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListFlows method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a ListFlows operation.
pageNum := 0
err := client.ListFlowsPages(params,
    func(page *appflow.ListFlowsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*Appflow) ListFlowsPagesWithContext 

func (c *Appflow) ListFlowsPagesWithContext(ctx aws.Context, input *ListFlowsInput, fn func(*ListFlowsOutput, bool) bool, opts ...request.Option) error

ListFlowsPagesWithContext same as ListFlowsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) ListFlowsRequest 

func (c *Appflow) ListFlowsRequest(input *ListFlowsInput) (req *request.Request, output *ListFlowsOutput)

ListFlowsRequest generates a "aws/request.Request" representing the client's request for the ListFlows operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListFlows for more information on using the ListFlows API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListFlowsRequest method.
req, resp := client.ListFlowsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListFlows

func (*Appflow) ListFlowsWithContext 

func (c *Appflow) ListFlowsWithContext(ctx aws.Context, input *ListFlowsInput, opts ...request.Option) (*ListFlowsOutput, error)

ListFlowsWithContext is the same as ListFlows with the addition of the ability to pass a context and additional request options.

See ListFlows for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) ListTagsForResource 

func (c *Appflow) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for Amazon Appflow.

Retrieves the tags that are associated with a specified flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation ListTagsForResource for usage and error information.

Returned Error Types:

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListTagsForResource

func (*Appflow) ListTagsForResourceRequest 

func (c *Appflow) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/ListTagsForResource

func (*Appflow) ListTagsForResourceWithContext 

func (c *Appflow) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) StartFlow 

func (c *Appflow) StartFlow(input *StartFlowInput) (*StartFlowOutput, error)

StartFlow API operation for Amazon Appflow.

Activates an existing flow. For on-demand flows, this operation runs the flow immediately. For schedule and event-triggered flows, this operation activates the flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation StartFlow for usage and error information.

Returned Error Types:

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

  • ServiceQuotaExceededException The request would cause a service quota (such as the number of flows) to be exceeded.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/StartFlow

func (*Appflow) StartFlowRequest 

func (c *Appflow) StartFlowRequest(input *StartFlowInput) (req *request.Request, output *StartFlowOutput)

StartFlowRequest generates a "aws/request.Request" representing the client's request for the StartFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StartFlow for more information on using the StartFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the StartFlowRequest method.
req, resp := client.StartFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/StartFlow

func (*Appflow) StartFlowWithContext 

func (c *Appflow) StartFlowWithContext(ctx aws.Context, input *StartFlowInput, opts ...request.Option) (*StartFlowOutput, error)

StartFlowWithContext is the same as StartFlow with the addition of the ability to pass a context and additional request options.

See StartFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) StopFlow 

func (c *Appflow) StopFlow(input *StopFlowInput) (*StopFlowOutput, error)

StopFlow API operation for Amazon Appflow.

Deactivates the existing flow. For on-demand flows, this operation returns an unsupportedOperationException error message. For schedule and event-triggered flows, this operation deactivates the flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation StopFlow for usage and error information.

Returned Error Types:

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • UnsupportedOperationException The requested operation is not supported for the current flow.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/StopFlow

func (*Appflow) StopFlowRequest 

func (c *Appflow) StopFlowRequest(input *StopFlowInput) (req *request.Request, output *StopFlowOutput)

StopFlowRequest generates a "aws/request.Request" representing the client's request for the StopFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StopFlow for more information on using the StopFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the StopFlowRequest method.
req, resp := client.StopFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/StopFlow

func (*Appflow) StopFlowWithContext 

func (c *Appflow) StopFlowWithContext(ctx aws.Context, input *StopFlowInput, opts ...request.Option) (*StopFlowOutput, error)

StopFlowWithContext is the same as StopFlow with the addition of the ability to pass a context and additional request options.

See StopFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) TagResource 

func (c *Appflow) TagResource(input *TagResourceInput) (*TagResourceOutput, error)

TagResource API operation for Amazon Appflow.

Applies a tag to the specified flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation TagResource for usage and error information.

Returned Error Types:

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/TagResource

func (*Appflow) TagResourceRequest 

func (c *Appflow) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)

TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See TagResource for more information on using the TagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/TagResource

func (*Appflow) TagResourceWithContext 

func (c *Appflow) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)

TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.

See TagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) UntagResource 

func (c *Appflow) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)

UntagResource API operation for Amazon Appflow.

Removes a tag from the specified flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation UntagResource for usage and error information.

Returned Error Types:

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UntagResource

func (*Appflow) UntagResourceRequest 

func (c *Appflow) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)

UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UntagResource for more information on using the UntagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UntagResource

func (*Appflow) UntagResourceWithContext 

func (c *Appflow) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)

UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.

See UntagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) UpdateConnectorProfile 

func (c *Appflow) UpdateConnectorProfile(input *UpdateConnectorProfileInput) (*UpdateConnectorProfileOutput, error)

UpdateConnectorProfile API operation for Amazon Appflow.

Updates a given connector profile associated with your account.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation UpdateConnectorProfile for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UpdateConnectorProfile

func (*Appflow) UpdateConnectorProfileRequest 

func (c *Appflow) UpdateConnectorProfileRequest(input *UpdateConnectorProfileInput) (req *request.Request, output *UpdateConnectorProfileOutput)

UpdateConnectorProfileRequest generates a "aws/request.Request" representing the client's request for the UpdateConnectorProfile operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateConnectorProfile for more information on using the UpdateConnectorProfile API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the UpdateConnectorProfileRequest method.
req, resp := client.UpdateConnectorProfileRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UpdateConnectorProfile

func (*Appflow) UpdateConnectorProfileWithContext 

func (c *Appflow) UpdateConnectorProfileWithContext(ctx aws.Context, input *UpdateConnectorProfileInput, opts ...request.Option) (*UpdateConnectorProfileOutput, error)

UpdateConnectorProfileWithContext is the same as UpdateConnectorProfile with the addition of the ability to pass a context and additional request options.

See UpdateConnectorProfile for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*Appflow) UpdateFlow 

func (c *Appflow) UpdateFlow(input *UpdateFlowInput) (*UpdateFlowOutput, error)

UpdateFlow API operation for Amazon Appflow.

Updates an existing flow.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon Appflow's API operation UpdateFlow for usage and error information.

Returned Error Types:

  • ValidationException The request has invalid or missing parameters.

  • ResourceNotFoundException The resource specified in the request (such as the source or destination connector profile) is not found.

  • ServiceQuotaExceededException The request would cause a service quota (such as the number of flows) to be exceeded.

  • ConflictException There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

  • ConnectorAuthenticationException An error occurred when authenticating with the connector endpoint.

  • ConnectorServerException An error occurred when retrieving data from the connector endpoint.

  • InternalServerException An internal service error occurred during the processing of your request. Try again later.

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UpdateFlow

func (*Appflow) UpdateFlowRequest 

func (c *Appflow) UpdateFlowRequest(input *UpdateFlowInput) (req *request.Request, output *UpdateFlowOutput)

UpdateFlowRequest generates a "aws/request.Request" representing the client's request for the UpdateFlow operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UpdateFlow for more information on using the UpdateFlow API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the UpdateFlowRequest method.
req, resp := client.UpdateFlowRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/appflow-2020-08-23/UpdateFlow

func (*Appflow) UpdateFlowWithContext 

func (c *Appflow) UpdateFlowWithContext(ctx aws.Context, input *UpdateFlowInput, opts ...request.Option) (*UpdateFlowOutput, error)

UpdateFlowWithContext is the same as UpdateFlow with the addition of the ability to pass a context and additional request options.

See UpdateFlow for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type ConflictException 

type ConflictException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

func (*ConflictException) Code 

func (s *ConflictException) Code() string

Code returns the exception type name.

func (*ConflictException) Error 

func (s *ConflictException) Error() string

func (ConflictException) GoString 

func (s ConflictException) GoString() string

GoString returns the string representation

func (*ConflictException) Message 

func (s *ConflictException) Message() string

Message returns the exception's message.

func (*ConflictException) OrigErr 

func (s *ConflictException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConflictException) RequestID 

func (s *ConflictException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConflictException) StatusCode 

func (s *ConflictException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConflictException) String 

func (s ConflictException) String() string

String returns the string representation

type ConnectorAuthenticationException 

type ConnectorAuthenticationException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

An error occurred when authenticating with the connector endpoint.

func (*ConnectorAuthenticationException) Code 

func (s *ConnectorAuthenticationException) Code() string

Code returns the exception type name.

func (*ConnectorAuthenticationException) Error 

func (s *ConnectorAuthenticationException) Error() string

func (ConnectorAuthenticationException) GoString 

func (s ConnectorAuthenticationException) GoString() string

GoString returns the string representation

func (*ConnectorAuthenticationException) Message 

func (s *ConnectorAuthenticationException) Message() string

Message returns the exception's message.

func (*ConnectorAuthenticationException) OrigErr 

func (s *ConnectorAuthenticationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConnectorAuthenticationException) RequestID 

func (s *ConnectorAuthenticationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConnectorAuthenticationException) StatusCode 

func (s *ConnectorAuthenticationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConnectorAuthenticationException) String 

func (s ConnectorAuthenticationException) String() string

String returns the string representation

type ConnectorConfiguration 

type ConnectorConfiguration struct {

	// Specifies whether the connector can be used as a destination.
	CanUseAsDestination *bool `locationName:"canUseAsDestination" type:"boolean"`

	// Specifies whether the connector can be used as a source.
	CanUseAsSource *bool `locationName:"canUseAsSource" type:"boolean"`

	// Specifies connector-specific metadata such as oAuthScopes, supportedRegions,
	// privateLinkServiceUrl, and so on.
	ConnectorMetadata *ConnectorMetadata `locationName:"connectorMetadata" type:"structure"`

	// Specifies if PrivateLink is enabled for that connector.
	IsPrivateLinkEnabled *bool `locationName:"isPrivateLinkEnabled" type:"boolean"`

	// Specifies if a PrivateLink endpoint URL is required.
	IsPrivateLinkEndpointUrlRequired *bool `locationName:"isPrivateLinkEndpointUrlRequired" type:"boolean"`

	// Lists the connectors that are available for use as destinations.
	SupportedDestinationConnectors []*string `locationName:"supportedDestinationConnectors" type:"list"`

	// Specifies the supported flow frequency for that connector.
	SupportedSchedulingFrequencies []*string `locationName:"supportedSchedulingFrequencies" type:"list"`

	// Specifies the supported trigger types for the flow.
	SupportedTriggerTypes []*string `locationName:"supportedTriggerTypes" type:"list"`
	// contains filtered or unexported fields
}

The configuration settings related to a given connector.

func (ConnectorConfiguration) GoString 

func (s ConnectorConfiguration) GoString() string

GoString returns the string representation

func (*ConnectorConfiguration) SetCanUseAsDestination 

func (s *ConnectorConfiguration) SetCanUseAsDestination(v bool) *ConnectorConfiguration

SetCanUseAsDestination sets the CanUseAsDestination field's value.

func (*ConnectorConfiguration) SetCanUseAsSource 

func (s *ConnectorConfiguration) SetCanUseAsSource(v bool) *ConnectorConfiguration

SetCanUseAsSource sets the CanUseAsSource field's value.

func (*ConnectorConfiguration) SetConnectorMetadata 

func (s *ConnectorConfiguration) SetConnectorMetadata(v *ConnectorMetadata) *ConnectorConfiguration

SetConnectorMetadata sets the ConnectorMetadata field's value.

func (*ConnectorConfiguration) SetIsPrivateLinkEnabled 

func (s *ConnectorConfiguration) SetIsPrivateLinkEnabled(v bool) *ConnectorConfiguration

SetIsPrivateLinkEnabled sets the IsPrivateLinkEnabled field's value.

func (*ConnectorConfiguration) SetIsPrivateLinkEndpointUrlRequired 

func (s *ConnectorConfiguration) SetIsPrivateLinkEndpointUrlRequired(v bool) *ConnectorConfiguration

SetIsPrivateLinkEndpointUrlRequired sets the IsPrivateLinkEndpointUrlRequired field's value.

func (*ConnectorConfiguration) SetSupportedDestinationConnectors 

func (s *ConnectorConfiguration) SetSupportedDestinationConnectors(v []*string) *ConnectorConfiguration

SetSupportedDestinationConnectors sets the SupportedDestinationConnectors field's value.

func (*ConnectorConfiguration) SetSupportedSchedulingFrequencies 

func (s *ConnectorConfiguration) SetSupportedSchedulingFrequencies(v []*string) *ConnectorConfiguration

SetSupportedSchedulingFrequencies sets the SupportedSchedulingFrequencies field's value.

func (*ConnectorConfiguration) SetSupportedTriggerTypes 

func (s *ConnectorConfiguration) SetSupportedTriggerTypes(v []*string) *ConnectorConfiguration

SetSupportedTriggerTypes sets the SupportedTriggerTypes field's value.

func (ConnectorConfiguration) String 

func (s ConnectorConfiguration) String() string

String returns the string representation

type ConnectorEntity 

type ConnectorEntity struct {

	// Specifies whether the connector entity is a parent or a category and has
	// more entities nested underneath it. If another call is made with entitiesPath
	// = "the_current_entity_name_with_hasNestedEntities_true", then it returns
	// the nested entities underneath it. This provides a way to retrieve all supported
	// entities in a recursive fashion.
	HasNestedEntities *bool `locationName:"hasNestedEntities" type:"boolean"`

	// The label applied to the connector entity.
	Label *string `locationName:"label" type:"string"`

	// The name of the connector entity.
	//
	// Name is a required field
	Name *string `locationName:"name" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The high-level entity that can be queried in Amazon AppFlow. For example, a Salesforce entity might be an Account or Opportunity, whereas a ServiceNow entity might be an Incident.

func (ConnectorEntity) GoString 

func (s ConnectorEntity) GoString() string

GoString returns the string representation

func (*ConnectorEntity) SetHasNestedEntities 

func (s *ConnectorEntity) SetHasNestedEntities(v bool) *ConnectorEntity

SetHasNestedEntities sets the HasNestedEntities field's value.

func (*ConnectorEntity) SetLabel 

func (s *ConnectorEntity) SetLabel(v string) *ConnectorEntity

SetLabel sets the Label field's value.

func (*ConnectorEntity) SetName 

func (s *ConnectorEntity) SetName(v string) *ConnectorEntity

SetName sets the Name field's value.

func (ConnectorEntity) String 

func (s ConnectorEntity) String() string

String returns the string representation

type ConnectorEntityField 

type ConnectorEntityField struct {

	// A description of the connector entity field.
	Description *string `locationName:"description" type:"string"`

	// The properties applied to a field when the connector is being used as a destination.
	DestinationProperties *DestinationFieldProperties `locationName:"destinationProperties" type:"structure"`

	// The unique identifier of the connector field.
	//
	// Identifier is a required field
	Identifier *string `locationName:"identifier" type:"string" required:"true"`

	// The label applied to a connector entity field.
	Label *string `locationName:"label" type:"string"`

	// The properties that can be applied to a field when the connector is being
	// used as a source.
	SourceProperties *SourceFieldProperties `locationName:"sourceProperties" type:"structure"`

	// Contains details regarding the supported FieldType, including the corresponding
	// filterOperators and supportedValues.
	SupportedFieldTypeDetails *SupportedFieldTypeDetails `locationName:"supportedFieldTypeDetails" type:"structure"`
	// contains filtered or unexported fields
}

Describes the data model of a connector field. For example, for an account entity, the fields would be account name, account ID, and so on.

func (ConnectorEntityField) GoString 

func (s ConnectorEntityField) GoString() string

GoString returns the string representation

func (*ConnectorEntityField) SetDescription 

func (s *ConnectorEntityField) SetDescription(v string) *ConnectorEntityField

SetDescription sets the Description field's value.

func (*ConnectorEntityField) SetDestinationProperties 

func (s *ConnectorEntityField) SetDestinationProperties(v *DestinationFieldProperties) *ConnectorEntityField

SetDestinationProperties sets the DestinationProperties field's value.

func (*ConnectorEntityField) SetIdentifier 

func (s *ConnectorEntityField) SetIdentifier(v string) *ConnectorEntityField

SetIdentifier sets the Identifier field's value.

func (*ConnectorEntityField) SetLabel 

func (s *ConnectorEntityField) SetLabel(v string) *ConnectorEntityField

SetLabel sets the Label field's value.

func (*ConnectorEntityField) SetSourceProperties 

func (s *ConnectorEntityField) SetSourceProperties(v *SourceFieldProperties) *ConnectorEntityField

SetSourceProperties sets the SourceProperties field's value.

func (*ConnectorEntityField) SetSupportedFieldTypeDetails 

func (s *ConnectorEntityField) SetSupportedFieldTypeDetails(v *SupportedFieldTypeDetails) *ConnectorEntityField

SetSupportedFieldTypeDetails sets the SupportedFieldTypeDetails field's value.

func (ConnectorEntityField) String 

func (s ConnectorEntityField) String() string

String returns the string representation

type ConnectorMetadata 

type ConnectorMetadata struct {

	// The connector metadata specific to Amplitude.
	Amplitude *AmplitudeMetadata `type:"structure"`

	// The connector metadata specific to Amazon Connect Customer Profiles.
	CustomerProfiles *CustomerProfilesMetadata `type:"structure"`

	// The connector metadata specific to Datadog.
	Datadog *DatadogMetadata `type:"structure"`

	// The connector metadata specific to Dynatrace.
	Dynatrace *DynatraceMetadata `type:"structure"`

	// The connector metadata specific to Amazon EventBridge.
	EventBridge *EventBridgeMetadata `type:"structure"`

	// The connector metadata specific to Google Analytics.
	GoogleAnalytics *GoogleAnalyticsMetadata `type:"structure"`

	// The connector metadata specific to Amazon Honeycode.
	Honeycode *HoneycodeMetadata `type:"structure"`

	// The connector metadata specific to Infor Nexus.
	InforNexus *InforNexusMetadata `type:"structure"`

	// The connector metadata specific to Marketo.
	Marketo *MarketoMetadata `type:"structure"`

	// The connector metadata specific to Amazon Redshift.
	Redshift *RedshiftMetadata `type:"structure"`

	// The connector metadata specific to Amazon S3.
	S3 *S3Metadata `type:"structure"`

	// The connector metadata specific to Salesforce.
	Salesforce *SalesforceMetadata `type:"structure"`

	// The connector metadata specific to ServiceNow.
	ServiceNow *ServiceNowMetadata `type:"structure"`

	// The connector metadata specific to Singular.
	Singular *SingularMetadata `type:"structure"`

	// The connector metadata specific to Slack.
	Slack *SlackMetadata `type:"structure"`

	// The connector metadata specific to Snowflake.
	Snowflake *SnowflakeMetadata `type:"structure"`

	// The connector metadata specific to Trend Micro.
	Trendmicro *TrendmicroMetadata `type:"structure"`

	// The connector metadata specific to Upsolver.
	Upsolver *UpsolverMetadata `type:"structure"`

	// The connector metadata specific to Veeva.
	Veeva *VeevaMetadata `type:"structure"`

	// The connector metadata specific to Zendesk.
	Zendesk *ZendeskMetadata `type:"structure"`
	// contains filtered or unexported fields
}

A structure to specify connector-specific metadata such as oAuthScopes, supportedRegions, privateLinkServiceUrl, and so on.

func (ConnectorMetadata) GoString 

func (s ConnectorMetadata) GoString() string

GoString returns the string representation

func (*ConnectorMetadata) SetAmplitude 

func (s *ConnectorMetadata) SetAmplitude(v *AmplitudeMetadata) *ConnectorMetadata

SetAmplitude sets the Amplitude field's value.

func (*ConnectorMetadata) SetCustomerProfiles added in v1.37.18 

func (s *ConnectorMetadata) SetCustomerProfiles(v *CustomerProfilesMetadata) *ConnectorMetadata

SetCustomerProfiles sets the CustomerProfiles field's value.

func (*ConnectorMetadata) SetDatadog 

func (s *ConnectorMetadata) SetDatadog(v *DatadogMetadata) *ConnectorMetadata

SetDatadog sets the Datadog field's value.

func (*ConnectorMetadata) SetDynatrace 

func (s *ConnectorMetadata) SetDynatrace(v *DynatraceMetadata) *ConnectorMetadata

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorMetadata) SetEventBridge 

func (s *ConnectorMetadata) SetEventBridge(v *EventBridgeMetadata) *ConnectorMetadata

SetEventBridge sets the EventBridge field's value.

func (*ConnectorMetadata) SetGoogleAnalytics 

func (s *ConnectorMetadata) SetGoogleAnalytics(v *GoogleAnalyticsMetadata) *ConnectorMetadata

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorMetadata) SetHoneycode added in v1.37.18 

func (s *ConnectorMetadata) SetHoneycode(v *HoneycodeMetadata) *ConnectorMetadata

SetHoneycode sets the Honeycode field's value.

func (*ConnectorMetadata) SetInforNexus 

func (s *ConnectorMetadata) SetInforNexus(v *InforNexusMetadata) *ConnectorMetadata

SetInforNexus sets the InforNexus field's value.

func (*ConnectorMetadata) SetMarketo 

func (s *ConnectorMetadata) SetMarketo(v *MarketoMetadata) *ConnectorMetadata

SetMarketo sets the Marketo field's value.

func (*ConnectorMetadata) SetRedshift 

func (s *ConnectorMetadata) SetRedshift(v *RedshiftMetadata) *ConnectorMetadata

SetRedshift sets the Redshift field's value.

func (*ConnectorMetadata) SetS3 

func (s *ConnectorMetadata) SetS3(v *S3Metadata) *ConnectorMetadata

SetS3 sets the S3 field's value.

func (*ConnectorMetadata) SetSalesforce 

func (s *ConnectorMetadata) SetSalesforce(v *SalesforceMetadata) *ConnectorMetadata

SetSalesforce sets the Salesforce field's value.

func (*ConnectorMetadata) SetServiceNow 

func (s *ConnectorMetadata) SetServiceNow(v *ServiceNowMetadata) *ConnectorMetadata

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorMetadata) SetSingular 

func (s *ConnectorMetadata) SetSingular(v *SingularMetadata) *ConnectorMetadata

SetSingular sets the Singular field's value.

func (*ConnectorMetadata) SetSlack 

func (s *ConnectorMetadata) SetSlack(v *SlackMetadata) *ConnectorMetadata

SetSlack sets the Slack field's value.

func (*ConnectorMetadata) SetSnowflake 

func (s *ConnectorMetadata) SetSnowflake(v *SnowflakeMetadata) *ConnectorMetadata

SetSnowflake sets the Snowflake field's value.

func (*ConnectorMetadata) SetTrendmicro 

func (s *ConnectorMetadata) SetTrendmicro(v *TrendmicroMetadata) *ConnectorMetadata

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorMetadata) SetUpsolver added in v1.35.35 

func (s *ConnectorMetadata) SetUpsolver(v *UpsolverMetadata) *ConnectorMetadata

SetUpsolver sets the Upsolver field's value.

func (*ConnectorMetadata) SetVeeva 

func (s *ConnectorMetadata) SetVeeva(v *VeevaMetadata) *ConnectorMetadata

SetVeeva sets the Veeva field's value.

func (*ConnectorMetadata) SetZendesk 

func (s *ConnectorMetadata) SetZendesk(v *ZendeskMetadata) *ConnectorMetadata

SetZendesk sets the Zendesk field's value.

func (ConnectorMetadata) String 

func (s ConnectorMetadata) String() string

String returns the string representation

type ConnectorOAuthRequest 

type ConnectorOAuthRequest struct {

	// The code provided by the connector when it has been authenticated via the
	// connected app.
	AuthCode *string `locationName:"authCode" type:"string"`

	// The URL to which the authentication server redirects the browser after authorization
	// has been granted.
	RedirectUri *string `locationName:"redirectUri" type:"string"`
	// contains filtered or unexported fields
}

Used by select connectors for which the OAuth workflow is supported, such as Salesforce, Google Analytics, Marketo, Zendesk, and Slack.

func (ConnectorOAuthRequest) GoString 

func (s ConnectorOAuthRequest) GoString() string

GoString returns the string representation

func (*ConnectorOAuthRequest) SetAuthCode 

func (s *ConnectorOAuthRequest) SetAuthCode(v string) *ConnectorOAuthRequest

SetAuthCode sets the AuthCode field's value.

func (*ConnectorOAuthRequest) SetRedirectUri 

func (s *ConnectorOAuthRequest) SetRedirectUri(v string) *ConnectorOAuthRequest

SetRedirectUri sets the RedirectUri field's value.

func (ConnectorOAuthRequest) String 

func (s ConnectorOAuthRequest) String() string

String returns the string representation

type ConnectorOperator 

type ConnectorOperator struct {

	// The operation to be performed on the provided Amplitude source fields.
	Amplitude *string `type:"string" enum:"AmplitudeConnectorOperator"`

	// The operation to be performed on the provided Datadog source fields.
	Datadog *string `type:"string" enum:"DatadogConnectorOperator"`

	// The operation to be performed on the provided Dynatrace source fields.
	Dynatrace *string `type:"string" enum:"DynatraceConnectorOperator"`

	// The operation to be performed on the provided Google Analytics source fields.
	GoogleAnalytics *string `type:"string" enum:"GoogleAnalyticsConnectorOperator"`

	// The operation to be performed on the provided Infor Nexus source fields.
	InforNexus *string `type:"string" enum:"InforNexusConnectorOperator"`

	// The operation to be performed on the provided Marketo source fields.
	Marketo *string `type:"string" enum:"MarketoConnectorOperator"`

	// The operation to be performed on the provided Amazon S3 source fields.
	S3 *string `type:"string" enum:"S3ConnectorOperator"`

	// The operation to be performed on the provided Salesforce source fields.
	Salesforce *string `type:"string" enum:"SalesforceConnectorOperator"`

	// The operation to be performed on the provided ServiceNow source fields.
	ServiceNow *string `type:"string" enum:"ServiceNowConnectorOperator"`

	// The operation to be performed on the provided Singular source fields.
	Singular *string `type:"string" enum:"SingularConnectorOperator"`

	// The operation to be performed on the provided Slack source fields.
	Slack *string `type:"string" enum:"SlackConnectorOperator"`

	// The operation to be performed on the provided Trend Micro source fields.
	Trendmicro *string `type:"string" enum:"TrendmicroConnectorOperator"`

	// The operation to be performed on the provided Veeva source fields.
	Veeva *string `type:"string" enum:"VeevaConnectorOperator"`

	// The operation to be performed on the provided Zendesk source fields.
	Zendesk *string `type:"string" enum:"ZendeskConnectorOperator"`
	// contains filtered or unexported fields
}

The operation to be performed on the provided source fields.

func (ConnectorOperator) GoString 

func (s ConnectorOperator) GoString() string

GoString returns the string representation

func (*ConnectorOperator) SetAmplitude 

func (s *ConnectorOperator) SetAmplitude(v string) *ConnectorOperator

SetAmplitude sets the Amplitude field's value.

func (*ConnectorOperator) SetDatadog 

func (s *ConnectorOperator) SetDatadog(v string) *ConnectorOperator

SetDatadog sets the Datadog field's value.

func (*ConnectorOperator) SetDynatrace 

func (s *ConnectorOperator) SetDynatrace(v string) *ConnectorOperator

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorOperator) SetGoogleAnalytics 

func (s *ConnectorOperator) SetGoogleAnalytics(v string) *ConnectorOperator

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorOperator) SetInforNexus 

func (s *ConnectorOperator) SetInforNexus(v string) *ConnectorOperator

SetInforNexus sets the InforNexus field's value.

func (*ConnectorOperator) SetMarketo 

func (s *ConnectorOperator) SetMarketo(v string) *ConnectorOperator

SetMarketo sets the Marketo field's value.

func (*ConnectorOperator) SetS3 

func (s *ConnectorOperator) SetS3(v string) *ConnectorOperator

SetS3 sets the S3 field's value.

func (*ConnectorOperator) SetSalesforce 

func (s *ConnectorOperator) SetSalesforce(v string) *ConnectorOperator

SetSalesforce sets the Salesforce field's value.

func (*ConnectorOperator) SetServiceNow 

func (s *ConnectorOperator) SetServiceNow(v string) *ConnectorOperator

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorOperator) SetSingular 

func (s *ConnectorOperator) SetSingular(v string) *ConnectorOperator

SetSingular sets the Singular field's value.

func (*ConnectorOperator) SetSlack 

func (s *ConnectorOperator) SetSlack(v string) *ConnectorOperator

SetSlack sets the Slack field's value.

func (*ConnectorOperator) SetTrendmicro 

func (s *ConnectorOperator) SetTrendmicro(v string) *ConnectorOperator

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorOperator) SetVeeva 

func (s *ConnectorOperator) SetVeeva(v string) *ConnectorOperator

SetVeeva sets the Veeva field's value.

func (*ConnectorOperator) SetZendesk 

func (s *ConnectorOperator) SetZendesk(v string) *ConnectorOperator

SetZendesk sets the Zendesk field's value.

func (ConnectorOperator) String 

func (s ConnectorOperator) String() string

String returns the string representation

type ConnectorProfile 

type ConnectorProfile struct {

	// Indicates the connection mode and if it is public or private.
	ConnectionMode *string `locationName:"connectionMode" type:"string" enum:"ConnectionMode"`

	// The Amazon Resource Name (ARN) of the connector profile.
	ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in the AWS account.
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

	// The connector-specific properties of the profile configuration.
	ConnectorProfileProperties *ConnectorProfileProperties `locationName:"connectorProfileProperties" type:"structure"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

	// Specifies when the connector profile was created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp"`

	// The Amazon Resource Name (ARN) of the connector profile credentials.
	CredentialsArn *string `locationName:"credentialsArn" type:"string"`

	// Specifies when the connector profile was last updated.
	LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`
	// contains filtered or unexported fields
}

Describes an instance of a connector. This includes the provided name, credentials ARN, connection-mode, and so on. To keep the API intuitive and extensible, the fields that are common to all types of connector profiles are explicitly specified at the top level. The rest of the connector-specific properties are available via the connectorProfileProperties field.

func (ConnectorProfile) GoString 

func (s ConnectorProfile) GoString() string

GoString returns the string representation

func (*ConnectorProfile) SetConnectionMode 

func (s *ConnectorProfile) SetConnectionMode(v string) *ConnectorProfile

SetConnectionMode sets the ConnectionMode field's value.

func (*ConnectorProfile) SetConnectorProfileArn 

func (s *ConnectorProfile) SetConnectorProfileArn(v string) *ConnectorProfile

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (*ConnectorProfile) SetConnectorProfileName 

func (s *ConnectorProfile) SetConnectorProfileName(v string) *ConnectorProfile

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*ConnectorProfile) SetConnectorProfileProperties 

func (s *ConnectorProfile) SetConnectorProfileProperties(v *ConnectorProfileProperties) *ConnectorProfile

SetConnectorProfileProperties sets the ConnectorProfileProperties field's value.

func (*ConnectorProfile) SetConnectorType 

func (s *ConnectorProfile) SetConnectorType(v string) *ConnectorProfile

SetConnectorType sets the ConnectorType field's value.

func (*ConnectorProfile) SetCreatedAt 

func (s *ConnectorProfile) SetCreatedAt(v time.Time) *ConnectorProfile

SetCreatedAt sets the CreatedAt field's value.

func (*ConnectorProfile) SetCredentialsArn 

func (s *ConnectorProfile) SetCredentialsArn(v string) *ConnectorProfile

SetCredentialsArn sets the CredentialsArn field's value.

func (*ConnectorProfile) SetLastUpdatedAt 

func (s *ConnectorProfile) SetLastUpdatedAt(v time.Time) *ConnectorProfile

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (ConnectorProfile) String 

func (s ConnectorProfile) String() string

String returns the string representation

type ConnectorProfileConfig 

type ConnectorProfileConfig struct {

	// The connector-specific credentials required by each connector.
	//
	// ConnectorProfileCredentials is a required field
	ConnectorProfileCredentials *ConnectorProfileCredentials `locationName:"connectorProfileCredentials" type:"structure" required:"true"`

	// The connector-specific properties of the profile configuration.
	//
	// ConnectorProfileProperties is a required field
	ConnectorProfileProperties *ConnectorProfileProperties `locationName:"connectorProfileProperties" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

Defines the connector-specific configuration and credentials for the connector profile.

func (ConnectorProfileConfig) GoString 

func (s ConnectorProfileConfig) GoString() string

GoString returns the string representation

func (*ConnectorProfileConfig) SetConnectorProfileCredentials 

func (s *ConnectorProfileConfig) SetConnectorProfileCredentials(v *ConnectorProfileCredentials) *ConnectorProfileConfig

SetConnectorProfileCredentials sets the ConnectorProfileCredentials field's value.

func (*ConnectorProfileConfig) SetConnectorProfileProperties 

func (s *ConnectorProfileConfig) SetConnectorProfileProperties(v *ConnectorProfileProperties) *ConnectorProfileConfig

SetConnectorProfileProperties sets the ConnectorProfileProperties field's value.

func (ConnectorProfileConfig) String 

func (s ConnectorProfileConfig) String() string

String returns the string representation

func (*ConnectorProfileConfig) Validate 

func (s *ConnectorProfileConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConnectorProfileCredentials 

type ConnectorProfileCredentials struct {

	// The connector-specific credentials required when using Amplitude.
	Amplitude *AmplitudeConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Datadog.
	Datadog *DatadogConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Dynatrace.
	Dynatrace *DynatraceConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Google Analytics.
	GoogleAnalytics *GoogleAnalyticsConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Amazon Honeycode.
	Honeycode *HoneycodeConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Infor Nexus.
	InforNexus *InforNexusConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Marketo.
	Marketo *MarketoConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Amazon Redshift.
	Redshift *RedshiftConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Salesforce.
	Salesforce *SalesforceConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using ServiceNow.
	ServiceNow *ServiceNowConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Singular.
	Singular *SingularConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Slack.
	Slack *SlackConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Snowflake.
	Snowflake *SnowflakeConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Trend Micro.
	Trendmicro *TrendmicroConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Veeva.
	Veeva *VeevaConnectorProfileCredentials `type:"structure"`

	// The connector-specific credentials required when using Zendesk.
	Zendesk *ZendeskConnectorProfileCredentials `type:"structure"`
	// contains filtered or unexported fields
}

The connector-specific credentials required by a connector.

func (ConnectorProfileCredentials) GoString 

func (s ConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ConnectorProfileCredentials) SetAmplitude 

func (s *ConnectorProfileCredentials) SetAmplitude(v *AmplitudeConnectorProfileCredentials) *ConnectorProfileCredentials

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileCredentials) SetDatadog 

func (s *ConnectorProfileCredentials) SetDatadog(v *DatadogConnectorProfileCredentials) *ConnectorProfileCredentials

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileCredentials) SetDynatrace 

func (s *ConnectorProfileCredentials) SetDynatrace(v *DynatraceConnectorProfileCredentials) *ConnectorProfileCredentials

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileCredentials) SetGoogleAnalytics 

func (s *ConnectorProfileCredentials) SetGoogleAnalytics(v *GoogleAnalyticsConnectorProfileCredentials) *ConnectorProfileCredentials

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileCredentials) SetHoneycode added in v1.37.18 

func (s *ConnectorProfileCredentials) SetHoneycode(v *HoneycodeConnectorProfileCredentials) *ConnectorProfileCredentials

SetHoneycode sets the Honeycode field's value.

func (*ConnectorProfileCredentials) SetInforNexus 

func (s *ConnectorProfileCredentials) SetInforNexus(v *InforNexusConnectorProfileCredentials) *ConnectorProfileCredentials

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileCredentials) SetMarketo 

func (s *ConnectorProfileCredentials) SetMarketo(v *MarketoConnectorProfileCredentials) *ConnectorProfileCredentials

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileCredentials) SetRedshift 

func (s *ConnectorProfileCredentials) SetRedshift(v *RedshiftConnectorProfileCredentials) *ConnectorProfileCredentials

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileCredentials) SetSalesforce 

func (s *ConnectorProfileCredentials) SetSalesforce(v *SalesforceConnectorProfileCredentials) *ConnectorProfileCredentials

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileCredentials) SetServiceNow 

func (s *ConnectorProfileCredentials) SetServiceNow(v *ServiceNowConnectorProfileCredentials) *ConnectorProfileCredentials

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileCredentials) SetSingular 

func (s *ConnectorProfileCredentials) SetSingular(v *SingularConnectorProfileCredentials) *ConnectorProfileCredentials

SetSingular sets the Singular field's value.

func (*ConnectorProfileCredentials) SetSlack 

func (s *ConnectorProfileCredentials) SetSlack(v *SlackConnectorProfileCredentials) *ConnectorProfileCredentials

SetSlack sets the Slack field's value.

func (*ConnectorProfileCredentials) SetSnowflake 

func (s *ConnectorProfileCredentials) SetSnowflake(v *SnowflakeConnectorProfileCredentials) *ConnectorProfileCredentials

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileCredentials) SetTrendmicro 

func (s *ConnectorProfileCredentials) SetTrendmicro(v *TrendmicroConnectorProfileCredentials) *ConnectorProfileCredentials

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileCredentials) SetVeeva 

func (s *ConnectorProfileCredentials) SetVeeva(v *VeevaConnectorProfileCredentials) *ConnectorProfileCredentials

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileCredentials) SetZendesk 

func (s *ConnectorProfileCredentials) SetZendesk(v *ZendeskConnectorProfileCredentials) *ConnectorProfileCredentials

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileCredentials) String 

func (s ConnectorProfileCredentials) String() string

String returns the string representation

func (*ConnectorProfileCredentials) Validate 

func (s *ConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConnectorProfileProperties 

type ConnectorProfileProperties struct {

	// The connector-specific properties required by Amplitude.
	Amplitude *AmplitudeConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Datadog.
	Datadog *DatadogConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Dynatrace.
	Dynatrace *DynatraceConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required Google Analytics.
	GoogleAnalytics *GoogleAnalyticsConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Amazon Honeycode.
	Honeycode *HoneycodeConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Infor Nexus.
	InforNexus *InforNexusConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Marketo.
	Marketo *MarketoConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Amazon Redshift.
	Redshift *RedshiftConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Salesforce.
	Salesforce *SalesforceConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by serviceNow.
	ServiceNow *ServiceNowConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Singular.
	Singular *SingularConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Slack.
	Slack *SlackConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Snowflake.
	Snowflake *SnowflakeConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Trend Micro.
	Trendmicro *TrendmicroConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Veeva.
	Veeva *VeevaConnectorProfileProperties `type:"structure"`

	// The connector-specific properties required by Zendesk.
	Zendesk *ZendeskConnectorProfileProperties `type:"structure"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required by each connector.

func (ConnectorProfileProperties) GoString 

func (s ConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ConnectorProfileProperties) SetAmplitude 

func (s *ConnectorProfileProperties) SetAmplitude(v *AmplitudeConnectorProfileProperties) *ConnectorProfileProperties

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileProperties) SetDatadog 

func (s *ConnectorProfileProperties) SetDatadog(v *DatadogConnectorProfileProperties) *ConnectorProfileProperties

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileProperties) SetDynatrace 

func (s *ConnectorProfileProperties) SetDynatrace(v *DynatraceConnectorProfileProperties) *ConnectorProfileProperties

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileProperties) SetGoogleAnalytics 

func (s *ConnectorProfileProperties) SetGoogleAnalytics(v *GoogleAnalyticsConnectorProfileProperties) *ConnectorProfileProperties

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileProperties) SetHoneycode added in v1.37.18 

func (s *ConnectorProfileProperties) SetHoneycode(v *HoneycodeConnectorProfileProperties) *ConnectorProfileProperties

SetHoneycode sets the Honeycode field's value.

func (*ConnectorProfileProperties) SetInforNexus 

func (s *ConnectorProfileProperties) SetInforNexus(v *InforNexusConnectorProfileProperties) *ConnectorProfileProperties

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileProperties) SetMarketo 

func (s *ConnectorProfileProperties) SetMarketo(v *MarketoConnectorProfileProperties) *ConnectorProfileProperties

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileProperties) SetRedshift 

func (s *ConnectorProfileProperties) SetRedshift(v *RedshiftConnectorProfileProperties) *ConnectorProfileProperties

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileProperties) SetSalesforce 

func (s *ConnectorProfileProperties) SetSalesforce(v *SalesforceConnectorProfileProperties) *ConnectorProfileProperties

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileProperties) SetServiceNow 

func (s *ConnectorProfileProperties) SetServiceNow(v *ServiceNowConnectorProfileProperties) *ConnectorProfileProperties

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileProperties) SetSingular 

func (s *ConnectorProfileProperties) SetSingular(v *SingularConnectorProfileProperties) *ConnectorProfileProperties

SetSingular sets the Singular field's value.

func (*ConnectorProfileProperties) SetSlack 

func (s *ConnectorProfileProperties) SetSlack(v *SlackConnectorProfileProperties) *ConnectorProfileProperties

SetSlack sets the Slack field's value.

func (*ConnectorProfileProperties) SetSnowflake 

func (s *ConnectorProfileProperties) SetSnowflake(v *SnowflakeConnectorProfileProperties) *ConnectorProfileProperties

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileProperties) SetTrendmicro 

func (s *ConnectorProfileProperties) SetTrendmicro(v *TrendmicroConnectorProfileProperties) *ConnectorProfileProperties

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileProperties) SetVeeva 

func (s *ConnectorProfileProperties) SetVeeva(v *VeevaConnectorProfileProperties) *ConnectorProfileProperties

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileProperties) SetZendesk 

func (s *ConnectorProfileProperties) SetZendesk(v *ZendeskConnectorProfileProperties) *ConnectorProfileProperties

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileProperties) String 

func (s ConnectorProfileProperties) String() string

String returns the string representation

func (*ConnectorProfileProperties) Validate 

func (s *ConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConnectorServerException 

type ConnectorServerException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

An error occurred when retrieving data from the connector endpoint.

func (*ConnectorServerException) Code 

func (s *ConnectorServerException) Code() string

Code returns the exception type name.

func (*ConnectorServerException) Error 

func (s *ConnectorServerException) Error() string

func (ConnectorServerException) GoString 

func (s ConnectorServerException) GoString() string

GoString returns the string representation

func (*ConnectorServerException) Message 

func (s *ConnectorServerException) Message() string

Message returns the exception's message.

func (*ConnectorServerException) OrigErr 

func (s *ConnectorServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConnectorServerException) RequestID 

func (s *ConnectorServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConnectorServerException) StatusCode 

func (s *ConnectorServerException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConnectorServerException) String 

func (s ConnectorServerException) String() string

String returns the string representation

type CreateConnectorProfileInput 

type CreateConnectorProfileInput struct {

	// Indicates the connection mode and specifies whether it is public or private.
	// Private flows use AWS PrivateLink to route data over AWS infrastructure without
	// exposing it to the public internet.
	//
	// ConnectionMode is a required field
	ConnectionMode *string `locationName:"connectionMode" type:"string" required:"true" enum:"ConnectionMode"`

	// Defines the connector-specific configuration and credentials.
	//
	// ConnectorProfileConfig is a required field
	ConnectorProfileConfig *ConnectorProfileConfig `locationName:"connectorProfileConfig" type:"structure" required:"true"`

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in your AWS account.
	//
	// ConnectorProfileName is a required field
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	//
	// ConnectorType is a required field
	ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

	// 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.
	KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`
	// contains filtered or unexported fields
}

func (CreateConnectorProfileInput) GoString 

func (s CreateConnectorProfileInput) GoString() string

GoString returns the string representation

func (*CreateConnectorProfileInput) SetConnectionMode 

func (s *CreateConnectorProfileInput) SetConnectionMode(v string) *CreateConnectorProfileInput

SetConnectionMode sets the ConnectionMode field's value.

func (*CreateConnectorProfileInput) SetConnectorProfileConfig 

func (s *CreateConnectorProfileInput) SetConnectorProfileConfig(v *ConnectorProfileConfig) *CreateConnectorProfileInput

SetConnectorProfileConfig sets the ConnectorProfileConfig field's value.

func (*CreateConnectorProfileInput) SetConnectorProfileName 

func (s *CreateConnectorProfileInput) SetConnectorProfileName(v string) *CreateConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*CreateConnectorProfileInput) SetConnectorType 

func (s *CreateConnectorProfileInput) SetConnectorType(v string) *CreateConnectorProfileInput

SetConnectorType sets the ConnectorType field's value.

func (*CreateConnectorProfileInput) SetKmsArn 

func (s *CreateConnectorProfileInput) SetKmsArn(v string) *CreateConnectorProfileInput

SetKmsArn sets the KmsArn field's value.

func (CreateConnectorProfileInput) String 

func (s CreateConnectorProfileInput) String() string

String returns the string representation

func (*CreateConnectorProfileInput) Validate 

func (s *CreateConnectorProfileInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateConnectorProfileOutput 

type CreateConnectorProfileOutput struct {

	// The Amazon Resource Name (ARN) of the connector profile.
	ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`
	// contains filtered or unexported fields
}

func (CreateConnectorProfileOutput) GoString 

func (s CreateConnectorProfileOutput) GoString() string

GoString returns the string representation

func (*CreateConnectorProfileOutput) SetConnectorProfileArn 

func (s *CreateConnectorProfileOutput) SetConnectorProfileArn(v string) *CreateConnectorProfileOutput

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (CreateConnectorProfileOutput) String 

func (s CreateConnectorProfileOutput) String() string

String returns the string representation

type CreateFlowInput 

type CreateFlowInput struct {

	// A description of the flow you want to create.
	Description *string `locationName:"description" type:"string"`

	// The configuration that controls how Amazon AppFlow places data in the destination
	// connector.
	//
	// DestinationFlowConfigList is a required field
	DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list" required:"true"`

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`

	// 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.
	KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`

	// The configuration that controls how Amazon AppFlow retrieves data from the
	// source connector.
	//
	// SourceFlowConfig is a required field
	SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure" required:"true"`

	// The tags used to organize, track, or control access for your flow.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// A list of tasks that Amazon AppFlow performs while transferring the data
	// in the flow run.
	//
	// Tasks is a required field
	Tasks []*Task `locationName:"tasks" type:"list" required:"true"`

	// The trigger settings that determine how and when the flow runs.
	//
	// TriggerConfig is a required field
	TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

func (CreateFlowInput) GoString 

func (s CreateFlowInput) GoString() string

GoString returns the string representation

func (*CreateFlowInput) SetDescription 

func (s *CreateFlowInput) SetDescription(v string) *CreateFlowInput

SetDescription sets the Description field's value.

func (*CreateFlowInput) SetDestinationFlowConfigList 

func (s *CreateFlowInput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *CreateFlowInput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*CreateFlowInput) SetFlowName 

func (s *CreateFlowInput) SetFlowName(v string) *CreateFlowInput

SetFlowName sets the FlowName field's value.

func (*CreateFlowInput) SetKmsArn 

func (s *CreateFlowInput) SetKmsArn(v string) *CreateFlowInput

SetKmsArn sets the KmsArn field's value.

func (*CreateFlowInput) SetSourceFlowConfig 

func (s *CreateFlowInput) SetSourceFlowConfig(v *SourceFlowConfig) *CreateFlowInput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*CreateFlowInput) SetTags 

func (s *CreateFlowInput) SetTags(v map[string]*string) *CreateFlowInput

SetTags sets the Tags field's value.

func (*CreateFlowInput) SetTasks 

func (s *CreateFlowInput) SetTasks(v []*Task) *CreateFlowInput

SetTasks sets the Tasks field's value.

func (*CreateFlowInput) SetTriggerConfig 

func (s *CreateFlowInput) SetTriggerConfig(v *TriggerConfig) *CreateFlowInput

SetTriggerConfig sets the TriggerConfig field's value.

func (CreateFlowInput) String 

func (s CreateFlowInput) String() string

String returns the string representation

func (*CreateFlowInput) Validate 

func (s *CreateFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateFlowOutput 

type CreateFlowOutput struct {

	// The flow's Amazon Resource Name (ARN).
	FlowArn *string `locationName:"flowArn" type:"string"`

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
	// contains filtered or unexported fields
}

func (CreateFlowOutput) GoString 

func (s CreateFlowOutput) GoString() string

GoString returns the string representation

func (*CreateFlowOutput) SetFlowArn 

func (s *CreateFlowOutput) SetFlowArn(v string) *CreateFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*CreateFlowOutput) SetFlowStatus 

func (s *CreateFlowOutput) SetFlowStatus(v string) *CreateFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (CreateFlowOutput) String 

func (s CreateFlowOutput) String() string

String returns the string representation

type CustomerProfilesDestinationProperties added in v1.37.18 

type CustomerProfilesDestinationProperties struct {

	// The unique name of the Amazon Connect Customer Profiles domain.
	//
	// DomainName is a required field
	DomainName *string `locationName:"domainName" type:"string" required:"true"`

	// The object specified in the Amazon Connect Customer Profiles flow destination.
	ObjectTypeName *string `locationName:"objectTypeName" type:"string"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon Connect Customer Profiles is used as a destination.

func (CustomerProfilesDestinationProperties) GoString added in v1.37.18 

func (s CustomerProfilesDestinationProperties) GoString() string

GoString returns the string representation

func (*CustomerProfilesDestinationProperties) SetDomainName added in v1.37.18 

func (s *CustomerProfilesDestinationProperties) SetDomainName(v string) *CustomerProfilesDestinationProperties

SetDomainName sets the DomainName field's value.

func (*CustomerProfilesDestinationProperties) SetObjectTypeName added in v1.37.18 

func (s *CustomerProfilesDestinationProperties) SetObjectTypeName(v string) *CustomerProfilesDestinationProperties

SetObjectTypeName sets the ObjectTypeName field's value.

func (CustomerProfilesDestinationProperties) String added in v1.37.18 

func (s CustomerProfilesDestinationProperties) String() string

String returns the string representation

func (*CustomerProfilesDestinationProperties) Validate added in v1.37.18 

func (s *CustomerProfilesDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CustomerProfilesMetadata added in v1.37.18 

type CustomerProfilesMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Amazon Connect Customer Profiles.

func (CustomerProfilesMetadata) GoString added in v1.37.18 

func (s CustomerProfilesMetadata) GoString() string

GoString returns the string representation

func (CustomerProfilesMetadata) String added in v1.37.18 

func (s CustomerProfilesMetadata) String() string

String returns the string representation

type DatadogConnectorProfileCredentials 

type DatadogConnectorProfileCredentials struct {

	// A unique alphanumeric identifier used to authenticate a user, developer,
	// or calling program to your API.
	//
	// ApiKey is a required field
	ApiKey *string `locationName:"apiKey" type:"string" required:"true"`

	// Application keys, in conjunction with your API key, give you full access
	// to Datadog’s programmatic API. Application keys are associated with the
	// user account that created them. The application key is used to log all requests
	// made to the API.
	//
	// ApplicationKey is a required field
	ApplicationKey *string `locationName:"applicationKey" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific credentials required by Datadog.

func (DatadogConnectorProfileCredentials) GoString 

func (s DatadogConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*DatadogConnectorProfileCredentials) SetApiKey 

func (s *DatadogConnectorProfileCredentials) SetApiKey(v string) *DatadogConnectorProfileCredentials

SetApiKey sets the ApiKey field's value.

func (*DatadogConnectorProfileCredentials) SetApplicationKey 

func (s *DatadogConnectorProfileCredentials) SetApplicationKey(v string) *DatadogConnectorProfileCredentials

SetApplicationKey sets the ApplicationKey field's value.

func (DatadogConnectorProfileCredentials) String 

func (s DatadogConnectorProfileCredentials) String() string

String returns the string representation

func (*DatadogConnectorProfileCredentials) Validate 

func (s *DatadogConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DatadogConnectorProfileProperties 

type DatadogConnectorProfileProperties struct {

	// The location of the Datadog resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required by Datadog.

func (DatadogConnectorProfileProperties) GoString 

func (s DatadogConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*DatadogConnectorProfileProperties) SetInstanceUrl 

func (s *DatadogConnectorProfileProperties) SetInstanceUrl(v string) *DatadogConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (DatadogConnectorProfileProperties) String 

func (s DatadogConnectorProfileProperties) String() string

String returns the string representation

func (*DatadogConnectorProfileProperties) Validate 

func (s *DatadogConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DatadogMetadata 

type DatadogMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Datadog.

func (DatadogMetadata) GoString 

func (s DatadogMetadata) GoString() string

GoString returns the string representation

func (DatadogMetadata) String 

func (s DatadogMetadata) String() string

String returns the string representation

type DatadogSourceProperties 

type DatadogSourceProperties struct {

	// The object specified in the Datadog flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Datadog is being used as a source.

func (DatadogSourceProperties) GoString 

func (s DatadogSourceProperties) GoString() string

GoString returns the string representation

func (*DatadogSourceProperties) SetObject 

func (s *DatadogSourceProperties) SetObject(v string) *DatadogSourceProperties

SetObject sets the Object field's value.

func (DatadogSourceProperties) String 

func (s DatadogSourceProperties) String() string

String returns the string representation

func (*DatadogSourceProperties) Validate 

func (s *DatadogSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteConnectorProfileInput 

type DeleteConnectorProfileInput struct {

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in your account.
	//
	// ConnectorProfileName is a required field
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`

	// Indicates whether Amazon AppFlow should delete the profile, even if it is
	// currently in use in one or more flows.
	ForceDelete *bool `locationName:"forceDelete" type:"boolean"`
	// contains filtered or unexported fields
}

func (DeleteConnectorProfileInput) GoString 

func (s DeleteConnectorProfileInput) GoString() string

GoString returns the string representation

func (*DeleteConnectorProfileInput) SetConnectorProfileName 

func (s *DeleteConnectorProfileInput) SetConnectorProfileName(v string) *DeleteConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DeleteConnectorProfileInput) SetForceDelete 

func (s *DeleteConnectorProfileInput) SetForceDelete(v bool) *DeleteConnectorProfileInput

SetForceDelete sets the ForceDelete field's value.

func (DeleteConnectorProfileInput) String 

func (s DeleteConnectorProfileInput) String() string

String returns the string representation

func (*DeleteConnectorProfileInput) Validate 

func (s *DeleteConnectorProfileInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteConnectorProfileOutput 

type DeleteConnectorProfileOutput struct {
	// contains filtered or unexported fields
}

func (DeleteConnectorProfileOutput) GoString 

func (s DeleteConnectorProfileOutput) GoString() string

GoString returns the string representation

func (DeleteConnectorProfileOutput) String 

func (s DeleteConnectorProfileOutput) String() string

String returns the string representation

type DeleteFlowInput 

type DeleteFlowInput struct {

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`

	// Indicates whether Amazon AppFlow should delete the flow, even if it is currently
	// in use.
	ForceDelete *bool `locationName:"forceDelete" type:"boolean"`
	// contains filtered or unexported fields
}

func (DeleteFlowInput) GoString 

func (s DeleteFlowInput) GoString() string

GoString returns the string representation

func (*DeleteFlowInput) SetFlowName 

func (s *DeleteFlowInput) SetFlowName(v string) *DeleteFlowInput

SetFlowName sets the FlowName field's value.

func (*DeleteFlowInput) SetForceDelete 

func (s *DeleteFlowInput) SetForceDelete(v bool) *DeleteFlowInput

SetForceDelete sets the ForceDelete field's value.

func (DeleteFlowInput) String 

func (s DeleteFlowInput) String() string

String returns the string representation

func (*DeleteFlowInput) Validate 

func (s *DeleteFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteFlowOutput 

type DeleteFlowOutput struct {
	// contains filtered or unexported fields
}

func (DeleteFlowOutput) GoString 

func (s DeleteFlowOutput) GoString() string

GoString returns the string representation

func (DeleteFlowOutput) String 

func (s DeleteFlowOutput) String() string

String returns the string representation

type DescribeConnectorEntityInput 

type DescribeConnectorEntityInput struct {

	// The entity name for that connector.
	//
	// ConnectorEntityName is a required field
	ConnectorEntityName *string `locationName:"connectorEntityName" type:"string" required:"true"`

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in the AWS account.
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

	// The type of connector application, such as Salesforce, Amplitude, and so
	// on.
	ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`
	// contains filtered or unexported fields
}

func (DescribeConnectorEntityInput) GoString 

func (s DescribeConnectorEntityInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorEntityInput) SetConnectorEntityName 

func (s *DescribeConnectorEntityInput) SetConnectorEntityName(v string) *DescribeConnectorEntityInput

SetConnectorEntityName sets the ConnectorEntityName field's value.

func (*DescribeConnectorEntityInput) SetConnectorProfileName 

func (s *DescribeConnectorEntityInput) SetConnectorProfileName(v string) *DescribeConnectorEntityInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DescribeConnectorEntityInput) SetConnectorType 

func (s *DescribeConnectorEntityInput) SetConnectorType(v string) *DescribeConnectorEntityInput

SetConnectorType sets the ConnectorType field's value.

func (DescribeConnectorEntityInput) String 

func (s DescribeConnectorEntityInput) String() string

String returns the string representation

func (*DescribeConnectorEntityInput) Validate 

func (s *DescribeConnectorEntityInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeConnectorEntityOutput 

type DescribeConnectorEntityOutput struct {

	// Describes the fields for that connector entity. For example, for an account
	// entity, the fields would be account name, account ID, and so on.
	//
	// ConnectorEntityFields is a required field
	ConnectorEntityFields []*ConnectorEntityField `locationName:"connectorEntityFields" type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (DescribeConnectorEntityOutput) GoString 

func (s DescribeConnectorEntityOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorEntityOutput) SetConnectorEntityFields 

func (s *DescribeConnectorEntityOutput) SetConnectorEntityFields(v []*ConnectorEntityField) *DescribeConnectorEntityOutput

SetConnectorEntityFields sets the ConnectorEntityFields field's value.

func (DescribeConnectorEntityOutput) String 

func (s DescribeConnectorEntityOutput) String() string

String returns the string representation

type DescribeConnectorProfilesInput 

type DescribeConnectorProfilesInput struct {

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in the AWS account.
	ConnectorProfileNames []*string `locationName:"connectorProfileNames" type:"list"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

	// 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).
	MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

	// The pagination token for the next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConnectorProfilesInput) GoString 

func (s DescribeConnectorProfilesInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorProfilesInput) SetConnectorProfileNames 

func (s *DescribeConnectorProfilesInput) SetConnectorProfileNames(v []*string) *DescribeConnectorProfilesInput

SetConnectorProfileNames sets the ConnectorProfileNames field's value.

func (*DescribeConnectorProfilesInput) SetConnectorType 

func (s *DescribeConnectorProfilesInput) SetConnectorType(v string) *DescribeConnectorProfilesInput

SetConnectorType sets the ConnectorType field's value.

func (*DescribeConnectorProfilesInput) SetMaxResults 

func (s *DescribeConnectorProfilesInput) SetMaxResults(v int64) *DescribeConnectorProfilesInput

SetMaxResults sets the MaxResults field's value.

func (*DescribeConnectorProfilesInput) SetNextToken 

func (s *DescribeConnectorProfilesInput) SetNextToken(v string) *DescribeConnectorProfilesInput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesInput) String 

func (s DescribeConnectorProfilesInput) String() string

String returns the string representation

func (*DescribeConnectorProfilesInput) Validate 

func (s *DescribeConnectorProfilesInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeConnectorProfilesOutput 

type DescribeConnectorProfilesOutput struct {

	// Returns information about the connector profiles associated with the flow.
	ConnectorProfileDetails []*ConnectorProfile `locationName:"connectorProfileDetails" type:"list"`

	// The pagination token for the next page of data. If nextToken=null, this means
	// that all records have been fetched.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConnectorProfilesOutput) GoString 

func (s DescribeConnectorProfilesOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorProfilesOutput) SetConnectorProfileDetails 

func (s *DescribeConnectorProfilesOutput) SetConnectorProfileDetails(v []*ConnectorProfile) *DescribeConnectorProfilesOutput

SetConnectorProfileDetails sets the ConnectorProfileDetails field's value.

func (*DescribeConnectorProfilesOutput) SetNextToken 

func (s *DescribeConnectorProfilesOutput) SetNextToken(v string) *DescribeConnectorProfilesOutput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesOutput) String 

func (s DescribeConnectorProfilesOutput) String() string

String returns the string representation

type DescribeConnectorsInput 

type DescribeConnectorsInput struct {

	// The type of connector, such as Salesforce, Amplitude, and so on.
	ConnectorTypes []*string `locationName:"connectorTypes" type:"list"`

	// The pagination token for the next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConnectorsInput) GoString 

func (s DescribeConnectorsInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorsInput) SetConnectorTypes 

func (s *DescribeConnectorsInput) SetConnectorTypes(v []*string) *DescribeConnectorsInput

SetConnectorTypes sets the ConnectorTypes field's value.

func (*DescribeConnectorsInput) SetNextToken 

func (s *DescribeConnectorsInput) SetNextToken(v string) *DescribeConnectorsInput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorsInput) String 

func (s DescribeConnectorsInput) String() string

String returns the string representation

type DescribeConnectorsOutput 

type DescribeConnectorsOutput struct {

	// The configuration that is applied to the connectors used in the flow.
	ConnectorConfigurations map[string]*ConnectorConfiguration `locationName:"connectorConfigurations" type:"map"`

	// The pagination token for the next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConnectorsOutput) GoString 

func (s DescribeConnectorsOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorsOutput) SetConnectorConfigurations 

func (s *DescribeConnectorsOutput) SetConnectorConfigurations(v map[string]*ConnectorConfiguration) *DescribeConnectorsOutput

SetConnectorConfigurations sets the ConnectorConfigurations field's value.

func (*DescribeConnectorsOutput) SetNextToken 

func (s *DescribeConnectorsOutput) SetNextToken(v string) *DescribeConnectorsOutput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorsOutput) String 

func (s DescribeConnectorsOutput) String() string

String returns the string representation

type DescribeFlowExecutionRecordsInput 

type DescribeFlowExecutionRecordsInput struct {

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`

	// 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).
	MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

	// The pagination token for the next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeFlowExecutionRecordsInput) GoString 

func (s DescribeFlowExecutionRecordsInput) GoString() string

GoString returns the string representation

func (*DescribeFlowExecutionRecordsInput) SetFlowName 

func (s *DescribeFlowExecutionRecordsInput) SetFlowName(v string) *DescribeFlowExecutionRecordsInput

SetFlowName sets the FlowName field's value.

func (*DescribeFlowExecutionRecordsInput) SetMaxResults 

func (s *DescribeFlowExecutionRecordsInput) SetMaxResults(v int64) *DescribeFlowExecutionRecordsInput

SetMaxResults sets the MaxResults field's value.

func (*DescribeFlowExecutionRecordsInput) SetNextToken 

func (s *DescribeFlowExecutionRecordsInput) SetNextToken(v string) *DescribeFlowExecutionRecordsInput

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsInput) String 

func (s DescribeFlowExecutionRecordsInput) String() string

String returns the string representation

func (*DescribeFlowExecutionRecordsInput) Validate 

func (s *DescribeFlowExecutionRecordsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeFlowExecutionRecordsOutput 

type DescribeFlowExecutionRecordsOutput struct {

	// Returns a list of all instances when this flow was run.
	FlowExecutions []*ExecutionRecord `locationName:"flowExecutions" type:"list"`

	// The pagination token for the next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (DescribeFlowExecutionRecordsOutput) GoString 

func (s DescribeFlowExecutionRecordsOutput) GoString() string

GoString returns the string representation

func (*DescribeFlowExecutionRecordsOutput) SetFlowExecutions 

func (s *DescribeFlowExecutionRecordsOutput) SetFlowExecutions(v []*ExecutionRecord) *DescribeFlowExecutionRecordsOutput

SetFlowExecutions sets the FlowExecutions field's value.

func (*DescribeFlowExecutionRecordsOutput) SetNextToken 

func (s *DescribeFlowExecutionRecordsOutput) SetNextToken(v string) *DescribeFlowExecutionRecordsOutput

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsOutput) String 

func (s DescribeFlowExecutionRecordsOutput) String() string

String returns the string representation

type DescribeFlowInput 

type DescribeFlowInput struct {

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DescribeFlowInput) GoString 

func (s DescribeFlowInput) GoString() string

GoString returns the string representation

func (*DescribeFlowInput) SetFlowName 

func (s *DescribeFlowInput) SetFlowName(v string) *DescribeFlowInput

SetFlowName sets the FlowName field's value.

func (DescribeFlowInput) String 

func (s DescribeFlowInput) String() string

String returns the string representation

func (*DescribeFlowInput) Validate 

func (s *DescribeFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeFlowOutput 

type DescribeFlowOutput struct {

	// Specifies when the flow was created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp"`

	// The ARN of the user who created the flow.
	CreatedBy *string `locationName:"createdBy" type:"string"`

	// A description of the flow.
	Description *string `locationName:"description" type:"string"`

	// The configuration that controls how Amazon AppFlow transfers data to the
	// destination connector.
	DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list"`

	// The flow's Amazon Resource Name (ARN).
	FlowArn *string `locationName:"flowArn" type:"string"`

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	FlowName *string `locationName:"flowName" type:"string"`

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`

	// Contains an error message if the flow status is in a suspended or error state.
	// This applies only to scheduled or event-triggered flows.
	FlowStatusMessage *string `locationName:"flowStatusMessage" type:"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.
	KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`

	// Describes the details of the most recent flow run.
	LastRunExecutionDetails *ExecutionDetails `locationName:"lastRunExecutionDetails" type:"structure"`

	// Specifies when the flow was last updated.
	LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`

	// Specifies the user name of the account that performed the most recent update.
	LastUpdatedBy *string `locationName:"lastUpdatedBy" type:"string"`

	// The configuration that controls how Amazon AppFlow retrieves data from the
	// source connector.
	SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure"`

	// The tags used to organize, track, or control access for your flow.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// A list of tasks that Amazon AppFlow performs while transferring the data
	// in the flow run.
	Tasks []*Task `locationName:"tasks" type:"list"`

	// The trigger settings that determine how and when the flow runs.
	TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure"`
	// contains filtered or unexported fields
}

func (DescribeFlowOutput) GoString 

func (s DescribeFlowOutput) GoString() string

GoString returns the string representation

func (*DescribeFlowOutput) SetCreatedAt 

func (s *DescribeFlowOutput) SetCreatedAt(v time.Time) *DescribeFlowOutput

SetCreatedAt sets the CreatedAt field's value.

func (*DescribeFlowOutput) SetCreatedBy 

func (s *DescribeFlowOutput) SetCreatedBy(v string) *DescribeFlowOutput

SetCreatedBy sets the CreatedBy field's value.

func (*DescribeFlowOutput) SetDescription 

func (s *DescribeFlowOutput) SetDescription(v string) *DescribeFlowOutput

SetDescription sets the Description field's value.

func (*DescribeFlowOutput) SetDestinationFlowConfigList 

func (s *DescribeFlowOutput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *DescribeFlowOutput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*DescribeFlowOutput) SetFlowArn 

func (s *DescribeFlowOutput) SetFlowArn(v string) *DescribeFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*DescribeFlowOutput) SetFlowName 

func (s *DescribeFlowOutput) SetFlowName(v string) *DescribeFlowOutput

SetFlowName sets the FlowName field's value.

func (*DescribeFlowOutput) SetFlowStatus 

func (s *DescribeFlowOutput) SetFlowStatus(v string) *DescribeFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (*DescribeFlowOutput) SetFlowStatusMessage 

func (s *DescribeFlowOutput) SetFlowStatusMessage(v string) *DescribeFlowOutput

SetFlowStatusMessage sets the FlowStatusMessage field's value.

func (*DescribeFlowOutput) SetKmsArn 

func (s *DescribeFlowOutput) SetKmsArn(v string) *DescribeFlowOutput

SetKmsArn sets the KmsArn field's value.

func (*DescribeFlowOutput) SetLastRunExecutionDetails 

func (s *DescribeFlowOutput) SetLastRunExecutionDetails(v *ExecutionDetails) *DescribeFlowOutput

SetLastRunExecutionDetails sets the LastRunExecutionDetails field's value.

func (*DescribeFlowOutput) SetLastUpdatedAt 

func (s *DescribeFlowOutput) SetLastUpdatedAt(v time.Time) *DescribeFlowOutput

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*DescribeFlowOutput) SetLastUpdatedBy 

func (s *DescribeFlowOutput) SetLastUpdatedBy(v string) *DescribeFlowOutput

SetLastUpdatedBy sets the LastUpdatedBy field's value.

func (*DescribeFlowOutput) SetSourceFlowConfig 

func (s *DescribeFlowOutput) SetSourceFlowConfig(v *SourceFlowConfig) *DescribeFlowOutput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*DescribeFlowOutput) SetTags 

func (s *DescribeFlowOutput) SetTags(v map[string]*string) *DescribeFlowOutput

SetTags sets the Tags field's value.

func (*DescribeFlowOutput) SetTasks 

func (s *DescribeFlowOutput) SetTasks(v []*Task) *DescribeFlowOutput

SetTasks sets the Tasks field's value.

func (*DescribeFlowOutput) SetTriggerConfig 

func (s *DescribeFlowOutput) SetTriggerConfig(v *TriggerConfig) *DescribeFlowOutput

SetTriggerConfig sets the TriggerConfig field's value.

func (DescribeFlowOutput) String 

func (s DescribeFlowOutput) String() string

String returns the string representation

type DestinationConnectorProperties 

type DestinationConnectorProperties struct {

	// The properties required to query Amazon Connect Customer Profiles.
	CustomerProfiles *CustomerProfilesDestinationProperties `type:"structure"`

	// The properties required to query Amazon EventBridge.
	EventBridge *EventBridgeDestinationProperties `type:"structure"`

	// The properties required to query Amazon Honeycode.
	Honeycode *HoneycodeDestinationProperties `type:"structure"`

	// The properties required to query Amazon Lookout for Metrics.
	LookoutMetrics *LookoutMetricsDestinationProperties `type:"structure"`

	// The properties required to query Amazon Redshift.
	Redshift *RedshiftDestinationProperties `type:"structure"`

	// The properties required to query Amazon S3.
	S3 *S3DestinationProperties `type:"structure"`

	// The properties required to query Salesforce.
	Salesforce *SalesforceDestinationProperties `type:"structure"`

	// The properties required to query Snowflake.
	Snowflake *SnowflakeDestinationProperties `type:"structure"`

	// The properties required to query Upsolver.
	Upsolver *UpsolverDestinationProperties `type:"structure"`

	// The properties required to query Zendesk.
	Zendesk *ZendeskDestinationProperties `type:"structure"`
	// contains filtered or unexported fields
}

This stores the information that is required to query a particular connector.

func (DestinationConnectorProperties) GoString 

func (s DestinationConnectorProperties) GoString() string

GoString returns the string representation

func (*DestinationConnectorProperties) SetCustomerProfiles added in v1.37.18 

func (s *DestinationConnectorProperties) SetCustomerProfiles(v *CustomerProfilesDestinationProperties) *DestinationConnectorProperties

SetCustomerProfiles sets the CustomerProfiles field's value.

func (*DestinationConnectorProperties) SetEventBridge 

func (s *DestinationConnectorProperties) SetEventBridge(v *EventBridgeDestinationProperties) *DestinationConnectorProperties

SetEventBridge sets the EventBridge field's value.

func (*DestinationConnectorProperties) SetHoneycode added in v1.37.18 

func (s *DestinationConnectorProperties) SetHoneycode(v *HoneycodeDestinationProperties) *DestinationConnectorProperties

SetHoneycode sets the Honeycode field's value.

func (*DestinationConnectorProperties) SetLookoutMetrics added in v1.37.18 

func (s *DestinationConnectorProperties) SetLookoutMetrics(v *LookoutMetricsDestinationProperties) *DestinationConnectorProperties

SetLookoutMetrics sets the LookoutMetrics field's value.

func (*DestinationConnectorProperties) SetRedshift 

func (s *DestinationConnectorProperties) SetRedshift(v *RedshiftDestinationProperties) *DestinationConnectorProperties

SetRedshift sets the Redshift field's value.

func (*DestinationConnectorProperties) SetS3 

func (s *DestinationConnectorProperties) SetS3(v *S3DestinationProperties) *DestinationConnectorProperties

SetS3 sets the S3 field's value.

func (*DestinationConnectorProperties) SetSalesforce 

func (s *DestinationConnectorProperties) SetSalesforce(v *SalesforceDestinationProperties) *DestinationConnectorProperties

SetSalesforce sets the Salesforce field's value.

func (*DestinationConnectorProperties) SetSnowflake 

func (s *DestinationConnectorProperties) SetSnowflake(v *SnowflakeDestinationProperties) *DestinationConnectorProperties

SetSnowflake sets the Snowflake field's value.

func (*DestinationConnectorProperties) SetUpsolver added in v1.35.35 

func (s *DestinationConnectorProperties) SetUpsolver(v *UpsolverDestinationProperties) *DestinationConnectorProperties

SetUpsolver sets the Upsolver field's value.

func (*DestinationConnectorProperties) SetZendesk added in v1.38.13 

func (s *DestinationConnectorProperties) SetZendesk(v *ZendeskDestinationProperties) *DestinationConnectorProperties

SetZendesk sets the Zendesk field's value.

func (DestinationConnectorProperties) String 

func (s DestinationConnectorProperties) String() string

String returns the string representation

func (*DestinationConnectorProperties) Validate 

func (s *DestinationConnectorProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DestinationFieldProperties 

type DestinationFieldProperties struct {

	// Specifies if the destination field can be created by the current user.
	IsCreatable *bool `locationName:"isCreatable" type:"boolean"`

	// Specifies if the destination field can have a null value.
	IsNullable *bool `locationName:"isNullable" type:"boolean"`

	// Specifies whether the field can be updated during an UPDATE or UPSERT write
	// operation.
	IsUpdatable *bool `locationName:"isUpdatable" type:"boolean"`

	// Specifies if the flow run can either insert new rows in the destination field
	// if they do not already exist, or update them if they do.
	IsUpsertable *bool `locationName:"isUpsertable" type:"boolean"`

	// A list of supported write operations. For each write operation listed, this
	// field can be used in idFieldNames when that write operation is present as
	// a destination option.
	SupportedWriteOperations []*string `locationName:"supportedWriteOperations" type:"list"`
	// contains filtered or unexported fields
}

The properties that can be applied to a field when connector is being used as a destination.

func (DestinationFieldProperties) GoString 

func (s DestinationFieldProperties) GoString() string

GoString returns the string representation

func (*DestinationFieldProperties) SetIsCreatable 

func (s *DestinationFieldProperties) SetIsCreatable(v bool) *DestinationFieldProperties

SetIsCreatable sets the IsCreatable field's value.

func (*DestinationFieldProperties) SetIsNullable 

func (s *DestinationFieldProperties) SetIsNullable(v bool) *DestinationFieldProperties

SetIsNullable sets the IsNullable field's value.

func (*DestinationFieldProperties) SetIsUpdatable added in v1.35.13 

func (s *DestinationFieldProperties) SetIsUpdatable(v bool) *DestinationFieldProperties

SetIsUpdatable sets the IsUpdatable field's value.

func (*DestinationFieldProperties) SetIsUpsertable 

func (s *DestinationFieldProperties) SetIsUpsertable(v bool) *DestinationFieldProperties

SetIsUpsertable sets the IsUpsertable field's value.

func (*DestinationFieldProperties) SetSupportedWriteOperations added in v1.35.13 

func (s *DestinationFieldProperties) SetSupportedWriteOperations(v []*string) *DestinationFieldProperties

SetSupportedWriteOperations sets the SupportedWriteOperations field's value.

func (DestinationFieldProperties) String 

func (s DestinationFieldProperties) String() string

String returns the string representation

type DestinationFlowConfig 

type DestinationFlowConfig struct {

	// The name of the connector profile. This name must be unique for each connector
	// profile in the AWS account.
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	//
	// ConnectorType is a required field
	ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

	// This stores the information that is required to query a particular connector.
	//
	// DestinationConnectorProperties is a required field
	DestinationConnectorProperties *DestinationConnectorProperties `locationName:"destinationConnectorProperties" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

Contains information about the configuration of destination connectors present in the flow.

func (DestinationFlowConfig) GoString 

func (s DestinationFlowConfig) GoString() string

GoString returns the string representation

func (*DestinationFlowConfig) SetConnectorProfileName 

func (s *DestinationFlowConfig) SetConnectorProfileName(v string) *DestinationFlowConfig

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DestinationFlowConfig) SetConnectorType 

func (s *DestinationFlowConfig) SetConnectorType(v string) *DestinationFlowConfig

SetConnectorType sets the ConnectorType field's value.

func (*DestinationFlowConfig) SetDestinationConnectorProperties 

func (s *DestinationFlowConfig) SetDestinationConnectorProperties(v *DestinationConnectorProperties) *DestinationFlowConfig

SetDestinationConnectorProperties sets the DestinationConnectorProperties field's value.

func (DestinationFlowConfig) String 

func (s DestinationFlowConfig) String() string

String returns the string representation

func (*DestinationFlowConfig) Validate 

func (s *DestinationFlowConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DynatraceConnectorProfileCredentials 

type DynatraceConnectorProfileCredentials struct {

	// The API tokens used by Dynatrace API to authenticate various API calls.
	//
	// ApiToken is a required field
	ApiToken *string `locationName:"apiToken" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required by Dynatrace.

func (DynatraceConnectorProfileCredentials) GoString 

func (s DynatraceConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*DynatraceConnectorProfileCredentials) SetApiToken 

func (s *DynatraceConnectorProfileCredentials) SetApiToken(v string) *DynatraceConnectorProfileCredentials

SetApiToken sets the ApiToken field's value.

func (DynatraceConnectorProfileCredentials) String 

func (s DynatraceConnectorProfileCredentials) String() string

String returns the string representation

func (*DynatraceConnectorProfileCredentials) Validate 

func (s *DynatraceConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DynatraceConnectorProfileProperties 

type DynatraceConnectorProfileProperties struct {

	// The location of the Dynatrace resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required by Dynatrace.

func (DynatraceConnectorProfileProperties) GoString 

func (s DynatraceConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*DynatraceConnectorProfileProperties) SetInstanceUrl 

func (s *DynatraceConnectorProfileProperties) SetInstanceUrl(v string) *DynatraceConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (DynatraceConnectorProfileProperties) String 

func (s DynatraceConnectorProfileProperties) String() string

String returns the string representation

func (*DynatraceConnectorProfileProperties) Validate 

func (s *DynatraceConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DynatraceMetadata 

type DynatraceMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Dynatrace.

func (DynatraceMetadata) GoString 

func (s DynatraceMetadata) GoString() string

GoString returns the string representation

func (DynatraceMetadata) String 

func (s DynatraceMetadata) String() string

String returns the string representation

type DynatraceSourceProperties 

type DynatraceSourceProperties struct {

	// The object specified in the Dynatrace flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Dynatrace is being used as a source.

func (DynatraceSourceProperties) GoString 

func (s DynatraceSourceProperties) GoString() string

GoString returns the string representation

func (*DynatraceSourceProperties) SetObject 

func (s *DynatraceSourceProperties) SetObject(v string) *DynatraceSourceProperties

SetObject sets the Object field's value.

func (DynatraceSourceProperties) String 

func (s DynatraceSourceProperties) String() string

String returns the string representation

func (*DynatraceSourceProperties) Validate 

func (s *DynatraceSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ErrorHandlingConfig 

type ErrorHandlingConfig struct {

	// Specifies the name of the Amazon S3 bucket.
	BucketName *string `locationName:"bucketName" min:"3" type:"string"`

	// Specifies the Amazon S3 bucket prefix.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// Specifies if the flow should fail after the first instance of a failure when
	// attempting to place data in the destination.
	FailOnFirstDestinationError *bool `locationName:"failOnFirstDestinationError" type:"boolean"`
	// contains filtered or unexported fields
}

The settings that determine how Amazon AppFlow handles an error when placing data in the destination. For example, this setting would determine if the flow should fail after one insertion error, or continue and attempt to insert every record regardless of the initial failure. ErrorHandlingConfig is a part of the destination connector details.

func (ErrorHandlingConfig) GoString 

func (s ErrorHandlingConfig) GoString() string

GoString returns the string representation

func (*ErrorHandlingConfig) SetBucketName 

func (s *ErrorHandlingConfig) SetBucketName(v string) *ErrorHandlingConfig

SetBucketName sets the BucketName field's value.

func (*ErrorHandlingConfig) SetBucketPrefix 

func (s *ErrorHandlingConfig) SetBucketPrefix(v string) *ErrorHandlingConfig

SetBucketPrefix sets the BucketPrefix field's value.

func (*ErrorHandlingConfig) SetFailOnFirstDestinationError 

func (s *ErrorHandlingConfig) SetFailOnFirstDestinationError(v bool) *ErrorHandlingConfig

SetFailOnFirstDestinationError sets the FailOnFirstDestinationError field's value.

func (ErrorHandlingConfig) String 

func (s ErrorHandlingConfig) String() string

String returns the string representation

func (*ErrorHandlingConfig) Validate 

func (s *ErrorHandlingConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ErrorInfo 

type ErrorInfo struct {

	// Specifies the error message that appears if a flow fails.
	ExecutionMessage *string `locationName:"executionMessage" type:"string"`

	// Specifies the failure count for the attempted flow.
	PutFailuresCount *int64 `locationName:"putFailuresCount" type:"long"`
	// contains filtered or unexported fields
}

Provides details in the event of a failed flow, including the failure count and the related error messages.

func (ErrorInfo) GoString 

func (s ErrorInfo) GoString() string

GoString returns the string representation

func (*ErrorInfo) SetExecutionMessage 

func (s *ErrorInfo) SetExecutionMessage(v string) *ErrorInfo

SetExecutionMessage sets the ExecutionMessage field's value.

func (*ErrorInfo) SetPutFailuresCount 

func (s *ErrorInfo) SetPutFailuresCount(v int64) *ErrorInfo

SetPutFailuresCount sets the PutFailuresCount field's value.

func (ErrorInfo) String 

func (s ErrorInfo) String() string

String returns the string representation

type EventBridgeDestinationProperties 

type EventBridgeDestinationProperties struct {

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the destination. For example, this setting would determine if the
	// flow should fail after one insertion error, or continue and attempt to insert
	// every record regardless of the initial failure. ErrorHandlingConfig is a
	// part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// The object specified in the Amazon EventBridge flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon EventBridge is being used as a destination.

func (EventBridgeDestinationProperties) GoString 

func (s EventBridgeDestinationProperties) GoString() string

GoString returns the string representation

func (*EventBridgeDestinationProperties) SetErrorHandlingConfig 

func (s *EventBridgeDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *EventBridgeDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*EventBridgeDestinationProperties) SetObject 

func (s *EventBridgeDestinationProperties) SetObject(v string) *EventBridgeDestinationProperties

SetObject sets the Object field's value.

func (EventBridgeDestinationProperties) String 

func (s EventBridgeDestinationProperties) String() string

String returns the string representation

func (*EventBridgeDestinationProperties) Validate 

func (s *EventBridgeDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type EventBridgeMetadata 

type EventBridgeMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Amazon EventBridge.

func (EventBridgeMetadata) GoString 

func (s EventBridgeMetadata) GoString() string

GoString returns the string representation

func (EventBridgeMetadata) String 

func (s EventBridgeMetadata) String() string

String returns the string representation

type ExecutionDetails 

type ExecutionDetails struct {

	// Describes the details of the most recent flow run.
	MostRecentExecutionMessage *string `locationName:"mostRecentExecutionMessage" type:"string"`

	// Specifies the status of the most recent flow run.
	MostRecentExecutionStatus *string `locationName:"mostRecentExecutionStatus" type:"string" enum:"ExecutionStatus"`

	// Specifies the time of the most recent flow run.
	MostRecentExecutionTime *time.Time `locationName:"mostRecentExecutionTime" type:"timestamp"`
	// contains filtered or unexported fields
}

Describes the details of the flow run, including the timestamp, status, and message.

func (ExecutionDetails) GoString 

func (s ExecutionDetails) GoString() string

GoString returns the string representation

func (*ExecutionDetails) SetMostRecentExecutionMessage 

func (s *ExecutionDetails) SetMostRecentExecutionMessage(v string) *ExecutionDetails

SetMostRecentExecutionMessage sets the MostRecentExecutionMessage field's value.

func (*ExecutionDetails) SetMostRecentExecutionStatus 

func (s *ExecutionDetails) SetMostRecentExecutionStatus(v string) *ExecutionDetails

SetMostRecentExecutionStatus sets the MostRecentExecutionStatus field's value.

func (*ExecutionDetails) SetMostRecentExecutionTime 

func (s *ExecutionDetails) SetMostRecentExecutionTime(v time.Time) *ExecutionDetails

SetMostRecentExecutionTime sets the MostRecentExecutionTime field's value.

func (ExecutionDetails) String 

func (s ExecutionDetails) String() string

String returns the string representation

type ExecutionRecord 

type ExecutionRecord struct {

	// The timestamp that indicates the last new or updated record to be transferred
	// in the flow run.
	DataPullEndTime *time.Time `locationName:"dataPullEndTime" type:"timestamp"`

	// The timestamp that determines the first new or updated record to be transferred
	// in the flow run.
	DataPullStartTime *time.Time `locationName:"dataPullStartTime" type:"timestamp"`

	// Specifies the identifier of the given flow run.
	ExecutionId *string `locationName:"executionId" type:"string"`

	// Describes the result of the given flow run.
	ExecutionResult *ExecutionResult `locationName:"executionResult" type:"structure"`

	// Specifies the flow run status and whether it is in progress, has completed
	// successfully, or has failed.
	ExecutionStatus *string `locationName:"executionStatus" type:"string" enum:"ExecutionStatus"`

	// Specifies the time of the most recent update.
	LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`

	// Specifies the start time of the flow run.
	StartedAt *time.Time `locationName:"startedAt" type:"timestamp"`
	// contains filtered or unexported fields
}

Specifies information about the past flow run instances for a given flow.

func (ExecutionRecord) GoString 

func (s ExecutionRecord) GoString() string

GoString returns the string representation

func (*ExecutionRecord) SetDataPullEndTime added in v1.37.4 

func (s *ExecutionRecord) SetDataPullEndTime(v time.Time) *ExecutionRecord

SetDataPullEndTime sets the DataPullEndTime field's value.

func (*ExecutionRecord) SetDataPullStartTime added in v1.37.4 

func (s *ExecutionRecord) SetDataPullStartTime(v time.Time) *ExecutionRecord

SetDataPullStartTime sets the DataPullStartTime field's value.

func (*ExecutionRecord) SetExecutionId 

func (s *ExecutionRecord) SetExecutionId(v string) *ExecutionRecord

SetExecutionId sets the ExecutionId field's value.

func (*ExecutionRecord) SetExecutionResult 

func (s *ExecutionRecord) SetExecutionResult(v *ExecutionResult) *ExecutionRecord

SetExecutionResult sets the ExecutionResult field's value.

func (*ExecutionRecord) SetExecutionStatus 

func (s *ExecutionRecord) SetExecutionStatus(v string) *ExecutionRecord

SetExecutionStatus sets the ExecutionStatus field's value.

func (*ExecutionRecord) SetLastUpdatedAt 

func (s *ExecutionRecord) SetLastUpdatedAt(v time.Time) *ExecutionRecord

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*ExecutionRecord) SetStartedAt 

func (s *ExecutionRecord) SetStartedAt(v time.Time) *ExecutionRecord

SetStartedAt sets the StartedAt field's value.

func (ExecutionRecord) String 

func (s ExecutionRecord) String() string

String returns the string representation

type ExecutionResult 

type ExecutionResult struct {

	// The total number of bytes processed by the flow run.
	BytesProcessed *int64 `locationName:"bytesProcessed" type:"long"`

	// The total number of bytes written as a result of the flow run.
	BytesWritten *int64 `locationName:"bytesWritten" type:"long"`

	// Provides any error message information related to the flow run.
	ErrorInfo *ErrorInfo `locationName:"errorInfo" type:"structure"`

	// The number of records processed in the flow run.
	RecordsProcessed *int64 `locationName:"recordsProcessed" type:"long"`
	// contains filtered or unexported fields
}

Specifies the end result of the flow run.

func (ExecutionResult) GoString 

func (s ExecutionResult) GoString() string

GoString returns the string representation

func (*ExecutionResult) SetBytesProcessed 

func (s *ExecutionResult) SetBytesProcessed(v int64) *ExecutionResult

SetBytesProcessed sets the BytesProcessed field's value.

func (*ExecutionResult) SetBytesWritten 

func (s *ExecutionResult) SetBytesWritten(v int64) *ExecutionResult

SetBytesWritten sets the BytesWritten field's value.

func (*ExecutionResult) SetErrorInfo 

func (s *ExecutionResult) SetErrorInfo(v *ErrorInfo) *ExecutionResult

SetErrorInfo sets the ErrorInfo field's value.

func (*ExecutionResult) SetRecordsProcessed 

func (s *ExecutionResult) SetRecordsProcessed(v int64) *ExecutionResult

SetRecordsProcessed sets the RecordsProcessed field's value.

func (ExecutionResult) String 

func (s ExecutionResult) String() string

String returns the string representation

type FieldTypeDetails 

type FieldTypeDetails struct {

	// The type of field, such as string, integer, date, and so on.
	//
	// FieldType is a required field
	FieldType *string `locationName:"fieldType" type:"string" required:"true"`

	// The list of operators supported by a field.
	//
	// FilterOperators is a required field
	FilterOperators []*string `locationName:"filterOperators" type:"list" required:"true"`

	// The list of values that a field can contain. For example, a Boolean fieldType
	// can have two values: "true" and "false".
	SupportedValues []*string `locationName:"supportedValues" type:"list"`
	// contains filtered or unexported fields
}

Contains details regarding the supported field type and the operators that can be applied for filtering.

func (FieldTypeDetails) GoString 

func (s FieldTypeDetails) GoString() string

GoString returns the string representation

func (*FieldTypeDetails) SetFieldType 

func (s *FieldTypeDetails) SetFieldType(v string) *FieldTypeDetails

SetFieldType sets the FieldType field's value.

func (*FieldTypeDetails) SetFilterOperators 

func (s *FieldTypeDetails) SetFilterOperators(v []*string) *FieldTypeDetails

SetFilterOperators sets the FilterOperators field's value.

func (*FieldTypeDetails) SetSupportedValues 

func (s *FieldTypeDetails) SetSupportedValues(v []*string) *FieldTypeDetails

SetSupportedValues sets the SupportedValues field's value.

func (FieldTypeDetails) String 

func (s FieldTypeDetails) String() string

String returns the string representation

type FlowDefinition 

type FlowDefinition struct {

	// Specifies when the flow was created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp"`

	// The ARN of the user who created the flow.
	CreatedBy *string `locationName:"createdBy" type:"string"`

	// A user-entered description of the flow.
	Description *string `locationName:"description" type:"string"`

	// Specifies the destination connector type, such as Salesforce, Amazon S3,
	// Amplitude, and so on.
	DestinationConnectorType *string `locationName:"destinationConnectorType" type:"string" enum:"ConnectorType"`

	// The flow's Amazon Resource Name (ARN).
	FlowArn *string `locationName:"flowArn" type:"string"`

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	FlowName *string `locationName:"flowName" type:"string"`

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`

	// Describes the details of the most recent flow run.
	LastRunExecutionDetails *ExecutionDetails `locationName:"lastRunExecutionDetails" type:"structure"`

	// Specifies when the flow was last updated.
	LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`

	// Specifies the account user name that most recently updated the flow.
	LastUpdatedBy *string `locationName:"lastUpdatedBy" type:"string"`

	// Specifies the source connector type, such as Salesforce, Amazon S3, Amplitude,
	// and so on.
	SourceConnectorType *string `locationName:"sourceConnectorType" type:"string" enum:"ConnectorType"`

	// The tags used to organize, track, or control access for your flow.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// Specifies the type of flow trigger. This can be OnDemand, Scheduled, or Event.
	TriggerType *string `locationName:"triggerType" type:"string" enum:"TriggerType"`
	// contains filtered or unexported fields
}

The properties of the flow, such as its source, destination, trigger type, and so on.

func (FlowDefinition) GoString 

func (s FlowDefinition) GoString() string

GoString returns the string representation

func (*FlowDefinition) SetCreatedAt 

func (s *FlowDefinition) SetCreatedAt(v time.Time) *FlowDefinition

SetCreatedAt sets the CreatedAt field's value.

func (*FlowDefinition) SetCreatedBy 

func (s *FlowDefinition) SetCreatedBy(v string) *FlowDefinition

SetCreatedBy sets the CreatedBy field's value.

func (*FlowDefinition) SetDescription 

func (s *FlowDefinition) SetDescription(v string) *FlowDefinition

SetDescription sets the Description field's value.

func (*FlowDefinition) SetDestinationConnectorType 

func (s *FlowDefinition) SetDestinationConnectorType(v string) *FlowDefinition

SetDestinationConnectorType sets the DestinationConnectorType field's value.

func (*FlowDefinition) SetFlowArn 

func (s *FlowDefinition) SetFlowArn(v string) *FlowDefinition

SetFlowArn sets the FlowArn field's value.

func (*FlowDefinition) SetFlowName 

func (s *FlowDefinition) SetFlowName(v string) *FlowDefinition

SetFlowName sets the FlowName field's value.

func (*FlowDefinition) SetFlowStatus 

func (s *FlowDefinition) SetFlowStatus(v string) *FlowDefinition

SetFlowStatus sets the FlowStatus field's value.

func (*FlowDefinition) SetLastRunExecutionDetails 

func (s *FlowDefinition) SetLastRunExecutionDetails(v *ExecutionDetails) *FlowDefinition

SetLastRunExecutionDetails sets the LastRunExecutionDetails field's value.

func (*FlowDefinition) SetLastUpdatedAt 

func (s *FlowDefinition) SetLastUpdatedAt(v time.Time) *FlowDefinition

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*FlowDefinition) SetLastUpdatedBy 

func (s *FlowDefinition) SetLastUpdatedBy(v string) *FlowDefinition

SetLastUpdatedBy sets the LastUpdatedBy field's value.

func (*FlowDefinition) SetSourceConnectorType 

func (s *FlowDefinition) SetSourceConnectorType(v string) *FlowDefinition

SetSourceConnectorType sets the SourceConnectorType field's value.

func (*FlowDefinition) SetTags 

func (s *FlowDefinition) SetTags(v map[string]*string) *FlowDefinition

SetTags sets the Tags field's value.

func (*FlowDefinition) SetTriggerType 

func (s *FlowDefinition) SetTriggerType(v string) *FlowDefinition

SetTriggerType sets the TriggerType field's value.

func (FlowDefinition) String 

func (s FlowDefinition) String() string

String returns the string representation

type GoogleAnalyticsConnectorProfileCredentials 

type GoogleAnalyticsConnectorProfileCredentials struct {

	// The credentials used to access protected Google Analytics resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// The identifier for the desired client.
	//
	// ClientId is a required field
	ClientId *string `locationName:"clientId" type:"string" required:"true"`

	// The client secret used by the OAuth client to authenticate to the authorization
	// server.
	//
	// ClientSecret is a required field
	ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

	// The OAuth requirement needed to request security tokens from the connector
	// endpoint.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`

	// The credentials used to acquire new access tokens. This is required only
	// for OAuth2 access tokens, and is not required for OAuth1 access tokens.
	RefreshToken *string `locationName:"refreshToken" type:"string"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required by Google Analytics.

func (GoogleAnalyticsConnectorProfileCredentials) GoString 

func (s GoogleAnalyticsConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) SetAccessToken 

func (s *GoogleAnalyticsConnectorProfileCredentials) SetAccessToken(v string) *GoogleAnalyticsConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientId 

func (s *GoogleAnalyticsConnectorProfileCredentials) SetClientId(v string) *GoogleAnalyticsConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientSecret 

func (s *GoogleAnalyticsConnectorProfileCredentials) SetClientSecret(v string) *GoogleAnalyticsConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetOAuthRequest 

func (s *GoogleAnalyticsConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *GoogleAnalyticsConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetRefreshToken 

func (s *GoogleAnalyticsConnectorProfileCredentials) SetRefreshToken(v string) *GoogleAnalyticsConnectorProfileCredentials

SetRefreshToken sets the RefreshToken field's value.

func (GoogleAnalyticsConnectorProfileCredentials) String 

func (s GoogleAnalyticsConnectorProfileCredentials) String() string

String returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) Validate 

func (s *GoogleAnalyticsConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GoogleAnalyticsConnectorProfileProperties 

type GoogleAnalyticsConnectorProfileProperties struct {
	// contains filtered or unexported fields
}

The connector-specific profile properties required by Google Analytics.

func (GoogleAnalyticsConnectorProfileProperties) GoString 

func (s GoogleAnalyticsConnectorProfileProperties) GoString() string

GoString returns the string representation

func (GoogleAnalyticsConnectorProfileProperties) String 

func (s GoogleAnalyticsConnectorProfileProperties) String() string

String returns the string representation

type GoogleAnalyticsMetadata 

type GoogleAnalyticsMetadata struct {

	// The desired authorization scope for the Google Analytics account.
	OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Google Analytics.

func (GoogleAnalyticsMetadata) GoString 

func (s GoogleAnalyticsMetadata) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsMetadata) SetOAuthScopes 

func (s *GoogleAnalyticsMetadata) SetOAuthScopes(v []*string) *GoogleAnalyticsMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (GoogleAnalyticsMetadata) String 

func (s GoogleAnalyticsMetadata) String() string

String returns the string representation

type GoogleAnalyticsSourceProperties 

type GoogleAnalyticsSourceProperties struct {

	// The object specified in the Google Analytics flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Google Analytics is being used as a source.

func (GoogleAnalyticsSourceProperties) GoString 

func (s GoogleAnalyticsSourceProperties) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsSourceProperties) SetObject 

func (s *GoogleAnalyticsSourceProperties) SetObject(v string) *GoogleAnalyticsSourceProperties

SetObject sets the Object field's value.

func (GoogleAnalyticsSourceProperties) String 

func (s GoogleAnalyticsSourceProperties) String() string

String returns the string representation

func (*GoogleAnalyticsSourceProperties) Validate 

func (s *GoogleAnalyticsSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type HoneycodeConnectorProfileCredentials added in v1.37.18 

type HoneycodeConnectorProfileCredentials struct {

	// The credentials used to access protected Amazon Honeycode resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// Used by select connectors for which the OAuth workflow is supported, such
	// as Salesforce, Google Analytics, Marketo, Zendesk, and Slack.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`

	// The credentials used to acquire new access tokens.
	RefreshToken *string `locationName:"refreshToken" type:"string"`
	// contains filtered or unexported fields
}

The connector-specific credentials required when using Amazon Honeycode.

func (HoneycodeConnectorProfileCredentials) GoString added in v1.37.18 

func (s HoneycodeConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*HoneycodeConnectorProfileCredentials) SetAccessToken added in v1.37.18 

func (s *HoneycodeConnectorProfileCredentials) SetAccessToken(v string) *HoneycodeConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*HoneycodeConnectorProfileCredentials) SetOAuthRequest added in v1.37.18 

func (s *HoneycodeConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *HoneycodeConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (*HoneycodeConnectorProfileCredentials) SetRefreshToken added in v1.37.18 

func (s *HoneycodeConnectorProfileCredentials) SetRefreshToken(v string) *HoneycodeConnectorProfileCredentials

SetRefreshToken sets the RefreshToken field's value.

func (HoneycodeConnectorProfileCredentials) String added in v1.37.18 

func (s HoneycodeConnectorProfileCredentials) String() string

String returns the string representation

type HoneycodeConnectorProfileProperties added in v1.37.18 

type HoneycodeConnectorProfileProperties struct {
	// contains filtered or unexported fields
}

The connector-specific properties required when using Amazon Honeycode.

func (HoneycodeConnectorProfileProperties) GoString added in v1.37.18 

func (s HoneycodeConnectorProfileProperties) GoString() string

GoString returns the string representation

func (HoneycodeConnectorProfileProperties) String added in v1.37.18 

func (s HoneycodeConnectorProfileProperties) String() string

String returns the string representation

type HoneycodeDestinationProperties added in v1.37.18 

type HoneycodeDestinationProperties struct {

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the destination. For example, this setting would determine if the
	// flow should fail after one insertion error, or continue and attempt to insert
	// every record regardless of the initial failure. ErrorHandlingConfig is a
	// part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// The object specified in the Amazon Honeycode flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon Honeycode is used as a destination.

func (HoneycodeDestinationProperties) GoString added in v1.37.18 

func (s HoneycodeDestinationProperties) GoString() string

GoString returns the string representation

func (*HoneycodeDestinationProperties) SetErrorHandlingConfig added in v1.37.18 

func (s *HoneycodeDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *HoneycodeDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*HoneycodeDestinationProperties) SetObject added in v1.37.18 

func (s *HoneycodeDestinationProperties) SetObject(v string) *HoneycodeDestinationProperties

SetObject sets the Object field's value.

func (HoneycodeDestinationProperties) String added in v1.37.18 

func (s HoneycodeDestinationProperties) String() string

String returns the string representation

func (*HoneycodeDestinationProperties) Validate added in v1.37.18 

func (s *HoneycodeDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type HoneycodeMetadata added in v1.37.18 

type HoneycodeMetadata struct {

	// The desired authorization scope for the Amazon Honeycode account.
	OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Amazon Honeycode.

func (HoneycodeMetadata) GoString added in v1.37.18 

func (s HoneycodeMetadata) GoString() string

GoString returns the string representation

func (*HoneycodeMetadata) SetOAuthScopes added in v1.37.18 

func (s *HoneycodeMetadata) SetOAuthScopes(v []*string) *HoneycodeMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (HoneycodeMetadata) String added in v1.37.18 

func (s HoneycodeMetadata) String() string

String returns the string representation

type IncrementalPullConfig added in v1.35.13 

type IncrementalPullConfig struct {

	// A field that specifies the date time or timestamp field as the criteria to
	// use when importing incremental records from the source.
	DatetimeTypeFieldName *string `locationName:"datetimeTypeFieldName" type:"string"`
	// contains filtered or unexported fields
}

Specifies the configuration used when importing incremental records from the source.

func (IncrementalPullConfig) GoString added in v1.35.13 

func (s IncrementalPullConfig) GoString() string

GoString returns the string representation

func (*IncrementalPullConfig) SetDatetimeTypeFieldName added in v1.35.13 

func (s *IncrementalPullConfig) SetDatetimeTypeFieldName(v string) *IncrementalPullConfig

SetDatetimeTypeFieldName sets the DatetimeTypeFieldName field's value.

func (IncrementalPullConfig) String added in v1.35.13 

func (s IncrementalPullConfig) String() string

String returns the string representation

type InforNexusConnectorProfileCredentials 

type InforNexusConnectorProfileCredentials struct {

	// The Access Key portion of the credentials.
	//
	// AccessKeyId is a required field
	AccessKeyId *string `locationName:"accessKeyId" type:"string" required:"true" sensitive:"true"`

	// The encryption keys used to encrypt data.
	//
	// Datakey is a required field
	Datakey *string `locationName:"datakey" type:"string" required:"true"`

	// The secret key used to sign requests.
	//
	// SecretAccessKey is a required field
	SecretAccessKey *string `locationName:"secretAccessKey" type:"string" required:"true"`

	// The identifier for the user.
	//
	// UserId is a required field
	UserId *string `locationName:"userId" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required by Infor Nexus.

func (InforNexusConnectorProfileCredentials) GoString 

func (s InforNexusConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*InforNexusConnectorProfileCredentials) SetAccessKeyId 

func (s *InforNexusConnectorProfileCredentials) SetAccessKeyId(v string) *InforNexusConnectorProfileCredentials

SetAccessKeyId sets the AccessKeyId field's value.

func (*InforNexusConnectorProfileCredentials) SetDatakey 

func (s *InforNexusConnectorProfileCredentials) SetDatakey(v string) *InforNexusConnectorProfileCredentials

SetDatakey sets the Datakey field's value.

func (*InforNexusConnectorProfileCredentials) SetSecretAccessKey 

func (s *InforNexusConnectorProfileCredentials) SetSecretAccessKey(v string) *InforNexusConnectorProfileCredentials

SetSecretAccessKey sets the SecretAccessKey field's value.

func (*InforNexusConnectorProfileCredentials) SetUserId 

func (s *InforNexusConnectorProfileCredentials) SetUserId(v string) *InforNexusConnectorProfileCredentials

SetUserId sets the UserId field's value.

func (InforNexusConnectorProfileCredentials) String 

func (s InforNexusConnectorProfileCredentials) String() string

String returns the string representation

func (*InforNexusConnectorProfileCredentials) Validate 

func (s *InforNexusConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type InforNexusConnectorProfileProperties 

type InforNexusConnectorProfileProperties struct {

	// The location of the Infor Nexus resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required by Infor Nexus.

func (InforNexusConnectorProfileProperties) GoString 

func (s InforNexusConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*InforNexusConnectorProfileProperties) SetInstanceUrl 

func (s *InforNexusConnectorProfileProperties) SetInstanceUrl(v string) *InforNexusConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (InforNexusConnectorProfileProperties) String 

func (s InforNexusConnectorProfileProperties) String() string

String returns the string representation

func (*InforNexusConnectorProfileProperties) Validate 

func (s *InforNexusConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type InforNexusMetadata 

type InforNexusMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Infor Nexus.

func (InforNexusMetadata) GoString 

func (s InforNexusMetadata) GoString() string

GoString returns the string representation

func (InforNexusMetadata) String 

func (s InforNexusMetadata) String() string

String returns the string representation

type InforNexusSourceProperties 

type InforNexusSourceProperties struct {

	// The object specified in the Infor Nexus flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Infor Nexus is being used as a source.

func (InforNexusSourceProperties) GoString 

func (s InforNexusSourceProperties) GoString() string

GoString returns the string representation

func (*InforNexusSourceProperties) SetObject 

func (s *InforNexusSourceProperties) SetObject(v string) *InforNexusSourceProperties

SetObject sets the Object field's value.

func (InforNexusSourceProperties) String 

func (s InforNexusSourceProperties) String() string

String returns the string representation

func (*InforNexusSourceProperties) Validate 

func (s *InforNexusSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type InternalServerException 

type InternalServerException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

An internal service error occurred during the processing of your request. Try again later.

func (*InternalServerException) Code 

func (s *InternalServerException) Code() string

Code returns the exception type name.

func (*InternalServerException) Error 

func (s *InternalServerException) Error() string

func (InternalServerException) GoString 

func (s InternalServerException) GoString() string

GoString returns the string representation

func (*InternalServerException) Message 

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr 

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID 

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode 

func (s *InternalServerException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (InternalServerException) String 

func (s InternalServerException) String() string

String returns the string representation

type ListConnectorEntitiesInput 

type ListConnectorEntitiesInput struct {

	// The name of the connector profile. The name is unique for each ConnectorProfile
	// in the AWS account, and is used to query the downstream connector.
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

	// 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.
	EntitiesPath *string `locationName:"entitiesPath" type:"string"`
	// contains filtered or unexported fields
}

func (ListConnectorEntitiesInput) GoString 

func (s ListConnectorEntitiesInput) GoString() string

GoString returns the string representation

func (*ListConnectorEntitiesInput) SetConnectorProfileName 

func (s *ListConnectorEntitiesInput) SetConnectorProfileName(v string) *ListConnectorEntitiesInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*ListConnectorEntitiesInput) SetConnectorType 

func (s *ListConnectorEntitiesInput) SetConnectorType(v string) *ListConnectorEntitiesInput

SetConnectorType sets the ConnectorType field's value.

func (*ListConnectorEntitiesInput) SetEntitiesPath 

func (s *ListConnectorEntitiesInput) SetEntitiesPath(v string) *ListConnectorEntitiesInput

SetEntitiesPath sets the EntitiesPath field's value.

func (ListConnectorEntitiesInput) String 

func (s ListConnectorEntitiesInput) String() string

String returns the string representation

type ListConnectorEntitiesOutput 

type ListConnectorEntitiesOutput struct {

	// 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.
	//
	// ConnectorEntityMap is a required field
	ConnectorEntityMap map[string][]*ConnectorEntity `locationName:"connectorEntityMap" type:"map" required:"true"`
	// contains filtered or unexported fields
}

func (ListConnectorEntitiesOutput) GoString 

func (s ListConnectorEntitiesOutput) GoString() string

GoString returns the string representation

func (*ListConnectorEntitiesOutput) SetConnectorEntityMap 

func (s *ListConnectorEntitiesOutput) SetConnectorEntityMap(v map[string][]*ConnectorEntity) *ListConnectorEntitiesOutput

SetConnectorEntityMap sets the ConnectorEntityMap field's value.

func (ListConnectorEntitiesOutput) String 

func (s ListConnectorEntitiesOutput) String() string

String returns the string representation

type ListFlowsInput 

type ListFlowsInput struct {

	// Specifies the maximum number of items that should be returned in the result
	// set.
	MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

	// The pagination token for next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (ListFlowsInput) GoString 

func (s ListFlowsInput) GoString() string

GoString returns the string representation

func (*ListFlowsInput) SetMaxResults 

func (s *ListFlowsInput) SetMaxResults(v int64) *ListFlowsInput

SetMaxResults sets the MaxResults field's value.

func (*ListFlowsInput) SetNextToken 

func (s *ListFlowsInput) SetNextToken(v string) *ListFlowsInput

SetNextToken sets the NextToken field's value.

func (ListFlowsInput) String 

func (s ListFlowsInput) String() string

String returns the string representation

func (*ListFlowsInput) Validate 

func (s *ListFlowsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListFlowsOutput 

type ListFlowsOutput struct {

	// The list of flows associated with your account.
	Flows []*FlowDefinition `locationName:"flows" type:"list"`

	// The pagination token for next page of data.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

func (ListFlowsOutput) GoString 

func (s ListFlowsOutput) GoString() string

GoString returns the string representation

func (*ListFlowsOutput) SetFlows 

func (s *ListFlowsOutput) SetFlows(v []*FlowDefinition) *ListFlowsOutput

SetFlows sets the Flows field's value.

func (*ListFlowsOutput) SetNextToken 

func (s *ListFlowsOutput) SetNextToken(v string) *ListFlowsOutput

SetNextToken sets the NextToken field's value.

func (ListFlowsOutput) String 

func (s ListFlowsOutput) String() string

String returns the string representation

type ListTagsForResourceInput 

type ListTagsForResourceInput struct {

	// The Amazon Resource Name (ARN) of the specified flow.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString 

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceInput) SetResourceArn 

func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String 

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate 

func (s *ListTagsForResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListTagsForResourceOutput 

type ListTagsForResourceOutput struct {

	// The tags used to organize, track, or control access for your flow.
	Tags map[string]*string `locationName:"tags" type:"map"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString 

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceOutput) SetTags 

func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String 

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type LookoutMetricsDestinationProperties added in v1.37.18 

type LookoutMetricsDestinationProperties struct {
	// contains filtered or unexported fields
}

The properties that are applied when Amazon Lookout for Metrics is used as a destination.

func (LookoutMetricsDestinationProperties) GoString added in v1.37.18 

func (s LookoutMetricsDestinationProperties) GoString() string

GoString returns the string representation

func (LookoutMetricsDestinationProperties) String added in v1.37.18 

func (s LookoutMetricsDestinationProperties) String() string

String returns the string representation

type MarketoConnectorProfileCredentials 

type MarketoConnectorProfileCredentials struct {

	// The credentials used to access protected Marketo resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// The identifier for the desired client.
	//
	// ClientId is a required field
	ClientId *string `locationName:"clientId" type:"string" required:"true"`

	// The client secret used by the OAuth client to authenticate to the authorization
	// server.
	//
	// ClientSecret is a required field
	ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

	// The OAuth requirement needed to request security tokens from the connector
	// endpoint.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required by Marketo.

func (MarketoConnectorProfileCredentials) GoString 

func (s MarketoConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*MarketoConnectorProfileCredentials) SetAccessToken 

func (s *MarketoConnectorProfileCredentials) SetAccessToken(v string) *MarketoConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*MarketoConnectorProfileCredentials) SetClientId 

func (s *MarketoConnectorProfileCredentials) SetClientId(v string) *MarketoConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*MarketoConnectorProfileCredentials) SetClientSecret 

func (s *MarketoConnectorProfileCredentials) SetClientSecret(v string) *MarketoConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*MarketoConnectorProfileCredentials) SetOAuthRequest 

func (s *MarketoConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *MarketoConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (MarketoConnectorProfileCredentials) String 

func (s MarketoConnectorProfileCredentials) String() string

String returns the string representation

func (*MarketoConnectorProfileCredentials) Validate 

func (s *MarketoConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type MarketoConnectorProfileProperties 

type MarketoConnectorProfileProperties struct {

	// The location of the Marketo resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Marketo.

func (MarketoConnectorProfileProperties) GoString 

func (s MarketoConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*MarketoConnectorProfileProperties) SetInstanceUrl 

func (s *MarketoConnectorProfileProperties) SetInstanceUrl(v string) *MarketoConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (MarketoConnectorProfileProperties) String 

func (s MarketoConnectorProfileProperties) String() string

String returns the string representation

func (*MarketoConnectorProfileProperties) Validate 

func (s *MarketoConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type MarketoMetadata 

type MarketoMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Marketo.

func (MarketoMetadata) GoString 

func (s MarketoMetadata) GoString() string

GoString returns the string representation

func (MarketoMetadata) String 

func (s MarketoMetadata) String() string

String returns the string representation

type MarketoSourceProperties 

type MarketoSourceProperties struct {

	// The object specified in the Marketo flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Marketo is being used as a source.

func (MarketoSourceProperties) GoString 

func (s MarketoSourceProperties) GoString() string

GoString returns the string representation

func (*MarketoSourceProperties) SetObject 

func (s *MarketoSourceProperties) SetObject(v string) *MarketoSourceProperties

SetObject sets the Object field's value.

func (MarketoSourceProperties) String 

func (s MarketoSourceProperties) String() string

String returns the string representation

func (*MarketoSourceProperties) Validate 

func (s *MarketoSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PrefixConfig 

type PrefixConfig struct {

	// Determines the level of granularity that's included in the prefix.
	PrefixFormat *string `locationName:"prefixFormat" type:"string" enum:"PrefixFormat"`

	// Determines the format of the prefix, and whether it applies to the file name,
	// file path, or both.
	PrefixType *string `locationName:"prefixType" type:"string" enum:"PrefixType"`
	// contains filtered or unexported fields
}

Determines the prefix that Amazon AppFlow applies to the destination folder name. You can name your destination folders according to the flow frequency and date.

func (PrefixConfig) GoString 

func (s PrefixConfig) GoString() string

GoString returns the string representation

func (*PrefixConfig) SetPrefixFormat 

func (s *PrefixConfig) SetPrefixFormat(v string) *PrefixConfig

SetPrefixFormat sets the PrefixFormat field's value.

func (*PrefixConfig) SetPrefixType 

func (s *PrefixConfig) SetPrefixType(v string) *PrefixConfig

SetPrefixType sets the PrefixType field's value.

func (PrefixConfig) String 

func (s PrefixConfig) String() string

String returns the string representation

type RedshiftConnectorProfileCredentials 

type RedshiftConnectorProfileCredentials struct {

	// The password that corresponds to the user name.
	//
	// Password is a required field
	Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

	// The name of the user.
	//
	// Username is a required field
	Username *string `locationName:"username" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Amazon Redshift.

func (RedshiftConnectorProfileCredentials) GoString 

func (s RedshiftConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*RedshiftConnectorProfileCredentials) SetPassword 

func (s *RedshiftConnectorProfileCredentials) SetPassword(v string) *RedshiftConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*RedshiftConnectorProfileCredentials) SetUsername 

func (s *RedshiftConnectorProfileCredentials) SetUsername(v string) *RedshiftConnectorProfileCredentials

SetUsername sets the Username field's value.

func (RedshiftConnectorProfileCredentials) String 

func (s RedshiftConnectorProfileCredentials) String() string

String returns the string representation

func (*RedshiftConnectorProfileCredentials) Validate 

func (s *RedshiftConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type RedshiftConnectorProfileProperties 

type RedshiftConnectorProfileProperties struct {

	// A name for the associated Amazon S3 bucket.
	//
	// BucketName is a required field
	BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

	// The object key for the destination bucket in which Amazon AppFlow places
	// the files.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The JDBC URL of the Amazon Redshift cluster.
	//
	// DatabaseUrl is a required field
	DatabaseUrl *string `locationName:"databaseUrl" type:"string" required:"true"`

	// The Amazon Resource Name (ARN) of the IAM role.
	//
	// RoleArn is a required field
	RoleArn *string `locationName:"roleArn" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties when using Amazon Redshift.

func (RedshiftConnectorProfileProperties) GoString 

func (s RedshiftConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*RedshiftConnectorProfileProperties) SetBucketName 

func (s *RedshiftConnectorProfileProperties) SetBucketName(v string) *RedshiftConnectorProfileProperties

SetBucketName sets the BucketName field's value.

func (*RedshiftConnectorProfileProperties) SetBucketPrefix 

func (s *RedshiftConnectorProfileProperties) SetBucketPrefix(v string) *RedshiftConnectorProfileProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftConnectorProfileProperties) SetDatabaseUrl 

func (s *RedshiftConnectorProfileProperties) SetDatabaseUrl(v string) *RedshiftConnectorProfileProperties

SetDatabaseUrl sets the DatabaseUrl field's value.

func (*RedshiftConnectorProfileProperties) SetRoleArn 

func (s *RedshiftConnectorProfileProperties) SetRoleArn(v string) *RedshiftConnectorProfileProperties

SetRoleArn sets the RoleArn field's value.

func (RedshiftConnectorProfileProperties) String 

func (s RedshiftConnectorProfileProperties) String() string

String returns the string representation

func (*RedshiftConnectorProfileProperties) Validate 

func (s *RedshiftConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type RedshiftDestinationProperties 

type RedshiftDestinationProperties struct {

	// The object key for the bucket in which Amazon AppFlow places the destination
	// files.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the Amazon Redshift destination. For example, this setting would
	// determine if the flow should fail after one insertion error, or continue
	// and attempt to insert every record regardless of the initial failure. ErrorHandlingConfig
	// is a part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// The intermediate bucket that Amazon AppFlow uses when moving data into Amazon
	// Redshift.
	//
	// IntermediateBucketName is a required field
	IntermediateBucketName *string `locationName:"intermediateBucketName" min:"3" type:"string" required:"true"`

	// The object specified in the Amazon Redshift flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon Redshift is being used as a destination.

func (RedshiftDestinationProperties) GoString 

func (s RedshiftDestinationProperties) GoString() string

GoString returns the string representation

func (*RedshiftDestinationProperties) SetBucketPrefix 

func (s *RedshiftDestinationProperties) SetBucketPrefix(v string) *RedshiftDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftDestinationProperties) SetErrorHandlingConfig 

func (s *RedshiftDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *RedshiftDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*RedshiftDestinationProperties) SetIntermediateBucketName 

func (s *RedshiftDestinationProperties) SetIntermediateBucketName(v string) *RedshiftDestinationProperties

SetIntermediateBucketName sets the IntermediateBucketName field's value.

func (*RedshiftDestinationProperties) SetObject 

func (s *RedshiftDestinationProperties) SetObject(v string) *RedshiftDestinationProperties

SetObject sets the Object field's value.

func (RedshiftDestinationProperties) String 

func (s RedshiftDestinationProperties) String() string

String returns the string representation

func (*RedshiftDestinationProperties) Validate 

func (s *RedshiftDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type RedshiftMetadata 

type RedshiftMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Amazon Redshift.

func (RedshiftMetadata) GoString 

func (s RedshiftMetadata) GoString() string

GoString returns the string representation

func (RedshiftMetadata) String 

func (s RedshiftMetadata) String() string

String returns the string representation

type ResourceNotFoundException 

type ResourceNotFoundException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

The resource specified in the request (such as the source or destination connector profile) is not found.

func (*ResourceNotFoundException) Code 

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error 

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString 

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation

func (*ResourceNotFoundException) Message 

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr 

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID 

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode 

func (s *ResourceNotFoundException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ResourceNotFoundException) String 

func (s ResourceNotFoundException) String() string

String returns the string representation

type S3DestinationProperties 

type S3DestinationProperties struct {

	// The Amazon S3 bucket name in which Amazon AppFlow places the transferred
	// data.
	//
	// BucketName is a required field
	BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

	// The object key for the destination bucket in which Amazon AppFlow places
	// the files.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The configuration that determines how Amazon AppFlow should format the flow
	// output data when Amazon S3 is used as the destination.
	S3OutputFormatConfig *S3OutputFormatConfig `locationName:"s3OutputFormatConfig" type:"structure"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon S3 is used as a destination.

func (S3DestinationProperties) GoString 

func (s S3DestinationProperties) GoString() string

GoString returns the string representation

func (*S3DestinationProperties) SetBucketName 

func (s *S3DestinationProperties) SetBucketName(v string) *S3DestinationProperties

SetBucketName sets the BucketName field's value.

func (*S3DestinationProperties) SetBucketPrefix 

func (s *S3DestinationProperties) SetBucketPrefix(v string) *S3DestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*S3DestinationProperties) SetS3OutputFormatConfig 

func (s *S3DestinationProperties) SetS3OutputFormatConfig(v *S3OutputFormatConfig) *S3DestinationProperties

SetS3OutputFormatConfig sets the S3OutputFormatConfig field's value.

func (S3DestinationProperties) String 

func (s S3DestinationProperties) String() string

String returns the string representation

func (*S3DestinationProperties) Validate 

func (s *S3DestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type S3Metadata 

type S3Metadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Amazon S3.

func (S3Metadata) GoString 

func (s S3Metadata) GoString() string

GoString returns the string representation

func (S3Metadata) String 

func (s S3Metadata) String() string

String returns the string representation

type S3OutputFormatConfig 

type S3OutputFormatConfig struct {

	// The aggregation settings that you can use to customize the output format
	// of your flow data.
	AggregationConfig *AggregationConfig `locationName:"aggregationConfig" type:"structure"`

	// Indicates the file type that Amazon AppFlow places in the Amazon S3 bucket.
	FileType *string `locationName:"fileType" type:"string" enum:"FileType"`

	// Determines the prefix that Amazon AppFlow applies to the folder name in the
	// Amazon S3 bucket. You can name folders according to the flow frequency and
	// date.
	PrefixConfig *PrefixConfig `locationName:"prefixConfig" type:"structure"`
	// contains filtered or unexported fields
}

The configuration that determines how Amazon AppFlow should format the flow output data when Amazon S3 is used as the destination.

func (S3OutputFormatConfig) GoString 

func (s S3OutputFormatConfig) GoString() string

GoString returns the string representation

func (*S3OutputFormatConfig) SetAggregationConfig 

func (s *S3OutputFormatConfig) SetAggregationConfig(v *AggregationConfig) *S3OutputFormatConfig

SetAggregationConfig sets the AggregationConfig field's value.

func (*S3OutputFormatConfig) SetFileType 

func (s *S3OutputFormatConfig) SetFileType(v string) *S3OutputFormatConfig

SetFileType sets the FileType field's value.

func (*S3OutputFormatConfig) SetPrefixConfig 

func (s *S3OutputFormatConfig) SetPrefixConfig(v *PrefixConfig) *S3OutputFormatConfig

SetPrefixConfig sets the PrefixConfig field's value.

func (S3OutputFormatConfig) String 

func (s S3OutputFormatConfig) String() string

String returns the string representation

type S3SourceProperties 

type S3SourceProperties struct {

	// The Amazon S3 bucket name where the source files are stored.
	//
	// BucketName is a required field
	BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

	// The object key for the Amazon S3 bucket in which the source files are stored.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`
	// contains filtered or unexported fields
}

The properties that are applied when Amazon S3 is being used as the flow source.

func (S3SourceProperties) GoString 

func (s S3SourceProperties) GoString() string

GoString returns the string representation

func (*S3SourceProperties) SetBucketName 

func (s *S3SourceProperties) SetBucketName(v string) *S3SourceProperties

SetBucketName sets the BucketName field's value.

func (*S3SourceProperties) SetBucketPrefix 

func (s *S3SourceProperties) SetBucketPrefix(v string) *S3SourceProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (S3SourceProperties) String 

func (s S3SourceProperties) String() string

String returns the string representation

func (*S3SourceProperties) Validate 

func (s *S3SourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SalesforceConnectorProfileCredentials 

type SalesforceConnectorProfileCredentials struct {

	// The credentials used to access protected Salesforce resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// The secret manager ARN, which contains the client ID and client secret of
	// the connected app.
	ClientCredentialsArn *string `locationName:"clientCredentialsArn" min:"20" type:"string" sensitive:"true"`

	// The OAuth requirement needed to request security tokens from the connector
	// endpoint.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`

	// The credentials used to acquire new access tokens.
	RefreshToken *string `locationName:"refreshToken" type:"string"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Salesforce.

func (SalesforceConnectorProfileCredentials) GoString 

func (s SalesforceConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SalesforceConnectorProfileCredentials) SetAccessToken 

func (s *SalesforceConnectorProfileCredentials) SetAccessToken(v string) *SalesforceConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*SalesforceConnectorProfileCredentials) SetClientCredentialsArn added in v1.35.13 

func (s *SalesforceConnectorProfileCredentials) SetClientCredentialsArn(v string) *SalesforceConnectorProfileCredentials

SetClientCredentialsArn sets the ClientCredentialsArn field's value.

func (*SalesforceConnectorProfileCredentials) SetOAuthRequest 

func (s *SalesforceConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *SalesforceConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (*SalesforceConnectorProfileCredentials) SetRefreshToken 

func (s *SalesforceConnectorProfileCredentials) SetRefreshToken(v string) *SalesforceConnectorProfileCredentials

SetRefreshToken sets the RefreshToken field's value.

func (SalesforceConnectorProfileCredentials) String 

func (s SalesforceConnectorProfileCredentials) String() string

String returns the string representation

func (*SalesforceConnectorProfileCredentials) Validate added in v1.35.13 

func (s *SalesforceConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SalesforceConnectorProfileProperties 

type SalesforceConnectorProfileProperties struct {

	// The location of the Salesforce resource.
	InstanceUrl *string `locationName:"instanceUrl" type:"string"`

	// Indicates whether the connector profile applies to a sandbox or production
	// environment.
	IsSandboxEnvironment *bool `locationName:"isSandboxEnvironment" type:"boolean"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Salesforce.

func (SalesforceConnectorProfileProperties) GoString 

func (s SalesforceConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SalesforceConnectorProfileProperties) SetInstanceUrl 

func (s *SalesforceConnectorProfileProperties) SetInstanceUrl(v string) *SalesforceConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (*SalesforceConnectorProfileProperties) SetIsSandboxEnvironment 

func (s *SalesforceConnectorProfileProperties) SetIsSandboxEnvironment(v bool) *SalesforceConnectorProfileProperties

SetIsSandboxEnvironment sets the IsSandboxEnvironment field's value.

func (SalesforceConnectorProfileProperties) String 

func (s SalesforceConnectorProfileProperties) String() string

String returns the string representation

type SalesforceDestinationProperties 

type SalesforceDestinationProperties struct {

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the Salesforce destination. For example, this setting would determine
	// if the flow should fail after one insertion error, or continue and attempt
	// to insert every record regardless of the initial failure. ErrorHandlingConfig
	// is a part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// The name of the field that Amazon AppFlow uses as an ID when performing a
	// write operation such as update or delete.
	IdFieldNames []*string `locationName:"idFieldNames" type:"list"`

	// The object specified in the Salesforce flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`

	// This specifies the type of write operation to be performed in Salesforce.
	// When the value is UPSERT, then idFieldNames is required.
	WriteOperationType *string `locationName:"writeOperationType" type:"string" enum:"WriteOperationType"`
	// contains filtered or unexported fields
}

The properties that are applied when Salesforce is being used as a destination.

func (SalesforceDestinationProperties) GoString 

func (s SalesforceDestinationProperties) GoString() string

GoString returns the string representation

func (*SalesforceDestinationProperties) SetErrorHandlingConfig 

func (s *SalesforceDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *SalesforceDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*SalesforceDestinationProperties) SetIdFieldNames added in v1.35.13 

func (s *SalesforceDestinationProperties) SetIdFieldNames(v []*string) *SalesforceDestinationProperties

SetIdFieldNames sets the IdFieldNames field's value.

func (*SalesforceDestinationProperties) SetObject 

func (s *SalesforceDestinationProperties) SetObject(v string) *SalesforceDestinationProperties

SetObject sets the Object field's value.

func (*SalesforceDestinationProperties) SetWriteOperationType added in v1.35.13 

func (s *SalesforceDestinationProperties) SetWriteOperationType(v string) *SalesforceDestinationProperties

SetWriteOperationType sets the WriteOperationType field's value.

func (SalesforceDestinationProperties) String 

func (s SalesforceDestinationProperties) String() string

String returns the string representation

func (*SalesforceDestinationProperties) Validate 

func (s *SalesforceDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SalesforceMetadata 

type SalesforceMetadata struct {

	// The desired authorization scope for the Salesforce account.
	OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Salesforce.

func (SalesforceMetadata) GoString 

func (s SalesforceMetadata) GoString() string

GoString returns the string representation

func (*SalesforceMetadata) SetOAuthScopes 

func (s *SalesforceMetadata) SetOAuthScopes(v []*string) *SalesforceMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (SalesforceMetadata) String 

func (s SalesforceMetadata) String() string

String returns the string representation

type SalesforceSourceProperties 

type SalesforceSourceProperties struct {

	// The flag that enables dynamic fetching of new (recently added) fields in
	// the Salesforce objects while running a flow.
	EnableDynamicFieldUpdate *bool `locationName:"enableDynamicFieldUpdate" type:"boolean"`

	// Indicates whether Amazon AppFlow includes deleted files in the flow run.
	IncludeDeletedRecords *bool `locationName:"includeDeletedRecords" type:"boolean"`

	// The object specified in the Salesforce flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Salesforce is being used as a source.

func (SalesforceSourceProperties) GoString 

func (s SalesforceSourceProperties) GoString() string

GoString returns the string representation

func (*SalesforceSourceProperties) SetEnableDynamicFieldUpdate 

func (s *SalesforceSourceProperties) SetEnableDynamicFieldUpdate(v bool) *SalesforceSourceProperties

SetEnableDynamicFieldUpdate sets the EnableDynamicFieldUpdate field's value.

func (*SalesforceSourceProperties) SetIncludeDeletedRecords 

func (s *SalesforceSourceProperties) SetIncludeDeletedRecords(v bool) *SalesforceSourceProperties

SetIncludeDeletedRecords sets the IncludeDeletedRecords field's value.

func (*SalesforceSourceProperties) SetObject 

func (s *SalesforceSourceProperties) SetObject(v string) *SalesforceSourceProperties

SetObject sets the Object field's value.

func (SalesforceSourceProperties) String 

func (s SalesforceSourceProperties) String() string

String returns the string representation

func (*SalesforceSourceProperties) Validate 

func (s *SalesforceSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ScheduledTriggerProperties 

type ScheduledTriggerProperties struct {

	// Specifies whether a scheduled flow has an incremental data transfer or a
	// complete data transfer for each flow run.
	DataPullMode *string `locationName:"dataPullMode" type:"string" enum:"DataPullMode"`

	// Specifies the date range for the records to import from the connector in
	// the first flow run.
	FirstExecutionFrom *time.Time `locationName:"firstExecutionFrom" type:"timestamp"`

	// Specifies the scheduled end time for a schedule-triggered flow.
	ScheduleEndTime *time.Time `locationName:"scheduleEndTime" type:"timestamp"`

	// The scheduling expression that determines the rate at which the schedule
	// will run, for example rate(5minutes).
	//
	// ScheduleExpression is a required field
	ScheduleExpression *string `locationName:"scheduleExpression" type:"string" required:"true"`

	// Specifies the optional offset that is added to the time interval for a schedule-triggered
	// flow.
	ScheduleOffset *int64 `locationName:"scheduleOffset" type:"long"`

	// Specifies the scheduled start time for a schedule-triggered flow.
	ScheduleStartTime *time.Time `locationName:"scheduleStartTime" type:"timestamp"`

	// Specifies the time zone used when referring to the date and time of a scheduled-triggered
	// flow, such as America/New_York.
	Timezone *string `locationName:"timezone" type:"string"`
	// contains filtered or unexported fields
}

Specifies the configuration details of a schedule-triggered flow as defined by the user. Currently, these settings only apply to the Scheduled trigger type.

func (ScheduledTriggerProperties) GoString 

func (s ScheduledTriggerProperties) GoString() string

GoString returns the string representation

func (*ScheduledTriggerProperties) SetDataPullMode 

func (s *ScheduledTriggerProperties) SetDataPullMode(v string) *ScheduledTriggerProperties

SetDataPullMode sets the DataPullMode field's value.

func (*ScheduledTriggerProperties) SetFirstExecutionFrom added in v1.37.18 

func (s *ScheduledTriggerProperties) SetFirstExecutionFrom(v time.Time) *ScheduledTriggerProperties

SetFirstExecutionFrom sets the FirstExecutionFrom field's value.

func (*ScheduledTriggerProperties) SetScheduleEndTime 

func (s *ScheduledTriggerProperties) SetScheduleEndTime(v time.Time) *ScheduledTriggerProperties

SetScheduleEndTime sets the ScheduleEndTime field's value.

func (*ScheduledTriggerProperties) SetScheduleExpression 

func (s *ScheduledTriggerProperties) SetScheduleExpression(v string) *ScheduledTriggerProperties

SetScheduleExpression sets the ScheduleExpression field's value.

func (*ScheduledTriggerProperties) SetScheduleOffset added in v1.37.4 

func (s *ScheduledTriggerProperties) SetScheduleOffset(v int64) *ScheduledTriggerProperties

SetScheduleOffset sets the ScheduleOffset field's value.

func (*ScheduledTriggerProperties) SetScheduleStartTime 

func (s *ScheduledTriggerProperties) SetScheduleStartTime(v time.Time) *ScheduledTriggerProperties

SetScheduleStartTime sets the ScheduleStartTime field's value.

func (*ScheduledTriggerProperties) SetTimezone 

func (s *ScheduledTriggerProperties) SetTimezone(v string) *ScheduledTriggerProperties

SetTimezone sets the Timezone field's value.

func (ScheduledTriggerProperties) String 

func (s ScheduledTriggerProperties) String() string

String returns the string representation

func (*ScheduledTriggerProperties) Validate 

func (s *ScheduledTriggerProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceNowConnectorProfileCredentials 

type ServiceNowConnectorProfileCredentials struct {

	// The password that corresponds to the user name.
	//
	// Password is a required field
	Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

	// The name of the user.
	//
	// Username is a required field
	Username *string `locationName:"username" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using ServiceNow.

func (ServiceNowConnectorProfileCredentials) GoString 

func (s ServiceNowConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ServiceNowConnectorProfileCredentials) SetPassword 

func (s *ServiceNowConnectorProfileCredentials) SetPassword(v string) *ServiceNowConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*ServiceNowConnectorProfileCredentials) SetUsername 

func (s *ServiceNowConnectorProfileCredentials) SetUsername(v string) *ServiceNowConnectorProfileCredentials

SetUsername sets the Username field's value.

func (ServiceNowConnectorProfileCredentials) String 

func (s ServiceNowConnectorProfileCredentials) String() string

String returns the string representation

func (*ServiceNowConnectorProfileCredentials) Validate 

func (s *ServiceNowConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceNowConnectorProfileProperties 

type ServiceNowConnectorProfileProperties struct {

	// The location of the ServiceNow resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using ServiceNow.

func (ServiceNowConnectorProfileProperties) GoString 

func (s ServiceNowConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ServiceNowConnectorProfileProperties) SetInstanceUrl 

func (s *ServiceNowConnectorProfileProperties) SetInstanceUrl(v string) *ServiceNowConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (ServiceNowConnectorProfileProperties) String 

func (s ServiceNowConnectorProfileProperties) String() string

String returns the string representation

func (*ServiceNowConnectorProfileProperties) Validate 

func (s *ServiceNowConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceNowMetadata 

type ServiceNowMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to ServiceNow.

func (ServiceNowMetadata) GoString 

func (s ServiceNowMetadata) GoString() string

GoString returns the string representation

func (ServiceNowMetadata) String 

func (s ServiceNowMetadata) String() string

String returns the string representation

type ServiceNowSourceProperties 

type ServiceNowSourceProperties struct {

	// The object specified in the ServiceNow flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when ServiceNow is being used as a source.

func (ServiceNowSourceProperties) GoString 

func (s ServiceNowSourceProperties) GoString() string

GoString returns the string representation

func (*ServiceNowSourceProperties) SetObject 

func (s *ServiceNowSourceProperties) SetObject(v string) *ServiceNowSourceProperties

SetObject sets the Object field's value.

func (ServiceNowSourceProperties) String 

func (s ServiceNowSourceProperties) String() string

String returns the string representation

func (*ServiceNowSourceProperties) Validate 

func (s *ServiceNowSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceQuotaExceededException 

type ServiceQuotaExceededException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

The request would cause a service quota (such as the number of flows) to be exceeded.

func (*ServiceQuotaExceededException) Code 

func (s *ServiceQuotaExceededException) Code() string

Code returns the exception type name.

func (*ServiceQuotaExceededException) Error 

func (s *ServiceQuotaExceededException) Error() string

func (ServiceQuotaExceededException) GoString 

func (s ServiceQuotaExceededException) GoString() string

GoString returns the string representation

func (*ServiceQuotaExceededException) Message 

func (s *ServiceQuotaExceededException) Message() string

Message returns the exception's message.

func (*ServiceQuotaExceededException) OrigErr 

func (s *ServiceQuotaExceededException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ServiceQuotaExceededException) RequestID 

func (s *ServiceQuotaExceededException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ServiceQuotaExceededException) StatusCode 

func (s *ServiceQuotaExceededException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ServiceQuotaExceededException) String 

func (s ServiceQuotaExceededException) String() string

String returns the string representation

type SingularConnectorProfileCredentials 

type SingularConnectorProfileCredentials struct {

	// A unique alphanumeric identifier used to authenticate a user, developer,
	// or calling program to your API.
	//
	// ApiKey is a required field
	ApiKey *string `locationName:"apiKey" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Singular.

func (SingularConnectorProfileCredentials) GoString 

func (s SingularConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SingularConnectorProfileCredentials) SetApiKey 

func (s *SingularConnectorProfileCredentials) SetApiKey(v string) *SingularConnectorProfileCredentials

SetApiKey sets the ApiKey field's value.

func (SingularConnectorProfileCredentials) String 

func (s SingularConnectorProfileCredentials) String() string

String returns the string representation

func (*SingularConnectorProfileCredentials) Validate 

func (s *SingularConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SingularConnectorProfileProperties 

type SingularConnectorProfileProperties struct {
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Singular.

func (SingularConnectorProfileProperties) GoString 

func (s SingularConnectorProfileProperties) GoString() string

GoString returns the string representation

func (SingularConnectorProfileProperties) String 

func (s SingularConnectorProfileProperties) String() string

String returns the string representation

type SingularMetadata 

type SingularMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Singular.

func (SingularMetadata) GoString 

func (s SingularMetadata) GoString() string

GoString returns the string representation

func (SingularMetadata) String 

func (s SingularMetadata) String() string

String returns the string representation

type SingularSourceProperties 

type SingularSourceProperties struct {

	// The object specified in the Singular flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Singular is being used as a source.

func (SingularSourceProperties) GoString 

func (s SingularSourceProperties) GoString() string

GoString returns the string representation

func (*SingularSourceProperties) SetObject 

func (s *SingularSourceProperties) SetObject(v string) *SingularSourceProperties

SetObject sets the Object field's value.

func (SingularSourceProperties) String 

func (s SingularSourceProperties) String() string

String returns the string representation

func (*SingularSourceProperties) Validate 

func (s *SingularSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SlackConnectorProfileCredentials 

type SlackConnectorProfileCredentials struct {

	// The credentials used to access protected Slack resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// The identifier for the client.
	//
	// ClientId is a required field
	ClientId *string `locationName:"clientId" type:"string" required:"true"`

	// The client secret used by the OAuth client to authenticate to the authorization
	// server.
	//
	// ClientSecret is a required field
	ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

	// The OAuth requirement needed to request security tokens from the connector
	// endpoint.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Slack.

func (SlackConnectorProfileCredentials) GoString 

func (s SlackConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SlackConnectorProfileCredentials) SetAccessToken 

func (s *SlackConnectorProfileCredentials) SetAccessToken(v string) *SlackConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*SlackConnectorProfileCredentials) SetClientId 

func (s *SlackConnectorProfileCredentials) SetClientId(v string) *SlackConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*SlackConnectorProfileCredentials) SetClientSecret 

func (s *SlackConnectorProfileCredentials) SetClientSecret(v string) *SlackConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*SlackConnectorProfileCredentials) SetOAuthRequest 

func (s *SlackConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *SlackConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (SlackConnectorProfileCredentials) String 

func (s SlackConnectorProfileCredentials) String() string

String returns the string representation

func (*SlackConnectorProfileCredentials) Validate 

func (s *SlackConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SlackConnectorProfileProperties 

type SlackConnectorProfileProperties struct {

	// The location of the Slack resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Slack.

func (SlackConnectorProfileProperties) GoString 

func (s SlackConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SlackConnectorProfileProperties) SetInstanceUrl 

func (s *SlackConnectorProfileProperties) SetInstanceUrl(v string) *SlackConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (SlackConnectorProfileProperties) String 

func (s SlackConnectorProfileProperties) String() string

String returns the string representation

func (*SlackConnectorProfileProperties) Validate 

func (s *SlackConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SlackMetadata 

type SlackMetadata struct {

	// The desired authorization scope for the Slack account.
	OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Slack.

func (SlackMetadata) GoString 

func (s SlackMetadata) GoString() string

GoString returns the string representation

func (*SlackMetadata) SetOAuthScopes 

func (s *SlackMetadata) SetOAuthScopes(v []*string) *SlackMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (SlackMetadata) String 

func (s SlackMetadata) String() string

String returns the string representation

type SlackSourceProperties 

type SlackSourceProperties struct {

	// The object specified in the Slack flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Slack is being used as a source.

func (SlackSourceProperties) GoString 

func (s SlackSourceProperties) GoString() string

GoString returns the string representation

func (*SlackSourceProperties) SetObject 

func (s *SlackSourceProperties) SetObject(v string) *SlackSourceProperties

SetObject sets the Object field's value.

func (SlackSourceProperties) String 

func (s SlackSourceProperties) String() string

String returns the string representation

func (*SlackSourceProperties) Validate 

func (s *SlackSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SnowflakeConnectorProfileCredentials 

type SnowflakeConnectorProfileCredentials struct {

	// The password that corresponds to the user name.
	//
	// Password is a required field
	Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

	// The name of the user.
	//
	// Username is a required field
	Username *string `locationName:"username" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Snowflake.

func (SnowflakeConnectorProfileCredentials) GoString 

func (s SnowflakeConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SnowflakeConnectorProfileCredentials) SetPassword 

func (s *SnowflakeConnectorProfileCredentials) SetPassword(v string) *SnowflakeConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*SnowflakeConnectorProfileCredentials) SetUsername 

func (s *SnowflakeConnectorProfileCredentials) SetUsername(v string) *SnowflakeConnectorProfileCredentials

SetUsername sets the Username field's value.

func (SnowflakeConnectorProfileCredentials) String 

func (s SnowflakeConnectorProfileCredentials) String() string

String returns the string representation

func (*SnowflakeConnectorProfileCredentials) Validate 

func (s *SnowflakeConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SnowflakeConnectorProfileProperties 

type SnowflakeConnectorProfileProperties struct {

	// The name of the account.
	AccountName *string `locationName:"accountName" type:"string"`

	// The name of the Amazon S3 bucket associated with Snowflake.
	//
	// BucketName is a required field
	BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

	// The bucket path that refers to the Amazon S3 bucket associated with Snowflake.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The Snowflake Private Link service name to be used for private data transfers.
	PrivateLinkServiceName *string `locationName:"privateLinkServiceName" type:"string"`

	// The AWS Region of the Snowflake account.
	Region *string `locationName:"region" type:"string"`

	// The name of the Amazon S3 stage that was created while setting up an Amazon
	// S3 stage in the Snowflake account. This is written in the following format:
	// < Database>< Schema><Stage Name>.
	//
	// Stage is a required field
	Stage *string `locationName:"stage" type:"string" required:"true"`

	// The name of the Snowflake warehouse.
	//
	// Warehouse is a required field
	Warehouse *string `locationName:"warehouse" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Snowflake.

func (SnowflakeConnectorProfileProperties) GoString 

func (s SnowflakeConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SnowflakeConnectorProfileProperties) SetAccountName 

func (s *SnowflakeConnectorProfileProperties) SetAccountName(v string) *SnowflakeConnectorProfileProperties

SetAccountName sets the AccountName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketName 

func (s *SnowflakeConnectorProfileProperties) SetBucketName(v string) *SnowflakeConnectorProfileProperties

SetBucketName sets the BucketName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketPrefix 

func (s *SnowflakeConnectorProfileProperties) SetBucketPrefix(v string) *SnowflakeConnectorProfileProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeConnectorProfileProperties) SetPrivateLinkServiceName 

func (s *SnowflakeConnectorProfileProperties) SetPrivateLinkServiceName(v string) *SnowflakeConnectorProfileProperties

SetPrivateLinkServiceName sets the PrivateLinkServiceName field's value.

func (*SnowflakeConnectorProfileProperties) SetRegion 

func (s *SnowflakeConnectorProfileProperties) SetRegion(v string) *SnowflakeConnectorProfileProperties

SetRegion sets the Region field's value.

func (*SnowflakeConnectorProfileProperties) SetStage 

func (s *SnowflakeConnectorProfileProperties) SetStage(v string) *SnowflakeConnectorProfileProperties

SetStage sets the Stage field's value.

func (*SnowflakeConnectorProfileProperties) SetWarehouse 

func (s *SnowflakeConnectorProfileProperties) SetWarehouse(v string) *SnowflakeConnectorProfileProperties

SetWarehouse sets the Warehouse field's value.

func (SnowflakeConnectorProfileProperties) String 

func (s SnowflakeConnectorProfileProperties) String() string

String returns the string representation

func (*SnowflakeConnectorProfileProperties) Validate 

func (s *SnowflakeConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SnowflakeDestinationProperties 

type SnowflakeDestinationProperties struct {

	// The object key for the destination bucket in which Amazon AppFlow places
	// the files.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the Snowflake destination. For example, this setting would determine
	// if the flow should fail after one insertion error, or continue and attempt
	// to insert every record regardless of the initial failure. ErrorHandlingConfig
	// is a part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// The intermediate bucket that Amazon AppFlow uses when moving data into Snowflake.
	//
	// IntermediateBucketName is a required field
	IntermediateBucketName *string `locationName:"intermediateBucketName" min:"3" type:"string" required:"true"`

	// The object specified in the Snowflake flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Snowflake is being used as a destination.

func (SnowflakeDestinationProperties) GoString 

func (s SnowflakeDestinationProperties) GoString() string

GoString returns the string representation

func (*SnowflakeDestinationProperties) SetBucketPrefix 

func (s *SnowflakeDestinationProperties) SetBucketPrefix(v string) *SnowflakeDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeDestinationProperties) SetErrorHandlingConfig 

func (s *SnowflakeDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *SnowflakeDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*SnowflakeDestinationProperties) SetIntermediateBucketName 

func (s *SnowflakeDestinationProperties) SetIntermediateBucketName(v string) *SnowflakeDestinationProperties

SetIntermediateBucketName sets the IntermediateBucketName field's value.

func (*SnowflakeDestinationProperties) SetObject 

func (s *SnowflakeDestinationProperties) SetObject(v string) *SnowflakeDestinationProperties

SetObject sets the Object field's value.

func (SnowflakeDestinationProperties) String 

func (s SnowflakeDestinationProperties) String() string

String returns the string representation

func (*SnowflakeDestinationProperties) Validate 

func (s *SnowflakeDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SnowflakeMetadata 

type SnowflakeMetadata struct {

	// Specifies the supported AWS Regions when using Snowflake.
	SupportedRegions []*string `locationName:"supportedRegions" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Snowflake.

func (SnowflakeMetadata) GoString 

func (s SnowflakeMetadata) GoString() string

GoString returns the string representation

func (*SnowflakeMetadata) SetSupportedRegions 

func (s *SnowflakeMetadata) SetSupportedRegions(v []*string) *SnowflakeMetadata

SetSupportedRegions sets the SupportedRegions field's value.

func (SnowflakeMetadata) String 

func (s SnowflakeMetadata) String() string

String returns the string representation

type SourceConnectorProperties 

type SourceConnectorProperties struct {

	// Specifies the information that is required for querying Amplitude.
	Amplitude *AmplitudeSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Datadog.
	Datadog *DatadogSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Dynatrace.
	Dynatrace *DynatraceSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Google Analytics.
	GoogleAnalytics *GoogleAnalyticsSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Infor Nexus.
	InforNexus *InforNexusSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Marketo.
	Marketo *MarketoSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Amazon S3.
	S3 *S3SourceProperties `type:"structure"`

	// Specifies the information that is required for querying Salesforce.
	Salesforce *SalesforceSourceProperties `type:"structure"`

	// Specifies the information that is required for querying ServiceNow.
	ServiceNow *ServiceNowSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Singular.
	Singular *SingularSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Slack.
	Slack *SlackSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Trend Micro.
	Trendmicro *TrendmicroSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Veeva.
	Veeva *VeevaSourceProperties `type:"structure"`

	// Specifies the information that is required for querying Zendesk.
	Zendesk *ZendeskSourceProperties `type:"structure"`
	// contains filtered or unexported fields
}

Specifies the information that is required to query a particular connector.

func (SourceConnectorProperties) GoString 

func (s SourceConnectorProperties) GoString() string

GoString returns the string representation

func (*SourceConnectorProperties) SetAmplitude 

func (s *SourceConnectorProperties) SetAmplitude(v *AmplitudeSourceProperties) *SourceConnectorProperties

SetAmplitude sets the Amplitude field's value.

func (*SourceConnectorProperties) SetDatadog 

func (s *SourceConnectorProperties) SetDatadog(v *DatadogSourceProperties) *SourceConnectorProperties

SetDatadog sets the Datadog field's value.

func (*SourceConnectorProperties) SetDynatrace 

func (s *SourceConnectorProperties) SetDynatrace(v *DynatraceSourceProperties) *SourceConnectorProperties

SetDynatrace sets the Dynatrace field's value.

func (*SourceConnectorProperties) SetGoogleAnalytics 

func (s *SourceConnectorProperties) SetGoogleAnalytics(v *GoogleAnalyticsSourceProperties) *SourceConnectorProperties

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*SourceConnectorProperties) SetInforNexus 

func (s *SourceConnectorProperties) SetInforNexus(v *InforNexusSourceProperties) *SourceConnectorProperties

SetInforNexus sets the InforNexus field's value.

func (*SourceConnectorProperties) SetMarketo 

func (s *SourceConnectorProperties) SetMarketo(v *MarketoSourceProperties) *SourceConnectorProperties

SetMarketo sets the Marketo field's value.

func (*SourceConnectorProperties) SetS3 

func (s *SourceConnectorProperties) SetS3(v *S3SourceProperties) *SourceConnectorProperties

SetS3 sets the S3 field's value.

func (*SourceConnectorProperties) SetSalesforce 

func (s *SourceConnectorProperties) SetSalesforce(v *SalesforceSourceProperties) *SourceConnectorProperties

SetSalesforce sets the Salesforce field's value.

func (*SourceConnectorProperties) SetServiceNow 

func (s *SourceConnectorProperties) SetServiceNow(v *ServiceNowSourceProperties) *SourceConnectorProperties

SetServiceNow sets the ServiceNow field's value.

func (*SourceConnectorProperties) SetSingular 

func (s *SourceConnectorProperties) SetSingular(v *SingularSourceProperties) *SourceConnectorProperties

SetSingular sets the Singular field's value.

func (*SourceConnectorProperties) SetSlack 

func (s *SourceConnectorProperties) SetSlack(v *SlackSourceProperties) *SourceConnectorProperties

SetSlack sets the Slack field's value.

func (*SourceConnectorProperties) SetTrendmicro 

func (s *SourceConnectorProperties) SetTrendmicro(v *TrendmicroSourceProperties) *SourceConnectorProperties

SetTrendmicro sets the Trendmicro field's value.

func (*SourceConnectorProperties) SetVeeva 

func (s *SourceConnectorProperties) SetVeeva(v *VeevaSourceProperties) *SourceConnectorProperties

SetVeeva sets the Veeva field's value.

func (*SourceConnectorProperties) SetZendesk 

func (s *SourceConnectorProperties) SetZendesk(v *ZendeskSourceProperties) *SourceConnectorProperties

SetZendesk sets the Zendesk field's value.

func (SourceConnectorProperties) String 

func (s SourceConnectorProperties) String() string

String returns the string representation

func (*SourceConnectorProperties) Validate 

func (s *SourceConnectorProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SourceFieldProperties 

type SourceFieldProperties struct {

	// Indicates if the field can be queried.
	IsQueryable *bool `locationName:"isQueryable" type:"boolean"`

	// Indicates whether the field can be returned in a search result.
	IsRetrievable *bool `locationName:"isRetrievable" type:"boolean"`
	// contains filtered or unexported fields
}

The properties that can be applied to a field when the connector is being used as a source.

func (SourceFieldProperties) GoString 

func (s SourceFieldProperties) GoString() string

GoString returns the string representation

func (*SourceFieldProperties) SetIsQueryable 

func (s *SourceFieldProperties) SetIsQueryable(v bool) *SourceFieldProperties

SetIsQueryable sets the IsQueryable field's value.

func (*SourceFieldProperties) SetIsRetrievable 

func (s *SourceFieldProperties) SetIsRetrievable(v bool) *SourceFieldProperties

SetIsRetrievable sets the IsRetrievable field's value.

func (SourceFieldProperties) String 

func (s SourceFieldProperties) String() string

String returns the string representation

type SourceFlowConfig 

type SourceFlowConfig struct {

	// The name of the connector profile. This name must be unique for each connector
	// profile in the AWS account.
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

	// The type of connector, such as Salesforce, Amplitude, and so on.
	//
	// ConnectorType is a required field
	ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

	// Defines the configuration for a scheduled incremental data pull. If a valid
	// configuration is provided, the fields specified in the configuration are
	// used when querying for the incremental data pull.
	IncrementalPullConfig *IncrementalPullConfig `locationName:"incrementalPullConfig" type:"structure"`

	// Specifies the information that is required to query a particular source connector.
	//
	// SourceConnectorProperties is a required field
	SourceConnectorProperties *SourceConnectorProperties `locationName:"sourceConnectorProperties" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

Contains information about the configuration of the source connector used in the flow.

func (SourceFlowConfig) GoString 

func (s SourceFlowConfig) GoString() string

GoString returns the string representation

func (*SourceFlowConfig) SetConnectorProfileName 

func (s *SourceFlowConfig) SetConnectorProfileName(v string) *SourceFlowConfig

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*SourceFlowConfig) SetConnectorType 

func (s *SourceFlowConfig) SetConnectorType(v string) *SourceFlowConfig

SetConnectorType sets the ConnectorType field's value.

func (*SourceFlowConfig) SetIncrementalPullConfig added in v1.35.13 

func (s *SourceFlowConfig) SetIncrementalPullConfig(v *IncrementalPullConfig) *SourceFlowConfig

SetIncrementalPullConfig sets the IncrementalPullConfig field's value.

func (*SourceFlowConfig) SetSourceConnectorProperties 

func (s *SourceFlowConfig) SetSourceConnectorProperties(v *SourceConnectorProperties) *SourceFlowConfig

SetSourceConnectorProperties sets the SourceConnectorProperties field's value.

func (SourceFlowConfig) String 

func (s SourceFlowConfig) String() string

String returns the string representation

func (*SourceFlowConfig) Validate 

func (s *SourceFlowConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartFlowInput 

type StartFlowInput struct {

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (StartFlowInput) GoString 

func (s StartFlowInput) GoString() string

GoString returns the string representation

func (*StartFlowInput) SetFlowName 

func (s *StartFlowInput) SetFlowName(v string) *StartFlowInput

SetFlowName sets the FlowName field's value.

func (StartFlowInput) String 

func (s StartFlowInput) String() string

String returns the string representation

func (*StartFlowInput) Validate 

func (s *StartFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartFlowOutput 

type StartFlowOutput struct {

	// 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.
	ExecutionId *string `locationName:"executionId" type:"string"`

	// The flow's Amazon Resource Name (ARN).
	FlowArn *string `locationName:"flowArn" type:"string"`

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
	// contains filtered or unexported fields
}

func (StartFlowOutput) GoString 

func (s StartFlowOutput) GoString() string

GoString returns the string representation

func (*StartFlowOutput) SetExecutionId added in v1.35.13 

func (s *StartFlowOutput) SetExecutionId(v string) *StartFlowOutput

SetExecutionId sets the ExecutionId field's value.

func (*StartFlowOutput) SetFlowArn 

func (s *StartFlowOutput) SetFlowArn(v string) *StartFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*StartFlowOutput) SetFlowStatus 

func (s *StartFlowOutput) SetFlowStatus(v string) *StartFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (StartFlowOutput) String 

func (s StartFlowOutput) String() string

String returns the string representation

type StopFlowInput 

type StopFlowInput struct {

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (StopFlowInput) GoString 

func (s StopFlowInput) GoString() string

GoString returns the string representation

func (*StopFlowInput) SetFlowName 

func (s *StopFlowInput) SetFlowName(v string) *StopFlowInput

SetFlowName sets the FlowName field's value.

func (StopFlowInput) String 

func (s StopFlowInput) String() string

String returns the string representation

func (*StopFlowInput) Validate 

func (s *StopFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StopFlowOutput 

type StopFlowOutput struct {

	// The flow's Amazon Resource Name (ARN).
	FlowArn *string `locationName:"flowArn" type:"string"`

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
	// contains filtered or unexported fields
}

func (StopFlowOutput) GoString 

func (s StopFlowOutput) GoString() string

GoString returns the string representation

func (*StopFlowOutput) SetFlowArn 

func (s *StopFlowOutput) SetFlowArn(v string) *StopFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*StopFlowOutput) SetFlowStatus 

func (s *StopFlowOutput) SetFlowStatus(v string) *StopFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (StopFlowOutput) String 

func (s StopFlowOutput) String() string

String returns the string representation

type SupportedFieldTypeDetails 

type SupportedFieldTypeDetails struct {

	// The initial supported version for fieldType. If this is later changed to
	// a different version, v2 will be introduced.
	//
	// V1 is a required field
	V1 *FieldTypeDetails `locationName:"v1" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

Contains details regarding all the supported FieldTypes and their corresponding filterOperators and supportedValues.

func (SupportedFieldTypeDetails) GoString 

func (s SupportedFieldTypeDetails) GoString() string

GoString returns the string representation

func (*SupportedFieldTypeDetails) SetV1 

func (s *SupportedFieldTypeDetails) SetV1(v *FieldTypeDetails) *SupportedFieldTypeDetails

SetV1 sets the V1 field's value.

func (SupportedFieldTypeDetails) String 

func (s SupportedFieldTypeDetails) String() string

String returns the string representation

type TagResourceInput 

type TagResourceInput struct {

	// The Amazon Resource Name (ARN) of the flow that you want to tag.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

	// The tags used to organize, track, or control access for your flow.
	//
	// Tags is a required field
	Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
	// contains filtered or unexported fields
}

func (TagResourceInput) GoString 

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (*TagResourceInput) SetResourceArn 

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags 

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String 

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate 

func (s *TagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceOutput 

type TagResourceOutput struct {
	// contains filtered or unexported fields
}

func (TagResourceOutput) GoString 

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) String 

func (s TagResourceOutput) String() string

String returns the string representation

type Task 

type Task struct {

	// The operation to be performed on the provided source fields.
	ConnectorOperator *ConnectorOperator `locationName:"connectorOperator" type:"structure"`

	// A field in a destination connector, or a field value against which Amazon
	// AppFlow validates a source field.
	DestinationField *string `locationName:"destinationField" type:"string"`

	// The source fields to which a particular task is applied.
	//
	// SourceFields is a required field
	SourceFields []*string `locationName:"sourceFields" type:"list" required:"true"`

	// A map used to store task-related information. The execution service looks
	// for particular information based on the TaskType.
	TaskProperties map[string]*string `locationName:"taskProperties" type:"map"`

	// Specifies the particular task implementation that Amazon AppFlow performs.
	//
	// TaskType is a required field
	TaskType *string `locationName:"taskType" type:"string" required:"true" enum:"TaskType"`
	// contains filtered or unexported fields
}

A class for modeling different type of tasks. Task implementation varies based on the TaskType.

func (Task) GoString 

func (s Task) GoString() string

GoString returns the string representation

func (*Task) SetConnectorOperator 

func (s *Task) SetConnectorOperator(v *ConnectorOperator) *Task

SetConnectorOperator sets the ConnectorOperator field's value.

func (*Task) SetDestinationField 

func (s *Task) SetDestinationField(v string) *Task

SetDestinationField sets the DestinationField field's value.

func (*Task) SetSourceFields 

func (s *Task) SetSourceFields(v []*string) *Task

SetSourceFields sets the SourceFields field's value.

func (*Task) SetTaskProperties 

func (s *Task) SetTaskProperties(v map[string]*string) *Task

SetTaskProperties sets the TaskProperties field's value.

func (*Task) SetTaskType 

func (s *Task) SetTaskType(v string) *Task

SetTaskType sets the TaskType field's value.

func (Task) String 

func (s Task) String() string

String returns the string representation

func (*Task) Validate 

func (s *Task) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TrendmicroConnectorProfileCredentials 

type TrendmicroConnectorProfileCredentials struct {

	// The Secret Access Key portion of the credentials.
	//
	// ApiSecretKey is a required field
	ApiSecretKey *string `locationName:"apiSecretKey" type:"string" required:"true" sensitive:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Trend Micro.

func (TrendmicroConnectorProfileCredentials) GoString 

func (s TrendmicroConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*TrendmicroConnectorProfileCredentials) SetApiSecretKey 

func (s *TrendmicroConnectorProfileCredentials) SetApiSecretKey(v string) *TrendmicroConnectorProfileCredentials

SetApiSecretKey sets the ApiSecretKey field's value.

func (TrendmicroConnectorProfileCredentials) String 

func (s TrendmicroConnectorProfileCredentials) String() string

String returns the string representation

func (*TrendmicroConnectorProfileCredentials) Validate 

func (s *TrendmicroConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TrendmicroConnectorProfileProperties 

type TrendmicroConnectorProfileProperties struct {
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Trend Micro.

func (TrendmicroConnectorProfileProperties) GoString 

func (s TrendmicroConnectorProfileProperties) GoString() string

GoString returns the string representation

func (TrendmicroConnectorProfileProperties) String 

func (s TrendmicroConnectorProfileProperties) String() string

String returns the string representation

type TrendmicroMetadata 

type TrendmicroMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Trend Micro.

func (TrendmicroMetadata) GoString 

func (s TrendmicroMetadata) GoString() string

GoString returns the string representation

func (TrendmicroMetadata) String 

func (s TrendmicroMetadata) String() string

String returns the string representation

type TrendmicroSourceProperties 

type TrendmicroSourceProperties struct {

	// The object specified in the Trend Micro flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when using Trend Micro as a flow source.

func (TrendmicroSourceProperties) GoString 

func (s TrendmicroSourceProperties) GoString() string

GoString returns the string representation

func (*TrendmicroSourceProperties) SetObject 

func (s *TrendmicroSourceProperties) SetObject(v string) *TrendmicroSourceProperties

SetObject sets the Object field's value.

func (TrendmicroSourceProperties) String 

func (s TrendmicroSourceProperties) String() string

String returns the string representation

func (*TrendmicroSourceProperties) Validate 

func (s *TrendmicroSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TriggerConfig 

type TriggerConfig struct {

	// Specifies the configuration details of a schedule-triggered flow as defined
	// by the user. Currently, these settings only apply to the Scheduled trigger
	// type.
	TriggerProperties *TriggerProperties `locationName:"triggerProperties" type:"structure"`

	// Specifies the type of flow trigger. This can be OnDemand, Scheduled, or Event.
	//
	// TriggerType is a required field
	TriggerType *string `locationName:"triggerType" type:"string" required:"true" enum:"TriggerType"`
	// contains filtered or unexported fields
}

The trigger settings that determine how and when Amazon AppFlow runs the specified flow.

func (TriggerConfig) GoString 

func (s TriggerConfig) GoString() string

GoString returns the string representation

func (*TriggerConfig) SetTriggerProperties 

func (s *TriggerConfig) SetTriggerProperties(v *TriggerProperties) *TriggerConfig

SetTriggerProperties sets the TriggerProperties field's value.

func (*TriggerConfig) SetTriggerType 

func (s *TriggerConfig) SetTriggerType(v string) *TriggerConfig

SetTriggerType sets the TriggerType field's value.

func (TriggerConfig) String 

func (s TriggerConfig) String() string

String returns the string representation

func (*TriggerConfig) Validate 

func (s *TriggerConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TriggerProperties 

type TriggerProperties struct {

	// Specifies the configuration details of a schedule-triggered flow as defined
	// by the user.
	Scheduled *ScheduledTriggerProperties `type:"structure"`
	// contains filtered or unexported fields
}

Specifies the configuration details that control the trigger for a flow. Currently, these settings only apply to the Scheduled trigger type.

func (TriggerProperties) GoString 

func (s TriggerProperties) GoString() string

GoString returns the string representation

func (*TriggerProperties) SetScheduled 

func (s *TriggerProperties) SetScheduled(v *ScheduledTriggerProperties) *TriggerProperties

SetScheduled sets the Scheduled field's value.

func (TriggerProperties) String 

func (s TriggerProperties) String() string

String returns the string representation

func (*TriggerProperties) Validate 

func (s *TriggerProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UnsupportedOperationException 

type UnsupportedOperationException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

The requested operation is not supported for the current flow.

func (*UnsupportedOperationException) Code 

func (s *UnsupportedOperationException) Code() string

Code returns the exception type name.

func (*UnsupportedOperationException) Error 

func (s *UnsupportedOperationException) Error() string

func (UnsupportedOperationException) GoString 

func (s UnsupportedOperationException) GoString() string

GoString returns the string representation

func (*UnsupportedOperationException) Message 

func (s *UnsupportedOperationException) Message() string

Message returns the exception's message.

func (*UnsupportedOperationException) OrigErr 

func (s *UnsupportedOperationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*UnsupportedOperationException) RequestID 

func (s *UnsupportedOperationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*UnsupportedOperationException) StatusCode 

func (s *UnsupportedOperationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (UnsupportedOperationException) String 

func (s UnsupportedOperationException) String() string

String returns the string representation

type UntagResourceInput 

type UntagResourceInput struct {

	// The Amazon Resource Name (ARN) of the flow that you want to untag.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

	// The tag keys associated with the tag that you want to remove from your flow.
	//
	// TagKeys is a required field
	TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (UntagResourceInput) GoString 

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (*UntagResourceInput) SetResourceArn 

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys 

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String 

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate 

func (s *UntagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UntagResourceOutput 

type UntagResourceOutput struct {
	// contains filtered or unexported fields
}

func (UntagResourceOutput) GoString 

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) String 

func (s UntagResourceOutput) String() string

String returns the string representation

type UpdateConnectorProfileInput 

type UpdateConnectorProfileInput struct {

	// Indicates the connection mode and if it is public or private.
	//
	// ConnectionMode is a required field
	ConnectionMode *string `locationName:"connectionMode" type:"string" required:"true" enum:"ConnectionMode"`

	// Defines the connector-specific profile configuration and credentials.
	//
	// ConnectorProfileConfig is a required field
	ConnectorProfileConfig *ConnectorProfileConfig `locationName:"connectorProfileConfig" type:"structure" required:"true"`

	// The name of the connector profile and is unique for each ConnectorProfile
	// in the AWS Account.
	//
	// ConnectorProfileName is a required field
	ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (UpdateConnectorProfileInput) GoString 

func (s UpdateConnectorProfileInput) GoString() string

GoString returns the string representation

func (*UpdateConnectorProfileInput) SetConnectionMode 

func (s *UpdateConnectorProfileInput) SetConnectionMode(v string) *UpdateConnectorProfileInput

SetConnectionMode sets the ConnectionMode field's value.

func (*UpdateConnectorProfileInput) SetConnectorProfileConfig 

func (s *UpdateConnectorProfileInput) SetConnectorProfileConfig(v *ConnectorProfileConfig) *UpdateConnectorProfileInput

SetConnectorProfileConfig sets the ConnectorProfileConfig field's value.

func (*UpdateConnectorProfileInput) SetConnectorProfileName 

func (s *UpdateConnectorProfileInput) SetConnectorProfileName(v string) *UpdateConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (UpdateConnectorProfileInput) String 

func (s UpdateConnectorProfileInput) String() string

String returns the string representation

func (*UpdateConnectorProfileInput) Validate 

func (s *UpdateConnectorProfileInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateConnectorProfileOutput 

type UpdateConnectorProfileOutput struct {

	// The Amazon Resource Name (ARN) of the connector profile.
	ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`
	// contains filtered or unexported fields
}

func (UpdateConnectorProfileOutput) GoString 

func (s UpdateConnectorProfileOutput) GoString() string

GoString returns the string representation

func (*UpdateConnectorProfileOutput) SetConnectorProfileArn 

func (s *UpdateConnectorProfileOutput) SetConnectorProfileArn(v string) *UpdateConnectorProfileOutput

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (UpdateConnectorProfileOutput) String 

func (s UpdateConnectorProfileOutput) String() string

String returns the string representation

type UpdateFlowInput 

type UpdateFlowInput struct {

	// A description of the flow.
	Description *string `locationName:"description" type:"string"`

	// The configuration that controls how Amazon AppFlow transfers data to the
	// destination connector.
	//
	// DestinationFlowConfigList is a required field
	DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list" required:"true"`

	// The specified name of the flow. Spaces are not allowed. Use underscores (_)
	// or hyphens (-) only.
	//
	// FlowName is a required field
	FlowName *string `locationName:"flowName" type:"string" required:"true"`

	// Contains information about the configuration of the source connector used
	// in the flow.
	SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure"`

	// A list of tasks that Amazon AppFlow performs while transferring the data
	// in the flow run.
	//
	// Tasks is a required field
	Tasks []*Task `locationName:"tasks" type:"list" required:"true"`

	// The trigger settings that determine how and when the flow runs.
	//
	// TriggerConfig is a required field
	TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

func (UpdateFlowInput) GoString 

func (s UpdateFlowInput) GoString() string

GoString returns the string representation

func (*UpdateFlowInput) SetDescription 

func (s *UpdateFlowInput) SetDescription(v string) *UpdateFlowInput

SetDescription sets the Description field's value.

func (*UpdateFlowInput) SetDestinationFlowConfigList 

func (s *UpdateFlowInput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *UpdateFlowInput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*UpdateFlowInput) SetFlowName 

func (s *UpdateFlowInput) SetFlowName(v string) *UpdateFlowInput

SetFlowName sets the FlowName field's value.

func (*UpdateFlowInput) SetSourceFlowConfig 

func (s *UpdateFlowInput) SetSourceFlowConfig(v *SourceFlowConfig) *UpdateFlowInput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*UpdateFlowInput) SetTasks 

func (s *UpdateFlowInput) SetTasks(v []*Task) *UpdateFlowInput

SetTasks sets the Tasks field's value.

func (*UpdateFlowInput) SetTriggerConfig 

func (s *UpdateFlowInput) SetTriggerConfig(v *TriggerConfig) *UpdateFlowInput

SetTriggerConfig sets the TriggerConfig field's value.

func (UpdateFlowInput) String 

func (s UpdateFlowInput) String() string

String returns the string representation

func (*UpdateFlowInput) Validate 

func (s *UpdateFlowInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateFlowOutput 

type UpdateFlowOutput struct {

	// Indicates the current status of the flow.
	FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
	// contains filtered or unexported fields
}

func (UpdateFlowOutput) GoString 

func (s UpdateFlowOutput) GoString() string

GoString returns the string representation

func (*UpdateFlowOutput) SetFlowStatus 

func (s *UpdateFlowOutput) SetFlowStatus(v string) *UpdateFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (UpdateFlowOutput) String 

func (s UpdateFlowOutput) String() string

String returns the string representation

type UpsolverDestinationProperties added in v1.35.35 

type UpsolverDestinationProperties struct {

	// The Upsolver Amazon S3 bucket name in which Amazon AppFlow places the transferred
	// data.
	//
	// BucketName is a required field
	BucketName *string `locationName:"bucketName" min:"16" type:"string" required:"true"`

	// The object key for the destination Upsolver Amazon S3 bucket in which Amazon
	// AppFlow places the files.
	BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

	// The configuration that determines how data is formatted when Upsolver is
	// used as the flow destination.
	//
	// S3OutputFormatConfig is a required field
	S3OutputFormatConfig *UpsolverS3OutputFormatConfig `locationName:"s3OutputFormatConfig" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when Upsolver is used as a destination.

func (UpsolverDestinationProperties) GoString added in v1.35.35 

func (s UpsolverDestinationProperties) GoString() string

GoString returns the string representation

func (*UpsolverDestinationProperties) SetBucketName added in v1.35.35 

func (s *UpsolverDestinationProperties) SetBucketName(v string) *UpsolverDestinationProperties

SetBucketName sets the BucketName field's value.

func (*UpsolverDestinationProperties) SetBucketPrefix added in v1.35.35 

func (s *UpsolverDestinationProperties) SetBucketPrefix(v string) *UpsolverDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*UpsolverDestinationProperties) SetS3OutputFormatConfig added in v1.35.35 

func (s *UpsolverDestinationProperties) SetS3OutputFormatConfig(v *UpsolverS3OutputFormatConfig) *UpsolverDestinationProperties

SetS3OutputFormatConfig sets the S3OutputFormatConfig field's value.

func (UpsolverDestinationProperties) String added in v1.35.35 

func (s UpsolverDestinationProperties) String() string

String returns the string representation

func (*UpsolverDestinationProperties) Validate added in v1.35.35 

func (s *UpsolverDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpsolverMetadata added in v1.35.35 

type UpsolverMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Upsolver.

func (UpsolverMetadata) GoString added in v1.35.35 

func (s UpsolverMetadata) GoString() string

GoString returns the string representation

func (UpsolverMetadata) String added in v1.35.35 

func (s UpsolverMetadata) String() string

String returns the string representation

type UpsolverS3OutputFormatConfig added in v1.35.35 

type UpsolverS3OutputFormatConfig struct {

	// The aggregation settings that you can use to customize the output format
	// of your flow data.
	AggregationConfig *AggregationConfig `locationName:"aggregationConfig" type:"structure"`

	// Indicates the file type that Amazon AppFlow places in the Upsolver Amazon
	// S3 bucket.
	FileType *string `locationName:"fileType" type:"string" enum:"FileType"`

	// Determines the prefix that Amazon AppFlow applies to the destination folder
	// name. You can name your destination folders according to the flow frequency
	// and date.
	//
	// PrefixConfig is a required field
	PrefixConfig *PrefixConfig `locationName:"prefixConfig" type:"structure" required:"true"`
	// contains filtered or unexported fields
}

The configuration that determines how Amazon AppFlow formats the flow output data when Upsolver is used as the destination.

func (UpsolverS3OutputFormatConfig) GoString added in v1.35.35 

func (s UpsolverS3OutputFormatConfig) GoString() string

GoString returns the string representation

func (*UpsolverS3OutputFormatConfig) SetAggregationConfig added in v1.35.35 

func (s *UpsolverS3OutputFormatConfig) SetAggregationConfig(v *AggregationConfig) *UpsolverS3OutputFormatConfig

SetAggregationConfig sets the AggregationConfig field's value.

func (*UpsolverS3OutputFormatConfig) SetFileType added in v1.35.35 

func (s *UpsolverS3OutputFormatConfig) SetFileType(v string) *UpsolverS3OutputFormatConfig

SetFileType sets the FileType field's value.

func (*UpsolverS3OutputFormatConfig) SetPrefixConfig added in v1.35.35 

func (s *UpsolverS3OutputFormatConfig) SetPrefixConfig(v *PrefixConfig) *UpsolverS3OutputFormatConfig

SetPrefixConfig sets the PrefixConfig field's value.

func (UpsolverS3OutputFormatConfig) String added in v1.35.35 

func (s UpsolverS3OutputFormatConfig) String() string

String returns the string representation

func (*UpsolverS3OutputFormatConfig) Validate added in v1.35.35 

func (s *UpsolverS3OutputFormatConfig) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ValidationException 

type ValidationException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" type:"string"`
	// contains filtered or unexported fields
}

The request has invalid or missing parameters.

func (*ValidationException) Code 

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error 

func (s *ValidationException) Error() string

func (ValidationException) GoString 

func (s ValidationException) GoString() string

GoString returns the string representation

func (*ValidationException) Message 

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr 

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID 

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode 

func (s *ValidationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ValidationException) String 

func (s ValidationException) String() string

String returns the string representation

type VeevaConnectorProfileCredentials 

type VeevaConnectorProfileCredentials struct {

	// The password that corresponds to the user name.
	//
	// Password is a required field
	Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

	// The name of the user.
	//
	// Username is a required field
	Username *string `locationName:"username" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Veeva.

func (VeevaConnectorProfileCredentials) GoString 

func (s VeevaConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*VeevaConnectorProfileCredentials) SetPassword 

func (s *VeevaConnectorProfileCredentials) SetPassword(v string) *VeevaConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*VeevaConnectorProfileCredentials) SetUsername 

func (s *VeevaConnectorProfileCredentials) SetUsername(v string) *VeevaConnectorProfileCredentials

SetUsername sets the Username field's value.

func (VeevaConnectorProfileCredentials) String 

func (s VeevaConnectorProfileCredentials) String() string

String returns the string representation

func (*VeevaConnectorProfileCredentials) Validate 

func (s *VeevaConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type VeevaConnectorProfileProperties 

type VeevaConnectorProfileProperties struct {

	// The location of the Veeva resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Veeva.

func (VeevaConnectorProfileProperties) GoString 

func (s VeevaConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*VeevaConnectorProfileProperties) SetInstanceUrl 

func (s *VeevaConnectorProfileProperties) SetInstanceUrl(v string) *VeevaConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (VeevaConnectorProfileProperties) String 

func (s VeevaConnectorProfileProperties) String() string

String returns the string representation

func (*VeevaConnectorProfileProperties) Validate 

func (s *VeevaConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type VeevaMetadata 

type VeevaMetadata struct {
	// contains filtered or unexported fields
}

The connector metadata specific to Veeva.

func (VeevaMetadata) GoString 

func (s VeevaMetadata) GoString() string

GoString returns the string representation

func (VeevaMetadata) String 

func (s VeevaMetadata) String() string

String returns the string representation

type VeevaSourceProperties 

type VeevaSourceProperties struct {

	// The object specified in the Veeva flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when using Veeva as a flow source.

func (VeevaSourceProperties) GoString 

func (s VeevaSourceProperties) GoString() string

GoString returns the string representation

func (*VeevaSourceProperties) SetObject 

func (s *VeevaSourceProperties) SetObject(v string) *VeevaSourceProperties

SetObject sets the Object field's value.

func (VeevaSourceProperties) String 

func (s VeevaSourceProperties) String() string

String returns the string representation

func (*VeevaSourceProperties) Validate 

func (s *VeevaSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ZendeskConnectorProfileCredentials 

type ZendeskConnectorProfileCredentials struct {

	// The credentials used to access protected Zendesk resources.
	AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

	// The identifier for the desired client.
	//
	// ClientId is a required field
	ClientId *string `locationName:"clientId" type:"string" required:"true"`

	// The client secret used by the OAuth client to authenticate to the authorization
	// server.
	//
	// ClientSecret is a required field
	ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

	// The OAuth requirement needed to request security tokens from the connector
	// endpoint.
	OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
	// contains filtered or unexported fields
}

The connector-specific profile credentials required when using Zendesk.

func (ZendeskConnectorProfileCredentials) GoString 

func (s ZendeskConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ZendeskConnectorProfileCredentials) SetAccessToken 

func (s *ZendeskConnectorProfileCredentials) SetAccessToken(v string) *ZendeskConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*ZendeskConnectorProfileCredentials) SetClientId 

func (s *ZendeskConnectorProfileCredentials) SetClientId(v string) *ZendeskConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*ZendeskConnectorProfileCredentials) SetClientSecret 

func (s *ZendeskConnectorProfileCredentials) SetClientSecret(v string) *ZendeskConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*ZendeskConnectorProfileCredentials) SetOAuthRequest 

func (s *ZendeskConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *ZendeskConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (ZendeskConnectorProfileCredentials) String 

func (s ZendeskConnectorProfileCredentials) String() string

String returns the string representation

func (*ZendeskConnectorProfileCredentials) Validate 

func (s *ZendeskConnectorProfileCredentials) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ZendeskConnectorProfileProperties 

type ZendeskConnectorProfileProperties struct {

	// The location of the Zendesk resource.
	//
	// InstanceUrl is a required field
	InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The connector-specific profile properties required when using Zendesk.

func (ZendeskConnectorProfileProperties) GoString 

func (s ZendeskConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ZendeskConnectorProfileProperties) SetInstanceUrl 

func (s *ZendeskConnectorProfileProperties) SetInstanceUrl(v string) *ZendeskConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (ZendeskConnectorProfileProperties) String 

func (s ZendeskConnectorProfileProperties) String() string

String returns the string representation

func (*ZendeskConnectorProfileProperties) Validate 

func (s *ZendeskConnectorProfileProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ZendeskDestinationProperties added in v1.38.13 

type ZendeskDestinationProperties struct {

	// The settings that determine how Amazon AppFlow handles an error when placing
	// data in the destination. For example, this setting would determine if the
	// flow should fail after one insertion error, or continue and attempt to insert
	// every record regardless of the initial failure. ErrorHandlingConfig is a
	// part of the destination connector details.
	ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

	// A list of field names that can be used as an ID field when performing a write
	// operation.
	IdFieldNames []*string `locationName:"idFieldNames" type:"list"`

	// The object specified in the Zendesk flow destination.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`

	// The possible write operations in the destination connector. When this value
	// is not provided, this defaults to the INSERT operation.
	WriteOperationType *string `locationName:"writeOperationType" type:"string" enum:"WriteOperationType"`
	// contains filtered or unexported fields
}

The properties that are applied when Zendesk is used as a destination.

func (ZendeskDestinationProperties) GoString added in v1.38.13 

func (s ZendeskDestinationProperties) GoString() string

GoString returns the string representation

func (*ZendeskDestinationProperties) SetErrorHandlingConfig added in v1.38.13 

func (s *ZendeskDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *ZendeskDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*ZendeskDestinationProperties) SetIdFieldNames added in v1.38.13 

func (s *ZendeskDestinationProperties) SetIdFieldNames(v []*string) *ZendeskDestinationProperties

SetIdFieldNames sets the IdFieldNames field's value.

func (*ZendeskDestinationProperties) SetObject added in v1.38.13 

func (s *ZendeskDestinationProperties) SetObject(v string) *ZendeskDestinationProperties

SetObject sets the Object field's value.

func (*ZendeskDestinationProperties) SetWriteOperationType added in v1.38.13 

func (s *ZendeskDestinationProperties) SetWriteOperationType(v string) *ZendeskDestinationProperties

SetWriteOperationType sets the WriteOperationType field's value.

func (ZendeskDestinationProperties) String added in v1.38.13 

func (s ZendeskDestinationProperties) String() string

String returns the string representation

func (*ZendeskDestinationProperties) Validate added in v1.38.13 

func (s *ZendeskDestinationProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ZendeskMetadata 

type ZendeskMetadata struct {

	// The desired authorization scope for the Zendesk account.
	OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
	// contains filtered or unexported fields
}

The connector metadata specific to Zendesk.

func (ZendeskMetadata) GoString 

func (s ZendeskMetadata) GoString() string

GoString returns the string representation

func (*ZendeskMetadata) SetOAuthScopes 

func (s *ZendeskMetadata) SetOAuthScopes(v []*string) *ZendeskMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (ZendeskMetadata) String 

func (s ZendeskMetadata) String() string

String returns the string representation

type ZendeskSourceProperties 

type ZendeskSourceProperties struct {

	// The object specified in the Zendesk flow source.
	//
	// Object is a required field
	Object *string `locationName:"object" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The properties that are applied when using Zendesk as a flow source.

func (ZendeskSourceProperties) GoString 

func (s ZendeskSourceProperties) GoString() string

GoString returns the string representation

func (*ZendeskSourceProperties) SetObject 

func (s *ZendeskSourceProperties) SetObject(v string) *ZendeskSourceProperties

SetObject sets the Object field's value.

func (ZendeskSourceProperties) String 

func (s ZendeskSourceProperties) String() string

String returns the string representation

func (*ZendeskSourceProperties) Validate 

func (s *ZendeskSourceProperties) Validate() error

Validate inspects the fields of the type to determine if they are valid.

Source Files

View all Source files

Directories

Path Synopsis
Package appflowiface provides an interface to enable mocking the Amazon Appflow service client for testing your code.
 Package appflowiface provides an interface to enable mocking the Amazon Appflow service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.