1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package appflow 4 5import ( 6 "context" 7 "fmt" 8 "github.com/aws/aws-sdk-go-v2/service/appflow/types" 9 smithy "github.com/aws/smithy-go" 10 "github.com/aws/smithy-go/middleware" 11) 12 13type validateOpCreateConnectorProfile struct { 14} 15 16func (*validateOpCreateConnectorProfile) ID() string { 17 return "OperationInputValidation" 18} 19 20func (m *validateOpCreateConnectorProfile) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 21 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 22) { 23 input, ok := in.Parameters.(*CreateConnectorProfileInput) 24 if !ok { 25 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 26 } 27 if err := validateOpCreateConnectorProfileInput(input); err != nil { 28 return out, metadata, err 29 } 30 return next.HandleInitialize(ctx, in) 31} 32 33type validateOpCreateFlow struct { 34} 35 36func (*validateOpCreateFlow) ID() string { 37 return "OperationInputValidation" 38} 39 40func (m *validateOpCreateFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 41 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 42) { 43 input, ok := in.Parameters.(*CreateFlowInput) 44 if !ok { 45 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 46 } 47 if err := validateOpCreateFlowInput(input); err != nil { 48 return out, metadata, err 49 } 50 return next.HandleInitialize(ctx, in) 51} 52 53type validateOpDeleteConnectorProfile struct { 54} 55 56func (*validateOpDeleteConnectorProfile) ID() string { 57 return "OperationInputValidation" 58} 59 60func (m *validateOpDeleteConnectorProfile) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 61 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 62) { 63 input, ok := in.Parameters.(*DeleteConnectorProfileInput) 64 if !ok { 65 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 66 } 67 if err := validateOpDeleteConnectorProfileInput(input); err != nil { 68 return out, metadata, err 69 } 70 return next.HandleInitialize(ctx, in) 71} 72 73type validateOpDeleteFlow struct { 74} 75 76func (*validateOpDeleteFlow) ID() string { 77 return "OperationInputValidation" 78} 79 80func (m *validateOpDeleteFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 81 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 82) { 83 input, ok := in.Parameters.(*DeleteFlowInput) 84 if !ok { 85 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 86 } 87 if err := validateOpDeleteFlowInput(input); err != nil { 88 return out, metadata, err 89 } 90 return next.HandleInitialize(ctx, in) 91} 92 93type validateOpDescribeConnectorEntity struct { 94} 95 96func (*validateOpDescribeConnectorEntity) ID() string { 97 return "OperationInputValidation" 98} 99 100func (m *validateOpDescribeConnectorEntity) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 101 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 102) { 103 input, ok := in.Parameters.(*DescribeConnectorEntityInput) 104 if !ok { 105 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 106 } 107 if err := validateOpDescribeConnectorEntityInput(input); err != nil { 108 return out, metadata, err 109 } 110 return next.HandleInitialize(ctx, in) 111} 112 113type validateOpDescribeFlowExecutionRecords struct { 114} 115 116func (*validateOpDescribeFlowExecutionRecords) ID() string { 117 return "OperationInputValidation" 118} 119 120func (m *validateOpDescribeFlowExecutionRecords) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 121 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 122) { 123 input, ok := in.Parameters.(*DescribeFlowExecutionRecordsInput) 124 if !ok { 125 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 126 } 127 if err := validateOpDescribeFlowExecutionRecordsInput(input); err != nil { 128 return out, metadata, err 129 } 130 return next.HandleInitialize(ctx, in) 131} 132 133type validateOpDescribeFlow struct { 134} 135 136func (*validateOpDescribeFlow) ID() string { 137 return "OperationInputValidation" 138} 139 140func (m *validateOpDescribeFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 141 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 142) { 143 input, ok := in.Parameters.(*DescribeFlowInput) 144 if !ok { 145 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 146 } 147 if err := validateOpDescribeFlowInput(input); err != nil { 148 return out, metadata, err 149 } 150 return next.HandleInitialize(ctx, in) 151} 152 153type validateOpListTagsForResource struct { 154} 155 156func (*validateOpListTagsForResource) ID() string { 157 return "OperationInputValidation" 158} 159 160func (m *validateOpListTagsForResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 161 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 162) { 163 input, ok := in.Parameters.(*ListTagsForResourceInput) 164 if !ok { 165 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 166 } 167 if err := validateOpListTagsForResourceInput(input); err != nil { 168 return out, metadata, err 169 } 170 return next.HandleInitialize(ctx, in) 171} 172 173type validateOpStartFlow struct { 174} 175 176func (*validateOpStartFlow) ID() string { 177 return "OperationInputValidation" 178} 179 180func (m *validateOpStartFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 181 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 182) { 183 input, ok := in.Parameters.(*StartFlowInput) 184 if !ok { 185 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 186 } 187 if err := validateOpStartFlowInput(input); err != nil { 188 return out, metadata, err 189 } 190 return next.HandleInitialize(ctx, in) 191} 192 193type validateOpStopFlow struct { 194} 195 196func (*validateOpStopFlow) ID() string { 197 return "OperationInputValidation" 198} 199 200func (m *validateOpStopFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 201 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 202) { 203 input, ok := in.Parameters.(*StopFlowInput) 204 if !ok { 205 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 206 } 207 if err := validateOpStopFlowInput(input); err != nil { 208 return out, metadata, err 209 } 210 return next.HandleInitialize(ctx, in) 211} 212 213type validateOpTagResource struct { 214} 215 216func (*validateOpTagResource) ID() string { 217 return "OperationInputValidation" 218} 219 220func (m *validateOpTagResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 221 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 222) { 223 input, ok := in.Parameters.(*TagResourceInput) 224 if !ok { 225 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 226 } 227 if err := validateOpTagResourceInput(input); err != nil { 228 return out, metadata, err 229 } 230 return next.HandleInitialize(ctx, in) 231} 232 233type validateOpUntagResource struct { 234} 235 236func (*validateOpUntagResource) ID() string { 237 return "OperationInputValidation" 238} 239 240func (m *validateOpUntagResource) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 241 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 242) { 243 input, ok := in.Parameters.(*UntagResourceInput) 244 if !ok { 245 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 246 } 247 if err := validateOpUntagResourceInput(input); err != nil { 248 return out, metadata, err 249 } 250 return next.HandleInitialize(ctx, in) 251} 252 253type validateOpUpdateConnectorProfile struct { 254} 255 256func (*validateOpUpdateConnectorProfile) ID() string { 257 return "OperationInputValidation" 258} 259 260func (m *validateOpUpdateConnectorProfile) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 261 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 262) { 263 input, ok := in.Parameters.(*UpdateConnectorProfileInput) 264 if !ok { 265 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 266 } 267 if err := validateOpUpdateConnectorProfileInput(input); err != nil { 268 return out, metadata, err 269 } 270 return next.HandleInitialize(ctx, in) 271} 272 273type validateOpUpdateFlow struct { 274} 275 276func (*validateOpUpdateFlow) ID() string { 277 return "OperationInputValidation" 278} 279 280func (m *validateOpUpdateFlow) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 281 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 282) { 283 input, ok := in.Parameters.(*UpdateFlowInput) 284 if !ok { 285 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 286 } 287 if err := validateOpUpdateFlowInput(input); err != nil { 288 return out, metadata, err 289 } 290 return next.HandleInitialize(ctx, in) 291} 292 293func addOpCreateConnectorProfileValidationMiddleware(stack *middleware.Stack) error { 294 return stack.Initialize.Add(&validateOpCreateConnectorProfile{}, middleware.After) 295} 296 297func addOpCreateFlowValidationMiddleware(stack *middleware.Stack) error { 298 return stack.Initialize.Add(&validateOpCreateFlow{}, middleware.After) 299} 300 301func addOpDeleteConnectorProfileValidationMiddleware(stack *middleware.Stack) error { 302 return stack.Initialize.Add(&validateOpDeleteConnectorProfile{}, middleware.After) 303} 304 305func addOpDeleteFlowValidationMiddleware(stack *middleware.Stack) error { 306 return stack.Initialize.Add(&validateOpDeleteFlow{}, middleware.After) 307} 308 309func addOpDescribeConnectorEntityValidationMiddleware(stack *middleware.Stack) error { 310 return stack.Initialize.Add(&validateOpDescribeConnectorEntity{}, middleware.After) 311} 312 313func addOpDescribeFlowExecutionRecordsValidationMiddleware(stack *middleware.Stack) error { 314 return stack.Initialize.Add(&validateOpDescribeFlowExecutionRecords{}, middleware.After) 315} 316 317func addOpDescribeFlowValidationMiddleware(stack *middleware.Stack) error { 318 return stack.Initialize.Add(&validateOpDescribeFlow{}, middleware.After) 319} 320 321func addOpListTagsForResourceValidationMiddleware(stack *middleware.Stack) error { 322 return stack.Initialize.Add(&validateOpListTagsForResource{}, middleware.After) 323} 324 325func addOpStartFlowValidationMiddleware(stack *middleware.Stack) error { 326 return stack.Initialize.Add(&validateOpStartFlow{}, middleware.After) 327} 328 329func addOpStopFlowValidationMiddleware(stack *middleware.Stack) error { 330 return stack.Initialize.Add(&validateOpStopFlow{}, middleware.After) 331} 332 333func addOpTagResourceValidationMiddleware(stack *middleware.Stack) error { 334 return stack.Initialize.Add(&validateOpTagResource{}, middleware.After) 335} 336 337func addOpUntagResourceValidationMiddleware(stack *middleware.Stack) error { 338 return stack.Initialize.Add(&validateOpUntagResource{}, middleware.After) 339} 340 341func addOpUpdateConnectorProfileValidationMiddleware(stack *middleware.Stack) error { 342 return stack.Initialize.Add(&validateOpUpdateConnectorProfile{}, middleware.After) 343} 344 345func addOpUpdateFlowValidationMiddleware(stack *middleware.Stack) error { 346 return stack.Initialize.Add(&validateOpUpdateFlow{}, middleware.After) 347} 348 349func validateAmplitudeConnectorProfileCredentials(v *types.AmplitudeConnectorProfileCredentials) error { 350 if v == nil { 351 return nil 352 } 353 invalidParams := smithy.InvalidParamsError{Context: "AmplitudeConnectorProfileCredentials"} 354 if v.ApiKey == nil { 355 invalidParams.Add(smithy.NewErrParamRequired("ApiKey")) 356 } 357 if v.SecretKey == nil { 358 invalidParams.Add(smithy.NewErrParamRequired("SecretKey")) 359 } 360 if invalidParams.Len() > 0 { 361 return invalidParams 362 } else { 363 return nil 364 } 365} 366 367func validateAmplitudeSourceProperties(v *types.AmplitudeSourceProperties) error { 368 if v == nil { 369 return nil 370 } 371 invalidParams := smithy.InvalidParamsError{Context: "AmplitudeSourceProperties"} 372 if v.Object == nil { 373 invalidParams.Add(smithy.NewErrParamRequired("Object")) 374 } 375 if invalidParams.Len() > 0 { 376 return invalidParams 377 } else { 378 return nil 379 } 380} 381 382func validateConnectorProfileConfig(v *types.ConnectorProfileConfig) error { 383 if v == nil { 384 return nil 385 } 386 invalidParams := smithy.InvalidParamsError{Context: "ConnectorProfileConfig"} 387 if v.ConnectorProfileProperties == nil { 388 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileProperties")) 389 } else if v.ConnectorProfileProperties != nil { 390 if err := validateConnectorProfileProperties(v.ConnectorProfileProperties); err != nil { 391 invalidParams.AddNested("ConnectorProfileProperties", err.(smithy.InvalidParamsError)) 392 } 393 } 394 if v.ConnectorProfileCredentials == nil { 395 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileCredentials")) 396 } else if v.ConnectorProfileCredentials != nil { 397 if err := validateConnectorProfileCredentials(v.ConnectorProfileCredentials); err != nil { 398 invalidParams.AddNested("ConnectorProfileCredentials", err.(smithy.InvalidParamsError)) 399 } 400 } 401 if invalidParams.Len() > 0 { 402 return invalidParams 403 } else { 404 return nil 405 } 406} 407 408func validateConnectorProfileCredentials(v *types.ConnectorProfileCredentials) error { 409 if v == nil { 410 return nil 411 } 412 invalidParams := smithy.InvalidParamsError{Context: "ConnectorProfileCredentials"} 413 if v.Amplitude != nil { 414 if err := validateAmplitudeConnectorProfileCredentials(v.Amplitude); err != nil { 415 invalidParams.AddNested("Amplitude", err.(smithy.InvalidParamsError)) 416 } 417 } 418 if v.Datadog != nil { 419 if err := validateDatadogConnectorProfileCredentials(v.Datadog); err != nil { 420 invalidParams.AddNested("Datadog", err.(smithy.InvalidParamsError)) 421 } 422 } 423 if v.Dynatrace != nil { 424 if err := validateDynatraceConnectorProfileCredentials(v.Dynatrace); err != nil { 425 invalidParams.AddNested("Dynatrace", err.(smithy.InvalidParamsError)) 426 } 427 } 428 if v.GoogleAnalytics != nil { 429 if err := validateGoogleAnalyticsConnectorProfileCredentials(v.GoogleAnalytics); err != nil { 430 invalidParams.AddNested("GoogleAnalytics", err.(smithy.InvalidParamsError)) 431 } 432 } 433 if v.InforNexus != nil { 434 if err := validateInforNexusConnectorProfileCredentials(v.InforNexus); err != nil { 435 invalidParams.AddNested("InforNexus", err.(smithy.InvalidParamsError)) 436 } 437 } 438 if v.Marketo != nil { 439 if err := validateMarketoConnectorProfileCredentials(v.Marketo); err != nil { 440 invalidParams.AddNested("Marketo", err.(smithy.InvalidParamsError)) 441 } 442 } 443 if v.Redshift != nil { 444 if err := validateRedshiftConnectorProfileCredentials(v.Redshift); err != nil { 445 invalidParams.AddNested("Redshift", err.(smithy.InvalidParamsError)) 446 } 447 } 448 if v.ServiceNow != nil { 449 if err := validateServiceNowConnectorProfileCredentials(v.ServiceNow); err != nil { 450 invalidParams.AddNested("ServiceNow", err.(smithy.InvalidParamsError)) 451 } 452 } 453 if v.Singular != nil { 454 if err := validateSingularConnectorProfileCredentials(v.Singular); err != nil { 455 invalidParams.AddNested("Singular", err.(smithy.InvalidParamsError)) 456 } 457 } 458 if v.Slack != nil { 459 if err := validateSlackConnectorProfileCredentials(v.Slack); err != nil { 460 invalidParams.AddNested("Slack", err.(smithy.InvalidParamsError)) 461 } 462 } 463 if v.Snowflake != nil { 464 if err := validateSnowflakeConnectorProfileCredentials(v.Snowflake); err != nil { 465 invalidParams.AddNested("Snowflake", err.(smithy.InvalidParamsError)) 466 } 467 } 468 if v.Trendmicro != nil { 469 if err := validateTrendmicroConnectorProfileCredentials(v.Trendmicro); err != nil { 470 invalidParams.AddNested("Trendmicro", err.(smithy.InvalidParamsError)) 471 } 472 } 473 if v.Veeva != nil { 474 if err := validateVeevaConnectorProfileCredentials(v.Veeva); err != nil { 475 invalidParams.AddNested("Veeva", err.(smithy.InvalidParamsError)) 476 } 477 } 478 if v.Zendesk != nil { 479 if err := validateZendeskConnectorProfileCredentials(v.Zendesk); err != nil { 480 invalidParams.AddNested("Zendesk", err.(smithy.InvalidParamsError)) 481 } 482 } 483 if invalidParams.Len() > 0 { 484 return invalidParams 485 } else { 486 return nil 487 } 488} 489 490func validateConnectorProfileProperties(v *types.ConnectorProfileProperties) error { 491 if v == nil { 492 return nil 493 } 494 invalidParams := smithy.InvalidParamsError{Context: "ConnectorProfileProperties"} 495 if v.Datadog != nil { 496 if err := validateDatadogConnectorProfileProperties(v.Datadog); err != nil { 497 invalidParams.AddNested("Datadog", err.(smithy.InvalidParamsError)) 498 } 499 } 500 if v.Dynatrace != nil { 501 if err := validateDynatraceConnectorProfileProperties(v.Dynatrace); err != nil { 502 invalidParams.AddNested("Dynatrace", err.(smithy.InvalidParamsError)) 503 } 504 } 505 if v.InforNexus != nil { 506 if err := validateInforNexusConnectorProfileProperties(v.InforNexus); err != nil { 507 invalidParams.AddNested("InforNexus", err.(smithy.InvalidParamsError)) 508 } 509 } 510 if v.Marketo != nil { 511 if err := validateMarketoConnectorProfileProperties(v.Marketo); err != nil { 512 invalidParams.AddNested("Marketo", err.(smithy.InvalidParamsError)) 513 } 514 } 515 if v.Redshift != nil { 516 if err := validateRedshiftConnectorProfileProperties(v.Redshift); err != nil { 517 invalidParams.AddNested("Redshift", err.(smithy.InvalidParamsError)) 518 } 519 } 520 if v.ServiceNow != nil { 521 if err := validateServiceNowConnectorProfileProperties(v.ServiceNow); err != nil { 522 invalidParams.AddNested("ServiceNow", err.(smithy.InvalidParamsError)) 523 } 524 } 525 if v.Slack != nil { 526 if err := validateSlackConnectorProfileProperties(v.Slack); err != nil { 527 invalidParams.AddNested("Slack", err.(smithy.InvalidParamsError)) 528 } 529 } 530 if v.Snowflake != nil { 531 if err := validateSnowflakeConnectorProfileProperties(v.Snowflake); err != nil { 532 invalidParams.AddNested("Snowflake", err.(smithy.InvalidParamsError)) 533 } 534 } 535 if v.Veeva != nil { 536 if err := validateVeevaConnectorProfileProperties(v.Veeva); err != nil { 537 invalidParams.AddNested("Veeva", err.(smithy.InvalidParamsError)) 538 } 539 } 540 if v.Zendesk != nil { 541 if err := validateZendeskConnectorProfileProperties(v.Zendesk); err != nil { 542 invalidParams.AddNested("Zendesk", err.(smithy.InvalidParamsError)) 543 } 544 } 545 if invalidParams.Len() > 0 { 546 return invalidParams 547 } else { 548 return nil 549 } 550} 551 552func validateCustomerProfilesDestinationProperties(v *types.CustomerProfilesDestinationProperties) error { 553 if v == nil { 554 return nil 555 } 556 invalidParams := smithy.InvalidParamsError{Context: "CustomerProfilesDestinationProperties"} 557 if v.DomainName == nil { 558 invalidParams.Add(smithy.NewErrParamRequired("DomainName")) 559 } 560 if invalidParams.Len() > 0 { 561 return invalidParams 562 } else { 563 return nil 564 } 565} 566 567func validateDatadogConnectorProfileCredentials(v *types.DatadogConnectorProfileCredentials) error { 568 if v == nil { 569 return nil 570 } 571 invalidParams := smithy.InvalidParamsError{Context: "DatadogConnectorProfileCredentials"} 572 if v.ApiKey == nil { 573 invalidParams.Add(smithy.NewErrParamRequired("ApiKey")) 574 } 575 if v.ApplicationKey == nil { 576 invalidParams.Add(smithy.NewErrParamRequired("ApplicationKey")) 577 } 578 if invalidParams.Len() > 0 { 579 return invalidParams 580 } else { 581 return nil 582 } 583} 584 585func validateDatadogConnectorProfileProperties(v *types.DatadogConnectorProfileProperties) error { 586 if v == nil { 587 return nil 588 } 589 invalidParams := smithy.InvalidParamsError{Context: "DatadogConnectorProfileProperties"} 590 if v.InstanceUrl == nil { 591 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 592 } 593 if invalidParams.Len() > 0 { 594 return invalidParams 595 } else { 596 return nil 597 } 598} 599 600func validateDatadogSourceProperties(v *types.DatadogSourceProperties) error { 601 if v == nil { 602 return nil 603 } 604 invalidParams := smithy.InvalidParamsError{Context: "DatadogSourceProperties"} 605 if v.Object == nil { 606 invalidParams.Add(smithy.NewErrParamRequired("Object")) 607 } 608 if invalidParams.Len() > 0 { 609 return invalidParams 610 } else { 611 return nil 612 } 613} 614 615func validateDestinationConnectorProperties(v *types.DestinationConnectorProperties) error { 616 if v == nil { 617 return nil 618 } 619 invalidParams := smithy.InvalidParamsError{Context: "DestinationConnectorProperties"} 620 if v.Redshift != nil { 621 if err := validateRedshiftDestinationProperties(v.Redshift); err != nil { 622 invalidParams.AddNested("Redshift", err.(smithy.InvalidParamsError)) 623 } 624 } 625 if v.S3 != nil { 626 if err := validateS3DestinationProperties(v.S3); err != nil { 627 invalidParams.AddNested("S3", err.(smithy.InvalidParamsError)) 628 } 629 } 630 if v.Salesforce != nil { 631 if err := validateSalesforceDestinationProperties(v.Salesforce); err != nil { 632 invalidParams.AddNested("Salesforce", err.(smithy.InvalidParamsError)) 633 } 634 } 635 if v.Snowflake != nil { 636 if err := validateSnowflakeDestinationProperties(v.Snowflake); err != nil { 637 invalidParams.AddNested("Snowflake", err.(smithy.InvalidParamsError)) 638 } 639 } 640 if v.EventBridge != nil { 641 if err := validateEventBridgeDestinationProperties(v.EventBridge); err != nil { 642 invalidParams.AddNested("EventBridge", err.(smithy.InvalidParamsError)) 643 } 644 } 645 if v.Upsolver != nil { 646 if err := validateUpsolverDestinationProperties(v.Upsolver); err != nil { 647 invalidParams.AddNested("Upsolver", err.(smithy.InvalidParamsError)) 648 } 649 } 650 if v.Honeycode != nil { 651 if err := validateHoneycodeDestinationProperties(v.Honeycode); err != nil { 652 invalidParams.AddNested("Honeycode", err.(smithy.InvalidParamsError)) 653 } 654 } 655 if v.CustomerProfiles != nil { 656 if err := validateCustomerProfilesDestinationProperties(v.CustomerProfiles); err != nil { 657 invalidParams.AddNested("CustomerProfiles", err.(smithy.InvalidParamsError)) 658 } 659 } 660 if v.Zendesk != nil { 661 if err := validateZendeskDestinationProperties(v.Zendesk); err != nil { 662 invalidParams.AddNested("Zendesk", err.(smithy.InvalidParamsError)) 663 } 664 } 665 if invalidParams.Len() > 0 { 666 return invalidParams 667 } else { 668 return nil 669 } 670} 671 672func validateDestinationFlowConfig(v *types.DestinationFlowConfig) error { 673 if v == nil { 674 return nil 675 } 676 invalidParams := smithy.InvalidParamsError{Context: "DestinationFlowConfig"} 677 if len(v.ConnectorType) == 0 { 678 invalidParams.Add(smithy.NewErrParamRequired("ConnectorType")) 679 } 680 if v.DestinationConnectorProperties == nil { 681 invalidParams.Add(smithy.NewErrParamRequired("DestinationConnectorProperties")) 682 } else if v.DestinationConnectorProperties != nil { 683 if err := validateDestinationConnectorProperties(v.DestinationConnectorProperties); err != nil { 684 invalidParams.AddNested("DestinationConnectorProperties", err.(smithy.InvalidParamsError)) 685 } 686 } 687 if invalidParams.Len() > 0 { 688 return invalidParams 689 } else { 690 return nil 691 } 692} 693 694func validateDestinationFlowConfigList(v []types.DestinationFlowConfig) error { 695 if v == nil { 696 return nil 697 } 698 invalidParams := smithy.InvalidParamsError{Context: "DestinationFlowConfigList"} 699 for i := range v { 700 if err := validateDestinationFlowConfig(&v[i]); err != nil { 701 invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) 702 } 703 } 704 if invalidParams.Len() > 0 { 705 return invalidParams 706 } else { 707 return nil 708 } 709} 710 711func validateDynatraceConnectorProfileCredentials(v *types.DynatraceConnectorProfileCredentials) error { 712 if v == nil { 713 return nil 714 } 715 invalidParams := smithy.InvalidParamsError{Context: "DynatraceConnectorProfileCredentials"} 716 if v.ApiToken == nil { 717 invalidParams.Add(smithy.NewErrParamRequired("ApiToken")) 718 } 719 if invalidParams.Len() > 0 { 720 return invalidParams 721 } else { 722 return nil 723 } 724} 725 726func validateDynatraceConnectorProfileProperties(v *types.DynatraceConnectorProfileProperties) error { 727 if v == nil { 728 return nil 729 } 730 invalidParams := smithy.InvalidParamsError{Context: "DynatraceConnectorProfileProperties"} 731 if v.InstanceUrl == nil { 732 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 733 } 734 if invalidParams.Len() > 0 { 735 return invalidParams 736 } else { 737 return nil 738 } 739} 740 741func validateDynatraceSourceProperties(v *types.DynatraceSourceProperties) error { 742 if v == nil { 743 return nil 744 } 745 invalidParams := smithy.InvalidParamsError{Context: "DynatraceSourceProperties"} 746 if v.Object == nil { 747 invalidParams.Add(smithy.NewErrParamRequired("Object")) 748 } 749 if invalidParams.Len() > 0 { 750 return invalidParams 751 } else { 752 return nil 753 } 754} 755 756func validateEventBridgeDestinationProperties(v *types.EventBridgeDestinationProperties) error { 757 if v == nil { 758 return nil 759 } 760 invalidParams := smithy.InvalidParamsError{Context: "EventBridgeDestinationProperties"} 761 if v.Object == nil { 762 invalidParams.Add(smithy.NewErrParamRequired("Object")) 763 } 764 if invalidParams.Len() > 0 { 765 return invalidParams 766 } else { 767 return nil 768 } 769} 770 771func validateGoogleAnalyticsConnectorProfileCredentials(v *types.GoogleAnalyticsConnectorProfileCredentials) error { 772 if v == nil { 773 return nil 774 } 775 invalidParams := smithy.InvalidParamsError{Context: "GoogleAnalyticsConnectorProfileCredentials"} 776 if v.ClientId == nil { 777 invalidParams.Add(smithy.NewErrParamRequired("ClientId")) 778 } 779 if v.ClientSecret == nil { 780 invalidParams.Add(smithy.NewErrParamRequired("ClientSecret")) 781 } 782 if invalidParams.Len() > 0 { 783 return invalidParams 784 } else { 785 return nil 786 } 787} 788 789func validateGoogleAnalyticsSourceProperties(v *types.GoogleAnalyticsSourceProperties) error { 790 if v == nil { 791 return nil 792 } 793 invalidParams := smithy.InvalidParamsError{Context: "GoogleAnalyticsSourceProperties"} 794 if v.Object == nil { 795 invalidParams.Add(smithy.NewErrParamRequired("Object")) 796 } 797 if invalidParams.Len() > 0 { 798 return invalidParams 799 } else { 800 return nil 801 } 802} 803 804func validateHoneycodeDestinationProperties(v *types.HoneycodeDestinationProperties) error { 805 if v == nil { 806 return nil 807 } 808 invalidParams := smithy.InvalidParamsError{Context: "HoneycodeDestinationProperties"} 809 if v.Object == nil { 810 invalidParams.Add(smithy.NewErrParamRequired("Object")) 811 } 812 if invalidParams.Len() > 0 { 813 return invalidParams 814 } else { 815 return nil 816 } 817} 818 819func validateInforNexusConnectorProfileCredentials(v *types.InforNexusConnectorProfileCredentials) error { 820 if v == nil { 821 return nil 822 } 823 invalidParams := smithy.InvalidParamsError{Context: "InforNexusConnectorProfileCredentials"} 824 if v.AccessKeyId == nil { 825 invalidParams.Add(smithy.NewErrParamRequired("AccessKeyId")) 826 } 827 if v.UserId == nil { 828 invalidParams.Add(smithy.NewErrParamRequired("UserId")) 829 } 830 if v.SecretAccessKey == nil { 831 invalidParams.Add(smithy.NewErrParamRequired("SecretAccessKey")) 832 } 833 if v.Datakey == nil { 834 invalidParams.Add(smithy.NewErrParamRequired("Datakey")) 835 } 836 if invalidParams.Len() > 0 { 837 return invalidParams 838 } else { 839 return nil 840 } 841} 842 843func validateInforNexusConnectorProfileProperties(v *types.InforNexusConnectorProfileProperties) error { 844 if v == nil { 845 return nil 846 } 847 invalidParams := smithy.InvalidParamsError{Context: "InforNexusConnectorProfileProperties"} 848 if v.InstanceUrl == nil { 849 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 850 } 851 if invalidParams.Len() > 0 { 852 return invalidParams 853 } else { 854 return nil 855 } 856} 857 858func validateInforNexusSourceProperties(v *types.InforNexusSourceProperties) error { 859 if v == nil { 860 return nil 861 } 862 invalidParams := smithy.InvalidParamsError{Context: "InforNexusSourceProperties"} 863 if v.Object == nil { 864 invalidParams.Add(smithy.NewErrParamRequired("Object")) 865 } 866 if invalidParams.Len() > 0 { 867 return invalidParams 868 } else { 869 return nil 870 } 871} 872 873func validateMarketoConnectorProfileCredentials(v *types.MarketoConnectorProfileCredentials) error { 874 if v == nil { 875 return nil 876 } 877 invalidParams := smithy.InvalidParamsError{Context: "MarketoConnectorProfileCredentials"} 878 if v.ClientId == nil { 879 invalidParams.Add(smithy.NewErrParamRequired("ClientId")) 880 } 881 if v.ClientSecret == nil { 882 invalidParams.Add(smithy.NewErrParamRequired("ClientSecret")) 883 } 884 if invalidParams.Len() > 0 { 885 return invalidParams 886 } else { 887 return nil 888 } 889} 890 891func validateMarketoConnectorProfileProperties(v *types.MarketoConnectorProfileProperties) error { 892 if v == nil { 893 return nil 894 } 895 invalidParams := smithy.InvalidParamsError{Context: "MarketoConnectorProfileProperties"} 896 if v.InstanceUrl == nil { 897 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 898 } 899 if invalidParams.Len() > 0 { 900 return invalidParams 901 } else { 902 return nil 903 } 904} 905 906func validateMarketoSourceProperties(v *types.MarketoSourceProperties) error { 907 if v == nil { 908 return nil 909 } 910 invalidParams := smithy.InvalidParamsError{Context: "MarketoSourceProperties"} 911 if v.Object == nil { 912 invalidParams.Add(smithy.NewErrParamRequired("Object")) 913 } 914 if invalidParams.Len() > 0 { 915 return invalidParams 916 } else { 917 return nil 918 } 919} 920 921func validateRedshiftConnectorProfileCredentials(v *types.RedshiftConnectorProfileCredentials) error { 922 if v == nil { 923 return nil 924 } 925 invalidParams := smithy.InvalidParamsError{Context: "RedshiftConnectorProfileCredentials"} 926 if v.Username == nil { 927 invalidParams.Add(smithy.NewErrParamRequired("Username")) 928 } 929 if v.Password == nil { 930 invalidParams.Add(smithy.NewErrParamRequired("Password")) 931 } 932 if invalidParams.Len() > 0 { 933 return invalidParams 934 } else { 935 return nil 936 } 937} 938 939func validateRedshiftConnectorProfileProperties(v *types.RedshiftConnectorProfileProperties) error { 940 if v == nil { 941 return nil 942 } 943 invalidParams := smithy.InvalidParamsError{Context: "RedshiftConnectorProfileProperties"} 944 if v.DatabaseUrl == nil { 945 invalidParams.Add(smithy.NewErrParamRequired("DatabaseUrl")) 946 } 947 if v.BucketName == nil { 948 invalidParams.Add(smithy.NewErrParamRequired("BucketName")) 949 } 950 if v.RoleArn == nil { 951 invalidParams.Add(smithy.NewErrParamRequired("RoleArn")) 952 } 953 if invalidParams.Len() > 0 { 954 return invalidParams 955 } else { 956 return nil 957 } 958} 959 960func validateRedshiftDestinationProperties(v *types.RedshiftDestinationProperties) error { 961 if v == nil { 962 return nil 963 } 964 invalidParams := smithy.InvalidParamsError{Context: "RedshiftDestinationProperties"} 965 if v.Object == nil { 966 invalidParams.Add(smithy.NewErrParamRequired("Object")) 967 } 968 if v.IntermediateBucketName == nil { 969 invalidParams.Add(smithy.NewErrParamRequired("IntermediateBucketName")) 970 } 971 if invalidParams.Len() > 0 { 972 return invalidParams 973 } else { 974 return nil 975 } 976} 977 978func validateS3DestinationProperties(v *types.S3DestinationProperties) error { 979 if v == nil { 980 return nil 981 } 982 invalidParams := smithy.InvalidParamsError{Context: "S3DestinationProperties"} 983 if v.BucketName == nil { 984 invalidParams.Add(smithy.NewErrParamRequired("BucketName")) 985 } 986 if invalidParams.Len() > 0 { 987 return invalidParams 988 } else { 989 return nil 990 } 991} 992 993func validateS3SourceProperties(v *types.S3SourceProperties) error { 994 if v == nil { 995 return nil 996 } 997 invalidParams := smithy.InvalidParamsError{Context: "S3SourceProperties"} 998 if v.BucketName == nil { 999 invalidParams.Add(smithy.NewErrParamRequired("BucketName")) 1000 } 1001 if invalidParams.Len() > 0 { 1002 return invalidParams 1003 } else { 1004 return nil 1005 } 1006} 1007 1008func validateSalesforceDestinationProperties(v *types.SalesforceDestinationProperties) error { 1009 if v == nil { 1010 return nil 1011 } 1012 invalidParams := smithy.InvalidParamsError{Context: "SalesforceDestinationProperties"} 1013 if v.Object == nil { 1014 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1015 } 1016 if invalidParams.Len() > 0 { 1017 return invalidParams 1018 } else { 1019 return nil 1020 } 1021} 1022 1023func validateSalesforceSourceProperties(v *types.SalesforceSourceProperties) error { 1024 if v == nil { 1025 return nil 1026 } 1027 invalidParams := smithy.InvalidParamsError{Context: "SalesforceSourceProperties"} 1028 if v.Object == nil { 1029 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1030 } 1031 if invalidParams.Len() > 0 { 1032 return invalidParams 1033 } else { 1034 return nil 1035 } 1036} 1037 1038func validateScheduledTriggerProperties(v *types.ScheduledTriggerProperties) error { 1039 if v == nil { 1040 return nil 1041 } 1042 invalidParams := smithy.InvalidParamsError{Context: "ScheduledTriggerProperties"} 1043 if v.ScheduleExpression == nil { 1044 invalidParams.Add(smithy.NewErrParamRequired("ScheduleExpression")) 1045 } 1046 if invalidParams.Len() > 0 { 1047 return invalidParams 1048 } else { 1049 return nil 1050 } 1051} 1052 1053func validateServiceNowConnectorProfileCredentials(v *types.ServiceNowConnectorProfileCredentials) error { 1054 if v == nil { 1055 return nil 1056 } 1057 invalidParams := smithy.InvalidParamsError{Context: "ServiceNowConnectorProfileCredentials"} 1058 if v.Username == nil { 1059 invalidParams.Add(smithy.NewErrParamRequired("Username")) 1060 } 1061 if v.Password == nil { 1062 invalidParams.Add(smithy.NewErrParamRequired("Password")) 1063 } 1064 if invalidParams.Len() > 0 { 1065 return invalidParams 1066 } else { 1067 return nil 1068 } 1069} 1070 1071func validateServiceNowConnectorProfileProperties(v *types.ServiceNowConnectorProfileProperties) error { 1072 if v == nil { 1073 return nil 1074 } 1075 invalidParams := smithy.InvalidParamsError{Context: "ServiceNowConnectorProfileProperties"} 1076 if v.InstanceUrl == nil { 1077 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 1078 } 1079 if invalidParams.Len() > 0 { 1080 return invalidParams 1081 } else { 1082 return nil 1083 } 1084} 1085 1086func validateServiceNowSourceProperties(v *types.ServiceNowSourceProperties) error { 1087 if v == nil { 1088 return nil 1089 } 1090 invalidParams := smithy.InvalidParamsError{Context: "ServiceNowSourceProperties"} 1091 if v.Object == nil { 1092 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1093 } 1094 if invalidParams.Len() > 0 { 1095 return invalidParams 1096 } else { 1097 return nil 1098 } 1099} 1100 1101func validateSingularConnectorProfileCredentials(v *types.SingularConnectorProfileCredentials) error { 1102 if v == nil { 1103 return nil 1104 } 1105 invalidParams := smithy.InvalidParamsError{Context: "SingularConnectorProfileCredentials"} 1106 if v.ApiKey == nil { 1107 invalidParams.Add(smithy.NewErrParamRequired("ApiKey")) 1108 } 1109 if invalidParams.Len() > 0 { 1110 return invalidParams 1111 } else { 1112 return nil 1113 } 1114} 1115 1116func validateSingularSourceProperties(v *types.SingularSourceProperties) error { 1117 if v == nil { 1118 return nil 1119 } 1120 invalidParams := smithy.InvalidParamsError{Context: "SingularSourceProperties"} 1121 if v.Object == nil { 1122 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1123 } 1124 if invalidParams.Len() > 0 { 1125 return invalidParams 1126 } else { 1127 return nil 1128 } 1129} 1130 1131func validateSlackConnectorProfileCredentials(v *types.SlackConnectorProfileCredentials) error { 1132 if v == nil { 1133 return nil 1134 } 1135 invalidParams := smithy.InvalidParamsError{Context: "SlackConnectorProfileCredentials"} 1136 if v.ClientId == nil { 1137 invalidParams.Add(smithy.NewErrParamRequired("ClientId")) 1138 } 1139 if v.ClientSecret == nil { 1140 invalidParams.Add(smithy.NewErrParamRequired("ClientSecret")) 1141 } 1142 if invalidParams.Len() > 0 { 1143 return invalidParams 1144 } else { 1145 return nil 1146 } 1147} 1148 1149func validateSlackConnectorProfileProperties(v *types.SlackConnectorProfileProperties) error { 1150 if v == nil { 1151 return nil 1152 } 1153 invalidParams := smithy.InvalidParamsError{Context: "SlackConnectorProfileProperties"} 1154 if v.InstanceUrl == nil { 1155 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 1156 } 1157 if invalidParams.Len() > 0 { 1158 return invalidParams 1159 } else { 1160 return nil 1161 } 1162} 1163 1164func validateSlackSourceProperties(v *types.SlackSourceProperties) error { 1165 if v == nil { 1166 return nil 1167 } 1168 invalidParams := smithy.InvalidParamsError{Context: "SlackSourceProperties"} 1169 if v.Object == nil { 1170 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1171 } 1172 if invalidParams.Len() > 0 { 1173 return invalidParams 1174 } else { 1175 return nil 1176 } 1177} 1178 1179func validateSnowflakeConnectorProfileCredentials(v *types.SnowflakeConnectorProfileCredentials) error { 1180 if v == nil { 1181 return nil 1182 } 1183 invalidParams := smithy.InvalidParamsError{Context: "SnowflakeConnectorProfileCredentials"} 1184 if v.Username == nil { 1185 invalidParams.Add(smithy.NewErrParamRequired("Username")) 1186 } 1187 if v.Password == nil { 1188 invalidParams.Add(smithy.NewErrParamRequired("Password")) 1189 } 1190 if invalidParams.Len() > 0 { 1191 return invalidParams 1192 } else { 1193 return nil 1194 } 1195} 1196 1197func validateSnowflakeConnectorProfileProperties(v *types.SnowflakeConnectorProfileProperties) error { 1198 if v == nil { 1199 return nil 1200 } 1201 invalidParams := smithy.InvalidParamsError{Context: "SnowflakeConnectorProfileProperties"} 1202 if v.Warehouse == nil { 1203 invalidParams.Add(smithy.NewErrParamRequired("Warehouse")) 1204 } 1205 if v.Stage == nil { 1206 invalidParams.Add(smithy.NewErrParamRequired("Stage")) 1207 } 1208 if v.BucketName == nil { 1209 invalidParams.Add(smithy.NewErrParamRequired("BucketName")) 1210 } 1211 if invalidParams.Len() > 0 { 1212 return invalidParams 1213 } else { 1214 return nil 1215 } 1216} 1217 1218func validateSnowflakeDestinationProperties(v *types.SnowflakeDestinationProperties) error { 1219 if v == nil { 1220 return nil 1221 } 1222 invalidParams := smithy.InvalidParamsError{Context: "SnowflakeDestinationProperties"} 1223 if v.Object == nil { 1224 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1225 } 1226 if v.IntermediateBucketName == nil { 1227 invalidParams.Add(smithy.NewErrParamRequired("IntermediateBucketName")) 1228 } 1229 if invalidParams.Len() > 0 { 1230 return invalidParams 1231 } else { 1232 return nil 1233 } 1234} 1235 1236func validateSourceConnectorProperties(v *types.SourceConnectorProperties) error { 1237 if v == nil { 1238 return nil 1239 } 1240 invalidParams := smithy.InvalidParamsError{Context: "SourceConnectorProperties"} 1241 if v.Amplitude != nil { 1242 if err := validateAmplitudeSourceProperties(v.Amplitude); err != nil { 1243 invalidParams.AddNested("Amplitude", err.(smithy.InvalidParamsError)) 1244 } 1245 } 1246 if v.Datadog != nil { 1247 if err := validateDatadogSourceProperties(v.Datadog); err != nil { 1248 invalidParams.AddNested("Datadog", err.(smithy.InvalidParamsError)) 1249 } 1250 } 1251 if v.Dynatrace != nil { 1252 if err := validateDynatraceSourceProperties(v.Dynatrace); err != nil { 1253 invalidParams.AddNested("Dynatrace", err.(smithy.InvalidParamsError)) 1254 } 1255 } 1256 if v.GoogleAnalytics != nil { 1257 if err := validateGoogleAnalyticsSourceProperties(v.GoogleAnalytics); err != nil { 1258 invalidParams.AddNested("GoogleAnalytics", err.(smithy.InvalidParamsError)) 1259 } 1260 } 1261 if v.InforNexus != nil { 1262 if err := validateInforNexusSourceProperties(v.InforNexus); err != nil { 1263 invalidParams.AddNested("InforNexus", err.(smithy.InvalidParamsError)) 1264 } 1265 } 1266 if v.Marketo != nil { 1267 if err := validateMarketoSourceProperties(v.Marketo); err != nil { 1268 invalidParams.AddNested("Marketo", err.(smithy.InvalidParamsError)) 1269 } 1270 } 1271 if v.S3 != nil { 1272 if err := validateS3SourceProperties(v.S3); err != nil { 1273 invalidParams.AddNested("S3", err.(smithy.InvalidParamsError)) 1274 } 1275 } 1276 if v.Salesforce != nil { 1277 if err := validateSalesforceSourceProperties(v.Salesforce); err != nil { 1278 invalidParams.AddNested("Salesforce", err.(smithy.InvalidParamsError)) 1279 } 1280 } 1281 if v.ServiceNow != nil { 1282 if err := validateServiceNowSourceProperties(v.ServiceNow); err != nil { 1283 invalidParams.AddNested("ServiceNow", err.(smithy.InvalidParamsError)) 1284 } 1285 } 1286 if v.Singular != nil { 1287 if err := validateSingularSourceProperties(v.Singular); err != nil { 1288 invalidParams.AddNested("Singular", err.(smithy.InvalidParamsError)) 1289 } 1290 } 1291 if v.Slack != nil { 1292 if err := validateSlackSourceProperties(v.Slack); err != nil { 1293 invalidParams.AddNested("Slack", err.(smithy.InvalidParamsError)) 1294 } 1295 } 1296 if v.Trendmicro != nil { 1297 if err := validateTrendmicroSourceProperties(v.Trendmicro); err != nil { 1298 invalidParams.AddNested("Trendmicro", err.(smithy.InvalidParamsError)) 1299 } 1300 } 1301 if v.Veeva != nil { 1302 if err := validateVeevaSourceProperties(v.Veeva); err != nil { 1303 invalidParams.AddNested("Veeva", err.(smithy.InvalidParamsError)) 1304 } 1305 } 1306 if v.Zendesk != nil { 1307 if err := validateZendeskSourceProperties(v.Zendesk); err != nil { 1308 invalidParams.AddNested("Zendesk", err.(smithy.InvalidParamsError)) 1309 } 1310 } 1311 if invalidParams.Len() > 0 { 1312 return invalidParams 1313 } else { 1314 return nil 1315 } 1316} 1317 1318func validateSourceFlowConfig(v *types.SourceFlowConfig) error { 1319 if v == nil { 1320 return nil 1321 } 1322 invalidParams := smithy.InvalidParamsError{Context: "SourceFlowConfig"} 1323 if len(v.ConnectorType) == 0 { 1324 invalidParams.Add(smithy.NewErrParamRequired("ConnectorType")) 1325 } 1326 if v.SourceConnectorProperties == nil { 1327 invalidParams.Add(smithy.NewErrParamRequired("SourceConnectorProperties")) 1328 } else if v.SourceConnectorProperties != nil { 1329 if err := validateSourceConnectorProperties(v.SourceConnectorProperties); err != nil { 1330 invalidParams.AddNested("SourceConnectorProperties", err.(smithy.InvalidParamsError)) 1331 } 1332 } 1333 if invalidParams.Len() > 0 { 1334 return invalidParams 1335 } else { 1336 return nil 1337 } 1338} 1339 1340func validateTask(v *types.Task) error { 1341 if v == nil { 1342 return nil 1343 } 1344 invalidParams := smithy.InvalidParamsError{Context: "Task"} 1345 if v.SourceFields == nil { 1346 invalidParams.Add(smithy.NewErrParamRequired("SourceFields")) 1347 } 1348 if len(v.TaskType) == 0 { 1349 invalidParams.Add(smithy.NewErrParamRequired("TaskType")) 1350 } 1351 if invalidParams.Len() > 0 { 1352 return invalidParams 1353 } else { 1354 return nil 1355 } 1356} 1357 1358func validateTasks(v []types.Task) error { 1359 if v == nil { 1360 return nil 1361 } 1362 invalidParams := smithy.InvalidParamsError{Context: "Tasks"} 1363 for i := range v { 1364 if err := validateTask(&v[i]); err != nil { 1365 invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) 1366 } 1367 } 1368 if invalidParams.Len() > 0 { 1369 return invalidParams 1370 } else { 1371 return nil 1372 } 1373} 1374 1375func validateTrendmicroConnectorProfileCredentials(v *types.TrendmicroConnectorProfileCredentials) error { 1376 if v == nil { 1377 return nil 1378 } 1379 invalidParams := smithy.InvalidParamsError{Context: "TrendmicroConnectorProfileCredentials"} 1380 if v.ApiSecretKey == nil { 1381 invalidParams.Add(smithy.NewErrParamRequired("ApiSecretKey")) 1382 } 1383 if invalidParams.Len() > 0 { 1384 return invalidParams 1385 } else { 1386 return nil 1387 } 1388} 1389 1390func validateTrendmicroSourceProperties(v *types.TrendmicroSourceProperties) error { 1391 if v == nil { 1392 return nil 1393 } 1394 invalidParams := smithy.InvalidParamsError{Context: "TrendmicroSourceProperties"} 1395 if v.Object == nil { 1396 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1397 } 1398 if invalidParams.Len() > 0 { 1399 return invalidParams 1400 } else { 1401 return nil 1402 } 1403} 1404 1405func validateTriggerConfig(v *types.TriggerConfig) error { 1406 if v == nil { 1407 return nil 1408 } 1409 invalidParams := smithy.InvalidParamsError{Context: "TriggerConfig"} 1410 if len(v.TriggerType) == 0 { 1411 invalidParams.Add(smithy.NewErrParamRequired("TriggerType")) 1412 } 1413 if v.TriggerProperties != nil { 1414 if err := validateTriggerProperties(v.TriggerProperties); err != nil { 1415 invalidParams.AddNested("TriggerProperties", err.(smithy.InvalidParamsError)) 1416 } 1417 } 1418 if invalidParams.Len() > 0 { 1419 return invalidParams 1420 } else { 1421 return nil 1422 } 1423} 1424 1425func validateTriggerProperties(v *types.TriggerProperties) error { 1426 if v == nil { 1427 return nil 1428 } 1429 invalidParams := smithy.InvalidParamsError{Context: "TriggerProperties"} 1430 if v.Scheduled != nil { 1431 if err := validateScheduledTriggerProperties(v.Scheduled); err != nil { 1432 invalidParams.AddNested("Scheduled", err.(smithy.InvalidParamsError)) 1433 } 1434 } 1435 if invalidParams.Len() > 0 { 1436 return invalidParams 1437 } else { 1438 return nil 1439 } 1440} 1441 1442func validateUpsolverDestinationProperties(v *types.UpsolverDestinationProperties) error { 1443 if v == nil { 1444 return nil 1445 } 1446 invalidParams := smithy.InvalidParamsError{Context: "UpsolverDestinationProperties"} 1447 if v.BucketName == nil { 1448 invalidParams.Add(smithy.NewErrParamRequired("BucketName")) 1449 } 1450 if v.S3OutputFormatConfig == nil { 1451 invalidParams.Add(smithy.NewErrParamRequired("S3OutputFormatConfig")) 1452 } else if v.S3OutputFormatConfig != nil { 1453 if err := validateUpsolverS3OutputFormatConfig(v.S3OutputFormatConfig); err != nil { 1454 invalidParams.AddNested("S3OutputFormatConfig", err.(smithy.InvalidParamsError)) 1455 } 1456 } 1457 if invalidParams.Len() > 0 { 1458 return invalidParams 1459 } else { 1460 return nil 1461 } 1462} 1463 1464func validateUpsolverS3OutputFormatConfig(v *types.UpsolverS3OutputFormatConfig) error { 1465 if v == nil { 1466 return nil 1467 } 1468 invalidParams := smithy.InvalidParamsError{Context: "UpsolverS3OutputFormatConfig"} 1469 if v.PrefixConfig == nil { 1470 invalidParams.Add(smithy.NewErrParamRequired("PrefixConfig")) 1471 } 1472 if invalidParams.Len() > 0 { 1473 return invalidParams 1474 } else { 1475 return nil 1476 } 1477} 1478 1479func validateVeevaConnectorProfileCredentials(v *types.VeevaConnectorProfileCredentials) error { 1480 if v == nil { 1481 return nil 1482 } 1483 invalidParams := smithy.InvalidParamsError{Context: "VeevaConnectorProfileCredentials"} 1484 if v.Username == nil { 1485 invalidParams.Add(smithy.NewErrParamRequired("Username")) 1486 } 1487 if v.Password == nil { 1488 invalidParams.Add(smithy.NewErrParamRequired("Password")) 1489 } 1490 if invalidParams.Len() > 0 { 1491 return invalidParams 1492 } else { 1493 return nil 1494 } 1495} 1496 1497func validateVeevaConnectorProfileProperties(v *types.VeevaConnectorProfileProperties) error { 1498 if v == nil { 1499 return nil 1500 } 1501 invalidParams := smithy.InvalidParamsError{Context: "VeevaConnectorProfileProperties"} 1502 if v.InstanceUrl == nil { 1503 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 1504 } 1505 if invalidParams.Len() > 0 { 1506 return invalidParams 1507 } else { 1508 return nil 1509 } 1510} 1511 1512func validateVeevaSourceProperties(v *types.VeevaSourceProperties) error { 1513 if v == nil { 1514 return nil 1515 } 1516 invalidParams := smithy.InvalidParamsError{Context: "VeevaSourceProperties"} 1517 if v.Object == nil { 1518 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1519 } 1520 if invalidParams.Len() > 0 { 1521 return invalidParams 1522 } else { 1523 return nil 1524 } 1525} 1526 1527func validateZendeskConnectorProfileCredentials(v *types.ZendeskConnectorProfileCredentials) error { 1528 if v == nil { 1529 return nil 1530 } 1531 invalidParams := smithy.InvalidParamsError{Context: "ZendeskConnectorProfileCredentials"} 1532 if v.ClientId == nil { 1533 invalidParams.Add(smithy.NewErrParamRequired("ClientId")) 1534 } 1535 if v.ClientSecret == nil { 1536 invalidParams.Add(smithy.NewErrParamRequired("ClientSecret")) 1537 } 1538 if invalidParams.Len() > 0 { 1539 return invalidParams 1540 } else { 1541 return nil 1542 } 1543} 1544 1545func validateZendeskConnectorProfileProperties(v *types.ZendeskConnectorProfileProperties) error { 1546 if v == nil { 1547 return nil 1548 } 1549 invalidParams := smithy.InvalidParamsError{Context: "ZendeskConnectorProfileProperties"} 1550 if v.InstanceUrl == nil { 1551 invalidParams.Add(smithy.NewErrParamRequired("InstanceUrl")) 1552 } 1553 if invalidParams.Len() > 0 { 1554 return invalidParams 1555 } else { 1556 return nil 1557 } 1558} 1559 1560func validateZendeskDestinationProperties(v *types.ZendeskDestinationProperties) error { 1561 if v == nil { 1562 return nil 1563 } 1564 invalidParams := smithy.InvalidParamsError{Context: "ZendeskDestinationProperties"} 1565 if v.Object == nil { 1566 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1567 } 1568 if invalidParams.Len() > 0 { 1569 return invalidParams 1570 } else { 1571 return nil 1572 } 1573} 1574 1575func validateZendeskSourceProperties(v *types.ZendeskSourceProperties) error { 1576 if v == nil { 1577 return nil 1578 } 1579 invalidParams := smithy.InvalidParamsError{Context: "ZendeskSourceProperties"} 1580 if v.Object == nil { 1581 invalidParams.Add(smithy.NewErrParamRequired("Object")) 1582 } 1583 if invalidParams.Len() > 0 { 1584 return invalidParams 1585 } else { 1586 return nil 1587 } 1588} 1589 1590func validateOpCreateConnectorProfileInput(v *CreateConnectorProfileInput) error { 1591 if v == nil { 1592 return nil 1593 } 1594 invalidParams := smithy.InvalidParamsError{Context: "CreateConnectorProfileInput"} 1595 if v.ConnectorProfileName == nil { 1596 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileName")) 1597 } 1598 if len(v.ConnectorType) == 0 { 1599 invalidParams.Add(smithy.NewErrParamRequired("ConnectorType")) 1600 } 1601 if len(v.ConnectionMode) == 0 { 1602 invalidParams.Add(smithy.NewErrParamRequired("ConnectionMode")) 1603 } 1604 if v.ConnectorProfileConfig == nil { 1605 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileConfig")) 1606 } else if v.ConnectorProfileConfig != nil { 1607 if err := validateConnectorProfileConfig(v.ConnectorProfileConfig); err != nil { 1608 invalidParams.AddNested("ConnectorProfileConfig", err.(smithy.InvalidParamsError)) 1609 } 1610 } 1611 if invalidParams.Len() > 0 { 1612 return invalidParams 1613 } else { 1614 return nil 1615 } 1616} 1617 1618func validateOpCreateFlowInput(v *CreateFlowInput) error { 1619 if v == nil { 1620 return nil 1621 } 1622 invalidParams := smithy.InvalidParamsError{Context: "CreateFlowInput"} 1623 if v.FlowName == nil { 1624 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1625 } 1626 if v.TriggerConfig == nil { 1627 invalidParams.Add(smithy.NewErrParamRequired("TriggerConfig")) 1628 } else if v.TriggerConfig != nil { 1629 if err := validateTriggerConfig(v.TriggerConfig); err != nil { 1630 invalidParams.AddNested("TriggerConfig", err.(smithy.InvalidParamsError)) 1631 } 1632 } 1633 if v.SourceFlowConfig == nil { 1634 invalidParams.Add(smithy.NewErrParamRequired("SourceFlowConfig")) 1635 } else if v.SourceFlowConfig != nil { 1636 if err := validateSourceFlowConfig(v.SourceFlowConfig); err != nil { 1637 invalidParams.AddNested("SourceFlowConfig", err.(smithy.InvalidParamsError)) 1638 } 1639 } 1640 if v.DestinationFlowConfigList == nil { 1641 invalidParams.Add(smithy.NewErrParamRequired("DestinationFlowConfigList")) 1642 } else if v.DestinationFlowConfigList != nil { 1643 if err := validateDestinationFlowConfigList(v.DestinationFlowConfigList); err != nil { 1644 invalidParams.AddNested("DestinationFlowConfigList", err.(smithy.InvalidParamsError)) 1645 } 1646 } 1647 if v.Tasks == nil { 1648 invalidParams.Add(smithy.NewErrParamRequired("Tasks")) 1649 } else if v.Tasks != nil { 1650 if err := validateTasks(v.Tasks); err != nil { 1651 invalidParams.AddNested("Tasks", err.(smithy.InvalidParamsError)) 1652 } 1653 } 1654 if invalidParams.Len() > 0 { 1655 return invalidParams 1656 } else { 1657 return nil 1658 } 1659} 1660 1661func validateOpDeleteConnectorProfileInput(v *DeleteConnectorProfileInput) error { 1662 if v == nil { 1663 return nil 1664 } 1665 invalidParams := smithy.InvalidParamsError{Context: "DeleteConnectorProfileInput"} 1666 if v.ConnectorProfileName == nil { 1667 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileName")) 1668 } 1669 if invalidParams.Len() > 0 { 1670 return invalidParams 1671 } else { 1672 return nil 1673 } 1674} 1675 1676func validateOpDeleteFlowInput(v *DeleteFlowInput) error { 1677 if v == nil { 1678 return nil 1679 } 1680 invalidParams := smithy.InvalidParamsError{Context: "DeleteFlowInput"} 1681 if v.FlowName == nil { 1682 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1683 } 1684 if invalidParams.Len() > 0 { 1685 return invalidParams 1686 } else { 1687 return nil 1688 } 1689} 1690 1691func validateOpDescribeConnectorEntityInput(v *DescribeConnectorEntityInput) error { 1692 if v == nil { 1693 return nil 1694 } 1695 invalidParams := smithy.InvalidParamsError{Context: "DescribeConnectorEntityInput"} 1696 if v.ConnectorEntityName == nil { 1697 invalidParams.Add(smithy.NewErrParamRequired("ConnectorEntityName")) 1698 } 1699 if invalidParams.Len() > 0 { 1700 return invalidParams 1701 } else { 1702 return nil 1703 } 1704} 1705 1706func validateOpDescribeFlowExecutionRecordsInput(v *DescribeFlowExecutionRecordsInput) error { 1707 if v == nil { 1708 return nil 1709 } 1710 invalidParams := smithy.InvalidParamsError{Context: "DescribeFlowExecutionRecordsInput"} 1711 if v.FlowName == nil { 1712 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1713 } 1714 if invalidParams.Len() > 0 { 1715 return invalidParams 1716 } else { 1717 return nil 1718 } 1719} 1720 1721func validateOpDescribeFlowInput(v *DescribeFlowInput) error { 1722 if v == nil { 1723 return nil 1724 } 1725 invalidParams := smithy.InvalidParamsError{Context: "DescribeFlowInput"} 1726 if v.FlowName == nil { 1727 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1728 } 1729 if invalidParams.Len() > 0 { 1730 return invalidParams 1731 } else { 1732 return nil 1733 } 1734} 1735 1736func validateOpListTagsForResourceInput(v *ListTagsForResourceInput) error { 1737 if v == nil { 1738 return nil 1739 } 1740 invalidParams := smithy.InvalidParamsError{Context: "ListTagsForResourceInput"} 1741 if v.ResourceArn == nil { 1742 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 1743 } 1744 if invalidParams.Len() > 0 { 1745 return invalidParams 1746 } else { 1747 return nil 1748 } 1749} 1750 1751func validateOpStartFlowInput(v *StartFlowInput) error { 1752 if v == nil { 1753 return nil 1754 } 1755 invalidParams := smithy.InvalidParamsError{Context: "StartFlowInput"} 1756 if v.FlowName == nil { 1757 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1758 } 1759 if invalidParams.Len() > 0 { 1760 return invalidParams 1761 } else { 1762 return nil 1763 } 1764} 1765 1766func validateOpStopFlowInput(v *StopFlowInput) error { 1767 if v == nil { 1768 return nil 1769 } 1770 invalidParams := smithy.InvalidParamsError{Context: "StopFlowInput"} 1771 if v.FlowName == nil { 1772 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1773 } 1774 if invalidParams.Len() > 0 { 1775 return invalidParams 1776 } else { 1777 return nil 1778 } 1779} 1780 1781func validateOpTagResourceInput(v *TagResourceInput) error { 1782 if v == nil { 1783 return nil 1784 } 1785 invalidParams := smithy.InvalidParamsError{Context: "TagResourceInput"} 1786 if v.ResourceArn == nil { 1787 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 1788 } 1789 if v.Tags == nil { 1790 invalidParams.Add(smithy.NewErrParamRequired("Tags")) 1791 } 1792 if invalidParams.Len() > 0 { 1793 return invalidParams 1794 } else { 1795 return nil 1796 } 1797} 1798 1799func validateOpUntagResourceInput(v *UntagResourceInput) error { 1800 if v == nil { 1801 return nil 1802 } 1803 invalidParams := smithy.InvalidParamsError{Context: "UntagResourceInput"} 1804 if v.ResourceArn == nil { 1805 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 1806 } 1807 if v.TagKeys == nil { 1808 invalidParams.Add(smithy.NewErrParamRequired("TagKeys")) 1809 } 1810 if invalidParams.Len() > 0 { 1811 return invalidParams 1812 } else { 1813 return nil 1814 } 1815} 1816 1817func validateOpUpdateConnectorProfileInput(v *UpdateConnectorProfileInput) error { 1818 if v == nil { 1819 return nil 1820 } 1821 invalidParams := smithy.InvalidParamsError{Context: "UpdateConnectorProfileInput"} 1822 if v.ConnectorProfileName == nil { 1823 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileName")) 1824 } 1825 if len(v.ConnectionMode) == 0 { 1826 invalidParams.Add(smithy.NewErrParamRequired("ConnectionMode")) 1827 } 1828 if v.ConnectorProfileConfig == nil { 1829 invalidParams.Add(smithy.NewErrParamRequired("ConnectorProfileConfig")) 1830 } else if v.ConnectorProfileConfig != nil { 1831 if err := validateConnectorProfileConfig(v.ConnectorProfileConfig); err != nil { 1832 invalidParams.AddNested("ConnectorProfileConfig", err.(smithy.InvalidParamsError)) 1833 } 1834 } 1835 if invalidParams.Len() > 0 { 1836 return invalidParams 1837 } else { 1838 return nil 1839 } 1840} 1841 1842func validateOpUpdateFlowInput(v *UpdateFlowInput) error { 1843 if v == nil { 1844 return nil 1845 } 1846 invalidParams := smithy.InvalidParamsError{Context: "UpdateFlowInput"} 1847 if v.FlowName == nil { 1848 invalidParams.Add(smithy.NewErrParamRequired("FlowName")) 1849 } 1850 if v.TriggerConfig == nil { 1851 invalidParams.Add(smithy.NewErrParamRequired("TriggerConfig")) 1852 } else if v.TriggerConfig != nil { 1853 if err := validateTriggerConfig(v.TriggerConfig); err != nil { 1854 invalidParams.AddNested("TriggerConfig", err.(smithy.InvalidParamsError)) 1855 } 1856 } 1857 if v.SourceFlowConfig != nil { 1858 if err := validateSourceFlowConfig(v.SourceFlowConfig); err != nil { 1859 invalidParams.AddNested("SourceFlowConfig", err.(smithy.InvalidParamsError)) 1860 } 1861 } 1862 if v.DestinationFlowConfigList == nil { 1863 invalidParams.Add(smithy.NewErrParamRequired("DestinationFlowConfigList")) 1864 } else if v.DestinationFlowConfigList != nil { 1865 if err := validateDestinationFlowConfigList(v.DestinationFlowConfigList); err != nil { 1866 invalidParams.AddNested("DestinationFlowConfigList", err.(smithy.InvalidParamsError)) 1867 } 1868 } 1869 if v.Tasks == nil { 1870 invalidParams.Add(smithy.NewErrParamRequired("Tasks")) 1871 } else if v.Tasks != nil { 1872 if err := validateTasks(v.Tasks); err != nil { 1873 invalidParams.AddNested("Tasks", err.(smithy.InvalidParamsError)) 1874 } 1875 } 1876 if invalidParams.Len() > 0 { 1877 return invalidParams 1878 } else { 1879 return nil 1880 } 1881} 1882