1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package kafkaconnect 4 5import ( 6 "context" 7 "fmt" 8 "github.com/aws/aws-sdk-go-v2/service/kafkaconnect/types" 9 smithy "github.com/aws/smithy-go" 10 "github.com/aws/smithy-go/middleware" 11) 12 13type validateOpCreateConnector struct { 14} 15 16func (*validateOpCreateConnector) ID() string { 17 return "OperationInputValidation" 18} 19 20func (m *validateOpCreateConnector) 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.(*CreateConnectorInput) 24 if !ok { 25 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 26 } 27 if err := validateOpCreateConnectorInput(input); err != nil { 28 return out, metadata, err 29 } 30 return next.HandleInitialize(ctx, in) 31} 32 33type validateOpCreateCustomPlugin struct { 34} 35 36func (*validateOpCreateCustomPlugin) ID() string { 37 return "OperationInputValidation" 38} 39 40func (m *validateOpCreateCustomPlugin) 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.(*CreateCustomPluginInput) 44 if !ok { 45 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 46 } 47 if err := validateOpCreateCustomPluginInput(input); err != nil { 48 return out, metadata, err 49 } 50 return next.HandleInitialize(ctx, in) 51} 52 53type validateOpCreateWorkerConfiguration struct { 54} 55 56func (*validateOpCreateWorkerConfiguration) ID() string { 57 return "OperationInputValidation" 58} 59 60func (m *validateOpCreateWorkerConfiguration) 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.(*CreateWorkerConfigurationInput) 64 if !ok { 65 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 66 } 67 if err := validateOpCreateWorkerConfigurationInput(input); err != nil { 68 return out, metadata, err 69 } 70 return next.HandleInitialize(ctx, in) 71} 72 73type validateOpDeleteConnector struct { 74} 75 76func (*validateOpDeleteConnector) ID() string { 77 return "OperationInputValidation" 78} 79 80func (m *validateOpDeleteConnector) 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.(*DeleteConnectorInput) 84 if !ok { 85 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 86 } 87 if err := validateOpDeleteConnectorInput(input); err != nil { 88 return out, metadata, err 89 } 90 return next.HandleInitialize(ctx, in) 91} 92 93type validateOpDescribeConnector struct { 94} 95 96func (*validateOpDescribeConnector) ID() string { 97 return "OperationInputValidation" 98} 99 100func (m *validateOpDescribeConnector) 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.(*DescribeConnectorInput) 104 if !ok { 105 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 106 } 107 if err := validateOpDescribeConnectorInput(input); err != nil { 108 return out, metadata, err 109 } 110 return next.HandleInitialize(ctx, in) 111} 112 113type validateOpDescribeCustomPlugin struct { 114} 115 116func (*validateOpDescribeCustomPlugin) ID() string { 117 return "OperationInputValidation" 118} 119 120func (m *validateOpDescribeCustomPlugin) 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.(*DescribeCustomPluginInput) 124 if !ok { 125 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 126 } 127 if err := validateOpDescribeCustomPluginInput(input); err != nil { 128 return out, metadata, err 129 } 130 return next.HandleInitialize(ctx, in) 131} 132 133type validateOpDescribeWorkerConfiguration struct { 134} 135 136func (*validateOpDescribeWorkerConfiguration) ID() string { 137 return "OperationInputValidation" 138} 139 140func (m *validateOpDescribeWorkerConfiguration) 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.(*DescribeWorkerConfigurationInput) 144 if !ok { 145 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 146 } 147 if err := validateOpDescribeWorkerConfigurationInput(input); err != nil { 148 return out, metadata, err 149 } 150 return next.HandleInitialize(ctx, in) 151} 152 153type validateOpUpdateConnector struct { 154} 155 156func (*validateOpUpdateConnector) ID() string { 157 return "OperationInputValidation" 158} 159 160func (m *validateOpUpdateConnector) 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.(*UpdateConnectorInput) 164 if !ok { 165 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 166 } 167 if err := validateOpUpdateConnectorInput(input); err != nil { 168 return out, metadata, err 169 } 170 return next.HandleInitialize(ctx, in) 171} 172 173func addOpCreateConnectorValidationMiddleware(stack *middleware.Stack) error { 174 return stack.Initialize.Add(&validateOpCreateConnector{}, middleware.After) 175} 176 177func addOpCreateCustomPluginValidationMiddleware(stack *middleware.Stack) error { 178 return stack.Initialize.Add(&validateOpCreateCustomPlugin{}, middleware.After) 179} 180 181func addOpCreateWorkerConfigurationValidationMiddleware(stack *middleware.Stack) error { 182 return stack.Initialize.Add(&validateOpCreateWorkerConfiguration{}, middleware.After) 183} 184 185func addOpDeleteConnectorValidationMiddleware(stack *middleware.Stack) error { 186 return stack.Initialize.Add(&validateOpDeleteConnector{}, middleware.After) 187} 188 189func addOpDescribeConnectorValidationMiddleware(stack *middleware.Stack) error { 190 return stack.Initialize.Add(&validateOpDescribeConnector{}, middleware.After) 191} 192 193func addOpDescribeCustomPluginValidationMiddleware(stack *middleware.Stack) error { 194 return stack.Initialize.Add(&validateOpDescribeCustomPlugin{}, middleware.After) 195} 196 197func addOpDescribeWorkerConfigurationValidationMiddleware(stack *middleware.Stack) error { 198 return stack.Initialize.Add(&validateOpDescribeWorkerConfiguration{}, middleware.After) 199} 200 201func addOpUpdateConnectorValidationMiddleware(stack *middleware.Stack) error { 202 return stack.Initialize.Add(&validateOpUpdateConnector{}, middleware.After) 203} 204 205func validate__listOfPlugin(v []types.Plugin) error { 206 if v == nil { 207 return nil 208 } 209 invalidParams := smithy.InvalidParamsError{Context: "ListOfPlugin"} 210 for i := range v { 211 if err := validatePlugin(&v[i]); err != nil { 212 invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError)) 213 } 214 } 215 if invalidParams.Len() > 0 { 216 return invalidParams 217 } else { 218 return nil 219 } 220} 221 222func validateApacheKafkaCluster(v *types.ApacheKafkaCluster) error { 223 if v == nil { 224 return nil 225 } 226 invalidParams := smithy.InvalidParamsError{Context: "ApacheKafkaCluster"} 227 if v.BootstrapServers == nil { 228 invalidParams.Add(smithy.NewErrParamRequired("BootstrapServers")) 229 } 230 if v.Vpc == nil { 231 invalidParams.Add(smithy.NewErrParamRequired("Vpc")) 232 } else if v.Vpc != nil { 233 if err := validateVpc(v.Vpc); err != nil { 234 invalidParams.AddNested("Vpc", err.(smithy.InvalidParamsError)) 235 } 236 } 237 if invalidParams.Len() > 0 { 238 return invalidParams 239 } else { 240 return nil 241 } 242} 243 244func validateAutoScaling(v *types.AutoScaling) error { 245 if v == nil { 246 return nil 247 } 248 invalidParams := smithy.InvalidParamsError{Context: "AutoScaling"} 249 if v.ScaleInPolicy != nil { 250 if err := validateScaleInPolicy(v.ScaleInPolicy); err != nil { 251 invalidParams.AddNested("ScaleInPolicy", err.(smithy.InvalidParamsError)) 252 } 253 } 254 if v.ScaleOutPolicy != nil { 255 if err := validateScaleOutPolicy(v.ScaleOutPolicy); err != nil { 256 invalidParams.AddNested("ScaleOutPolicy", err.(smithy.InvalidParamsError)) 257 } 258 } 259 if invalidParams.Len() > 0 { 260 return invalidParams 261 } else { 262 return nil 263 } 264} 265 266func validateAutoScalingUpdate(v *types.AutoScalingUpdate) error { 267 if v == nil { 268 return nil 269 } 270 invalidParams := smithy.InvalidParamsError{Context: "AutoScalingUpdate"} 271 if v.ScaleInPolicy == nil { 272 invalidParams.Add(smithy.NewErrParamRequired("ScaleInPolicy")) 273 } else if v.ScaleInPolicy != nil { 274 if err := validateScaleInPolicyUpdate(v.ScaleInPolicy); err != nil { 275 invalidParams.AddNested("ScaleInPolicy", err.(smithy.InvalidParamsError)) 276 } 277 } 278 if v.ScaleOutPolicy == nil { 279 invalidParams.Add(smithy.NewErrParamRequired("ScaleOutPolicy")) 280 } else if v.ScaleOutPolicy != nil { 281 if err := validateScaleOutPolicyUpdate(v.ScaleOutPolicy); err != nil { 282 invalidParams.AddNested("ScaleOutPolicy", err.(smithy.InvalidParamsError)) 283 } 284 } 285 if invalidParams.Len() > 0 { 286 return invalidParams 287 } else { 288 return nil 289 } 290} 291 292func validateCapacity(v *types.Capacity) error { 293 if v == nil { 294 return nil 295 } 296 invalidParams := smithy.InvalidParamsError{Context: "Capacity"} 297 if v.AutoScaling != nil { 298 if err := validateAutoScaling(v.AutoScaling); err != nil { 299 invalidParams.AddNested("AutoScaling", err.(smithy.InvalidParamsError)) 300 } 301 } 302 if v.ProvisionedCapacity != nil { 303 if err := validateProvisionedCapacity(v.ProvisionedCapacity); err != nil { 304 invalidParams.AddNested("ProvisionedCapacity", err.(smithy.InvalidParamsError)) 305 } 306 } 307 if invalidParams.Len() > 0 { 308 return invalidParams 309 } else { 310 return nil 311 } 312} 313 314func validateCapacityUpdate(v *types.CapacityUpdate) error { 315 if v == nil { 316 return nil 317 } 318 invalidParams := smithy.InvalidParamsError{Context: "CapacityUpdate"} 319 if v.AutoScaling != nil { 320 if err := validateAutoScalingUpdate(v.AutoScaling); err != nil { 321 invalidParams.AddNested("AutoScaling", err.(smithy.InvalidParamsError)) 322 } 323 } 324 if v.ProvisionedCapacity != nil { 325 if err := validateProvisionedCapacityUpdate(v.ProvisionedCapacity); err != nil { 326 invalidParams.AddNested("ProvisionedCapacity", err.(smithy.InvalidParamsError)) 327 } 328 } 329 if invalidParams.Len() > 0 { 330 return invalidParams 331 } else { 332 return nil 333 } 334} 335 336func validateCloudWatchLogsLogDelivery(v *types.CloudWatchLogsLogDelivery) error { 337 if v == nil { 338 return nil 339 } 340 invalidParams := smithy.InvalidParamsError{Context: "CloudWatchLogsLogDelivery"} 341 if invalidParams.Len() > 0 { 342 return invalidParams 343 } else { 344 return nil 345 } 346} 347 348func validateCustomPlugin(v *types.CustomPlugin) error { 349 if v == nil { 350 return nil 351 } 352 invalidParams := smithy.InvalidParamsError{Context: "CustomPlugin"} 353 if v.CustomPluginArn == nil { 354 invalidParams.Add(smithy.NewErrParamRequired("CustomPluginArn")) 355 } 356 if invalidParams.Len() > 0 { 357 return invalidParams 358 } else { 359 return nil 360 } 361} 362 363func validateCustomPluginLocation(v *types.CustomPluginLocation) error { 364 if v == nil { 365 return nil 366 } 367 invalidParams := smithy.InvalidParamsError{Context: "CustomPluginLocation"} 368 if v.S3Location == nil { 369 invalidParams.Add(smithy.NewErrParamRequired("S3Location")) 370 } else if v.S3Location != nil { 371 if err := validateS3Location(v.S3Location); err != nil { 372 invalidParams.AddNested("S3Location", err.(smithy.InvalidParamsError)) 373 } 374 } 375 if invalidParams.Len() > 0 { 376 return invalidParams 377 } else { 378 return nil 379 } 380} 381 382func validateFirehoseLogDelivery(v *types.FirehoseLogDelivery) error { 383 if v == nil { 384 return nil 385 } 386 invalidParams := smithy.InvalidParamsError{Context: "FirehoseLogDelivery"} 387 if invalidParams.Len() > 0 { 388 return invalidParams 389 } else { 390 return nil 391 } 392} 393 394func validateKafkaCluster(v *types.KafkaCluster) error { 395 if v == nil { 396 return nil 397 } 398 invalidParams := smithy.InvalidParamsError{Context: "KafkaCluster"} 399 if v.ApacheKafkaCluster == nil { 400 invalidParams.Add(smithy.NewErrParamRequired("ApacheKafkaCluster")) 401 } else if v.ApacheKafkaCluster != nil { 402 if err := validateApacheKafkaCluster(v.ApacheKafkaCluster); err != nil { 403 invalidParams.AddNested("ApacheKafkaCluster", err.(smithy.InvalidParamsError)) 404 } 405 } 406 if invalidParams.Len() > 0 { 407 return invalidParams 408 } else { 409 return nil 410 } 411} 412 413func validateKafkaClusterClientAuthentication(v *types.KafkaClusterClientAuthentication) error { 414 if v == nil { 415 return nil 416 } 417 invalidParams := smithy.InvalidParamsError{Context: "KafkaClusterClientAuthentication"} 418 if len(v.AuthenticationType) == 0 { 419 invalidParams.Add(smithy.NewErrParamRequired("AuthenticationType")) 420 } 421 if invalidParams.Len() > 0 { 422 return invalidParams 423 } else { 424 return nil 425 } 426} 427 428func validateKafkaClusterEncryptionInTransit(v *types.KafkaClusterEncryptionInTransit) error { 429 if v == nil { 430 return nil 431 } 432 invalidParams := smithy.InvalidParamsError{Context: "KafkaClusterEncryptionInTransit"} 433 if len(v.EncryptionType) == 0 { 434 invalidParams.Add(smithy.NewErrParamRequired("EncryptionType")) 435 } 436 if invalidParams.Len() > 0 { 437 return invalidParams 438 } else { 439 return nil 440 } 441} 442 443func validateLogDelivery(v *types.LogDelivery) error { 444 if v == nil { 445 return nil 446 } 447 invalidParams := smithy.InvalidParamsError{Context: "LogDelivery"} 448 if v.WorkerLogDelivery == nil { 449 invalidParams.Add(smithy.NewErrParamRequired("WorkerLogDelivery")) 450 } else if v.WorkerLogDelivery != nil { 451 if err := validateWorkerLogDelivery(v.WorkerLogDelivery); err != nil { 452 invalidParams.AddNested("WorkerLogDelivery", err.(smithy.InvalidParamsError)) 453 } 454 } 455 if invalidParams.Len() > 0 { 456 return invalidParams 457 } else { 458 return nil 459 } 460} 461 462func validatePlugin(v *types.Plugin) error { 463 if v == nil { 464 return nil 465 } 466 invalidParams := smithy.InvalidParamsError{Context: "Plugin"} 467 if v.CustomPlugin == nil { 468 invalidParams.Add(smithy.NewErrParamRequired("CustomPlugin")) 469 } else if v.CustomPlugin != nil { 470 if err := validateCustomPlugin(v.CustomPlugin); err != nil { 471 invalidParams.AddNested("CustomPlugin", err.(smithy.InvalidParamsError)) 472 } 473 } 474 if invalidParams.Len() > 0 { 475 return invalidParams 476 } else { 477 return nil 478 } 479} 480 481func validateProvisionedCapacity(v *types.ProvisionedCapacity) error { 482 if v == nil { 483 return nil 484 } 485 invalidParams := smithy.InvalidParamsError{Context: "ProvisionedCapacity"} 486 if invalidParams.Len() > 0 { 487 return invalidParams 488 } else { 489 return nil 490 } 491} 492 493func validateProvisionedCapacityUpdate(v *types.ProvisionedCapacityUpdate) error { 494 if v == nil { 495 return nil 496 } 497 invalidParams := smithy.InvalidParamsError{Context: "ProvisionedCapacityUpdate"} 498 if invalidParams.Len() > 0 { 499 return invalidParams 500 } else { 501 return nil 502 } 503} 504 505func validateS3Location(v *types.S3Location) error { 506 if v == nil { 507 return nil 508 } 509 invalidParams := smithy.InvalidParamsError{Context: "S3Location"} 510 if v.BucketArn == nil { 511 invalidParams.Add(smithy.NewErrParamRequired("BucketArn")) 512 } 513 if v.FileKey == nil { 514 invalidParams.Add(smithy.NewErrParamRequired("FileKey")) 515 } 516 if invalidParams.Len() > 0 { 517 return invalidParams 518 } else { 519 return nil 520 } 521} 522 523func validateS3LogDelivery(v *types.S3LogDelivery) error { 524 if v == nil { 525 return nil 526 } 527 invalidParams := smithy.InvalidParamsError{Context: "S3LogDelivery"} 528 if invalidParams.Len() > 0 { 529 return invalidParams 530 } else { 531 return nil 532 } 533} 534 535func validateScaleInPolicy(v *types.ScaleInPolicy) error { 536 if v == nil { 537 return nil 538 } 539 invalidParams := smithy.InvalidParamsError{Context: "ScaleInPolicy"} 540 if invalidParams.Len() > 0 { 541 return invalidParams 542 } else { 543 return nil 544 } 545} 546 547func validateScaleInPolicyUpdate(v *types.ScaleInPolicyUpdate) error { 548 if v == nil { 549 return nil 550 } 551 invalidParams := smithy.InvalidParamsError{Context: "ScaleInPolicyUpdate"} 552 if invalidParams.Len() > 0 { 553 return invalidParams 554 } else { 555 return nil 556 } 557} 558 559func validateScaleOutPolicy(v *types.ScaleOutPolicy) error { 560 if v == nil { 561 return nil 562 } 563 invalidParams := smithy.InvalidParamsError{Context: "ScaleOutPolicy"} 564 if invalidParams.Len() > 0 { 565 return invalidParams 566 } else { 567 return nil 568 } 569} 570 571func validateScaleOutPolicyUpdate(v *types.ScaleOutPolicyUpdate) error { 572 if v == nil { 573 return nil 574 } 575 invalidParams := smithy.InvalidParamsError{Context: "ScaleOutPolicyUpdate"} 576 if invalidParams.Len() > 0 { 577 return invalidParams 578 } else { 579 return nil 580 } 581} 582 583func validateVpc(v *types.Vpc) error { 584 if v == nil { 585 return nil 586 } 587 invalidParams := smithy.InvalidParamsError{Context: "Vpc"} 588 if v.Subnets == nil { 589 invalidParams.Add(smithy.NewErrParamRequired("Subnets")) 590 } 591 if invalidParams.Len() > 0 { 592 return invalidParams 593 } else { 594 return nil 595 } 596} 597 598func validateWorkerConfiguration(v *types.WorkerConfiguration) error { 599 if v == nil { 600 return nil 601 } 602 invalidParams := smithy.InvalidParamsError{Context: "WorkerConfiguration"} 603 if v.WorkerConfigurationArn == nil { 604 invalidParams.Add(smithy.NewErrParamRequired("WorkerConfigurationArn")) 605 } 606 if invalidParams.Len() > 0 { 607 return invalidParams 608 } else { 609 return nil 610 } 611} 612 613func validateWorkerLogDelivery(v *types.WorkerLogDelivery) error { 614 if v == nil { 615 return nil 616 } 617 invalidParams := smithy.InvalidParamsError{Context: "WorkerLogDelivery"} 618 if v.CloudWatchLogs != nil { 619 if err := validateCloudWatchLogsLogDelivery(v.CloudWatchLogs); err != nil { 620 invalidParams.AddNested("CloudWatchLogs", err.(smithy.InvalidParamsError)) 621 } 622 } 623 if v.Firehose != nil { 624 if err := validateFirehoseLogDelivery(v.Firehose); err != nil { 625 invalidParams.AddNested("Firehose", err.(smithy.InvalidParamsError)) 626 } 627 } 628 if v.S3 != nil { 629 if err := validateS3LogDelivery(v.S3); err != nil { 630 invalidParams.AddNested("S3", err.(smithy.InvalidParamsError)) 631 } 632 } 633 if invalidParams.Len() > 0 { 634 return invalidParams 635 } else { 636 return nil 637 } 638} 639 640func validateOpCreateConnectorInput(v *CreateConnectorInput) error { 641 if v == nil { 642 return nil 643 } 644 invalidParams := smithy.InvalidParamsError{Context: "CreateConnectorInput"} 645 if v.Capacity == nil { 646 invalidParams.Add(smithy.NewErrParamRequired("Capacity")) 647 } else if v.Capacity != nil { 648 if err := validateCapacity(v.Capacity); err != nil { 649 invalidParams.AddNested("Capacity", err.(smithy.InvalidParamsError)) 650 } 651 } 652 if v.ConnectorConfiguration == nil { 653 invalidParams.Add(smithy.NewErrParamRequired("ConnectorConfiguration")) 654 } 655 if v.ConnectorName == nil { 656 invalidParams.Add(smithy.NewErrParamRequired("ConnectorName")) 657 } 658 if v.KafkaCluster == nil { 659 invalidParams.Add(smithy.NewErrParamRequired("KafkaCluster")) 660 } else if v.KafkaCluster != nil { 661 if err := validateKafkaCluster(v.KafkaCluster); err != nil { 662 invalidParams.AddNested("KafkaCluster", err.(smithy.InvalidParamsError)) 663 } 664 } 665 if v.KafkaClusterClientAuthentication == nil { 666 invalidParams.Add(smithy.NewErrParamRequired("KafkaClusterClientAuthentication")) 667 } else if v.KafkaClusterClientAuthentication != nil { 668 if err := validateKafkaClusterClientAuthentication(v.KafkaClusterClientAuthentication); err != nil { 669 invalidParams.AddNested("KafkaClusterClientAuthentication", err.(smithy.InvalidParamsError)) 670 } 671 } 672 if v.KafkaClusterEncryptionInTransit == nil { 673 invalidParams.Add(smithy.NewErrParamRequired("KafkaClusterEncryptionInTransit")) 674 } else if v.KafkaClusterEncryptionInTransit != nil { 675 if err := validateKafkaClusterEncryptionInTransit(v.KafkaClusterEncryptionInTransit); err != nil { 676 invalidParams.AddNested("KafkaClusterEncryptionInTransit", err.(smithy.InvalidParamsError)) 677 } 678 } 679 if v.KafkaConnectVersion == nil { 680 invalidParams.Add(smithy.NewErrParamRequired("KafkaConnectVersion")) 681 } 682 if v.LogDelivery != nil { 683 if err := validateLogDelivery(v.LogDelivery); err != nil { 684 invalidParams.AddNested("LogDelivery", err.(smithy.InvalidParamsError)) 685 } 686 } 687 if v.Plugins == nil { 688 invalidParams.Add(smithy.NewErrParamRequired("Plugins")) 689 } else if v.Plugins != nil { 690 if err := validate__listOfPlugin(v.Plugins); err != nil { 691 invalidParams.AddNested("Plugins", err.(smithy.InvalidParamsError)) 692 } 693 } 694 if v.ServiceExecutionRoleArn == nil { 695 invalidParams.Add(smithy.NewErrParamRequired("ServiceExecutionRoleArn")) 696 } 697 if v.WorkerConfiguration != nil { 698 if err := validateWorkerConfiguration(v.WorkerConfiguration); err != nil { 699 invalidParams.AddNested("WorkerConfiguration", err.(smithy.InvalidParamsError)) 700 } 701 } 702 if invalidParams.Len() > 0 { 703 return invalidParams 704 } else { 705 return nil 706 } 707} 708 709func validateOpCreateCustomPluginInput(v *CreateCustomPluginInput) error { 710 if v == nil { 711 return nil 712 } 713 invalidParams := smithy.InvalidParamsError{Context: "CreateCustomPluginInput"} 714 if len(v.ContentType) == 0 { 715 invalidParams.Add(smithy.NewErrParamRequired("ContentType")) 716 } 717 if v.Location == nil { 718 invalidParams.Add(smithy.NewErrParamRequired("Location")) 719 } else if v.Location != nil { 720 if err := validateCustomPluginLocation(v.Location); err != nil { 721 invalidParams.AddNested("Location", err.(smithy.InvalidParamsError)) 722 } 723 } 724 if v.Name == nil { 725 invalidParams.Add(smithy.NewErrParamRequired("Name")) 726 } 727 if invalidParams.Len() > 0 { 728 return invalidParams 729 } else { 730 return nil 731 } 732} 733 734func validateOpCreateWorkerConfigurationInput(v *CreateWorkerConfigurationInput) error { 735 if v == nil { 736 return nil 737 } 738 invalidParams := smithy.InvalidParamsError{Context: "CreateWorkerConfigurationInput"} 739 if v.Name == nil { 740 invalidParams.Add(smithy.NewErrParamRequired("Name")) 741 } 742 if v.PropertiesFileContent == nil { 743 invalidParams.Add(smithy.NewErrParamRequired("PropertiesFileContent")) 744 } 745 if invalidParams.Len() > 0 { 746 return invalidParams 747 } else { 748 return nil 749 } 750} 751 752func validateOpDeleteConnectorInput(v *DeleteConnectorInput) error { 753 if v == nil { 754 return nil 755 } 756 invalidParams := smithy.InvalidParamsError{Context: "DeleteConnectorInput"} 757 if v.ConnectorArn == nil { 758 invalidParams.Add(smithy.NewErrParamRequired("ConnectorArn")) 759 } 760 if invalidParams.Len() > 0 { 761 return invalidParams 762 } else { 763 return nil 764 } 765} 766 767func validateOpDescribeConnectorInput(v *DescribeConnectorInput) error { 768 if v == nil { 769 return nil 770 } 771 invalidParams := smithy.InvalidParamsError{Context: "DescribeConnectorInput"} 772 if v.ConnectorArn == nil { 773 invalidParams.Add(smithy.NewErrParamRequired("ConnectorArn")) 774 } 775 if invalidParams.Len() > 0 { 776 return invalidParams 777 } else { 778 return nil 779 } 780} 781 782func validateOpDescribeCustomPluginInput(v *DescribeCustomPluginInput) error { 783 if v == nil { 784 return nil 785 } 786 invalidParams := smithy.InvalidParamsError{Context: "DescribeCustomPluginInput"} 787 if v.CustomPluginArn == nil { 788 invalidParams.Add(smithy.NewErrParamRequired("CustomPluginArn")) 789 } 790 if invalidParams.Len() > 0 { 791 return invalidParams 792 } else { 793 return nil 794 } 795} 796 797func validateOpDescribeWorkerConfigurationInput(v *DescribeWorkerConfigurationInput) error { 798 if v == nil { 799 return nil 800 } 801 invalidParams := smithy.InvalidParamsError{Context: "DescribeWorkerConfigurationInput"} 802 if v.WorkerConfigurationArn == nil { 803 invalidParams.Add(smithy.NewErrParamRequired("WorkerConfigurationArn")) 804 } 805 if invalidParams.Len() > 0 { 806 return invalidParams 807 } else { 808 return nil 809 } 810} 811 812func validateOpUpdateConnectorInput(v *UpdateConnectorInput) error { 813 if v == nil { 814 return nil 815 } 816 invalidParams := smithy.InvalidParamsError{Context: "UpdateConnectorInput"} 817 if v.Capacity == nil { 818 invalidParams.Add(smithy.NewErrParamRequired("Capacity")) 819 } else if v.Capacity != nil { 820 if err := validateCapacityUpdate(v.Capacity); err != nil { 821 invalidParams.AddNested("Capacity", err.(smithy.InvalidParamsError)) 822 } 823 } 824 if v.ConnectorArn == nil { 825 invalidParams.Add(smithy.NewErrParamRequired("ConnectorArn")) 826 } 827 if v.CurrentVersion == nil { 828 invalidParams.Add(smithy.NewErrParamRequired("CurrentVersion")) 829 } 830 if invalidParams.Len() > 0 { 831 return invalidParams 832 } else { 833 return nil 834 } 835} 836