1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package iotjobsdataplane 4 5import ( 6 "context" 7 "fmt" 8 smithy "github.com/aws/smithy-go" 9 "github.com/aws/smithy-go/middleware" 10) 11 12type validateOpDescribeJobExecution struct { 13} 14 15func (*validateOpDescribeJobExecution) ID() string { 16 return "OperationInputValidation" 17} 18 19func (m *validateOpDescribeJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 20 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 21) { 22 input, ok := in.Parameters.(*DescribeJobExecutionInput) 23 if !ok { 24 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 25 } 26 if err := validateOpDescribeJobExecutionInput(input); err != nil { 27 return out, metadata, err 28 } 29 return next.HandleInitialize(ctx, in) 30} 31 32type validateOpGetPendingJobExecutions struct { 33} 34 35func (*validateOpGetPendingJobExecutions) ID() string { 36 return "OperationInputValidation" 37} 38 39func (m *validateOpGetPendingJobExecutions) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 40 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 41) { 42 input, ok := in.Parameters.(*GetPendingJobExecutionsInput) 43 if !ok { 44 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 45 } 46 if err := validateOpGetPendingJobExecutionsInput(input); err != nil { 47 return out, metadata, err 48 } 49 return next.HandleInitialize(ctx, in) 50} 51 52type validateOpStartNextPendingJobExecution struct { 53} 54 55func (*validateOpStartNextPendingJobExecution) ID() string { 56 return "OperationInputValidation" 57} 58 59func (m *validateOpStartNextPendingJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 60 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 61) { 62 input, ok := in.Parameters.(*StartNextPendingJobExecutionInput) 63 if !ok { 64 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 65 } 66 if err := validateOpStartNextPendingJobExecutionInput(input); err != nil { 67 return out, metadata, err 68 } 69 return next.HandleInitialize(ctx, in) 70} 71 72type validateOpUpdateJobExecution struct { 73} 74 75func (*validateOpUpdateJobExecution) ID() string { 76 return "OperationInputValidation" 77} 78 79func (m *validateOpUpdateJobExecution) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 80 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 81) { 82 input, ok := in.Parameters.(*UpdateJobExecutionInput) 83 if !ok { 84 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 85 } 86 if err := validateOpUpdateJobExecutionInput(input); err != nil { 87 return out, metadata, err 88 } 89 return next.HandleInitialize(ctx, in) 90} 91 92func addOpDescribeJobExecutionValidationMiddleware(stack *middleware.Stack) error { 93 return stack.Initialize.Add(&validateOpDescribeJobExecution{}, middleware.After) 94} 95 96func addOpGetPendingJobExecutionsValidationMiddleware(stack *middleware.Stack) error { 97 return stack.Initialize.Add(&validateOpGetPendingJobExecutions{}, middleware.After) 98} 99 100func addOpStartNextPendingJobExecutionValidationMiddleware(stack *middleware.Stack) error { 101 return stack.Initialize.Add(&validateOpStartNextPendingJobExecution{}, middleware.After) 102} 103 104func addOpUpdateJobExecutionValidationMiddleware(stack *middleware.Stack) error { 105 return stack.Initialize.Add(&validateOpUpdateJobExecution{}, middleware.After) 106} 107 108func validateOpDescribeJobExecutionInput(v *DescribeJobExecutionInput) error { 109 if v == nil { 110 return nil 111 } 112 invalidParams := smithy.InvalidParamsError{Context: "DescribeJobExecutionInput"} 113 if v.JobId == nil { 114 invalidParams.Add(smithy.NewErrParamRequired("JobId")) 115 } 116 if v.ThingName == nil { 117 invalidParams.Add(smithy.NewErrParamRequired("ThingName")) 118 } 119 if invalidParams.Len() > 0 { 120 return invalidParams 121 } else { 122 return nil 123 } 124} 125 126func validateOpGetPendingJobExecutionsInput(v *GetPendingJobExecutionsInput) error { 127 if v == nil { 128 return nil 129 } 130 invalidParams := smithy.InvalidParamsError{Context: "GetPendingJobExecutionsInput"} 131 if v.ThingName == nil { 132 invalidParams.Add(smithy.NewErrParamRequired("ThingName")) 133 } 134 if invalidParams.Len() > 0 { 135 return invalidParams 136 } else { 137 return nil 138 } 139} 140 141func validateOpStartNextPendingJobExecutionInput(v *StartNextPendingJobExecutionInput) error { 142 if v == nil { 143 return nil 144 } 145 invalidParams := smithy.InvalidParamsError{Context: "StartNextPendingJobExecutionInput"} 146 if v.ThingName == nil { 147 invalidParams.Add(smithy.NewErrParamRequired("ThingName")) 148 } 149 if invalidParams.Len() > 0 { 150 return invalidParams 151 } else { 152 return nil 153 } 154} 155 156func validateOpUpdateJobExecutionInput(v *UpdateJobExecutionInput) error { 157 if v == nil { 158 return nil 159 } 160 invalidParams := smithy.InvalidParamsError{Context: "UpdateJobExecutionInput"} 161 if v.JobId == nil { 162 invalidParams.Add(smithy.NewErrParamRequired("JobId")) 163 } 164 if v.ThingName == nil { 165 invalidParams.Add(smithy.NewErrParamRequired("ThingName")) 166 } 167 if len(v.Status) == 0 { 168 invalidParams.Add(smithy.NewErrParamRequired("Status")) 169 } 170 if invalidParams.Len() > 0 { 171 return invalidParams 172 } else { 173 return nil 174 } 175} 176