...
AWS SDK for Go API Reference
import "github.com/aws/aws-sdk-go/service/appflow"
Overview
Constants

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:

* Actions (https://docs.aws.amazon.com/appflow/1.0/APIReference/API_Operations.html):
An alphabetical list of all Amazon AppFlow API operations.

* Data types (https://docs.aws.amazon.com/appflow/1.0/APIReference/API_Types.html):
An alphabetical list of all Amazon AppFlow data types.

* Common parameters (https://docs.aws.amazon.com/appflow/1.0/APIReference/CommonParameters.html):
Parameters that all Query operations can use.

* Common errors (https://docs.aws.amazon.com/appflow/1.0/APIReference/CommonErrors.html):
Client and server errors that all operations can return.

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

The stub package, appflowiface, can be used to provide alternative implementations of service clients, such as mocking the client for testing.

Types ▾

type Appflow
func New(p client.ConfigProvider, cfgs ...*aws.Config) *Appflow
func (c *Appflow) CreateConnectorProfile(input *CreateConnectorProfileInput) (*CreateConnectorProfileOutput, error)
func (c *Appflow) CreateConnectorProfileRequest(input *CreateConnectorProfileInput) (req *request.Request, output *CreateConnectorProfileOutput)
func (c *Appflow) CreateConnectorProfileWithContext(ctx aws.Context, input *CreateConnectorProfileInput, opts ...request.Option) (*CreateConnectorProfileOutput, error)
func (c *Appflow) CreateFlow(input *CreateFlowInput) (*CreateFlowOutput, error)
func (c *Appflow) CreateFlowRequest(input *CreateFlowInput) (req *request.Request, output *CreateFlowOutput)
func (c *Appflow) CreateFlowWithContext(ctx aws.Context, input *CreateFlowInput, opts ...request.Option) (*CreateFlowOutput, error)
func (c *Appflow) DeleteConnectorProfile(input *DeleteConnectorProfileInput) (*DeleteConnectorProfileOutput, error)
func (c *Appflow) DeleteConnectorProfileRequest(input *DeleteConnectorProfileInput) (req *request.Request, output *DeleteConnectorProfileOutput)
func (c *Appflow) DeleteConnectorProfileWithContext(ctx aws.Context, input *DeleteConnectorProfileInput, opts ...request.Option) (*DeleteConnectorProfileOutput, error)
func (c *Appflow) DeleteFlow(input *DeleteFlowInput) (*DeleteFlowOutput, error)
func (c *Appflow) DeleteFlowRequest(input *DeleteFlowInput) (req *request.Request, output *DeleteFlowOutput)
func (c *Appflow) DeleteFlowWithContext(ctx aws.Context, input *DeleteFlowInput, opts ...request.Option) (*DeleteFlowOutput, error)
func (c *Appflow) DescribeConnectorEntity(input *DescribeConnectorEntityInput) (*DescribeConnectorEntityOutput, error)
func (c *Appflow) DescribeConnectorEntityRequest(input *DescribeConnectorEntityInput) (req *request.Request, output *DescribeConnectorEntityOutput)
func (c *Appflow) DescribeConnectorEntityWithContext(ctx aws.Context, input *DescribeConnectorEntityInput, opts ...request.Option) (*DescribeConnectorEntityOutput, error)
func (c *Appflow) DescribeConnectorProfiles(input *DescribeConnectorProfilesInput) (*DescribeConnectorProfilesOutput, error)
func (c *Appflow) DescribeConnectorProfilesPages(input *DescribeConnectorProfilesInput, fn func(*DescribeConnectorProfilesOutput, bool) bool) error
func (c *Appflow) DescribeConnectorProfilesPagesWithContext(ctx aws.Context, input *DescribeConnectorProfilesInput, fn func(*DescribeConnectorProfilesOutput, bool) bool, opts ...request.Option) error
func (c *Appflow) DescribeConnectorProfilesRequest(input *DescribeConnectorProfilesInput) (req *request.Request, output *DescribeConnectorProfilesOutput)
func (c *Appflow) DescribeConnectorProfilesWithContext(ctx aws.Context, input *DescribeConnectorProfilesInput, opts ...request.Option) (*DescribeConnectorProfilesOutput, error)
func (c *Appflow) DescribeConnectors(input *DescribeConnectorsInput) (*DescribeConnectorsOutput, error)
func (c *Appflow) DescribeConnectorsPages(input *DescribeConnectorsInput, fn func(*DescribeConnectorsOutput, bool) bool) error
func (c *Appflow) DescribeConnectorsPagesWithContext(ctx aws.Context, input *DescribeConnectorsInput, fn func(*DescribeConnectorsOutput, bool) bool, opts ...request.Option) error
func (c *Appflow) DescribeConnectorsRequest(input *DescribeConnectorsInput) (req *request.Request, output *DescribeConnectorsOutput)
func (c *Appflow) DescribeConnectorsWithContext(ctx aws.Context, input *DescribeConnectorsInput, opts ...request.Option) (*DescribeConnectorsOutput, error)
func (c *Appflow) DescribeFlow(input *DescribeFlowInput) (*DescribeFlowOutput, error)
func (c *Appflow) DescribeFlowExecutionRecords(input *DescribeFlowExecutionRecordsInput) (*DescribeFlowExecutionRecordsOutput, error)
func (c *Appflow) DescribeFlowExecutionRecordsPages(input *DescribeFlowExecutionRecordsInput, fn func(*DescribeFlowExecutionRecordsOutput, bool) bool) error
func (c *Appflow) DescribeFlowExecutionRecordsPagesWithContext(ctx aws.Context, input *DescribeFlowExecutionRecordsInput, fn func(*DescribeFlowExecutionRecordsOutput, bool) bool, opts ...request.Option) error
func (c *Appflow) DescribeFlowExecutionRecordsRequest(input *DescribeFlowExecutionRecordsInput) (req *request.Request, output *DescribeFlowExecutionRecordsOutput)
func (c *Appflow) DescribeFlowExecutionRecordsWithContext(ctx aws.Context, input *DescribeFlowExecutionRecordsInput, opts ...request.Option) (*DescribeFlowExecutionRecordsOutput, error)
func (c *Appflow) DescribeFlowRequest(input *DescribeFlowInput) (req *request.Request, output *DescribeFlowOutput)
func (c *Appflow) DescribeFlowWithContext(ctx aws.Context, input *DescribeFlowInput, opts ...request.Option) (*DescribeFlowOutput, error)
func (c *Appflow) ListConnectorEntities(input *ListConnectorEntitiesInput) (*ListConnectorEntitiesOutput, error)
func (c *Appflow) ListConnectorEntitiesRequest(input *ListConnectorEntitiesInput) (req *request.Request, output *ListConnectorEntitiesOutput)
func (c *Appflow) ListConnectorEntitiesWithContext(ctx aws.Context, input *ListConnectorEntitiesInput, opts ...request.Option) (*ListConnectorEntitiesOutput, error)
func (c *Appflow) ListFlows(input *ListFlowsInput) (*ListFlowsOutput, error)
func (c *Appflow) ListFlowsPages(input *ListFlowsInput, fn func(*ListFlowsOutput, bool) bool) error
func (c *Appflow) ListFlowsPagesWithContext(ctx aws.Context, input *ListFlowsInput, fn func(*ListFlowsOutput, bool) bool, opts ...request.Option) error
func (c *Appflow) ListFlowsRequest(input *ListFlowsInput) (req *request.Request, output *ListFlowsOutput)
func (c *Appflow) ListFlowsWithContext(ctx aws.Context, input *ListFlowsInput, opts ...request.Option) (*ListFlowsOutput, error)
func (c *Appflow) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
func (c *Appflow) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
func (c *Appflow) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
func (c *Appflow) StartFlow(input *StartFlowInput) (*StartFlowOutput, error)
func (c *Appflow) StartFlowRequest(input *StartFlowInput) (req *request.Request, output *StartFlowOutput)
func (c *Appflow) StartFlowWithContext(ctx aws.Context, input *StartFlowInput, opts ...request.Option) (*StartFlowOutput, error)
func (c *Appflow) StopFlow(input *StopFlowInput) (*StopFlowOutput, error)
func (c *Appflow) StopFlowRequest(input *StopFlowInput) (req *request.Request, output *StopFlowOutput)
func (c *Appflow) StopFlowWithContext(ctx aws.Context, input *StopFlowInput, opts ...request.Option) (*StopFlowOutput, error)
func (c *Appflow) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
func (c *Appflow) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
func (c *Appflow) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
func (c *Appflow) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
func (c *Appflow) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
func (c *Appflow) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
func (c *Appflow) UpdateConnectorProfile(input *UpdateConnectorProfileInput) (*UpdateConnectorProfileOutput, error)
func (c *Appflow) UpdateConnectorProfileRequest(input *UpdateConnectorProfileInput) (req *request.Request, output *UpdateConnectorProfileOutput)
func (c *Appflow) UpdateConnectorProfileWithContext(ctx aws.Context, input *UpdateConnectorProfileInput, opts ...request.Option) (*UpdateConnectorProfileOutput, error)
func (c *Appflow) UpdateFlow(input *UpdateFlowInput) (*UpdateFlowOutput, error)
func (c *Appflow) UpdateFlowRequest(input *UpdateFlowInput) (req *request.Request, output *UpdateFlowOutput)
func (c *Appflow) UpdateFlowWithContext(ctx aws.Context, input *UpdateFlowInput, opts ...request.Option) (*UpdateFlowOutput, error)
func AggregationType_Values() []string
func AmplitudeConnectorOperator_Values() []string
func ConnectionMode_Values() []string
func ConnectorType_Values() []string
func DataPullMode_Values() []string
func DatadogConnectorOperator_Values() []string
func DynatraceConnectorOperator_Values() []string
func ExecutionStatus_Values() []string
func FileType_Values() []string
func FlowStatus_Values() []string
func GoogleAnalyticsConnectorOperator_Values() []string
func InforNexusConnectorOperator_Values() []string
func MarketoConnectorOperator_Values() []string
func OperatorPropertiesKeys_Values() []string
func Operator_Values() []string
func PrefixFormat_Values() []string
func PrefixType_Values() []string
func S3ConnectorOperator_Values() []string
func SalesforceConnectorOperator_Values() []string
func ScheduleFrequencyType_Values() []string
func ServiceNowConnectorOperator_Values() []string
func SingularConnectorOperator_Values() []string
func SlackConnectorOperator_Values() []string
func TaskType_Values() []string
func TrendmicroConnectorOperator_Values() []string
func TriggerType_Values() []string
func VeevaConnectorOperator_Values() []string
func WriteOperationType_Values() []string
func ZendeskConnectorOperator_Values() []string
type AggregationConfig
type AmplitudeConnectorProfileCredentials
type AmplitudeConnectorProfileProperties
type AmplitudeMetadata
type AmplitudeSourceProperties
type ConflictException
type ConnectorAuthenticationException
type ConnectorConfiguration
type ConnectorEntity
type ConnectorEntityField
type ConnectorMetadata
type ConnectorOAuthRequest
type ConnectorOperator
type ConnectorProfile
type ConnectorProfileConfig
type ConnectorProfileCredentials
type ConnectorProfileProperties
type ConnectorServerException
type CreateConnectorProfileInput
type CreateConnectorProfileOutput
type CreateFlowInput
type CreateFlowOutput
type DatadogConnectorProfileCredentials
type DatadogConnectorProfileProperties
type DatadogMetadata
type DatadogSourceProperties
type DeleteConnectorProfileInput
type DeleteConnectorProfileOutput
type DeleteFlowInput
type DeleteFlowOutput
type DescribeConnectorEntityInput
type DescribeConnectorEntityOutput
type DescribeConnectorProfilesInput
type DescribeConnectorProfilesOutput
type DescribeConnectorsInput
type DescribeConnectorsOutput
type DescribeFlowExecutionRecordsInput
type DescribeFlowExecutionRecordsOutput
type DescribeFlowInput
type DescribeFlowOutput
type DestinationConnectorProperties
type DestinationFieldProperties
type DestinationFlowConfig
type DynatraceConnectorProfileCredentials
type DynatraceConnectorProfileProperties
type DynatraceMetadata
type DynatraceSourceProperties
type ErrorHandlingConfig
type ErrorInfo
type EventBridgeDestinationProperties
type EventBridgeMetadata
type ExecutionDetails
type ExecutionRecord
type ExecutionResult
type FieldTypeDetails
type FlowDefinition
type GoogleAnalyticsConnectorProfileCredentials
type GoogleAnalyticsConnectorProfileProperties
type GoogleAnalyticsMetadata
type GoogleAnalyticsSourceProperties
type IncrementalPullConfig
type InforNexusConnectorProfileCredentials
type InforNexusConnectorProfileProperties
type InforNexusMetadata
type InforNexusSourceProperties
type InternalServerException
type ListConnectorEntitiesInput
type ListConnectorEntitiesOutput
type ListFlowsInput
type ListFlowsOutput
type ListTagsForResourceInput
type ListTagsForResourceOutput
type MarketoConnectorProfileCredentials
type MarketoConnectorProfileProperties
type MarketoMetadata
type MarketoSourceProperties
type PrefixConfig
type RedshiftConnectorProfileCredentials
type RedshiftConnectorProfileProperties
type RedshiftDestinationProperties
type RedshiftMetadata
type ResourceNotFoundException
type S3DestinationProperties
type S3Metadata
type S3OutputFormatConfig
type S3SourceProperties
type SalesforceConnectorProfileCredentials
type SalesforceConnectorProfileProperties
type SalesforceDestinationProperties
type SalesforceMetadata
type SalesforceSourceProperties
type ScheduledTriggerProperties
type ServiceNowConnectorProfileCredentials
type ServiceNowConnectorProfileProperties
type ServiceNowMetadata
type ServiceNowSourceProperties
type ServiceQuotaExceededException
type SingularConnectorProfileCredentials
type SingularConnectorProfileProperties
type SingularMetadata
type SingularSourceProperties
type SlackConnectorProfileCredentials
type SlackConnectorProfileProperties
type SlackMetadata
type SlackSourceProperties
type SnowflakeConnectorProfileCredentials
type SnowflakeConnectorProfileProperties
type SnowflakeDestinationProperties
type SnowflakeMetadata
type SourceConnectorProperties
type SourceFieldProperties
type SourceFlowConfig
type StartFlowInput
type StartFlowOutput
type StopFlowInput
type StopFlowOutput
type SupportedFieldTypeDetails
type TagResourceInput
type TagResourceOutput
type Task
type TrendmicroConnectorProfileCredentials
type TrendmicroConnectorProfileProperties
type TrendmicroMetadata
type TrendmicroSourceProperties
type TriggerConfig
type TriggerProperties
type UnsupportedOperationException
type UntagResourceInput
type UntagResourceOutput
type UpdateConnectorProfileInput
type UpdateConnectorProfileOutput
type UpdateFlowInput
type UpdateFlowOutput
type UpsolverDestinationProperties
type UpsolverMetadata
type UpsolverS3OutputFormatConfig
type ValidationException
type VeevaConnectorProfileCredentials
type VeevaConnectorProfileProperties
type VeevaMetadata
type VeevaSourceProperties
type ZendeskConnectorProfileCredentials
type ZendeskConnectorProfileProperties
type ZendeskMetadata
type ZendeskSourceProperties

Constants ▾

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

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

    // ConnectionModePrivate is a ConnectionMode enum value
    ConnectionModePrivate = "Private"
)
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"

    // ConnectorTypeUpsolver is a ConnectorType enum value
    ConnectorTypeUpsolver = "Upsolver"
)
const (
    // DataPullModeIncremental is a DataPullMode enum value
    DataPullModeIncremental = "Incremental"

    // DataPullModeComplete is a DataPullMode enum value
    DataPullModeComplete = "Complete"
)
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"
)
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"
)
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"
)
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"
)
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"
)
const (
    // GoogleAnalyticsConnectorOperatorProjection is a GoogleAnalyticsConnectorOperator enum value
    GoogleAnalyticsConnectorOperatorProjection = "PROJECTION"

    // GoogleAnalyticsConnectorOperatorBetween is a GoogleAnalyticsConnectorOperator enum value
    GoogleAnalyticsConnectorOperatorBetween = "BETWEEN"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
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"
)
const (
    // WriteOperationTypeInsert is a WriteOperationType enum value
    WriteOperationTypeInsert = "INSERT"

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

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

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

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

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

func AggregationType_Values

func AggregationType_Values() []string

AggregationType_Values returns all elements of the AggregationType enum

func AmplitudeConnectorOperator_Values

func AmplitudeConnectorOperator_Values() []string

AmplitudeConnectorOperator_Values returns all elements of the AmplitudeConnectorOperator enum

func ConnectionMode_Values

func ConnectionMode_Values() []string

ConnectionMode_Values returns all elements of the ConnectionMode enum

func ConnectorType_Values

func ConnectorType_Values() []string

ConnectorType_Values returns all elements of the ConnectorType enum

func DataPullMode_Values

func DataPullMode_Values() []string

DataPullMode_Values returns all elements of the DataPullMode enum

func DatadogConnectorOperator_Values

func DatadogConnectorOperator_Values() []string

DatadogConnectorOperator_Values returns all elements of the DatadogConnectorOperator enum

func DynatraceConnectorOperator_Values

func DynatraceConnectorOperator_Values() []string

DynatraceConnectorOperator_Values returns all elements of the DynatraceConnectorOperator enum

func ExecutionStatus_Values

func ExecutionStatus_Values() []string

ExecutionStatus_Values returns all elements of the ExecutionStatus enum

func FileType_Values

func FileType_Values() []string

FileType_Values returns all elements of the FileType enum

func FlowStatus_Values

func FlowStatus_Values() []string

FlowStatus_Values returns all elements of the FlowStatus enum

func GoogleAnalyticsConnectorOperator_Values

func GoogleAnalyticsConnectorOperator_Values() []string

GoogleAnalyticsConnectorOperator_Values returns all elements of the GoogleAnalyticsConnectorOperator enum

func InforNexusConnectorOperator_Values

func InforNexusConnectorOperator_Values() []string

InforNexusConnectorOperator_Values returns all elements of the InforNexusConnectorOperator enum

func MarketoConnectorOperator_Values

func MarketoConnectorOperator_Values() []string

MarketoConnectorOperator_Values returns all elements of the MarketoConnectorOperator enum

func OperatorPropertiesKeys_Values

func OperatorPropertiesKeys_Values() []string

OperatorPropertiesKeys_Values returns all elements of the OperatorPropertiesKeys enum

func Operator_Values

func Operator_Values() []string

Operator_Values returns all elements of the Operator enum

func PrefixFormat_Values

func PrefixFormat_Values() []string

PrefixFormat_Values returns all elements of the PrefixFormat enum

func PrefixType_Values

func PrefixType_Values() []string

PrefixType_Values returns all elements of the PrefixType enum

func S3ConnectorOperator_Values

func S3ConnectorOperator_Values() []string

S3ConnectorOperator_Values returns all elements of the S3ConnectorOperator enum

func SalesforceConnectorOperator_Values

func SalesforceConnectorOperator_Values() []string

SalesforceConnectorOperator_Values returns all elements of the SalesforceConnectorOperator enum

func ScheduleFrequencyType_Values

func ScheduleFrequencyType_Values() []string

ScheduleFrequencyType_Values returns all elements of the ScheduleFrequencyType enum

func ServiceNowConnectorOperator_Values

func ServiceNowConnectorOperator_Values() []string

ServiceNowConnectorOperator_Values returns all elements of the ServiceNowConnectorOperator enum

func SingularConnectorOperator_Values

func SingularConnectorOperator_Values() []string

SingularConnectorOperator_Values returns all elements of the SingularConnectorOperator enum

func SlackConnectorOperator_Values

func SlackConnectorOperator_Values() []string

SlackConnectorOperator_Values returns all elements of the SlackConnectorOperator enum

func TaskType_Values

func TaskType_Values() []string

TaskType_Values returns all elements of the TaskType enum

func TrendmicroConnectorOperator_Values

func TrendmicroConnectorOperator_Values() []string

TrendmicroConnectorOperator_Values returns all elements of the TrendmicroConnectorOperator enum

func TriggerType_Values

func TriggerType_Values() []string

TriggerType_Values returns all elements of the TriggerType enum

func VeevaConnectorOperator_Values

func VeevaConnectorOperator_Values() []string

VeevaConnectorOperator_Values returns all elements of the VeevaConnectorOperator enum

func WriteOperationType_Values

func WriteOperationType_Values() []string

WriteOperationType_Values returns all elements of the WriteOperationType enum

func ZendeskConnectorOperator_Values

func ZendeskConnectorOperator_Values() []string

ZendeskConnectorOperator_Values returns all elements of the ZendeskConnectorOperator enum

type AggregationConfig

type AggregationConfig struct {

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

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

func (AggregationConfig) GoString

func (s AggregationConfig) GoString() string

GoString returns the string representation

func (*AggregationConfig) SetAggregationType

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

SetAggregationType sets the AggregationType field's value.

func (AggregationConfig) String

func (s AggregationConfig) String() string

String returns the string representation

type AmplitudeConnectorProfileCredentials

type AmplitudeConnectorProfileCredentials struct {

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

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

The connector-specific credentials required when using Amplitude.

func (AmplitudeConnectorProfileCredentials) GoString

func (s AmplitudeConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*AmplitudeConnectorProfileCredentials) SetApiKey

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

SetApiKey sets the ApiKey field's value.

func (*AmplitudeConnectorProfileCredentials) SetSecretKey

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

SetSecretKey sets the SecretKey field's value.

func (AmplitudeConnectorProfileCredentials) String

func (s AmplitudeConnectorProfileCredentials) String() string

String returns the string representation

func (*AmplitudeConnectorProfileCredentials) Validate

func (s *AmplitudeConnectorProfileCredentials) Validate() error

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

type AmplitudeConnectorProfileProperties

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

The connector-specific profile properties required when using Amplitude.

func (AmplitudeConnectorProfileProperties) GoString

func (s AmplitudeConnectorProfileProperties) GoString() string

GoString returns the string representation

func (AmplitudeConnectorProfileProperties) String

func (s AmplitudeConnectorProfileProperties) String() string

String returns the string representation

type AmplitudeMetadata

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

The connector metadata specific to Amplitude.

func (AmplitudeMetadata) GoString

func (s AmplitudeMetadata) GoString() string

GoString returns the string representation

func (AmplitudeMetadata) String

func (s AmplitudeMetadata) String() string

String returns the string representation

type AmplitudeSourceProperties

type AmplitudeSourceProperties struct {

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

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

func (AmplitudeSourceProperties) GoString

func (s AmplitudeSourceProperties) GoString() string

GoString returns the string representation

func (*AmplitudeSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (AmplitudeSourceProperties) String

func (s AmplitudeSourceProperties) String() string

String returns the string representation

func (*AmplitudeSourceProperties) Validate

func (s *AmplitudeSourceProperties) Validate() error

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

type Appflow

type Appflow struct {
    *client.Client
}

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

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

func New

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

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

Example:

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

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

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

func (*Appflow) CreateConnectorProfile

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

CreateConnectorProfile API operation for Amazon Appflow.

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

func (*Appflow) CreateConnectorProfileRequest

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

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

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

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

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

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

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

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

func (*Appflow) CreateConnectorProfileWithContext

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

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

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

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

func (*Appflow) CreateFlow

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

CreateFlow API operation for Amazon Appflow.

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

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

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

func (*Appflow) CreateFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) CreateFlowWithContext

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

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

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

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

func (*Appflow) DeleteConnectorProfile

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

DeleteConnectorProfile API operation for Amazon Appflow.

Enables you to delete an existing connector profile.

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

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

Returned Error Types:

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

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

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

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

func (*Appflow) DeleteConnectorProfileRequest

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

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

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

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

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

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

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

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

func (*Appflow) DeleteConnectorProfileWithContext

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

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

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

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

func (*Appflow) DeleteFlow

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

DeleteFlow API operation for Amazon Appflow.

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

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

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

Returned Error Types:

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

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

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

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

func (*Appflow) DeleteFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) DeleteFlowWithContext

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

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

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

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

func (*Appflow) DescribeConnectorEntity

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

DescribeConnectorEntity API operation for Amazon Appflow.

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

func (*Appflow) DescribeConnectorEntityRequest

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

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

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

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

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

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

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

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

func (*Appflow) DescribeConnectorEntityWithContext

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

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

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

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

func (*Appflow) DescribeConnectorProfiles

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

DescribeConnectorProfiles API operation for Amazon Appflow.

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

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) DescribeConnectorProfilesPages

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

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

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

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

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

func (*Appflow) DescribeConnectorProfilesPagesWithContext

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

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

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

func (*Appflow) DescribeConnectorProfilesRequest

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

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

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

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

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

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

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

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

func (*Appflow) DescribeConnectorProfilesWithContext

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

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

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

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

func (*Appflow) DescribeConnectors

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

DescribeConnectors API operation for Amazon Appflow.

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) DescribeConnectorsPages

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

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

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

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

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

func (*Appflow) DescribeConnectorsPagesWithContext

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

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

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

func (*Appflow) DescribeConnectorsRequest

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

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

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

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

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

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

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

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

func (*Appflow) DescribeConnectorsWithContext

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

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

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

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

func (*Appflow) DescribeFlow

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

DescribeFlow API operation for Amazon Appflow.

Provides a description of the specified flow.

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

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

Returned Error Types:

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

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

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

func (*Appflow) DescribeFlowExecutionRecords

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

DescribeFlowExecutionRecords API operation for Amazon Appflow.

Fetches the execution history of the flow.

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

func (*Appflow) DescribeFlowExecutionRecordsPages

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

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

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

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

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

func (*Appflow) DescribeFlowExecutionRecordsPagesWithContext

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

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

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

func (*Appflow) DescribeFlowExecutionRecordsRequest

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

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

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

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

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

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

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

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

func (*Appflow) DescribeFlowExecutionRecordsWithContext

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

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

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

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

func (*Appflow) DescribeFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) DescribeFlowWithContext

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

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

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

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

