appflow

package
v1.34.25 Latest Latest
Warning

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

Go to latest
Published: Sep 16, 2020 License: Apache-2.0 Imports: 10 Imported by: 16

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"
)
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"
)
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"

	// 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 (
	// 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 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

GoString returns the string representation

func (*AmplitudeConnectorProfileCredentials) SetApiKey

SetApiKey sets the ApiKey field's value.

func (*AmplitudeConnectorProfileCredentials) SetSecretKey

SetSecretKey sets the SecretKey field's value.

func (AmplitudeConnectorProfileCredentials) String

String returns the string representation

func (*AmplitudeConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (AmplitudeConnectorProfileProperties) 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

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

Code returns the exception type name.

func (*ConnectorAuthenticationException) Error

func (ConnectorAuthenticationException) GoString

GoString returns the string representation

func (*ConnectorAuthenticationException) Message

Message returns the exception's message.

func (*ConnectorAuthenticationException) OrigErr

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConnectorAuthenticationException) RequestID

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

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

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

SetLabel sets the Label field's value.

func (*ConnectorEntityField) SetSourceProperties

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 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 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 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

SetAmplitude sets the Amplitude field's value.

func (*ConnectorMetadata) SetDatadog

SetDatadog sets the Datadog field's value.

func (*ConnectorMetadata) SetDynatrace

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorMetadata) SetEventBridge

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) SetInforNexus

SetInforNexus sets the InforNexus field's value.

func (*ConnectorMetadata) SetMarketo

SetMarketo sets the Marketo field's value.

func (*ConnectorMetadata) SetRedshift

SetRedshift sets the Redshift field's value.

func (*ConnectorMetadata) SetS3

SetS3 sets the S3 field's value.

func (*ConnectorMetadata) SetSalesforce

SetSalesforce sets the Salesforce field's value.

func (*ConnectorMetadata) SetServiceNow

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorMetadata) SetSingular

SetSingular sets the Singular field's value.

func (*ConnectorMetadata) SetSlack

SetSlack sets the Slack field's value.

func (*ConnectorMetadata) SetSnowflake

SetSnowflake sets the Snowflake field's value.

func (*ConnectorMetadata) SetTrendmicro

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorMetadata) SetVeeva

SetVeeva sets the Veeva field's value.

func (*ConnectorMetadata) SetZendesk

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

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

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 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

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileCredentials) SetDatadog

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileCredentials) SetDynatrace

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileCredentials) SetGoogleAnalytics

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileCredentials) SetInforNexus

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileCredentials) SetMarketo

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileCredentials) SetRedshift

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileCredentials) SetSalesforce

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileCredentials) SetServiceNow

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileCredentials) SetSingular

SetSingular sets the Singular field's value.

func (*ConnectorProfileCredentials) SetSlack

SetSlack sets the Slack field's value.

func (*ConnectorProfileCredentials) SetSnowflake

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileCredentials) SetTrendmicro

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileCredentials) SetVeeva

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileCredentials) SetZendesk

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileCredentials) 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 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

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileProperties) SetDatadog

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileProperties) SetDynatrace

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileProperties) SetGoogleAnalytics

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileProperties) SetInforNexus

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileProperties) SetMarketo

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileProperties) SetRedshift

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileProperties) SetSalesforce

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileProperties) SetServiceNow

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileProperties) SetSingular

SetSingular sets the Singular field's value.

func (*ConnectorProfileProperties) SetSlack

SetSlack sets the Slack field's value.

func (*ConnectorProfileProperties) SetSnowflake

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileProperties) SetTrendmicro

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileProperties) SetVeeva

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileProperties) SetZendesk

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileProperties) 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

SetConnectionMode sets the ConnectionMode field's value.

func (*CreateConnectorProfileInput) SetConnectorProfileConfig

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

SetConnectorType sets the ConnectorType field's value.

func (*CreateConnectorProfileInput) SetKmsArn

SetKmsArn sets the KmsArn field's value.

func (CreateConnectorProfileInput) 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

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (CreateConnectorProfileOutput) 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 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

GoString returns the string representation

