1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package kinesisanalytics 4 5import ( 6 "bytes" 7 "context" 8 "fmt" 9 "github.com/aws/aws-sdk-go-v2/service/kinesisanalytics/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_20150814.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_20150814.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_20150814.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_20150814.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_20150814.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_serializeOpCreateApplication struct { 254} 255 256func (*awsAwsjson11_serializeOpCreateApplication) ID() string { 257 return "OperationSerializer" 258} 259 260func (m *awsAwsjson11_serializeOpCreateApplication) 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.(*CreateApplicationInput) 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_20150814.CreateApplication") 282 283 jsonEncoder := smithyjson.NewEncoder() 284 if err := awsAwsjson11_serializeOpDocumentCreateApplicationInput(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_serializeOpDeleteApplication struct { 301} 302 303func (*awsAwsjson11_serializeOpDeleteApplication) ID() string { 304 return "OperationSerializer" 305} 306 307func (m *awsAwsjson11_serializeOpDeleteApplication) 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.(*DeleteApplicationInput) 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_20150814.DeleteApplication") 329 330 jsonEncoder := smithyjson.NewEncoder() 331 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationInput(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_serializeOpDeleteApplicationCloudWatchLoggingOption struct { 348} 349 350func (*awsAwsjson11_serializeOpDeleteApplicationCloudWatchLoggingOption) ID() string { 351 return "OperationSerializer" 352} 353 354func (m *awsAwsjson11_serializeOpDeleteApplicationCloudWatchLoggingOption) 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.(*DeleteApplicationCloudWatchLoggingOptionInput) 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_20150814.DeleteApplicationCloudWatchLoggingOption") 376 377 jsonEncoder := smithyjson.NewEncoder() 378 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationCloudWatchLoggingOptionInput(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_serializeOpDeleteApplicationInputProcessingConfiguration struct { 395} 396 397func (*awsAwsjson11_serializeOpDeleteApplicationInputProcessingConfiguration) ID() string { 398 return "OperationSerializer" 399} 400 401func (m *awsAwsjson11_serializeOpDeleteApplicationInputProcessingConfiguration) 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.(*DeleteApplicationInputProcessingConfigurationInput) 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_20150814.DeleteApplicationInputProcessingConfiguration") 423 424 jsonEncoder := smithyjson.NewEncoder() 425 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationInputProcessingConfigurationInput(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_serializeOpDeleteApplicationOutput struct { 442} 443 444func (*awsAwsjson11_serializeOpDeleteApplicationOutput) ID() string { 445 return "OperationSerializer" 446} 447 448func (m *awsAwsjson11_serializeOpDeleteApplicationOutput) 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.(*DeleteApplicationOutputInput) 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_20150814.DeleteApplicationOutput") 470 471 jsonEncoder := smithyjson.NewEncoder() 472 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationOutputInput(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_serializeOpDeleteApplicationReferenceDataSource struct { 489} 490 491func (*awsAwsjson11_serializeOpDeleteApplicationReferenceDataSource) ID() string { 492 return "OperationSerializer" 493} 494 495func (m *awsAwsjson11_serializeOpDeleteApplicationReferenceDataSource) 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.(*DeleteApplicationReferenceDataSourceInput) 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_20150814.DeleteApplicationReferenceDataSource") 517 518 jsonEncoder := smithyjson.NewEncoder() 519 if err := awsAwsjson11_serializeOpDocumentDeleteApplicationReferenceDataSourceInput(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_serializeOpDescribeApplication struct { 536} 537 538func (*awsAwsjson11_serializeOpDescribeApplication) ID() string { 539 return "OperationSerializer" 540} 541 542func (m *awsAwsjson11_serializeOpDescribeApplication) 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.(*DescribeApplicationInput) 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_20150814.DescribeApplication") 564 565 jsonEncoder := smithyjson.NewEncoder() 566 if err := awsAwsjson11_serializeOpDocumentDescribeApplicationInput(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_serializeOpDiscoverInputSchema struct { 583} 584 585func (*awsAwsjson11_serializeOpDiscoverInputSchema) ID() string { 586 return "OperationSerializer" 587} 588 589func (m *awsAwsjson11_serializeOpDiscoverInputSchema) 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.(*DiscoverInputSchemaInput) 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_20150814.DiscoverInputSchema") 611 612 jsonEncoder := smithyjson.NewEncoder() 613 if err := awsAwsjson11_serializeOpDocumentDiscoverInputSchemaInput(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_serializeOpListApplications struct { 630} 631 632func (*awsAwsjson11_serializeOpListApplications) ID() string { 633 return "OperationSerializer" 634} 635 636func (m *awsAwsjson11_serializeOpListApplications) 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.(*ListApplicationsInput) 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_20150814.ListApplications") 658 659 jsonEncoder := smithyjson.NewEncoder() 660 if err := awsAwsjson11_serializeOpDocumentListApplicationsInput(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_serializeOpListTagsForResource struct { 677} 678 679func (*awsAwsjson11_serializeOpListTagsForResource) ID() string { 680 return "OperationSerializer" 681} 682 683func (m *awsAwsjson11_serializeOpListTagsForResource) 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.(*ListTagsForResourceInput) 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_20150814.ListTagsForResource") 705 706 jsonEncoder := smithyjson.NewEncoder() 707 if err := awsAwsjson11_serializeOpDocumentListTagsForResourceInput(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_serializeOpStartApplication struct { 724} 725 726func (*awsAwsjson11_serializeOpStartApplication) ID() string { 727 return "OperationSerializer" 728} 729 730func (m *awsAwsjson11_serializeOpStartApplication) 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.(*StartApplicationInput) 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_20150814.StartApplication") 752 753 jsonEncoder := smithyjson.NewEncoder() 754 if err := awsAwsjson11_serializeOpDocumentStartApplicationInput(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_serializeOpStopApplication struct { 771} 772 773func (*awsAwsjson11_serializeOpStopApplication) ID() string { 774 return "OperationSerializer" 775} 776 777func (m *awsAwsjson11_serializeOpStopApplication) 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.(*StopApplicationInput) 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_20150814.StopApplication") 799 800 jsonEncoder := smithyjson.NewEncoder() 801 if err := awsAwsjson11_serializeOpDocumentStopApplicationInput(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_serializeOpTagResource struct { 818} 819 820func (*awsAwsjson11_serializeOpTagResource) ID() string { 821 return "OperationSerializer" 822} 823 824func (m *awsAwsjson11_serializeOpTagResource) 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.(*TagResourceInput) 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_20150814.TagResource") 846 847 jsonEncoder := smithyjson.NewEncoder() 848 if err := awsAwsjson11_serializeOpDocumentTagResourceInput(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_serializeOpUntagResource struct { 865} 866 867func (*awsAwsjson11_serializeOpUntagResource) ID() string { 868 return "OperationSerializer" 869} 870 871func (m *awsAwsjson11_serializeOpUntagResource) 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.(*UntagResourceInput) 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_20150814.UntagResource") 893 894 jsonEncoder := smithyjson.NewEncoder() 895 if err := awsAwsjson11_serializeOpDocumentUntagResourceInput(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_serializeOpUpdateApplication struct { 912} 913 914func (*awsAwsjson11_serializeOpUpdateApplication) ID() string { 915 return "OperationSerializer" 916} 917 918func (m *awsAwsjson11_serializeOpUpdateApplication) 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.(*UpdateApplicationInput) 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_20150814.UpdateApplication") 940 941 jsonEncoder := smithyjson.NewEncoder() 942 if err := awsAwsjson11_serializeOpDocumentUpdateApplicationInput(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} 957func awsAwsjson11_serializeDocumentApplicationUpdate(v *types.ApplicationUpdate, value smithyjson.Value) error { 958 object := value.Object() 959 defer object.Close() 960 961 if v.ApplicationCodeUpdate != nil { 962 ok := object.Key("ApplicationCodeUpdate") 963 ok.String(*v.ApplicationCodeUpdate) 964 } 965 966 if v.CloudWatchLoggingOptionUpdates != nil { 967 ok := object.Key("CloudWatchLoggingOptionUpdates") 968 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdates(v.CloudWatchLoggingOptionUpdates, ok); err != nil { 969 return err 970 } 971 } 972 973 if v.InputUpdates != nil { 974 ok := object.Key("InputUpdates") 975 if err := awsAwsjson11_serializeDocumentInputUpdates(v.InputUpdates, ok); err != nil { 976 return err 977 } 978 } 979 980 if v.OutputUpdates != nil { 981 ok := object.Key("OutputUpdates") 982 if err := awsAwsjson11_serializeDocumentOutputUpdates(v.OutputUpdates, ok); err != nil { 983 return err 984 } 985 } 986 987 if v.ReferenceDataSourceUpdates != nil { 988 ok := object.Key("ReferenceDataSourceUpdates") 989 if err := awsAwsjson11_serializeDocumentReferenceDataSourceUpdates(v.ReferenceDataSourceUpdates, ok); err != nil { 990 return err 991 } 992 } 993 994 return nil 995} 996 997func awsAwsjson11_serializeDocumentCloudWatchLoggingOption(v *types.CloudWatchLoggingOption, value smithyjson.Value) error { 998 object := value.Object() 999 defer object.Close() 1000 1001 if v.LogStreamARN != nil { 1002 ok := object.Key("LogStreamARN") 1003 ok.String(*v.LogStreamARN) 1004 } 1005 1006 if v.RoleARN != nil { 1007 ok := object.Key("RoleARN") 1008 ok.String(*v.RoleARN) 1009 } 1010 1011 return nil 1012} 1013 1014func awsAwsjson11_serializeDocumentCloudWatchLoggingOptions(v []types.CloudWatchLoggingOption, value smithyjson.Value) error { 1015 array := value.Array() 1016 defer array.Close() 1017 1018 for i := range v { 1019 av := array.Value() 1020 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOption(&v[i], av); err != nil { 1021 return err 1022 } 1023 } 1024 return nil 1025} 1026 1027func awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdate(v *types.CloudWatchLoggingOptionUpdate, value smithyjson.Value) error { 1028 object := value.Object() 1029 defer object.Close() 1030 1031 if v.CloudWatchLoggingOptionId != nil { 1032 ok := object.Key("CloudWatchLoggingOptionId") 1033 ok.String(*v.CloudWatchLoggingOptionId) 1034 } 1035 1036 if v.LogStreamARNUpdate != nil { 1037 ok := object.Key("LogStreamARNUpdate") 1038 ok.String(*v.LogStreamARNUpdate) 1039 } 1040 1041 if v.RoleARNUpdate != nil { 1042 ok := object.Key("RoleARNUpdate") 1043 ok.String(*v.RoleARNUpdate) 1044 } 1045 1046 return nil 1047} 1048 1049func awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdates(v []types.CloudWatchLoggingOptionUpdate, value smithyjson.Value) error { 1050 array := value.Array() 1051 defer array.Close() 1052 1053 for i := range v { 1054 av := array.Value() 1055 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptionUpdate(&v[i], av); err != nil { 1056 return err 1057 } 1058 } 1059 return nil 1060} 1061 1062func awsAwsjson11_serializeDocumentCSVMappingParameters(v *types.CSVMappingParameters, value smithyjson.Value) error { 1063 object := value.Object() 1064 defer object.Close() 1065 1066 if v.RecordColumnDelimiter != nil { 1067 ok := object.Key("RecordColumnDelimiter") 1068 ok.String(*v.RecordColumnDelimiter) 1069 } 1070 1071 if v.RecordRowDelimiter != nil { 1072 ok := object.Key("RecordRowDelimiter") 1073 ok.String(*v.RecordRowDelimiter) 1074 } 1075 1076 return nil 1077} 1078 1079func awsAwsjson11_serializeDocumentDestinationSchema(v *types.DestinationSchema, value smithyjson.Value) error { 1080 object := value.Object() 1081 defer object.Close() 1082 1083 if len(v.RecordFormatType) > 0 { 1084 ok := object.Key("RecordFormatType") 1085 ok.String(string(v.RecordFormatType)) 1086 } 1087 1088 return nil 1089} 1090 1091func awsAwsjson11_serializeDocumentInput(v *types.Input, value smithyjson.Value) error { 1092 object := value.Object() 1093 defer object.Close() 1094 1095 if v.InputParallelism != nil { 1096 ok := object.Key("InputParallelism") 1097 if err := awsAwsjson11_serializeDocumentInputParallelism(v.InputParallelism, ok); err != nil { 1098 return err 1099 } 1100 } 1101 1102 if v.InputProcessingConfiguration != nil { 1103 ok := object.Key("InputProcessingConfiguration") 1104 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 1105 return err 1106 } 1107 } 1108 1109 if v.InputSchema != nil { 1110 ok := object.Key("InputSchema") 1111 if err := awsAwsjson11_serializeDocumentSourceSchema(v.InputSchema, ok); err != nil { 1112 return err 1113 } 1114 } 1115 1116 if v.KinesisFirehoseInput != nil { 1117 ok := object.Key("KinesisFirehoseInput") 1118 if err := awsAwsjson11_serializeDocumentKinesisFirehoseInput(v.KinesisFirehoseInput, ok); err != nil { 1119 return err 1120 } 1121 } 1122 1123 if v.KinesisStreamsInput != nil { 1124 ok := object.Key("KinesisStreamsInput") 1125 if err := awsAwsjson11_serializeDocumentKinesisStreamsInput(v.KinesisStreamsInput, ok); err != nil { 1126 return err 1127 } 1128 } 1129 1130 if v.NamePrefix != nil { 1131 ok := object.Key("NamePrefix") 1132 ok.String(*v.NamePrefix) 1133 } 1134 1135 return nil 1136} 1137 1138func awsAwsjson11_serializeDocumentInputConfiguration(v *types.InputConfiguration, value smithyjson.Value) error { 1139 object := value.Object() 1140 defer object.Close() 1141 1142 if v.Id != nil { 1143 ok := object.Key("Id") 1144 ok.String(*v.Id) 1145 } 1146 1147 if v.InputStartingPositionConfiguration != nil { 1148 ok := object.Key("InputStartingPositionConfiguration") 1149 if err := awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v.InputStartingPositionConfiguration, ok); err != nil { 1150 return err 1151 } 1152 } 1153 1154 return nil 1155} 1156 1157func awsAwsjson11_serializeDocumentInputConfigurations(v []types.InputConfiguration, value smithyjson.Value) error { 1158 array := value.Array() 1159 defer array.Close() 1160 1161 for i := range v { 1162 av := array.Value() 1163 if err := awsAwsjson11_serializeDocumentInputConfiguration(&v[i], av); err != nil { 1164 return err 1165 } 1166 } 1167 return nil 1168} 1169 1170func awsAwsjson11_serializeDocumentInputLambdaProcessor(v *types.InputLambdaProcessor, value smithyjson.Value) error { 1171 object := value.Object() 1172 defer object.Close() 1173 1174 if v.ResourceARN != nil { 1175 ok := object.Key("ResourceARN") 1176 ok.String(*v.ResourceARN) 1177 } 1178 1179 if v.RoleARN != nil { 1180 ok := object.Key("RoleARN") 1181 ok.String(*v.RoleARN) 1182 } 1183 1184 return nil 1185} 1186 1187func awsAwsjson11_serializeDocumentInputLambdaProcessorUpdate(v *types.InputLambdaProcessorUpdate, value smithyjson.Value) error { 1188 object := value.Object() 1189 defer object.Close() 1190 1191 if v.ResourceARNUpdate != nil { 1192 ok := object.Key("ResourceARNUpdate") 1193 ok.String(*v.ResourceARNUpdate) 1194 } 1195 1196 if v.RoleARNUpdate != nil { 1197 ok := object.Key("RoleARNUpdate") 1198 ok.String(*v.RoleARNUpdate) 1199 } 1200 1201 return nil 1202} 1203 1204func awsAwsjson11_serializeDocumentInputParallelism(v *types.InputParallelism, value smithyjson.Value) error { 1205 object := value.Object() 1206 defer object.Close() 1207 1208 if v.Count != nil { 1209 ok := object.Key("Count") 1210 ok.Integer(*v.Count) 1211 } 1212 1213 return nil 1214} 1215 1216func awsAwsjson11_serializeDocumentInputParallelismUpdate(v *types.InputParallelismUpdate, value smithyjson.Value) error { 1217 object := value.Object() 1218 defer object.Close() 1219 1220 if v.CountUpdate != nil { 1221 ok := object.Key("CountUpdate") 1222 ok.Integer(*v.CountUpdate) 1223 } 1224 1225 return nil 1226} 1227 1228func awsAwsjson11_serializeDocumentInputProcessingConfiguration(v *types.InputProcessingConfiguration, value smithyjson.Value) error { 1229 object := value.Object() 1230 defer object.Close() 1231 1232 if v.InputLambdaProcessor != nil { 1233 ok := object.Key("InputLambdaProcessor") 1234 if err := awsAwsjson11_serializeDocumentInputLambdaProcessor(v.InputLambdaProcessor, ok); err != nil { 1235 return err 1236 } 1237 } 1238 1239 return nil 1240} 1241 1242func awsAwsjson11_serializeDocumentInputProcessingConfigurationUpdate(v *types.InputProcessingConfigurationUpdate, value smithyjson.Value) error { 1243 object := value.Object() 1244 defer object.Close() 1245 1246 if v.InputLambdaProcessorUpdate != nil { 1247 ok := object.Key("InputLambdaProcessorUpdate") 1248 if err := awsAwsjson11_serializeDocumentInputLambdaProcessorUpdate(v.InputLambdaProcessorUpdate, ok); err != nil { 1249 return err 1250 } 1251 } 1252 1253 return nil 1254} 1255 1256func awsAwsjson11_serializeDocumentInputs(v []types.Input, value smithyjson.Value) error { 1257 array := value.Array() 1258 defer array.Close() 1259 1260 for i := range v { 1261 av := array.Value() 1262 if err := awsAwsjson11_serializeDocumentInput(&v[i], av); err != nil { 1263 return err 1264 } 1265 } 1266 return nil 1267} 1268 1269func awsAwsjson11_serializeDocumentInputSchemaUpdate(v *types.InputSchemaUpdate, value smithyjson.Value) error { 1270 object := value.Object() 1271 defer object.Close() 1272 1273 if v.RecordColumnUpdates != nil { 1274 ok := object.Key("RecordColumnUpdates") 1275 if err := awsAwsjson11_serializeDocumentRecordColumns(v.RecordColumnUpdates, ok); err != nil { 1276 return err 1277 } 1278 } 1279 1280 if v.RecordEncodingUpdate != nil { 1281 ok := object.Key("RecordEncodingUpdate") 1282 ok.String(*v.RecordEncodingUpdate) 1283 } 1284 1285 if v.RecordFormatUpdate != nil { 1286 ok := object.Key("RecordFormatUpdate") 1287 if err := awsAwsjson11_serializeDocumentRecordFormat(v.RecordFormatUpdate, ok); err != nil { 1288 return err 1289 } 1290 } 1291 1292 return nil 1293} 1294 1295func awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v *types.InputStartingPositionConfiguration, value smithyjson.Value) error { 1296 object := value.Object() 1297 defer object.Close() 1298 1299 if len(v.InputStartingPosition) > 0 { 1300 ok := object.Key("InputStartingPosition") 1301 ok.String(string(v.InputStartingPosition)) 1302 } 1303 1304 return nil 1305} 1306 1307func awsAwsjson11_serializeDocumentInputUpdate(v *types.InputUpdate, value smithyjson.Value) error { 1308 object := value.Object() 1309 defer object.Close() 1310 1311 if v.InputId != nil { 1312 ok := object.Key("InputId") 1313 ok.String(*v.InputId) 1314 } 1315 1316 if v.InputParallelismUpdate != nil { 1317 ok := object.Key("InputParallelismUpdate") 1318 if err := awsAwsjson11_serializeDocumentInputParallelismUpdate(v.InputParallelismUpdate, ok); err != nil { 1319 return err 1320 } 1321 } 1322 1323 if v.InputProcessingConfigurationUpdate != nil { 1324 ok := object.Key("InputProcessingConfigurationUpdate") 1325 if err := awsAwsjson11_serializeDocumentInputProcessingConfigurationUpdate(v.InputProcessingConfigurationUpdate, ok); err != nil { 1326 return err 1327 } 1328 } 1329 1330 if v.InputSchemaUpdate != nil { 1331 ok := object.Key("InputSchemaUpdate") 1332 if err := awsAwsjson11_serializeDocumentInputSchemaUpdate(v.InputSchemaUpdate, ok); err != nil { 1333 return err 1334 } 1335 } 1336 1337 if v.KinesisFirehoseInputUpdate != nil { 1338 ok := object.Key("KinesisFirehoseInputUpdate") 1339 if err := awsAwsjson11_serializeDocumentKinesisFirehoseInputUpdate(v.KinesisFirehoseInputUpdate, ok); err != nil { 1340 return err 1341 } 1342 } 1343 1344 if v.KinesisStreamsInputUpdate != nil { 1345 ok := object.Key("KinesisStreamsInputUpdate") 1346 if err := awsAwsjson11_serializeDocumentKinesisStreamsInputUpdate(v.KinesisStreamsInputUpdate, ok); err != nil { 1347 return err 1348 } 1349 } 1350 1351 if v.NamePrefixUpdate != nil { 1352 ok := object.Key("NamePrefixUpdate") 1353 ok.String(*v.NamePrefixUpdate) 1354 } 1355 1356 return nil 1357} 1358 1359func awsAwsjson11_serializeDocumentInputUpdates(v []types.InputUpdate, value smithyjson.Value) error { 1360 array := value.Array() 1361 defer array.Close() 1362 1363 for i := range v { 1364 av := array.Value() 1365 if err := awsAwsjson11_serializeDocumentInputUpdate(&v[i], av); err != nil { 1366 return err 1367 } 1368 } 1369 return nil 1370} 1371 1372func awsAwsjson11_serializeDocumentJSONMappingParameters(v *types.JSONMappingParameters, value smithyjson.Value) error { 1373 object := value.Object() 1374 defer object.Close() 1375 1376 if v.RecordRowPath != nil { 1377 ok := object.Key("RecordRowPath") 1378 ok.String(*v.RecordRowPath) 1379 } 1380 1381 return nil 1382} 1383 1384func awsAwsjson11_serializeDocumentKinesisFirehoseInput(v *types.KinesisFirehoseInput, value smithyjson.Value) error { 1385 object := value.Object() 1386 defer object.Close() 1387 1388 if v.ResourceARN != nil { 1389 ok := object.Key("ResourceARN") 1390 ok.String(*v.ResourceARN) 1391 } 1392 1393 if v.RoleARN != nil { 1394 ok := object.Key("RoleARN") 1395 ok.String(*v.RoleARN) 1396 } 1397 1398 return nil 1399} 1400 1401func awsAwsjson11_serializeDocumentKinesisFirehoseInputUpdate(v *types.KinesisFirehoseInputUpdate, value smithyjson.Value) error { 1402 object := value.Object() 1403 defer object.Close() 1404 1405 if v.ResourceARNUpdate != nil { 1406 ok := object.Key("ResourceARNUpdate") 1407 ok.String(*v.ResourceARNUpdate) 1408 } 1409 1410 if v.RoleARNUpdate != nil { 1411 ok := object.Key("RoleARNUpdate") 1412 ok.String(*v.RoleARNUpdate) 1413 } 1414 1415 return nil 1416} 1417 1418func awsAwsjson11_serializeDocumentKinesisFirehoseOutput(v *types.KinesisFirehoseOutput, value smithyjson.Value) error { 1419 object := value.Object() 1420 defer object.Close() 1421 1422 if v.ResourceARN != nil { 1423 ok := object.Key("ResourceARN") 1424 ok.String(*v.ResourceARN) 1425 } 1426 1427 if v.RoleARN != nil { 1428 ok := object.Key("RoleARN") 1429 ok.String(*v.RoleARN) 1430 } 1431 1432 return nil 1433} 1434 1435func awsAwsjson11_serializeDocumentKinesisFirehoseOutputUpdate(v *types.KinesisFirehoseOutputUpdate, value smithyjson.Value) error { 1436 object := value.Object() 1437 defer object.Close() 1438 1439 if v.ResourceARNUpdate != nil { 1440 ok := object.Key("ResourceARNUpdate") 1441 ok.String(*v.ResourceARNUpdate) 1442 } 1443 1444 if v.RoleARNUpdate != nil { 1445 ok := object.Key("RoleARNUpdate") 1446 ok.String(*v.RoleARNUpdate) 1447 } 1448 1449 return nil 1450} 1451 1452func awsAwsjson11_serializeDocumentKinesisStreamsInput(v *types.KinesisStreamsInput, value smithyjson.Value) error { 1453 object := value.Object() 1454 defer object.Close() 1455 1456 if v.ResourceARN != nil { 1457 ok := object.Key("ResourceARN") 1458 ok.String(*v.ResourceARN) 1459 } 1460 1461 if v.RoleARN != nil { 1462 ok := object.Key("RoleARN") 1463 ok.String(*v.RoleARN) 1464 } 1465 1466 return nil 1467} 1468 1469func awsAwsjson11_serializeDocumentKinesisStreamsInputUpdate(v *types.KinesisStreamsInputUpdate, value smithyjson.Value) error { 1470 object := value.Object() 1471 defer object.Close() 1472 1473 if v.ResourceARNUpdate != nil { 1474 ok := object.Key("ResourceARNUpdate") 1475 ok.String(*v.ResourceARNUpdate) 1476 } 1477 1478 if v.RoleARNUpdate != nil { 1479 ok := object.Key("RoleARNUpdate") 1480 ok.String(*v.RoleARNUpdate) 1481 } 1482 1483 return nil 1484} 1485 1486func awsAwsjson11_serializeDocumentKinesisStreamsOutput(v *types.KinesisStreamsOutput, value smithyjson.Value) error { 1487 object := value.Object() 1488 defer object.Close() 1489 1490 if v.ResourceARN != nil { 1491 ok := object.Key("ResourceARN") 1492 ok.String(*v.ResourceARN) 1493 } 1494 1495 if v.RoleARN != nil { 1496 ok := object.Key("RoleARN") 1497 ok.String(*v.RoleARN) 1498 } 1499 1500 return nil 1501} 1502 1503func awsAwsjson11_serializeDocumentKinesisStreamsOutputUpdate(v *types.KinesisStreamsOutputUpdate, value smithyjson.Value) error { 1504 object := value.Object() 1505 defer object.Close() 1506 1507 if v.ResourceARNUpdate != nil { 1508 ok := object.Key("ResourceARNUpdate") 1509 ok.String(*v.ResourceARNUpdate) 1510 } 1511 1512 if v.RoleARNUpdate != nil { 1513 ok := object.Key("RoleARNUpdate") 1514 ok.String(*v.RoleARNUpdate) 1515 } 1516 1517 return nil 1518} 1519 1520func awsAwsjson11_serializeDocumentLambdaOutput(v *types.LambdaOutput, value smithyjson.Value) error { 1521 object := value.Object() 1522 defer object.Close() 1523 1524 if v.ResourceARN != nil { 1525 ok := object.Key("ResourceARN") 1526 ok.String(*v.ResourceARN) 1527 } 1528 1529 if v.RoleARN != nil { 1530 ok := object.Key("RoleARN") 1531 ok.String(*v.RoleARN) 1532 } 1533 1534 return nil 1535} 1536 1537func awsAwsjson11_serializeDocumentLambdaOutputUpdate(v *types.LambdaOutputUpdate, value smithyjson.Value) error { 1538 object := value.Object() 1539 defer object.Close() 1540 1541 if v.ResourceARNUpdate != nil { 1542 ok := object.Key("ResourceARNUpdate") 1543 ok.String(*v.ResourceARNUpdate) 1544 } 1545 1546 if v.RoleARNUpdate != nil { 1547 ok := object.Key("RoleARNUpdate") 1548 ok.String(*v.RoleARNUpdate) 1549 } 1550 1551 return nil 1552} 1553 1554func awsAwsjson11_serializeDocumentMappingParameters(v *types.MappingParameters, value smithyjson.Value) error { 1555 object := value.Object() 1556 defer object.Close() 1557 1558 if v.CSVMappingParameters != nil { 1559 ok := object.Key("CSVMappingParameters") 1560 if err := awsAwsjson11_serializeDocumentCSVMappingParameters(v.CSVMappingParameters, ok); err != nil { 1561 return err 1562 } 1563 } 1564 1565 if v.JSONMappingParameters != nil { 1566 ok := object.Key("JSONMappingParameters") 1567 if err := awsAwsjson11_serializeDocumentJSONMappingParameters(v.JSONMappingParameters, ok); err != nil { 1568 return err 1569 } 1570 } 1571 1572 return nil 1573} 1574 1575func awsAwsjson11_serializeDocumentOutput(v *types.Output, value smithyjson.Value) error { 1576 object := value.Object() 1577 defer object.Close() 1578 1579 if v.DestinationSchema != nil { 1580 ok := object.Key("DestinationSchema") 1581 if err := awsAwsjson11_serializeDocumentDestinationSchema(v.DestinationSchema, ok); err != nil { 1582 return err 1583 } 1584 } 1585 1586 if v.KinesisFirehoseOutput != nil { 1587 ok := object.Key("KinesisFirehoseOutput") 1588 if err := awsAwsjson11_serializeDocumentKinesisFirehoseOutput(v.KinesisFirehoseOutput, ok); err != nil { 1589 return err 1590 } 1591 } 1592 1593 if v.KinesisStreamsOutput != nil { 1594 ok := object.Key("KinesisStreamsOutput") 1595 if err := awsAwsjson11_serializeDocumentKinesisStreamsOutput(v.KinesisStreamsOutput, ok); err != nil { 1596 return err 1597 } 1598 } 1599 1600 if v.LambdaOutput != nil { 1601 ok := object.Key("LambdaOutput") 1602 if err := awsAwsjson11_serializeDocumentLambdaOutput(v.LambdaOutput, ok); err != nil { 1603 return err 1604 } 1605 } 1606 1607 if v.Name != nil { 1608 ok := object.Key("Name") 1609 ok.String(*v.Name) 1610 } 1611 1612 return nil 1613} 1614 1615func awsAwsjson11_serializeDocumentOutputs(v []types.Output, value smithyjson.Value) error { 1616 array := value.Array() 1617 defer array.Close() 1618 1619 for i := range v { 1620 av := array.Value() 1621 if err := awsAwsjson11_serializeDocumentOutput(&v[i], av); err != nil { 1622 return err 1623 } 1624 } 1625 return nil 1626} 1627 1628func awsAwsjson11_serializeDocumentOutputUpdate(v *types.OutputUpdate, value smithyjson.Value) error { 1629 object := value.Object() 1630 defer object.Close() 1631 1632 if v.DestinationSchemaUpdate != nil { 1633 ok := object.Key("DestinationSchemaUpdate") 1634 if err := awsAwsjson11_serializeDocumentDestinationSchema(v.DestinationSchemaUpdate, ok); err != nil { 1635 return err 1636 } 1637 } 1638 1639 if v.KinesisFirehoseOutputUpdate != nil { 1640 ok := object.Key("KinesisFirehoseOutputUpdate") 1641 if err := awsAwsjson11_serializeDocumentKinesisFirehoseOutputUpdate(v.KinesisFirehoseOutputUpdate, ok); err != nil { 1642 return err 1643 } 1644 } 1645 1646 if v.KinesisStreamsOutputUpdate != nil { 1647 ok := object.Key("KinesisStreamsOutputUpdate") 1648 if err := awsAwsjson11_serializeDocumentKinesisStreamsOutputUpdate(v.KinesisStreamsOutputUpdate, ok); err != nil { 1649 return err 1650 } 1651 } 1652 1653 if v.LambdaOutputUpdate != nil { 1654 ok := object.Key("LambdaOutputUpdate") 1655 if err := awsAwsjson11_serializeDocumentLambdaOutputUpdate(v.LambdaOutputUpdate, ok); err != nil { 1656 return err 1657 } 1658 } 1659 1660 if v.NameUpdate != nil { 1661 ok := object.Key("NameUpdate") 1662 ok.String(*v.NameUpdate) 1663 } 1664 1665 if v.OutputId != nil { 1666 ok := object.Key("OutputId") 1667 ok.String(*v.OutputId) 1668 } 1669 1670 return nil 1671} 1672 1673func awsAwsjson11_serializeDocumentOutputUpdates(v []types.OutputUpdate, value smithyjson.Value) error { 1674 array := value.Array() 1675 defer array.Close() 1676 1677 for i := range v { 1678 av := array.Value() 1679 if err := awsAwsjson11_serializeDocumentOutputUpdate(&v[i], av); err != nil { 1680 return err 1681 } 1682 } 1683 return nil 1684} 1685 1686func awsAwsjson11_serializeDocumentRecordColumn(v *types.RecordColumn, value smithyjson.Value) error { 1687 object := value.Object() 1688 defer object.Close() 1689 1690 if v.Mapping != nil { 1691 ok := object.Key("Mapping") 1692 ok.String(*v.Mapping) 1693 } 1694 1695 if v.Name != nil { 1696 ok := object.Key("Name") 1697 ok.String(*v.Name) 1698 } 1699 1700 if v.SqlType != nil { 1701 ok := object.Key("SqlType") 1702 ok.String(*v.SqlType) 1703 } 1704 1705 return nil 1706} 1707 1708func awsAwsjson11_serializeDocumentRecordColumns(v []types.RecordColumn, value smithyjson.Value) error { 1709 array := value.Array() 1710 defer array.Close() 1711 1712 for i := range v { 1713 av := array.Value() 1714 if err := awsAwsjson11_serializeDocumentRecordColumn(&v[i], av); err != nil { 1715 return err 1716 } 1717 } 1718 return nil 1719} 1720 1721func awsAwsjson11_serializeDocumentRecordFormat(v *types.RecordFormat, value smithyjson.Value) error { 1722 object := value.Object() 1723 defer object.Close() 1724 1725 if v.MappingParameters != nil { 1726 ok := object.Key("MappingParameters") 1727 if err := awsAwsjson11_serializeDocumentMappingParameters(v.MappingParameters, ok); err != nil { 1728 return err 1729 } 1730 } 1731 1732 if len(v.RecordFormatType) > 0 { 1733 ok := object.Key("RecordFormatType") 1734 ok.String(string(v.RecordFormatType)) 1735 } 1736 1737 return nil 1738} 1739 1740func awsAwsjson11_serializeDocumentReferenceDataSource(v *types.ReferenceDataSource, value smithyjson.Value) error { 1741 object := value.Object() 1742 defer object.Close() 1743 1744 if v.ReferenceSchema != nil { 1745 ok := object.Key("ReferenceSchema") 1746 if err := awsAwsjson11_serializeDocumentSourceSchema(v.ReferenceSchema, ok); err != nil { 1747 return err 1748 } 1749 } 1750 1751 if v.S3ReferenceDataSource != nil { 1752 ok := object.Key("S3ReferenceDataSource") 1753 if err := awsAwsjson11_serializeDocumentS3ReferenceDataSource(v.S3ReferenceDataSource, ok); err != nil { 1754 return err 1755 } 1756 } 1757 1758 if v.TableName != nil { 1759 ok := object.Key("TableName") 1760 ok.String(*v.TableName) 1761 } 1762 1763 return nil 1764} 1765 1766func awsAwsjson11_serializeDocumentReferenceDataSourceUpdate(v *types.ReferenceDataSourceUpdate, value smithyjson.Value) error { 1767 object := value.Object() 1768 defer object.Close() 1769 1770 if v.ReferenceId != nil { 1771 ok := object.Key("ReferenceId") 1772 ok.String(*v.ReferenceId) 1773 } 1774 1775 if v.ReferenceSchemaUpdate != nil { 1776 ok := object.Key("ReferenceSchemaUpdate") 1777 if err := awsAwsjson11_serializeDocumentSourceSchema(v.ReferenceSchemaUpdate, ok); err != nil { 1778 return err 1779 } 1780 } 1781 1782 if v.S3ReferenceDataSourceUpdate != nil { 1783 ok := object.Key("S3ReferenceDataSourceUpdate") 1784 if err := awsAwsjson11_serializeDocumentS3ReferenceDataSourceUpdate(v.S3ReferenceDataSourceUpdate, ok); err != nil { 1785 return err 1786 } 1787 } 1788 1789 if v.TableNameUpdate != nil { 1790 ok := object.Key("TableNameUpdate") 1791 ok.String(*v.TableNameUpdate) 1792 } 1793 1794 return nil 1795} 1796 1797func awsAwsjson11_serializeDocumentReferenceDataSourceUpdates(v []types.ReferenceDataSourceUpdate, value smithyjson.Value) error { 1798 array := value.Array() 1799 defer array.Close() 1800 1801 for i := range v { 1802 av := array.Value() 1803 if err := awsAwsjson11_serializeDocumentReferenceDataSourceUpdate(&v[i], av); err != nil { 1804 return err 1805 } 1806 } 1807 return nil 1808} 1809 1810func awsAwsjson11_serializeDocumentS3Configuration(v *types.S3Configuration, value smithyjson.Value) error { 1811 object := value.Object() 1812 defer object.Close() 1813 1814 if v.BucketARN != nil { 1815 ok := object.Key("BucketARN") 1816 ok.String(*v.BucketARN) 1817 } 1818 1819 if v.FileKey != nil { 1820 ok := object.Key("FileKey") 1821 ok.String(*v.FileKey) 1822 } 1823 1824 if v.RoleARN != nil { 1825 ok := object.Key("RoleARN") 1826 ok.String(*v.RoleARN) 1827 } 1828 1829 return nil 1830} 1831 1832func awsAwsjson11_serializeDocumentS3ReferenceDataSource(v *types.S3ReferenceDataSource, value smithyjson.Value) error { 1833 object := value.Object() 1834 defer object.Close() 1835 1836 if v.BucketARN != nil { 1837 ok := object.Key("BucketARN") 1838 ok.String(*v.BucketARN) 1839 } 1840 1841 if v.FileKey != nil { 1842 ok := object.Key("FileKey") 1843 ok.String(*v.FileKey) 1844 } 1845 1846 if v.ReferenceRoleARN != nil { 1847 ok := object.Key("ReferenceRoleARN") 1848 ok.String(*v.ReferenceRoleARN) 1849 } 1850 1851 return nil 1852} 1853 1854func awsAwsjson11_serializeDocumentS3ReferenceDataSourceUpdate(v *types.S3ReferenceDataSourceUpdate, value smithyjson.Value) error { 1855 object := value.Object() 1856 defer object.Close() 1857 1858 if v.BucketARNUpdate != nil { 1859 ok := object.Key("BucketARNUpdate") 1860 ok.String(*v.BucketARNUpdate) 1861 } 1862 1863 if v.FileKeyUpdate != nil { 1864 ok := object.Key("FileKeyUpdate") 1865 ok.String(*v.FileKeyUpdate) 1866 } 1867 1868 if v.ReferenceRoleARNUpdate != nil { 1869 ok := object.Key("ReferenceRoleARNUpdate") 1870 ok.String(*v.ReferenceRoleARNUpdate) 1871 } 1872 1873 return nil 1874} 1875 1876func awsAwsjson11_serializeDocumentSourceSchema(v *types.SourceSchema, value smithyjson.Value) error { 1877 object := value.Object() 1878 defer object.Close() 1879 1880 if v.RecordColumns != nil { 1881 ok := object.Key("RecordColumns") 1882 if err := awsAwsjson11_serializeDocumentRecordColumns(v.RecordColumns, ok); err != nil { 1883 return err 1884 } 1885 } 1886 1887 if v.RecordEncoding != nil { 1888 ok := object.Key("RecordEncoding") 1889 ok.String(*v.RecordEncoding) 1890 } 1891 1892 if v.RecordFormat != nil { 1893 ok := object.Key("RecordFormat") 1894 if err := awsAwsjson11_serializeDocumentRecordFormat(v.RecordFormat, ok); err != nil { 1895 return err 1896 } 1897 } 1898 1899 return nil 1900} 1901 1902func awsAwsjson11_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { 1903 object := value.Object() 1904 defer object.Close() 1905 1906 if v.Key != nil { 1907 ok := object.Key("Key") 1908 ok.String(*v.Key) 1909 } 1910 1911 if v.Value != nil { 1912 ok := object.Key("Value") 1913 ok.String(*v.Value) 1914 } 1915 1916 return nil 1917} 1918 1919func awsAwsjson11_serializeDocumentTagKeys(v []string, value smithyjson.Value) error { 1920 array := value.Array() 1921 defer array.Close() 1922 1923 for i := range v { 1924 av := array.Value() 1925 av.String(v[i]) 1926 } 1927 return nil 1928} 1929 1930func awsAwsjson11_serializeDocumentTags(v []types.Tag, value smithyjson.Value) error { 1931 array := value.Array() 1932 defer array.Close() 1933 1934 for i := range v { 1935 av := array.Value() 1936 if err := awsAwsjson11_serializeDocumentTag(&v[i], av); err != nil { 1937 return err 1938 } 1939 } 1940 return nil 1941} 1942 1943func awsAwsjson11_serializeOpDocumentAddApplicationCloudWatchLoggingOptionInput(v *AddApplicationCloudWatchLoggingOptionInput, value smithyjson.Value) error { 1944 object := value.Object() 1945 defer object.Close() 1946 1947 if v.ApplicationName != nil { 1948 ok := object.Key("ApplicationName") 1949 ok.String(*v.ApplicationName) 1950 } 1951 1952 if v.CloudWatchLoggingOption != nil { 1953 ok := object.Key("CloudWatchLoggingOption") 1954 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOption(v.CloudWatchLoggingOption, ok); err != nil { 1955 return err 1956 } 1957 } 1958 1959 if v.CurrentApplicationVersionId != nil { 1960 ok := object.Key("CurrentApplicationVersionId") 1961 ok.Long(*v.CurrentApplicationVersionId) 1962 } 1963 1964 return nil 1965} 1966 1967func awsAwsjson11_serializeOpDocumentAddApplicationInputInput(v *AddApplicationInputInput, value smithyjson.Value) error { 1968 object := value.Object() 1969 defer object.Close() 1970 1971 if v.ApplicationName != nil { 1972 ok := object.Key("ApplicationName") 1973 ok.String(*v.ApplicationName) 1974 } 1975 1976 if v.CurrentApplicationVersionId != nil { 1977 ok := object.Key("CurrentApplicationVersionId") 1978 ok.Long(*v.CurrentApplicationVersionId) 1979 } 1980 1981 if v.Input != nil { 1982 ok := object.Key("Input") 1983 if err := awsAwsjson11_serializeDocumentInput(v.Input, ok); err != nil { 1984 return err 1985 } 1986 } 1987 1988 return nil 1989} 1990 1991func awsAwsjson11_serializeOpDocumentAddApplicationInputProcessingConfigurationInput(v *AddApplicationInputProcessingConfigurationInput, value smithyjson.Value) error { 1992 object := value.Object() 1993 defer object.Close() 1994 1995 if v.ApplicationName != nil { 1996 ok := object.Key("ApplicationName") 1997 ok.String(*v.ApplicationName) 1998 } 1999 2000 if v.CurrentApplicationVersionId != nil { 2001 ok := object.Key("CurrentApplicationVersionId") 2002 ok.Long(*v.CurrentApplicationVersionId) 2003 } 2004 2005 if v.InputId != nil { 2006 ok := object.Key("InputId") 2007 ok.String(*v.InputId) 2008 } 2009 2010 if v.InputProcessingConfiguration != nil { 2011 ok := object.Key("InputProcessingConfiguration") 2012 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 2013 return err 2014 } 2015 } 2016 2017 return nil 2018} 2019 2020func awsAwsjson11_serializeOpDocumentAddApplicationOutputInput(v *AddApplicationOutputInput, value smithyjson.Value) error { 2021 object := value.Object() 2022 defer object.Close() 2023 2024 if v.ApplicationName != nil { 2025 ok := object.Key("ApplicationName") 2026 ok.String(*v.ApplicationName) 2027 } 2028 2029 if v.CurrentApplicationVersionId != nil { 2030 ok := object.Key("CurrentApplicationVersionId") 2031 ok.Long(*v.CurrentApplicationVersionId) 2032 } 2033 2034 if v.Output != nil { 2035 ok := object.Key("Output") 2036 if err := awsAwsjson11_serializeDocumentOutput(v.Output, ok); err != nil { 2037 return err 2038 } 2039 } 2040 2041 return nil 2042} 2043 2044func awsAwsjson11_serializeOpDocumentAddApplicationReferenceDataSourceInput(v *AddApplicationReferenceDataSourceInput, value smithyjson.Value) error { 2045 object := value.Object() 2046 defer object.Close() 2047 2048 if v.ApplicationName != nil { 2049 ok := object.Key("ApplicationName") 2050 ok.String(*v.ApplicationName) 2051 } 2052 2053 if v.CurrentApplicationVersionId != nil { 2054 ok := object.Key("CurrentApplicationVersionId") 2055 ok.Long(*v.CurrentApplicationVersionId) 2056 } 2057 2058 if v.ReferenceDataSource != nil { 2059 ok := object.Key("ReferenceDataSource") 2060 if err := awsAwsjson11_serializeDocumentReferenceDataSource(v.ReferenceDataSource, ok); err != nil { 2061 return err 2062 } 2063 } 2064 2065 return nil 2066} 2067 2068func awsAwsjson11_serializeOpDocumentCreateApplicationInput(v *CreateApplicationInput, value smithyjson.Value) error { 2069 object := value.Object() 2070 defer object.Close() 2071 2072 if v.ApplicationCode != nil { 2073 ok := object.Key("ApplicationCode") 2074 ok.String(*v.ApplicationCode) 2075 } 2076 2077 if v.ApplicationDescription != nil { 2078 ok := object.Key("ApplicationDescription") 2079 ok.String(*v.ApplicationDescription) 2080 } 2081 2082 if v.ApplicationName != nil { 2083 ok := object.Key("ApplicationName") 2084 ok.String(*v.ApplicationName) 2085 } 2086 2087 if v.CloudWatchLoggingOptions != nil { 2088 ok := object.Key("CloudWatchLoggingOptions") 2089 if err := awsAwsjson11_serializeDocumentCloudWatchLoggingOptions(v.CloudWatchLoggingOptions, ok); err != nil { 2090 return err 2091 } 2092 } 2093 2094 if v.Inputs != nil { 2095 ok := object.Key("Inputs") 2096 if err := awsAwsjson11_serializeDocumentInputs(v.Inputs, ok); err != nil { 2097 return err 2098 } 2099 } 2100 2101 if v.Outputs != nil { 2102 ok := object.Key("Outputs") 2103 if err := awsAwsjson11_serializeDocumentOutputs(v.Outputs, ok); err != nil { 2104 return err 2105 } 2106 } 2107 2108 if v.Tags != nil { 2109 ok := object.Key("Tags") 2110 if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil { 2111 return err 2112 } 2113 } 2114 2115 return nil 2116} 2117 2118func awsAwsjson11_serializeOpDocumentDeleteApplicationCloudWatchLoggingOptionInput(v *DeleteApplicationCloudWatchLoggingOptionInput, value smithyjson.Value) error { 2119 object := value.Object() 2120 defer object.Close() 2121 2122 if v.ApplicationName != nil { 2123 ok := object.Key("ApplicationName") 2124 ok.String(*v.ApplicationName) 2125 } 2126 2127 if v.CloudWatchLoggingOptionId != nil { 2128 ok := object.Key("CloudWatchLoggingOptionId") 2129 ok.String(*v.CloudWatchLoggingOptionId) 2130 } 2131 2132 if v.CurrentApplicationVersionId != nil { 2133 ok := object.Key("CurrentApplicationVersionId") 2134 ok.Long(*v.CurrentApplicationVersionId) 2135 } 2136 2137 return nil 2138} 2139 2140func awsAwsjson11_serializeOpDocumentDeleteApplicationInput(v *DeleteApplicationInput, value smithyjson.Value) error { 2141 object := value.Object() 2142 defer object.Close() 2143 2144 if v.ApplicationName != nil { 2145 ok := object.Key("ApplicationName") 2146 ok.String(*v.ApplicationName) 2147 } 2148 2149 if v.CreateTimestamp != nil { 2150 ok := object.Key("CreateTimestamp") 2151 ok.Double(smithytime.FormatEpochSeconds(*v.CreateTimestamp)) 2152 } 2153 2154 return nil 2155} 2156 2157func awsAwsjson11_serializeOpDocumentDeleteApplicationInputProcessingConfigurationInput(v *DeleteApplicationInputProcessingConfigurationInput, value smithyjson.Value) error { 2158 object := value.Object() 2159 defer object.Close() 2160 2161 if v.ApplicationName != nil { 2162 ok := object.Key("ApplicationName") 2163 ok.String(*v.ApplicationName) 2164 } 2165 2166 if v.CurrentApplicationVersionId != nil { 2167 ok := object.Key("CurrentApplicationVersionId") 2168 ok.Long(*v.CurrentApplicationVersionId) 2169 } 2170 2171 if v.InputId != nil { 2172 ok := object.Key("InputId") 2173 ok.String(*v.InputId) 2174 } 2175 2176 return nil 2177} 2178 2179func awsAwsjson11_serializeOpDocumentDeleteApplicationOutputInput(v *DeleteApplicationOutputInput, value smithyjson.Value) error { 2180 object := value.Object() 2181 defer object.Close() 2182 2183 if v.ApplicationName != nil { 2184 ok := object.Key("ApplicationName") 2185 ok.String(*v.ApplicationName) 2186 } 2187 2188 if v.CurrentApplicationVersionId != nil { 2189 ok := object.Key("CurrentApplicationVersionId") 2190 ok.Long(*v.CurrentApplicationVersionId) 2191 } 2192 2193 if v.OutputId != nil { 2194 ok := object.Key("OutputId") 2195 ok.String(*v.OutputId) 2196 } 2197 2198 return nil 2199} 2200 2201func awsAwsjson11_serializeOpDocumentDeleteApplicationReferenceDataSourceInput(v *DeleteApplicationReferenceDataSourceInput, value smithyjson.Value) error { 2202 object := value.Object() 2203 defer object.Close() 2204 2205 if v.ApplicationName != nil { 2206 ok := object.Key("ApplicationName") 2207 ok.String(*v.ApplicationName) 2208 } 2209 2210 if v.CurrentApplicationVersionId != nil { 2211 ok := object.Key("CurrentApplicationVersionId") 2212 ok.Long(*v.CurrentApplicationVersionId) 2213 } 2214 2215 if v.ReferenceId != nil { 2216 ok := object.Key("ReferenceId") 2217 ok.String(*v.ReferenceId) 2218 } 2219 2220 return nil 2221} 2222 2223func awsAwsjson11_serializeOpDocumentDescribeApplicationInput(v *DescribeApplicationInput, value smithyjson.Value) error { 2224 object := value.Object() 2225 defer object.Close() 2226 2227 if v.ApplicationName != nil { 2228 ok := object.Key("ApplicationName") 2229 ok.String(*v.ApplicationName) 2230 } 2231 2232 return nil 2233} 2234 2235func awsAwsjson11_serializeOpDocumentDiscoverInputSchemaInput(v *DiscoverInputSchemaInput, value smithyjson.Value) error { 2236 object := value.Object() 2237 defer object.Close() 2238 2239 if v.InputProcessingConfiguration != nil { 2240 ok := object.Key("InputProcessingConfiguration") 2241 if err := awsAwsjson11_serializeDocumentInputProcessingConfiguration(v.InputProcessingConfiguration, ok); err != nil { 2242 return err 2243 } 2244 } 2245 2246 if v.InputStartingPositionConfiguration != nil { 2247 ok := object.Key("InputStartingPositionConfiguration") 2248 if err := awsAwsjson11_serializeDocumentInputStartingPositionConfiguration(v.InputStartingPositionConfiguration, ok); err != nil { 2249 return err 2250 } 2251 } 2252 2253 if v.ResourceARN != nil { 2254 ok := object.Key("ResourceARN") 2255 ok.String(*v.ResourceARN) 2256 } 2257 2258 if v.RoleARN != nil { 2259 ok := object.Key("RoleARN") 2260 ok.String(*v.RoleARN) 2261 } 2262 2263 if v.S3Configuration != nil { 2264 ok := object.Key("S3Configuration") 2265 if err := awsAwsjson11_serializeDocumentS3Configuration(v.S3Configuration, ok); err != nil { 2266 return err 2267 } 2268 } 2269 2270 return nil 2271} 2272 2273func awsAwsjson11_serializeOpDocumentListApplicationsInput(v *ListApplicationsInput, value smithyjson.Value) error { 2274 object := value.Object() 2275 defer object.Close() 2276 2277 if v.ExclusiveStartApplicationName != nil { 2278 ok := object.Key("ExclusiveStartApplicationName") 2279 ok.String(*v.ExclusiveStartApplicationName) 2280 } 2281 2282 if v.Limit != nil { 2283 ok := object.Key("Limit") 2284 ok.Integer(*v.Limit) 2285 } 2286 2287 return nil 2288} 2289 2290func awsAwsjson11_serializeOpDocumentListTagsForResourceInput(v *ListTagsForResourceInput, value smithyjson.Value) error { 2291 object := value.Object() 2292 defer object.Close() 2293 2294 if v.ResourceARN != nil { 2295 ok := object.Key("ResourceARN") 2296 ok.String(*v.ResourceARN) 2297 } 2298 2299 return nil 2300} 2301 2302func awsAwsjson11_serializeOpDocumentStartApplicationInput(v *StartApplicationInput, value smithyjson.Value) error { 2303 object := value.Object() 2304 defer object.Close() 2305 2306 if v.ApplicationName != nil { 2307 ok := object.Key("ApplicationName") 2308 ok.String(*v.ApplicationName) 2309 } 2310 2311 if v.InputConfigurations != nil { 2312 ok := object.Key("InputConfigurations") 2313 if err := awsAwsjson11_serializeDocumentInputConfigurations(v.InputConfigurations, ok); err != nil { 2314 return err 2315 } 2316 } 2317 2318 return nil 2319} 2320 2321func awsAwsjson11_serializeOpDocumentStopApplicationInput(v *StopApplicationInput, value smithyjson.Value) error { 2322 object := value.Object() 2323 defer object.Close() 2324 2325 if v.ApplicationName != nil { 2326 ok := object.Key("ApplicationName") 2327 ok.String(*v.ApplicationName) 2328 } 2329 2330 return nil 2331} 2332 2333func awsAwsjson11_serializeOpDocumentTagResourceInput(v *TagResourceInput, value smithyjson.Value) error { 2334 object := value.Object() 2335 defer object.Close() 2336 2337 if v.ResourceARN != nil { 2338 ok := object.Key("ResourceARN") 2339 ok.String(*v.ResourceARN) 2340 } 2341 2342 if v.Tags != nil { 2343 ok := object.Key("Tags") 2344 if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil { 2345 return err 2346 } 2347 } 2348 2349 return nil 2350} 2351 2352func awsAwsjson11_serializeOpDocumentUntagResourceInput(v *UntagResourceInput, value smithyjson.Value) error { 2353 object := value.Object() 2354 defer object.Close() 2355 2356 if v.ResourceARN != nil { 2357 ok := object.Key("ResourceARN") 2358 ok.String(*v.ResourceARN) 2359 } 2360 2361 if v.TagKeys != nil { 2362 ok := object.Key("TagKeys") 2363 if err := awsAwsjson11_serializeDocumentTagKeys(v.TagKeys, ok); err != nil { 2364 return err 2365 } 2366 } 2367 2368 return nil 2369} 2370 2371func awsAwsjson11_serializeOpDocumentUpdateApplicationInput(v *UpdateApplicationInput, value smithyjson.Value) error { 2372 object := value.Object() 2373 defer object.Close() 2374 2375 if v.ApplicationName != nil { 2376 ok := object.Key("ApplicationName") 2377 ok.String(*v.ApplicationName) 2378 } 2379 2380 if v.ApplicationUpdate != nil { 2381 ok := object.Key("ApplicationUpdate") 2382 if err := awsAwsjson11_serializeDocumentApplicationUpdate(v.ApplicationUpdate, ok); err != nil { 2383 return err 2384 } 2385 } 2386 2387 if v.CurrentApplicationVersionId != nil { 2388 ok := object.Key("CurrentApplicationVersionId") 2389 ok.Long(*v.CurrentApplicationVersionId) 2390 } 2391 2392 return nil 2393} 2394