func (*Appflow) ListConnectorEntities

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

ListConnectorEntities API operation for Amazon Appflow.

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

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

func (*Appflow) ListConnectorEntitiesRequest

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

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

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

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

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

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

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

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

func (*Appflow) ListConnectorEntitiesWithContext

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

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

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

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

func (*Appflow) ListFlows

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

ListFlows API operation for Amazon Appflow.

Lists all of the flows associated with your account.

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) ListFlowsPages

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

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

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

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

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

func (*Appflow) ListFlowsPagesWithContext

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

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

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

func (*Appflow) ListFlowsRequest

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

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

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

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

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

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

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

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

func (*Appflow) ListFlowsWithContext

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

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

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

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

func (*Appflow) ListTagsForResource

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

ListTagsForResource API operation for Amazon Appflow.

Retrieves the tags that are associated with a specified flow.

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

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

Returned Error Types:

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

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) ListTagsForResourceRequest

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

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

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

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

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

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

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

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

func (*Appflow) ListTagsForResourceWithContext

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

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

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

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

func (*Appflow) StartFlow

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

StartFlow API operation for Amazon Appflow.

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

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

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

Returned Error Types:

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

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

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

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

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

func (*Appflow) StartFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) StartFlowWithContext

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

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

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

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

func (*Appflow) StopFlow

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

StopFlow API operation for Amazon Appflow.

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

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

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

Returned Error Types:

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

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

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

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

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

func (*Appflow) StopFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) StopFlowWithContext

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

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

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

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

func (*Appflow) TagResource

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

TagResource API operation for Amazon Appflow.

Applies a tag to the specified flow.

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

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

Returned Error Types:

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

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) TagResourceRequest

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

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

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

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

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

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

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

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

func (*Appflow) TagResourceWithContext

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

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

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

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

func (*Appflow) UntagResource

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

UntagResource API operation for Amazon Appflow.

Removes a tag from the specified flow.

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

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

Returned Error Types:

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

* ValidationException
The request has invalid or missing parameters.

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

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

func (*Appflow) UntagResourceRequest

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

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

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

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

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

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

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

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

func (*Appflow) UntagResourceWithContext

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

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

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

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

func (*Appflow) UpdateConnectorProfile

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

UpdateConnectorProfile API operation for Amazon Appflow.

Updates a given connector profile associated with your account.

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

func (*Appflow) UpdateConnectorProfileRequest

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

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

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

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

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

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

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

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

func (*Appflow) UpdateConnectorProfileWithContext

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

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

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

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

func (*Appflow) UpdateFlow

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

UpdateFlow API operation for Amazon Appflow.

Updates an existing flow.

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

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

Returned Error Types:

* ValidationException
The request has invalid or missing parameters.

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

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

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

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

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

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

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

func (*Appflow) UpdateFlowRequest

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

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

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

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

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

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

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

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

func (*Appflow) UpdateFlowWithContext

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

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

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

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

type ConflictException

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

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

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

func (*ConflictException) Code

func (s *ConflictException) Code() string

Code returns the exception type name.

func (*ConflictException) Error

func (s *ConflictException) Error() string

func (ConflictException) GoString

func (s ConflictException) GoString() string

GoString returns the string representation

func (*ConflictException) Message

func (s *ConflictException) Message() string

Message returns the exception's message.

func (*ConflictException) OrigErr

func (s *ConflictException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConflictException) RequestID

func (s *ConflictException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConflictException) StatusCode

func (s *ConflictException) StatusCode() int

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

func (ConflictException) String

func (s ConflictException) String() string

String returns the string representation

type ConnectorAuthenticationException

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

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

An error occurred when authenticating with the connector endpoint.

func (*ConnectorAuthenticationException) Code

func (s *ConnectorAuthenticationException) Code() string

Code returns the exception type name.

func (*ConnectorAuthenticationException) Error

func (s *ConnectorAuthenticationException) Error() string

func (ConnectorAuthenticationException) GoString

func (s ConnectorAuthenticationException) GoString() string

GoString returns the string representation

func (*ConnectorAuthenticationException) Message

func (s *ConnectorAuthenticationException) Message() string

Message returns the exception's message.

func (*ConnectorAuthenticationException) OrigErr

func (s *ConnectorAuthenticationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConnectorAuthenticationException) RequestID

func (s *ConnectorAuthenticationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConnectorAuthenticationException) StatusCode

func (s *ConnectorAuthenticationException) StatusCode() int

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

func (ConnectorAuthenticationException) String

func (s ConnectorAuthenticationException) String() string

String returns the string representation

type ConnectorConfiguration

type ConnectorConfiguration struct {

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

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

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

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

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

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

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

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

The configuration settings related to a given connector.

func (ConnectorConfiguration) GoString

func (s ConnectorConfiguration) GoString() string

GoString returns the string representation

func (*ConnectorConfiguration) SetCanUseAsDestination

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

SetCanUseAsDestination sets the CanUseAsDestination field's value.

func (*ConnectorConfiguration) SetCanUseAsSource

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

SetCanUseAsSource sets the CanUseAsSource field's value.

func (*ConnectorConfiguration) SetConnectorMetadata

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

SetConnectorMetadata sets the ConnectorMetadata field's value.

func (*ConnectorConfiguration) SetIsPrivateLinkEnabled

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

SetIsPrivateLinkEnabled sets the IsPrivateLinkEnabled field's value.

func (*ConnectorConfiguration) SetIsPrivateLinkEndpointUrlRequired

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

SetIsPrivateLinkEndpointUrlRequired sets the IsPrivateLinkEndpointUrlRequired field's value.

func (*ConnectorConfiguration) SetSupportedDestinationConnectors

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

SetSupportedDestinationConnectors sets the SupportedDestinationConnectors field's value.

func (*ConnectorConfiguration) SetSupportedSchedulingFrequencies

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

SetSupportedSchedulingFrequencies sets the SupportedSchedulingFrequencies field's value.

func (*ConnectorConfiguration) SetSupportedTriggerTypes

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

SetSupportedTriggerTypes sets the SupportedTriggerTypes field's value.

func (ConnectorConfiguration) String

func (s ConnectorConfiguration) String() string

String returns the string representation

type ConnectorEntity

type ConnectorEntity struct {

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

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

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

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

func (ConnectorEntity) GoString

func (s ConnectorEntity) GoString() string

GoString returns the string representation

func (*ConnectorEntity) SetHasNestedEntities

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

SetHasNestedEntities sets the HasNestedEntities field's value.

func (*ConnectorEntity) SetLabel

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

SetLabel sets the Label field's value.

func (*ConnectorEntity) SetName

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

SetName sets the Name field's value.

func (ConnectorEntity) String

func (s ConnectorEntity) String() string

String returns the string representation

type ConnectorEntityField

type ConnectorEntityField struct {

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

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

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

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

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

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

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

func (ConnectorEntityField) GoString

func (s ConnectorEntityField) GoString() string

GoString returns the string representation

func (*ConnectorEntityField) SetDescription

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

SetDescription sets the Description field's value.

func (*ConnectorEntityField) SetDestinationProperties

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

SetDestinationProperties sets the DestinationProperties field's value.

func (*ConnectorEntityField) SetIdentifier

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

SetIdentifier sets the Identifier field's value.

func (*ConnectorEntityField) SetLabel

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

SetLabel sets the Label field's value.

func (*ConnectorEntityField) SetSourceProperties

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

SetSourceProperties sets the SourceProperties field's value.

func (*ConnectorEntityField) SetSupportedFieldTypeDetails

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

SetSupportedFieldTypeDetails sets the SupportedFieldTypeDetails field's value.

func (ConnectorEntityField) String

func (s ConnectorEntityField) String() string

String returns the string representation

type ConnectorMetadata

type ConnectorMetadata struct {

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

    // The connector metadata specific to 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 Upsolver.
    Upsolver *UpsolverMetadata `type:"structure"`

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

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

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

func (ConnectorMetadata) GoString

func (s ConnectorMetadata) GoString() string

GoString returns the string representation

func (*ConnectorMetadata) SetAmplitude

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

SetAmplitude sets the Amplitude field's value.

func (*ConnectorMetadata) SetDatadog

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

SetDatadog sets the Datadog field's value.

func (*ConnectorMetadata) SetDynatrace

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

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorMetadata) SetEventBridge

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

SetEventBridge sets the EventBridge field's value.

func (*ConnectorMetadata) SetGoogleAnalytics

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

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorMetadata) SetInforNexus

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

SetInforNexus sets the InforNexus field's value.

func (*ConnectorMetadata) SetMarketo

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

SetMarketo sets the Marketo field's value.

func (*ConnectorMetadata) SetRedshift

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

SetRedshift sets the Redshift field's value.

func (*ConnectorMetadata) SetS3

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

SetS3 sets the S3 field's value.

func (*ConnectorMetadata) SetSalesforce

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

SetSalesforce sets the Salesforce field's value.

func (*ConnectorMetadata) SetServiceNow

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

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorMetadata) SetSingular

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

SetSingular sets the Singular field's value.

func (*ConnectorMetadata) SetSlack

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

SetSlack sets the Slack field's value.

func (*ConnectorMetadata) SetSnowflake

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

SetSnowflake sets the Snowflake field's value.

func (*ConnectorMetadata) SetTrendmicro

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

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorMetadata) SetUpsolver

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

SetUpsolver sets the Upsolver field's value.

func (*ConnectorMetadata) SetVeeva

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

SetVeeva sets the Veeva field's value.

func (*ConnectorMetadata) SetZendesk

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

SetZendesk sets the Zendesk field's value.

func (ConnectorMetadata) String

func (s ConnectorMetadata) String() string

String returns the string representation

type ConnectorOAuthRequest

type ConnectorOAuthRequest struct {

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

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

Used by select connectors for which the OAuth workflow is supported, such as Salesforce, Google Analytics, Marketo, Zendesk, and Slack.

func (ConnectorOAuthRequest) GoString

func (s ConnectorOAuthRequest) GoString() string

GoString returns the string representation

func (*ConnectorOAuthRequest) SetAuthCode

func (s *ConnectorOAuthRequest) SetAuthCode(v string) *ConnectorOAuthRequest

SetAuthCode sets the AuthCode field's value.

func (*ConnectorOAuthRequest) SetRedirectUri

func (s *ConnectorOAuthRequest) SetRedirectUri(v string) *ConnectorOAuthRequest

SetRedirectUri sets the RedirectUri field's value.

func (ConnectorOAuthRequest) String

func (s ConnectorOAuthRequest) String() string

String returns the string representation

type ConnectorOperator

type ConnectorOperator struct {

    // The operation to be performed on the provided Amplitude source fields.
    Amplitude *string `type:"string" enum:"AmplitudeConnectorOperator"`

    // The operation to be performed on the provided Datadog source fields.
    Datadog *string `type:"string" enum:"DatadogConnectorOperator"`

    // The operation to be performed on the provided Dynatrace source fields.
    Dynatrace *string `type:"string" enum:"DynatraceConnectorOperator"`

    // The operation to be performed on the provided Google Analytics source fields.
    GoogleAnalytics *string `type:"string" enum:"GoogleAnalyticsConnectorOperator"`

    // The operation to be performed on the provided Infor Nexus source fields.
    InforNexus *string `type:"string" enum:"InforNexusConnectorOperator"`

    // The operation to be performed on the provided Marketo source fields.
    Marketo *string `type:"string" enum:"MarketoConnectorOperator"`

    // The operation to be performed on the provided Amazon S3 source fields.
    S3 *string `type:"string" enum:"S3ConnectorOperator"`

    // The operation to be performed on the provided Salesforce source fields.
    Salesforce *string `type:"string" enum:"SalesforceConnectorOperator"`

    // The operation to be performed on the provided ServiceNow source fields.
    ServiceNow *string `type:"string" enum:"ServiceNowConnectorOperator"`

    // The operation to be performed on the provided Singular source fields.
    Singular *string `type:"string" enum:"SingularConnectorOperator"`

    // The operation to be performed on the provided Slack source fields.
    Slack *string `type:"string" enum:"SlackConnectorOperator"`

    // The operation to be performed on the provided Trend Micro source fields.
    Trendmicro *string `type:"string" enum:"TrendmicroConnectorOperator"`

    // The operation to be performed on the provided Veeva source fields.
    Veeva *string `type:"string" enum:"VeevaConnectorOperator"`

    // The operation to be performed on the provided Zendesk source fields.
    Zendesk *string `type:"string" enum:"ZendeskConnectorOperator"`
    // contains filtered or unexported fields
}

The operation to be performed on the provided source fields.

func (ConnectorOperator) GoString

func (s ConnectorOperator) GoString() string

GoString returns the string representation

func (*ConnectorOperator) SetAmplitude

func (s *ConnectorOperator) SetAmplitude(v string) *ConnectorOperator

SetAmplitude sets the Amplitude field's value.

func (*ConnectorOperator) SetDatadog

func (s *ConnectorOperator) SetDatadog(v string) *ConnectorOperator

SetDatadog sets the Datadog field's value.

func (*ConnectorOperator) SetDynatrace

func (s *ConnectorOperator) SetDynatrace(v string) *ConnectorOperator

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorOperator) SetGoogleAnalytics

func (s *ConnectorOperator) SetGoogleAnalytics(v string) *ConnectorOperator

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorOperator) SetInforNexus

func (s *ConnectorOperator) SetInforNexus(v string) *ConnectorOperator

SetInforNexus sets the InforNexus field's value.

func (*ConnectorOperator) SetMarketo

func (s *ConnectorOperator) SetMarketo(v string) *ConnectorOperator

SetMarketo sets the Marketo field's value.

func (*ConnectorOperator) SetS3

func (s *ConnectorOperator) SetS3(v string) *ConnectorOperator

SetS3 sets the S3 field's value.

func (*ConnectorOperator) SetSalesforce

func (s *ConnectorOperator) SetSalesforce(v string) *ConnectorOperator

SetSalesforce sets the Salesforce field's value.

func (*ConnectorOperator) SetServiceNow

func (s *ConnectorOperator) SetServiceNow(v string) *ConnectorOperator

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorOperator) SetSingular

func (s *ConnectorOperator) SetSingular(v string) *ConnectorOperator

SetSingular sets the Singular field's value.

func (*ConnectorOperator) SetSlack

func (s *ConnectorOperator) SetSlack(v string) *ConnectorOperator

SetSlack sets the Slack field's value.

func (*ConnectorOperator) SetTrendmicro

func (s *ConnectorOperator) SetTrendmicro(v string) *ConnectorOperator

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorOperator) SetVeeva

func (s *ConnectorOperator) SetVeeva(v string) *ConnectorOperator

SetVeeva sets the Veeva field's value.

func (*ConnectorOperator) SetZendesk

func (s *ConnectorOperator) SetZendesk(v string) *ConnectorOperator

SetZendesk sets the Zendesk field's value.

func (ConnectorOperator) String

func (s ConnectorOperator) String() string

String returns the string representation

type ConnectorProfile

type ConnectorProfile struct {

    // Indicates the connection mode and if it is public or private.
    ConnectionMode *string `locationName:"connectionMode" type:"string" enum:"ConnectionMode"`

    // The Amazon Resource Name (ARN) of the connector profile.
    ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in the AWS account.
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

    // The connector-specific properties of the profile configuration.
    ConnectorProfileProperties *ConnectorProfileProperties `locationName:"connectorProfileProperties" type:"structure"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

    // Specifies when the connector profile was created.
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp"`

    // The Amazon Resource Name (ARN) of the connector profile credentials.
    CredentialsArn *string `locationName:"credentialsArn" type:"string"`

    // Specifies when the connector profile was last updated.
    LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`
    // contains filtered or unexported fields
}

Describes an instance of a connector. This includes the provided name, credentials ARN, connection-mode, and so on. To keep the API intuitive and extensible, the fields that are common to all types of connector profiles are explicitly specified at the top level. The rest of the connector-specific properties are available via the connectorProfileProperties field.

func (ConnectorProfile) GoString

func (s ConnectorProfile) GoString() string

GoString returns the string representation

func (*ConnectorProfile) SetConnectionMode

func (s *ConnectorProfile) SetConnectionMode(v string) *ConnectorProfile

SetConnectionMode sets the ConnectionMode field's value.

func (*ConnectorProfile) SetConnectorProfileArn

func (s *ConnectorProfile) SetConnectorProfileArn(v string) *ConnectorProfile

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (*ConnectorProfile) SetConnectorProfileName

func (s *ConnectorProfile) SetConnectorProfileName(v string) *ConnectorProfile

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*ConnectorProfile) SetConnectorProfileProperties

func (s *ConnectorProfile) SetConnectorProfileProperties(v *ConnectorProfileProperties) *ConnectorProfile

SetConnectorProfileProperties sets the ConnectorProfileProperties field's value.

func (*ConnectorProfile) SetConnectorType

func (s *ConnectorProfile) SetConnectorType(v string) *ConnectorProfile

SetConnectorType sets the ConnectorType field's value.

func (*ConnectorProfile) SetCreatedAt

func (s *ConnectorProfile) SetCreatedAt(v time.Time) *ConnectorProfile

SetCreatedAt sets the CreatedAt field's value.

func (*ConnectorProfile) SetCredentialsArn

func (s *ConnectorProfile) SetCredentialsArn(v string) *ConnectorProfile

SetCredentialsArn sets the CredentialsArn field's value.

func (*ConnectorProfile) SetLastUpdatedAt

func (s *ConnectorProfile) SetLastUpdatedAt(v time.Time) *ConnectorProfile

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (ConnectorProfile) String

func (s ConnectorProfile) String() string

String returns the string representation

type ConnectorProfileConfig

type ConnectorProfileConfig struct {

    // The connector-specific credentials required by each connector.
    //
    // ConnectorProfileCredentials is a required field
    ConnectorProfileCredentials *ConnectorProfileCredentials `locationName:"connectorProfileCredentials" type:"structure" required:"true"`

    // The connector-specific properties of the profile configuration.
    //
    // ConnectorProfileProperties is a required field
    ConnectorProfileProperties *ConnectorProfileProperties `locationName:"connectorProfileProperties" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

Defines the connector-specific configuration and credentials for the connector profile.

func (ConnectorProfileConfig) GoString

func (s ConnectorProfileConfig) GoString() string

GoString returns the string representation

func (*ConnectorProfileConfig) SetConnectorProfileCredentials

func (s *ConnectorProfileConfig) SetConnectorProfileCredentials(v *ConnectorProfileCredentials) *ConnectorProfileConfig

SetConnectorProfileCredentials sets the ConnectorProfileCredentials field's value.

func (*ConnectorProfileConfig) SetConnectorProfileProperties

func (s *ConnectorProfileConfig) SetConnectorProfileProperties(v *ConnectorProfileProperties) *ConnectorProfileConfig

SetConnectorProfileProperties sets the ConnectorProfileProperties field's value.

func (ConnectorProfileConfig) String

func (s ConnectorProfileConfig) String() string

String returns the string representation

func (*ConnectorProfileConfig) Validate

func (s *ConnectorProfileConfig) Validate() error

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

type ConnectorProfileCredentials

type ConnectorProfileCredentials struct {

    // The connector-specific credentials required when using Amplitude.
    Amplitude *AmplitudeConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Datadog.
    Datadog *DatadogConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Dynatrace.
    Dynatrace *DynatraceConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Google Analytics.
    GoogleAnalytics *GoogleAnalyticsConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Infor Nexus.
    InforNexus *InforNexusConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Marketo.
    Marketo *MarketoConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Amazon Redshift.
    Redshift *RedshiftConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Salesforce.
    Salesforce *SalesforceConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using ServiceNow.
    ServiceNow *ServiceNowConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Singular.
    Singular *SingularConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Slack.
    Slack *SlackConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Snowflake.
    Snowflake *SnowflakeConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Trend Micro.
    Trendmicro *TrendmicroConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Veeva.
    Veeva *VeevaConnectorProfileCredentials `type:"structure"`

    // The connector-specific credentials required when using Zendesk.
    Zendesk *ZendeskConnectorProfileCredentials `type:"structure"`
    // contains filtered or unexported fields
}

The connector-specific credentials required by a connector.

func (ConnectorProfileCredentials) GoString

func (s ConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ConnectorProfileCredentials) SetAmplitude

func (s *ConnectorProfileCredentials) SetAmplitude(v *AmplitudeConnectorProfileCredentials) *ConnectorProfileCredentials

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileCredentials) SetDatadog