func (*DatadogConnectorProfileCredentials) SetApiKey

SetApiKey sets the ApiKey field's value.

func (*DatadogConnectorProfileCredentials) SetApplicationKey

SetApplicationKey sets the ApplicationKey field's value.

func (DatadogConnectorProfileCredentials) String

String returns the string representation

func (*DatadogConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*DatadogConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (DatadogConnectorProfileProperties) String

String returns the string representation

func (*DatadogConnectorProfileProperties) Validate

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

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

SetForceDelete sets the ForceDelete field's value.

func (DeleteConnectorProfileInput) 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

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

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

SetConnectorType sets the ConnectorType field's value.

func (DescribeConnectorEntityInput) 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

GoString returns the string representation

func (*DescribeConnectorEntityOutput) SetConnectorEntityFields

SetConnectorEntityFields sets the ConnectorEntityFields field's value.

func (DescribeConnectorEntityOutput) 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

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

SetConnectorType sets the ConnectorType field's value.

func (*DescribeConnectorProfilesInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*DescribeConnectorProfilesInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesInput) 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

GoString returns the string representation

func (*DescribeConnectorProfilesOutput) SetConnectorProfileDetails

SetConnectorProfileDetails sets the ConnectorProfileDetails field's value.

func (*DescribeConnectorProfilesOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesOutput) 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

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

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

GoString returns the string representation

func (*DescribeFlowExecutionRecordsInput) SetFlowName

SetFlowName sets the FlowName field's value.

func (*DescribeFlowExecutionRecordsInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*DescribeFlowExecutionRecordsInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsInput) String

String returns the string representation

func (*DescribeFlowExecutionRecordsInput) Validate

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

GoString returns the string representation

func (*DescribeFlowExecutionRecordsOutput) SetFlowExecutions

SetFlowExecutions sets the FlowExecutions field's value.

func (*DescribeFlowExecutionRecordsOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsOutput) 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 EventBridge.
	EventBridge *EventBridgeDestinationProperties `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"`
	// contains filtered or unexported fields
}

This stores the information that is required to query a particular connector.

func (DestinationConnectorProperties) GoString

GoString returns the string representation

func (*DestinationConnectorProperties) SetEventBridge

SetEventBridge sets the EventBridge field's value.

func (*DestinationConnectorProperties) SetRedshift

SetRedshift sets the Redshift field's value.

func (*DestinationConnectorProperties) SetS3

SetS3 sets the S3 field's value.

func (*DestinationConnectorProperties) SetSalesforce

SetSalesforce sets the Salesforce field's value.

func (*DestinationConnectorProperties) SetSnowflake

SetSnowflake sets the Snowflake field's value.

func (DestinationConnectorProperties) 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 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"`
	// 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

SetIsCreatable sets the IsCreatable field's value.

func (*DestinationFieldProperties) SetIsNullable

SetIsNullable sets the IsNullable field's value.

func (*DestinationFieldProperties) SetIsUpsertable

SetIsUpsertable sets the IsUpsertable field's value.

func (DestinationFieldProperties) 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

GoString returns the string representation

func (*DynatraceConnectorProfileCredentials) SetApiToken

SetApiToken sets the ApiToken field's value.

func (DynatraceConnectorProfileCredentials) String

String returns the string representation

func (*DynatraceConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*DynatraceConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (DynatraceConnectorProfileProperties) String

String returns the string representation

func (*DynatraceConnectorProfileProperties) Validate

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

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

GoString returns the string representation

func (*EventBridgeDestinationProperties) SetErrorHandlingConfig

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*EventBridgeDestinationProperties) SetObject

SetObject sets the Object field's value.

func (EventBridgeDestinationProperties) String

String returns the string representation

func (*EventBridgeDestinationProperties) Validate

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 {

	// 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) 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

GoString returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) SetAccessToken

SetAccessToken sets the AccessToken field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientId

SetClientId sets the ClientId field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientSecret

SetClientSecret sets the ClientSecret field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetOAuthRequest

SetOAuthRequest sets the OAuthRequest field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetRefreshToken

SetRefreshToken sets the RefreshToken field's value.

func (GoogleAnalyticsConnectorProfileCredentials) String

String returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (GoogleAnalyticsConnectorProfileProperties) 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

GoString returns the string representation

func (*GoogleAnalyticsSourceProperties) SetObject

SetObject sets the Object field's value.

func (GoogleAnalyticsSourceProperties) 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 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

GoString returns the string representation

func (*InforNexusConnectorProfileCredentials) SetAccessKeyId

SetAccessKeyId sets the AccessKeyId field's value.

func (*InforNexusConnectorProfileCredentials) SetDatakey

SetDatakey sets the Datakey field's value.

func (*InforNexusConnectorProfileCredentials) SetSecretAccessKey

SetSecretAccessKey sets the SecretAccessKey field's value.

func (*InforNexusConnectorProfileCredentials) SetUserId

SetUserId sets the UserId field's value.

func (InforNexusConnectorProfileCredentials) String

String returns the string representation

func (*InforNexusConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*InforNexusConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (InforNexusConnectorProfileProperties) String

String returns the string representation

func (*InforNexusConnectorProfileProperties) Validate

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

SetObject sets the Object field's value.

func (InforNexusSourceProperties) 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

SetConnectorType sets the ConnectorType field's value.

func (*ListConnectorEntitiesInput) SetEntitiesPath

SetEntitiesPath sets the EntitiesPath field's value.

func (ListConnectorEntitiesInput) 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

SetConnectorEntityMap sets the ConnectorEntityMap field's value.

func (ListConnectorEntitiesOutput) 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

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

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) 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

GoString returns the string representation

func (*MarketoConnectorProfileCredentials) SetAccessToken

SetAccessToken sets the AccessToken field's value.

func (*MarketoConnectorProfileCredentials) SetClientId

SetClientId sets the ClientId field's value.

func (*MarketoConnectorProfileCredentials) SetClientSecret

SetClientSecret sets the ClientSecret field's value.

func (*MarketoConnectorProfileCredentials) SetOAuthRequest

SetOAuthRequest sets the OAuthRequest field's value.

func (MarketoConnectorProfileCredentials) String

String returns the string representation

func (*MarketoConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*MarketoConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (MarketoConnectorProfileProperties) String

String returns the string representation

func (*MarketoConnectorProfileProperties) Validate

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

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 format of the prefix, and whether it applies to the file name,
	// file path, or both.
	PrefixFormat *string `locationName:"prefixFormat" type:"string" enum:"PrefixFormat"`

	// Determines the level of granularity that's included in the prefix.
	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

GoString returns the string representation

func (*RedshiftConnectorProfileCredentials) SetPassword

SetPassword sets the Password field's value.

func (*RedshiftConnectorProfileCredentials) SetUsername

SetUsername sets the Username field's value.

func (RedshiftConnectorProfileCredentials) String

String returns the string representation

func (*RedshiftConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*RedshiftConnectorProfileProperties) SetBucketName

SetBucketName sets the BucketName field's value.

func (*RedshiftConnectorProfileProperties) SetBucketPrefix

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftConnectorProfileProperties) SetDatabaseUrl

SetDatabaseUrl sets the DatabaseUrl field's value.

func (*RedshiftConnectorProfileProperties) SetRoleArn

SetRoleArn sets the RoleArn field's value.

func (RedshiftConnectorProfileProperties) String

String returns the string representation

func (*RedshiftConnectorProfileProperties) Validate

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

GoString returns the string representation

func (*RedshiftDestinationProperties) SetBucketPrefix

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftDestinationProperties) SetErrorHandlingConfig

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

SetObject sets the Object field's value.

func (RedshiftDestinationProperties) 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

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

SetBucketName sets the BucketName field's value.

func (*S3DestinationProperties) SetBucketPrefix

SetBucketPrefix sets the BucketPrefix field's value.

func (*S3DestinationProperties) SetS3OutputFormatConfig

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

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 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

GoString returns the string representation

func (*SalesforceConnectorProfileCredentials) SetAccessToken

SetAccessToken sets the AccessToken field's value.

func (*SalesforceConnectorProfileCredentials) SetOAuthRequest

SetOAuthRequest sets the OAuthRequest field's value.

