1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package kinesisanalyticsv2 4 5import ( 6 "bytes" 7 "context" 8 "fmt" 9 "github.com/aws/aws-sdk-go-v2/service/kinesisanalyticsv2/types" 10 smithy "github.com/aws/smithy-go" 11 "github.com/aws/smithy-go/encoding/httpbinding" 12 smithyjson "github.com/aws/smithy-go/encoding/json" 13 "github.com/aws/smithy-go/middleware" 14 smithytime "github.com/aws/smithy-go/time" 15 smithyhttp "github.com/aws/smithy-go/transport/http" 16) 17 18type awsAwsjson11_serializeOpAddApplicationCloudWatchLoggingOption struct { 19} 20 21func (*awsAwsjson11_serializeOpAddApplicationCloudWatchLoggingOption) ID() string { 22 return "OperationSerializer" 23} 24 25func (m *awsAwsjson11_serializeOpAddApplicationCloudWatchLoggingOption) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 26 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 27) { 28 request, ok := in.Request.(*smithyhttp.Request) 29 if !ok { 30 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 31 } 32 33 input, ok := in.Parameters.(*AddApplicationCloudWatchLoggingOptionInput) 34 _ = input 35 if !ok { 36 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 37 } 38 39 request.Request.URL.Path = "/" 40 request.Request.Method = "POST" 41 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 42 if err != nil { 43 return out, metadata, &smithy.SerializationError{Err: err} 44 } 45 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 46 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption") 47 48 jsonEncoder := smithyjson.NewEncoder() 49 if err := awsAwsjson11_serializeOpDocumentAddApplicationCloudWatchLoggingOptionInput(input, jsonEncoder.Value); err != nil { 50 return out, metadata, &smithy.SerializationError{Err: err} 51 } 52 53 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 54 return out, metadata, &smithy.SerializationError{Err: err} 55 } 56 57 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 58 return out, metadata, &smithy.SerializationError{Err: err} 59 } 60 in.Request = request 61 62 return next.HandleSerialize(ctx, in) 63} 64 65type awsAwsjson11_serializeOpAddApplicationInput struct { 66} 67 68func (*awsAwsjson11_serializeOpAddApplicationInput) ID() string { 69 return "OperationSerializer" 70} 71 72func (m *awsAwsjson11_serializeOpAddApplicationInput) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 73 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 74) { 75 request, ok := in.Request.(*smithyhttp.Request) 76 if !ok { 77 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 78 } 79 80 input, ok := in.Parameters.(*AddApplicationInputInput) 81 _ = input 82 if !ok { 83 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 84 } 85 86 request.Request.URL.Path = "/" 87 request.Request.Method = "POST" 88 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 89 if err != nil { 90 return out, metadata, &smithy.SerializationError{Err: err} 91 } 92 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 93 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationInput") 94 95 jsonEncoder := smithyjson.NewEncoder() 96 if err := awsAwsjson11_serializeOpDocumentAddApplicationInputInput(input, jsonEncoder.Value); err != nil { 97 return out, metadata, &smithy.SerializationError{Err: err} 98 } 99 100 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 101 return out, metadata, &smithy.SerializationError{Err: err} 102 } 103 104 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 105 return out, metadata, &smithy.SerializationError{Err: err} 106 } 107 in.Request = request 108 109 return next.HandleSerialize(ctx, in) 110} 111 112type awsAwsjson11_serializeOpAddApplicationInputProcessingConfiguration struct { 113} 114 115func (*awsAwsjson11_serializeOpAddApplicationInputProcessingConfiguration) ID() string { 116 return "OperationSerializer" 117} 118 119func (m *awsAwsjson11_serializeOpAddApplicationInputProcessingConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 120 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 121) { 122 request, ok := in.Request.(*smithyhttp.Request) 123 if !ok { 124 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 125 } 126 127 input, ok := in.Parameters.(*AddApplicationInputProcessingConfigurationInput) 128 _ = input 129 if !ok { 130 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 131 } 132 133 request.Request.URL.Path = "/" 134 request.Request.Method = "POST" 135 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 136 if err != nil { 137 return out, metadata, &smithy.SerializationError{Err: err} 138 } 139 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 140 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration") 141 142 jsonEncoder := smithyjson.NewEncoder() 143 if err := awsAwsjson11_serializeOpDocumentAddApplicationInputProcessingConfigurationInput(input, jsonEncoder.Value); err != nil { 144 return out, metadata, &smithy.SerializationError{Err: err} 145 } 146 147 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 148 return out, metadata, &smithy.SerializationError{Err: err} 149 } 150 151 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 152 return out, metadata, &smithy.SerializationError{Err: err} 153 } 154 in.Request = request 155 156 return next.HandleSerialize(ctx, in) 157} 158 159type awsAwsjson11_serializeOpAddApplicationOutput struct { 160} 161 162func (*awsAwsjson11_serializeOpAddApplicationOutput) ID() string { 163 return "OperationSerializer" 164} 165 166func (m *awsAwsjson11_serializeOpAddApplicationOutput) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 167 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 168) { 169 request, ok := in.Request.(*smithyhttp.Request) 170 if !ok { 171 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 172 } 173 174 input, ok := in.Parameters.(*AddApplicationOutputInput) 175 _ = input 176 if !ok { 177 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 178 } 179 180 request.Request.URL.Path = "/" 181 request.Request.Method = "POST" 182 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 183 if err != nil { 184 return out, metadata, &smithy.SerializationError{Err: err} 185 } 186 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 187 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationOutput") 188 189 jsonEncoder := smithyjson.NewEncoder() 190 if err := awsAwsjson11_serializeOpDocumentAddApplicationOutputInput(input, jsonEncoder.Value); err != nil { 191 return out, metadata, &smithy.SerializationError{Err: err} 192 } 193 194 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 195 return out, metadata, &smithy.SerializationError{Err: err} 196 } 197 198 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 199 return out, metadata, &smithy.SerializationError{Err: err} 200 } 201 in.Request = request 202 203 return next.HandleSerialize(ctx, in) 204} 205 206type awsAwsjson11_serializeOpAddApplicationReferenceDataSource struct { 207} 208 209func (*awsAwsjson11_serializeOpAddApplicationReferenceDataSource) ID() string { 210 return "OperationSerializer" 211} 212 213func (m *awsAwsjson11_serializeOpAddApplicationReferenceDataSource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 214 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 215) { 216 request, ok := in.Request.(*smithyhttp.Request) 217 if !ok { 218 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 219 } 220 221 input, ok := in.Parameters.(*AddApplicationReferenceDataSourceInput) 222 _ = input 223 if !ok { 224 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 225 } 226 227 request.Request.URL.Path = "/" 228 request.Request.Method = "POST" 229 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 230 if err != nil { 231 return out, metadata, &smithy.SerializationError{Err: err} 232 } 233 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 234 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationReferenceDataSource") 235 236 jsonEncoder := smithyjson.NewEncoder() 237 if err := awsAwsjson11_serializeOpDocumentAddApplicationReferenceDataSourceInput(input, jsonEncoder.Value); err != nil { 238 return out, metadata, &smithy.SerializationError{Err: err} 239 } 240 241 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 242 return out, metadata, &smithy.SerializationError{Err: err} 243 } 244 245 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 246 return out, metadata, &smithy.SerializationError{Err: err} 247 } 248 in.Request = request 249 250 return next.HandleSerialize(ctx, in) 251} 252 253type awsAwsjson11_serializeOpAddApplicationVpcConfiguration struct { 254} 255 256func (*awsAwsjson11_serializeOpAddApplicationVpcConfiguration) ID() string { 257 return "OperationSerializer" 258} 259 260func (m *awsAwsjson11_serializeOpAddApplicationVpcConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 261 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 262) { 263 request, ok := in.Request.(*smithyhttp.Request) 264 if !ok { 265 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 266 } 267 268 input, ok := in.Parameters.(*AddApplicationVpcConfigurationInput) 269 _ = input 270 if !ok { 271 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 272 } 273 274 request.Request.URL.Path = "/" 275 request.Request.Method = "POST" 276 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 277 if err != nil { 278 return out, metadata, &smithy.SerializationError{Err: err} 279 } 280 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 281 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.AddApplicationVpcConfiguration") 282 283 jsonEncoder := smithyjson.NewEncoder() 284 if err := awsAwsjson11_serializeOpDocumentAddApplicationVpcConfigurationInput(input, jsonEncoder.Value); err != nil { 285 return out, metadata, &smithy.SerializationError{Err: err} 286 } 287 288 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 289 return out, metadata, &smithy.SerializationError{Err: err} 290 } 291 292 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 293 return out, metadata, &smithy.SerializationError{Err: err} 294 } 295 in.Request = request 296 297 return next.HandleSerialize(ctx, in) 298} 299 300type awsAwsjson11_serializeOpCreateApplication struct { 301} 302 303func (*awsAwsjson11_serializeOpCreateApplication) ID() string { 304 return "OperationSerializer" 305} 306 307func (m *awsAwsjson11_serializeOpCreateApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 308 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 309) { 310 request, ok := in.Request.(*smithyhttp.Request) 311 if !ok { 312 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 313 } 314 315 input, ok := in.Parameters.(*CreateApplicationInput) 316 _ = input 317 if !ok { 318 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 319 } 320 321 request.Request.URL.Path = "/" 322 request.Request.Method = "POST" 323 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 324 if err != nil { 325 return out, metadata, &smithy.SerializationError{Err: err} 326 } 327 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 328 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.CreateApplication") 329 330 jsonEncoder := smithyjson.NewEncoder() 331 if err := awsAwsjson11_serializeOpDocumentCreateApplicationInput(input, jsonEncoder.Value); err != nil { 332 return out, metadata, &smithy.SerializationError{Err: err} 333 } 334 335 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 336 return out, metadata, &smithy.SerializationError{Err: err} 337 } 338 339 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 340 return out, metadata, &smithy.SerializationError{Err: err} 341 } 342 in.Request = request 343 344 return next.HandleSerialize(ctx, in) 345} 346 347type awsAwsjson11_serializeOpCreateApplicationPresignedUrl struct { 348} 349 350func (*awsAwsjson11_serializeOpCreateApplicationPresignedUrl) ID() string { 351 return "OperationSerializer" 352} 353 354func (m *awsAwsjson11_serializeOpCreateApplicationPresignedUrl) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 355 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 356) { 357 request, ok := in.Request.(*smithyhttp.Request) 358 if !ok { 359 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 360 } 361 362 input, ok := in.Parameters.(*CreateApplicationPresignedUrlInput) 363 _ = input 364 if !ok { 365 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 366 } 367 368 request.Request.URL.Path = "/" 369 request.Request.Method = "POST" 370 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 371 if err != nil { 372 return out, metadata, &smithy.SerializationError{Err: err} 373 } 374 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 375 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.CreateApplicationPresignedUrl") 376 377 jsonEncoder := smithyjson.NewEncoder() 378 if err := awsAwsjson11_serializeOpDocumentCreateApplicationPresignedUrlInput(input, jsonEncoder.Value); err != nil { 379 return out, metadata, &smithy.SerializationError{Err: err} 380 } 381 382 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 383 return out, metadata, &smithy.SerializationError{Err: err} 384 } 385 386 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 387 return out, metadata, &smithy.SerializationError{Err: err} 388 } 389 in.Request = request 390 391 return next.HandleSerialize(ctx, in) 392} 393 394type awsAwsjson11_serializeOpCreateApplicationSnapshot struct { 395} 396 397func (*awsAwsjson11_serializeOpCreateApplicationSnapshot) ID() string { 398 return "OperationSerializer" 399} 400 401func (m *awsAwsjson11_serializeOpCreateApplicationSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 402 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 403) { 404 request, ok := in.Request.(*smithyhttp.Request) 405 if !ok { 406 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 407 } 408 409 input, ok := in.Parameters.(*CreateApplicationSnapshotInput) 410 _ = input 411 if !ok { 412 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 413 } 414 415 request.Request.URL.Path = "/" 416 request.Request.Method = "POST" 417 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 418 if err != nil { 419 return out, metadata, &smithy.SerializationError{Err: err} 420 } 421 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 422 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.CreateApplicationSnapshot") 423 424 jsonEncoder := smithyjson.NewEncoder() 425 if err := awsAwsjson11_serializeOpDocumentCreateApplicationSnapshotInput(input, jsonEncoder.Value); err != nil { 426 return out, metadata, &smithy.SerializationError{Err: err} 427 } 428 429 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 430 return out, metadata, &smithy.SerializationError{Err: err} 431 } 432 433 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 434 return out, metadata, &smithy.SerializationError{Err: err} 435 } 436 in.Request = request 437 438 return next.HandleSerialize(ctx, in) 439} 440 441type awsAwsjson11_serializeOpDeleteApplication struct { 442} 443 444func (*awsAwsjson11_serializeOpDeleteApplication) ID() string { 445 return "OperationSerializer" 446} 447 448func (m *awsAwsjson11_serializeOpDeleteApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 449 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 450) { 451 request, ok := in.Request.(*smithyhttp.Request) 452 if !ok { 453 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 454 } 455 456 input, ok := in.Parameters.(*DeleteApplicationInput) 457 _ = input 458 if !ok { 459 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 460 } 461 462 request.Request.URL.Path = "/" 463 request.Request.Method = "POST" 464 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 465 if err != nil { 466 return out, metadata, &smithy.SerializationError{Err: err} 467 } 468 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 469 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplication") 470 471 jsonEncoder := smithyjson.NewEncoder() 472 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationInput(input, jsonEncoder.Value); err != nil { 473 return out, metadata, &smithy.SerializationError{Err: err} 474 } 475 476 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 477 return out, metadata, &smithy.SerializationError{Err: err} 478 } 479 480 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 481 return out, metadata, &smithy.SerializationError{Err: err} 482 } 483 in.Request = request 484 485 return next.HandleSerialize(ctx, in) 486} 487 488type awsAwsjson11_serializeOpDeleteApplicationCloudWatchLoggingOption struct { 489} 490 491func (*awsAwsjson11_serializeOpDeleteApplicationCloudWatchLoggingOption) ID() string { 492 return "OperationSerializer" 493} 494 495func (m *awsAwsjson11_serializeOpDeleteApplicationCloudWatchLoggingOption) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 496 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 497) { 498 request, ok := in.Request.(*smithyhttp.Request) 499 if !ok { 500 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 501 } 502 503 input, ok := in.Parameters.(*DeleteApplicationCloudWatchLoggingOptionInput) 504 _ = input 505 if !ok { 506 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 507 } 508 509 request.Request.URL.Path = "/" 510 request.Request.Method = "POST" 511 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 512 if err != nil { 513 return out, metadata, &smithy.SerializationError{Err: err} 514 } 515 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 516 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationCloudWatchLoggingOption") 517 518 jsonEncoder := smithyjson.NewEncoder() 519 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationCloudWatchLoggingOptionInput(input, jsonEncoder.Value); err != nil { 520 return out, metadata, &smithy.SerializationError{Err: err} 521 } 522 523 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 524 return out, metadata, &smithy.SerializationError{Err: err} 525 } 526 527 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 528 return out, metadata, &smithy.SerializationError{Err: err} 529 } 530 in.Request = request 531 532 return next.HandleSerialize(ctx, in) 533} 534 535type awsAwsjson11_serializeOpDeleteApplicationInputProcessingConfiguration struct { 536} 537 538func (*awsAwsjson11_serializeOpDeleteApplicationInputProcessingConfiguration) ID() string { 539 return "OperationSerializer" 540} 541 542func (m *awsAwsjson11_serializeOpDeleteApplicationInputProcessingConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 543 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 544) { 545 request, ok := in.Request.(*smithyhttp.Request) 546 if !ok { 547 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 548 } 549 550 input, ok := in.Parameters.(*DeleteApplicationInputProcessingConfigurationInput) 551 _ = input 552 if !ok { 553 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 554 } 555 556 request.Request.URL.Path = "/" 557 request.Request.Method = "POST" 558 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 559 if err != nil { 560 return out, metadata, &smithy.SerializationError{Err: err} 561 } 562 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 563 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationInputProcessingConfiguration") 564 565 jsonEncoder := smithyjson.NewEncoder() 566 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationInputProcessingConfigurationInput(input, jsonEncoder.Value); err != nil { 567 return out, metadata, &smithy.SerializationError{Err: err} 568 } 569 570 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 571 return out, metadata, &smithy.SerializationError{Err: err} 572 } 573 574 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 575 return out, metadata, &smithy.SerializationError{Err: err} 576 } 577 in.Request = request 578 579 return next.HandleSerialize(ctx, in) 580} 581 582type awsAwsjson11_serializeOpDeleteApplicationOutput struct { 583} 584 585func (*awsAwsjson11_serializeOpDeleteApplicationOutput) ID() string { 586 return "OperationSerializer" 587} 588 589func (m *awsAwsjson11_serializeOpDeleteApplicationOutput) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 590 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 591) { 592 request, ok := in.Request.(*smithyhttp.Request) 593 if !ok { 594 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 595 } 596 597 input, ok := in.Parameters.(*DeleteApplicationOutputInput) 598 _ = input 599 if !ok { 600 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 601 } 602 603 request.Request.URL.Path = "/" 604 request.Request.Method = "POST" 605 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 606 if err != nil { 607 return out, metadata, &smithy.SerializationError{Err: err} 608 } 609 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 610 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationOutput") 611 612 jsonEncoder := smithyjson.NewEncoder() 613 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationOutputInput(input, jsonEncoder.Value); err != nil { 614 return out, metadata, &smithy.SerializationError{Err: err} 615 } 616 617 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 618 return out, metadata, &smithy.SerializationError{Err: err} 619 } 620 621 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 622 return out, metadata, &smithy.SerializationError{Err: err} 623 } 624 in.Request = request 625 626 return next.HandleSerialize(ctx, in) 627} 628 629type awsAwsjson11_serializeOpDeleteApplicationReferenceDataSource struct { 630} 631 632func (*awsAwsjson11_serializeOpDeleteApplicationReferenceDataSource) ID() string { 633 return "OperationSerializer" 634} 635 636func (m *awsAwsjson11_serializeOpDeleteApplicationReferenceDataSource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 637 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 638) { 639 request, ok := in.Request.(*smithyhttp.Request) 640 if !ok { 641 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 642 } 643 644 input, ok := in.Parameters.(*DeleteApplicationReferenceDataSourceInput) 645 _ = input 646 if !ok { 647 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 648 } 649 650 request.Request.URL.Path = "/" 651 request.Request.Method = "POST" 652 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 653 if err != nil { 654 return out, metadata, &smithy.SerializationError{Err: err} 655 } 656 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 657 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationReferenceDataSource") 658 659 jsonEncoder := smithyjson.NewEncoder() 660 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationReferenceDataSourceInput(input, jsonEncoder.Value); err != nil { 661 return out, metadata, &smithy.SerializationError{Err: err} 662 } 663 664 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 665 return out, metadata, &smithy.SerializationError{Err: err} 666 } 667 668 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 669 return out, metadata, &smithy.SerializationError{Err: err} 670 } 671 in.Request = request 672 673 return next.HandleSerialize(ctx, in) 674} 675 676type awsAwsjson11_serializeOpDeleteApplicationSnapshot struct { 677} 678 679func (*awsAwsjson11_serializeOpDeleteApplicationSnapshot) ID() string { 680 return "OperationSerializer" 681} 682 683func (m *awsAwsjson11_serializeOpDeleteApplicationSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 684 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 685) { 686 request, ok := in.Request.(*smithyhttp.Request) 687 if !ok { 688 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 689 } 690 691 input, ok := in.Parameters.(*DeleteApplicationSnapshotInput) 692 _ = input 693 if !ok { 694 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 695 } 696 697 request.Request.URL.Path = "/" 698 request.Request.Method = "POST" 699 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 700 if err != nil { 701 return out, metadata, &smithy.SerializationError{Err: err} 702 } 703 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 704 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationSnapshot") 705 706 jsonEncoder := smithyjson.NewEncoder() 707 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationSnapshotInput(input, jsonEncoder.Value); err != nil { 708 return out, metadata, &smithy.SerializationError{Err: err} 709 } 710 711 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 712 return out, metadata, &smithy.SerializationError{Err: err} 713 } 714 715 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 716 return out, metadata, &smithy.SerializationError{Err: err} 717 } 718 in.Request = request 719 720 return next.HandleSerialize(ctx, in) 721} 722 723type awsAwsjson11_serializeOpDeleteApplicationVpcConfiguration struct { 724} 725 726func (*awsAwsjson11_serializeOpDeleteApplicationVpcConfiguration) ID() string { 727 return "OperationSerializer" 728} 729 730func (m *awsAwsjson11_serializeOpDeleteApplicationVpcConfiguration) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 731 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 732) { 733 request, ok := in.Request.(*smithyhttp.Request) 734 if !ok { 735 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 736 } 737 738 input, ok := in.Parameters.(*DeleteApplicationVpcConfigurationInput) 739 _ = input 740 if !ok { 741 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 742 } 743 744 request.Request.URL.Path = "/" 745 request.Request.Method = "POST" 746 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 747 if err != nil { 748 return out, metadata, &smithy.SerializationError{Err: err} 749 } 750 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 751 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DeleteApplicationVpcConfiguration") 752 753 jsonEncoder := smithyjson.NewEncoder() 754 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationVpcConfigurationInput(input, jsonEncoder.Value); err != nil { 755 return out, metadata, &smithy.SerializationError{Err: err} 756 } 757 758 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 759 return out, metadata, &smithy.SerializationError{Err: err} 760 } 761 762 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 763 return out, metadata, &smithy.SerializationError{Err: err} 764 } 765 in.Request = request 766 767 return next.HandleSerialize(ctx, in) 768} 769 770type awsAwsjson11_serializeOpDescribeApplication struct { 771} 772 773func (*awsAwsjson11_serializeOpDescribeApplication) ID() string { 774 return "OperationSerializer" 775} 776 777func (m *awsAwsjson11_serializeOpDescribeApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 778 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 779) { 780 request, ok := in.Request.(*smithyhttp.Request) 781 if !ok { 782 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 783 } 784 785 input, ok := in.Parameters.(*DescribeApplicationInput) 786 _ = input 787 if !ok { 788 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 789 } 790 791 request.Request.URL.Path = "/" 792 request.Request.Method = "POST" 793 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 794 if err != nil { 795 return out, metadata, &smithy.SerializationError{Err: err} 796 } 797 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 798 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DescribeApplication") 799 800 jsonEncoder := smithyjson.NewEncoder() 801 if err := awsAwsjson11_serializeOpDocumentDescribeApplicationInput(input, jsonEncoder.Value); err != nil { 802 return out, metadata, &smithy.SerializationError{Err: err} 803 } 804 805 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 806 return out, metadata, &smithy.SerializationError{Err: err} 807 } 808 809 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 810 return out, metadata, &smithy.SerializationError{Err: err} 811 } 812 in.Request = request 813 814 return next.HandleSerialize(ctx, in) 815} 816 817type awsAwsjson11_serializeOpDescribeApplicationSnapshot struct { 818} 819 820func (*awsAwsjson11_serializeOpDescribeApplicationSnapshot) ID() string { 821 return "OperationSerializer" 822} 823 824func (m *awsAwsjson11_serializeOpDescribeApplicationSnapshot) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 825 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 826) { 827 request, ok := in.Request.(*smithyhttp.Request) 828 if !ok { 829 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 830 } 831 832 input, ok := in.Parameters.(*DescribeApplicationSnapshotInput) 833 _ = input 834 if !ok { 835 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 836 } 837 838 request.Request.URL.Path = "/" 839 request.Request.Method = "POST" 840 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 841 if err != nil { 842 return out, metadata, &smithy.SerializationError{Err: err} 843 } 844 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 845 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DescribeApplicationSnapshot") 846 847 jsonEncoder := smithyjson.NewEncoder() 848 if err := awsAwsjson11_serializeOpDocumentDescribeApplicationSnapshotInput(input, jsonEncoder.Value); err != nil { 849 return out, metadata, &smithy.SerializationError{Err: err} 850 } 851 852 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 853 return out, metadata, &smithy.SerializationError{Err: err} 854 } 855 856 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 857 return out, metadata, &smithy.SerializationError{Err: err} 858 } 859 in.Request = request 860 861 return next.HandleSerialize(ctx, in) 862} 863 864type awsAwsjson11_serializeOpDiscoverInputSchema struct { 865} 866 867func (*awsAwsjson11_serializeOpDiscoverInputSchema) ID() string { 868 return "OperationSerializer" 869} 870 871func (m *awsAwsjson11_serializeOpDiscoverInputSchema) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 872 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 873) { 874 request, ok := in.Request.(*smithyhttp.Request) 875 if !ok { 876 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 877 } 878 879 input, ok := in.Parameters.(*DiscoverInputSchemaInput) 880 _ = input 881 if !ok { 882 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 883 } 884 885 request.Request.URL.Path = "/" 886 request.Request.Method = "POST" 887 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 888 if err != nil { 889 return out, metadata, &smithy.SerializationError{Err: err} 890 } 891 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 892 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.DiscoverInputSchema") 893 894 jsonEncoder := smithyjson.NewEncoder() 895 if err := awsAwsjson11_serializeOpDocumentDiscoverInputSchemaInput(input, jsonEncoder.Value); err != nil { 896 return out, metadata, &smithy.SerializationError{Err: err} 897 } 898 899 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 900 return out, metadata, &smithy.SerializationError{Err: err} 901 } 902 903 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 904 return out, metadata, &smithy.SerializationError{Err: err} 905 } 906 in.Request = request 907 908 return next.HandleSerialize(ctx, in) 909} 910 911type awsAwsjson11_serializeOpListApplications struct { 912} 913 914func (*awsAwsjson11_serializeOpListApplications) ID() string { 915 return "OperationSerializer" 916} 917 918func (m *awsAwsjson11_serializeOpListApplications) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 919 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 920) { 921 request, ok := in.Request.(*smithyhttp.Request) 922 if !ok { 923 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 924 } 925 926 input, ok := in.Parameters.(*ListApplicationsInput) 927 _ = input 928 if !ok { 929 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 930 } 931 932 request.Request.URL.Path = "/" 933 request.Request.Method = "POST" 934 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 935 if err != nil { 936 return out, metadata, &smithy.SerializationError{Err: err} 937 } 938 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 939 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.ListApplications") 940 941 jsonEncoder := smithyjson.NewEncoder() 942 if err := awsAwsjson11_serializeOpDocumentListApplicationsInput(input, jsonEncoder.Value); err != nil { 943 return out, metadata, &smithy.SerializationError{Err: err} 944 } 945 946 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 947 return out, metadata, &smithy.SerializationError{Err: err} 948 } 949 950 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 951 return out, metadata, &smithy.SerializationError{Err: err} 952 } 953 in.Request = request 954 955 return next.HandleSerialize(ctx, in) 956} 957 958type awsAwsjson11_serializeOpListApplicationSnapshots struct { 959} 960 961func (*awsAwsjson11_serializeOpListApplicationSnapshots) ID() string { 962 return "OperationSerializer" 963} 964 965func (m *awsAwsjson11_serializeOpListApplicationSnapshots) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 966 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 967) { 968 request, ok := in.Request.(*smithyhttp.Request) 969 if !ok { 970 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 971 } 972 973 input, ok := in.Parameters.(*ListApplicationSnapshotsInput) 974 _ = input 975 if !ok { 976 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 977 } 978 979 request.Request.URL.Path = "/" 980 request.Request.Method = "POST" 981 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 982 if err != nil { 983 return out, metadata, &smithy.SerializationError{Err: err} 984 } 985 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 986 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.ListApplicationSnapshots") 987 988 jsonEncoder := smithyjson.NewEncoder() 989 if err := awsAwsjson11_serializeOpDocumentListApplicationSnapshotsInput(input, jsonEncoder.Value); err != nil { 990 return out, metadata, &smithy.SerializationError{Err: err} 991 } 992 993 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 994 return out, metadata, &smithy.SerializationError{Err: err} 995 } 996 997 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 998 return out, metadata, &smithy.SerializationError{Err: err} 999 } 1000 in.Request = request 1001 1002 return next.HandleSerialize(ctx, in) 1003} 1004 1005type awsAwsjson11_serializeOpListTagsForResource struct { 1006} 1007 1008func (*awsAwsjson11_serializeOpListTagsForResource) ID() string { 1009 return "OperationSerializer" 1010} 1011 1012func (m *awsAwsjson11_serializeOpListTagsForResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1013 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1014) { 1015 request, ok := in.Request.(*smithyhttp.Request) 1016 if !ok { 1017 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1018 } 1019 1020 input, ok := in.Parameters.(*ListTagsForResourceInput) 1021 _ = input 1022 if !ok { 1023 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1024 } 1025 1026 request.Request.URL.Path = "/" 1027 request.Request.Method = "POST" 1028 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1029 if err != nil { 1030 return out, metadata, &smithy.SerializationError{Err: err} 1031 } 1032 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1033 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.ListTagsForResource") 1034 1035 jsonEncoder := smithyjson.NewEncoder() 1036 if err := awsAwsjson11_serializeOpDocumentListTagsForResourceInput(input, jsonEncoder.Value); err != nil { 1037 return out, metadata, &smithy.SerializationError{Err: err} 1038 } 1039 1040 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1041 return out, metadata, &smithy.SerializationError{Err: err} 1042 } 1043 1044 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1045 return out, metadata, &smithy.SerializationError{Err: err} 1046 } 1047 in.Request = request 1048 1049 return next.HandleSerialize(ctx, in) 1050} 1051 1052type awsAwsjson11_serializeOpStartApplication struct { 1053} 1054 1055func (*awsAwsjson11_serializeOpStartApplication) ID() string { 1056 return "OperationSerializer" 1057} 1058 1059func (m *awsAwsjson11_serializeOpStartApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1060 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1061) { 1062 request, ok := in.Request.(*smithyhttp.Request) 1063 if !ok { 1064 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1065 } 1066 1067 input, ok := in.Parameters.(*StartApplicationInput) 1068 _ = input 1069 if !ok { 1070 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1071 } 1072 1073 request.Request.URL.Path = "/" 1074 request.Request.Method = "POST" 1075 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1076 if err != nil { 1077 return out, metadata, &smithy.SerializationError{Err: err} 1078 } 1079 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1080 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.StartApplication") 1081 1082 jsonEncoder := smithyjson.NewEncoder() 1083 if err := awsAwsjson11_serializeOpDocumentStartApplicationInput(input, jsonEncoder.Value); err != nil { 1084 return out, metadata, &smithy.SerializationError{Err: err} 1085 } 1086 1087 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1088 return out, metadata, &smithy.SerializationError{Err: err} 1089 } 1090 1091 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1092 return out, metadata, &smithy.SerializationError{Err: err} 1093 } 1094 in.Request = request 1095 1096 return next.HandleSerialize(ctx, in) 1097} 1098 1099type awsAwsjson11_serializeOpStopApplication struct { 1100} 1101 1102func (*awsAwsjson11_serializeOpStopApplication) ID() string { 1103 return "OperationSerializer" 1104} 1105 1106func (m *awsAwsjson11_serializeOpStopApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1107 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1108) { 1109 request, ok := in.Request.(*smithyhttp.Request) 1110 if !ok { 1111 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1112 } 1113 1114 input, ok := in.Parameters.(*StopApplicationInput) 1115 _ = input 1116 if !ok { 1117 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1118 } 1119 1120 request.Request.URL.Path = "/" 1121 request.Request.Method = "POST" 1122 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1123 if err != nil { 1124 return out, metadata, &smithy.SerializationError{Err: err} 1125 } 1126 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1127 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.StopApplication") 1128 1129 jsonEncoder := smithyjson.NewEncoder() 1130 if err := awsAwsjson11_serializeOpDocumentStopApplicationInput(input, jsonEncoder.Value); err != nil { 1131 return out, metadata, &smithy.SerializationError{Err: err} 1132 } 1133 1134 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1135 return out, metadata, &smithy.SerializationError{Err: err} 1136 } 1137 1138 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1139 return out, metadata, &smithy.SerializationError{Err: err} 1140 } 1141 in.Request = request 1142 1143 return next.HandleSerialize(ctx, in) 1144} 1145 1146type awsAwsjson11_serializeOpTagResource struct { 1147} 1148 1149func (*awsAwsjson11_serializeOpTagResource) ID() string { 1150 return "OperationSerializer" 1151} 1152 1153func (m *awsAwsjson11_serializeOpTagResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1154 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1155) { 1156 request, ok := in.Request.(*smithyhttp.Request) 1157 if !ok { 1158 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1159 } 1160 1161 input, ok := in.Parameters.(*TagResourceInput) 1162 _ = input 1163 if !ok { 1164 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1165 } 1166 1167 request.Request.URL.Path = "/" 1168 request.Request.Method = "POST" 1169 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1170 if err != nil { 1171 return out, metadata, &smithy.SerializationError{Err: err} 1172 } 1173 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1174 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.TagResource") 1175 1176 jsonEncoder := smithyjson.NewEncoder() 1177 if err := awsAwsjson11_serializeOpDocumentTagResourceInput(input, jsonEncoder.Value); err != nil { 1178 return out, metadata, &smithy.SerializationError{Err: err} 1179 } 1180 1181 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1182 return out, metadata, &smithy.SerializationError{Err: err} 1183 } 1184 1185 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1186 return out, metadata, &smithy.SerializationError{Err: err} 1187 } 1188 in.Request = request 1189 1190 return next.HandleSerialize(ctx, in) 1191} 1192 1193type awsAwsjson11_serializeOpUntagResource struct { 1194} 1195 1196func (*awsAwsjson11_serializeOpUntagResource) ID() string { 1197 return "OperationSerializer" 1198} 1199 1200func (m *awsAwsjson11_serializeOpUntagResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1201 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1202) { 1203 request, ok := in.Request.(*smithyhttp.Request) 1204 if !ok { 1205 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1206 } 1207 1208 input, ok := in.Parameters.(*UntagResourceInput) 1209 _ = input 1210 if !ok { 1211 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1212 } 1213 1214 request.Request.URL.Path = "/" 1215 request.Request.Method = "POST" 1216 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1217 if err != nil { 1218 return out, metadata, &smithy.SerializationError{Err: err} 1219 } 1220 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1221 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.UntagResource") 1222 1223 jsonEncoder := smithyjson.NewEncoder() 1224 if err := awsAwsjson11_serializeOpDocumentUntagResourceInput(input, jsonEncoder.Value); err != nil { 1225 return out, metadata, &smithy.SerializationError{Err: err} 1226 } 1227 1228 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1229 return out, metadata, &smithy.SerializationError{Err: err} 1230 } 1231 1232 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1233 return out, metadata, &smithy.SerializationError{Err: err} 1234 } 1235 in.Request = request 1236 1237 return next.HandleSerialize(ctx, in) 1238} 1239 1240type awsAwsjson11_serializeOpUpdateApplication struct { 1241} 1242 1243func (*awsAwsjson11_serializeOpUpdateApplication) ID() string { 1244 return "OperationSerializer" 1245} 1246 1247func (m *awsAwsjson11_serializeOpUpdateApplication) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1248 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1249) { 1250 request, ok := in.Request.(*smithyhttp.Request) 1251 if !ok { 1252 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1253 } 1254 1255 input, ok := in.Parameters.(*UpdateApplicationInput) 1256 _ = input 1257 if !ok { 1258 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1259 } 1260 1261 request.Request.URL.Path = "/" 1262 request.Request.Method = "POST" 1263 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1264 if err != nil { 1265 return out, metadata, &smithy.SerializationError{Err: err} 1266 } 1267 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1268 httpBindingEncoder.SetHeader("X-Amz-Target").String("KinesisAnalytics_20180523.UpdateApplication") 1269 1270 jsonEncoder := smithyjson.NewEncoder() 1271 if err := awsAwsjson11_serializeOpDocumentUpdateApplicationInput(input, jsonEncoder.Value); err != nil { 1272 return out, metadata, &smithy.SerializationError{Err: err} 1273 } 1274 1275 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1276 return out, metadata, &smithy.SerializationError{Err: err} 1277 } 1278 1279 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1280 return out, metadata, &smithy.SerializationError{Err: err} 1281 } 1282 in.Request = request 1283 1284 return next.HandleSerialize(ctx, in) 1285} 1286func awsAwsjson11_serializeDocumentApplicationCodeConfiguration(v *types.ApplicationCodeConfiguration, value smithyjson.Value) error { 1287 object := value.Object() 1288 defer object.Close() 1289 1290 if v.CodeContent != nil { 1291 ok := object.Key("CodeContent") 1292 if err := awsAwsjson11_serializeDocumentCodeContent(v.CodeContent, ok); err != nil { 1293 return err 1294 } 1295 } 1296 1297 if len(v.CodeContentType) > 0 { 1298 ok := object.Key("CodeContentType") 1299 ok.String(string(v.CodeContentType)) 1300 } 1301 1302 return nil 1303} 1304 1305func awsAwsjson11_serializeDocumentApplicationCodeConfigurationUpdate(v *types.ApplicationCodeConfigurationUpdate, value smithyjson.Value) error { 1306 object := value.Object() 1307 defer object.Close() 1308 1309 if len(v.CodeContentTypeUpdate) > 0 { 1310 ok := object.Key("CodeContentTypeUpdate") 1311 ok.String(string(v.CodeContentTypeUpdate)) 1312 } 1313 1314 if v.CodeContentUpdate != nil { 1315 ok := object.Key("CodeContentUpdate") 1316 if err := awsAwsjson11_serializeDocumentCodeContentUpdate(v.CodeContentUpdate, ok); err != nil { 1317 return err 1318 } 1319 } 1320 1321 return nil 1322} 1323 1324func awsAwsjson11_serializeDocumentApplicationConfiguration(v *types.ApplicationConfiguration, value smithyjson.Value) error { 1325 object := value.Object() 1326 defer object.Close() 1327 1328 if v.ApplicationCodeConfiguration != nil { 1329 ok := object.Key("ApplicationCodeConfiguration") 1330 if err := awsAwsjson11_serializeDocumentApplicationCodeConfiguration(v.ApplicationCodeConfiguration, ok); err != nil { 1331 return err 1332 } 1333 } 1334 1335 if v.ApplicationSnapshotConfiguration != nil { 1336 ok := object.Key("ApplicationSnapshotConfiguration") 1337 if err := awsAwsjson11_serializeDocumentApplicationSnapshotConfiguration(v.ApplicationSnapshotConfiguration, ok); err != nil { 1338 return err 1339 } 1340 } 1341 1342 if v.EnvironmentProperties != nil { 1343 ok := object.Key("EnvironmentProperties") 1344 if err := awsAwsjson11_serializeDocumentEnvironmentProperties(v.EnvironmentProperties, ok); err != nil { 1345 return err 1346 } 1347 } 1348 1349 if v.FlinkApplicationConfiguration != nil { 1350 ok := object.Key("FlinkApplicationConfiguration") 1351 if err := awsAwsjson11_serializeDocumentFlinkApplicationConfiguration(v.FlinkApplicationConfiguration, ok); err != nil { 1352 return err 1353 } 1354 } 1355 1356 if v.SqlApplicationConfiguration != nil { 1357 ok := object.Key("SqlApplicationConfiguration") 1358 if err := awsAwsjson11_serializeDocumentSqlApplicationConfiguration(v.SqlApplicationConfiguration, ok); err != nil { 1359 return err 1360 } 1361 } 1362 1363 if v.VpcConfigurations != nil { 1364 ok := object.Key("VpcConfigurations") 1365 if err := awsAwsjson11_serializeDocumentVpcConfigurations(v.VpcConfigurations, ok); err != nil { 1366 return err 1367 } 1368 } 1369 1370 return nil 1371} 1372 1373func awsAwsjson11_serializeDocumentApplicationConfigurationUpdate(v *types.ApplicationConfigurationUpdate, value smithyjson.Value) error { 1374 object := value.Object() 1375 defer object.Close() 1376 1377 if v.ApplicationCodeConfigurationUpdate != nil { 1378 ok := object.Key("ApplicationCodeConfigurationUpdate") 1379 if err := awsAwsjson11_serializeDocumentApplicationCodeConfigurationUpdate(v.ApplicationCodeConfigurationUpdate, ok); err != nil { 1380 return err 1381 } 1382 } 1383 1384 if v.ApplicationSnapshotConfigurationUpdate != nil { 1385 ok := object.Key("ApplicationSnapshotConfigurationUpdate") 1386 if err := awsAwsjson11_serializeDocumentApplicationSnapshotConfigurationUpdate(v.ApplicationSnapshotConfigurationUpdate, ok); err != nil { 1387 return err 1388 } 1389 } 1390 1391 if v.EnvironmentPropertyUpdates != nil { 1392 ok := object.Key("EnvironmentPropertyUpdates") 1393 if err := awsAwsjson11_serializeDocumentEnvironmentPropertyUpdates(v.EnvironmentPropertyUpdates, ok); err != nil { 1394 return err 1395 } 1396 } 1397 1398 if v.FlinkApplicationConfigurationUpdate != nil { 1399 ok := object.Key("FlinkApplicationConfigurationUpdate") 1400 if err := awsAwsjson11_serializeDocumentFlinkApplicationConfigurationUpdate(v.FlinkApplicationConfigurationUpdate, ok); err != nil { 1401 return err 1402 } 1403 } 1404 1405 if v.SqlApplicationConfigurationUpdate != nil { 1406 ok := object.Key("SqlApplicationConfigurationUpdate") 1407 if err := awsAwsjson11_serializeDocumentSqlApplicationConfigurationUpdate(v.SqlApplicationConfigurationUpdate, ok); err != nil { 1408 return err 1409 } 1410 } 1411 1412 if v.VpcConfigurationUpdates != nil { 1413 ok := object.Key("VpcConfigurationUpdates") 1414 if err := awsAwsjson11_serializeDocumentVpcConfigurationUpdates(v.VpcConfigurationUpdates, ok); err != nil { 1415 return err 1416 } 1417 } 1418 1419 return nil 1420} 1421 1422func awsAwsjson11_serializeDocumentApplicationRestoreConfiguration(v *types.ApplicationRestoreConfiguration, value smithyjson.Value) error { 1423 object := value.Object() 1424 defer object.Close() 1425 1426 if len(v.ApplicationRestoreType) > 0 { 1427 ok := object.Key("ApplicationRestoreType") 1428 ok.String(string(v.ApplicationRestoreType)) 1429 } 1430 1431 if v.SnapshotName != nil { 1432 ok := object.Key("SnapshotName") 1433 ok.String(*v.SnapshotName) 1434 } 1435 1436 return nil 1437} 1438 1439func awsAwsjson11_serializeDocumentApplicationSnapshotConfiguration(v *types.ApplicationSnapshotConfiguration, value smithyjson.Value) error { 1440 object := value.Object() 1441 defer object.Close() 1442 1443 if v.SnapshotsEnabled != nil { 1444 ok := object.Key("SnapshotsEnabled") 1445 ok.Boolean(*v.SnapshotsEnabled) 1446 } 1447 1448 return nil 1449} 1450 1451func awsAwsjson11_serializeDocumentApplicationSnapshotConfigurationUpdate(v *types.ApplicationSnapshotConfigurationUpdate, value smithyjson.Value) error { 1452 object := value.Object() 1453 defer object.Close() 1454 1455 if v.SnapshotsEnabledUpdate != nil { 1456 ok := object.Key("SnapshotsEnabledUpdate") 1457 ok.Boolean(*v.SnapshotsEnabledUpdate) 1458 } 1459 1460 return nil 1461} 1462 1463func awsAwsjson11_serializeDocumentCheckpointConfiguration(v *types.CheckpointConfiguration, value smithyjson.Value) error { 1464 object := value.Object() 1465 defer object.Close() 1466 1467 if v.CheckpointingEnabled != nil { 1468 ok := object.Key("CheckpointingEnabled") 1469 ok.Boolean(*v.CheckpointingEnabled) 1470 } 1471 1472 if v.CheckpointInterval != nil { 1473 ok := object.Key("CheckpointInterval") 1474 ok.Long(*v.CheckpointInterval) 1475 } 1476 1477 if len(v.ConfigurationType) > 0 { 1478 ok := object.Key("ConfigurationType") 1479 ok.String(string(v.ConfigurationType)) 1480 } 1481 1482 if v.MinPauseBetweenCheckpoints != nil { 1483 ok := object.Key("MinPauseBetweenCheckpoints") 1484 ok.Long(*v.MinPauseBetweenCheckpoints) 1485 } 1486 1487 return nil 1488} 1489 1490func awsAwsjson11_serializeDocumentCheckpointConfigurationUpdate(v *types.CheckpointConfigurationUpdate, value smithyjson.Value) error { 1491 object := value.Object() 1492 defer object.Close() 1493 1494 if v.CheckpointingEnabledUpdate != nil { 1495 ok := object.Key("CheckpointingEnabledUpdate") 1496 ok.Boolean(*v.CheckpointingEnabledUpdate) 1497 } 1498 1499 if v.CheckpointIntervalUpdate != nil { 1500 ok := object.Key("CheckpointIntervalUpdate") 1501 ok.Long(*v.CheckpointIntervalUpdate) 1502 } 1503 1504 if len(v.ConfigurationTypeUpdate) > 0 { 1505 ok := object.Key("ConfigurationTypeUpdate") 1506 ok.String(string(v.ConfigurationTypeUpdate)) 1507 } 1508 1509 if v.MinPauseBetweenCheckpointsUpdate != nil { 1510 ok := object.Key("MinPauseBetweenCheckpointsUpdate") 1511 ok.Long(*v.MinPauseBetweenCheckpointsUpdate) 1512 } 1513 1514 return nil 1515} 1516 1517func awsAwsjson11_serializeDocumentCloudWatchLoggingOption(v *types.CloudWatchLoggingOption, value smithyjson.Value) error { 1518 object := value.Object() 1519 defer object.Close() 1520 1521 if v.LogStreamARN != nil { 1522 ok := object.Key("LogStreamARN") 1523 ok.String(*v.LogStreamARN) 1524 } 1525 1526 return nil 1527} 1528 1529func awsAwsjson11_serializeDocumentCloudWatchLoggingOptions(v []types.CloudWatchLoggingOption, value smithyjson.Value) error { 1530 array := value.Array() 1531 defer array.Close() 1532 1533 for i := range v { 1534 av := array.Value() 1535 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOption(&v[i], av); err != nil { 1536 return err 1537 } 1538 } 1539 return nil 1540} 1541 1542func awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdate(v *types.CloudWatchLoggingOptionUpdate, value smithyjson.Value) error { 1543 object := value.Object() 1544 defer object.Close() 1545 1546 if v.CloudWatchLoggingOptionId != nil { 1547 ok := object.Key("CloudWatchLoggingOptionId") 1548 ok.String(*v.CloudWatchLoggingOptionId) 1549 } 1550 1551 if v.LogStreamARNUpdate != nil { 1552 ok := object.Key("LogStreamARNUpdate") 1553 ok.String(*v.LogStreamARNUpdate) 1554 } 1555 1556 return nil 1557} 1558 1559func awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdates(v []types.CloudWatchLoggingOptionUpdate, value smithyjson.Value) error { 1560 array := value.Array() 1561 defer array.Close() 1562 1563 for i := range v { 1564 av := array.Value() 1565 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdate(&v[i], av); err != nil { 1566 return err 1567 } 1568 } 1569 return nil 1570} 1571 1572func awsAwsjson11_serializeDocumentCodeContent(v *types.CodeContent, value smithyjson.Value) error { 1573 object := value.Object() 1574 defer object.Close() 1575 1576 if v.S3ContentLocation != nil { 1577 ok := object.Key("S3ContentLocation") 1578 if err := awsAwsjson11_serializeDocumentS3ContentLocation(v.S3ContentLocation, ok); err != nil { 1579 return err 1580 } 1581 } 1582 1583 if v.TextContent != nil { 1584 ok := object.Key("TextContent") 1585 ok.String(*v.TextContent) 1586 } 1587 1588 if v.ZipFileContent != nil { 1589 ok := object.Key("ZipFileContent") 1590 ok.Base64EncodeBytes(v.ZipFileContent) 1591 } 1592 1593 return nil 1594} 1595 1596func awsAwsjson11_serializeDocumentCodeContentUpdate(v *types.CodeContentUpdate, value smithyjson.Value) error { 1597 object := value.Object() 1598 defer object.Close() 1599 1600 if v.S3ContentLocationUpdate != nil { 1601 ok := object.Key("S3ContentLocationUpdate") 1602 if err := awsAwsjson11_serializeDocumentS3ContentLocationUpdate(v.S3ContentLocationUpdate, ok); err != nil { 1603 return err 1604 } 1605 } 1606 1607 if v.TextContentUpdate != nil { 1608 ok := object.Key("TextContentUpdate") 1609 ok.String(*v.TextContentUpdate) 1610 } 1611 1612 if v.ZipFileContentUpdate != nil { 1613 ok := object.Key("ZipFileContentUpdate") 1614 ok.Base64EncodeBytes(v.ZipFileContentUpdate) 1615 } 1616 1617 return nil 1618} 1619 1620func awsAwsjson11_serializeDocumentCSVMappingParameters(v *types.CSVMappingParameters, value smithyjson.Value) error { 1621 object := value.Object() 1622 defer object.Close() 1623 1624 if v.RecordColumnDelimiter != nil { 1625 ok := object.Key("RecordColumnDelimiter") 1626 ok.String(*v.RecordColumnDelimiter) 1627 } 1628 1629 if v.RecordRowDelimiter != nil { 1630 ok := object.Key("RecordRowDelimiter") 1631 ok.String(*v.RecordRowDelimiter) 1632 } 1633 1634 return nil 1635} 1636 1637func awsAwsjson11_serializeDocumentDestinationSchema(v *types.DestinationSchema, value smithyjson.Value) error { 1638 object := value.Object() 1639 defer object.Close() 1640 1641 if len(v.RecordFormatType) > 0 { 1642 ok := object.Key("RecordFormatType") 1643 ok.String(string(v.RecordFormatType)) 1644 } 1645 1646 return nil 1647} 1648 1649func awsAwsjson11_serializeDocumentEnvironmentProperties(v *types.EnvironmentProperties, value smithyjson.Value) error { 1650 object := value.Object() 1651 defer object.Close() 1652 1653 if v.PropertyGroups != nil { 1654 ok := object.Key("PropertyGroups") 1655 if err := awsAwsjson11_serializeDocumentPropertyGroups(v.PropertyGroups, ok); err != nil { 1656 return err 1657 } 1658 } 1659 1660 return nil 1661} 1662 1663func awsAwsjson11_serializeDocumentEnvironmentPropertyUpdates(v *types.EnvironmentPropertyUpdates, value smithyjson.Value) error { 1664 object := value.Object() 1665 defer object.Close() 1666 1667 if v.PropertyGroups != nil { 1668 ok := object.Key("PropertyGroups") 1669 if err := awsAwsjson11_serializeDocumentPropertyGroups(v.PropertyGroups, ok); err != nil { 1670 return err 1671 } 1672 } 1673 1674 return nil 1675} 1676 1677func awsAwsjson11_serializeDocumentFlinkApplicationConfiguration(v *types.FlinkApplicationConfiguration, value smithyjson.Value) error { 1678 object := value.Object() 1679 defer object.Close() 1680 1681 if v.CheckpointConfiguration != nil { 1682 ok := object.Key("CheckpointConfiguration") 1683 if err := awsAwsjson11_serializeDocumentCheckpointConfiguration(v.CheckpointConfiguration, ok); err != nil { 1684 return err 1685 } 1686 } 1687 1688 if v.MonitoringConfiguration != nil { 1689 ok := object.Key("MonitoringConfiguration") 1690 if err := awsAwsjson11_serializeDocumentMonitoringConfiguration(v.MonitoringConfiguration, ok); err != nil { 1691 return err 1692 } 1693 } 1694 1695 if v.ParallelismConfiguration != nil { 1696 ok := object.Key("ParallelismConfiguration") 1697 if err := awsAwsjson11_serializeDocumentParallelismConfiguration(v.ParallelismConfiguration, ok); err != nil { 1698 return err 1699 } 1700 } 1701 1702 return nil 1703} 1704 1705func awsAwsjson11_serializeDocumentFlinkApplicationConfigurationUpdate(v *types.FlinkApplicationConfigurationUpdate, value smithyjson.Value) error { 1706 object := value.Object() 1707 defer object.Close() 1708 1709 if v.CheckpointConfigurationUpdate != nil { 1710 ok := object.Key("CheckpointConfigurationUpdate") 1711 if err := awsAwsjson11_serializeDocumentCheckpointConfigurationUpdate(v.CheckpointConfigurationUpdate, ok); err != nil { 1712 return err 1713 } 1714 } 1715 1716 if v.MonitoringConfigurationUpdate != nil { 1717 ok := object.Key("MonitoringConfigurationUpdate") 1718 if err := awsAwsjson11_serializeDocumentMonitoringConfigurationUpdate(v.MonitoringConfigurationUpdate, ok); err != nil { 1719 return err 1720 } 1721 } 1722 1723 if v.ParallelismConfigurationUpdate != nil { 1724 ok := object.Key("ParallelismConfigurationUpdate") 1725 if err := awsAwsjson11_serializeDocumentParallelismConfigurationUpdate(v.ParallelismConfigurationUpdate, ok); err != nil { 1726 return err 1727 } 1728 } 1729 1730 return nil 1731} 1732 1733func awsAwsjson11_serializeDocumentFlinkRunConfiguration(v *types.FlinkRunConfiguration, value smithyjson.Value) error { 1734 object := value.Object() 1735 defer object.Close() 1736 1737 if v.AllowNonRestoredState != nil { 1738 ok := object.Key("AllowNonRestoredState") 1739 ok.Boolean(*v.AllowNonRestoredState) 1740 } 1741 1742 return nil 1743} 1744 1745func awsAwsjson11_serializeDocumentInput(v *types.Input, value smithyjson.Value) error { 1746 object := value.Object() 1747 defer object.Close() 1748 1749 if v.InputParallelism != nil { 1750 ok := object.Key("InputParallelism") 1751 if err := awsAwsjson11_serializeDocumentInputParallelism(v.InputParallelism, ok); err != nil { 1752 return err 1753 } 1754 } 1755 1756 if v.InputProcessingConfiguration != nil { 1757 ok := object.Key("InputProcessingConfiguration") 1758 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 1759 return err 1760 } 1761 } 1762 1763 if v.InputSchema != nil { 1764 ok := object.Key("InputSchema") 1765 if err := awsAwsjson11_serializeDocumentSourceSchema(v.InputSchema, ok); err != nil { 1766 return err 1767 } 1768 } 1769 1770 if v.KinesisFirehoseInput != nil { 1771 ok := object.Key("KinesisFirehoseInput") 1772 if err := awsAwsjson11_serializeDocumentKinesisFirehoseInput(v.KinesisFirehoseInput, ok); err != nil { 1773 return err 1774 } 1775 } 1776 1777 if v.KinesisStreamsInput != nil { 1778 ok := object.Key("KinesisStreamsInput") 1779 if err := awsAwsjson11_serializeDocumentKinesisStreamsInput(v.KinesisStreamsInput, ok); err != nil { 1780 return err 1781 } 1782 } 1783 1784 if v.NamePrefix != nil { 1785 ok := object.Key("NamePrefix") 1786 ok.String(*v.NamePrefix) 1787 } 1788 1789 return nil 1790} 1791 1792func awsAwsjson11_serializeDocumentInputLambdaProcessor(v *types.InputLambdaProcessor, value smithyjson.Value) error { 1793 object := value.Object() 1794 defer object.Close() 1795 1796 if v.ResourceARN != nil { 1797 ok := object.Key("ResourceARN") 1798 ok.String(*v.ResourceARN) 1799 } 1800 1801 return nil 1802} 1803 1804func awsAwsjson11_serializeDocumentInputLambdaProcessorUpdate(v *types.InputLambdaProcessorUpdate, value smithyjson.Value) error { 1805 object := value.Object() 1806 defer object.Close() 1807 1808 if v.ResourceARNUpdate != nil { 1809 ok := object.Key("ResourceARNUpdate") 1810 ok.String(*v.ResourceARNUpdate) 1811 } 1812 1813 return nil 1814} 1815 1816func awsAwsjson11_serializeDocumentInputParallelism(v *types.InputParallelism, value smithyjson.Value) error { 1817 object := value.Object() 1818 defer object.Close() 1819 1820 if v.Count != nil { 1821 ok := object.Key("Count") 1822 ok.Integer(*v.Count) 1823 } 1824 1825 return nil 1826} 1827 1828func awsAwsjson11_serializeDocumentInputParallelismUpdate(v *types.InputParallelismUpdate, value smithyjson.Value) error { 1829 object := value.Object() 1830 defer object.Close() 1831 1832 if v.CountUpdate != nil { 1833 ok := object.Key("CountUpdate") 1834 ok.Integer(*v.CountUpdate) 1835 } 1836 1837 return nil 1838} 1839 1840func awsAwsjson11_serializeDocumentInputProcessingConfiguration(v *types.InputProcessingConfiguration, value smithyjson.Value) error { 1841 object := value.Object() 1842 defer object.Close() 1843 1844 if v.InputLambdaProcessor != nil { 1845 ok := object.Key("InputLambdaProcessor") 1846 if err := awsAwsjson11_serializeDocumentInputLambdaProcessor(v.InputLambdaProcessor, ok); err != nil { 1847 return err 1848 } 1849 } 1850 1851 return nil 1852} 1853 1854func awsAwsjson11_serializeDocumentInputProcessingConfigurationUpdate(v *types.InputProcessingConfigurationUpdate, value smithyjson.Value) error { 1855 object := value.Object() 1856 defer object.Close() 1857 1858 if v.InputLambdaProcessorUpdate != nil { 1859 ok := object.Key("InputLambdaProcessorUpdate") 1860 if err := awsAwsjson11_serializeDocumentInputLambdaProcessorUpdate(v.InputLambdaProcessorUpdate, ok); err != nil { 1861 return err 1862 } 1863 } 1864 1865 return nil 1866} 1867 1868func awsAwsjson11_serializeDocumentInputs(v []types.Input, value smithyjson.Value) error { 1869 array := value.Array() 1870 defer array.Close() 1871 1872 for i := range v { 1873 av := array.Value() 1874 if err := awsAwsjson11_serializeDocumentInput(&v[i], av); err != nil { 1875 return err 1876 } 1877 } 1878 return nil 1879} 1880 1881func awsAwsjson11_serializeDocumentInputSchemaUpdate(v *types.InputSchemaUpdate, value smithyjson.Value) error { 1882 object := value.Object() 1883 defer object.Close() 1884 1885 if v.RecordColumnUpdates != nil { 1886 ok := object.Key("RecordColumnUpdates") 1887 if err := awsAwsjson11_serializeDocumentRecordColumns(v.RecordColumnUpdates, ok); err != nil { 1888 return err 1889 } 1890 } 1891 1892 if v.RecordEncodingUpdate != nil { 1893 ok := object.Key("RecordEncodingUpdate") 1894 ok.String(*v.RecordEncodingUpdate) 1895 } 1896 1897 if v.RecordFormatUpdate != nil { 1898 ok := object.Key("RecordFormatUpdate") 1899 if err := awsAwsjson11_serializeDocumentRecordFormat(v.RecordFormatUpdate, ok); err != nil { 1900 return err 1901 } 1902 } 1903 1904 return nil 1905} 1906 1907func awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v *types.InputStartingPositionConfiguration, value smithyjson.Value) error { 1908 object := value.Object() 1909 defer object.Close() 1910 1911 if len(v.InputStartingPosition) > 0 { 1912 ok := object.Key("InputStartingPosition") 1913 ok.String(string(v.InputStartingPosition)) 1914 } 1915 1916 return nil 1917} 1918 1919func awsAwsjson11_serializeDocumentInputUpdate(v *types.InputUpdate, value smithyjson.Value) error { 1920 object := value.Object() 1921 defer object.Close() 1922 1923 if v.InputId != nil { 1924 ok := object.Key("InputId") 1925 ok.String(*v.InputId) 1926 } 1927 1928 if v.InputParallelismUpdate != nil { 1929 ok := object.Key("InputParallelismUpdate") 1930 if err := awsAwsjson11_serializeDocumentInputParallelismUpdate(v.InputParallelismUpdate, ok); err != nil { 1931 return err 1932 } 1933 } 1934 1935 if v.InputProcessingConfigurationUpdate != nil { 1936 ok := object.Key("InputProcessingConfigurationUpdate") 1937 if err := awsAwsjson11_serializeDocumentInputProcessingConfigurationUpdate(v.InputProcessingConfigurationUpdate, ok); err != nil { 1938 return err 1939 } 1940 } 1941 1942 if v.InputSchemaUpdate != nil { 1943 ok := object.Key("InputSchemaUpdate") 1944 if err := awsAwsjson11_serializeDocumentInputSchemaUpdate(v.InputSchemaUpdate, ok); err != nil { 1945 return err 1946 } 1947 } 1948 1949 if v.KinesisFirehoseInputUpdate != nil { 1950 ok := object.Key("KinesisFirehoseInputUpdate") 1951 if err := awsAwsjson11_serializeDocumentKinesisFirehoseInputUpdate(v.KinesisFirehoseInputUpdate, ok); err != nil { 1952 return err 1953 } 1954 } 1955 1956 if v.KinesisStreamsInputUpdate != nil { 1957 ok := object.Key("KinesisStreamsInputUpdate") 1958 if err := awsAwsjson11_serializeDocumentKinesisStreamsInputUpdate(v.KinesisStreamsInputUpdate, ok); err != nil { 1959 return err 1960 } 1961 } 1962 1963 if v.NamePrefixUpdate != nil { 1964 ok := object.Key("NamePrefixUpdate") 1965 ok.String(*v.NamePrefixUpdate) 1966 } 1967 1968 return nil 1969} 1970 1971func awsAwsjson11_serializeDocumentInputUpdates(v []types.InputUpdate, value smithyjson.Value) error { 1972 array := value.Array() 1973 defer array.Close() 1974 1975 for i := range v { 1976 av := array.Value() 1977 if err := awsAwsjson11_serializeDocumentInputUpdate(&v[i], av); err != nil { 1978 return err 1979 } 1980 } 1981 return nil 1982} 1983 1984func awsAwsjson11_serializeDocumentJSONMappingParameters(v *types.JSONMappingParameters, value smithyjson.Value) error { 1985 object := value.Object() 1986 defer object.Close() 1987 1988 if v.RecordRowPath != nil { 1989 ok := object.Key("RecordRowPath") 1990 ok.String(*v.RecordRowPath) 1991 } 1992 1993 return nil 1994} 1995 1996func awsAwsjson11_serializeDocumentKinesisFirehoseInput(v *types.KinesisFirehoseInput, value smithyjson.Value) error { 1997 object := value.Object() 1998 defer object.Close() 1999 2000 if v.ResourceARN != nil { 2001 ok := object.Key("ResourceARN") 2002 ok.String(*v.ResourceARN) 2003 } 2004 2005 return nil 2006} 2007 2008func awsAwsjson11_serializeDocumentKinesisFirehoseInputUpdate(v *types.KinesisFirehoseInputUpdate, value smithyjson.Value) error { 2009 object := value.Object() 2010 defer object.Close() 2011 2012 if v.ResourceARNUpdate != nil { 2013 ok := object.Key("ResourceARNUpdate") 2014 ok.String(*v.ResourceARNUpdate) 2015 } 2016 2017 return nil 2018} 2019 2020func awsAwsjson11_serializeDocumentKinesisFirehoseOutput(v *types.KinesisFirehoseOutput, value smithyjson.Value) error { 2021 object := value.Object() 2022 defer object.Close() 2023 2024 if v.ResourceARN != nil { 2025 ok := object.Key("ResourceARN") 2026 ok.String(*v.ResourceARN) 2027 } 2028 2029 return nil 2030} 2031 2032func awsAwsjson11_serializeDocumentKinesisFirehoseOutputUpdate(v *types.KinesisFirehoseOutputUpdate, value smithyjson.Value) error { 2033 object := value.Object() 2034 defer object.Close() 2035 2036 if v.ResourceARNUpdate != nil { 2037 ok := object.Key("ResourceARNUpdate") 2038 ok.String(*v.ResourceARNUpdate) 2039 } 2040 2041 return nil 2042} 2043 2044func awsAwsjson11_serializeDocumentKinesisStreamsInput(v *types.KinesisStreamsInput, value smithyjson.Value) error { 2045 object := value.Object() 2046 defer object.Close() 2047 2048 if v.ResourceARN != nil { 2049 ok := object.Key("ResourceARN") 2050 ok.String(*v.ResourceARN) 2051 } 2052 2053 return nil 2054} 2055 2056func awsAwsjson11_serializeDocumentKinesisStreamsInputUpdate(v *types.KinesisStreamsInputUpdate, value smithyjson.Value) error { 2057 object := value.Object() 2058 defer object.Close() 2059 2060 if v.ResourceARNUpdate != nil { 2061 ok := object.Key("ResourceARNUpdate") 2062 ok.String(*v.ResourceARNUpdate) 2063 } 2064 2065 return nil 2066} 2067 2068func awsAwsjson11_serializeDocumentKinesisStreamsOutput(v *types.KinesisStreamsOutput, value smithyjson.Value) error { 2069 object := value.Object() 2070 defer object.Close() 2071 2072 if v.ResourceARN != nil { 2073 ok := object.Key("ResourceARN") 2074 ok.String(*v.ResourceARN) 2075 } 2076 2077 return nil 2078} 2079 2080func awsAwsjson11_serializeDocumentKinesisStreamsOutputUpdate(v *types.KinesisStreamsOutputUpdate, value smithyjson.Value) error { 2081 object := value.Object() 2082 defer object.Close() 2083 2084 if v.ResourceARNUpdate != nil { 2085 ok := object.Key("ResourceARNUpdate") 2086 ok.String(*v.ResourceARNUpdate) 2087 } 2088 2089 return nil 2090} 2091 2092func awsAwsjson11_serializeDocumentLambdaOutput(v *types.LambdaOutput, value smithyjson.Value) error { 2093 object := value.Object() 2094 defer object.Close() 2095 2096 if v.ResourceARN != nil { 2097 ok := object.Key("ResourceARN") 2098 ok.String(*v.ResourceARN) 2099 } 2100 2101 return nil 2102} 2103 2104func awsAwsjson11_serializeDocumentLambdaOutputUpdate(v *types.LambdaOutputUpdate, value smithyjson.Value) error { 2105 object := value.Object() 2106 defer object.Close() 2107 2108 if v.ResourceARNUpdate != nil { 2109 ok := object.Key("ResourceARNUpdate") 2110 ok.String(*v.ResourceARNUpdate) 2111 } 2112 2113 return nil 2114} 2115 2116func awsAwsjson11_serializeDocumentMappingParameters(v *types.MappingParameters, value smithyjson.Value) error { 2117 object := value.Object() 2118 defer object.Close() 2119 2120 if v.CSVMappingParameters != nil { 2121 ok := object.Key("CSVMappingParameters") 2122 if err := awsAwsjson11_serializeDocumentCSVMappingParameters(v.CSVMappingParameters, ok); err != nil { 2123 return err 2124 } 2125 } 2126 2127 if v.JSONMappingParameters != nil { 2128 ok := object.Key("JSONMappingParameters") 2129 if err := awsAwsjson11_serializeDocumentJSONMappingParameters(v.JSONMappingParameters, ok); err != nil { 2130 return err 2131 } 2132 } 2133 2134 return nil 2135} 2136 2137func awsAwsjson11_serializeDocumentMonitoringConfiguration(v *types.MonitoringConfiguration, value smithyjson.Value) error { 2138 object := value.Object() 2139 defer object.Close() 2140 2141 if len(v.ConfigurationType) > 0 { 2142 ok := object.Key("ConfigurationType") 2143 ok.String(string(v.ConfigurationType)) 2144 } 2145 2146 if len(v.LogLevel) > 0 { 2147 ok := object.Key("LogLevel") 2148 ok.String(string(v.LogLevel)) 2149 } 2150 2151 if len(v.MetricsLevel) > 0 { 2152 ok := object.Key("MetricsLevel") 2153 ok.String(string(v.MetricsLevel)) 2154 } 2155 2156 return nil 2157} 2158 2159func awsAwsjson11_serializeDocumentMonitoringConfigurationUpdate(v *types.MonitoringConfigurationUpdate, value smithyjson.Value) error { 2160 object := value.Object() 2161 defer object.Close() 2162 2163 if len(v.ConfigurationTypeUpdate) > 0 { 2164 ok := object.Key("ConfigurationTypeUpdate") 2165 ok.String(string(v.ConfigurationTypeUpdate)) 2166 } 2167 2168 if len(v.LogLevelUpdate) > 0 { 2169 ok := object.Key("LogLevelUpdate") 2170 ok.String(string(v.LogLevelUpdate)) 2171 } 2172 2173 if len(v.MetricsLevelUpdate) > 0 { 2174 ok := object.Key("MetricsLevelUpdate") 2175 ok.String(string(v.MetricsLevelUpdate)) 2176 } 2177 2178 return nil 2179} 2180 2181func awsAwsjson11_serializeDocumentOutput(v *types.Output, value smithyjson.Value) error { 2182 object := value.Object() 2183 defer object.Close() 2184 2185 if v.DestinationSchema != nil { 2186 ok := object.Key("DestinationSchema") 2187 if err := awsAwsjson11_serializeDocumentDestinationSchema(v.DestinationSchema, ok); err != nil { 2188 return err 2189 } 2190 } 2191 2192 if v.KinesisFirehoseOutput != nil { 2193 ok := object.Key("KinesisFirehoseOutput") 2194 if err := awsAwsjson11_serializeDocumentKinesisFirehoseOutput(v.KinesisFirehoseOutput, ok); err != nil { 2195 return err 2196 } 2197 } 2198 2199 if v.KinesisStreamsOutput != nil { 2200 ok := object.Key("KinesisStreamsOutput") 2201 if err := awsAwsjson11_serializeDocumentKinesisStreamsOutput(v.KinesisStreamsOutput, ok); err != nil { 2202 return err 2203 } 2204 } 2205 2206 if v.LambdaOutput != nil { 2207 ok := object.Key("LambdaOutput") 2208 if err := awsAwsjson11_serializeDocumentLambdaOutput(v.LambdaOutput, ok); err != nil { 2209 return err 2210 } 2211 } 2212 2213 if v.Name != nil { 2214 ok := object.Key("Name") 2215 ok.String(*v.Name) 2216 } 2217 2218 return nil 2219} 2220 2221func awsAwsjson11_serializeDocumentOutputs(v []types.Output, value smithyjson.Value) error { 2222 array := value.Array() 2223 defer array.Close() 2224 2225 for i := range v { 2226 av := array.Value() 2227 if err := awsAwsjson11_serializeDocumentOutput(&v[i], av); err != nil { 2228 return err 2229 } 2230 } 2231 return nil 2232} 2233 2234func awsAwsjson11_serializeDocumentOutputUpdate(v *types.OutputUpdate, value smithyjson.Value) error { 2235 object := value.Object() 2236 defer object.Close() 2237 2238 if v.DestinationSchemaUpdate != nil { 2239 ok := object.Key("DestinationSchemaUpdate") 2240 if err := awsAwsjson11_serializeDocumentDestinationSchema(v.DestinationSchemaUpdate, ok); err != nil { 2241 return err 2242 } 2243 } 2244 2245 if v.KinesisFirehoseOutputUpdate != nil { 2246 ok := object.Key("KinesisFirehoseOutputUpdate") 2247 if err := awsAwsjson11_serializeDocumentKinesisFirehoseOutputUpdate(v.KinesisFirehoseOutputUpdate, ok); err != nil { 2248 return err 2249 } 2250 } 2251 2252 if v.KinesisStreamsOutputUpdate != nil { 2253 ok := object.Key("KinesisStreamsOutputUpdate") 2254 if err := awsAwsjson11_serializeDocumentKinesisStreamsOutputUpdate(v.KinesisStreamsOutputUpdate, ok); err != nil { 2255 return err 2256 } 2257 } 2258 2259 if v.LambdaOutputUpdate != nil { 2260 ok := object.Key("LambdaOutputUpdate") 2261 if err := awsAwsjson11_serializeDocumentLambdaOutputUpdate(v.LambdaOutputUpdate, ok); err != nil { 2262 return err 2263 } 2264 } 2265 2266 if v.NameUpdate != nil { 2267 ok := object.Key("NameUpdate") 2268 ok.String(*v.NameUpdate) 2269 } 2270 2271 if v.OutputId != nil { 2272 ok := object.Key("OutputId") 2273 ok.String(*v.OutputId) 2274 } 2275 2276 return nil 2277} 2278 2279func awsAwsjson11_serializeDocumentOutputUpdates(v []types.OutputUpdate, value smithyjson.Value) error { 2280 array := value.Array() 2281 defer array.Close() 2282 2283 for i := range v { 2284 av := array.Value() 2285 if err := awsAwsjson11_serializeDocumentOutputUpdate(&v[i], av); err != nil { 2286 return err 2287 } 2288 } 2289 return nil 2290} 2291 2292func awsAwsjson11_serializeDocumentParallelismConfiguration(v *types.ParallelismConfiguration, value smithyjson.Value) error { 2293 object := value.Object() 2294 defer object.Close() 2295 2296 if v.AutoScalingEnabled != nil { 2297 ok := object.Key("AutoScalingEnabled") 2298 ok.Boolean(*v.AutoScalingEnabled) 2299 } 2300 2301 if len(v.ConfigurationType) > 0 { 2302 ok := object.Key("ConfigurationType") 2303 ok.String(string(v.ConfigurationType)) 2304 } 2305 2306 if v.Parallelism != nil { 2307 ok := object.Key("Parallelism") 2308 ok.Integer(*v.Parallelism) 2309 } 2310 2311 if v.ParallelismPerKPU != nil { 2312 ok := object.Key("ParallelismPerKPU") 2313 ok.Integer(*v.ParallelismPerKPU) 2314 } 2315 2316 return nil 2317} 2318 2319func awsAwsjson11_serializeDocumentParallelismConfigurationUpdate(v *types.ParallelismConfigurationUpdate, value smithyjson.Value) error { 2320 object := value.Object() 2321 defer object.Close() 2322 2323 if v.AutoScalingEnabledUpdate != nil { 2324 ok := object.Key("AutoScalingEnabledUpdate") 2325 ok.Boolean(*v.AutoScalingEnabledUpdate) 2326 } 2327 2328 if len(v.ConfigurationTypeUpdate) > 0 { 2329 ok := object.Key("ConfigurationTypeUpdate") 2330 ok.String(string(v.ConfigurationTypeUpdate)) 2331 } 2332 2333 if v.ParallelismPerKPUUpdate != nil { 2334 ok := object.Key("ParallelismPerKPUUpdate") 2335 ok.Integer(*v.ParallelismPerKPUUpdate) 2336 } 2337 2338 if v.ParallelismUpdate != nil { 2339 ok := object.Key("ParallelismUpdate") 2340 ok.Integer(*v.ParallelismUpdate) 2341 } 2342 2343 return nil 2344} 2345 2346func awsAwsjson11_serializeDocumentPropertyGroup(v *types.PropertyGroup, value smithyjson.Value) error { 2347 object := value.Object() 2348 defer object.Close() 2349 2350 if v.PropertyGroupId != nil { 2351 ok := object.Key("PropertyGroupId") 2352 ok.String(*v.PropertyGroupId) 2353 } 2354 2355 if v.PropertyMap != nil { 2356 ok := object.Key("PropertyMap") 2357 if err := awsAwsjson11_serializeDocumentPropertyMap(v.PropertyMap, ok); err != nil { 2358 return err 2359 } 2360 } 2361 2362 return nil 2363} 2364 2365func awsAwsjson11_serializeDocumentPropertyGroups(v []types.PropertyGroup, value smithyjson.Value) error { 2366 array := value.Array() 2367 defer array.Close() 2368 2369 for i := range v { 2370 av := array.Value() 2371 if err := awsAwsjson11_serializeDocumentPropertyGroup(&v[i], av); err != nil { 2372 return err 2373 } 2374 } 2375 return nil 2376} 2377 2378func awsAwsjson11_serializeDocumentPropertyMap(v map[string]string, value smithyjson.Value) error { 2379 object := value.Object() 2380 defer object.Close() 2381 2382 for key := range v { 2383 om := object.Key(key) 2384 om.String(v[key]) 2385 } 2386 return nil 2387} 2388 2389func awsAwsjson11_serializeDocumentRecordColumn(v *types.RecordColumn, value smithyjson.Value) error { 2390 object := value.Object() 2391 defer object.Close() 2392 2393 if v.Mapping != nil { 2394 ok := object.Key("Mapping") 2395 ok.String(*v.Mapping) 2396 } 2397 2398 if v.Name != nil { 2399 ok := object.Key("Name") 2400 ok.String(*v.Name) 2401 } 2402 2403 if v.SqlType != nil { 2404 ok := object.Key("SqlType") 2405 ok.String(*v.SqlType) 2406 } 2407 2408 return nil 2409} 2410 2411func awsAwsjson11_serializeDocumentRecordColumns(v []types.RecordColumn, value smithyjson.Value) error { 2412 array := value.Array() 2413 defer array.Close() 2414 2415 for i := range v { 2416 av := array.Value() 2417 if err := awsAwsjson11_serializeDocumentRecordColumn(&v[i], av); err != nil { 2418 return err 2419 } 2420 } 2421 return nil 2422} 2423 2424func awsAwsjson11_serializeDocumentRecordFormat(v *types.RecordFormat, value smithyjson.Value) error { 2425 object := value.Object() 2426 defer object.Close() 2427 2428 if v.MappingParameters != nil { 2429 ok := object.Key("MappingParameters") 2430 if err := awsAwsjson11_serializeDocumentMappingParameters(v.MappingParameters, ok); err != nil { 2431 return err 2432 } 2433 } 2434 2435 if len(v.RecordFormatType) > 0 { 2436 ok := object.Key("RecordFormatType") 2437 ok.String(string(v.RecordFormatType)) 2438 } 2439 2440 return nil 2441} 2442 2443func awsAwsjson11_serializeDocumentReferenceDataSource(v *types.ReferenceDataSource, value smithyjson.Value) error { 2444 object := value.Object() 2445 defer object.Close() 2446 2447 if v.ReferenceSchema != nil { 2448 ok := object.Key("ReferenceSchema") 2449 if err := awsAwsjson11_serializeDocumentSourceSchema(v.ReferenceSchema, ok); err != nil { 2450 return err 2451 } 2452 } 2453 2454 if v.S3ReferenceDataSource != nil { 2455 ok := object.Key("S3ReferenceDataSource") 2456 if err := awsAwsjson11_serializeDocumentS3ReferenceDataSource(v.S3ReferenceDataSource, ok); err != nil { 2457 return err 2458 } 2459 } 2460 2461 if v.TableName != nil { 2462 ok := object.Key("TableName") 2463 ok.String(*v.TableName) 2464 } 2465 2466 return nil 2467} 2468 2469func awsAwsjson11_serializeDocumentReferenceDataSources(v []types.ReferenceDataSource, value smithyjson.Value) error { 2470 array := value.Array() 2471 defer array.Close() 2472 2473 for i := range v { 2474 av := array.Value() 2475 if err := awsAwsjson11_serializeDocumentReferenceDataSource(&v[i], av); err != nil { 2476 return err 2477 } 2478 } 2479 return nil 2480} 2481 2482func awsAwsjson11_serializeDocumentReferenceDataSourceUpdate(v *types.ReferenceDataSourceUpdate, value smithyjson.Value) error { 2483 object := value.Object() 2484 defer object.Close() 2485 2486 if v.ReferenceId != nil { 2487 ok := object.Key("ReferenceId") 2488 ok.String(*v.ReferenceId) 2489 } 2490 2491 if v.ReferenceSchemaUpdate != nil { 2492 ok := object.Key("ReferenceSchemaUpdate") 2493 if err := awsAwsjson11_serializeDocumentSourceSchema(v.ReferenceSchemaUpdate, ok); err != nil { 2494 return err 2495 } 2496 } 2497 2498 if v.S3ReferenceDataSourceUpdate != nil { 2499 ok := object.Key("S3ReferenceDataSourceUpdate") 2500 if err := awsAwsjson11_serializeDocumentS3ReferenceDataSourceUpdate(v.S3ReferenceDataSourceUpdate, ok); err != nil { 2501 return err 2502 } 2503 } 2504 2505 if v.TableNameUpdate != nil { 2506 ok := object.Key("TableNameUpdate") 2507 ok.String(*v.TableNameUpdate) 2508 } 2509 2510 return nil 2511} 2512 2513func awsAwsjson11_serializeDocumentReferenceDataSourceUpdates(v []types.ReferenceDataSourceUpdate, value smithyjson.Value) error { 2514 array := value.Array() 2515 defer array.Close() 2516 2517 for i := range v { 2518 av := array.Value() 2519 if err := awsAwsjson11_serializeDocumentReferenceDataSourceUpdate(&v[i], av); err != nil { 2520 return err 2521 } 2522 } 2523 return nil 2524} 2525 2526func awsAwsjson11_serializeDocumentRunConfiguration(v *types.RunConfiguration, value smithyjson.Value) error { 2527 object := value.Object() 2528 defer object.Close() 2529 2530 if v.ApplicationRestoreConfiguration != nil { 2531 ok := object.Key("ApplicationRestoreConfiguration") 2532 if err := awsAwsjson11_serializeDocumentApplicationRestoreConfiguration(v.ApplicationRestoreConfiguration, ok); err != nil { 2533 return err 2534 } 2535 } 2536 2537 if v.FlinkRunConfiguration != nil { 2538 ok := object.Key("FlinkRunConfiguration") 2539 if err := awsAwsjson11_serializeDocumentFlinkRunConfiguration(v.FlinkRunConfiguration, ok); err != nil { 2540 return err 2541 } 2542 } 2543 2544 if v.SqlRunConfigurations != nil { 2545 ok := object.Key("SqlRunConfigurations") 2546 if err := awsAwsjson11_serializeDocumentSqlRunConfigurations(v.SqlRunConfigurations, ok); err != nil { 2547 return err 2548 } 2549 } 2550 2551 return nil 2552} 2553 2554func awsAwsjson11_serializeDocumentRunConfigurationUpdate(v *types.RunConfigurationUpdate, value smithyjson.Value) error { 2555 object := value.Object() 2556 defer object.Close() 2557 2558 if v.ApplicationRestoreConfiguration != nil { 2559 ok := object.Key("ApplicationRestoreConfiguration") 2560 if err := awsAwsjson11_serializeDocumentApplicationRestoreConfiguration(v.ApplicationRestoreConfiguration, ok); err != nil { 2561 return err 2562 } 2563 } 2564 2565 if v.FlinkRunConfiguration != nil { 2566 ok := object.Key("FlinkRunConfiguration") 2567 if err := awsAwsjson11_serializeDocumentFlinkRunConfiguration(v.FlinkRunConfiguration, ok); err != nil { 2568 return err 2569 } 2570 } 2571 2572 return nil 2573} 2574 2575func awsAwsjson11_serializeDocumentS3Configuration(v *types.S3Configuration, value smithyjson.Value) error { 2576 object := value.Object() 2577 defer object.Close() 2578 2579 if v.BucketARN != nil { 2580 ok := object.Key("BucketARN") 2581 ok.String(*v.BucketARN) 2582 } 2583 2584 if v.FileKey != nil { 2585 ok := object.Key("FileKey") 2586 ok.String(*v.FileKey) 2587 } 2588 2589 return nil 2590} 2591 2592func awsAwsjson11_serializeDocumentS3ContentLocation(v *types.S3ContentLocation, value smithyjson.Value) error { 2593 object := value.Object() 2594 defer object.Close() 2595 2596 if v.BucketARN != nil { 2597 ok := object.Key("BucketARN") 2598 ok.String(*v.BucketARN) 2599 } 2600 2601 if v.FileKey != nil { 2602 ok := object.Key("FileKey") 2603 ok.String(*v.FileKey) 2604 } 2605 2606 if v.ObjectVersion != nil { 2607 ok := object.Key("ObjectVersion") 2608 ok.String(*v.ObjectVersion) 2609 } 2610 2611 return nil 2612} 2613 2614func awsAwsjson11_serializeDocumentS3ContentLocationUpdate(v *types.S3ContentLocationUpdate, value smithyjson.Value) error { 2615 object := value.Object() 2616 defer object.Close() 2617 2618 if v.BucketARNUpdate != nil { 2619 ok := object.Key("BucketARNUpdate") 2620 ok.String(*v.BucketARNUpdate) 2621 } 2622 2623 if v.FileKeyUpdate != nil { 2624 ok := object.Key("FileKeyUpdate") 2625 ok.String(*v.FileKeyUpdate) 2626 } 2627 2628 if v.ObjectVersionUpdate != nil { 2629 ok := object.Key("ObjectVersionUpdate") 2630 ok.String(*v.ObjectVersionUpdate) 2631 } 2632 2633 return nil 2634} 2635 2636func awsAwsjson11_serializeDocumentS3ReferenceDataSource(v *types.S3ReferenceDataSource, value smithyjson.Value) error { 2637 object := value.Object() 2638 defer object.Close() 2639 2640 if v.BucketARN != nil { 2641 ok := object.Key("BucketARN") 2642 ok.String(*v.BucketARN) 2643 } 2644 2645 if v.FileKey != nil { 2646 ok := object.Key("FileKey") 2647 ok.String(*v.FileKey) 2648 } 2649 2650 return nil 2651} 2652 2653func awsAwsjson11_serializeDocumentS3ReferenceDataSourceUpdate(v *types.S3ReferenceDataSourceUpdate, value smithyjson.Value) error { 2654 object := value.Object() 2655 defer object.Close() 2656 2657 if v.BucketARNUpdate != nil { 2658 ok := object.Key("BucketARNUpdate") 2659 ok.String(*v.BucketARNUpdate) 2660 } 2661 2662 if v.FileKeyUpdate != nil { 2663 ok := object.Key("FileKeyUpdate") 2664 ok.String(*v.FileKeyUpdate) 2665 } 2666 2667 return nil 2668} 2669 2670func awsAwsjson11_serializeDocumentSecurityGroupIds(v []string, value smithyjson.Value) error { 2671 array := value.Array() 2672 defer array.Close() 2673 2674 for i := range v { 2675 av := array.Value() 2676 av.String(v[i]) 2677 } 2678 return nil 2679} 2680 2681func awsAwsjson11_serializeDocumentSourceSchema(v *types.SourceSchema, value smithyjson.Value) error { 2682 object := value.Object() 2683 defer object.Close() 2684 2685 if v.RecordColumns != nil { 2686 ok := object.Key("RecordColumns") 2687 if err := awsAwsjson11_serializeDocumentRecordColumns(v.RecordColumns, ok); err != nil { 2688 return err 2689 } 2690 } 2691 2692 if v.RecordEncoding != nil { 2693 ok := object.Key("RecordEncoding") 2694 ok.String(*v.RecordEncoding) 2695 } 2696 2697 if v.RecordFormat != nil { 2698 ok := object.Key("RecordFormat") 2699 if err := awsAwsjson11_serializeDocumentRecordFormat(v.RecordFormat, ok); err != nil { 2700 return err 2701 } 2702 } 2703 2704 return nil 2705} 2706 2707func awsAwsjson11_serializeDocumentSqlApplicationConfiguration(v *types.SqlApplicationConfiguration, value smithyjson.Value) error { 2708 object := value.Object() 2709 defer object.Close() 2710 2711 if v.Inputs != nil { 2712 ok := object.Key("Inputs") 2713 if err := awsAwsjson11_serializeDocumentInputs(v.Inputs, ok); err != nil { 2714 return err 2715 } 2716 } 2717 2718 if v.Outputs != nil { 2719 ok := object.Key("Outputs") 2720 if err := awsAwsjson11_serializeDocumentOutputs(v.Outputs, ok); err != nil { 2721 return err 2722 } 2723 } 2724 2725 if v.ReferenceDataSources != nil { 2726 ok := object.Key("ReferenceDataSources") 2727 if err := awsAwsjson11_serializeDocumentReferenceDataSources(v.ReferenceDataSources, ok); err != nil { 2728 return err 2729 } 2730 } 2731 2732 return nil 2733} 2734 2735func awsAwsjson11_serializeDocumentSqlApplicationConfigurationUpdate(v *types.SqlApplicationConfigurationUpdate, value smithyjson.Value) error { 2736 object := value.Object() 2737 defer object.Close() 2738 2739 if v.InputUpdates != nil { 2740 ok := object.Key("InputUpdates") 2741 if err := awsAwsjson11_serializeDocumentInputUpdates(v.InputUpdates, ok); err != nil { 2742 return err 2743 } 2744 } 2745 2746 if v.OutputUpdates != nil { 2747 ok := object.Key("OutputUpdates") 2748 if err := awsAwsjson11_serializeDocumentOutputUpdates(v.OutputUpdates, ok); err != nil { 2749 return err 2750 } 2751 } 2752 2753 if v.ReferenceDataSourceUpdates != nil { 2754 ok := object.Key("ReferenceDataSourceUpdates") 2755 if err := awsAwsjson11_serializeDocumentReferenceDataSourceUpdates(v.ReferenceDataSourceUpdates, ok); err != nil { 2756 return err 2757 } 2758 } 2759 2760 return nil 2761} 2762 2763func awsAwsjson11_serializeDocumentSqlRunConfiguration(v *types.SqlRunConfiguration, value smithyjson.Value) error { 2764 object := value.Object() 2765 defer object.Close() 2766 2767 if v.InputId != nil { 2768 ok := object.Key("InputId") 2769 ok.String(*v.InputId) 2770 } 2771 2772 if v.InputStartingPositionConfiguration != nil { 2773 ok := object.Key("InputStartingPositionConfiguration") 2774 if err := awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v.InputStartingPositionConfiguration, ok); err != nil { 2775 return err 2776 } 2777 } 2778 2779 return nil 2780} 2781 2782func awsAwsjson11_serializeDocumentSqlRunConfigurations(v []types.SqlRunConfiguration, value smithyjson.Value) error { 2783 array := value.Array() 2784 defer array.Close() 2785 2786 for i := range v { 2787 av := array.Value() 2788 if err := awsAwsjson11_serializeDocumentSqlRunConfiguration(&v[i], av); err != nil { 2789 return err 2790 } 2791 } 2792 return nil 2793} 2794 2795func awsAwsjson11_serializeDocumentSubnetIds(v []string, value smithyjson.Value) error { 2796 array := value.Array() 2797 defer array.Close() 2798 2799 for i := range v { 2800 av := array.Value() 2801 av.String(v[i]) 2802 } 2803 return nil 2804} 2805 2806func awsAwsjson11_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { 2807 object := value.Object() 2808 defer object.Close() 2809 2810 if v.Key != nil { 2811 ok := object.Key("Key") 2812 ok.String(*v.Key) 2813 } 2814 2815 if v.Value != nil { 2816 ok := object.Key("Value") 2817 ok.String(*v.Value) 2818 } 2819 2820 return nil 2821} 2822 2823func awsAwsjson11_serializeDocumentTagKeys(v []string, value smithyjson.Value) error { 2824 array := value.Array() 2825 defer array.Close() 2826 2827 for i := range v { 2828 av := array.Value() 2829 av.String(v[i]) 2830 } 2831 return nil 2832} 2833 2834func awsAwsjson11_serializeDocumentTags(v []types.Tag, value smithyjson.Value) error { 2835 array := value.Array() 2836 defer array.Close() 2837 2838 for i := range v { 2839 av := array.Value() 2840 if err := awsAwsjson11_serializeDocumentTag(&v[i], av); err != nil { 2841 return err 2842 } 2843 } 2844 return nil 2845} 2846 2847func awsAwsjson11_serializeDocumentVpcConfiguration(v *types.VpcConfiguration, value smithyjson.Value) error { 2848 object := value.Object() 2849 defer object.Close() 2850 2851 if v.SecurityGroupIds != nil { 2852 ok := object.Key("SecurityGroupIds") 2853 if err := awsAwsjson11_serializeDocumentSecurityGroupIds(v.SecurityGroupIds, ok); err != nil { 2854 return err 2855 } 2856 } 2857 2858 if v.SubnetIds != nil { 2859 ok := object.Key("SubnetIds") 2860 if err := awsAwsjson11_serializeDocumentSubnetIds(v.SubnetIds, ok); err != nil { 2861 return err 2862 } 2863 } 2864 2865 return nil 2866} 2867 2868func awsAwsjson11_serializeDocumentVpcConfigurations(v []types.VpcConfiguration, value smithyjson.Value) error { 2869 array := value.Array() 2870 defer array.Close() 2871 2872 for i := range v { 2873 av := array.Value() 2874 if err := awsAwsjson11_serializeDocumentVpcConfiguration(&v[i], av); err != nil { 2875 return err 2876 } 2877 } 2878 return nil 2879} 2880 2881func awsAwsjson11_serializeDocumentVpcConfigurationUpdate(v *types.VpcConfigurationUpdate, value smithyjson.Value) error { 2882 object := value.Object() 2883 defer object.Close() 2884 2885 if v.SecurityGroupIdUpdates != nil { 2886 ok := object.Key("SecurityGroupIdUpdates") 2887 if err := awsAwsjson11_serializeDocumentSecurityGroupIds(v.SecurityGroupIdUpdates, ok); err != nil { 2888 return err 2889 } 2890 } 2891 2892 if v.SubnetIdUpdates != nil { 2893 ok := object.Key("SubnetIdUpdates") 2894 if err := awsAwsjson11_serializeDocumentSubnetIds(v.SubnetIdUpdates, ok); err != nil { 2895 return err 2896 } 2897 } 2898 2899 if v.VpcConfigurationId != nil { 2900 ok := object.Key("VpcConfigurationId") 2901 ok.String(*v.VpcConfigurationId) 2902 } 2903 2904 return nil 2905} 2906 2907func awsAwsjson11_serializeDocumentVpcConfigurationUpdates(v []types.VpcConfigurationUpdate, value smithyjson.Value) error { 2908 array := value.Array() 2909 defer array.Close() 2910 2911 for i := range v { 2912 av := array.Value() 2913 if err := awsAwsjson11_serializeDocumentVpcConfigurationUpdate(&v[i], av); err != nil { 2914 return err 2915 } 2916 } 2917 return nil 2918} 2919 2920func awsAwsjson11_serializeOpDocumentAddApplicationCloudWatchLoggingOptionInput(v *AddApplicationCloudWatchLoggingOptionInput, value smithyjson.Value) error { 2921 object := value.Object() 2922 defer object.Close() 2923 2924 if v.ApplicationName != nil { 2925 ok := object.Key("ApplicationName") 2926 ok.String(*v.ApplicationName) 2927 } 2928 2929 if v.CloudWatchLoggingOption != nil { 2930 ok := object.Key("CloudWatchLoggingOption") 2931 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOption(v.CloudWatchLoggingOption, ok); err != nil { 2932 return err 2933 } 2934 } 2935 2936 if v.CurrentApplicationVersionId != nil { 2937 ok := object.Key("CurrentApplicationVersionId") 2938 ok.Long(*v.CurrentApplicationVersionId) 2939 } 2940 2941 return nil 2942} 2943 2944func awsAwsjson11_serializeOpDocumentAddApplicationInputInput(v *AddApplicationInputInput, value smithyjson.Value) error { 2945 object := value.Object() 2946 defer object.Close() 2947 2948 if v.ApplicationName != nil { 2949 ok := object.Key("ApplicationName") 2950 ok.String(*v.ApplicationName) 2951 } 2952 2953 if v.CurrentApplicationVersionId != nil { 2954 ok := object.Key("CurrentApplicationVersionId") 2955 ok.Long(*v.CurrentApplicationVersionId) 2956 } 2957 2958 if v.Input != nil { 2959 ok := object.Key("Input") 2960 if err := awsAwsjson11_serializeDocumentInput(v.Input, ok); err != nil { 2961 return err 2962 } 2963 } 2964 2965 return nil 2966} 2967 2968func awsAwsjson11_serializeOpDocumentAddApplicationInputProcessingConfigurationInput(v *AddApplicationInputProcessingConfigurationInput, value smithyjson.Value) error { 2969 object := value.Object() 2970 defer object.Close() 2971 2972 if v.ApplicationName != nil { 2973 ok := object.Key("ApplicationName") 2974 ok.String(*v.ApplicationName) 2975 } 2976 2977 if v.CurrentApplicationVersionId != nil { 2978 ok := object.Key("CurrentApplicationVersionId") 2979 ok.Long(*v.CurrentApplicationVersionId) 2980 } 2981 2982 if v.InputId != nil { 2983 ok := object.Key("InputId") 2984 ok.String(*v.InputId) 2985 } 2986 2987 if v.InputProcessingConfiguration != nil { 2988 ok := object.Key("InputProcessingConfiguration") 2989 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 2990 return err 2991 } 2992 } 2993 2994 return nil 2995} 2996 2997func awsAwsjson11_serializeOpDocumentAddApplicationOutputInput(v *AddApplicationOutputInput, value smithyjson.Value) error { 2998 object := value.Object() 2999 defer object.Close() 3000 3001 if v.ApplicationName != nil { 3002 ok := object.Key("ApplicationName") 3003 ok.String(*v.ApplicationName) 3004 } 3005 3006 if v.CurrentApplicationVersionId != nil { 3007 ok := object.Key("CurrentApplicationVersionId") 3008 ok.Long(*v.CurrentApplicationVersionId) 3009 } 3010 3011 if v.Output != nil { 3012 ok := object.Key("Output") 3013 if err := awsAwsjson11_serializeDocumentOutput(v.Output, ok); err != nil { 3014 return err 3015 } 3016 } 3017 3018 return nil 3019} 3020 3021func awsAwsjson11_serializeOpDocumentAddApplicationReferenceDataSourceInput(v *AddApplicationReferenceDataSourceInput, value smithyjson.Value) error { 3022 object := value.Object() 3023 defer object.Close() 3024 3025 if v.ApplicationName != nil { 3026 ok := object.Key("ApplicationName") 3027 ok.String(*v.ApplicationName) 3028 } 3029 3030 if v.CurrentApplicationVersionId != nil { 3031 ok := object.Key("CurrentApplicationVersionId") 3032 ok.Long(*v.CurrentApplicationVersionId) 3033 } 3034 3035 if v.ReferenceDataSource != nil { 3036 ok := object.Key("ReferenceDataSource") 3037 if err := awsAwsjson11_serializeDocumentReferenceDataSource(v.ReferenceDataSource, ok); err != nil { 3038 return err 3039 } 3040 } 3041 3042 return nil 3043} 3044 3045func awsAwsjson11_serializeOpDocumentAddApplicationVpcConfigurationInput(v *AddApplicationVpcConfigurationInput, value smithyjson.Value) error { 3046 object := value.Object() 3047 defer object.Close() 3048 3049 if v.ApplicationName != nil { 3050 ok := object.Key("ApplicationName") 3051 ok.String(*v.ApplicationName) 3052 } 3053 3054 if v.CurrentApplicationVersionId != nil { 3055 ok := object.Key("CurrentApplicationVersionId") 3056 ok.Long(*v.CurrentApplicationVersionId) 3057 } 3058 3059 if v.VpcConfiguration != nil { 3060 ok := object.Key("VpcConfiguration") 3061 if err := awsAwsjson11_serializeDocumentVpcConfiguration(v.VpcConfiguration, ok); err != nil { 3062 return err 3063 } 3064 } 3065 3066 return nil 3067} 3068 3069func awsAwsjson11_serializeOpDocumentCreateApplicationInput(v *CreateApplicationInput, value smithyjson.Value) error { 3070 object := value.Object() 3071 defer object.Close() 3072 3073 if v.ApplicationConfiguration != nil { 3074 ok := object.Key("ApplicationConfiguration") 3075 if err := awsAwsjson11_serializeDocumentApplicationConfiguration(v.ApplicationConfiguration, ok); err != nil { 3076 return err 3077 } 3078 } 3079 3080 if v.ApplicationDescription != nil { 3081 ok := object.Key("ApplicationDescription") 3082 ok.String(*v.ApplicationDescription) 3083 } 3084 3085 if v.ApplicationName != nil { 3086 ok := object.Key("ApplicationName") 3087 ok.String(*v.ApplicationName) 3088 } 3089 3090 if v.CloudWatchLoggingOptions != nil { 3091 ok := object.Key("CloudWatchLoggingOptions") 3092 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptions(v.CloudWatchLoggingOptions, ok); err != nil { 3093 return err 3094 } 3095 } 3096 3097 if len(v.RuntimeEnvironment) > 0 { 3098 ok := object.Key("RuntimeEnvironment") 3099 ok.String(string(v.RuntimeEnvironment)) 3100 } 3101 3102 if v.ServiceExecutionRole != nil { 3103 ok := object.Key("ServiceExecutionRole") 3104 ok.String(*v.ServiceExecutionRole) 3105 } 3106 3107 if v.Tags != nil { 3108 ok := object.Key("Tags") 3109 if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil { 3110 return err 3111 } 3112 } 3113 3114 return nil 3115} 3116 3117func awsAwsjson11_serializeOpDocumentCreateApplicationPresignedUrlInput(v *CreateApplicationPresignedUrlInput, value smithyjson.Value) error { 3118 object := value.Object() 3119 defer object.Close() 3120 3121 if v.ApplicationName != nil { 3122 ok := object.Key("ApplicationName") 3123 ok.String(*v.ApplicationName) 3124 } 3125 3126 if v.SessionExpirationDurationInSeconds != nil { 3127 ok := object.Key("SessionExpirationDurationInSeconds") 3128 ok.Long(*v.SessionExpirationDurationInSeconds) 3129 } 3130 3131 if len(v.UrlType) > 0 { 3132 ok := object.Key("UrlType") 3133 ok.String(string(v.UrlType)) 3134 } 3135 3136 return nil 3137} 3138 3139func awsAwsjson11_serializeOpDocumentCreateApplicationSnapshotInput(v *CreateApplicationSnapshotInput, value smithyjson.Value) error { 3140 object := value.Object() 3141 defer object.Close() 3142 3143 if v.ApplicationName != nil { 3144 ok := object.Key("ApplicationName") 3145 ok.String(*v.ApplicationName) 3146 } 3147 3148 if v.SnapshotName != nil { 3149 ok := object.Key("SnapshotName") 3150 ok.String(*v.SnapshotName) 3151 } 3152 3153 return nil 3154} 3155 3156func awsAwsjson11_serializeOpDocumentDeleteApplicationCloudWatchLoggingOptionInput(v *DeleteApplicationCloudWatchLoggingOptionInput, value smithyjson.Value) error { 3157 object := value.Object() 3158 defer object.Close() 3159 3160 if v.ApplicationName != nil { 3161 ok := object.Key("ApplicationName") 3162 ok.String(*v.ApplicationName) 3163 } 3164 3165 if v.CloudWatchLoggingOptionId != nil { 3166 ok := object.Key("CloudWatchLoggingOptionId") 3167 ok.String(*v.CloudWatchLoggingOptionId) 3168 } 3169 3170 if v.CurrentApplicationVersionId != nil { 3171 ok := object.Key("CurrentApplicationVersionId") 3172 ok.Long(*v.CurrentApplicationVersionId) 3173 } 3174 3175 return nil 3176} 3177 3178func awsAwsjson11_serializeOpDocumentDeleteApplicationInput(v *DeleteApplicationInput, value smithyjson.Value) error { 3179 object := value.Object() 3180 defer object.Close() 3181 3182 if v.ApplicationName != nil { 3183 ok := object.Key("ApplicationName") 3184 ok.String(*v.ApplicationName) 3185 } 3186 3187 if v.CreateTimestamp != nil { 3188 ok := object.Key("CreateTimestamp") 3189 ok.Double(smithytime.FormatEpochSeconds(*v.CreateTimestamp)) 3190 } 3191 3192 return nil 3193} 3194 3195func awsAwsjson11_serializeOpDocumentDeleteApplicationInputProcessingConfigurationInput(v *DeleteApplicationInputProcessingConfigurationInput, value smithyjson.Value) error { 3196 object := value.Object() 3197 defer object.Close() 3198 3199 if v.ApplicationName != nil { 3200 ok := object.Key("ApplicationName") 3201 ok.String(*v.ApplicationName) 3202 } 3203 3204 if v.CurrentApplicationVersionId != nil { 3205 ok := object.Key("CurrentApplicationVersionId") 3206 ok.Long(*v.CurrentApplicationVersionId) 3207 } 3208 3209 if v.InputId != nil { 3210 ok := object.Key("InputId") 3211 ok.String(*v.InputId) 3212 } 3213 3214 return nil 3215} 3216 3217func awsAwsjson11_serializeOpDocumentDeleteApplicationOutputInput(v *DeleteApplicationOutputInput, value smithyjson.Value) error { 3218 object := value.Object() 3219 defer object.Close() 3220 3221 if v.ApplicationName != nil { 3222 ok := object.Key("ApplicationName") 3223 ok.String(*v.ApplicationName) 3224 } 3225 3226 if v.CurrentApplicationVersionId != nil { 3227 ok := object.Key("CurrentApplicationVersionId") 3228 ok.Long(*v.CurrentApplicationVersionId) 3229 } 3230 3231 if v.OutputId != nil { 3232 ok := object.Key("OutputId") 3233 ok.String(*v.OutputId) 3234 } 3235 3236 return nil 3237} 3238 3239func awsAwsjson11_serializeOpDocumentDeleteApplicationReferenceDataSourceInput(v *DeleteApplicationReferenceDataSourceInput, value smithyjson.Value) error { 3240 object := value.Object() 3241 defer object.Close() 3242 3243 if v.ApplicationName != nil { 3244 ok := object.Key("ApplicationName") 3245 ok.String(*v.ApplicationName) 3246 } 3247 3248 if v.CurrentApplicationVersionId != nil { 3249 ok := object.Key("CurrentApplicationVersionId") 3250 ok.Long(*v.CurrentApplicationVersionId) 3251 } 3252 3253 if v.ReferenceId != nil { 3254 ok := object.Key("ReferenceId") 3255 ok.String(*v.ReferenceId) 3256 } 3257 3258 return nil 3259} 3260 3261func awsAwsjson11_serializeOpDocumentDeleteApplicationSnapshotInput(v *DeleteApplicationSnapshotInput, value smithyjson.Value) error { 3262 object := value.Object() 3263 defer object.Close() 3264 3265 if v.ApplicationName != nil { 3266 ok := object.Key("ApplicationName") 3267 ok.String(*v.ApplicationName) 3268 } 3269 3270 if v.SnapshotCreationTimestamp != nil { 3271 ok := object.Key("SnapshotCreationTimestamp") 3272 ok.Double(smithytime.FormatEpochSeconds(*v.SnapshotCreationTimestamp)) 3273 } 3274 3275 if v.SnapshotName != nil { 3276 ok := object.Key("SnapshotName") 3277 ok.String(*v.SnapshotName) 3278 } 3279 3280 return nil 3281} 3282 3283func awsAwsjson11_serializeOpDocumentDeleteApplicationVpcConfigurationInput(v *DeleteApplicationVpcConfigurationInput, value smithyjson.Value) error { 3284 object := value.Object() 3285 defer object.Close() 3286 3287 if v.ApplicationName != nil { 3288 ok := object.Key("ApplicationName") 3289 ok.String(*v.ApplicationName) 3290 } 3291 3292 if v.CurrentApplicationVersionId != nil { 3293 ok := object.Key("CurrentApplicationVersionId") 3294 ok.Long(*v.CurrentApplicationVersionId) 3295 } 3296 3297 if v.VpcConfigurationId != nil { 3298 ok := object.Key("VpcConfigurationId") 3299 ok.String(*v.VpcConfigurationId) 3300 } 3301 3302 return nil 3303} 3304 3305func awsAwsjson11_serializeOpDocumentDescribeApplicationInput(v *DescribeApplicationInput, value smithyjson.Value) error { 3306 object := value.Object() 3307 defer object.Close() 3308 3309 if v.ApplicationName != nil { 3310 ok := object.Key("ApplicationName") 3311 ok.String(*v.ApplicationName) 3312 } 3313 3314 if v.IncludeAdditionalDetails != nil { 3315 ok := object.Key("IncludeAdditionalDetails") 3316 ok.Boolean(*v.IncludeAdditionalDetails) 3317 } 3318 3319 return nil 3320} 3321 3322func awsAwsjson11_serializeOpDocumentDescribeApplicationSnapshotInput(v *DescribeApplicationSnapshotInput, value smithyjson.Value) error { 3323 object := value.Object() 3324 defer object.Close() 3325 3326 if v.ApplicationName != nil { 3327 ok := object.Key("ApplicationName") 3328 ok.String(*v.ApplicationName) 3329 } 3330 3331 if v.SnapshotName != nil { 3332 ok := object.Key("SnapshotName") 3333 ok.String(*v.SnapshotName) 3334 } 3335 3336 return nil 3337} 3338 3339func awsAwsjson11_serializeOpDocumentDiscoverInputSchemaInput(v *DiscoverInputSchemaInput, value smithyjson.Value) error { 3340 object := value.Object() 3341 defer object.Close() 3342 3343 if v.InputProcessingConfiguration != nil { 3344 ok := object.Key("InputProcessingConfiguration") 3345 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 3346 return err 3347 } 3348 } 3349 3350 if v.InputStartingPositionConfiguration != nil { 3351 ok := object.Key("InputStartingPositionConfiguration") 3352 if err := awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v.InputStartingPositionConfiguration, ok); err != nil { 3353 return err 3354 } 3355 } 3356 3357 if v.ResourceARN != nil { 3358 ok := object.Key("ResourceARN") 3359 ok.String(*v.ResourceARN) 3360 } 3361 3362 if v.S3Configuration != nil { 3363 ok := object.Key("S3Configuration") 3364 if err := awsAwsjson11_serializeDocumentS3Configuration(v.S3Configuration, ok); err != nil { 3365 return err 3366 } 3367 } 3368 3369 if v.ServiceExecutionRole != nil { 3370 ok := object.Key("ServiceExecutionRole") 3371 ok.String(*v.ServiceExecutionRole) 3372 } 3373 3374 return nil 3375} 3376 3377func awsAwsjson11_serializeOpDocumentListApplicationsInput(v *ListApplicationsInput, value smithyjson.Value) error { 3378 object := value.Object() 3379 defer object.Close() 3380 3381 if v.Limit != nil { 3382 ok := object.Key("Limit") 3383 ok.Integer(*v.Limit) 3384 } 3385 3386 if v.NextToken != nil { 3387 ok := object.Key("NextToken") 3388 ok.String(*v.NextToken) 3389 } 3390 3391 return nil 3392} 3393 3394func awsAwsjson11_serializeOpDocumentListApplicationSnapshotsInput(v *ListApplicationSnapshotsInput, value smithyjson.Value) error { 3395 object := value.Object() 3396 defer object.Close() 3397 3398 if v.ApplicationName != nil { 3399 ok := object.Key("ApplicationName") 3400 ok.String(*v.ApplicationName) 3401 } 3402 3403 if v.Limit != nil { 3404 ok := object.Key("Limit") 3405 ok.Integer(*v.Limit) 3406 } 3407 3408 if v.NextToken != nil { 3409 ok := object.Key("NextToken") 3410 ok.String(*v.NextToken) 3411 } 3412 3413 return nil 3414} 3415 3416func awsAwsjson11_serializeOpDocumentListTagsForResourceInput(v *ListTagsForResourceInput, value smithyjson.Value) error { 3417 object := value.Object() 3418 defer object.Close() 3419 3420 if v.ResourceARN != nil { 3421 ok := object.Key("ResourceARN") 3422 ok.String(*v.ResourceARN) 3423 } 3424 3425 return nil 3426} 3427 3428func awsAwsjson11_serializeOpDocumentStartApplicationInput(v *StartApplicationInput, value smithyjson.Value) error { 3429 object := value.Object() 3430 defer object.Close() 3431 3432 if v.ApplicationName != nil { 3433 ok := object.Key("ApplicationName") 3434 ok.String(*v.ApplicationName) 3435 } 3436 3437 if v.RunConfiguration != nil { 3438 ok := object.Key("RunConfiguration") 3439 if err := awsAwsjson11_serializeDocumentRunConfiguration(v.RunConfiguration, ok); err != nil { 3440 return err 3441 } 3442 } 3443 3444 return nil 3445} 3446 3447func awsAwsjson11_serializeOpDocumentStopApplicationInput(v *StopApplicationInput, value smithyjson.Value) error { 3448 object := value.Object() 3449 defer object.Close() 3450 3451 if v.ApplicationName != nil { 3452 ok := object.Key("ApplicationName") 3453 ok.String(*v.ApplicationName) 3454 } 3455 3456 if v.Force != nil { 3457 ok := object.Key("Force") 3458 ok.Boolean(*v.Force) 3459 } 3460 3461 return nil 3462} 3463 3464func awsAwsjson11_serializeOpDocumentTagResourceInput(v *TagResourceInput, value smithyjson.Value) error { 3465 object := value.Object() 3466 defer object.Close() 3467 3468 if v.ResourceARN != nil { 3469 ok := object.Key("ResourceARN") 3470 ok.String(*v.ResourceARN) 3471 } 3472 3473 if v.Tags != nil { 3474 ok := object.Key("Tags") 3475 if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil { 3476 return err 3477 } 3478 } 3479 3480 return nil 3481} 3482 3483func awsAwsjson11_serializeOpDocumentUntagResourceInput(v *UntagResourceInput, value smithyjson.Value) error { 3484 object := value.Object() 3485 defer object.Close() 3486 3487 if v.ResourceARN != nil { 3488 ok := object.Key("ResourceARN") 3489 ok.String(*v.ResourceARN) 3490 } 3491 3492 if v.TagKeys != nil { 3493 ok := object.Key("TagKeys") 3494 if err := awsAwsjson11_serializeDocumentTagKeys(v.TagKeys, ok); err != nil { 3495 return err 3496 } 3497 } 3498 3499 return nil 3500} 3501 3502func awsAwsjson11_serializeOpDocumentUpdateApplicationInput(v *UpdateApplicationInput, value smithyjson.Value) error { 3503 object := value.Object() 3504 defer object.Close() 3505 3506 if v.ApplicationConfigurationUpdate != nil { 3507 ok := object.Key("ApplicationConfigurationUpdate") 3508 if err := awsAwsjson11_serializeDocumentApplicationConfigurationUpdate(v.ApplicationConfigurationUpdate, ok); err != nil { 3509 return err 3510 } 3511 } 3512 3513 if v.ApplicationName != nil { 3514 ok := object.Key("ApplicationName") 3515 ok.String(*v.ApplicationName) 3516 } 3517 3518 if v.CloudWatchLoggingOptionUpdates != nil { 3519 ok := object.Key("CloudWatchLoggingOptionUpdates") 3520 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdates(v.CloudWatchLoggingOptionUpdates, ok); err != nil { 3521 return err 3522 } 3523 } 3524 3525 if v.CurrentApplicationVersionId != nil { 3526 ok := object.Key("CurrentApplicationVersionId") 3527 ok.Long(*v.CurrentApplicationVersionId) 3528 } 3529 3530 if v.RunConfigurationUpdate != nil { 3531 ok := object.Key("RunConfigurationUpdate") 3532 if err := awsAwsjson11_serializeDocumentRunConfigurationUpdate(v.RunConfigurationUpdate, ok); err != nil { 3533 return err 3534 } 3535 } 3536 3537 if v.ServiceExecutionRoleUpdate != nil { 3538 ok := object.Key("ServiceExecutionRoleUpdate") 3539 ok.String(*v.ServiceExecutionRoleUpdate) 3540 } 3541 3542 return nil 3543} 3544