func (s *ConnectorProfileCredentials) SetDatadog(v *DatadogConnectorProfileCredentials) *ConnectorProfileCredentials

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileCredentials) SetDynatrace

func (s *ConnectorProfileCredentials) SetDynatrace(v *DynatraceConnectorProfileCredentials) *ConnectorProfileCredentials

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileCredentials) SetGoogleAnalytics

func (s *ConnectorProfileCredentials) SetGoogleAnalytics(v *GoogleAnalyticsConnectorProfileCredentials) *ConnectorProfileCredentials

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileCredentials) SetInforNexus

func (s *ConnectorProfileCredentials) SetInforNexus(v *InforNexusConnectorProfileCredentials) *ConnectorProfileCredentials

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileCredentials) SetMarketo

func (s *ConnectorProfileCredentials) SetMarketo(v *MarketoConnectorProfileCredentials) *ConnectorProfileCredentials

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileCredentials) SetRedshift

func (s *ConnectorProfileCredentials) SetRedshift(v *RedshiftConnectorProfileCredentials) *ConnectorProfileCredentials

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileCredentials) SetSalesforce

func (s *ConnectorProfileCredentials) SetSalesforce(v *SalesforceConnectorProfileCredentials) *ConnectorProfileCredentials

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileCredentials) SetServiceNow

func (s *ConnectorProfileCredentials) SetServiceNow(v *ServiceNowConnectorProfileCredentials) *ConnectorProfileCredentials

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileCredentials) SetSingular

func (s *ConnectorProfileCredentials) SetSingular(v *SingularConnectorProfileCredentials) *ConnectorProfileCredentials

SetSingular sets the Singular field's value.

func (*ConnectorProfileCredentials) SetSlack

func (s *ConnectorProfileCredentials) SetSlack(v *SlackConnectorProfileCredentials) *ConnectorProfileCredentials

SetSlack sets the Slack field's value.

func (*ConnectorProfileCredentials) SetSnowflake

func (s *ConnectorProfileCredentials) SetSnowflake(v *SnowflakeConnectorProfileCredentials) *ConnectorProfileCredentials

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileCredentials) SetTrendmicro

func (s *ConnectorProfileCredentials) SetTrendmicro(v *TrendmicroConnectorProfileCredentials) *ConnectorProfileCredentials

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileCredentials) SetVeeva

func (s *ConnectorProfileCredentials) SetVeeva(v *VeevaConnectorProfileCredentials) *ConnectorProfileCredentials

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileCredentials) SetZendesk

func (s *ConnectorProfileCredentials) SetZendesk(v *ZendeskConnectorProfileCredentials) *ConnectorProfileCredentials

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileCredentials) String

func (s ConnectorProfileCredentials) String() string

String returns the string representation

func (*ConnectorProfileCredentials) Validate

func (s *ConnectorProfileCredentials) Validate() error

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

type ConnectorProfileProperties

type ConnectorProfileProperties struct {

    // The connector-specific properties required by Amplitude.
    Amplitude *AmplitudeConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Datadog.
    Datadog *DatadogConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Dynatrace.
    Dynatrace *DynatraceConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required Google Analytics.
    GoogleAnalytics *GoogleAnalyticsConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Infor Nexus.
    InforNexus *InforNexusConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Marketo.
    Marketo *MarketoConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Amazon Redshift.
    Redshift *RedshiftConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Salesforce.
    Salesforce *SalesforceConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by serviceNow.
    ServiceNow *ServiceNowConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Singular.
    Singular *SingularConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Slack.
    Slack *SlackConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Snowflake.
    Snowflake *SnowflakeConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Trend Micro.
    Trendmicro *TrendmicroConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Veeva.
    Veeva *VeevaConnectorProfileProperties `type:"structure"`

    // The connector-specific properties required by Zendesk.
    Zendesk *ZendeskConnectorProfileProperties `type:"structure"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required by each connector.

func (ConnectorProfileProperties) GoString

func (s ConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ConnectorProfileProperties) SetAmplitude

func (s *ConnectorProfileProperties) SetAmplitude(v *AmplitudeConnectorProfileProperties) *ConnectorProfileProperties

SetAmplitude sets the Amplitude field's value.

func (*ConnectorProfileProperties) SetDatadog

func (s *ConnectorProfileProperties) SetDatadog(v *DatadogConnectorProfileProperties) *ConnectorProfileProperties

SetDatadog sets the Datadog field's value.

func (*ConnectorProfileProperties) SetDynatrace

func (s *ConnectorProfileProperties) SetDynatrace(v *DynatraceConnectorProfileProperties) *ConnectorProfileProperties

SetDynatrace sets the Dynatrace field's value.

func (*ConnectorProfileProperties) SetGoogleAnalytics

func (s *ConnectorProfileProperties) SetGoogleAnalytics(v *GoogleAnalyticsConnectorProfileProperties) *ConnectorProfileProperties

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*ConnectorProfileProperties) SetInforNexus

func (s *ConnectorProfileProperties) SetInforNexus(v *InforNexusConnectorProfileProperties) *ConnectorProfileProperties

SetInforNexus sets the InforNexus field's value.

func (*ConnectorProfileProperties) SetMarketo

func (s *ConnectorProfileProperties) SetMarketo(v *MarketoConnectorProfileProperties) *ConnectorProfileProperties

SetMarketo sets the Marketo field's value.

func (*ConnectorProfileProperties) SetRedshift

func (s *ConnectorProfileProperties) SetRedshift(v *RedshiftConnectorProfileProperties) *ConnectorProfileProperties

SetRedshift sets the Redshift field's value.

func (*ConnectorProfileProperties) SetSalesforce

func (s *ConnectorProfileProperties) SetSalesforce(v *SalesforceConnectorProfileProperties) *ConnectorProfileProperties

SetSalesforce sets the Salesforce field's value.

func (*ConnectorProfileProperties) SetServiceNow

func (s *ConnectorProfileProperties) SetServiceNow(v *ServiceNowConnectorProfileProperties) *ConnectorProfileProperties

SetServiceNow sets the ServiceNow field's value.

func (*ConnectorProfileProperties) SetSingular

func (s *ConnectorProfileProperties) SetSingular(v *SingularConnectorProfileProperties) *ConnectorProfileProperties

SetSingular sets the Singular field's value.

func (*ConnectorProfileProperties) SetSlack

func (s *ConnectorProfileProperties) SetSlack(v *SlackConnectorProfileProperties) *ConnectorProfileProperties

SetSlack sets the Slack field's value.

func (*ConnectorProfileProperties) SetSnowflake

func (s *ConnectorProfileProperties) SetSnowflake(v *SnowflakeConnectorProfileProperties) *ConnectorProfileProperties

SetSnowflake sets the Snowflake field's value.

func (*ConnectorProfileProperties) SetTrendmicro

func (s *ConnectorProfileProperties) SetTrendmicro(v *TrendmicroConnectorProfileProperties) *ConnectorProfileProperties

SetTrendmicro sets the Trendmicro field's value.

func (*ConnectorProfileProperties) SetVeeva

func (s *ConnectorProfileProperties) SetVeeva(v *VeevaConnectorProfileProperties) *ConnectorProfileProperties

SetVeeva sets the Veeva field's value.

func (*ConnectorProfileProperties) SetZendesk

func (s *ConnectorProfileProperties) SetZendesk(v *ZendeskConnectorProfileProperties) *ConnectorProfileProperties

SetZendesk sets the Zendesk field's value.

func (ConnectorProfileProperties) String

func (s ConnectorProfileProperties) String() string

String returns the string representation

func (*ConnectorProfileProperties) Validate

func (s *ConnectorProfileProperties) Validate() error

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

type ConnectorServerException

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

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

An error occurred when retrieving data from the connector endpoint.

func (*ConnectorServerException) Code

func (s *ConnectorServerException) Code() string

Code returns the exception type name.

func (*ConnectorServerException) Error

func (s *ConnectorServerException) Error() string

func (ConnectorServerException) GoString

func (s ConnectorServerException) GoString() string

GoString returns the string representation

func (*ConnectorServerException) Message

func (s *ConnectorServerException) Message() string

Message returns the exception's message.

func (*ConnectorServerException) OrigErr

func (s *ConnectorServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConnectorServerException) RequestID

func (s *ConnectorServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConnectorServerException) StatusCode

func (s *ConnectorServerException) StatusCode() int

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

func (ConnectorServerException) String

func (s ConnectorServerException) String() string

String returns the string representation

type CreateConnectorProfileInput

type CreateConnectorProfileInput struct {

    // Indicates the connection mode and specifies whether it is public or private.
    // Private flows use AWS PrivateLink to route data over AWS infrastructure without
    // exposing it to the public internet.
    //
    // ConnectionMode is a required field
    ConnectionMode *string `locationName:"connectionMode" type:"string" required:"true" enum:"ConnectionMode"`

    // Defines the connector-specific configuration and credentials.
    //
    // ConnectorProfileConfig is a required field
    ConnectorProfileConfig *ConnectorProfileConfig `locationName:"connectorProfileConfig" type:"structure" required:"true"`

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in your AWS account.
    //
    // ConnectorProfileName is a required field
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    //
    // ConnectorType is a required field
    ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

    // The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you
    // provide for encryption. This is required if you do not want to use the Amazon
    // AppFlow-managed KMS key. If you don't provide anything here, Amazon AppFlow
    // uses the Amazon AppFlow-managed KMS key.
    KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`
    // contains filtered or unexported fields
}

func (CreateConnectorProfileInput) GoString

func (s CreateConnectorProfileInput) GoString() string

GoString returns the string representation

func (*CreateConnectorProfileInput) SetConnectionMode

func (s *CreateConnectorProfileInput) SetConnectionMode(v string) *CreateConnectorProfileInput

SetConnectionMode sets the ConnectionMode field's value.

func (*CreateConnectorProfileInput) SetConnectorProfileConfig

func (s *CreateConnectorProfileInput) SetConnectorProfileConfig(v *ConnectorProfileConfig) *CreateConnectorProfileInput

SetConnectorProfileConfig sets the ConnectorProfileConfig field's value.

func (*CreateConnectorProfileInput) SetConnectorProfileName

func (s *CreateConnectorProfileInput) SetConnectorProfileName(v string) *CreateConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*CreateConnectorProfileInput) SetConnectorType

func (s *CreateConnectorProfileInput) SetConnectorType(v string) *CreateConnectorProfileInput

SetConnectorType sets the ConnectorType field's value.

func (*CreateConnectorProfileInput) SetKmsArn

func (s *CreateConnectorProfileInput) SetKmsArn(v string) *CreateConnectorProfileInput

SetKmsArn sets the KmsArn field's value.

func (CreateConnectorProfileInput) String

func (s CreateConnectorProfileInput) String() string

String returns the string representation

func (*CreateConnectorProfileInput) Validate

func (s *CreateConnectorProfileInput) Validate() error

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

type CreateConnectorProfileOutput

type CreateConnectorProfileOutput struct {

    // The Amazon Resource Name (ARN) of the connector profile.
    ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`
    // contains filtered or unexported fields
}

func (CreateConnectorProfileOutput) GoString

func (s CreateConnectorProfileOutput) GoString() string

GoString returns the string representation

func (*CreateConnectorProfileOutput) SetConnectorProfileArn

func (s *CreateConnectorProfileOutput) SetConnectorProfileArn(v string) *CreateConnectorProfileOutput

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (CreateConnectorProfileOutput) String

func (s CreateConnectorProfileOutput) String() string

String returns the string representation

type CreateFlowInput

type CreateFlowInput struct {

    // A description of the flow you want to create.
    Description *string `locationName:"description" type:"string"`

    // The configuration that controls how Amazon AppFlow places data in the destination
    // connector.
    //
    // DestinationFlowConfigList is a required field
    DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list" required:"true"`

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`

    // The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you
    // provide for encryption. This is required if you do not want to use the Amazon
    // AppFlow-managed KMS key. If you don't provide anything here, Amazon AppFlow
    // uses the Amazon AppFlow-managed KMS key.
    KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`

    // The configuration that controls how Amazon AppFlow retrieves data from the
    // source connector.
    //
    // SourceFlowConfig is a required field
    SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure" required:"true"`

    // The tags used to organize, track, or control access for your flow.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // A list of tasks that Amazon AppFlow performs while transferring the data
    // in the flow run.
    //
    // Tasks is a required field
    Tasks []*Task `locationName:"tasks" type:"list" required:"true"`

    // The trigger settings that determine how and when the flow runs.
    //
    // TriggerConfig is a required field
    TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

func (CreateFlowInput) GoString

func (s CreateFlowInput) GoString() string

GoString returns the string representation

func (*CreateFlowInput) SetDescription

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

SetDescription sets the Description field's value.

func (*CreateFlowInput) SetDestinationFlowConfigList

func (s *CreateFlowInput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *CreateFlowInput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*CreateFlowInput) SetFlowName

func (s *CreateFlowInput) SetFlowName(v string) *CreateFlowInput

SetFlowName sets the FlowName field's value.

func (*CreateFlowInput) SetKmsArn

func (s *CreateFlowInput) SetKmsArn(v string) *CreateFlowInput

SetKmsArn sets the KmsArn field's value.

func (*CreateFlowInput) SetSourceFlowConfig

func (s *CreateFlowInput) SetSourceFlowConfig(v *SourceFlowConfig) *CreateFlowInput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*CreateFlowInput) SetTags

func (s *CreateFlowInput) SetTags(v map[string]*string) *CreateFlowInput

SetTags sets the Tags field's value.

func (*CreateFlowInput) SetTasks

func (s *CreateFlowInput) SetTasks(v []*Task) *CreateFlowInput

SetTasks sets the Tasks field's value.

func (*CreateFlowInput) SetTriggerConfig

func (s *CreateFlowInput) SetTriggerConfig(v *TriggerConfig) *CreateFlowInput

SetTriggerConfig sets the TriggerConfig field's value.

func (CreateFlowInput) String

func (s CreateFlowInput) String() string

String returns the string representation

func (*CreateFlowInput) Validate

func (s *CreateFlowInput) Validate() error

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

type CreateFlowOutput

type CreateFlowOutput struct {

    // The flow's Amazon Resource Name (ARN).
    FlowArn *string `locationName:"flowArn" type:"string"`

    // Indicates the current status of the flow.
    FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
    // contains filtered or unexported fields
}

func (CreateFlowOutput) GoString

func (s CreateFlowOutput) GoString() string

GoString returns the string representation

func (*CreateFlowOutput) SetFlowArn

func (s *CreateFlowOutput) SetFlowArn(v string) *CreateFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*CreateFlowOutput) SetFlowStatus

func (s *CreateFlowOutput) SetFlowStatus(v string) *CreateFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (CreateFlowOutput) String

func (s CreateFlowOutput) String() string

String returns the string representation

type DatadogConnectorProfileCredentials

type DatadogConnectorProfileCredentials struct {

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

    // Application keys, in conjunction with your API key, give you full access
    // to Datadog’s programmatic API. Application keys are associated with the
    // user account that created them. The application key is used to log all requests
    // made to the API.
    //
    // ApplicationKey is a required field
    ApplicationKey *string `locationName:"applicationKey" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific credentials required by Datadog.

func (DatadogConnectorProfileCredentials) GoString

func (s DatadogConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*DatadogConnectorProfileCredentials) SetApiKey

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

SetApiKey sets the ApiKey field's value.

func (*DatadogConnectorProfileCredentials) SetApplicationKey

func (s *DatadogConnectorProfileCredentials) SetApplicationKey(v string) *DatadogConnectorProfileCredentials

SetApplicationKey sets the ApplicationKey field's value.

func (DatadogConnectorProfileCredentials) String

func (s DatadogConnectorProfileCredentials) String() string

String returns the string representation

func (*DatadogConnectorProfileCredentials) Validate

func (s *DatadogConnectorProfileCredentials) Validate() error

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

type DatadogConnectorProfileProperties

type DatadogConnectorProfileProperties struct {

    // The location of the Datadog resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required by Datadog.

func (DatadogConnectorProfileProperties) GoString

func (s DatadogConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*DatadogConnectorProfileProperties) SetInstanceUrl

func (s *DatadogConnectorProfileProperties) SetInstanceUrl(v string) *DatadogConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (DatadogConnectorProfileProperties) String

func (s DatadogConnectorProfileProperties) String() string

String returns the string representation

func (*DatadogConnectorProfileProperties) Validate

func (s *DatadogConnectorProfileProperties) Validate() error

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

type DatadogMetadata

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

The connector metadata specific to Datadog.

func (DatadogMetadata) GoString

func (s DatadogMetadata) GoString() string

GoString returns the string representation

func (DatadogMetadata) String

func (s DatadogMetadata) String() string

String returns the string representation

type DatadogSourceProperties

type DatadogSourceProperties struct {

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

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

func (DatadogSourceProperties) GoString

func (s DatadogSourceProperties) GoString() string

GoString returns the string representation

func (*DatadogSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (DatadogSourceProperties) String

func (s DatadogSourceProperties) String() string

String returns the string representation

func (*DatadogSourceProperties) Validate

func (s *DatadogSourceProperties) Validate() error

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

type DeleteConnectorProfileInput

type DeleteConnectorProfileInput struct {

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in your account.
    //
    // ConnectorProfileName is a required field
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`

    // Indicates whether Amazon AppFlow should delete the profile, even if it is
    // currently in use in one or more flows.
    ForceDelete *bool `locationName:"forceDelete" type:"boolean"`
    // contains filtered or unexported fields
}

func (DeleteConnectorProfileInput) GoString

func (s DeleteConnectorProfileInput) GoString() string

GoString returns the string representation

func (*DeleteConnectorProfileInput) SetConnectorProfileName

func (s *DeleteConnectorProfileInput) SetConnectorProfileName(v string) *DeleteConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DeleteConnectorProfileInput) SetForceDelete

func (s *DeleteConnectorProfileInput) SetForceDelete(v bool) *DeleteConnectorProfileInput

SetForceDelete sets the ForceDelete field's value.

func (DeleteConnectorProfileInput) String

func (s DeleteConnectorProfileInput) String() string

String returns the string representation

func (*DeleteConnectorProfileInput) Validate

func (s *DeleteConnectorProfileInput) Validate() error

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

type DeleteConnectorProfileOutput

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

func (DeleteConnectorProfileOutput) GoString

func (s DeleteConnectorProfileOutput) GoString() string

GoString returns the string representation

func (DeleteConnectorProfileOutput) String

func (s DeleteConnectorProfileOutput) String() string

String returns the string representation

type DeleteFlowInput

type DeleteFlowInput struct {

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`

    // Indicates whether Amazon AppFlow should delete the flow, even if it is currently
    // in use.
    ForceDelete *bool `locationName:"forceDelete" type:"boolean"`
    // contains filtered or unexported fields
}

func (DeleteFlowInput) GoString

func (s DeleteFlowInput) GoString() string

GoString returns the string representation

func (*DeleteFlowInput) SetFlowName

func (s *DeleteFlowInput) SetFlowName(v string) *DeleteFlowInput

SetFlowName sets the FlowName field's value.

func (*DeleteFlowInput) SetForceDelete

func (s *DeleteFlowInput) SetForceDelete(v bool) *DeleteFlowInput

SetForceDelete sets the ForceDelete field's value.

func (DeleteFlowInput) String

func (s DeleteFlowInput) String() string

String returns the string representation

func (*DeleteFlowInput) Validate

func (s *DeleteFlowInput) Validate() error

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

type DeleteFlowOutput

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

func (DeleteFlowOutput) GoString

func (s DeleteFlowOutput) GoString() string

GoString returns the string representation

func (DeleteFlowOutput) String

func (s DeleteFlowOutput) String() string

String returns the string representation

type DescribeConnectorEntityInput

type DescribeConnectorEntityInput struct {

    // The entity name for that connector.
    //
    // ConnectorEntityName is a required field
    ConnectorEntityName *string `locationName:"connectorEntityName" type:"string" required:"true"`

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in the AWS account.
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

    // The type of connector application, such as Salesforce, Amplitude, and so
    // on.
    ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`
    // contains filtered or unexported fields
}