func (*SalesforceConnectorProfileCredentials) SetRefreshToken

SetRefreshToken sets the RefreshToken field's value.

func (SalesforceConnectorProfileCredentials) String

String returns the string representation

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

GoString returns the string representation

func (*SalesforceConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (*SalesforceConnectorProfileProperties) SetIsSandboxEnvironment

SetIsSandboxEnvironment sets the IsSandboxEnvironment field's value.

func (SalesforceConnectorProfileProperties) 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 object specified in the Salesforce 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 Salesforce is being used as a destination.

func (SalesforceDestinationProperties) GoString

GoString returns the string representation

func (*SalesforceDestinationProperties) SetErrorHandlingConfig

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*SalesforceDestinationProperties) SetObject

SetObject sets the Object field's value.

func (SalesforceDestinationProperties) 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

SetObject sets the Object field's value.

func (SalesforceSourceProperties) 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 scheduled end time for a schedule-triggered flow.
	ScheduleEndTime *time.Time `locationName:"scheduleEndTime" type:"timestamp"`

	// The scheduling expression that determines when and how often the rule runs.
	//
	// ScheduleExpression is a required field
	ScheduleExpression *string `locationName:"scheduleExpression" type:"string" required:"true"`

	// 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.
	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

SetDataPullMode sets the DataPullMode field's value.

func (*ScheduledTriggerProperties) SetScheduleEndTime

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) SetScheduleStartTime

func (s *ScheduledTriggerProperties) SetScheduleStartTime(v time.Time) *ScheduledTriggerProperties

SetScheduleStartTime sets the ScheduleStartTime field's value.

func (*ScheduledTriggerProperties) SetTimezone

SetTimezone sets the Timezone field's value.

func (ScheduledTriggerProperties) 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

GoString returns the string representation

func (*ServiceNowConnectorProfileCredentials) SetPassword

SetPassword sets the Password field's value.

func (*ServiceNowConnectorProfileCredentials) SetUsername

SetUsername sets the Username field's value.

func (ServiceNowConnectorProfileCredentials) String

String returns the string representation

func (*ServiceNowConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*ServiceNowConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (ServiceNowConnectorProfileProperties) String

String returns the string representation

func (*ServiceNowConnectorProfileProperties) Validate

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

SetObject sets the Object field's value.

func (ServiceNowSourceProperties) 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

Code returns the exception type name.

func (*ServiceQuotaExceededException) Error

func (ServiceQuotaExceededException) GoString

GoString returns the string representation

func (*ServiceQuotaExceededException) Message

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

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

GoString returns the string representation

func (*SingularConnectorProfileCredentials) SetApiKey

SetApiKey sets the ApiKey field's value.

func (SingularConnectorProfileCredentials) String

String returns the string representation

func (*SingularConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (SingularConnectorProfileProperties) 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

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

GoString returns the string representation

func (*SlackConnectorProfileCredentials) SetAccessToken

SetAccessToken sets the AccessToken field's value.

func (*SlackConnectorProfileCredentials) SetClientId

SetClientId sets the ClientId field's value.

func (*SlackConnectorProfileCredentials) SetClientSecret

SetClientSecret sets the ClientSecret field's value.

func (*SlackConnectorProfileCredentials) SetOAuthRequest

SetOAuthRequest sets the OAuthRequest field's value.

func (SlackConnectorProfileCredentials) String

String returns the string representation

func (*SlackConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*SlackConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (SlackConnectorProfileProperties) 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

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

GoString returns the string representation

func (*SnowflakeConnectorProfileCredentials) SetPassword

SetPassword sets the Password field's value.

func (*SnowflakeConnectorProfileCredentials) SetUsername

SetUsername sets the Username field's value.

func (SnowflakeConnectorProfileCredentials) String

String returns the string representation

func (*SnowflakeConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*SnowflakeConnectorProfileProperties) SetAccountName

SetAccountName sets the AccountName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketName

SetBucketName sets the BucketName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketPrefix

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeConnectorProfileProperties) SetPrivateLinkServiceName

SetPrivateLinkServiceName sets the PrivateLinkServiceName field's value.

func (*SnowflakeConnectorProfileProperties) SetRegion

SetRegion sets the Region field's value.

func (*SnowflakeConnectorProfileProperties) SetStage

SetStage sets the Stage field's value.

func (*SnowflakeConnectorProfileProperties) SetWarehouse

SetWarehouse sets the Warehouse field's value.

func (SnowflakeConnectorProfileProperties) String

String returns the string representation

func (*SnowflakeConnectorProfileProperties) Validate

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

GoString returns the string representation

func (*SnowflakeDestinationProperties) SetBucketPrefix

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeDestinationProperties) SetErrorHandlingConfig

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

SetObject sets the Object field's value.

func (SnowflakeDestinationProperties) 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

SetAmplitude sets the Amplitude field's value.

func (*SourceConnectorProperties) SetDatadog

SetDatadog sets the Datadog field's value.

func (*SourceConnectorProperties) SetDynatrace

SetDynatrace sets the Dynatrace field's value.

func (*SourceConnectorProperties) SetGoogleAnalytics

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*SourceConnectorProperties) SetInforNexus

