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