func (DescribeConnectorEntityInput) GoString

func (s DescribeConnectorEntityInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorEntityInput) SetConnectorEntityName

func (s *DescribeConnectorEntityInput) SetConnectorEntityName(v string) *DescribeConnectorEntityInput

SetConnectorEntityName sets the ConnectorEntityName field's value.

func (*DescribeConnectorEntityInput) SetConnectorProfileName

func (s *DescribeConnectorEntityInput) SetConnectorProfileName(v string) *DescribeConnectorEntityInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DescribeConnectorEntityInput) SetConnectorType

func (s *DescribeConnectorEntityInput) SetConnectorType(v string) *DescribeConnectorEntityInput

SetConnectorType sets the ConnectorType field's value.

func (DescribeConnectorEntityInput) String

func (s DescribeConnectorEntityInput) String() string

String returns the string representation

func (*DescribeConnectorEntityInput) Validate

func (s *DescribeConnectorEntityInput) Validate() error

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

type DescribeConnectorEntityOutput

type DescribeConnectorEntityOutput struct {

    // Describes the fields for that connector entity. For example, for an account
    // entity, the fields would be account name, account ID, and so on.
    //
    // ConnectorEntityFields is a required field
    ConnectorEntityFields []*ConnectorEntityField `locationName:"connectorEntityFields" type:"list" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeConnectorEntityOutput) GoString

func (s DescribeConnectorEntityOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorEntityOutput) SetConnectorEntityFields

func (s *DescribeConnectorEntityOutput) SetConnectorEntityFields(v []*ConnectorEntityField) *DescribeConnectorEntityOutput

SetConnectorEntityFields sets the ConnectorEntityFields field's value.

func (DescribeConnectorEntityOutput) String

func (s DescribeConnectorEntityOutput) String() string

String returns the string representation

type DescribeConnectorProfilesInput

type DescribeConnectorProfilesInput struct {

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in the AWS account.
    ConnectorProfileNames []*string `locationName:"connectorProfileNames" type:"list"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

    // Specifies the maximum number of items that should be returned in the result
    // set. The default for maxResults is 20 (for all paginated API operations).
    MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

    // The pagination token for the next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeConnectorProfilesInput) GoString

func (s DescribeConnectorProfilesInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorProfilesInput) SetConnectorProfileNames

func (s *DescribeConnectorProfilesInput) SetConnectorProfileNames(v []*string) *DescribeConnectorProfilesInput

SetConnectorProfileNames sets the ConnectorProfileNames field's value.

func (*DescribeConnectorProfilesInput) SetConnectorType

func (s *DescribeConnectorProfilesInput) SetConnectorType(v string) *DescribeConnectorProfilesInput

SetConnectorType sets the ConnectorType field's value.

func (*DescribeConnectorProfilesInput) SetMaxResults

func (s *DescribeConnectorProfilesInput) SetMaxResults(v int64) *DescribeConnectorProfilesInput

SetMaxResults sets the MaxResults field's value.

func (*DescribeConnectorProfilesInput) SetNextToken

func (s *DescribeConnectorProfilesInput) SetNextToken(v string) *DescribeConnectorProfilesInput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesInput) String

func (s DescribeConnectorProfilesInput) String() string

String returns the string representation

func (*DescribeConnectorProfilesInput) Validate

func (s *DescribeConnectorProfilesInput) Validate() error

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

type DescribeConnectorProfilesOutput

type DescribeConnectorProfilesOutput struct {

    // Returns information about the connector profiles associated with the flow.
    ConnectorProfileDetails []*ConnectorProfile `locationName:"connectorProfileDetails" type:"list"`

    // The pagination token for the next page of data. If nextToken=null, this means
    // that all records have been fetched.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeConnectorProfilesOutput) GoString

func (s DescribeConnectorProfilesOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorProfilesOutput) SetConnectorProfileDetails

func (s *DescribeConnectorProfilesOutput) SetConnectorProfileDetails(v []*ConnectorProfile) *DescribeConnectorProfilesOutput

SetConnectorProfileDetails sets the ConnectorProfileDetails field's value.

func (*DescribeConnectorProfilesOutput) SetNextToken

func (s *DescribeConnectorProfilesOutput) SetNextToken(v string) *DescribeConnectorProfilesOutput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorProfilesOutput) String

func (s DescribeConnectorProfilesOutput) String() string

String returns the string representation

type DescribeConnectorsInput

type DescribeConnectorsInput struct {

    // The type of connector, such as Salesforce, Amplitude, and so on.
    ConnectorTypes []*string `locationName:"connectorTypes" type:"list"`

    // The pagination token for the next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeConnectorsInput) GoString

func (s DescribeConnectorsInput) GoString() string

GoString returns the string representation

func (*DescribeConnectorsInput) SetConnectorTypes

func (s *DescribeConnectorsInput) SetConnectorTypes(v []*string) *DescribeConnectorsInput

SetConnectorTypes sets the ConnectorTypes field's value.

func (*DescribeConnectorsInput) SetNextToken

func (s *DescribeConnectorsInput) SetNextToken(v string) *DescribeConnectorsInput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorsInput) String

func (s DescribeConnectorsInput) String() string

String returns the string representation

type DescribeConnectorsOutput

type DescribeConnectorsOutput struct {

    // The configuration that is applied to the connectors used in the flow.
    ConnectorConfigurations map[string]*ConnectorConfiguration `locationName:"connectorConfigurations" type:"map"`

    // The pagination token for the next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeConnectorsOutput) GoString

func (s DescribeConnectorsOutput) GoString() string

GoString returns the string representation

func (*DescribeConnectorsOutput) SetConnectorConfigurations

func (s *DescribeConnectorsOutput) SetConnectorConfigurations(v map[string]*ConnectorConfiguration) *DescribeConnectorsOutput

SetConnectorConfigurations sets the ConnectorConfigurations field's value.

func (*DescribeConnectorsOutput) SetNextToken

func (s *DescribeConnectorsOutput) SetNextToken(v string) *DescribeConnectorsOutput

SetNextToken sets the NextToken field's value.

func (DescribeConnectorsOutput) String

func (s DescribeConnectorsOutput) String() string

String returns the string representation

type DescribeFlowExecutionRecordsInput

type DescribeFlowExecutionRecordsInput struct {

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`

    // Specifies the maximum number of items that should be returned in the result
    // set. The default for maxResults is 20 (for all paginated API operations).
    MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

    // The pagination token for the next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeFlowExecutionRecordsInput) GoString

func (s DescribeFlowExecutionRecordsInput) GoString() string

GoString returns the string representation

func (*DescribeFlowExecutionRecordsInput) SetFlowName

func (s *DescribeFlowExecutionRecordsInput) SetFlowName(v string) *DescribeFlowExecutionRecordsInput

SetFlowName sets the FlowName field's value.

func (*DescribeFlowExecutionRecordsInput) SetMaxResults

func (s *DescribeFlowExecutionRecordsInput) SetMaxResults(v int64) *DescribeFlowExecutionRecordsInput

SetMaxResults sets the MaxResults field's value.

func (*DescribeFlowExecutionRecordsInput) SetNextToken

func (s *DescribeFlowExecutionRecordsInput) SetNextToken(v string) *DescribeFlowExecutionRecordsInput

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsInput) String

func (s DescribeFlowExecutionRecordsInput) String() string

String returns the string representation

func (*DescribeFlowExecutionRecordsInput) Validate

func (s *DescribeFlowExecutionRecordsInput) Validate() error

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

type DescribeFlowExecutionRecordsOutput

type DescribeFlowExecutionRecordsOutput struct {

    // Returns a list of all instances when this flow was run.
    FlowExecutions []*ExecutionRecord `locationName:"flowExecutions" type:"list"`

    // The pagination token for the next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (DescribeFlowExecutionRecordsOutput) GoString

func (s DescribeFlowExecutionRecordsOutput) GoString() string

GoString returns the string representation

func (*DescribeFlowExecutionRecordsOutput) SetFlowExecutions

func (s *DescribeFlowExecutionRecordsOutput) SetFlowExecutions(v []*ExecutionRecord) *DescribeFlowExecutionRecordsOutput

SetFlowExecutions sets the FlowExecutions field's value.

func (*DescribeFlowExecutionRecordsOutput) SetNextToken

func (s *DescribeFlowExecutionRecordsOutput) SetNextToken(v string) *DescribeFlowExecutionRecordsOutput

SetNextToken sets the NextToken field's value.

func (DescribeFlowExecutionRecordsOutput) String

func (s DescribeFlowExecutionRecordsOutput) String() string

String returns the string representation

type DescribeFlowInput

type DescribeFlowInput struct {

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (DescribeFlowInput) GoString

func (s DescribeFlowInput) GoString() string

GoString returns the string representation

func (*DescribeFlowInput) SetFlowName

func (s *DescribeFlowInput) SetFlowName(v string) *DescribeFlowInput

SetFlowName sets the FlowName field's value.

func (DescribeFlowInput) String

func (s DescribeFlowInput) String() string

String returns the string representation

func (*DescribeFlowInput) Validate

func (s *DescribeFlowInput) Validate() error

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

type DescribeFlowOutput

type DescribeFlowOutput struct {

    // Specifies when the flow was created.
    CreatedAt *time.Time `locationName:"createdAt" type:"timestamp"`

    // The ARN of the user who created the flow.
    CreatedBy *string `locationName:"createdBy" type:"string"`

    // A description of the flow.
    Description *string `locationName:"description" type:"string"`

    // The configuration that controls how Amazon AppFlow transfers data to the
    // destination connector.
    DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list"`

    // The flow's Amazon Resource Name (ARN).
    FlowArn *string `locationName:"flowArn" type:"string"`

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    FlowName *string `locationName:"flowName" type:"string"`

    // Indicates the current status of the flow.
    FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`

    // Contains an error message if the flow status is in a suspended or error state.
    // This applies only to scheduled or event-triggered flows.
    FlowStatusMessage *string `locationName:"flowStatusMessage" type:"string"`

    // The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you
    // provide for encryption. This is required if you do not want to use the Amazon
    // AppFlow-managed KMS key. If you don't provide anything here, Amazon AppFlow
    // uses the Amazon AppFlow-managed KMS key.
    KmsArn *string `locationName:"kmsArn" min:"20" type:"string"`

    // Describes the details of the most recent flow run.
    LastRunExecutionDetails *ExecutionDetails `locationName:"lastRunExecutionDetails" type:"structure"`

    // Specifies when the flow was last updated.
    LastUpdatedAt *time.Time `locationName:"lastUpdatedAt" type:"timestamp"`

    // Specifies the user name of the account that performed the most recent update.
    LastUpdatedBy *string `locationName:"lastUpdatedBy" type:"string"`

    // The configuration that controls how Amazon AppFlow retrieves data from the
    // source connector.
    SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure"`

    // The tags used to organize, track, or control access for your flow.
    Tags map[string]*string `locationName:"tags" type:"map"`

    // A list of tasks that Amazon AppFlow performs while transferring the data
    // in the flow run.
    Tasks []*Task `locationName:"tasks" type:"list"`

    // The trigger settings that determine how and when the flow runs.
    TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure"`
    // contains filtered or unexported fields
}

func (DescribeFlowOutput) GoString

func (s DescribeFlowOutput) GoString() string

GoString returns the string representation

func (*DescribeFlowOutput) SetCreatedAt

func (s *DescribeFlowOutput) SetCreatedAt(v time.Time) *DescribeFlowOutput

SetCreatedAt sets the CreatedAt field's value.

func (*DescribeFlowOutput) SetCreatedBy

func (s *DescribeFlowOutput) SetCreatedBy(v string) *DescribeFlowOutput

SetCreatedBy sets the CreatedBy field's value.

func (*DescribeFlowOutput) SetDescription

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

SetDescription sets the Description field's value.

func (*DescribeFlowOutput) SetDestinationFlowConfigList

func (s *DescribeFlowOutput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *DescribeFlowOutput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*DescribeFlowOutput) SetFlowArn

func (s *DescribeFlowOutput) SetFlowArn(v string) *DescribeFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*DescribeFlowOutput) SetFlowName

func (s *DescribeFlowOutput) SetFlowName(v string) *DescribeFlowOutput

SetFlowName sets the FlowName field's value.

func (*DescribeFlowOutput) SetFlowStatus

func (s *DescribeFlowOutput) SetFlowStatus(v string) *DescribeFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (*DescribeFlowOutput) SetFlowStatusMessage

func (s *DescribeFlowOutput) SetFlowStatusMessage(v string) *DescribeFlowOutput

SetFlowStatusMessage sets the FlowStatusMessage field's value.

func (*DescribeFlowOutput) SetKmsArn

func (s *DescribeFlowOutput) SetKmsArn(v string) *DescribeFlowOutput

SetKmsArn sets the KmsArn field's value.

func (*DescribeFlowOutput) SetLastRunExecutionDetails

func (s *DescribeFlowOutput) SetLastRunExecutionDetails(v *ExecutionDetails) *DescribeFlowOutput

SetLastRunExecutionDetails sets the LastRunExecutionDetails field's value.

func (*DescribeFlowOutput) SetLastUpdatedAt

func (s *DescribeFlowOutput) SetLastUpdatedAt(v time.Time) *DescribeFlowOutput

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*DescribeFlowOutput) SetLastUpdatedBy

func (s *DescribeFlowOutput) SetLastUpdatedBy(v string) *DescribeFlowOutput

SetLastUpdatedBy sets the LastUpdatedBy field's value.

func (*DescribeFlowOutput) SetSourceFlowConfig

func (s *DescribeFlowOutput) SetSourceFlowConfig(v *SourceFlowConfig) *DescribeFlowOutput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*DescribeFlowOutput) SetTags

func (s *DescribeFlowOutput) SetTags(v map[string]*string) *DescribeFlowOutput

SetTags sets the Tags field's value.

func (*DescribeFlowOutput) SetTasks

func (s *DescribeFlowOutput) SetTasks(v []*Task) *DescribeFlowOutput

SetTasks sets the Tasks field's value.

func (*DescribeFlowOutput) SetTriggerConfig

func (s *DescribeFlowOutput) SetTriggerConfig(v *TriggerConfig) *DescribeFlowOutput

SetTriggerConfig sets the TriggerConfig field's value.

func (DescribeFlowOutput) String

func (s DescribeFlowOutput) String() string

String returns the string representation

type DestinationConnectorProperties

type DestinationConnectorProperties struct {

    // The properties required to query Amazon 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"`

    // The properties required to query Upsolver.
    Upsolver *UpsolverDestinationProperties `type:"structure"`
    // contains filtered or unexported fields
}

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

func (DestinationConnectorProperties) GoString

func (s DestinationConnectorProperties) GoString() string

GoString returns the string representation

func (*DestinationConnectorProperties) SetEventBridge

func (s *DestinationConnectorProperties) SetEventBridge(v *EventBridgeDestinationProperties) *DestinationConnectorProperties

SetEventBridge sets the EventBridge field's value.

func (*DestinationConnectorProperties) SetRedshift

func (s *DestinationConnectorProperties) SetRedshift(v *RedshiftDestinationProperties) *DestinationConnectorProperties

SetRedshift sets the Redshift field's value.

func (*DestinationConnectorProperties) SetS3

func (s *DestinationConnectorProperties) SetS3(v *S3DestinationProperties) *DestinationConnectorProperties

SetS3 sets the S3 field's value.

func (*DestinationConnectorProperties) SetSalesforce

func (s *DestinationConnectorProperties) SetSalesforce(v *SalesforceDestinationProperties) *DestinationConnectorProperties

SetSalesforce sets the Salesforce field's value.

func (*DestinationConnectorProperties) SetSnowflake

func (s *DestinationConnectorProperties) SetSnowflake(v *SnowflakeDestinationProperties) *DestinationConnectorProperties

SetSnowflake sets the Snowflake field's value.

func (*DestinationConnectorProperties) SetUpsolver

func (s *DestinationConnectorProperties) SetUpsolver(v *UpsolverDestinationProperties) *DestinationConnectorProperties

SetUpsolver sets the Upsolver field's value.

func (DestinationConnectorProperties) String

func (s DestinationConnectorProperties) String() string

String returns the string representation

func (*DestinationConnectorProperties) Validate

func (s *DestinationConnectorProperties) Validate() error

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

type DestinationFieldProperties

type DestinationFieldProperties struct {

    // Specifies if the destination field can be created by the current user.
    IsCreatable *bool `locationName:"isCreatable" type:"boolean"`

    // Specifies if the destination field can have a null value.
    IsNullable *bool `locationName:"isNullable" type:"boolean"`

    // Specifies whether the field can be updated during an UPDATE or UPSERT write
    // operation.
    IsUpdatable *bool `locationName:"isUpdatable" type:"boolean"`

    // Specifies if the flow run can either insert new rows in the destination field
    // if they do not already exist, or update them if they do.
    IsUpsertable *bool `locationName:"isUpsertable" type:"boolean"`

    // A list of supported write operations. For each write operation listed, this
    // field can be used in idFieldNames when that write operation is present as
    // a destination option.
    SupportedWriteOperations []*string `locationName:"supportedWriteOperations" type:"list"`
    // contains filtered or unexported fields
}

The properties that can be applied to a field when connector is being used as a destination.

func (DestinationFieldProperties) GoString

func (s DestinationFieldProperties) GoString() string

GoString returns the string representation

func (*DestinationFieldProperties) SetIsCreatable

func (s *DestinationFieldProperties) SetIsCreatable(v bool) *DestinationFieldProperties

SetIsCreatable sets the IsCreatable field's value.

func (*DestinationFieldProperties) SetIsNullable

func (s *DestinationFieldProperties) SetIsNullable(v bool) *DestinationFieldProperties

SetIsNullable sets the IsNullable field's value.

func (*DestinationFieldProperties) SetIsUpdatable

func (s *DestinationFieldProperties) SetIsUpdatable(v bool) *DestinationFieldProperties

SetIsUpdatable sets the IsUpdatable field's value.

func (*DestinationFieldProperties) SetIsUpsertable

func (s *DestinationFieldProperties) SetIsUpsertable(v bool) *DestinationFieldProperties

SetIsUpsertable sets the IsUpsertable field's value.

func (*DestinationFieldProperties) SetSupportedWriteOperations

func (s *DestinationFieldProperties) SetSupportedWriteOperations(v []*string) *DestinationFieldProperties

SetSupportedWriteOperations sets the SupportedWriteOperations field's value.

func (DestinationFieldProperties) String

func (s DestinationFieldProperties) String() string

String returns the string representation

type DestinationFlowConfig