SetInforNexus sets the InforNexus field's value.

func (*SourceConnectorProperties) SetMarketo

SetMarketo sets the Marketo field's value.

func (*SourceConnectorProperties) SetS3

SetS3 sets the S3 field's value.

func (*SourceConnectorProperties) SetSalesforce

SetSalesforce sets the Salesforce field's value.

func (*SourceConnectorProperties) SetServiceNow

SetServiceNow sets the ServiceNow field's value.

func (*SourceConnectorProperties) SetSingular

SetSingular sets the Singular field's value.

func (*SourceConnectorProperties) SetSlack

SetSlack sets the Slack field's value.

func (*SourceConnectorProperties) SetTrendmicro

SetTrendmicro sets the Trendmicro field's value.

func (*SourceConnectorProperties) SetVeeva

SetVeeva sets the Veeva field's value.

func (*SourceConnectorProperties) SetZendesk

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"`

	// 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) 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 {

	// 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) 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

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

GoString returns the string representation

func (*TrendmicroConnectorProfileCredentials) SetApiSecretKey

SetApiSecretKey sets the ApiSecretKey field's value.

func (TrendmicroConnectorProfileCredentials) String

String returns the string representation

func (*TrendmicroConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (TrendmicroConnectorProfileProperties) 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

SetObject sets the Object field's value.

func (TrendmicroSourceProperties) 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

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

Code returns the exception type name.

func (*UnsupportedOperationException) Error

func (UnsupportedOperationException) GoString

GoString returns the string representation

func (*UnsupportedOperationException) Message

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

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

SetConnectionMode sets the ConnectionMode field's value.

func (*UpdateConnectorProfileInput) SetConnectorProfileConfig

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

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

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (UpdateConnectorProfileOutput) 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 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

GoString returns the string representation

func (*VeevaConnectorProfileCredentials) SetPassword

SetPassword sets the Password field's value.

func (*VeevaConnectorProfileCredentials) SetUsername

SetUsername sets the Username field's value.

func (VeevaConnectorProfileCredentials) String

String returns the string representation

func (*VeevaConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*VeevaConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (VeevaConnectorProfileProperties) 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

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

GoString returns the string representation

func (*ZendeskConnectorProfileCredentials) SetAccessToken

SetAccessToken sets the AccessToken field's value.

func (*ZendeskConnectorProfileCredentials) SetClientId

SetClientId sets the ClientId field's value.

func (*ZendeskConnectorProfileCredentials) SetClientSecret

SetClientSecret sets the ClientSecret field's value.

func (*ZendeskConnectorProfileCredentials) SetOAuthRequest

SetOAuthRequest sets the OAuthRequest field's value.

func (ZendeskConnectorProfileCredentials) String

String returns the string representation

func (*ZendeskConnectorProfileCredentials) Validate

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

GoString returns the string representation

func (*ZendeskConnectorProfileProperties) SetInstanceUrl

SetInstanceUrl sets the InstanceUrl field's value.

func (ZendeskConnectorProfileProperties) String

String returns the string representation

func (*ZendeskConnectorProfileProperties) Validate

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

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.

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