type DestinationFlowConfig struct {

    // The name of the connector profile. This name must be unique for each connector
    // profile in the AWS account.
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    //
    // ConnectorType is a required field
    ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

    // This stores the information that is required to query a particular connector.
    //
    // DestinationConnectorProperties is a required field
    DestinationConnectorProperties *DestinationConnectorProperties `locationName:"destinationConnectorProperties" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

Contains information about the configuration of destination connectors present in the flow.

func (DestinationFlowConfig) GoString

func (s DestinationFlowConfig) GoString() string

GoString returns the string representation

func (*DestinationFlowConfig) SetConnectorProfileName

func (s *DestinationFlowConfig) SetConnectorProfileName(v string) *DestinationFlowConfig

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*DestinationFlowConfig) SetConnectorType

func (s *DestinationFlowConfig) SetConnectorType(v string) *DestinationFlowConfig

SetConnectorType sets the ConnectorType field's value.

func (*DestinationFlowConfig) SetDestinationConnectorProperties

func (s *DestinationFlowConfig) SetDestinationConnectorProperties(v *DestinationConnectorProperties) *DestinationFlowConfig

SetDestinationConnectorProperties sets the DestinationConnectorProperties field's value.

func (DestinationFlowConfig) String

func (s DestinationFlowConfig) String() string

String returns the string representation

func (*DestinationFlowConfig) Validate

func (s *DestinationFlowConfig) Validate() error

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

type DynatraceConnectorProfileCredentials

type DynatraceConnectorProfileCredentials struct {

    // The API tokens used by Dynatrace API to authenticate various API calls.
    //
    // ApiToken is a required field
    ApiToken *string `locationName:"apiToken" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required by Dynatrace.

func (DynatraceConnectorProfileCredentials) GoString

func (s DynatraceConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*DynatraceConnectorProfileCredentials) SetApiToken

func (s *DynatraceConnectorProfileCredentials) SetApiToken(v string) *DynatraceConnectorProfileCredentials

SetApiToken sets the ApiToken field's value.

func (DynatraceConnectorProfileCredentials) String

func (s DynatraceConnectorProfileCredentials) String() string

String returns the string representation

func (*DynatraceConnectorProfileCredentials) Validate

func (s *DynatraceConnectorProfileCredentials) Validate() error

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

type DynatraceConnectorProfileProperties

type DynatraceConnectorProfileProperties struct {

    // The location of the Dynatrace resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required by Dynatrace.

func (DynatraceConnectorProfileProperties) GoString

func (s DynatraceConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*DynatraceConnectorProfileProperties) SetInstanceUrl

func (s *DynatraceConnectorProfileProperties) SetInstanceUrl(v string) *DynatraceConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (DynatraceConnectorProfileProperties) String

func (s DynatraceConnectorProfileProperties) String() string

String returns the string representation

func (*DynatraceConnectorProfileProperties) Validate

func (s *DynatraceConnectorProfileProperties) Validate() error

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

type DynatraceMetadata

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

The connector metadata specific to Dynatrace.

func (DynatraceMetadata) GoString

func (s DynatraceMetadata) GoString() string

GoString returns the string representation

func (DynatraceMetadata) String

func (s DynatraceMetadata) String() string

String returns the string representation

type DynatraceSourceProperties

type DynatraceSourceProperties struct {

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

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

func (DynatraceSourceProperties) GoString

func (s DynatraceSourceProperties) GoString() string

GoString returns the string representation

func (*DynatraceSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (DynatraceSourceProperties) String

func (s DynatraceSourceProperties) String() string

String returns the string representation

func (*DynatraceSourceProperties) Validate

func (s *DynatraceSourceProperties) Validate() error

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

type ErrorHandlingConfig

type ErrorHandlingConfig struct {

    // Specifies the name of the Amazon S3 bucket.
    BucketName *string `locationName:"bucketName" min:"3" type:"string"`

    // Specifies the Amazon S3 bucket prefix.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // Specifies if the flow should fail after the first instance of a failure when
    // attempting to place data in the destination.
    FailOnFirstDestinationError *bool `locationName:"failOnFirstDestinationError" type:"boolean"`
    // contains filtered or unexported fields
}

The settings that determine how Amazon AppFlow handles an error when placing data in the destination. For example, this setting would determine if the flow should fail after one insertion error, or continue and attempt to insert every record regardless of the initial failure. ErrorHandlingConfig is a part of the destination connector details.

func (ErrorHandlingConfig) GoString

func (s ErrorHandlingConfig) GoString() string

GoString returns the string representation

func (*ErrorHandlingConfig) SetBucketName

func (s *ErrorHandlingConfig) SetBucketName(v string) *ErrorHandlingConfig

SetBucketName sets the BucketName field's value.

func (*ErrorHandlingConfig) SetBucketPrefix

func (s *ErrorHandlingConfig) SetBucketPrefix(v string) *ErrorHandlingConfig

SetBucketPrefix sets the BucketPrefix field's value.

func (*ErrorHandlingConfig) SetFailOnFirstDestinationError

func (s *ErrorHandlingConfig) SetFailOnFirstDestinationError(v bool) *ErrorHandlingConfig

SetFailOnFirstDestinationError sets the FailOnFirstDestinationError field's value.

func (ErrorHandlingConfig) String

func (s ErrorHandlingConfig) String() string

String returns the string representation

func (*ErrorHandlingConfig) Validate

func (s *ErrorHandlingConfig) Validate() error

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

type ErrorInfo

type ErrorInfo struct {

    // Specifies the error message that appears if a flow fails.
    ExecutionMessage *string `locationName:"executionMessage" type:"string"`

    // Specifies the failure count for the attempted flow.
    PutFailuresCount *int64 `locationName:"putFailuresCount" type:"long"`
    // contains filtered or unexported fields
}

Provides details in the event of a failed flow, including the failure count and the related error messages.

func (ErrorInfo) GoString

func (s ErrorInfo) GoString() string

GoString returns the string representation

func (*ErrorInfo) SetExecutionMessage

func (s *ErrorInfo) SetExecutionMessage(v string) *ErrorInfo

SetExecutionMessage sets the ExecutionMessage field's value.

func (*ErrorInfo) SetPutFailuresCount

func (s *ErrorInfo) SetPutFailuresCount(v int64) *ErrorInfo

SetPutFailuresCount sets the PutFailuresCount field's value.

func (ErrorInfo) String

func (s ErrorInfo) String() string

String returns the string representation

type EventBridgeDestinationProperties

type EventBridgeDestinationProperties struct {

    // The settings that determine how Amazon AppFlow handles an error when placing
    // data in the destination. For example, this setting would determine if the
    // flow should fail after one insertion error, or continue and attempt to insert
    // every record regardless of the initial failure. ErrorHandlingConfig is a
    // part of the destination connector details.
    ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

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

The properties that are applied when Amazon EventBridge is being used as a destination.

func (EventBridgeDestinationProperties) GoString

func (s EventBridgeDestinationProperties) GoString() string

GoString returns the string representation

func (*EventBridgeDestinationProperties) SetErrorHandlingConfig

func (s *EventBridgeDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *EventBridgeDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*EventBridgeDestinationProperties) SetObject

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

SetObject sets the Object field's value.

func (EventBridgeDestinationProperties) String

func (s EventBridgeDestinationProperties) String() string

String returns the string representation

func (*EventBridgeDestinationProperties) Validate

func (s *EventBridgeDestinationProperties) Validate() error

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

type EventBridgeMetadata

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

The connector metadata specific to Amazon EventBridge.

func (EventBridgeMetadata) GoString

func (s EventBridgeMetadata) GoString() string

GoString returns the string representation

func (EventBridgeMetadata) String

func (s EventBridgeMetadata) String() string

String returns the string representation

type ExecutionDetails

type ExecutionDetails struct {

    // Describes the details of the most recent flow run.
    MostRecentExecutionMessage *string `locationName:"mostRecentExecutionMessage" type:"string"`

    // Specifies the status of the most recent flow run.
    MostRecentExecutionStatus *string `locationName:"mostRecentExecutionStatus" type:"string" enum:"ExecutionStatus"`

    // Specifies the time of the most recent flow run.
    MostRecentExecutionTime *time.Time `locationName:"mostRecentExecutionTime" type:"timestamp"`
    // contains filtered or unexported fields
}

Describes the details of the flow run, including the timestamp, status, and message.

func (ExecutionDetails) GoString

func (s ExecutionDetails) GoString() string

GoString returns the string representation

func (*ExecutionDetails) SetMostRecentExecutionMessage

func (s *ExecutionDetails) SetMostRecentExecutionMessage(v string) *ExecutionDetails

SetMostRecentExecutionMessage sets the MostRecentExecutionMessage field's value.

func (*ExecutionDetails) SetMostRecentExecutionStatus

func (s *ExecutionDetails) SetMostRecentExecutionStatus(v string) *ExecutionDetails

SetMostRecentExecutionStatus sets the MostRecentExecutionStatus field's value.

func (*ExecutionDetails) SetMostRecentExecutionTime

func (s *ExecutionDetails) SetMostRecentExecutionTime(v time.Time) *ExecutionDetails

SetMostRecentExecutionTime sets the MostRecentExecutionTime field's value.

func (ExecutionDetails) String

func (s ExecutionDetails) String() string

String returns the string representation

type ExecutionRecord

type ExecutionRecord struct {

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

func (s GoogleAnalyticsConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) SetAccessToken

func (s *GoogleAnalyticsConnectorProfileCredentials) SetAccessToken(v string) *GoogleAnalyticsConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientId

func (s *GoogleAnalyticsConnectorProfileCredentials) SetClientId(v string) *GoogleAnalyticsConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetClientSecret

func (s *GoogleAnalyticsConnectorProfileCredentials) SetClientSecret(v string) *GoogleAnalyticsConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetOAuthRequest

func (s *GoogleAnalyticsConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *GoogleAnalyticsConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (*GoogleAnalyticsConnectorProfileCredentials) SetRefreshToken

func (s *GoogleAnalyticsConnectorProfileCredentials) SetRefreshToken(v string) *GoogleAnalyticsConnectorProfileCredentials

SetRefreshToken sets the RefreshToken field's value.

func (GoogleAnalyticsConnectorProfileCredentials) String

func (s GoogleAnalyticsConnectorProfileCredentials) String() string

String returns the string representation

func (*GoogleAnalyticsConnectorProfileCredentials) Validate

func (s *GoogleAnalyticsConnectorProfileCredentials) Validate() error

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

type GoogleAnalyticsConnectorProfileProperties

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

The connector-specific profile properties required by Google Analytics.

func (GoogleAnalyticsConnectorProfileProperties) GoString

func (s GoogleAnalyticsConnectorProfileProperties) GoString() string

GoString returns the string representation

func (GoogleAnalyticsConnectorProfileProperties) String

func (s GoogleAnalyticsConnectorProfileProperties) String() string

String returns the string representation

type GoogleAnalyticsMetadata

type GoogleAnalyticsMetadata struct {

    // The desired authorization scope for the Google Analytics account.
    OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
    // contains filtered or unexported fields
}

The connector metadata specific to Google Analytics.

func (GoogleAnalyticsMetadata) GoString

func (s GoogleAnalyticsMetadata) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsMetadata) SetOAuthScopes

func (s *GoogleAnalyticsMetadata) SetOAuthScopes(v []*string) *GoogleAnalyticsMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (GoogleAnalyticsMetadata) String

func (s GoogleAnalyticsMetadata) String() string

String returns the string representation

type GoogleAnalyticsSourceProperties

type GoogleAnalyticsSourceProperties struct {

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

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

func (GoogleAnalyticsSourceProperties) GoString

func (s GoogleAnalyticsSourceProperties) GoString() string

GoString returns the string representation

func (*GoogleAnalyticsSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (GoogleAnalyticsSourceProperties) String

func (s GoogleAnalyticsSourceProperties) String() string

String returns the string representation

func (*GoogleAnalyticsSourceProperties) Validate

func (s *GoogleAnalyticsSourceProperties) Validate() error

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

type IncrementalPullConfig

type IncrementalPullConfig struct {

    // A field that specifies the date time or timestamp field as the criteria to
    // use when importing incremental records from the source.
    DatetimeTypeFieldName *string `locationName:"datetimeTypeFieldName" type:"string"`
    // contains filtered or unexported fields
}

Specifies the configuration used when importing incremental records from the source.

func (IncrementalPullConfig) GoString

func (s IncrementalPullConfig) GoString() string

GoString returns the string representation

func (*IncrementalPullConfig) SetDatetimeTypeFieldName

func (s *IncrementalPullConfig) SetDatetimeTypeFieldName(v string) *IncrementalPullConfig

SetDatetimeTypeFieldName sets the DatetimeTypeFieldName field's value.

func (IncrementalPullConfig) String

func (s IncrementalPullConfig) String() string

String returns the string representation

type InforNexusConnectorProfileCredentials

type InforNexusConnectorProfileCredentials struct {

    // The Access Key portion of the credentials.
    //
    // AccessKeyId is a required field
    AccessKeyId *string `locationName:"accessKeyId" type:"string" required:"true" sensitive:"true"`

    // The encryption keys used to encrypt data.
    //
    // Datakey is a required field
    Datakey *string `locationName:"datakey" type:"string" required:"true"`

    // The secret key used to sign requests.
    //
    // SecretAccessKey is a required field
    SecretAccessKey *string `locationName:"secretAccessKey" type:"string" required:"true"`

    // The identifier for the user.
    //
    // UserId is a required field
    UserId *string `locationName:"userId" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required by Infor Nexus.

func (InforNexusConnectorProfileCredentials) GoString

func (s InforNexusConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*InforNexusConnectorProfileCredentials) SetAccessKeyId

func (s *InforNexusConnectorProfileCredentials) SetAccessKeyId(v string) *InforNexusConnectorProfileCredentials

SetAccessKeyId sets the AccessKeyId field's value.

func (*InforNexusConnectorProfileCredentials) SetDatakey

func (s *InforNexusConnectorProfileCredentials) SetDatakey(v string) *InforNexusConnectorProfileCredentials

SetDatakey sets the Datakey field's value.

func (*InforNexusConnectorProfileCredentials) SetSecretAccessKey

func (s *InforNexusConnectorProfileCredentials) SetSecretAccessKey(v string) *InforNexusConnectorProfileCredentials

SetSecretAccessKey sets the SecretAccessKey field's value.

func (*InforNexusConnectorProfileCredentials) SetUserId

func (s *InforNexusConnectorProfileCredentials) SetUserId(v string) *InforNexusConnectorProfileCredentials

SetUserId sets the UserId field's value.

func (InforNexusConnectorProfileCredentials) String

func (s InforNexusConnectorProfileCredentials) String() string

String returns the string representation

func (*InforNexusConnectorProfileCredentials) Validate

func (s *InforNexusConnectorProfileCredentials) Validate() error

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

type InforNexusConnectorProfileProperties

type InforNexusConnectorProfileProperties struct {

    // The location of the Infor Nexus resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required by Infor Nexus.

func (InforNexusConnectorProfileProperties) GoString

func (s InforNexusConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*InforNexusConnectorProfileProperties) SetInstanceUrl

func (s *InforNexusConnectorProfileProperties) SetInstanceUrl(v string) *InforNexusConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (InforNexusConnectorProfileProperties) String

func (s InforNexusConnectorProfileProperties) String() string

String returns the string representation

func (*InforNexusConnectorProfileProperties) Validate

func (s *InforNexusConnectorProfileProperties) Validate() error

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

type InforNexusMetadata

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

The connector metadata specific to Infor Nexus.

func (InforNexusMetadata) GoString

func (s InforNexusMetadata) GoString() string

GoString returns the string representation

func (InforNexusMetadata) String

func (s InforNexusMetadata) String() string

String returns the string representation

type InforNexusSourceProperties

type InforNexusSourceProperties struct {

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

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

func (InforNexusSourceProperties) GoString

func (s InforNexusSourceProperties) GoString() string

GoString returns the string representation

func (*InforNexusSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (InforNexusSourceProperties) String

func (s InforNexusSourceProperties) String() string

String returns the string representation

func (*InforNexusSourceProperties) Validate

func (s *InforNexusSourceProperties) Validate() error

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

type InternalServerException

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

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

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

func (*InternalServerException) Code

func (s *InternalServerException) Code() string

Code returns the exception type name.

func (*InternalServerException) Error

func (s *InternalServerException) Error() string

func (InternalServerException) GoString

func (s InternalServerException) GoString() string

GoString returns the string representation

func (*InternalServerException) Message

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode

func (s *InternalServerException) StatusCode() int

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

func (InternalServerException) String

func (s InternalServerException) String() string

String returns the string representation

type ListConnectorEntitiesInput

type ListConnectorEntitiesInput struct {

    // The name of the connector profile. The name is unique for each ConnectorProfile
    // in the AWS account, and is used to query the downstream connector.
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    ConnectorType *string `locationName:"connectorType" type:"string" enum:"ConnectorType"`

    // This optional parameter is specific to connector implementation. Some connectors
    // support multiple levels or categories of entities. You can find out the list
    // of roots for such providers by sending a request without the entitiesPath
    // parameter. If the connector supports entities at different roots, this initial
    // request returns the list of roots. Otherwise, this request returns all entities
    // supported by the provider.
    EntitiesPath *string `locationName:"entitiesPath" type:"string"`
    // contains filtered or unexported fields
}

func (ListConnectorEntitiesInput) GoString

func (s ListConnectorEntitiesInput) GoString() string

GoString returns the string representation

func (*ListConnectorEntitiesInput) SetConnectorProfileName

func (s *ListConnectorEntitiesInput) SetConnectorProfileName(v string) *ListConnectorEntitiesInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*ListConnectorEntitiesInput) SetConnectorType

func (s *ListConnectorEntitiesInput) SetConnectorType(v string) *ListConnectorEntitiesInput

SetConnectorType sets the ConnectorType field's value.

func (*ListConnectorEntitiesInput) SetEntitiesPath

func (s *ListConnectorEntitiesInput) SetEntitiesPath(v string) *ListConnectorEntitiesInput

SetEntitiesPath sets the EntitiesPath field's value.

func (ListConnectorEntitiesInput) String

func (s ListConnectorEntitiesInput) String() string

String returns the string representation

type ListConnectorEntitiesOutput

type ListConnectorEntitiesOutput struct {

    // The response of ListConnectorEntities lists entities grouped by category.
    // This map's key represents the group name, and its value contains the list
    // of entities belonging to that group.
    //
    // ConnectorEntityMap is a required field
    ConnectorEntityMap map[string][]*ConnectorEntity `locationName:"connectorEntityMap" type:"map" required:"true"`
    // contains filtered or unexported fields
}

func (ListConnectorEntitiesOutput) GoString

func (s ListConnectorEntitiesOutput) GoString() string

GoString returns the string representation

func (*ListConnectorEntitiesOutput) SetConnectorEntityMap

func (s *ListConnectorEntitiesOutput) SetConnectorEntityMap(v map[string][]*ConnectorEntity) *ListConnectorEntitiesOutput

SetConnectorEntityMap sets the ConnectorEntityMap field's value.

func (ListConnectorEntitiesOutput) String

func (s ListConnectorEntitiesOutput) String() string

String returns the string representation

type ListFlowsInput

type ListFlowsInput struct {

    // Specifies the maximum number of items that should be returned in the result
    // set.
    MaxResults *int64 `locationName:"maxResults" min:"1" type:"integer"`

    // The pagination token for next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListFlowsInput) GoString

func (s ListFlowsInput) GoString() string

GoString returns the string representation

func (*ListFlowsInput) SetMaxResults

func (s *ListFlowsInput) SetMaxResults(v int64) *ListFlowsInput

SetMaxResults sets the MaxResults field's value.

func (*ListFlowsInput) SetNextToken

func (s *ListFlowsInput) SetNextToken(v string) *ListFlowsInput

SetNextToken sets the NextToken field's value.

func (ListFlowsInput) String

func (s ListFlowsInput) String() string

String returns the string representation

func (*ListFlowsInput) Validate

func (s *ListFlowsInput) Validate() error

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

type ListFlowsOutput

type ListFlowsOutput struct {

    // The list of flows associated with your account.
    Flows []*FlowDefinition `locationName:"flows" type:"list"`

    // The pagination token for next page of data.
    NextToken *string `locationName:"nextToken" type:"string"`
    // contains filtered or unexported fields
}

func (ListFlowsOutput) GoString

func (s ListFlowsOutput) GoString() string

GoString returns the string representation

func (*ListFlowsOutput) SetFlows

func (s *ListFlowsOutput) SetFlows(v []*FlowDefinition) *ListFlowsOutput

SetFlows sets the Flows field's value.

func (*ListFlowsOutput) SetNextToken

func (s *ListFlowsOutput) SetNextToken(v string) *ListFlowsOutput

SetNextToken sets the NextToken field's value.

func (ListFlowsOutput) String

func (s ListFlowsOutput) String() string

String returns the string representation

type ListTagsForResourceInput

type ListTagsForResourceInput struct {

    // The Amazon Resource Name (ARN) of the specified flow.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceInput) SetResourceArn

func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate

func (s *ListTagsForResourceInput) Validate() error

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

type ListTagsForResourceOutput

type ListTagsForResourceOutput struct {

    // The tags used to organize, track, or control access for your flow.
    Tags map[string]*string `locationName:"tags" type:"map"`
    // contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceOutput) SetTags

func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type MarketoConnectorProfileCredentials

type MarketoConnectorProfileCredentials struct {

    // The credentials used to access protected Marketo resources.
    AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

    // The identifier for the desired client.
    //
    // ClientId is a required field
    ClientId *string `locationName:"clientId" type:"string" required:"true"`

    // The client secret used by the OAuth client to authenticate to the authorization
    // server.
    //
    // ClientSecret is a required field
    ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

    // The OAuth requirement needed to request security tokens from the connector
    // endpoint.
    OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required by Marketo.

func (MarketoConnectorProfileCredentials) GoString

func (s MarketoConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*MarketoConnectorProfileCredentials) SetAccessToken

func (s *MarketoConnectorProfileCredentials) SetAccessToken(v string) *MarketoConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*MarketoConnectorProfileCredentials) SetClientId

func (s *MarketoConnectorProfileCredentials) SetClientId(v string) *MarketoConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*MarketoConnectorProfileCredentials) SetClientSecret

func (s *MarketoConnectorProfileCredentials) SetClientSecret(v string) *MarketoConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*MarketoConnectorProfileCredentials) SetOAuthRequest

func (s *MarketoConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *MarketoConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (MarketoConnectorProfileCredentials) String

func (s MarketoConnectorProfileCredentials) String() string

String returns the string representation

func (*MarketoConnectorProfileCredentials) Validate

func (s *MarketoConnectorProfileCredentials) Validate() error

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

type MarketoConnectorProfileProperties

type MarketoConnectorProfileProperties struct {

    // The location of the Marketo resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using Marketo.

func (MarketoConnectorProfileProperties) GoString

func (s MarketoConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*MarketoConnectorProfileProperties) SetInstanceUrl

func (s *MarketoConnectorProfileProperties) SetInstanceUrl(v string) *MarketoConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (MarketoConnectorProfileProperties) String

func (s MarketoConnectorProfileProperties) String() string

String returns the string representation

func (*MarketoConnectorProfileProperties) Validate

func (s *MarketoConnectorProfileProperties) Validate() error

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

type MarketoMetadata

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

The connector metadata specific to Marketo.

func (MarketoMetadata) GoString

func (s MarketoMetadata) GoString() string

GoString returns the string representation

func (MarketoMetadata) String

func (s MarketoMetadata) String() string

String returns the string representation

type MarketoSourceProperties

type MarketoSourceProperties struct {

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

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

func (MarketoSourceProperties) GoString

func (s MarketoSourceProperties) GoString() string

GoString returns the string representation

func (*MarketoSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (MarketoSourceProperties) String

func (s MarketoSourceProperties) String() string

String returns the string representation

func (*MarketoSourceProperties) Validate

func (s *MarketoSourceProperties) Validate() error

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

type PrefixConfig

type PrefixConfig struct {

    // Determines the 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

func (s RedshiftConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*RedshiftConnectorProfileCredentials) SetPassword

func (s *RedshiftConnectorProfileCredentials) SetPassword(v string) *RedshiftConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*RedshiftConnectorProfileCredentials) SetUsername

func (s *RedshiftConnectorProfileCredentials) SetUsername(v string) *RedshiftConnectorProfileCredentials

SetUsername sets the Username field's value.

func (RedshiftConnectorProfileCredentials) String

func (s RedshiftConnectorProfileCredentials) String() string

String returns the string representation

func (*RedshiftConnectorProfileCredentials) Validate

func (s *RedshiftConnectorProfileCredentials) Validate() error

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

type RedshiftConnectorProfileProperties

type RedshiftConnectorProfileProperties struct {

    // A name for the associated Amazon S3 bucket.
    //
    // BucketName is a required field
    BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

    // The object key for the destination bucket in which Amazon AppFlow places
    // the files.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The JDBC URL of the Amazon Redshift cluster.
    //
    // DatabaseUrl is a required field
    DatabaseUrl *string `locationName:"databaseUrl" type:"string" required:"true"`

    // The Amazon Resource Name (ARN) of the IAM role.
    //
    // RoleArn is a required field
    RoleArn *string `locationName:"roleArn" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties when using Amazon Redshift.

func (RedshiftConnectorProfileProperties) GoString

func (s RedshiftConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*RedshiftConnectorProfileProperties) SetBucketName

func (s *RedshiftConnectorProfileProperties) SetBucketName(v string) *RedshiftConnectorProfileProperties

SetBucketName sets the BucketName field's value.

func (*RedshiftConnectorProfileProperties) SetBucketPrefix

func (s *RedshiftConnectorProfileProperties) SetBucketPrefix(v string) *RedshiftConnectorProfileProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftConnectorProfileProperties) SetDatabaseUrl

func (s *RedshiftConnectorProfileProperties) SetDatabaseUrl(v string) *RedshiftConnectorProfileProperties

SetDatabaseUrl sets the DatabaseUrl field's value.

func (*RedshiftConnectorProfileProperties) SetRoleArn

func (s *RedshiftConnectorProfileProperties) SetRoleArn(v string) *RedshiftConnectorProfileProperties

SetRoleArn sets the RoleArn field's value.

func (RedshiftConnectorProfileProperties) String

func (s RedshiftConnectorProfileProperties) String() string

String returns the string representation

func (*RedshiftConnectorProfileProperties) Validate

func (s *RedshiftConnectorProfileProperties) Validate() error

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

type RedshiftDestinationProperties

type RedshiftDestinationProperties struct {

    // The object key for the bucket in which Amazon AppFlow places the destination
    // files.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The settings that determine how Amazon AppFlow handles an error when placing
    // data in the Amazon Redshift destination. For example, this setting would
    // determine if the flow should fail after one insertion error, or continue
    // and attempt to insert every record regardless of the initial failure. ErrorHandlingConfig
    // is a part of the destination connector details.
    ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

    // The intermediate bucket that Amazon AppFlow uses when moving data into Amazon
    // Redshift.
    //
    // IntermediateBucketName is a required field
    IntermediateBucketName *string `locationName:"intermediateBucketName" min:"3" type:"string" required:"true"`

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

The properties that are applied when Amazon Redshift is being used as a destination.

func (RedshiftDestinationProperties) GoString

func (s RedshiftDestinationProperties) GoString() string

GoString returns the string representation

func (*RedshiftDestinationProperties) SetBucketPrefix

func (s *RedshiftDestinationProperties) SetBucketPrefix(v string) *RedshiftDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*RedshiftDestinationProperties) SetErrorHandlingConfig

func (s *RedshiftDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *RedshiftDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*RedshiftDestinationProperties) SetIntermediateBucketName

func (s *RedshiftDestinationProperties) SetIntermediateBucketName(v string) *RedshiftDestinationProperties

SetIntermediateBucketName sets the IntermediateBucketName field's value.

func (*RedshiftDestinationProperties) SetObject

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

SetObject sets the Object field's value.

func (RedshiftDestinationProperties) String

func (s RedshiftDestinationProperties) String() string

String returns the string representation

func (*RedshiftDestinationProperties) Validate

func (s *RedshiftDestinationProperties) Validate() error

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

type RedshiftMetadata

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

The connector metadata specific to Amazon Redshift.

func (RedshiftMetadata) GoString

func (s RedshiftMetadata) GoString() string

GoString returns the string representation

func (RedshiftMetadata) String

func (s RedshiftMetadata) String() string

String returns the string representation

type ResourceNotFoundException

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

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

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

func (*ResourceNotFoundException) Code

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation

func (*ResourceNotFoundException) Message

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode

func (s *ResourceNotFoundException) StatusCode() int

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

func (ResourceNotFoundException) String

func (s ResourceNotFoundException) String() string

String returns the string representation

type S3DestinationProperties

type S3DestinationProperties struct {

    // The Amazon S3 bucket name in which Amazon AppFlow places the transferred
    // data.
    //
    // BucketName is a required field
    BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

    // The object key for the destination bucket in which Amazon AppFlow places
    // the files.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The configuration that determines how Amazon AppFlow should format the flow
    // output data when Amazon S3 is used as the destination.
    S3OutputFormatConfig *S3OutputFormatConfig `locationName:"s3OutputFormatConfig" type:"structure"`
    // contains filtered or unexported fields
}

The properties that are applied when Amazon S3 is used as a destination.

func (S3DestinationProperties) GoString

func (s S3DestinationProperties) GoString() string

GoString returns the string representation

func (*S3DestinationProperties) SetBucketName

func (s *S3DestinationProperties) SetBucketName(v string) *S3DestinationProperties

SetBucketName sets the BucketName field's value.

func (*S3DestinationProperties) SetBucketPrefix

func (s *S3DestinationProperties) SetBucketPrefix(v string) *S3DestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*S3DestinationProperties) SetS3OutputFormatConfig

func (s *S3DestinationProperties) SetS3OutputFormatConfig(v *S3OutputFormatConfig) *S3DestinationProperties

SetS3OutputFormatConfig sets the S3OutputFormatConfig field's value.

func (S3DestinationProperties) String

func (s S3DestinationProperties) String() string

String returns the string representation

func (*S3DestinationProperties) Validate

func (s *S3DestinationProperties) Validate() error

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

type S3Metadata

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

The connector metadata specific to Amazon S3.

func (S3Metadata) GoString

func (s S3Metadata) GoString() string

GoString returns the string representation

func (S3Metadata) String

func (s S3Metadata) String() string

String returns the string representation

type S3OutputFormatConfig

type S3OutputFormatConfig struct {

    // The aggregation settings that you can use to customize the output format
    // of your flow data.
    AggregationConfig *AggregationConfig `locationName:"aggregationConfig" type:"structure"`

    // Indicates the file type that Amazon AppFlow places in the Amazon S3 bucket.
    FileType *string `locationName:"fileType" type:"string" enum:"FileType"`

    // Determines the prefix that Amazon AppFlow applies to the folder name in the
    // Amazon S3 bucket. You can name folders according to the flow frequency and
    // date.
    PrefixConfig *PrefixConfig `locationName:"prefixConfig" type:"structure"`
    // contains filtered or unexported fields
}

The configuration that determines how Amazon AppFlow should format the flow output data when Amazon S3 is used as the destination.

func (S3OutputFormatConfig) GoString

func (s S3OutputFormatConfig) GoString() string

GoString returns the string representation

func (*S3OutputFormatConfig) SetAggregationConfig

func (s *S3OutputFormatConfig) SetAggregationConfig(v *AggregationConfig) *S3OutputFormatConfig

SetAggregationConfig sets the AggregationConfig field's value.

func (*S3OutputFormatConfig) SetFileType

func (s *S3OutputFormatConfig) SetFileType(v string) *S3OutputFormatConfig

SetFileType sets the FileType field's value.

func (*S3OutputFormatConfig) SetPrefixConfig

func (s *S3OutputFormatConfig) SetPrefixConfig(v *PrefixConfig) *S3OutputFormatConfig

SetPrefixConfig sets the PrefixConfig field's value.

func (S3OutputFormatConfig) String

func (s S3OutputFormatConfig) String() string

String returns the string representation

type S3SourceProperties

type S3SourceProperties struct {

    // The Amazon S3 bucket name where the source files are stored.
    //
    // BucketName is a required field
    BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

    // The object key for the Amazon S3 bucket in which the source files are stored.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`
    // contains filtered or unexported fields
}

The properties that are applied when Amazon S3 is being used as the flow source.

func (S3SourceProperties) GoString

func (s S3SourceProperties) GoString() string

GoString returns the string representation

func (*S3SourceProperties) SetBucketName

func (s *S3SourceProperties) SetBucketName(v string) *S3SourceProperties

SetBucketName sets the BucketName field's value.

func (*S3SourceProperties) SetBucketPrefix

func (s *S3SourceProperties) SetBucketPrefix(v string) *S3SourceProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (S3SourceProperties) String

func (s S3SourceProperties) String() string

String returns the string representation

func (*S3SourceProperties) Validate

func (s *S3SourceProperties) Validate() error

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

type SalesforceConnectorProfileCredentials

type SalesforceConnectorProfileCredentials struct {

    // The credentials used to access protected Salesforce resources.
    AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

    // The secret manager ARN, which contains the client ID and client secret of
    // the connected app.
    ClientCredentialsArn *string `locationName:"clientCredentialsArn" min:"20" type:"string" sensitive:"true"`

    // The OAuth requirement needed to request security tokens from the connector
    // endpoint.
    OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`

    // The credentials used to acquire new access tokens.
    RefreshToken *string `locationName:"refreshToken" type:"string"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required when using Salesforce.

func (SalesforceConnectorProfileCredentials) GoString

func (s SalesforceConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SalesforceConnectorProfileCredentials) SetAccessToken

func (s *SalesforceConnectorProfileCredentials) SetAccessToken(v string) *SalesforceConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*SalesforceConnectorProfileCredentials) SetClientCredentialsArn

func (s *SalesforceConnectorProfileCredentials) SetClientCredentialsArn(v string) *SalesforceConnectorProfileCredentials

SetClientCredentialsArn sets the ClientCredentialsArn field's value.

func (*SalesforceConnectorProfileCredentials) SetOAuthRequest

func (s *SalesforceConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *SalesforceConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (*SalesforceConnectorProfileCredentials) SetRefreshToken

func (s *SalesforceConnectorProfileCredentials) SetRefreshToken(v string) *SalesforceConnectorProfileCredentials

SetRefreshToken sets the RefreshToken field's value.

func (SalesforceConnectorProfileCredentials) String

func (s SalesforceConnectorProfileCredentials) String() string

String returns the string representation

func (*SalesforceConnectorProfileCredentials) Validate

func (s *SalesforceConnectorProfileCredentials) Validate() error

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

type SalesforceConnectorProfileProperties

type SalesforceConnectorProfileProperties struct {

    // The location of the Salesforce resource.
    InstanceUrl *string `locationName:"instanceUrl" type:"string"`

    // Indicates whether the connector profile applies to a sandbox or production
    // environment.
    IsSandboxEnvironment *bool `locationName:"isSandboxEnvironment" type:"boolean"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using Salesforce.

func (SalesforceConnectorProfileProperties) GoString

func (s SalesforceConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SalesforceConnectorProfileProperties) SetInstanceUrl

func (s *SalesforceConnectorProfileProperties) SetInstanceUrl(v string) *SalesforceConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (*SalesforceConnectorProfileProperties) SetIsSandboxEnvironment

func (s *SalesforceConnectorProfileProperties) SetIsSandboxEnvironment(v bool) *SalesforceConnectorProfileProperties

SetIsSandboxEnvironment sets the IsSandboxEnvironment field's value.

func (SalesforceConnectorProfileProperties) String

func (s SalesforceConnectorProfileProperties) String() string

String returns the string representation

type SalesforceDestinationProperties

type SalesforceDestinationProperties struct {

    // The settings that determine how Amazon AppFlow handles an error when placing
    // data in the Salesforce destination. For example, this setting would determine
    // if the flow should fail after one insertion error, or continue and attempt
    // to insert every record regardless of the initial failure. ErrorHandlingConfig
    // is a part of the destination connector details.
    ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

    // The name of the field that Amazon AppFlow uses as an ID when performing a
    // write operation such as update or delete.
    IdFieldNames []*string `locationName:"idFieldNames" type:"list"`

    // The object specified in the Salesforce flow destination.
    //
    // Object is a required field
    Object *string `locationName:"object" type:"string" required:"true"`

    // This specifies the type of write operation to be performed in Salesforce.
    // When the value is UPSERT, then idFieldNames is required.
    WriteOperationType *string `locationName:"writeOperationType" type:"string" enum:"WriteOperationType"`
    // contains filtered or unexported fields
}

The properties that are applied when Salesforce is being used as a destination.

func (SalesforceDestinationProperties) GoString

func (s SalesforceDestinationProperties) GoString() string

GoString returns the string representation

func (*SalesforceDestinationProperties) SetErrorHandlingConfig

func (s *SalesforceDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *SalesforceDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*SalesforceDestinationProperties) SetIdFieldNames

func (s *SalesforceDestinationProperties) SetIdFieldNames(v []*string) *SalesforceDestinationProperties

SetIdFieldNames sets the IdFieldNames field's value.

func (*SalesforceDestinationProperties) SetObject

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

SetObject sets the Object field's value.

func (*SalesforceDestinationProperties) SetWriteOperationType

func (s *SalesforceDestinationProperties) SetWriteOperationType(v string) *SalesforceDestinationProperties

SetWriteOperationType sets the WriteOperationType field's value.

func (SalesforceDestinationProperties) String

func (s SalesforceDestinationProperties) String() string

String returns the string representation

func (*SalesforceDestinationProperties) Validate

func (s *SalesforceDestinationProperties) Validate() error

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

type SalesforceMetadata

type SalesforceMetadata struct {

    // The desired authorization scope for the Salesforce account.
    OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
    // contains filtered or unexported fields
}

The connector metadata specific to Salesforce.

func (SalesforceMetadata) GoString

func (s SalesforceMetadata) GoString() string

GoString returns the string representation

func (*SalesforceMetadata) SetOAuthScopes

func (s *SalesforceMetadata) SetOAuthScopes(v []*string) *SalesforceMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (SalesforceMetadata) String

func (s SalesforceMetadata) String() string

String returns the string representation

type SalesforceSourceProperties

type SalesforceSourceProperties struct {

    // The flag that enables dynamic fetching of new (recently added) fields in
    // the Salesforce objects while running a flow.
    EnableDynamicFieldUpdate *bool `locationName:"enableDynamicFieldUpdate" type:"boolean"`

    // Indicates whether Amazon AppFlow includes deleted files in the flow run.
    IncludeDeletedRecords *bool `locationName:"includeDeletedRecords" type:"boolean"`

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

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

func (SalesforceSourceProperties) GoString

func (s SalesforceSourceProperties) GoString() string

GoString returns the string representation

func (*SalesforceSourceProperties) SetEnableDynamicFieldUpdate

func (s *SalesforceSourceProperties) SetEnableDynamicFieldUpdate(v bool) *SalesforceSourceProperties

SetEnableDynamicFieldUpdate sets the EnableDynamicFieldUpdate field's value.

func (*SalesforceSourceProperties) SetIncludeDeletedRecords

func (s *SalesforceSourceProperties) SetIncludeDeletedRecords(v bool) *SalesforceSourceProperties

SetIncludeDeletedRecords sets the IncludeDeletedRecords field's value.

func (*SalesforceSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (SalesforceSourceProperties) String

func (s SalesforceSourceProperties) String() string

String returns the string representation

func (*SalesforceSourceProperties) Validate

func (s *SalesforceSourceProperties) Validate() error

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

type ScheduledTriggerProperties

type ScheduledTriggerProperties struct {

    // Specifies whether a scheduled flow has an incremental data transfer or a
    // complete data transfer for each flow run.
    DataPullMode *string `locationName:"dataPullMode" type:"string" enum:"DataPullMode"`

    // Specifies the scheduled end time for a schedule-triggered flow.
    ScheduleEndTime *time.Time `locationName:"scheduleEndTime" type:"timestamp"`

    // The scheduling expression that determines the rate at which the schedule
    // will run, for example rate(5minutes).
    //
    // ScheduleExpression is a required field
    ScheduleExpression *string `locationName:"scheduleExpression" type:"string" required:"true"`

    // Specifies the 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

func (s *ScheduledTriggerProperties) SetDataPullMode(v string) *ScheduledTriggerProperties

SetDataPullMode sets the DataPullMode field's value.

func (*ScheduledTriggerProperties) SetScheduleEndTime

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

SetScheduleEndTime sets the ScheduleEndTime field's value.

func (*ScheduledTriggerProperties) SetScheduleExpression

func (s *ScheduledTriggerProperties) SetScheduleExpression(v string) *ScheduledTriggerProperties

SetScheduleExpression sets the ScheduleExpression field's value.

func (*ScheduledTriggerProperties) SetScheduleStartTime

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

SetScheduleStartTime sets the ScheduleStartTime field's value.

func (*ScheduledTriggerProperties) SetTimezone

func (s *ScheduledTriggerProperties) SetTimezone(v string) *ScheduledTriggerProperties

SetTimezone sets the Timezone field's value.

func (ScheduledTriggerProperties) String

func (s ScheduledTriggerProperties) String() string

String returns the string representation

func (*ScheduledTriggerProperties) Validate

func (s *ScheduledTriggerProperties) Validate() error

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

type ServiceNowConnectorProfileCredentials

type ServiceNowConnectorProfileCredentials struct {

    // The password that corresponds to the user name.
    //
    // Password is a required field
    Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

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

The connector-specific profile credentials required when using ServiceNow.

func (ServiceNowConnectorProfileCredentials) GoString

func (s ServiceNowConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ServiceNowConnectorProfileCredentials) SetPassword

func (s *ServiceNowConnectorProfileCredentials) SetPassword(v string) *ServiceNowConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*ServiceNowConnectorProfileCredentials) SetUsername

func (s *ServiceNowConnectorProfileCredentials) SetUsername(v string) *ServiceNowConnectorProfileCredentials

SetUsername sets the Username field's value.

func (ServiceNowConnectorProfileCredentials) String

func (s ServiceNowConnectorProfileCredentials) String() string

String returns the string representation

func (*ServiceNowConnectorProfileCredentials) Validate

func (s *ServiceNowConnectorProfileCredentials) Validate() error

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

type ServiceNowConnectorProfileProperties

type ServiceNowConnectorProfileProperties struct {

    // The location of the ServiceNow resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using ServiceNow.

func (ServiceNowConnectorProfileProperties) GoString

func (s ServiceNowConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ServiceNowConnectorProfileProperties) SetInstanceUrl

func (s *ServiceNowConnectorProfileProperties) SetInstanceUrl(v string) *ServiceNowConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (ServiceNowConnectorProfileProperties) String

func (s ServiceNowConnectorProfileProperties) String() string

String returns the string representation

func (*ServiceNowConnectorProfileProperties) Validate

func (s *ServiceNowConnectorProfileProperties) Validate() error

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

type ServiceNowMetadata

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

The connector metadata specific to ServiceNow.

func (ServiceNowMetadata) GoString

func (s ServiceNowMetadata) GoString() string

GoString returns the string representation

func (ServiceNowMetadata) String

func (s ServiceNowMetadata) String() string

String returns the string representation

type ServiceNowSourceProperties

type ServiceNowSourceProperties struct {

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

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

func (ServiceNowSourceProperties) GoString

func (s ServiceNowSourceProperties) GoString() string

GoString returns the string representation

func (*ServiceNowSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (ServiceNowSourceProperties) String

func (s ServiceNowSourceProperties) String() string

String returns the string representation

func (*ServiceNowSourceProperties) Validate

func (s *ServiceNowSourceProperties) Validate() error

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

type ServiceQuotaExceededException

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

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

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

func (*ServiceQuotaExceededException) Code

func (s *ServiceQuotaExceededException) Code() string

Code returns the exception type name.

func (*ServiceQuotaExceededException) Error

func (s *ServiceQuotaExceededException) Error() string

func (ServiceQuotaExceededException) GoString

func (s ServiceQuotaExceededException) GoString() string

GoString returns the string representation

func (*ServiceQuotaExceededException) Message

func (s *ServiceQuotaExceededException) Message() string

Message returns the exception's message.

func (*ServiceQuotaExceededException) OrigErr

func (s *ServiceQuotaExceededException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ServiceQuotaExceededException) RequestID

func (s *ServiceQuotaExceededException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ServiceQuotaExceededException) StatusCode

func (s *ServiceQuotaExceededException) StatusCode() int

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

func (ServiceQuotaExceededException) String

func (s ServiceQuotaExceededException) String() string

String returns the string representation

type SingularConnectorProfileCredentials

type SingularConnectorProfileCredentials struct {

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

The connector-specific profile credentials required when using Singular.

func (SingularConnectorProfileCredentials) GoString

func (s SingularConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SingularConnectorProfileCredentials) SetApiKey

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

SetApiKey sets the ApiKey field's value.

func (SingularConnectorProfileCredentials) String

func (s SingularConnectorProfileCredentials) String() string

String returns the string representation

func (*SingularConnectorProfileCredentials) Validate

func (s *SingularConnectorProfileCredentials) Validate() error

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

type SingularConnectorProfileProperties

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

The connector-specific profile properties required when using Singular.

func (SingularConnectorProfileProperties) GoString

func (s SingularConnectorProfileProperties) GoString() string

GoString returns the string representation

func (SingularConnectorProfileProperties) String

func (s SingularConnectorProfileProperties) String() string

String returns the string representation

type SingularMetadata

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

The connector metadata specific to Singular.

func (SingularMetadata) GoString

func (s SingularMetadata) GoString() string

GoString returns the string representation

func (SingularMetadata) String

func (s SingularMetadata) String() string

String returns the string representation

type SingularSourceProperties

type SingularSourceProperties struct {

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

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

func (SingularSourceProperties) GoString

func (s SingularSourceProperties) GoString() string

GoString returns the string representation

func (*SingularSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (SingularSourceProperties) String

func (s SingularSourceProperties) String() string

String returns the string representation

func (*SingularSourceProperties) Validate

func (s *SingularSourceProperties) Validate() error

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

type SlackConnectorProfileCredentials

type SlackConnectorProfileCredentials struct {

    // The credentials used to access protected Slack resources.
    AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

    // The identifier for the client.
    //
    // ClientId is a required field
    ClientId *string `locationName:"clientId" type:"string" required:"true"`

    // The client secret used by the OAuth client to authenticate to the authorization
    // server.
    //
    // ClientSecret is a required field
    ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

    // The OAuth requirement needed to request security tokens from the connector
    // endpoint.
    OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required when using Slack.

func (SlackConnectorProfileCredentials) GoString

func (s SlackConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SlackConnectorProfileCredentials) SetAccessToken

func (s *SlackConnectorProfileCredentials) SetAccessToken(v string) *SlackConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*SlackConnectorProfileCredentials) SetClientId

func (s *SlackConnectorProfileCredentials) SetClientId(v string) *SlackConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*SlackConnectorProfileCredentials) SetClientSecret

func (s *SlackConnectorProfileCredentials) SetClientSecret(v string) *SlackConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*SlackConnectorProfileCredentials) SetOAuthRequest

func (s *SlackConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *SlackConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (SlackConnectorProfileCredentials) String

func (s SlackConnectorProfileCredentials) String() string

String returns the string representation

func (*SlackConnectorProfileCredentials) Validate

func (s *SlackConnectorProfileCredentials) Validate() error

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

type SlackConnectorProfileProperties

type SlackConnectorProfileProperties struct {

    // The location of the Slack resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using Slack.

func (SlackConnectorProfileProperties) GoString

func (s SlackConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SlackConnectorProfileProperties) SetInstanceUrl

func (s *SlackConnectorProfileProperties) SetInstanceUrl(v string) *SlackConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (SlackConnectorProfileProperties) String

func (s SlackConnectorProfileProperties) String() string

String returns the string representation

func (*SlackConnectorProfileProperties) Validate

func (s *SlackConnectorProfileProperties) Validate() error

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

type SlackMetadata

type SlackMetadata struct {

    // The desired authorization scope for the Slack account.
    OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
    // contains filtered or unexported fields
}

The connector metadata specific to Slack.

func (SlackMetadata) GoString

func (s SlackMetadata) GoString() string

GoString returns the string representation

func (*SlackMetadata) SetOAuthScopes

func (s *SlackMetadata) SetOAuthScopes(v []*string) *SlackMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (SlackMetadata) String

func (s SlackMetadata) String() string

String returns the string representation

type SlackSourceProperties

type SlackSourceProperties struct {

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

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

func (SlackSourceProperties) GoString

func (s SlackSourceProperties) GoString() string

GoString returns the string representation

func (*SlackSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (SlackSourceProperties) String

func (s SlackSourceProperties) String() string

String returns the string representation

func (*SlackSourceProperties) Validate

func (s *SlackSourceProperties) Validate() error

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

type SnowflakeConnectorProfileCredentials

type SnowflakeConnectorProfileCredentials struct {

    // The password that corresponds to the user name.
    //
    // Password is a required field
    Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

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

The connector-specific profile credentials required when using Snowflake.

func (SnowflakeConnectorProfileCredentials) GoString

func (s SnowflakeConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*SnowflakeConnectorProfileCredentials) SetPassword

func (s *SnowflakeConnectorProfileCredentials) SetPassword(v string) *SnowflakeConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*SnowflakeConnectorProfileCredentials) SetUsername

func (s *SnowflakeConnectorProfileCredentials) SetUsername(v string) *SnowflakeConnectorProfileCredentials

SetUsername sets the Username field's value.

func (SnowflakeConnectorProfileCredentials) String

func (s SnowflakeConnectorProfileCredentials) String() string

String returns the string representation

func (*SnowflakeConnectorProfileCredentials) Validate

func (s *SnowflakeConnectorProfileCredentials) Validate() error

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

type SnowflakeConnectorProfileProperties

type SnowflakeConnectorProfileProperties struct {

    // The name of the account.
    AccountName *string `locationName:"accountName" type:"string"`

    // The name of the Amazon S3 bucket associated with Snowflake.
    //
    // BucketName is a required field
    BucketName *string `locationName:"bucketName" min:"3" type:"string" required:"true"`

    // The bucket path that refers to the Amazon S3 bucket associated with Snowflake.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The Snowflake Private Link service name to be used for private data transfers.
    PrivateLinkServiceName *string `locationName:"privateLinkServiceName" type:"string"`

    // The AWS Region of the Snowflake account.
    Region *string `locationName:"region" type:"string"`

    // The name of the Amazon S3 stage that was created while setting up an Amazon
    // S3 stage in the Snowflake account. This is written in the following format:
    // < Database>< Schema><Stage Name>.
    //
    // Stage is a required field
    Stage *string `locationName:"stage" type:"string" required:"true"`

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

The connector-specific profile properties required when using Snowflake.

func (SnowflakeConnectorProfileProperties) GoString

func (s SnowflakeConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*SnowflakeConnectorProfileProperties) SetAccountName

func (s *SnowflakeConnectorProfileProperties) SetAccountName(v string) *SnowflakeConnectorProfileProperties

SetAccountName sets the AccountName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketName

func (s *SnowflakeConnectorProfileProperties) SetBucketName(v string) *SnowflakeConnectorProfileProperties

SetBucketName sets the BucketName field's value.

func (*SnowflakeConnectorProfileProperties) SetBucketPrefix

func (s *SnowflakeConnectorProfileProperties) SetBucketPrefix(v string) *SnowflakeConnectorProfileProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeConnectorProfileProperties) SetPrivateLinkServiceName

func (s *SnowflakeConnectorProfileProperties) SetPrivateLinkServiceName(v string) *SnowflakeConnectorProfileProperties

SetPrivateLinkServiceName sets the PrivateLinkServiceName field's value.

func (*SnowflakeConnectorProfileProperties) SetRegion

func (s *SnowflakeConnectorProfileProperties) SetRegion(v string) *SnowflakeConnectorProfileProperties

SetRegion sets the Region field's value.

func (*SnowflakeConnectorProfileProperties) SetStage

func (s *SnowflakeConnectorProfileProperties) SetStage(v string) *SnowflakeConnectorProfileProperties

SetStage sets the Stage field's value.

func (*SnowflakeConnectorProfileProperties) SetWarehouse

func (s *SnowflakeConnectorProfileProperties) SetWarehouse(v string) *SnowflakeConnectorProfileProperties

SetWarehouse sets the Warehouse field's value.

func (SnowflakeConnectorProfileProperties) String

func (s SnowflakeConnectorProfileProperties) String() string

String returns the string representation

func (*SnowflakeConnectorProfileProperties) Validate

func (s *SnowflakeConnectorProfileProperties) Validate() error

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

type SnowflakeDestinationProperties

type SnowflakeDestinationProperties struct {

    // The object key for the destination bucket in which Amazon AppFlow places
    // the files.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The settings that determine how Amazon AppFlow handles an error when placing
    // data in the Snowflake destination. For example, this setting would determine
    // if the flow should fail after one insertion error, or continue and attempt
    // to insert every record regardless of the initial failure. ErrorHandlingConfig
    // is a part of the destination connector details.
    ErrorHandlingConfig *ErrorHandlingConfig `locationName:"errorHandlingConfig" type:"structure"`

    // The intermediate bucket that Amazon AppFlow uses when moving data into Snowflake.
    //
    // IntermediateBucketName is a required field
    IntermediateBucketName *string `locationName:"intermediateBucketName" min:"3" type:"string" required:"true"`

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

The properties that are applied when Snowflake is being used as a destination.

func (SnowflakeDestinationProperties) GoString

func (s SnowflakeDestinationProperties) GoString() string

GoString returns the string representation

func (*SnowflakeDestinationProperties) SetBucketPrefix

func (s *SnowflakeDestinationProperties) SetBucketPrefix(v string) *SnowflakeDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*SnowflakeDestinationProperties) SetErrorHandlingConfig

func (s *SnowflakeDestinationProperties) SetErrorHandlingConfig(v *ErrorHandlingConfig) *SnowflakeDestinationProperties

SetErrorHandlingConfig sets the ErrorHandlingConfig field's value.

func (*SnowflakeDestinationProperties) SetIntermediateBucketName

func (s *SnowflakeDestinationProperties) SetIntermediateBucketName(v string) *SnowflakeDestinationProperties

SetIntermediateBucketName sets the IntermediateBucketName field's value.

func (*SnowflakeDestinationProperties) SetObject

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

SetObject sets the Object field's value.

func (SnowflakeDestinationProperties) String

func (s SnowflakeDestinationProperties) String() string

String returns the string representation

func (*SnowflakeDestinationProperties) Validate

func (s *SnowflakeDestinationProperties) Validate() error

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

type SnowflakeMetadata

type SnowflakeMetadata struct {

    // Specifies the supported AWS Regions when using Snowflake.
    SupportedRegions []*string `locationName:"supportedRegions" type:"list"`
    // contains filtered or unexported fields
}

The connector metadata specific to Snowflake.

func (SnowflakeMetadata) GoString

func (s SnowflakeMetadata) GoString() string

GoString returns the string representation

func (*SnowflakeMetadata) SetSupportedRegions

func (s *SnowflakeMetadata) SetSupportedRegions(v []*string) *SnowflakeMetadata

SetSupportedRegions sets the SupportedRegions field's value.

func (SnowflakeMetadata) String

func (s SnowflakeMetadata) String() string

String returns the string representation

type SourceConnectorProperties

type SourceConnectorProperties struct {

    // Specifies the information that is required for querying Amplitude.
    Amplitude *AmplitudeSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Datadog.
    Datadog *DatadogSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Dynatrace.
    Dynatrace *DynatraceSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Google Analytics.
    GoogleAnalytics *GoogleAnalyticsSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Infor Nexus.
    InforNexus *InforNexusSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Marketo.
    Marketo *MarketoSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Amazon S3.
    S3 *S3SourceProperties `type:"structure"`

    // Specifies the information that is required for querying Salesforce.
    Salesforce *SalesforceSourceProperties `type:"structure"`

    // Specifies the information that is required for querying ServiceNow.
    ServiceNow *ServiceNowSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Singular.
    Singular *SingularSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Slack.
    Slack *SlackSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Trend Micro.
    Trendmicro *TrendmicroSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Veeva.
    Veeva *VeevaSourceProperties `type:"structure"`

    // Specifies the information that is required for querying Zendesk.
    Zendesk *ZendeskSourceProperties `type:"structure"`
    // contains filtered or unexported fields
}

Specifies the information that is required to query a particular connector.

func (SourceConnectorProperties) GoString

func (s SourceConnectorProperties) GoString() string

GoString returns the string representation

func (*SourceConnectorProperties) SetAmplitude

func (s *SourceConnectorProperties) SetAmplitude(v *AmplitudeSourceProperties) *SourceConnectorProperties

SetAmplitude sets the Amplitude field's value.

func (*SourceConnectorProperties) SetDatadog

func (s *SourceConnectorProperties) SetDatadog(v *DatadogSourceProperties) *SourceConnectorProperties

SetDatadog sets the Datadog field's value.

func (*SourceConnectorProperties) SetDynatrace

func (s *SourceConnectorProperties) SetDynatrace(v *DynatraceSourceProperties) *SourceConnectorProperties

SetDynatrace sets the Dynatrace field's value.

func (*SourceConnectorProperties) SetGoogleAnalytics

func (s *SourceConnectorProperties) SetGoogleAnalytics(v *GoogleAnalyticsSourceProperties) *SourceConnectorProperties

SetGoogleAnalytics sets the GoogleAnalytics field's value.

func (*SourceConnectorProperties) SetInforNexus

func (s *SourceConnectorProperties) SetInforNexus(v *InforNexusSourceProperties) *SourceConnectorProperties

SetInforNexus sets the InforNexus field's value.

func (*SourceConnectorProperties) SetMarketo

func (s *SourceConnectorProperties) SetMarketo(v *MarketoSourceProperties) *SourceConnectorProperties

SetMarketo sets the Marketo field's value.

func (*SourceConnectorProperties) SetS3

func (s *SourceConnectorProperties) SetS3(v *S3SourceProperties) *SourceConnectorProperties

SetS3 sets the S3 field's value.

func (*SourceConnectorProperties) SetSalesforce

func (s *SourceConnectorProperties) SetSalesforce(v *SalesforceSourceProperties) *SourceConnectorProperties

SetSalesforce sets the Salesforce field's value.

func (*SourceConnectorProperties) SetServiceNow

func (s *SourceConnectorProperties) SetServiceNow(v *ServiceNowSourceProperties) *SourceConnectorProperties

SetServiceNow sets the ServiceNow field's value.

func (*SourceConnectorProperties) SetSingular

func (s *SourceConnectorProperties) SetSingular(v *SingularSourceProperties) *SourceConnectorProperties

SetSingular sets the Singular field's value.

func (*SourceConnectorProperties) SetSlack

func (s *SourceConnectorProperties) SetSlack(v *SlackSourceProperties) *SourceConnectorProperties

SetSlack sets the Slack field's value.

func (*SourceConnectorProperties) SetTrendmicro

func (s *SourceConnectorProperties) SetTrendmicro(v *TrendmicroSourceProperties) *SourceConnectorProperties

SetTrendmicro sets the Trendmicro field's value.

func (*SourceConnectorProperties) SetVeeva

func (s *SourceConnectorProperties) SetVeeva(v *VeevaSourceProperties) *SourceConnectorProperties

SetVeeva sets the Veeva field's value.

func (*SourceConnectorProperties) SetZendesk

func (s *SourceConnectorProperties) SetZendesk(v *ZendeskSourceProperties) *SourceConnectorProperties

SetZendesk sets the Zendesk field's value.

func (SourceConnectorProperties) String

func (s SourceConnectorProperties) String() string

String returns the string representation

func (*SourceConnectorProperties) Validate

func (s *SourceConnectorProperties) Validate() error

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

type SourceFieldProperties

type SourceFieldProperties struct {

    // Indicates if the field can be queried.
    IsQueryable *bool `locationName:"isQueryable" type:"boolean"`

    // Indicates whether the field can be returned in a search result.
    IsRetrievable *bool `locationName:"isRetrievable" type:"boolean"`
    // contains filtered or unexported fields
}

The properties that can be applied to a field when the connector is being used as a source.

func (SourceFieldProperties) GoString

func (s SourceFieldProperties) GoString() string

GoString returns the string representation

func (*SourceFieldProperties) SetIsQueryable

func (s *SourceFieldProperties) SetIsQueryable(v bool) *SourceFieldProperties

SetIsQueryable sets the IsQueryable field's value.

func (*SourceFieldProperties) SetIsRetrievable

func (s *SourceFieldProperties) SetIsRetrievable(v bool) *SourceFieldProperties

SetIsRetrievable sets the IsRetrievable field's value.

func (SourceFieldProperties) String

func (s SourceFieldProperties) String() string

String returns the string representation

type SourceFlowConfig

type SourceFlowConfig struct {

    // The name of the connector profile. This name must be unique for each connector
    // profile in the AWS account.
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string"`

    // The type of connector, such as Salesforce, Amplitude, and so on.
    //
    // ConnectorType is a required field
    ConnectorType *string `locationName:"connectorType" type:"string" required:"true" enum:"ConnectorType"`

    // Defines the configuration for a scheduled incremental data pull. If a valid
    // configuration is provided, the fields specified in the configuration are
    // used when querying for the incremental data pull.
    IncrementalPullConfig *IncrementalPullConfig `locationName:"incrementalPullConfig" type:"structure"`

    // Specifies the information that is required to query a particular source connector.
    //
    // SourceConnectorProperties is a required field
    SourceConnectorProperties *SourceConnectorProperties `locationName:"sourceConnectorProperties" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

Contains information about the configuration of the source connector used in the flow.

func (SourceFlowConfig) GoString

func (s SourceFlowConfig) GoString() string

GoString returns the string representation

func (*SourceFlowConfig) SetConnectorProfileName

func (s *SourceFlowConfig) SetConnectorProfileName(v string) *SourceFlowConfig

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (*SourceFlowConfig) SetConnectorType

func (s *SourceFlowConfig) SetConnectorType(v string) *SourceFlowConfig

SetConnectorType sets the ConnectorType field's value.

func (*SourceFlowConfig) SetIncrementalPullConfig

func (s *SourceFlowConfig) SetIncrementalPullConfig(v *IncrementalPullConfig) *SourceFlowConfig

SetIncrementalPullConfig sets the IncrementalPullConfig field's value.

func (*SourceFlowConfig) SetSourceConnectorProperties

func (s *SourceFlowConfig) SetSourceConnectorProperties(v *SourceConnectorProperties) *SourceFlowConfig

SetSourceConnectorProperties sets the SourceConnectorProperties field's value.

func (SourceFlowConfig) String

func (s SourceFlowConfig) String() string

String returns the string representation

func (*SourceFlowConfig) Validate

func (s *SourceFlowConfig) Validate() error

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

type StartFlowInput

type StartFlowInput struct {

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (StartFlowInput) GoString

func (s StartFlowInput) GoString() string

GoString returns the string representation

func (*StartFlowInput) SetFlowName

func (s *StartFlowInput) SetFlowName(v string) *StartFlowInput

SetFlowName sets the FlowName field's value.

func (StartFlowInput) String

func (s StartFlowInput) String() string

String returns the string representation

func (*StartFlowInput) Validate

func (s *StartFlowInput) Validate() error

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

type StartFlowOutput

type StartFlowOutput struct {

    // Returns the internal execution ID of an on-demand flow when the flow is started.
    // For scheduled or event-triggered flows, this value is null.
    ExecutionId *string `locationName:"executionId" type:"string"`

    // The flow's Amazon Resource Name (ARN).
    FlowArn *string `locationName:"flowArn" type:"string"`

    // Indicates the current status of the flow.
    FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
    // contains filtered or unexported fields
}

func (StartFlowOutput) GoString

func (s StartFlowOutput) GoString() string

GoString returns the string representation

func (*StartFlowOutput) SetExecutionId

func (s *StartFlowOutput) SetExecutionId(v string) *StartFlowOutput

SetExecutionId sets the ExecutionId field's value.

func (*StartFlowOutput) SetFlowArn

func (s *StartFlowOutput) SetFlowArn(v string) *StartFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*StartFlowOutput) SetFlowStatus

func (s *StartFlowOutput) SetFlowStatus(v string) *StartFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (StartFlowOutput) String

func (s StartFlowOutput) String() string

String returns the string representation

type StopFlowInput

type StopFlowInput struct {

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (StopFlowInput) GoString

func (s StopFlowInput) GoString() string

GoString returns the string representation

func (*StopFlowInput) SetFlowName

func (s *StopFlowInput) SetFlowName(v string) *StopFlowInput

SetFlowName sets the FlowName field's value.

func (StopFlowInput) String

func (s StopFlowInput) String() string

String returns the string representation

func (*StopFlowInput) Validate

func (s *StopFlowInput) Validate() error

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

type StopFlowOutput

type StopFlowOutput struct {

    // The flow's Amazon Resource Name (ARN).
    FlowArn *string `locationName:"flowArn" type:"string"`

    // Indicates the current status of the flow.
    FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
    // contains filtered or unexported fields
}

func (StopFlowOutput) GoString

func (s StopFlowOutput) GoString() string

GoString returns the string representation

func (*StopFlowOutput) SetFlowArn

func (s *StopFlowOutput) SetFlowArn(v string) *StopFlowOutput

SetFlowArn sets the FlowArn field's value.

func (*StopFlowOutput) SetFlowStatus

func (s *StopFlowOutput) SetFlowStatus(v string) *StopFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (StopFlowOutput) String

func (s StopFlowOutput) String() string

String returns the string representation

type SupportedFieldTypeDetails

type SupportedFieldTypeDetails struct {

    // The initial supported version for fieldType. If this is later changed to
    // a different version, v2 will be introduced.
    //
    // V1 is a required field
    V1 *FieldTypeDetails `locationName:"v1" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

Contains details regarding all the supported FieldTypes and their corresponding filterOperators and supportedValues.

func (SupportedFieldTypeDetails) GoString

func (s SupportedFieldTypeDetails) GoString() string

GoString returns the string representation

func (*SupportedFieldTypeDetails) SetV1

func (s *SupportedFieldTypeDetails) SetV1(v *FieldTypeDetails) *SupportedFieldTypeDetails

SetV1 sets the V1 field's value.

func (SupportedFieldTypeDetails) String

func (s SupportedFieldTypeDetails) String() string

String returns the string representation

type TagResourceInput

type TagResourceInput struct {

    // The Amazon Resource Name (ARN) of the flow that you want to tag.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

    // The tags used to organize, track, or control access for your flow.
    //
    // Tags is a required field
    Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
    // contains filtered or unexported fields
}

func (TagResourceInput) GoString

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (*TagResourceInput) SetResourceArn

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate

func (s *TagResourceInput) Validate() error

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

type TagResourceOutput

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

func (TagResourceOutput) GoString

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation

type Task

type Task struct {

    // The operation to be performed on the provided source fields.
    ConnectorOperator *ConnectorOperator `locationName:"connectorOperator" type:"structure"`

    // A field in a destination connector, or a field value against which Amazon
    // AppFlow validates a source field.
    DestinationField *string `locationName:"destinationField" type:"string"`

    // The source fields to which a particular task is applied.
    //
    // SourceFields is a required field
    SourceFields []*string `locationName:"sourceFields" type:"list" required:"true"`

    // A map used to store task-related information. The execution service looks
    // for particular information based on the TaskType.
    TaskProperties map[string]*string `locationName:"taskProperties" type:"map"`

    // Specifies the particular task implementation that Amazon AppFlow performs.
    //
    // TaskType is a required field
    TaskType *string `locationName:"taskType" type:"string" required:"true" enum:"TaskType"`
    // contains filtered or unexported fields
}

A class for modeling different type of tasks. Task implementation varies based on the TaskType.

func (Task) GoString

func (s Task) GoString() string

GoString returns the string representation

func (*Task) SetConnectorOperator

func (s *Task) SetConnectorOperator(v *ConnectorOperator) *Task

SetConnectorOperator sets the ConnectorOperator field's value.

func (*Task) SetDestinationField

func (s *Task) SetDestinationField(v string) *Task

SetDestinationField sets the DestinationField field's value.

func (*Task) SetSourceFields

func (s *Task) SetSourceFields(v []*string) *Task

SetSourceFields sets the SourceFields field's value.

func (*Task) SetTaskProperties

func (s *Task) SetTaskProperties(v map[string]*string) *Task

SetTaskProperties sets the TaskProperties field's value.

func (*Task) SetTaskType

func (s *Task) SetTaskType(v string) *Task

SetTaskType sets the TaskType field's value.

func (Task) String

func (s Task) String() string

String returns the string representation

func (*Task) Validate

func (s *Task) Validate() error

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

type TrendmicroConnectorProfileCredentials

type TrendmicroConnectorProfileCredentials struct {

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

The connector-specific profile credentials required when using Trend Micro.

func (TrendmicroConnectorProfileCredentials) GoString

func (s TrendmicroConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*TrendmicroConnectorProfileCredentials) SetApiSecretKey

func (s *TrendmicroConnectorProfileCredentials) SetApiSecretKey(v string) *TrendmicroConnectorProfileCredentials

SetApiSecretKey sets the ApiSecretKey field's value.

func (TrendmicroConnectorProfileCredentials) String

func (s TrendmicroConnectorProfileCredentials) String() string

String returns the string representation

func (*TrendmicroConnectorProfileCredentials) Validate

func (s *TrendmicroConnectorProfileCredentials) Validate() error

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

type TrendmicroConnectorProfileProperties

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

The connector-specific profile properties required when using Trend Micro.

func (TrendmicroConnectorProfileProperties) GoString

func (s TrendmicroConnectorProfileProperties) GoString() string

GoString returns the string representation

func (TrendmicroConnectorProfileProperties) String

func (s TrendmicroConnectorProfileProperties) String() string

String returns the string representation

type TrendmicroMetadata

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

The connector metadata specific to Trend Micro.

func (TrendmicroMetadata) GoString

func (s TrendmicroMetadata) GoString() string

GoString returns the string representation

func (TrendmicroMetadata) String

func (s TrendmicroMetadata) String() string

String returns the string representation

type TrendmicroSourceProperties

type TrendmicroSourceProperties struct {

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

The properties that are applied when using Trend Micro as a flow source.

func (TrendmicroSourceProperties) GoString

func (s TrendmicroSourceProperties) GoString() string

GoString returns the string representation

func (*TrendmicroSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (TrendmicroSourceProperties) String

func (s TrendmicroSourceProperties) String() string

String returns the string representation

func (*TrendmicroSourceProperties) Validate

func (s *TrendmicroSourceProperties) Validate() error

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

type TriggerConfig

type TriggerConfig struct {

    // Specifies the configuration details of a schedule-triggered flow as defined
    // by the user. Currently, these settings only apply to the Scheduled trigger
    // type.
    TriggerProperties *TriggerProperties `locationName:"triggerProperties" type:"structure"`

    // Specifies the type of flow trigger. This can be OnDemand, Scheduled, or Event.
    //
    // TriggerType is a required field
    TriggerType *string `locationName:"triggerType" type:"string" required:"true" enum:"TriggerType"`
    // contains filtered or unexported fields
}

The trigger settings that determine how and when Amazon AppFlow runs the specified flow.

func (TriggerConfig) GoString

func (s TriggerConfig) GoString() string

GoString returns the string representation

func (*TriggerConfig) SetTriggerProperties

func (s *TriggerConfig) SetTriggerProperties(v *TriggerProperties) *TriggerConfig

SetTriggerProperties sets the TriggerProperties field's value.

func (*TriggerConfig) SetTriggerType

func (s *TriggerConfig) SetTriggerType(v string) *TriggerConfig

SetTriggerType sets the TriggerType field's value.

func (TriggerConfig) String

func (s TriggerConfig) String() string

String returns the string representation

func (*TriggerConfig) Validate

func (s *TriggerConfig) Validate() error

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

type TriggerProperties

type TriggerProperties struct {

    // Specifies the configuration details of a schedule-triggered flow as defined
    // by the user.
    Scheduled *ScheduledTriggerProperties `type:"structure"`
    // contains filtered or unexported fields
}

Specifies the configuration details that control the trigger for a flow. Currently, these settings only apply to the Scheduled trigger type.

func (TriggerProperties) GoString

func (s TriggerProperties) GoString() string

GoString returns the string representation

func (*TriggerProperties) SetScheduled

func (s *TriggerProperties) SetScheduled(v *ScheduledTriggerProperties) *TriggerProperties

SetScheduled sets the Scheduled field's value.

func (TriggerProperties) String

func (s TriggerProperties) String() string

String returns the string representation

func (*TriggerProperties) Validate

func (s *TriggerProperties) Validate() error

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

type UnsupportedOperationException

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

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

The requested operation is not supported for the current flow.

func (*UnsupportedOperationException) Code

func (s *UnsupportedOperationException) Code() string

Code returns the exception type name.

func (*UnsupportedOperationException) Error

func (s *UnsupportedOperationException) Error() string

func (UnsupportedOperationException) GoString

func (s UnsupportedOperationException) GoString() string

GoString returns the string representation

func (*UnsupportedOperationException) Message

func (s *UnsupportedOperationException) Message() string

Message returns the exception's message.

func (*UnsupportedOperationException) OrigErr

func (s *UnsupportedOperationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*UnsupportedOperationException) RequestID

func (s *UnsupportedOperationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*UnsupportedOperationException) StatusCode

func (s *UnsupportedOperationException) StatusCode() int

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

func (UnsupportedOperationException) String

func (s UnsupportedOperationException) String() string

String returns the string representation

type UntagResourceInput

type UntagResourceInput struct {

    // The Amazon Resource Name (ARN) of the flow that you want to untag.
    //
    // ResourceArn is a required field
    ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`

    // The tag keys associated with the tag that you want to remove from your flow.
    //
    // TagKeys is a required field
    TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
    // contains filtered or unexported fields
}

func (UntagResourceInput) GoString

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (*UntagResourceInput) SetResourceArn

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate

func (s *UntagResourceInput) Validate() error

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

type UntagResourceOutput

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

func (UntagResourceOutput) GoString

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation

type UpdateConnectorProfileInput

type UpdateConnectorProfileInput struct {

    // Indicates the connection mode and if it is public or private.
    //
    // ConnectionMode is a required field
    ConnectionMode *string `locationName:"connectionMode" type:"string" required:"true" enum:"ConnectionMode"`

    // Defines the connector-specific profile configuration and credentials.
    //
    // ConnectorProfileConfig is a required field
    ConnectorProfileConfig *ConnectorProfileConfig `locationName:"connectorProfileConfig" type:"structure" required:"true"`

    // The name of the connector profile and is unique for each ConnectorProfile
    // in the AWS Account.
    //
    // ConnectorProfileName is a required field
    ConnectorProfileName *string `locationName:"connectorProfileName" type:"string" required:"true"`
    // contains filtered or unexported fields
}

func (UpdateConnectorProfileInput) GoString

func (s UpdateConnectorProfileInput) GoString() string

GoString returns the string representation

func (*UpdateConnectorProfileInput) SetConnectionMode

func (s *UpdateConnectorProfileInput) SetConnectionMode(v string) *UpdateConnectorProfileInput

SetConnectionMode sets the ConnectionMode field's value.

func (*UpdateConnectorProfileInput) SetConnectorProfileConfig

func (s *UpdateConnectorProfileInput) SetConnectorProfileConfig(v *ConnectorProfileConfig) *UpdateConnectorProfileInput

SetConnectorProfileConfig sets the ConnectorProfileConfig field's value.

func (*UpdateConnectorProfileInput) SetConnectorProfileName

func (s *UpdateConnectorProfileInput) SetConnectorProfileName(v string) *UpdateConnectorProfileInput

SetConnectorProfileName sets the ConnectorProfileName field's value.

func (UpdateConnectorProfileInput) String

func (s UpdateConnectorProfileInput) String() string

String returns the string representation

func (*UpdateConnectorProfileInput) Validate

func (s *UpdateConnectorProfileInput) Validate() error

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

type UpdateConnectorProfileOutput

type UpdateConnectorProfileOutput struct {

    // The Amazon Resource Name (ARN) of the connector profile.
    ConnectorProfileArn *string `locationName:"connectorProfileArn" type:"string"`
    // contains filtered or unexported fields
}

func (UpdateConnectorProfileOutput) GoString

func (s UpdateConnectorProfileOutput) GoString() string

GoString returns the string representation

func (*UpdateConnectorProfileOutput) SetConnectorProfileArn

func (s *UpdateConnectorProfileOutput) SetConnectorProfileArn(v string) *UpdateConnectorProfileOutput

SetConnectorProfileArn sets the ConnectorProfileArn field's value.

func (UpdateConnectorProfileOutput) String

func (s UpdateConnectorProfileOutput) String() string

String returns the string representation

type UpdateFlowInput

type UpdateFlowInput struct {

    // A description of the flow.
    Description *string `locationName:"description" type:"string"`

    // The configuration that controls how Amazon AppFlow transfers data to the
    // destination connector.
    //
    // DestinationFlowConfigList is a required field
    DestinationFlowConfigList []*DestinationFlowConfig `locationName:"destinationFlowConfigList" type:"list" required:"true"`

    // The specified name of the flow. Spaces are not allowed. Use underscores (_)
    // or hyphens (-) only.
    //
    // FlowName is a required field
    FlowName *string `locationName:"flowName" type:"string" required:"true"`

    // Contains information about the configuration of the source connector used
    // in the flow.
    SourceFlowConfig *SourceFlowConfig `locationName:"sourceFlowConfig" type:"structure"`

    // A list of tasks that Amazon AppFlow performs while transferring the data
    // in the flow run.
    //
    // Tasks is a required field
    Tasks []*Task `locationName:"tasks" type:"list" required:"true"`

    // The trigger settings that determine how and when the flow runs.
    //
    // TriggerConfig is a required field
    TriggerConfig *TriggerConfig `locationName:"triggerConfig" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

func (UpdateFlowInput) GoString

func (s UpdateFlowInput) GoString() string

GoString returns the string representation

func (*UpdateFlowInput) SetDescription

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

SetDescription sets the Description field's value.

func (*UpdateFlowInput) SetDestinationFlowConfigList

func (s *UpdateFlowInput) SetDestinationFlowConfigList(v []*DestinationFlowConfig) *UpdateFlowInput

SetDestinationFlowConfigList sets the DestinationFlowConfigList field's value.

func (*UpdateFlowInput) SetFlowName

func (s *UpdateFlowInput) SetFlowName(v string) *UpdateFlowInput

SetFlowName sets the FlowName field's value.

func (*UpdateFlowInput) SetSourceFlowConfig

func (s *UpdateFlowInput) SetSourceFlowConfig(v *SourceFlowConfig) *UpdateFlowInput

SetSourceFlowConfig sets the SourceFlowConfig field's value.

func (*UpdateFlowInput) SetTasks

func (s *UpdateFlowInput) SetTasks(v []*Task) *UpdateFlowInput

SetTasks sets the Tasks field's value.

func (*UpdateFlowInput) SetTriggerConfig

func (s *UpdateFlowInput) SetTriggerConfig(v *TriggerConfig) *UpdateFlowInput

SetTriggerConfig sets the TriggerConfig field's value.

func (UpdateFlowInput) String

func (s UpdateFlowInput) String() string

String returns the string representation

func (*UpdateFlowInput) Validate

func (s *UpdateFlowInput) Validate() error

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

type UpdateFlowOutput

type UpdateFlowOutput struct {

    // Indicates the current status of the flow.
    FlowStatus *string `locationName:"flowStatus" type:"string" enum:"FlowStatus"`
    // contains filtered or unexported fields
}

func (UpdateFlowOutput) GoString

func (s UpdateFlowOutput) GoString() string

GoString returns the string representation

func (*UpdateFlowOutput) SetFlowStatus

func (s *UpdateFlowOutput) SetFlowStatus(v string) *UpdateFlowOutput

SetFlowStatus sets the FlowStatus field's value.

func (UpdateFlowOutput) String

func (s UpdateFlowOutput) String() string

String returns the string representation

type UpsolverDestinationProperties

type UpsolverDestinationProperties struct {

    // The Upsolver Amazon S3 bucket name in which Amazon AppFlow places the transferred
    // data.
    //
    // BucketName is a required field
    BucketName *string `locationName:"bucketName" min:"16" type:"string" required:"true"`

    // The object key for the destination Upsolver Amazon S3 bucket in which Amazon
    // AppFlow places the files.
    BucketPrefix *string `locationName:"bucketPrefix" type:"string"`

    // The configuration that determines how data is formatted when Upsolver is
    // used as the flow destination.
    //
    // S3OutputFormatConfig is a required field
    S3OutputFormatConfig *UpsolverS3OutputFormatConfig `locationName:"s3OutputFormatConfig" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

The properties that are applied when Upsolver is used as a destination.

func (UpsolverDestinationProperties) GoString

func (s UpsolverDestinationProperties) GoString() string

GoString returns the string representation

func (*UpsolverDestinationProperties) SetBucketName

func (s *UpsolverDestinationProperties) SetBucketName(v string) *UpsolverDestinationProperties

SetBucketName sets the BucketName field's value.

func (*UpsolverDestinationProperties) SetBucketPrefix

func (s *UpsolverDestinationProperties) SetBucketPrefix(v string) *UpsolverDestinationProperties

SetBucketPrefix sets the BucketPrefix field's value.

func (*UpsolverDestinationProperties) SetS3OutputFormatConfig

func (s *UpsolverDestinationProperties) SetS3OutputFormatConfig(v *UpsolverS3OutputFormatConfig) *UpsolverDestinationProperties

SetS3OutputFormatConfig sets the S3OutputFormatConfig field's value.

func (UpsolverDestinationProperties) String

func (s UpsolverDestinationProperties) String() string

String returns the string representation

func (*UpsolverDestinationProperties) Validate

func (s *UpsolverDestinationProperties) Validate() error

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

type UpsolverMetadata

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

The connector metadata specific to Upsolver.

func (UpsolverMetadata) GoString

func (s UpsolverMetadata) GoString() string

GoString returns the string representation

func (UpsolverMetadata) String

func (s UpsolverMetadata) String() string

String returns the string representation

type UpsolverS3OutputFormatConfig

type UpsolverS3OutputFormatConfig struct {

    // The aggregation settings that you can use to customize the output format
    // of your flow data.
    AggregationConfig *AggregationConfig `locationName:"aggregationConfig" type:"structure"`

    // Indicates the file type that Amazon AppFlow places in the Upsolver Amazon
    // S3 bucket.
    FileType *string `locationName:"fileType" type:"string" enum:"FileType"`

    // Determines the prefix that Amazon AppFlow applies to the destination folder
    // name. You can name your destination folders according to the flow frequency
    // and date.
    //
    // PrefixConfig is a required field
    PrefixConfig *PrefixConfig `locationName:"prefixConfig" type:"structure" required:"true"`
    // contains filtered or unexported fields
}

The configuration that determines how Amazon AppFlow formats the flow output data when Upsolver is used as the destination.

func (UpsolverS3OutputFormatConfig) GoString

func (s UpsolverS3OutputFormatConfig) GoString() string

GoString returns the string representation

func (*UpsolverS3OutputFormatConfig) SetAggregationConfig

func (s *UpsolverS3OutputFormatConfig) SetAggregationConfig(v *AggregationConfig) *UpsolverS3OutputFormatConfig

SetAggregationConfig sets the AggregationConfig field's value.

func (*UpsolverS3OutputFormatConfig) SetFileType

func (s *UpsolverS3OutputFormatConfig) SetFileType(v string) *UpsolverS3OutputFormatConfig

SetFileType sets the FileType field's value.

func (*UpsolverS3OutputFormatConfig) SetPrefixConfig

func (s *UpsolverS3OutputFormatConfig) SetPrefixConfig(v *PrefixConfig) *UpsolverS3OutputFormatConfig

SetPrefixConfig sets the PrefixConfig field's value.

func (UpsolverS3OutputFormatConfig) String

func (s UpsolverS3OutputFormatConfig) String() string

String returns the string representation

func (*UpsolverS3OutputFormatConfig) Validate

func (s *UpsolverS3OutputFormatConfig) Validate() error

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

type ValidationException

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

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

The request has invalid or missing parameters.

func (*ValidationException) Code

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error

func (s *ValidationException) Error() string

func (ValidationException) GoString

func (s ValidationException) GoString() string

GoString returns the string representation

func (*ValidationException) Message

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode

func (s *ValidationException) StatusCode() int

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

func (ValidationException) String

func (s ValidationException) String() string

String returns the string representation

type VeevaConnectorProfileCredentials

type VeevaConnectorProfileCredentials struct {

    // The password that corresponds to the user name.
    //
    // Password is a required field
    Password *string `locationName:"password" type:"string" required:"true" sensitive:"true"`

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

The connector-specific profile credentials required when using Veeva.

func (VeevaConnectorProfileCredentials) GoString

func (s VeevaConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*VeevaConnectorProfileCredentials) SetPassword

func (s *VeevaConnectorProfileCredentials) SetPassword(v string) *VeevaConnectorProfileCredentials

SetPassword sets the Password field's value.

func (*VeevaConnectorProfileCredentials) SetUsername

func (s *VeevaConnectorProfileCredentials) SetUsername(v string) *VeevaConnectorProfileCredentials

SetUsername sets the Username field's value.

func (VeevaConnectorProfileCredentials) String

func (s VeevaConnectorProfileCredentials) String() string

String returns the string representation

func (*VeevaConnectorProfileCredentials) Validate

func (s *VeevaConnectorProfileCredentials) Validate() error

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

type VeevaConnectorProfileProperties

type VeevaConnectorProfileProperties struct {

    // The location of the Veeva resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using Veeva.

func (VeevaConnectorProfileProperties) GoString

func (s VeevaConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*VeevaConnectorProfileProperties) SetInstanceUrl

func (s *VeevaConnectorProfileProperties) SetInstanceUrl(v string) *VeevaConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (VeevaConnectorProfileProperties) String

func (s VeevaConnectorProfileProperties) String() string

String returns the string representation

func (*VeevaConnectorProfileProperties) Validate

func (s *VeevaConnectorProfileProperties) Validate() error

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

type VeevaMetadata

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

The connector metadata specific to Veeva.

func (VeevaMetadata) GoString

func (s VeevaMetadata) GoString() string

GoString returns the string representation

func (VeevaMetadata) String

func (s VeevaMetadata) String() string

String returns the string representation

type VeevaSourceProperties

type VeevaSourceProperties struct {

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

The properties that are applied when using Veeva as a flow source.

func (VeevaSourceProperties) GoString

func (s VeevaSourceProperties) GoString() string

GoString returns the string representation

func (*VeevaSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (VeevaSourceProperties) String

func (s VeevaSourceProperties) String() string

String returns the string representation

func (*VeevaSourceProperties) Validate

func (s *VeevaSourceProperties) Validate() error

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

type ZendeskConnectorProfileCredentials

type ZendeskConnectorProfileCredentials struct {

    // The credentials used to access protected Zendesk resources.
    AccessToken *string `locationName:"accessToken" type:"string" sensitive:"true"`

    // The identifier for the desired client.
    //
    // ClientId is a required field
    ClientId *string `locationName:"clientId" type:"string" required:"true"`

    // The client secret used by the OAuth client to authenticate to the authorization
    // server.
    //
    // ClientSecret is a required field
    ClientSecret *string `locationName:"clientSecret" type:"string" required:"true" sensitive:"true"`

    // The OAuth requirement needed to request security tokens from the connector
    // endpoint.
    OAuthRequest *ConnectorOAuthRequest `locationName:"oAuthRequest" type:"structure"`
    // contains filtered or unexported fields
}

The connector-specific profile credentials required when using Zendesk.

func (ZendeskConnectorProfileCredentials) GoString

func (s ZendeskConnectorProfileCredentials) GoString() string

GoString returns the string representation

func (*ZendeskConnectorProfileCredentials) SetAccessToken

func (s *ZendeskConnectorProfileCredentials) SetAccessToken(v string) *ZendeskConnectorProfileCredentials

SetAccessToken sets the AccessToken field's value.

func (*ZendeskConnectorProfileCredentials) SetClientId

func (s *ZendeskConnectorProfileCredentials) SetClientId(v string) *ZendeskConnectorProfileCredentials

SetClientId sets the ClientId field's value.

func (*ZendeskConnectorProfileCredentials) SetClientSecret

func (s *ZendeskConnectorProfileCredentials) SetClientSecret(v string) *ZendeskConnectorProfileCredentials

SetClientSecret sets the ClientSecret field's value.

func (*ZendeskConnectorProfileCredentials) SetOAuthRequest

func (s *ZendeskConnectorProfileCredentials) SetOAuthRequest(v *ConnectorOAuthRequest) *ZendeskConnectorProfileCredentials

SetOAuthRequest sets the OAuthRequest field's value.

func (ZendeskConnectorProfileCredentials) String

func (s ZendeskConnectorProfileCredentials) String() string

String returns the string representation

func (*ZendeskConnectorProfileCredentials) Validate

func (s *ZendeskConnectorProfileCredentials) Validate() error

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

type ZendeskConnectorProfileProperties

type ZendeskConnectorProfileProperties struct {

    // The location of the Zendesk resource.
    //
    // InstanceUrl is a required field
    InstanceUrl *string `locationName:"instanceUrl" type:"string" required:"true"`
    // contains filtered or unexported fields
}

The connector-specific profile properties required when using Zendesk.

func (ZendeskConnectorProfileProperties) GoString

func (s ZendeskConnectorProfileProperties) GoString() string

GoString returns the string representation

func (*ZendeskConnectorProfileProperties) SetInstanceUrl

func (s *ZendeskConnectorProfileProperties) SetInstanceUrl(v string) *ZendeskConnectorProfileProperties

SetInstanceUrl sets the InstanceUrl field's value.

func (ZendeskConnectorProfileProperties) String

func (s ZendeskConnectorProfileProperties) String() string

String returns the string representation

func (*ZendeskConnectorProfileProperties) Validate

func (s *ZendeskConnectorProfileProperties) Validate() error

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

type ZendeskMetadata

type ZendeskMetadata struct {

    // The desired authorization scope for the Zendesk account.
    OAuthScopes []*string `locationName:"oAuthScopes" type:"list"`
    // contains filtered or unexported fields
}

The connector metadata specific to Zendesk.

func (ZendeskMetadata) GoString

func (s ZendeskMetadata) GoString() string

GoString returns the string representation

func (*ZendeskMetadata) SetOAuthScopes

func (s *ZendeskMetadata) SetOAuthScopes(v []*string) *ZendeskMetadata

SetOAuthScopes sets the OAuthScopes field's value.

func (ZendeskMetadata) String

func (s ZendeskMetadata) String() string

String returns the string representation

type ZendeskSourceProperties

type ZendeskSourceProperties struct {

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

The properties that are applied when using Zendesk as a flow source.

func (ZendeskSourceProperties) GoString

func (s ZendeskSourceProperties) GoString() string

GoString returns the string representation

func (*ZendeskSourceProperties) SetObject

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

SetObject sets the Object field's value.

func (ZendeskSourceProperties) String

func (s ZendeskSourceProperties) String() string

String returns the string representation

func (*ZendeskSourceProperties) Validate

func (s *ZendeskSourceProperties) Validate() error

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