1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package databasemigrationservice 4 5import ( 6 "bytes" 7 "context" 8 "fmt" 9 "github.com/aws/aws-sdk-go-v2/service/databasemigrationservice/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_serializeOpAddTagsToResource struct { 19} 20 21func (*awsAwsjson11_serializeOpAddTagsToResource) ID() string { 22 return "OperationSerializer" 23} 24 25func (m *awsAwsjson11_serializeOpAddTagsToResource) 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.(*AddTagsToResourceInput) 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("AmazonDMSv20160101.AddTagsToResource") 47 48 jsonEncoder := smithyjson.NewEncoder() 49 if err := awsAwsjson11_serializeOpDocumentAddTagsToResourceInput(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_serializeOpApplyPendingMaintenanceAction struct { 66} 67 68func (*awsAwsjson11_serializeOpApplyPendingMaintenanceAction) ID() string { 69 return "OperationSerializer" 70} 71 72func (m *awsAwsjson11_serializeOpApplyPendingMaintenanceAction) 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.(*ApplyPendingMaintenanceActionInput) 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("AmazonDMSv20160101.ApplyPendingMaintenanceAction") 94 95 jsonEncoder := smithyjson.NewEncoder() 96 if err := awsAwsjson11_serializeOpDocumentApplyPendingMaintenanceActionInput(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_serializeOpCancelReplicationTaskAssessmentRun struct { 113} 114 115func (*awsAwsjson11_serializeOpCancelReplicationTaskAssessmentRun) ID() string { 116 return "OperationSerializer" 117} 118 119func (m *awsAwsjson11_serializeOpCancelReplicationTaskAssessmentRun) 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.(*CancelReplicationTaskAssessmentRunInput) 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("AmazonDMSv20160101.CancelReplicationTaskAssessmentRun") 141 142 jsonEncoder := smithyjson.NewEncoder() 143 if err := awsAwsjson11_serializeOpDocumentCancelReplicationTaskAssessmentRunInput(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_serializeOpCreateEndpoint struct { 160} 161 162func (*awsAwsjson11_serializeOpCreateEndpoint) ID() string { 163 return "OperationSerializer" 164} 165 166func (m *awsAwsjson11_serializeOpCreateEndpoint) 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.(*CreateEndpointInput) 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("AmazonDMSv20160101.CreateEndpoint") 188 189 jsonEncoder := smithyjson.NewEncoder() 190 if err := awsAwsjson11_serializeOpDocumentCreateEndpointInput(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_serializeOpCreateEventSubscription struct { 207} 208 209func (*awsAwsjson11_serializeOpCreateEventSubscription) ID() string { 210 return "OperationSerializer" 211} 212 213func (m *awsAwsjson11_serializeOpCreateEventSubscription) 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.(*CreateEventSubscriptionInput) 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("AmazonDMSv20160101.CreateEventSubscription") 235 236 jsonEncoder := smithyjson.NewEncoder() 237 if err := awsAwsjson11_serializeOpDocumentCreateEventSubscriptionInput(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_serializeOpCreateReplicationInstance struct { 254} 255 256func (*awsAwsjson11_serializeOpCreateReplicationInstance) ID() string { 257 return "OperationSerializer" 258} 259 260func (m *awsAwsjson11_serializeOpCreateReplicationInstance) 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.(*CreateReplicationInstanceInput) 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("AmazonDMSv20160101.CreateReplicationInstance") 282 283 jsonEncoder := smithyjson.NewEncoder() 284 if err := awsAwsjson11_serializeOpDocumentCreateReplicationInstanceInput(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_serializeOpCreateReplicationSubnetGroup struct { 301} 302 303func (*awsAwsjson11_serializeOpCreateReplicationSubnetGroup) ID() string { 304 return "OperationSerializer" 305} 306 307func (m *awsAwsjson11_serializeOpCreateReplicationSubnetGroup) 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.(*CreateReplicationSubnetGroupInput) 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("AmazonDMSv20160101.CreateReplicationSubnetGroup") 329 330 jsonEncoder := smithyjson.NewEncoder() 331 if err := awsAwsjson11_serializeOpDocumentCreateReplicationSubnetGroupInput(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_serializeOpCreateReplicationTask struct { 348} 349 350func (*awsAwsjson11_serializeOpCreateReplicationTask) ID() string { 351 return "OperationSerializer" 352} 353 354func (m *awsAwsjson11_serializeOpCreateReplicationTask) 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.(*CreateReplicationTaskInput) 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("AmazonDMSv20160101.CreateReplicationTask") 376 377 jsonEncoder := smithyjson.NewEncoder() 378 if err := awsAwsjson11_serializeOpDocumentCreateReplicationTaskInput(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_serializeOpDeleteCertificate struct { 395} 396 397func (*awsAwsjson11_serializeOpDeleteCertificate) ID() string { 398 return "OperationSerializer" 399} 400 401func (m *awsAwsjson11_serializeOpDeleteCertificate) 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.(*DeleteCertificateInput) 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("AmazonDMSv20160101.DeleteCertificate") 423 424 jsonEncoder := smithyjson.NewEncoder() 425 if err := awsAwsjson11_serializeOpDocumentDeleteCertificateInput(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_serializeOpDeleteConnection struct { 442} 443 444func (*awsAwsjson11_serializeOpDeleteConnection) ID() string { 445 return "OperationSerializer" 446} 447 448func (m *awsAwsjson11_serializeOpDeleteConnection) 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.(*DeleteConnectionInput) 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("AmazonDMSv20160101.DeleteConnection") 470 471 jsonEncoder := smithyjson.NewEncoder() 472 if err := awsAwsjson11_serializeOpDocumentDeleteConnectionInput(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_serializeOpDeleteEndpoint struct { 489} 490 491func (*awsAwsjson11_serializeOpDeleteEndpoint) ID() string { 492 return "OperationSerializer" 493} 494 495func (m *awsAwsjson11_serializeOpDeleteEndpoint) 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.(*DeleteEndpointInput) 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("AmazonDMSv20160101.DeleteEndpoint") 517 518 jsonEncoder := smithyjson.NewEncoder() 519 if err := awsAwsjson11_serializeOpDocumentDeleteEndpointInput(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_serializeOpDeleteEventSubscription struct { 536} 537 538func (*awsAwsjson11_serializeOpDeleteEventSubscription) ID() string { 539 return "OperationSerializer" 540} 541 542func (m *awsAwsjson11_serializeOpDeleteEventSubscription) 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.(*DeleteEventSubscriptionInput) 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("AmazonDMSv20160101.DeleteEventSubscription") 564 565 jsonEncoder := smithyjson.NewEncoder() 566 if err := awsAwsjson11_serializeOpDocumentDeleteEventSubscriptionInput(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_serializeOpDeleteReplicationInstance struct { 583} 584 585func (*awsAwsjson11_serializeOpDeleteReplicationInstance) ID() string { 586 return "OperationSerializer" 587} 588 589func (m *awsAwsjson11_serializeOpDeleteReplicationInstance) 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.(*DeleteReplicationInstanceInput) 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("AmazonDMSv20160101.DeleteReplicationInstance") 611 612 jsonEncoder := smithyjson.NewEncoder() 613 if err := awsAwsjson11_serializeOpDocumentDeleteReplicationInstanceInput(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_serializeOpDeleteReplicationSubnetGroup struct { 630} 631 632func (*awsAwsjson11_serializeOpDeleteReplicationSubnetGroup) ID() string { 633 return "OperationSerializer" 634} 635 636func (m *awsAwsjson11_serializeOpDeleteReplicationSubnetGroup) 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.(*DeleteReplicationSubnetGroupInput) 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("AmazonDMSv20160101.DeleteReplicationSubnetGroup") 658 659 jsonEncoder := smithyjson.NewEncoder() 660 if err := awsAwsjson11_serializeOpDocumentDeleteReplicationSubnetGroupInput(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_serializeOpDeleteReplicationTask struct { 677} 678 679func (*awsAwsjson11_serializeOpDeleteReplicationTask) ID() string { 680 return "OperationSerializer" 681} 682 683func (m *awsAwsjson11_serializeOpDeleteReplicationTask) 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.(*DeleteReplicationTaskInput) 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("AmazonDMSv20160101.DeleteReplicationTask") 705 706 jsonEncoder := smithyjson.NewEncoder() 707 if err := awsAwsjson11_serializeOpDocumentDeleteReplicationTaskInput(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_serializeOpDeleteReplicationTaskAssessmentRun struct { 724} 725 726func (*awsAwsjson11_serializeOpDeleteReplicationTaskAssessmentRun) ID() string { 727 return "OperationSerializer" 728} 729 730func (m *awsAwsjson11_serializeOpDeleteReplicationTaskAssessmentRun) 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.(*DeleteReplicationTaskAssessmentRunInput) 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("AmazonDMSv20160101.DeleteReplicationTaskAssessmentRun") 752 753 jsonEncoder := smithyjson.NewEncoder() 754 if err := awsAwsjson11_serializeOpDocumentDeleteReplicationTaskAssessmentRunInput(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_serializeOpDescribeAccountAttributes struct { 771} 772 773func (*awsAwsjson11_serializeOpDescribeAccountAttributes) ID() string { 774 return "OperationSerializer" 775} 776 777func (m *awsAwsjson11_serializeOpDescribeAccountAttributes) 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.(*DescribeAccountAttributesInput) 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("AmazonDMSv20160101.DescribeAccountAttributes") 799 800 jsonEncoder := smithyjson.NewEncoder() 801 if err := awsAwsjson11_serializeOpDocumentDescribeAccountAttributesInput(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_serializeOpDescribeApplicableIndividualAssessments struct { 818} 819 820func (*awsAwsjson11_serializeOpDescribeApplicableIndividualAssessments) ID() string { 821 return "OperationSerializer" 822} 823 824func (m *awsAwsjson11_serializeOpDescribeApplicableIndividualAssessments) 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.(*DescribeApplicableIndividualAssessmentsInput) 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("AmazonDMSv20160101.DescribeApplicableIndividualAssessments") 846 847 jsonEncoder := smithyjson.NewEncoder() 848 if err := awsAwsjson11_serializeOpDocumentDescribeApplicableIndividualAssessmentsInput(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_serializeOpDescribeCertificates struct { 865} 866 867func (*awsAwsjson11_serializeOpDescribeCertificates) ID() string { 868 return "OperationSerializer" 869} 870 871func (m *awsAwsjson11_serializeOpDescribeCertificates) 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.(*DescribeCertificatesInput) 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("AmazonDMSv20160101.DescribeCertificates") 893 894 jsonEncoder := smithyjson.NewEncoder() 895 if err := awsAwsjson11_serializeOpDocumentDescribeCertificatesInput(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_serializeOpDescribeConnections struct { 912} 913 914func (*awsAwsjson11_serializeOpDescribeConnections) ID() string { 915 return "OperationSerializer" 916} 917 918func (m *awsAwsjson11_serializeOpDescribeConnections) 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.(*DescribeConnectionsInput) 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("AmazonDMSv20160101.DescribeConnections") 940 941 jsonEncoder := smithyjson.NewEncoder() 942 if err := awsAwsjson11_serializeOpDocumentDescribeConnectionsInput(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_serializeOpDescribeEndpoints struct { 959} 960 961func (*awsAwsjson11_serializeOpDescribeEndpoints) ID() string { 962 return "OperationSerializer" 963} 964 965func (m *awsAwsjson11_serializeOpDescribeEndpoints) 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.(*DescribeEndpointsInput) 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("AmazonDMSv20160101.DescribeEndpoints") 987 988 jsonEncoder := smithyjson.NewEncoder() 989 if err := awsAwsjson11_serializeOpDocumentDescribeEndpointsInput(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_serializeOpDescribeEndpointTypes struct { 1006} 1007 1008func (*awsAwsjson11_serializeOpDescribeEndpointTypes) ID() string { 1009 return "OperationSerializer" 1010} 1011 1012func (m *awsAwsjson11_serializeOpDescribeEndpointTypes) 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.(*DescribeEndpointTypesInput) 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("AmazonDMSv20160101.DescribeEndpointTypes") 1034 1035 jsonEncoder := smithyjson.NewEncoder() 1036 if err := awsAwsjson11_serializeOpDocumentDescribeEndpointTypesInput(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_serializeOpDescribeEventCategories struct { 1053} 1054 1055func (*awsAwsjson11_serializeOpDescribeEventCategories) ID() string { 1056 return "OperationSerializer" 1057} 1058 1059func (m *awsAwsjson11_serializeOpDescribeEventCategories) 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.(*DescribeEventCategoriesInput) 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("AmazonDMSv20160101.DescribeEventCategories") 1081 1082 jsonEncoder := smithyjson.NewEncoder() 1083 if err := awsAwsjson11_serializeOpDocumentDescribeEventCategoriesInput(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_serializeOpDescribeEvents struct { 1100} 1101 1102func (*awsAwsjson11_serializeOpDescribeEvents) ID() string { 1103 return "OperationSerializer" 1104} 1105 1106func (m *awsAwsjson11_serializeOpDescribeEvents) 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.(*DescribeEventsInput) 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("AmazonDMSv20160101.DescribeEvents") 1128 1129 jsonEncoder := smithyjson.NewEncoder() 1130 if err := awsAwsjson11_serializeOpDocumentDescribeEventsInput(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_serializeOpDescribeEventSubscriptions struct { 1147} 1148 1149func (*awsAwsjson11_serializeOpDescribeEventSubscriptions) ID() string { 1150 return "OperationSerializer" 1151} 1152 1153func (m *awsAwsjson11_serializeOpDescribeEventSubscriptions) 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.(*DescribeEventSubscriptionsInput) 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("AmazonDMSv20160101.DescribeEventSubscriptions") 1175 1176 jsonEncoder := smithyjson.NewEncoder() 1177 if err := awsAwsjson11_serializeOpDocumentDescribeEventSubscriptionsInput(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_serializeOpDescribeOrderableReplicationInstances struct { 1194} 1195 1196func (*awsAwsjson11_serializeOpDescribeOrderableReplicationInstances) ID() string { 1197 return "OperationSerializer" 1198} 1199 1200func (m *awsAwsjson11_serializeOpDescribeOrderableReplicationInstances) 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.(*DescribeOrderableReplicationInstancesInput) 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("AmazonDMSv20160101.DescribeOrderableReplicationInstances") 1222 1223 jsonEncoder := smithyjson.NewEncoder() 1224 if err := awsAwsjson11_serializeOpDocumentDescribeOrderableReplicationInstancesInput(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_serializeOpDescribePendingMaintenanceActions struct { 1241} 1242 1243func (*awsAwsjson11_serializeOpDescribePendingMaintenanceActions) ID() string { 1244 return "OperationSerializer" 1245} 1246 1247func (m *awsAwsjson11_serializeOpDescribePendingMaintenanceActions) 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.(*DescribePendingMaintenanceActionsInput) 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("AmazonDMSv20160101.DescribePendingMaintenanceActions") 1269 1270 jsonEncoder := smithyjson.NewEncoder() 1271 if err := awsAwsjson11_serializeOpDocumentDescribePendingMaintenanceActionsInput(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} 1286 1287type awsAwsjson11_serializeOpDescribeRefreshSchemasStatus struct { 1288} 1289 1290func (*awsAwsjson11_serializeOpDescribeRefreshSchemasStatus) ID() string { 1291 return "OperationSerializer" 1292} 1293 1294func (m *awsAwsjson11_serializeOpDescribeRefreshSchemasStatus) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1295 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1296) { 1297 request, ok := in.Request.(*smithyhttp.Request) 1298 if !ok { 1299 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1300 } 1301 1302 input, ok := in.Parameters.(*DescribeRefreshSchemasStatusInput) 1303 _ = input 1304 if !ok { 1305 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1306 } 1307 1308 request.Request.URL.Path = "/" 1309 request.Request.Method = "POST" 1310 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1311 if err != nil { 1312 return out, metadata, &smithy.SerializationError{Err: err} 1313 } 1314 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1315 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeRefreshSchemasStatus") 1316 1317 jsonEncoder := smithyjson.NewEncoder() 1318 if err := awsAwsjson11_serializeOpDocumentDescribeRefreshSchemasStatusInput(input, jsonEncoder.Value); err != nil { 1319 return out, metadata, &smithy.SerializationError{Err: err} 1320 } 1321 1322 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1323 return out, metadata, &smithy.SerializationError{Err: err} 1324 } 1325 1326 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1327 return out, metadata, &smithy.SerializationError{Err: err} 1328 } 1329 in.Request = request 1330 1331 return next.HandleSerialize(ctx, in) 1332} 1333 1334type awsAwsjson11_serializeOpDescribeReplicationInstances struct { 1335} 1336 1337func (*awsAwsjson11_serializeOpDescribeReplicationInstances) ID() string { 1338 return "OperationSerializer" 1339} 1340 1341func (m *awsAwsjson11_serializeOpDescribeReplicationInstances) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1342 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1343) { 1344 request, ok := in.Request.(*smithyhttp.Request) 1345 if !ok { 1346 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1347 } 1348 1349 input, ok := in.Parameters.(*DescribeReplicationInstancesInput) 1350 _ = input 1351 if !ok { 1352 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1353 } 1354 1355 request.Request.URL.Path = "/" 1356 request.Request.Method = "POST" 1357 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1358 if err != nil { 1359 return out, metadata, &smithy.SerializationError{Err: err} 1360 } 1361 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1362 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationInstances") 1363 1364 jsonEncoder := smithyjson.NewEncoder() 1365 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationInstancesInput(input, jsonEncoder.Value); err != nil { 1366 return out, metadata, &smithy.SerializationError{Err: err} 1367 } 1368 1369 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1370 return out, metadata, &smithy.SerializationError{Err: err} 1371 } 1372 1373 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1374 return out, metadata, &smithy.SerializationError{Err: err} 1375 } 1376 in.Request = request 1377 1378 return next.HandleSerialize(ctx, in) 1379} 1380 1381type awsAwsjson11_serializeOpDescribeReplicationInstanceTaskLogs struct { 1382} 1383 1384func (*awsAwsjson11_serializeOpDescribeReplicationInstanceTaskLogs) ID() string { 1385 return "OperationSerializer" 1386} 1387 1388func (m *awsAwsjson11_serializeOpDescribeReplicationInstanceTaskLogs) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1389 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1390) { 1391 request, ok := in.Request.(*smithyhttp.Request) 1392 if !ok { 1393 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1394 } 1395 1396 input, ok := in.Parameters.(*DescribeReplicationInstanceTaskLogsInput) 1397 _ = input 1398 if !ok { 1399 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1400 } 1401 1402 request.Request.URL.Path = "/" 1403 request.Request.Method = "POST" 1404 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1405 if err != nil { 1406 return out, metadata, &smithy.SerializationError{Err: err} 1407 } 1408 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1409 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationInstanceTaskLogs") 1410 1411 jsonEncoder := smithyjson.NewEncoder() 1412 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationInstanceTaskLogsInput(input, jsonEncoder.Value); err != nil { 1413 return out, metadata, &smithy.SerializationError{Err: err} 1414 } 1415 1416 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1417 return out, metadata, &smithy.SerializationError{Err: err} 1418 } 1419 1420 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1421 return out, metadata, &smithy.SerializationError{Err: err} 1422 } 1423 in.Request = request 1424 1425 return next.HandleSerialize(ctx, in) 1426} 1427 1428type awsAwsjson11_serializeOpDescribeReplicationSubnetGroups struct { 1429} 1430 1431func (*awsAwsjson11_serializeOpDescribeReplicationSubnetGroups) ID() string { 1432 return "OperationSerializer" 1433} 1434 1435func (m *awsAwsjson11_serializeOpDescribeReplicationSubnetGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1436 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1437) { 1438 request, ok := in.Request.(*smithyhttp.Request) 1439 if !ok { 1440 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1441 } 1442 1443 input, ok := in.Parameters.(*DescribeReplicationSubnetGroupsInput) 1444 _ = input 1445 if !ok { 1446 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1447 } 1448 1449 request.Request.URL.Path = "/" 1450 request.Request.Method = "POST" 1451 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1452 if err != nil { 1453 return out, metadata, &smithy.SerializationError{Err: err} 1454 } 1455 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1456 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationSubnetGroups") 1457 1458 jsonEncoder := smithyjson.NewEncoder() 1459 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationSubnetGroupsInput(input, jsonEncoder.Value); err != nil { 1460 return out, metadata, &smithy.SerializationError{Err: err} 1461 } 1462 1463 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1464 return out, metadata, &smithy.SerializationError{Err: err} 1465 } 1466 1467 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1468 return out, metadata, &smithy.SerializationError{Err: err} 1469 } 1470 in.Request = request 1471 1472 return next.HandleSerialize(ctx, in) 1473} 1474 1475type awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentResults struct { 1476} 1477 1478func (*awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentResults) ID() string { 1479 return "OperationSerializer" 1480} 1481 1482func (m *awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentResults) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1483 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1484) { 1485 request, ok := in.Request.(*smithyhttp.Request) 1486 if !ok { 1487 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1488 } 1489 1490 input, ok := in.Parameters.(*DescribeReplicationTaskAssessmentResultsInput) 1491 _ = input 1492 if !ok { 1493 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1494 } 1495 1496 request.Request.URL.Path = "/" 1497 request.Request.Method = "POST" 1498 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1499 if err != nil { 1500 return out, metadata, &smithy.SerializationError{Err: err} 1501 } 1502 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1503 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationTaskAssessmentResults") 1504 1505 jsonEncoder := smithyjson.NewEncoder() 1506 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationTaskAssessmentResultsInput(input, jsonEncoder.Value); err != nil { 1507 return out, metadata, &smithy.SerializationError{Err: err} 1508 } 1509 1510 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1511 return out, metadata, &smithy.SerializationError{Err: err} 1512 } 1513 1514 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1515 return out, metadata, &smithy.SerializationError{Err: err} 1516 } 1517 in.Request = request 1518 1519 return next.HandleSerialize(ctx, in) 1520} 1521 1522type awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentRuns struct { 1523} 1524 1525func (*awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentRuns) ID() string { 1526 return "OperationSerializer" 1527} 1528 1529func (m *awsAwsjson11_serializeOpDescribeReplicationTaskAssessmentRuns) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1530 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1531) { 1532 request, ok := in.Request.(*smithyhttp.Request) 1533 if !ok { 1534 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1535 } 1536 1537 input, ok := in.Parameters.(*DescribeReplicationTaskAssessmentRunsInput) 1538 _ = input 1539 if !ok { 1540 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1541 } 1542 1543 request.Request.URL.Path = "/" 1544 request.Request.Method = "POST" 1545 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1546 if err != nil { 1547 return out, metadata, &smithy.SerializationError{Err: err} 1548 } 1549 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1550 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationTaskAssessmentRuns") 1551 1552 jsonEncoder := smithyjson.NewEncoder() 1553 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationTaskAssessmentRunsInput(input, jsonEncoder.Value); err != nil { 1554 return out, metadata, &smithy.SerializationError{Err: err} 1555 } 1556 1557 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1558 return out, metadata, &smithy.SerializationError{Err: err} 1559 } 1560 1561 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1562 return out, metadata, &smithy.SerializationError{Err: err} 1563 } 1564 in.Request = request 1565 1566 return next.HandleSerialize(ctx, in) 1567} 1568 1569type awsAwsjson11_serializeOpDescribeReplicationTaskIndividualAssessments struct { 1570} 1571 1572func (*awsAwsjson11_serializeOpDescribeReplicationTaskIndividualAssessments) ID() string { 1573 return "OperationSerializer" 1574} 1575 1576func (m *awsAwsjson11_serializeOpDescribeReplicationTaskIndividualAssessments) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1577 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1578) { 1579 request, ok := in.Request.(*smithyhttp.Request) 1580 if !ok { 1581 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1582 } 1583 1584 input, ok := in.Parameters.(*DescribeReplicationTaskIndividualAssessmentsInput) 1585 _ = input 1586 if !ok { 1587 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1588 } 1589 1590 request.Request.URL.Path = "/" 1591 request.Request.Method = "POST" 1592 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1593 if err != nil { 1594 return out, metadata, &smithy.SerializationError{Err: err} 1595 } 1596 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1597 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationTaskIndividualAssessments") 1598 1599 jsonEncoder := smithyjson.NewEncoder() 1600 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationTaskIndividualAssessmentsInput(input, jsonEncoder.Value); err != nil { 1601 return out, metadata, &smithy.SerializationError{Err: err} 1602 } 1603 1604 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1605 return out, metadata, &smithy.SerializationError{Err: err} 1606 } 1607 1608 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1609 return out, metadata, &smithy.SerializationError{Err: err} 1610 } 1611 in.Request = request 1612 1613 return next.HandleSerialize(ctx, in) 1614} 1615 1616type awsAwsjson11_serializeOpDescribeReplicationTasks struct { 1617} 1618 1619func (*awsAwsjson11_serializeOpDescribeReplicationTasks) ID() string { 1620 return "OperationSerializer" 1621} 1622 1623func (m *awsAwsjson11_serializeOpDescribeReplicationTasks) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1624 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1625) { 1626 request, ok := in.Request.(*smithyhttp.Request) 1627 if !ok { 1628 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1629 } 1630 1631 input, ok := in.Parameters.(*DescribeReplicationTasksInput) 1632 _ = input 1633 if !ok { 1634 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1635 } 1636 1637 request.Request.URL.Path = "/" 1638 request.Request.Method = "POST" 1639 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1640 if err != nil { 1641 return out, metadata, &smithy.SerializationError{Err: err} 1642 } 1643 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1644 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeReplicationTasks") 1645 1646 jsonEncoder := smithyjson.NewEncoder() 1647 if err := awsAwsjson11_serializeOpDocumentDescribeReplicationTasksInput(input, jsonEncoder.Value); err != nil { 1648 return out, metadata, &smithy.SerializationError{Err: err} 1649 } 1650 1651 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1652 return out, metadata, &smithy.SerializationError{Err: err} 1653 } 1654 1655 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1656 return out, metadata, &smithy.SerializationError{Err: err} 1657 } 1658 in.Request = request 1659 1660 return next.HandleSerialize(ctx, in) 1661} 1662 1663type awsAwsjson11_serializeOpDescribeSchemas struct { 1664} 1665 1666func (*awsAwsjson11_serializeOpDescribeSchemas) ID() string { 1667 return "OperationSerializer" 1668} 1669 1670func (m *awsAwsjson11_serializeOpDescribeSchemas) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1671 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1672) { 1673 request, ok := in.Request.(*smithyhttp.Request) 1674 if !ok { 1675 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1676 } 1677 1678 input, ok := in.Parameters.(*DescribeSchemasInput) 1679 _ = input 1680 if !ok { 1681 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1682 } 1683 1684 request.Request.URL.Path = "/" 1685 request.Request.Method = "POST" 1686 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1687 if err != nil { 1688 return out, metadata, &smithy.SerializationError{Err: err} 1689 } 1690 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1691 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeSchemas") 1692 1693 jsonEncoder := smithyjson.NewEncoder() 1694 if err := awsAwsjson11_serializeOpDocumentDescribeSchemasInput(input, jsonEncoder.Value); err != nil { 1695 return out, metadata, &smithy.SerializationError{Err: err} 1696 } 1697 1698 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1699 return out, metadata, &smithy.SerializationError{Err: err} 1700 } 1701 1702 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1703 return out, metadata, &smithy.SerializationError{Err: err} 1704 } 1705 in.Request = request 1706 1707 return next.HandleSerialize(ctx, in) 1708} 1709 1710type awsAwsjson11_serializeOpDescribeTableStatistics struct { 1711} 1712 1713func (*awsAwsjson11_serializeOpDescribeTableStatistics) ID() string { 1714 return "OperationSerializer" 1715} 1716 1717func (m *awsAwsjson11_serializeOpDescribeTableStatistics) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1718 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1719) { 1720 request, ok := in.Request.(*smithyhttp.Request) 1721 if !ok { 1722 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1723 } 1724 1725 input, ok := in.Parameters.(*DescribeTableStatisticsInput) 1726 _ = input 1727 if !ok { 1728 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1729 } 1730 1731 request.Request.URL.Path = "/" 1732 request.Request.Method = "POST" 1733 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1734 if err != nil { 1735 return out, metadata, &smithy.SerializationError{Err: err} 1736 } 1737 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1738 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.DescribeTableStatistics") 1739 1740 jsonEncoder := smithyjson.NewEncoder() 1741 if err := awsAwsjson11_serializeOpDocumentDescribeTableStatisticsInput(input, jsonEncoder.Value); err != nil { 1742 return out, metadata, &smithy.SerializationError{Err: err} 1743 } 1744 1745 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1746 return out, metadata, &smithy.SerializationError{Err: err} 1747 } 1748 1749 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1750 return out, metadata, &smithy.SerializationError{Err: err} 1751 } 1752 in.Request = request 1753 1754 return next.HandleSerialize(ctx, in) 1755} 1756 1757type awsAwsjson11_serializeOpImportCertificate struct { 1758} 1759 1760func (*awsAwsjson11_serializeOpImportCertificate) ID() string { 1761 return "OperationSerializer" 1762} 1763 1764func (m *awsAwsjson11_serializeOpImportCertificate) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1765 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1766) { 1767 request, ok := in.Request.(*smithyhttp.Request) 1768 if !ok { 1769 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1770 } 1771 1772 input, ok := in.Parameters.(*ImportCertificateInput) 1773 _ = input 1774 if !ok { 1775 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1776 } 1777 1778 request.Request.URL.Path = "/" 1779 request.Request.Method = "POST" 1780 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1781 if err != nil { 1782 return out, metadata, &smithy.SerializationError{Err: err} 1783 } 1784 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1785 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ImportCertificate") 1786 1787 jsonEncoder := smithyjson.NewEncoder() 1788 if err := awsAwsjson11_serializeOpDocumentImportCertificateInput(input, jsonEncoder.Value); err != nil { 1789 return out, metadata, &smithy.SerializationError{Err: err} 1790 } 1791 1792 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1793 return out, metadata, &smithy.SerializationError{Err: err} 1794 } 1795 1796 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1797 return out, metadata, &smithy.SerializationError{Err: err} 1798 } 1799 in.Request = request 1800 1801 return next.HandleSerialize(ctx, in) 1802} 1803 1804type awsAwsjson11_serializeOpListTagsForResource struct { 1805} 1806 1807func (*awsAwsjson11_serializeOpListTagsForResource) ID() string { 1808 return "OperationSerializer" 1809} 1810 1811func (m *awsAwsjson11_serializeOpListTagsForResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1812 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1813) { 1814 request, ok := in.Request.(*smithyhttp.Request) 1815 if !ok { 1816 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1817 } 1818 1819 input, ok := in.Parameters.(*ListTagsForResourceInput) 1820 _ = input 1821 if !ok { 1822 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1823 } 1824 1825 request.Request.URL.Path = "/" 1826 request.Request.Method = "POST" 1827 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1828 if err != nil { 1829 return out, metadata, &smithy.SerializationError{Err: err} 1830 } 1831 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1832 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ListTagsForResource") 1833 1834 jsonEncoder := smithyjson.NewEncoder() 1835 if err := awsAwsjson11_serializeOpDocumentListTagsForResourceInput(input, jsonEncoder.Value); err != nil { 1836 return out, metadata, &smithy.SerializationError{Err: err} 1837 } 1838 1839 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1840 return out, metadata, &smithy.SerializationError{Err: err} 1841 } 1842 1843 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1844 return out, metadata, &smithy.SerializationError{Err: err} 1845 } 1846 in.Request = request 1847 1848 return next.HandleSerialize(ctx, in) 1849} 1850 1851type awsAwsjson11_serializeOpModifyEndpoint struct { 1852} 1853 1854func (*awsAwsjson11_serializeOpModifyEndpoint) ID() string { 1855 return "OperationSerializer" 1856} 1857 1858func (m *awsAwsjson11_serializeOpModifyEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1859 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1860) { 1861 request, ok := in.Request.(*smithyhttp.Request) 1862 if !ok { 1863 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1864 } 1865 1866 input, ok := in.Parameters.(*ModifyEndpointInput) 1867 _ = input 1868 if !ok { 1869 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1870 } 1871 1872 request.Request.URL.Path = "/" 1873 request.Request.Method = "POST" 1874 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1875 if err != nil { 1876 return out, metadata, &smithy.SerializationError{Err: err} 1877 } 1878 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1879 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ModifyEndpoint") 1880 1881 jsonEncoder := smithyjson.NewEncoder() 1882 if err := awsAwsjson11_serializeOpDocumentModifyEndpointInput(input, jsonEncoder.Value); err != nil { 1883 return out, metadata, &smithy.SerializationError{Err: err} 1884 } 1885 1886 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1887 return out, metadata, &smithy.SerializationError{Err: err} 1888 } 1889 1890 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1891 return out, metadata, &smithy.SerializationError{Err: err} 1892 } 1893 in.Request = request 1894 1895 return next.HandleSerialize(ctx, in) 1896} 1897 1898type awsAwsjson11_serializeOpModifyEventSubscription struct { 1899} 1900 1901func (*awsAwsjson11_serializeOpModifyEventSubscription) ID() string { 1902 return "OperationSerializer" 1903} 1904 1905func (m *awsAwsjson11_serializeOpModifyEventSubscription) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1906 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1907) { 1908 request, ok := in.Request.(*smithyhttp.Request) 1909 if !ok { 1910 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1911 } 1912 1913 input, ok := in.Parameters.(*ModifyEventSubscriptionInput) 1914 _ = input 1915 if !ok { 1916 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1917 } 1918 1919 request.Request.URL.Path = "/" 1920 request.Request.Method = "POST" 1921 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1922 if err != nil { 1923 return out, metadata, &smithy.SerializationError{Err: err} 1924 } 1925 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1926 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ModifyEventSubscription") 1927 1928 jsonEncoder := smithyjson.NewEncoder() 1929 if err := awsAwsjson11_serializeOpDocumentModifyEventSubscriptionInput(input, jsonEncoder.Value); err != nil { 1930 return out, metadata, &smithy.SerializationError{Err: err} 1931 } 1932 1933 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1934 return out, metadata, &smithy.SerializationError{Err: err} 1935 } 1936 1937 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1938 return out, metadata, &smithy.SerializationError{Err: err} 1939 } 1940 in.Request = request 1941 1942 return next.HandleSerialize(ctx, in) 1943} 1944 1945type awsAwsjson11_serializeOpModifyReplicationInstance struct { 1946} 1947 1948func (*awsAwsjson11_serializeOpModifyReplicationInstance) ID() string { 1949 return "OperationSerializer" 1950} 1951 1952func (m *awsAwsjson11_serializeOpModifyReplicationInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 1953 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 1954) { 1955 request, ok := in.Request.(*smithyhttp.Request) 1956 if !ok { 1957 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 1958 } 1959 1960 input, ok := in.Parameters.(*ModifyReplicationInstanceInput) 1961 _ = input 1962 if !ok { 1963 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 1964 } 1965 1966 request.Request.URL.Path = "/" 1967 request.Request.Method = "POST" 1968 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 1969 if err != nil { 1970 return out, metadata, &smithy.SerializationError{Err: err} 1971 } 1972 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 1973 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ModifyReplicationInstance") 1974 1975 jsonEncoder := smithyjson.NewEncoder() 1976 if err := awsAwsjson11_serializeOpDocumentModifyReplicationInstanceInput(input, jsonEncoder.Value); err != nil { 1977 return out, metadata, &smithy.SerializationError{Err: err} 1978 } 1979 1980 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 1981 return out, metadata, &smithy.SerializationError{Err: err} 1982 } 1983 1984 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 1985 return out, metadata, &smithy.SerializationError{Err: err} 1986 } 1987 in.Request = request 1988 1989 return next.HandleSerialize(ctx, in) 1990} 1991 1992type awsAwsjson11_serializeOpModifyReplicationSubnetGroup struct { 1993} 1994 1995func (*awsAwsjson11_serializeOpModifyReplicationSubnetGroup) ID() string { 1996 return "OperationSerializer" 1997} 1998 1999func (m *awsAwsjson11_serializeOpModifyReplicationSubnetGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2000 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2001) { 2002 request, ok := in.Request.(*smithyhttp.Request) 2003 if !ok { 2004 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2005 } 2006 2007 input, ok := in.Parameters.(*ModifyReplicationSubnetGroupInput) 2008 _ = input 2009 if !ok { 2010 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2011 } 2012 2013 request.Request.URL.Path = "/" 2014 request.Request.Method = "POST" 2015 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2016 if err != nil { 2017 return out, metadata, &smithy.SerializationError{Err: err} 2018 } 2019 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2020 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ModifyReplicationSubnetGroup") 2021 2022 jsonEncoder := smithyjson.NewEncoder() 2023 if err := awsAwsjson11_serializeOpDocumentModifyReplicationSubnetGroupInput(input, jsonEncoder.Value); err != nil { 2024 return out, metadata, &smithy.SerializationError{Err: err} 2025 } 2026 2027 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2028 return out, metadata, &smithy.SerializationError{Err: err} 2029 } 2030 2031 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2032 return out, metadata, &smithy.SerializationError{Err: err} 2033 } 2034 in.Request = request 2035 2036 return next.HandleSerialize(ctx, in) 2037} 2038 2039type awsAwsjson11_serializeOpModifyReplicationTask struct { 2040} 2041 2042func (*awsAwsjson11_serializeOpModifyReplicationTask) ID() string { 2043 return "OperationSerializer" 2044} 2045 2046func (m *awsAwsjson11_serializeOpModifyReplicationTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2047 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2048) { 2049 request, ok := in.Request.(*smithyhttp.Request) 2050 if !ok { 2051 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2052 } 2053 2054 input, ok := in.Parameters.(*ModifyReplicationTaskInput) 2055 _ = input 2056 if !ok { 2057 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2058 } 2059 2060 request.Request.URL.Path = "/" 2061 request.Request.Method = "POST" 2062 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2063 if err != nil { 2064 return out, metadata, &smithy.SerializationError{Err: err} 2065 } 2066 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2067 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ModifyReplicationTask") 2068 2069 jsonEncoder := smithyjson.NewEncoder() 2070 if err := awsAwsjson11_serializeOpDocumentModifyReplicationTaskInput(input, jsonEncoder.Value); err != nil { 2071 return out, metadata, &smithy.SerializationError{Err: err} 2072 } 2073 2074 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2075 return out, metadata, &smithy.SerializationError{Err: err} 2076 } 2077 2078 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2079 return out, metadata, &smithy.SerializationError{Err: err} 2080 } 2081 in.Request = request 2082 2083 return next.HandleSerialize(ctx, in) 2084} 2085 2086type awsAwsjson11_serializeOpMoveReplicationTask struct { 2087} 2088 2089func (*awsAwsjson11_serializeOpMoveReplicationTask) ID() string { 2090 return "OperationSerializer" 2091} 2092 2093func (m *awsAwsjson11_serializeOpMoveReplicationTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2094 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2095) { 2096 request, ok := in.Request.(*smithyhttp.Request) 2097 if !ok { 2098 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2099 } 2100 2101 input, ok := in.Parameters.(*MoveReplicationTaskInput) 2102 _ = input 2103 if !ok { 2104 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2105 } 2106 2107 request.Request.URL.Path = "/" 2108 request.Request.Method = "POST" 2109 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2110 if err != nil { 2111 return out, metadata, &smithy.SerializationError{Err: err} 2112 } 2113 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2114 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.MoveReplicationTask") 2115 2116 jsonEncoder := smithyjson.NewEncoder() 2117 if err := awsAwsjson11_serializeOpDocumentMoveReplicationTaskInput(input, jsonEncoder.Value); err != nil { 2118 return out, metadata, &smithy.SerializationError{Err: err} 2119 } 2120 2121 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2122 return out, metadata, &smithy.SerializationError{Err: err} 2123 } 2124 2125 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2126 return out, metadata, &smithy.SerializationError{Err: err} 2127 } 2128 in.Request = request 2129 2130 return next.HandleSerialize(ctx, in) 2131} 2132 2133type awsAwsjson11_serializeOpRebootReplicationInstance struct { 2134} 2135 2136func (*awsAwsjson11_serializeOpRebootReplicationInstance) ID() string { 2137 return "OperationSerializer" 2138} 2139 2140func (m *awsAwsjson11_serializeOpRebootReplicationInstance) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2141 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2142) { 2143 request, ok := in.Request.(*smithyhttp.Request) 2144 if !ok { 2145 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2146 } 2147 2148 input, ok := in.Parameters.(*RebootReplicationInstanceInput) 2149 _ = input 2150 if !ok { 2151 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2152 } 2153 2154 request.Request.URL.Path = "/" 2155 request.Request.Method = "POST" 2156 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2157 if err != nil { 2158 return out, metadata, &smithy.SerializationError{Err: err} 2159 } 2160 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2161 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.RebootReplicationInstance") 2162 2163 jsonEncoder := smithyjson.NewEncoder() 2164 if err := awsAwsjson11_serializeOpDocumentRebootReplicationInstanceInput(input, jsonEncoder.Value); err != nil { 2165 return out, metadata, &smithy.SerializationError{Err: err} 2166 } 2167 2168 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2169 return out, metadata, &smithy.SerializationError{Err: err} 2170 } 2171 2172 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2173 return out, metadata, &smithy.SerializationError{Err: err} 2174 } 2175 in.Request = request 2176 2177 return next.HandleSerialize(ctx, in) 2178} 2179 2180type awsAwsjson11_serializeOpRefreshSchemas struct { 2181} 2182 2183func (*awsAwsjson11_serializeOpRefreshSchemas) ID() string { 2184 return "OperationSerializer" 2185} 2186 2187func (m *awsAwsjson11_serializeOpRefreshSchemas) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2188 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2189) { 2190 request, ok := in.Request.(*smithyhttp.Request) 2191 if !ok { 2192 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2193 } 2194 2195 input, ok := in.Parameters.(*RefreshSchemasInput) 2196 _ = input 2197 if !ok { 2198 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2199 } 2200 2201 request.Request.URL.Path = "/" 2202 request.Request.Method = "POST" 2203 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2204 if err != nil { 2205 return out, metadata, &smithy.SerializationError{Err: err} 2206 } 2207 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2208 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.RefreshSchemas") 2209 2210 jsonEncoder := smithyjson.NewEncoder() 2211 if err := awsAwsjson11_serializeOpDocumentRefreshSchemasInput(input, jsonEncoder.Value); err != nil { 2212 return out, metadata, &smithy.SerializationError{Err: err} 2213 } 2214 2215 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2216 return out, metadata, &smithy.SerializationError{Err: err} 2217 } 2218 2219 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2220 return out, metadata, &smithy.SerializationError{Err: err} 2221 } 2222 in.Request = request 2223 2224 return next.HandleSerialize(ctx, in) 2225} 2226 2227type awsAwsjson11_serializeOpReloadTables struct { 2228} 2229 2230func (*awsAwsjson11_serializeOpReloadTables) ID() string { 2231 return "OperationSerializer" 2232} 2233 2234func (m *awsAwsjson11_serializeOpReloadTables) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2235 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2236) { 2237 request, ok := in.Request.(*smithyhttp.Request) 2238 if !ok { 2239 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2240 } 2241 2242 input, ok := in.Parameters.(*ReloadTablesInput) 2243 _ = input 2244 if !ok { 2245 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2246 } 2247 2248 request.Request.URL.Path = "/" 2249 request.Request.Method = "POST" 2250 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2251 if err != nil { 2252 return out, metadata, &smithy.SerializationError{Err: err} 2253 } 2254 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2255 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.ReloadTables") 2256 2257 jsonEncoder := smithyjson.NewEncoder() 2258 if err := awsAwsjson11_serializeOpDocumentReloadTablesInput(input, jsonEncoder.Value); err != nil { 2259 return out, metadata, &smithy.SerializationError{Err: err} 2260 } 2261 2262 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2263 return out, metadata, &smithy.SerializationError{Err: err} 2264 } 2265 2266 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2267 return out, metadata, &smithy.SerializationError{Err: err} 2268 } 2269 in.Request = request 2270 2271 return next.HandleSerialize(ctx, in) 2272} 2273 2274type awsAwsjson11_serializeOpRemoveTagsFromResource struct { 2275} 2276 2277func (*awsAwsjson11_serializeOpRemoveTagsFromResource) ID() string { 2278 return "OperationSerializer" 2279} 2280 2281func (m *awsAwsjson11_serializeOpRemoveTagsFromResource) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2282 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2283) { 2284 request, ok := in.Request.(*smithyhttp.Request) 2285 if !ok { 2286 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2287 } 2288 2289 input, ok := in.Parameters.(*RemoveTagsFromResourceInput) 2290 _ = input 2291 if !ok { 2292 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2293 } 2294 2295 request.Request.URL.Path = "/" 2296 request.Request.Method = "POST" 2297 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2298 if err != nil { 2299 return out, metadata, &smithy.SerializationError{Err: err} 2300 } 2301 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2302 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.RemoveTagsFromResource") 2303 2304 jsonEncoder := smithyjson.NewEncoder() 2305 if err := awsAwsjson11_serializeOpDocumentRemoveTagsFromResourceInput(input, jsonEncoder.Value); err != nil { 2306 return out, metadata, &smithy.SerializationError{Err: err} 2307 } 2308 2309 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2310 return out, metadata, &smithy.SerializationError{Err: err} 2311 } 2312 2313 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2314 return out, metadata, &smithy.SerializationError{Err: err} 2315 } 2316 in.Request = request 2317 2318 return next.HandleSerialize(ctx, in) 2319} 2320 2321type awsAwsjson11_serializeOpStartReplicationTask struct { 2322} 2323 2324func (*awsAwsjson11_serializeOpStartReplicationTask) ID() string { 2325 return "OperationSerializer" 2326} 2327 2328func (m *awsAwsjson11_serializeOpStartReplicationTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2329 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2330) { 2331 request, ok := in.Request.(*smithyhttp.Request) 2332 if !ok { 2333 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2334 } 2335 2336 input, ok := in.Parameters.(*StartReplicationTaskInput) 2337 _ = input 2338 if !ok { 2339 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2340 } 2341 2342 request.Request.URL.Path = "/" 2343 request.Request.Method = "POST" 2344 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2345 if err != nil { 2346 return out, metadata, &smithy.SerializationError{Err: err} 2347 } 2348 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2349 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.StartReplicationTask") 2350 2351 jsonEncoder := smithyjson.NewEncoder() 2352 if err := awsAwsjson11_serializeOpDocumentStartReplicationTaskInput(input, jsonEncoder.Value); err != nil { 2353 return out, metadata, &smithy.SerializationError{Err: err} 2354 } 2355 2356 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2357 return out, metadata, &smithy.SerializationError{Err: err} 2358 } 2359 2360 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2361 return out, metadata, &smithy.SerializationError{Err: err} 2362 } 2363 in.Request = request 2364 2365 return next.HandleSerialize(ctx, in) 2366} 2367 2368type awsAwsjson11_serializeOpStartReplicationTaskAssessment struct { 2369} 2370 2371func (*awsAwsjson11_serializeOpStartReplicationTaskAssessment) ID() string { 2372 return "OperationSerializer" 2373} 2374 2375func (m *awsAwsjson11_serializeOpStartReplicationTaskAssessment) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2376 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2377) { 2378 request, ok := in.Request.(*smithyhttp.Request) 2379 if !ok { 2380 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2381 } 2382 2383 input, ok := in.Parameters.(*StartReplicationTaskAssessmentInput) 2384 _ = input 2385 if !ok { 2386 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2387 } 2388 2389 request.Request.URL.Path = "/" 2390 request.Request.Method = "POST" 2391 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2392 if err != nil { 2393 return out, metadata, &smithy.SerializationError{Err: err} 2394 } 2395 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2396 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.StartReplicationTaskAssessment") 2397 2398 jsonEncoder := smithyjson.NewEncoder() 2399 if err := awsAwsjson11_serializeOpDocumentStartReplicationTaskAssessmentInput(input, jsonEncoder.Value); err != nil { 2400 return out, metadata, &smithy.SerializationError{Err: err} 2401 } 2402 2403 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2404 return out, metadata, &smithy.SerializationError{Err: err} 2405 } 2406 2407 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2408 return out, metadata, &smithy.SerializationError{Err: err} 2409 } 2410 in.Request = request 2411 2412 return next.HandleSerialize(ctx, in) 2413} 2414 2415type awsAwsjson11_serializeOpStartReplicationTaskAssessmentRun struct { 2416} 2417 2418func (*awsAwsjson11_serializeOpStartReplicationTaskAssessmentRun) ID() string { 2419 return "OperationSerializer" 2420} 2421 2422func (m *awsAwsjson11_serializeOpStartReplicationTaskAssessmentRun) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2423 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2424) { 2425 request, ok := in.Request.(*smithyhttp.Request) 2426 if !ok { 2427 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2428 } 2429 2430 input, ok := in.Parameters.(*StartReplicationTaskAssessmentRunInput) 2431 _ = input 2432 if !ok { 2433 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2434 } 2435 2436 request.Request.URL.Path = "/" 2437 request.Request.Method = "POST" 2438 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2439 if err != nil { 2440 return out, metadata, &smithy.SerializationError{Err: err} 2441 } 2442 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2443 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.StartReplicationTaskAssessmentRun") 2444 2445 jsonEncoder := smithyjson.NewEncoder() 2446 if err := awsAwsjson11_serializeOpDocumentStartReplicationTaskAssessmentRunInput(input, jsonEncoder.Value); err != nil { 2447 return out, metadata, &smithy.SerializationError{Err: err} 2448 } 2449 2450 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2451 return out, metadata, &smithy.SerializationError{Err: err} 2452 } 2453 2454 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2455 return out, metadata, &smithy.SerializationError{Err: err} 2456 } 2457 in.Request = request 2458 2459 return next.HandleSerialize(ctx, in) 2460} 2461 2462type awsAwsjson11_serializeOpStopReplicationTask struct { 2463} 2464 2465func (*awsAwsjson11_serializeOpStopReplicationTask) ID() string { 2466 return "OperationSerializer" 2467} 2468 2469func (m *awsAwsjson11_serializeOpStopReplicationTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2470 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2471) { 2472 request, ok := in.Request.(*smithyhttp.Request) 2473 if !ok { 2474 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2475 } 2476 2477 input, ok := in.Parameters.(*StopReplicationTaskInput) 2478 _ = input 2479 if !ok { 2480 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2481 } 2482 2483 request.Request.URL.Path = "/" 2484 request.Request.Method = "POST" 2485 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2486 if err != nil { 2487 return out, metadata, &smithy.SerializationError{Err: err} 2488 } 2489 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2490 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.StopReplicationTask") 2491 2492 jsonEncoder := smithyjson.NewEncoder() 2493 if err := awsAwsjson11_serializeOpDocumentStopReplicationTaskInput(input, jsonEncoder.Value); err != nil { 2494 return out, metadata, &smithy.SerializationError{Err: err} 2495 } 2496 2497 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2498 return out, metadata, &smithy.SerializationError{Err: err} 2499 } 2500 2501 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2502 return out, metadata, &smithy.SerializationError{Err: err} 2503 } 2504 in.Request = request 2505 2506 return next.HandleSerialize(ctx, in) 2507} 2508 2509type awsAwsjson11_serializeOpTestConnection struct { 2510} 2511 2512func (*awsAwsjson11_serializeOpTestConnection) ID() string { 2513 return "OperationSerializer" 2514} 2515 2516func (m *awsAwsjson11_serializeOpTestConnection) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( 2517 out middleware.SerializeOutput, metadata middleware.Metadata, err error, 2518) { 2519 request, ok := in.Request.(*smithyhttp.Request) 2520 if !ok { 2521 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)} 2522 } 2523 2524 input, ok := in.Parameters.(*TestConnectionInput) 2525 _ = input 2526 if !ok { 2527 return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)} 2528 } 2529 2530 request.Request.URL.Path = "/" 2531 request.Request.Method = "POST" 2532 httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header) 2533 if err != nil { 2534 return out, metadata, &smithy.SerializationError{Err: err} 2535 } 2536 httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1") 2537 httpBindingEncoder.SetHeader("X-Amz-Target").String("AmazonDMSv20160101.TestConnection") 2538 2539 jsonEncoder := smithyjson.NewEncoder() 2540 if err := awsAwsjson11_serializeOpDocumentTestConnectionInput(input, jsonEncoder.Value); err != nil { 2541 return out, metadata, &smithy.SerializationError{Err: err} 2542 } 2543 2544 if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil { 2545 return out, metadata, &smithy.SerializationError{Err: err} 2546 } 2547 2548 if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil { 2549 return out, metadata, &smithy.SerializationError{Err: err} 2550 } 2551 in.Request = request 2552 2553 return next.HandleSerialize(ctx, in) 2554} 2555func awsAwsjson11_serializeDocumentDmsTransferSettings(v *types.DmsTransferSettings, value smithyjson.Value) error { 2556 object := value.Object() 2557 defer object.Close() 2558 2559 if v.BucketName != nil { 2560 ok := object.Key("BucketName") 2561 ok.String(*v.BucketName) 2562 } 2563 2564 if v.ServiceAccessRoleArn != nil { 2565 ok := object.Key("ServiceAccessRoleArn") 2566 ok.String(*v.ServiceAccessRoleArn) 2567 } 2568 2569 return nil 2570} 2571 2572func awsAwsjson11_serializeDocumentDocDbSettings(v *types.DocDbSettings, value smithyjson.Value) error { 2573 object := value.Object() 2574 defer object.Close() 2575 2576 if v.DatabaseName != nil { 2577 ok := object.Key("DatabaseName") 2578 ok.String(*v.DatabaseName) 2579 } 2580 2581 if v.DocsToInvestigate != nil { 2582 ok := object.Key("DocsToInvestigate") 2583 ok.Integer(*v.DocsToInvestigate) 2584 } 2585 2586 if v.ExtractDocId != nil { 2587 ok := object.Key("ExtractDocId") 2588 ok.Boolean(*v.ExtractDocId) 2589 } 2590 2591 if v.KmsKeyId != nil { 2592 ok := object.Key("KmsKeyId") 2593 ok.String(*v.KmsKeyId) 2594 } 2595 2596 if len(v.NestingLevel) > 0 { 2597 ok := object.Key("NestingLevel") 2598 ok.String(string(v.NestingLevel)) 2599 } 2600 2601 if v.Password != nil { 2602 ok := object.Key("Password") 2603 ok.String(*v.Password) 2604 } 2605 2606 if v.Port != nil { 2607 ok := object.Key("Port") 2608 ok.Integer(*v.Port) 2609 } 2610 2611 if v.SecretsManagerAccessRoleArn != nil { 2612 ok := object.Key("SecretsManagerAccessRoleArn") 2613 ok.String(*v.SecretsManagerAccessRoleArn) 2614 } 2615 2616 if v.SecretsManagerSecretId != nil { 2617 ok := object.Key("SecretsManagerSecretId") 2618 ok.String(*v.SecretsManagerSecretId) 2619 } 2620 2621 if v.ServerName != nil { 2622 ok := object.Key("ServerName") 2623 ok.String(*v.ServerName) 2624 } 2625 2626 if v.Username != nil { 2627 ok := object.Key("Username") 2628 ok.String(*v.Username) 2629 } 2630 2631 return nil 2632} 2633 2634func awsAwsjson11_serializeDocumentDynamoDbSettings(v *types.DynamoDbSettings, value smithyjson.Value) error { 2635 object := value.Object() 2636 defer object.Close() 2637 2638 if v.ServiceAccessRoleArn != nil { 2639 ok := object.Key("ServiceAccessRoleArn") 2640 ok.String(*v.ServiceAccessRoleArn) 2641 } 2642 2643 return nil 2644} 2645 2646func awsAwsjson11_serializeDocumentElasticsearchSettings(v *types.ElasticsearchSettings, value smithyjson.Value) error { 2647 object := value.Object() 2648 defer object.Close() 2649 2650 if v.EndpointUri != nil { 2651 ok := object.Key("EndpointUri") 2652 ok.String(*v.EndpointUri) 2653 } 2654 2655 if v.ErrorRetryDuration != nil { 2656 ok := object.Key("ErrorRetryDuration") 2657 ok.Integer(*v.ErrorRetryDuration) 2658 } 2659 2660 if v.FullLoadErrorPercentage != nil { 2661 ok := object.Key("FullLoadErrorPercentage") 2662 ok.Integer(*v.FullLoadErrorPercentage) 2663 } 2664 2665 if v.ServiceAccessRoleArn != nil { 2666 ok := object.Key("ServiceAccessRoleArn") 2667 ok.String(*v.ServiceAccessRoleArn) 2668 } 2669 2670 return nil 2671} 2672 2673func awsAwsjson11_serializeDocumentEventCategoriesList(v []string, value smithyjson.Value) error { 2674 array := value.Array() 2675 defer array.Close() 2676 2677 for i := range v { 2678 av := array.Value() 2679 av.String(v[i]) 2680 } 2681 return nil 2682} 2683 2684func awsAwsjson11_serializeDocumentExcludeTestList(v []string, value smithyjson.Value) error { 2685 array := value.Array() 2686 defer array.Close() 2687 2688 for i := range v { 2689 av := array.Value() 2690 av.String(v[i]) 2691 } 2692 return nil 2693} 2694 2695func awsAwsjson11_serializeDocumentFilter(v *types.Filter, value smithyjson.Value) error { 2696 object := value.Object() 2697 defer object.Close() 2698 2699 if v.Name != nil { 2700 ok := object.Key("Name") 2701 ok.String(*v.Name) 2702 } 2703 2704 if v.Values != nil { 2705 ok := object.Key("Values") 2706 if err := awsAwsjson11_serializeDocumentFilterValueList(v.Values, ok); err != nil { 2707 return err 2708 } 2709 } 2710 2711 return nil 2712} 2713 2714func awsAwsjson11_serializeDocumentFilterList(v []types.Filter, value smithyjson.Value) error { 2715 array := value.Array() 2716 defer array.Close() 2717 2718 for i := range v { 2719 av := array.Value() 2720 if err := awsAwsjson11_serializeDocumentFilter(&v[i], av); err != nil { 2721 return err 2722 } 2723 } 2724 return nil 2725} 2726 2727func awsAwsjson11_serializeDocumentFilterValueList(v []string, value smithyjson.Value) error { 2728 array := value.Array() 2729 defer array.Close() 2730 2731 for i := range v { 2732 av := array.Value() 2733 av.String(v[i]) 2734 } 2735 return nil 2736} 2737 2738func awsAwsjson11_serializeDocumentIBMDb2Settings(v *types.IBMDb2Settings, value smithyjson.Value) error { 2739 object := value.Object() 2740 defer object.Close() 2741 2742 if v.CurrentLsn != nil { 2743 ok := object.Key("CurrentLsn") 2744 ok.String(*v.CurrentLsn) 2745 } 2746 2747 if v.DatabaseName != nil { 2748 ok := object.Key("DatabaseName") 2749 ok.String(*v.DatabaseName) 2750 } 2751 2752 if v.MaxKBytesPerRead != nil { 2753 ok := object.Key("MaxKBytesPerRead") 2754 ok.Integer(*v.MaxKBytesPerRead) 2755 } 2756 2757 if v.Password != nil { 2758 ok := object.Key("Password") 2759 ok.String(*v.Password) 2760 } 2761 2762 if v.Port != nil { 2763 ok := object.Key("Port") 2764 ok.Integer(*v.Port) 2765 } 2766 2767 if v.SecretsManagerAccessRoleArn != nil { 2768 ok := object.Key("SecretsManagerAccessRoleArn") 2769 ok.String(*v.SecretsManagerAccessRoleArn) 2770 } 2771 2772 if v.SecretsManagerSecretId != nil { 2773 ok := object.Key("SecretsManagerSecretId") 2774 ok.String(*v.SecretsManagerSecretId) 2775 } 2776 2777 if v.ServerName != nil { 2778 ok := object.Key("ServerName") 2779 ok.String(*v.ServerName) 2780 } 2781 2782 if v.SetDataCaptureChanges != nil { 2783 ok := object.Key("SetDataCaptureChanges") 2784 ok.Boolean(*v.SetDataCaptureChanges) 2785 } 2786 2787 if v.Username != nil { 2788 ok := object.Key("Username") 2789 ok.String(*v.Username) 2790 } 2791 2792 return nil 2793} 2794 2795func awsAwsjson11_serializeDocumentIncludeTestList(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_serializeDocumentKafkaSettings(v *types.KafkaSettings, value smithyjson.Value) error { 2807 object := value.Object() 2808 defer object.Close() 2809 2810 if v.Broker != nil { 2811 ok := object.Key("Broker") 2812 ok.String(*v.Broker) 2813 } 2814 2815 if v.IncludeControlDetails != nil { 2816 ok := object.Key("IncludeControlDetails") 2817 ok.Boolean(*v.IncludeControlDetails) 2818 } 2819 2820 if v.IncludeNullAndEmpty != nil { 2821 ok := object.Key("IncludeNullAndEmpty") 2822 ok.Boolean(*v.IncludeNullAndEmpty) 2823 } 2824 2825 if v.IncludePartitionValue != nil { 2826 ok := object.Key("IncludePartitionValue") 2827 ok.Boolean(*v.IncludePartitionValue) 2828 } 2829 2830 if v.IncludeTableAlterOperations != nil { 2831 ok := object.Key("IncludeTableAlterOperations") 2832 ok.Boolean(*v.IncludeTableAlterOperations) 2833 } 2834 2835 if v.IncludeTransactionDetails != nil { 2836 ok := object.Key("IncludeTransactionDetails") 2837 ok.Boolean(*v.IncludeTransactionDetails) 2838 } 2839 2840 if len(v.MessageFormat) > 0 { 2841 ok := object.Key("MessageFormat") 2842 ok.String(string(v.MessageFormat)) 2843 } 2844 2845 if v.MessageMaxBytes != nil { 2846 ok := object.Key("MessageMaxBytes") 2847 ok.Integer(*v.MessageMaxBytes) 2848 } 2849 2850 if v.PartitionIncludeSchemaTable != nil { 2851 ok := object.Key("PartitionIncludeSchemaTable") 2852 ok.Boolean(*v.PartitionIncludeSchemaTable) 2853 } 2854 2855 if v.Topic != nil { 2856 ok := object.Key("Topic") 2857 ok.String(*v.Topic) 2858 } 2859 2860 return nil 2861} 2862 2863func awsAwsjson11_serializeDocumentKeyList(v []string, value smithyjson.Value) error { 2864 array := value.Array() 2865 defer array.Close() 2866 2867 for i := range v { 2868 av := array.Value() 2869 av.String(v[i]) 2870 } 2871 return nil 2872} 2873 2874func awsAwsjson11_serializeDocumentKinesisSettings(v *types.KinesisSettings, value smithyjson.Value) error { 2875 object := value.Object() 2876 defer object.Close() 2877 2878 if v.IncludeControlDetails != nil { 2879 ok := object.Key("IncludeControlDetails") 2880 ok.Boolean(*v.IncludeControlDetails) 2881 } 2882 2883 if v.IncludeNullAndEmpty != nil { 2884 ok := object.Key("IncludeNullAndEmpty") 2885 ok.Boolean(*v.IncludeNullAndEmpty) 2886 } 2887 2888 if v.IncludePartitionValue != nil { 2889 ok := object.Key("IncludePartitionValue") 2890 ok.Boolean(*v.IncludePartitionValue) 2891 } 2892 2893 if v.IncludeTableAlterOperations != nil { 2894 ok := object.Key("IncludeTableAlterOperations") 2895 ok.Boolean(*v.IncludeTableAlterOperations) 2896 } 2897 2898 if v.IncludeTransactionDetails != nil { 2899 ok := object.Key("IncludeTransactionDetails") 2900 ok.Boolean(*v.IncludeTransactionDetails) 2901 } 2902 2903 if len(v.MessageFormat) > 0 { 2904 ok := object.Key("MessageFormat") 2905 ok.String(string(v.MessageFormat)) 2906 } 2907 2908 if v.PartitionIncludeSchemaTable != nil { 2909 ok := object.Key("PartitionIncludeSchemaTable") 2910 ok.Boolean(*v.PartitionIncludeSchemaTable) 2911 } 2912 2913 if v.ServiceAccessRoleArn != nil { 2914 ok := object.Key("ServiceAccessRoleArn") 2915 ok.String(*v.ServiceAccessRoleArn) 2916 } 2917 2918 if v.StreamArn != nil { 2919 ok := object.Key("StreamArn") 2920 ok.String(*v.StreamArn) 2921 } 2922 2923 return nil 2924} 2925 2926func awsAwsjson11_serializeDocumentMicrosoftSQLServerSettings(v *types.MicrosoftSQLServerSettings, value smithyjson.Value) error { 2927 object := value.Object() 2928 defer object.Close() 2929 2930 if v.BcpPacketSize != nil { 2931 ok := object.Key("BcpPacketSize") 2932 ok.Integer(*v.BcpPacketSize) 2933 } 2934 2935 if v.ControlTablesFileGroup != nil { 2936 ok := object.Key("ControlTablesFileGroup") 2937 ok.String(*v.ControlTablesFileGroup) 2938 } 2939 2940 if v.DatabaseName != nil { 2941 ok := object.Key("DatabaseName") 2942 ok.String(*v.DatabaseName) 2943 } 2944 2945 if v.Password != nil { 2946 ok := object.Key("Password") 2947 ok.String(*v.Password) 2948 } 2949 2950 if v.Port != nil { 2951 ok := object.Key("Port") 2952 ok.Integer(*v.Port) 2953 } 2954 2955 if v.ReadBackupOnly != nil { 2956 ok := object.Key("ReadBackupOnly") 2957 ok.Boolean(*v.ReadBackupOnly) 2958 } 2959 2960 if len(v.SafeguardPolicy) > 0 { 2961 ok := object.Key("SafeguardPolicy") 2962 ok.String(string(v.SafeguardPolicy)) 2963 } 2964 2965 if v.SecretsManagerAccessRoleArn != nil { 2966 ok := object.Key("SecretsManagerAccessRoleArn") 2967 ok.String(*v.SecretsManagerAccessRoleArn) 2968 } 2969 2970 if v.SecretsManagerSecretId != nil { 2971 ok := object.Key("SecretsManagerSecretId") 2972 ok.String(*v.SecretsManagerSecretId) 2973 } 2974 2975 if v.ServerName != nil { 2976 ok := object.Key("ServerName") 2977 ok.String(*v.ServerName) 2978 } 2979 2980 if v.UseBcpFullLoad != nil { 2981 ok := object.Key("UseBcpFullLoad") 2982 ok.Boolean(*v.UseBcpFullLoad) 2983 } 2984 2985 if v.Username != nil { 2986 ok := object.Key("Username") 2987 ok.String(*v.Username) 2988 } 2989 2990 return nil 2991} 2992 2993func awsAwsjson11_serializeDocumentMongoDbSettings(v *types.MongoDbSettings, value smithyjson.Value) error { 2994 object := value.Object() 2995 defer object.Close() 2996 2997 if len(v.AuthMechanism) > 0 { 2998 ok := object.Key("AuthMechanism") 2999 ok.String(string(v.AuthMechanism)) 3000 } 3001 3002 if v.AuthSource != nil { 3003 ok := object.Key("AuthSource") 3004 ok.String(*v.AuthSource) 3005 } 3006 3007 if len(v.AuthType) > 0 { 3008 ok := object.Key("AuthType") 3009 ok.String(string(v.AuthType)) 3010 } 3011 3012 if v.DatabaseName != nil { 3013 ok := object.Key("DatabaseName") 3014 ok.String(*v.DatabaseName) 3015 } 3016 3017 if v.DocsToInvestigate != nil { 3018 ok := object.Key("DocsToInvestigate") 3019 ok.String(*v.DocsToInvestigate) 3020 } 3021 3022 if v.ExtractDocId != nil { 3023 ok := object.Key("ExtractDocId") 3024 ok.String(*v.ExtractDocId) 3025 } 3026 3027 if v.KmsKeyId != nil { 3028 ok := object.Key("KmsKeyId") 3029 ok.String(*v.KmsKeyId) 3030 } 3031 3032 if len(v.NestingLevel) > 0 { 3033 ok := object.Key("NestingLevel") 3034 ok.String(string(v.NestingLevel)) 3035 } 3036 3037 if v.Password != nil { 3038 ok := object.Key("Password") 3039 ok.String(*v.Password) 3040 } 3041 3042 if v.Port != nil { 3043 ok := object.Key("Port") 3044 ok.Integer(*v.Port) 3045 } 3046 3047 if v.SecretsManagerAccessRoleArn != nil { 3048 ok := object.Key("SecretsManagerAccessRoleArn") 3049 ok.String(*v.SecretsManagerAccessRoleArn) 3050 } 3051 3052 if v.SecretsManagerSecretId != nil { 3053 ok := object.Key("SecretsManagerSecretId") 3054 ok.String(*v.SecretsManagerSecretId) 3055 } 3056 3057 if v.ServerName != nil { 3058 ok := object.Key("ServerName") 3059 ok.String(*v.ServerName) 3060 } 3061 3062 if v.Username != nil { 3063 ok := object.Key("Username") 3064 ok.String(*v.Username) 3065 } 3066 3067 return nil 3068} 3069 3070func awsAwsjson11_serializeDocumentMySQLSettings(v *types.MySQLSettings, value smithyjson.Value) error { 3071 object := value.Object() 3072 defer object.Close() 3073 3074 if v.AfterConnectScript != nil { 3075 ok := object.Key("AfterConnectScript") 3076 ok.String(*v.AfterConnectScript) 3077 } 3078 3079 if v.DatabaseName != nil { 3080 ok := object.Key("DatabaseName") 3081 ok.String(*v.DatabaseName) 3082 } 3083 3084 if v.EventsPollInterval != nil { 3085 ok := object.Key("EventsPollInterval") 3086 ok.Integer(*v.EventsPollInterval) 3087 } 3088 3089 if v.MaxFileSize != nil { 3090 ok := object.Key("MaxFileSize") 3091 ok.Integer(*v.MaxFileSize) 3092 } 3093 3094 if v.ParallelLoadThreads != nil { 3095 ok := object.Key("ParallelLoadThreads") 3096 ok.Integer(*v.ParallelLoadThreads) 3097 } 3098 3099 if v.Password != nil { 3100 ok := object.Key("Password") 3101 ok.String(*v.Password) 3102 } 3103 3104 if v.Port != nil { 3105 ok := object.Key("Port") 3106 ok.Integer(*v.Port) 3107 } 3108 3109 if v.SecretsManagerAccessRoleArn != nil { 3110 ok := object.Key("SecretsManagerAccessRoleArn") 3111 ok.String(*v.SecretsManagerAccessRoleArn) 3112 } 3113 3114 if v.SecretsManagerSecretId != nil { 3115 ok := object.Key("SecretsManagerSecretId") 3116 ok.String(*v.SecretsManagerSecretId) 3117 } 3118 3119 if v.ServerName != nil { 3120 ok := object.Key("ServerName") 3121 ok.String(*v.ServerName) 3122 } 3123 3124 if v.ServerTimezone != nil { 3125 ok := object.Key("ServerTimezone") 3126 ok.String(*v.ServerTimezone) 3127 } 3128 3129 if len(v.TargetDbType) > 0 { 3130 ok := object.Key("TargetDbType") 3131 ok.String(string(v.TargetDbType)) 3132 } 3133 3134 if v.Username != nil { 3135 ok := object.Key("Username") 3136 ok.String(*v.Username) 3137 } 3138 3139 return nil 3140} 3141 3142func awsAwsjson11_serializeDocumentNeptuneSettings(v *types.NeptuneSettings, value smithyjson.Value) error { 3143 object := value.Object() 3144 defer object.Close() 3145 3146 if v.ErrorRetryDuration != nil { 3147 ok := object.Key("ErrorRetryDuration") 3148 ok.Integer(*v.ErrorRetryDuration) 3149 } 3150 3151 if v.IamAuthEnabled != nil { 3152 ok := object.Key("IamAuthEnabled") 3153 ok.Boolean(*v.IamAuthEnabled) 3154 } 3155 3156 if v.MaxFileSize != nil { 3157 ok := object.Key("MaxFileSize") 3158 ok.Integer(*v.MaxFileSize) 3159 } 3160 3161 if v.MaxRetryCount != nil { 3162 ok := object.Key("MaxRetryCount") 3163 ok.Integer(*v.MaxRetryCount) 3164 } 3165 3166 if v.S3BucketFolder != nil { 3167 ok := object.Key("S3BucketFolder") 3168 ok.String(*v.S3BucketFolder) 3169 } 3170 3171 if v.S3BucketName != nil { 3172 ok := object.Key("S3BucketName") 3173 ok.String(*v.S3BucketName) 3174 } 3175 3176 if v.ServiceAccessRoleArn != nil { 3177 ok := object.Key("ServiceAccessRoleArn") 3178 ok.String(*v.ServiceAccessRoleArn) 3179 } 3180 3181 return nil 3182} 3183 3184func awsAwsjson11_serializeDocumentOracleSettings(v *types.OracleSettings, value smithyjson.Value) error { 3185 object := value.Object() 3186 defer object.Close() 3187 3188 if v.AccessAlternateDirectly != nil { 3189 ok := object.Key("AccessAlternateDirectly") 3190 ok.Boolean(*v.AccessAlternateDirectly) 3191 } 3192 3193 if v.AdditionalArchivedLogDestId != nil { 3194 ok := object.Key("AdditionalArchivedLogDestId") 3195 ok.Integer(*v.AdditionalArchivedLogDestId) 3196 } 3197 3198 if v.AddSupplementalLogging != nil { 3199 ok := object.Key("AddSupplementalLogging") 3200 ok.Boolean(*v.AddSupplementalLogging) 3201 } 3202 3203 if v.AllowSelectNestedTables != nil { 3204 ok := object.Key("AllowSelectNestedTables") 3205 ok.Boolean(*v.AllowSelectNestedTables) 3206 } 3207 3208 if v.ArchivedLogDestId != nil { 3209 ok := object.Key("ArchivedLogDestId") 3210 ok.Integer(*v.ArchivedLogDestId) 3211 } 3212 3213 if v.ArchivedLogsOnly != nil { 3214 ok := object.Key("ArchivedLogsOnly") 3215 ok.Boolean(*v.ArchivedLogsOnly) 3216 } 3217 3218 if v.AsmPassword != nil { 3219 ok := object.Key("AsmPassword") 3220 ok.String(*v.AsmPassword) 3221 } 3222 3223 if v.AsmServer != nil { 3224 ok := object.Key("AsmServer") 3225 ok.String(*v.AsmServer) 3226 } 3227 3228 if v.AsmUser != nil { 3229 ok := object.Key("AsmUser") 3230 ok.String(*v.AsmUser) 3231 } 3232 3233 if len(v.CharLengthSemantics) > 0 { 3234 ok := object.Key("CharLengthSemantics") 3235 ok.String(string(v.CharLengthSemantics)) 3236 } 3237 3238 if v.DatabaseName != nil { 3239 ok := object.Key("DatabaseName") 3240 ok.String(*v.DatabaseName) 3241 } 3242 3243 if v.DirectPathNoLog != nil { 3244 ok := object.Key("DirectPathNoLog") 3245 ok.Boolean(*v.DirectPathNoLog) 3246 } 3247 3248 if v.DirectPathParallelLoad != nil { 3249 ok := object.Key("DirectPathParallelLoad") 3250 ok.Boolean(*v.DirectPathParallelLoad) 3251 } 3252 3253 if v.EnableHomogenousTablespace != nil { 3254 ok := object.Key("EnableHomogenousTablespace") 3255 ok.Boolean(*v.EnableHomogenousTablespace) 3256 } 3257 3258 if v.FailTasksOnLobTruncation != nil { 3259 ok := object.Key("FailTasksOnLobTruncation") 3260 ok.Boolean(*v.FailTasksOnLobTruncation) 3261 } 3262 3263 if v.NumberDatatypeScale != nil { 3264 ok := object.Key("NumberDatatypeScale") 3265 ok.Integer(*v.NumberDatatypeScale) 3266 } 3267 3268 if v.OraclePathPrefix != nil { 3269 ok := object.Key("OraclePathPrefix") 3270 ok.String(*v.OraclePathPrefix) 3271 } 3272 3273 if v.ParallelAsmReadThreads != nil { 3274 ok := object.Key("ParallelAsmReadThreads") 3275 ok.Integer(*v.ParallelAsmReadThreads) 3276 } 3277 3278 if v.Password != nil { 3279 ok := object.Key("Password") 3280 ok.String(*v.Password) 3281 } 3282 3283 if v.Port != nil { 3284 ok := object.Key("Port") 3285 ok.Integer(*v.Port) 3286 } 3287 3288 if v.ReadAheadBlocks != nil { 3289 ok := object.Key("ReadAheadBlocks") 3290 ok.Integer(*v.ReadAheadBlocks) 3291 } 3292 3293 if v.ReadTableSpaceName != nil { 3294 ok := object.Key("ReadTableSpaceName") 3295 ok.Boolean(*v.ReadTableSpaceName) 3296 } 3297 3298 if v.ReplacePathPrefix != nil { 3299 ok := object.Key("ReplacePathPrefix") 3300 ok.Boolean(*v.ReplacePathPrefix) 3301 } 3302 3303 if v.RetryInterval != nil { 3304 ok := object.Key("RetryInterval") 3305 ok.Integer(*v.RetryInterval) 3306 } 3307 3308 if v.SecretsManagerAccessRoleArn != nil { 3309 ok := object.Key("SecretsManagerAccessRoleArn") 3310 ok.String(*v.SecretsManagerAccessRoleArn) 3311 } 3312 3313 if v.SecretsManagerOracleAsmAccessRoleArn != nil { 3314 ok := object.Key("SecretsManagerOracleAsmAccessRoleArn") 3315 ok.String(*v.SecretsManagerOracleAsmAccessRoleArn) 3316 } 3317 3318 if v.SecretsManagerOracleAsmSecretId != nil { 3319 ok := object.Key("SecretsManagerOracleAsmSecretId") 3320 ok.String(*v.SecretsManagerOracleAsmSecretId) 3321 } 3322 3323 if v.SecretsManagerSecretId != nil { 3324 ok := object.Key("SecretsManagerSecretId") 3325 ok.String(*v.SecretsManagerSecretId) 3326 } 3327 3328 if v.SecurityDbEncryption != nil { 3329 ok := object.Key("SecurityDbEncryption") 3330 ok.String(*v.SecurityDbEncryption) 3331 } 3332 3333 if v.SecurityDbEncryptionName != nil { 3334 ok := object.Key("SecurityDbEncryptionName") 3335 ok.String(*v.SecurityDbEncryptionName) 3336 } 3337 3338 if v.ServerName != nil { 3339 ok := object.Key("ServerName") 3340 ok.String(*v.ServerName) 3341 } 3342 3343 if v.UseAlternateFolderForOnline != nil { 3344 ok := object.Key("UseAlternateFolderForOnline") 3345 ok.Boolean(*v.UseAlternateFolderForOnline) 3346 } 3347 3348 if v.UsePathPrefix != nil { 3349 ok := object.Key("UsePathPrefix") 3350 ok.String(*v.UsePathPrefix) 3351 } 3352 3353 if v.Username != nil { 3354 ok := object.Key("Username") 3355 ok.String(*v.Username) 3356 } 3357 3358 return nil 3359} 3360 3361func awsAwsjson11_serializeDocumentPostgreSQLSettings(v *types.PostgreSQLSettings, value smithyjson.Value) error { 3362 object := value.Object() 3363 defer object.Close() 3364 3365 if v.AfterConnectScript != nil { 3366 ok := object.Key("AfterConnectScript") 3367 ok.String(*v.AfterConnectScript) 3368 } 3369 3370 if v.CaptureDdls != nil { 3371 ok := object.Key("CaptureDdls") 3372 ok.Boolean(*v.CaptureDdls) 3373 } 3374 3375 if v.DatabaseName != nil { 3376 ok := object.Key("DatabaseName") 3377 ok.String(*v.DatabaseName) 3378 } 3379 3380 if v.DdlArtifactsSchema != nil { 3381 ok := object.Key("DdlArtifactsSchema") 3382 ok.String(*v.DdlArtifactsSchema) 3383 } 3384 3385 if v.ExecuteTimeout != nil { 3386 ok := object.Key("ExecuteTimeout") 3387 ok.Integer(*v.ExecuteTimeout) 3388 } 3389 3390 if v.FailTasksOnLobTruncation != nil { 3391 ok := object.Key("FailTasksOnLobTruncation") 3392 ok.Boolean(*v.FailTasksOnLobTruncation) 3393 } 3394 3395 if v.MaxFileSize != nil { 3396 ok := object.Key("MaxFileSize") 3397 ok.Integer(*v.MaxFileSize) 3398 } 3399 3400 if v.Password != nil { 3401 ok := object.Key("Password") 3402 ok.String(*v.Password) 3403 } 3404 3405 if v.Port != nil { 3406 ok := object.Key("Port") 3407 ok.Integer(*v.Port) 3408 } 3409 3410 if v.SecretsManagerAccessRoleArn != nil { 3411 ok := object.Key("SecretsManagerAccessRoleArn") 3412 ok.String(*v.SecretsManagerAccessRoleArn) 3413 } 3414 3415 if v.SecretsManagerSecretId != nil { 3416 ok := object.Key("SecretsManagerSecretId") 3417 ok.String(*v.SecretsManagerSecretId) 3418 } 3419 3420 if v.ServerName != nil { 3421 ok := object.Key("ServerName") 3422 ok.String(*v.ServerName) 3423 } 3424 3425 if v.SlotName != nil { 3426 ok := object.Key("SlotName") 3427 ok.String(*v.SlotName) 3428 } 3429 3430 if v.Username != nil { 3431 ok := object.Key("Username") 3432 ok.String(*v.Username) 3433 } 3434 3435 return nil 3436} 3437 3438func awsAwsjson11_serializeDocumentRedshiftSettings(v *types.RedshiftSettings, value smithyjson.Value) error { 3439 object := value.Object() 3440 defer object.Close() 3441 3442 if v.AcceptAnyDate != nil { 3443 ok := object.Key("AcceptAnyDate") 3444 ok.Boolean(*v.AcceptAnyDate) 3445 } 3446 3447 if v.AfterConnectScript != nil { 3448 ok := object.Key("AfterConnectScript") 3449 ok.String(*v.AfterConnectScript) 3450 } 3451 3452 if v.BucketFolder != nil { 3453 ok := object.Key("BucketFolder") 3454 ok.String(*v.BucketFolder) 3455 } 3456 3457 if v.BucketName != nil { 3458 ok := object.Key("BucketName") 3459 ok.String(*v.BucketName) 3460 } 3461 3462 if v.CaseSensitiveNames != nil { 3463 ok := object.Key("CaseSensitiveNames") 3464 ok.Boolean(*v.CaseSensitiveNames) 3465 } 3466 3467 if v.CompUpdate != nil { 3468 ok := object.Key("CompUpdate") 3469 ok.Boolean(*v.CompUpdate) 3470 } 3471 3472 if v.ConnectionTimeout != nil { 3473 ok := object.Key("ConnectionTimeout") 3474 ok.Integer(*v.ConnectionTimeout) 3475 } 3476 3477 if v.DatabaseName != nil { 3478 ok := object.Key("DatabaseName") 3479 ok.String(*v.DatabaseName) 3480 } 3481 3482 if v.DateFormat != nil { 3483 ok := object.Key("DateFormat") 3484 ok.String(*v.DateFormat) 3485 } 3486 3487 if v.EmptyAsNull != nil { 3488 ok := object.Key("EmptyAsNull") 3489 ok.Boolean(*v.EmptyAsNull) 3490 } 3491 3492 if len(v.EncryptionMode) > 0 { 3493 ok := object.Key("EncryptionMode") 3494 ok.String(string(v.EncryptionMode)) 3495 } 3496 3497 if v.ExplicitIds != nil { 3498 ok := object.Key("ExplicitIds") 3499 ok.Boolean(*v.ExplicitIds) 3500 } 3501 3502 if v.FileTransferUploadStreams != nil { 3503 ok := object.Key("FileTransferUploadStreams") 3504 ok.Integer(*v.FileTransferUploadStreams) 3505 } 3506 3507 if v.LoadTimeout != nil { 3508 ok := object.Key("LoadTimeout") 3509 ok.Integer(*v.LoadTimeout) 3510 } 3511 3512 if v.MaxFileSize != nil { 3513 ok := object.Key("MaxFileSize") 3514 ok.Integer(*v.MaxFileSize) 3515 } 3516 3517 if v.Password != nil { 3518 ok := object.Key("Password") 3519 ok.String(*v.Password) 3520 } 3521 3522 if v.Port != nil { 3523 ok := object.Key("Port") 3524 ok.Integer(*v.Port) 3525 } 3526 3527 if v.RemoveQuotes != nil { 3528 ok := object.Key("RemoveQuotes") 3529 ok.Boolean(*v.RemoveQuotes) 3530 } 3531 3532 if v.ReplaceChars != nil { 3533 ok := object.Key("ReplaceChars") 3534 ok.String(*v.ReplaceChars) 3535 } 3536 3537 if v.ReplaceInvalidChars != nil { 3538 ok := object.Key("ReplaceInvalidChars") 3539 ok.String(*v.ReplaceInvalidChars) 3540 } 3541 3542 if v.SecretsManagerAccessRoleArn != nil { 3543 ok := object.Key("SecretsManagerAccessRoleArn") 3544 ok.String(*v.SecretsManagerAccessRoleArn) 3545 } 3546 3547 if v.SecretsManagerSecretId != nil { 3548 ok := object.Key("SecretsManagerSecretId") 3549 ok.String(*v.SecretsManagerSecretId) 3550 } 3551 3552 if v.ServerName != nil { 3553 ok := object.Key("ServerName") 3554 ok.String(*v.ServerName) 3555 } 3556 3557 if v.ServerSideEncryptionKmsKeyId != nil { 3558 ok := object.Key("ServerSideEncryptionKmsKeyId") 3559 ok.String(*v.ServerSideEncryptionKmsKeyId) 3560 } 3561 3562 if v.ServiceAccessRoleArn != nil { 3563 ok := object.Key("ServiceAccessRoleArn") 3564 ok.String(*v.ServiceAccessRoleArn) 3565 } 3566 3567 if v.TimeFormat != nil { 3568 ok := object.Key("TimeFormat") 3569 ok.String(*v.TimeFormat) 3570 } 3571 3572 if v.TrimBlanks != nil { 3573 ok := object.Key("TrimBlanks") 3574 ok.Boolean(*v.TrimBlanks) 3575 } 3576 3577 if v.TruncateColumns != nil { 3578 ok := object.Key("TruncateColumns") 3579 ok.Boolean(*v.TruncateColumns) 3580 } 3581 3582 if v.Username != nil { 3583 ok := object.Key("Username") 3584 ok.String(*v.Username) 3585 } 3586 3587 if v.WriteBufferSize != nil { 3588 ok := object.Key("WriteBufferSize") 3589 ok.Integer(*v.WriteBufferSize) 3590 } 3591 3592 return nil 3593} 3594 3595func awsAwsjson11_serializeDocumentS3Settings(v *types.S3Settings, value smithyjson.Value) error { 3596 object := value.Object() 3597 defer object.Close() 3598 3599 if v.BucketFolder != nil { 3600 ok := object.Key("BucketFolder") 3601 ok.String(*v.BucketFolder) 3602 } 3603 3604 if v.BucketName != nil { 3605 ok := object.Key("BucketName") 3606 ok.String(*v.BucketName) 3607 } 3608 3609 if v.CdcInsertsAndUpdates != nil { 3610 ok := object.Key("CdcInsertsAndUpdates") 3611 ok.Boolean(*v.CdcInsertsAndUpdates) 3612 } 3613 3614 if v.CdcInsertsOnly != nil { 3615 ok := object.Key("CdcInsertsOnly") 3616 ok.Boolean(*v.CdcInsertsOnly) 3617 } 3618 3619 if v.CdcPath != nil { 3620 ok := object.Key("CdcPath") 3621 ok.String(*v.CdcPath) 3622 } 3623 3624 if len(v.CompressionType) > 0 { 3625 ok := object.Key("CompressionType") 3626 ok.String(string(v.CompressionType)) 3627 } 3628 3629 if v.CsvDelimiter != nil { 3630 ok := object.Key("CsvDelimiter") 3631 ok.String(*v.CsvDelimiter) 3632 } 3633 3634 if v.CsvNoSupValue != nil { 3635 ok := object.Key("CsvNoSupValue") 3636 ok.String(*v.CsvNoSupValue) 3637 } 3638 3639 if v.CsvRowDelimiter != nil { 3640 ok := object.Key("CsvRowDelimiter") 3641 ok.String(*v.CsvRowDelimiter) 3642 } 3643 3644 if len(v.DataFormat) > 0 { 3645 ok := object.Key("DataFormat") 3646 ok.String(string(v.DataFormat)) 3647 } 3648 3649 if v.DataPageSize != nil { 3650 ok := object.Key("DataPageSize") 3651 ok.Integer(*v.DataPageSize) 3652 } 3653 3654 if len(v.DatePartitionDelimiter) > 0 { 3655 ok := object.Key("DatePartitionDelimiter") 3656 ok.String(string(v.DatePartitionDelimiter)) 3657 } 3658 3659 if v.DatePartitionEnabled != nil { 3660 ok := object.Key("DatePartitionEnabled") 3661 ok.Boolean(*v.DatePartitionEnabled) 3662 } 3663 3664 if len(v.DatePartitionSequence) > 0 { 3665 ok := object.Key("DatePartitionSequence") 3666 ok.String(string(v.DatePartitionSequence)) 3667 } 3668 3669 if v.DictPageSizeLimit != nil { 3670 ok := object.Key("DictPageSizeLimit") 3671 ok.Integer(*v.DictPageSizeLimit) 3672 } 3673 3674 if v.EnableStatistics != nil { 3675 ok := object.Key("EnableStatistics") 3676 ok.Boolean(*v.EnableStatistics) 3677 } 3678 3679 if len(v.EncodingType) > 0 { 3680 ok := object.Key("EncodingType") 3681 ok.String(string(v.EncodingType)) 3682 } 3683 3684 if len(v.EncryptionMode) > 0 { 3685 ok := object.Key("EncryptionMode") 3686 ok.String(string(v.EncryptionMode)) 3687 } 3688 3689 if v.ExternalTableDefinition != nil { 3690 ok := object.Key("ExternalTableDefinition") 3691 ok.String(*v.ExternalTableDefinition) 3692 } 3693 3694 if v.IncludeOpForFullLoad != nil { 3695 ok := object.Key("IncludeOpForFullLoad") 3696 ok.Boolean(*v.IncludeOpForFullLoad) 3697 } 3698 3699 if v.ParquetTimestampInMillisecond != nil { 3700 ok := object.Key("ParquetTimestampInMillisecond") 3701 ok.Boolean(*v.ParquetTimestampInMillisecond) 3702 } 3703 3704 if len(v.ParquetVersion) > 0 { 3705 ok := object.Key("ParquetVersion") 3706 ok.String(string(v.ParquetVersion)) 3707 } 3708 3709 if v.PreserveTransactions != nil { 3710 ok := object.Key("PreserveTransactions") 3711 ok.Boolean(*v.PreserveTransactions) 3712 } 3713 3714 if v.RowGroupLength != nil { 3715 ok := object.Key("RowGroupLength") 3716 ok.Integer(*v.RowGroupLength) 3717 } 3718 3719 if v.ServerSideEncryptionKmsKeyId != nil { 3720 ok := object.Key("ServerSideEncryptionKmsKeyId") 3721 ok.String(*v.ServerSideEncryptionKmsKeyId) 3722 } 3723 3724 if v.ServiceAccessRoleArn != nil { 3725 ok := object.Key("ServiceAccessRoleArn") 3726 ok.String(*v.ServiceAccessRoleArn) 3727 } 3728 3729 if v.TimestampColumnName != nil { 3730 ok := object.Key("TimestampColumnName") 3731 ok.String(*v.TimestampColumnName) 3732 } 3733 3734 if v.UseCsvNoSupValue != nil { 3735 ok := object.Key("UseCsvNoSupValue") 3736 ok.Boolean(*v.UseCsvNoSupValue) 3737 } 3738 3739 return nil 3740} 3741 3742func awsAwsjson11_serializeDocumentSourceIdsList(v []string, value smithyjson.Value) error { 3743 array := value.Array() 3744 defer array.Close() 3745 3746 for i := range v { 3747 av := array.Value() 3748 av.String(v[i]) 3749 } 3750 return nil 3751} 3752 3753func awsAwsjson11_serializeDocumentSubnetIdentifierList(v []string, value smithyjson.Value) error { 3754 array := value.Array() 3755 defer array.Close() 3756 3757 for i := range v { 3758 av := array.Value() 3759 av.String(v[i]) 3760 } 3761 return nil 3762} 3763 3764func awsAwsjson11_serializeDocumentSybaseSettings(v *types.SybaseSettings, value smithyjson.Value) error { 3765 object := value.Object() 3766 defer object.Close() 3767 3768 if v.DatabaseName != nil { 3769 ok := object.Key("DatabaseName") 3770 ok.String(*v.DatabaseName) 3771 } 3772 3773 if v.Password != nil { 3774 ok := object.Key("Password") 3775 ok.String(*v.Password) 3776 } 3777 3778 if v.Port != nil { 3779 ok := object.Key("Port") 3780 ok.Integer(*v.Port) 3781 } 3782 3783 if v.SecretsManagerAccessRoleArn != nil { 3784 ok := object.Key("SecretsManagerAccessRoleArn") 3785 ok.String(*v.SecretsManagerAccessRoleArn) 3786 } 3787 3788 if v.SecretsManagerSecretId != nil { 3789 ok := object.Key("SecretsManagerSecretId") 3790 ok.String(*v.SecretsManagerSecretId) 3791 } 3792 3793 if v.ServerName != nil { 3794 ok := object.Key("ServerName") 3795 ok.String(*v.ServerName) 3796 } 3797 3798 if v.Username != nil { 3799 ok := object.Key("Username") 3800 ok.String(*v.Username) 3801 } 3802 3803 return nil 3804} 3805 3806func awsAwsjson11_serializeDocumentTableListToReload(v []types.TableToReload, value smithyjson.Value) error { 3807 array := value.Array() 3808 defer array.Close() 3809 3810 for i := range v { 3811 av := array.Value() 3812 if err := awsAwsjson11_serializeDocumentTableToReload(&v[i], av); err != nil { 3813 return err 3814 } 3815 } 3816 return nil 3817} 3818 3819func awsAwsjson11_serializeDocumentTableToReload(v *types.TableToReload, value smithyjson.Value) error { 3820 object := value.Object() 3821 defer object.Close() 3822 3823 if v.SchemaName != nil { 3824 ok := object.Key("SchemaName") 3825 ok.String(*v.SchemaName) 3826 } 3827 3828 if v.TableName != nil { 3829 ok := object.Key("TableName") 3830 ok.String(*v.TableName) 3831 } 3832 3833 return nil 3834} 3835 3836func awsAwsjson11_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { 3837 object := value.Object() 3838 defer object.Close() 3839 3840 if v.Key != nil { 3841 ok := object.Key("Key") 3842 ok.String(*v.Key) 3843 } 3844 3845 if v.Value != nil { 3846 ok := object.Key("Value") 3847 ok.String(*v.Value) 3848 } 3849 3850 return nil 3851} 3852 3853func awsAwsjson11_serializeDocumentTagList(v []types.Tag, value smithyjson.Value) error { 3854 array := value.Array() 3855 defer array.Close() 3856 3857 for i := range v { 3858 av := array.Value() 3859 if err := awsAwsjson11_serializeDocumentTag(&v[i], av); err != nil { 3860 return err 3861 } 3862 } 3863 return nil 3864} 3865 3866func awsAwsjson11_serializeDocumentVpcSecurityGroupIdList(v []string, value smithyjson.Value) error { 3867 array := value.Array() 3868 defer array.Close() 3869 3870 for i := range v { 3871 av := array.Value() 3872 av.String(v[i]) 3873 } 3874 return nil 3875} 3876 3877func awsAwsjson11_serializeOpDocumentAddTagsToResourceInput(v *AddTagsToResourceInput, value smithyjson.Value) error { 3878 object := value.Object() 3879 defer object.Close() 3880 3881 if v.ResourceArn != nil { 3882 ok := object.Key("ResourceArn") 3883 ok.String(*v.ResourceArn) 3884 } 3885 3886 if v.Tags != nil { 3887 ok := object.Key("Tags") 3888 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 3889 return err 3890 } 3891 } 3892 3893 return nil 3894} 3895 3896func awsAwsjson11_serializeOpDocumentApplyPendingMaintenanceActionInput(v *ApplyPendingMaintenanceActionInput, value smithyjson.Value) error { 3897 object := value.Object() 3898 defer object.Close() 3899 3900 if v.ApplyAction != nil { 3901 ok := object.Key("ApplyAction") 3902 ok.String(*v.ApplyAction) 3903 } 3904 3905 if v.OptInType != nil { 3906 ok := object.Key("OptInType") 3907 ok.String(*v.OptInType) 3908 } 3909 3910 if v.ReplicationInstanceArn != nil { 3911 ok := object.Key("ReplicationInstanceArn") 3912 ok.String(*v.ReplicationInstanceArn) 3913 } 3914 3915 return nil 3916} 3917 3918func awsAwsjson11_serializeOpDocumentCancelReplicationTaskAssessmentRunInput(v *CancelReplicationTaskAssessmentRunInput, value smithyjson.Value) error { 3919 object := value.Object() 3920 defer object.Close() 3921 3922 if v.ReplicationTaskAssessmentRunArn != nil { 3923 ok := object.Key("ReplicationTaskAssessmentRunArn") 3924 ok.String(*v.ReplicationTaskAssessmentRunArn) 3925 } 3926 3927 return nil 3928} 3929 3930func awsAwsjson11_serializeOpDocumentCreateEndpointInput(v *CreateEndpointInput, value smithyjson.Value) error { 3931 object := value.Object() 3932 defer object.Close() 3933 3934 if v.CertificateArn != nil { 3935 ok := object.Key("CertificateArn") 3936 ok.String(*v.CertificateArn) 3937 } 3938 3939 if v.DatabaseName != nil { 3940 ok := object.Key("DatabaseName") 3941 ok.String(*v.DatabaseName) 3942 } 3943 3944 if v.DmsTransferSettings != nil { 3945 ok := object.Key("DmsTransferSettings") 3946 if err := awsAwsjson11_serializeDocumentDmsTransferSettings(v.DmsTransferSettings, ok); err != nil { 3947 return err 3948 } 3949 } 3950 3951 if v.DocDbSettings != nil { 3952 ok := object.Key("DocDbSettings") 3953 if err := awsAwsjson11_serializeDocumentDocDbSettings(v.DocDbSettings, ok); err != nil { 3954 return err 3955 } 3956 } 3957 3958 if v.DynamoDbSettings != nil { 3959 ok := object.Key("DynamoDbSettings") 3960 if err := awsAwsjson11_serializeDocumentDynamoDbSettings(v.DynamoDbSettings, ok); err != nil { 3961 return err 3962 } 3963 } 3964 3965 if v.ElasticsearchSettings != nil { 3966 ok := object.Key("ElasticsearchSettings") 3967 if err := awsAwsjson11_serializeDocumentElasticsearchSettings(v.ElasticsearchSettings, ok); err != nil { 3968 return err 3969 } 3970 } 3971 3972 if v.EndpointIdentifier != nil { 3973 ok := object.Key("EndpointIdentifier") 3974 ok.String(*v.EndpointIdentifier) 3975 } 3976 3977 if len(v.EndpointType) > 0 { 3978 ok := object.Key("EndpointType") 3979 ok.String(string(v.EndpointType)) 3980 } 3981 3982 if v.EngineName != nil { 3983 ok := object.Key("EngineName") 3984 ok.String(*v.EngineName) 3985 } 3986 3987 if v.ExternalTableDefinition != nil { 3988 ok := object.Key("ExternalTableDefinition") 3989 ok.String(*v.ExternalTableDefinition) 3990 } 3991 3992 if v.ExtraConnectionAttributes != nil { 3993 ok := object.Key("ExtraConnectionAttributes") 3994 ok.String(*v.ExtraConnectionAttributes) 3995 } 3996 3997 if v.IBMDb2Settings != nil { 3998 ok := object.Key("IBMDb2Settings") 3999 if err := awsAwsjson11_serializeDocumentIBMDb2Settings(v.IBMDb2Settings, ok); err != nil { 4000 return err 4001 } 4002 } 4003 4004 if v.KafkaSettings != nil { 4005 ok := object.Key("KafkaSettings") 4006 if err := awsAwsjson11_serializeDocumentKafkaSettings(v.KafkaSettings, ok); err != nil { 4007 return err 4008 } 4009 } 4010 4011 if v.KinesisSettings != nil { 4012 ok := object.Key("KinesisSettings") 4013 if err := awsAwsjson11_serializeDocumentKinesisSettings(v.KinesisSettings, ok); err != nil { 4014 return err 4015 } 4016 } 4017 4018 if v.KmsKeyId != nil { 4019 ok := object.Key("KmsKeyId") 4020 ok.String(*v.KmsKeyId) 4021 } 4022 4023 if v.MicrosoftSQLServerSettings != nil { 4024 ok := object.Key("MicrosoftSQLServerSettings") 4025 if err := awsAwsjson11_serializeDocumentMicrosoftSQLServerSettings(v.MicrosoftSQLServerSettings, ok); err != nil { 4026 return err 4027 } 4028 } 4029 4030 if v.MongoDbSettings != nil { 4031 ok := object.Key("MongoDbSettings") 4032 if err := awsAwsjson11_serializeDocumentMongoDbSettings(v.MongoDbSettings, ok); err != nil { 4033 return err 4034 } 4035 } 4036 4037 if v.MySQLSettings != nil { 4038 ok := object.Key("MySQLSettings") 4039 if err := awsAwsjson11_serializeDocumentMySQLSettings(v.MySQLSettings, ok); err != nil { 4040 return err 4041 } 4042 } 4043 4044 if v.NeptuneSettings != nil { 4045 ok := object.Key("NeptuneSettings") 4046 if err := awsAwsjson11_serializeDocumentNeptuneSettings(v.NeptuneSettings, ok); err != nil { 4047 return err 4048 } 4049 } 4050 4051 if v.OracleSettings != nil { 4052 ok := object.Key("OracleSettings") 4053 if err := awsAwsjson11_serializeDocumentOracleSettings(v.OracleSettings, ok); err != nil { 4054 return err 4055 } 4056 } 4057 4058 if v.Password != nil { 4059 ok := object.Key("Password") 4060 ok.String(*v.Password) 4061 } 4062 4063 if v.Port != nil { 4064 ok := object.Key("Port") 4065 ok.Integer(*v.Port) 4066 } 4067 4068 if v.PostgreSQLSettings != nil { 4069 ok := object.Key("PostgreSQLSettings") 4070 if err := awsAwsjson11_serializeDocumentPostgreSQLSettings(v.PostgreSQLSettings, ok); err != nil { 4071 return err 4072 } 4073 } 4074 4075 if v.RedshiftSettings != nil { 4076 ok := object.Key("RedshiftSettings") 4077 if err := awsAwsjson11_serializeDocumentRedshiftSettings(v.RedshiftSettings, ok); err != nil { 4078 return err 4079 } 4080 } 4081 4082 if v.ResourceIdentifier != nil { 4083 ok := object.Key("ResourceIdentifier") 4084 ok.String(*v.ResourceIdentifier) 4085 } 4086 4087 if v.S3Settings != nil { 4088 ok := object.Key("S3Settings") 4089 if err := awsAwsjson11_serializeDocumentS3Settings(v.S3Settings, ok); err != nil { 4090 return err 4091 } 4092 } 4093 4094 if v.ServerName != nil { 4095 ok := object.Key("ServerName") 4096 ok.String(*v.ServerName) 4097 } 4098 4099 if v.ServiceAccessRoleArn != nil { 4100 ok := object.Key("ServiceAccessRoleArn") 4101 ok.String(*v.ServiceAccessRoleArn) 4102 } 4103 4104 if len(v.SslMode) > 0 { 4105 ok := object.Key("SslMode") 4106 ok.String(string(v.SslMode)) 4107 } 4108 4109 if v.SybaseSettings != nil { 4110 ok := object.Key("SybaseSettings") 4111 if err := awsAwsjson11_serializeDocumentSybaseSettings(v.SybaseSettings, ok); err != nil { 4112 return err 4113 } 4114 } 4115 4116 if v.Tags != nil { 4117 ok := object.Key("Tags") 4118 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 4119 return err 4120 } 4121 } 4122 4123 if v.Username != nil { 4124 ok := object.Key("Username") 4125 ok.String(*v.Username) 4126 } 4127 4128 return nil 4129} 4130 4131func awsAwsjson11_serializeOpDocumentCreateEventSubscriptionInput(v *CreateEventSubscriptionInput, value smithyjson.Value) error { 4132 object := value.Object() 4133 defer object.Close() 4134 4135 if v.Enabled != nil { 4136 ok := object.Key("Enabled") 4137 ok.Boolean(*v.Enabled) 4138 } 4139 4140 if v.EventCategories != nil { 4141 ok := object.Key("EventCategories") 4142 if err := awsAwsjson11_serializeDocumentEventCategoriesList(v.EventCategories, ok); err != nil { 4143 return err 4144 } 4145 } 4146 4147 if v.SnsTopicArn != nil { 4148 ok := object.Key("SnsTopicArn") 4149 ok.String(*v.SnsTopicArn) 4150 } 4151 4152 if v.SourceIds != nil { 4153 ok := object.Key("SourceIds") 4154 if err := awsAwsjson11_serializeDocumentSourceIdsList(v.SourceIds, ok); err != nil { 4155 return err 4156 } 4157 } 4158 4159 if v.SourceType != nil { 4160 ok := object.Key("SourceType") 4161 ok.String(*v.SourceType) 4162 } 4163 4164 if v.SubscriptionName != nil { 4165 ok := object.Key("SubscriptionName") 4166 ok.String(*v.SubscriptionName) 4167 } 4168 4169 if v.Tags != nil { 4170 ok := object.Key("Tags") 4171 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 4172 return err 4173 } 4174 } 4175 4176 return nil 4177} 4178 4179func awsAwsjson11_serializeOpDocumentCreateReplicationInstanceInput(v *CreateReplicationInstanceInput, value smithyjson.Value) error { 4180 object := value.Object() 4181 defer object.Close() 4182 4183 if v.AllocatedStorage != nil { 4184 ok := object.Key("AllocatedStorage") 4185 ok.Integer(*v.AllocatedStorage) 4186 } 4187 4188 if v.AutoMinorVersionUpgrade != nil { 4189 ok := object.Key("AutoMinorVersionUpgrade") 4190 ok.Boolean(*v.AutoMinorVersionUpgrade) 4191 } 4192 4193 if v.AvailabilityZone != nil { 4194 ok := object.Key("AvailabilityZone") 4195 ok.String(*v.AvailabilityZone) 4196 } 4197 4198 if v.DnsNameServers != nil { 4199 ok := object.Key("DnsNameServers") 4200 ok.String(*v.DnsNameServers) 4201 } 4202 4203 if v.EngineVersion != nil { 4204 ok := object.Key("EngineVersion") 4205 ok.String(*v.EngineVersion) 4206 } 4207 4208 if v.KmsKeyId != nil { 4209 ok := object.Key("KmsKeyId") 4210 ok.String(*v.KmsKeyId) 4211 } 4212 4213 if v.MultiAZ != nil { 4214 ok := object.Key("MultiAZ") 4215 ok.Boolean(*v.MultiAZ) 4216 } 4217 4218 if v.PreferredMaintenanceWindow != nil { 4219 ok := object.Key("PreferredMaintenanceWindow") 4220 ok.String(*v.PreferredMaintenanceWindow) 4221 } 4222 4223 if v.PubliclyAccessible != nil { 4224 ok := object.Key("PubliclyAccessible") 4225 ok.Boolean(*v.PubliclyAccessible) 4226 } 4227 4228 if v.ReplicationInstanceClass != nil { 4229 ok := object.Key("ReplicationInstanceClass") 4230 ok.String(*v.ReplicationInstanceClass) 4231 } 4232 4233 if v.ReplicationInstanceIdentifier != nil { 4234 ok := object.Key("ReplicationInstanceIdentifier") 4235 ok.String(*v.ReplicationInstanceIdentifier) 4236 } 4237 4238 if v.ReplicationSubnetGroupIdentifier != nil { 4239 ok := object.Key("ReplicationSubnetGroupIdentifier") 4240 ok.String(*v.ReplicationSubnetGroupIdentifier) 4241 } 4242 4243 if v.ResourceIdentifier != nil { 4244 ok := object.Key("ResourceIdentifier") 4245 ok.String(*v.ResourceIdentifier) 4246 } 4247 4248 if v.Tags != nil { 4249 ok := object.Key("Tags") 4250 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 4251 return err 4252 } 4253 } 4254 4255 if v.VpcSecurityGroupIds != nil { 4256 ok := object.Key("VpcSecurityGroupIds") 4257 if err := awsAwsjson11_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, ok); err != nil { 4258 return err 4259 } 4260 } 4261 4262 return nil 4263} 4264 4265func awsAwsjson11_serializeOpDocumentCreateReplicationSubnetGroupInput(v *CreateReplicationSubnetGroupInput, value smithyjson.Value) error { 4266 object := value.Object() 4267 defer object.Close() 4268 4269 if v.ReplicationSubnetGroupDescription != nil { 4270 ok := object.Key("ReplicationSubnetGroupDescription") 4271 ok.String(*v.ReplicationSubnetGroupDescription) 4272 } 4273 4274 if v.ReplicationSubnetGroupIdentifier != nil { 4275 ok := object.Key("ReplicationSubnetGroupIdentifier") 4276 ok.String(*v.ReplicationSubnetGroupIdentifier) 4277 } 4278 4279 if v.SubnetIds != nil { 4280 ok := object.Key("SubnetIds") 4281 if err := awsAwsjson11_serializeDocumentSubnetIdentifierList(v.SubnetIds, ok); err != nil { 4282 return err 4283 } 4284 } 4285 4286 if v.Tags != nil { 4287 ok := object.Key("Tags") 4288 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 4289 return err 4290 } 4291 } 4292 4293 return nil 4294} 4295 4296func awsAwsjson11_serializeOpDocumentCreateReplicationTaskInput(v *CreateReplicationTaskInput, value smithyjson.Value) error { 4297 object := value.Object() 4298 defer object.Close() 4299 4300 if v.CdcStartPosition != nil { 4301 ok := object.Key("CdcStartPosition") 4302 ok.String(*v.CdcStartPosition) 4303 } 4304 4305 if v.CdcStartTime != nil { 4306 ok := object.Key("CdcStartTime") 4307 ok.Double(smithytime.FormatEpochSeconds(*v.CdcStartTime)) 4308 } 4309 4310 if v.CdcStopPosition != nil { 4311 ok := object.Key("CdcStopPosition") 4312 ok.String(*v.CdcStopPosition) 4313 } 4314 4315 if len(v.MigrationType) > 0 { 4316 ok := object.Key("MigrationType") 4317 ok.String(string(v.MigrationType)) 4318 } 4319 4320 if v.ReplicationInstanceArn != nil { 4321 ok := object.Key("ReplicationInstanceArn") 4322 ok.String(*v.ReplicationInstanceArn) 4323 } 4324 4325 if v.ReplicationTaskIdentifier != nil { 4326 ok := object.Key("ReplicationTaskIdentifier") 4327 ok.String(*v.ReplicationTaskIdentifier) 4328 } 4329 4330 if v.ReplicationTaskSettings != nil { 4331 ok := object.Key("ReplicationTaskSettings") 4332 ok.String(*v.ReplicationTaskSettings) 4333 } 4334 4335 if v.ResourceIdentifier != nil { 4336 ok := object.Key("ResourceIdentifier") 4337 ok.String(*v.ResourceIdentifier) 4338 } 4339 4340 if v.SourceEndpointArn != nil { 4341 ok := object.Key("SourceEndpointArn") 4342 ok.String(*v.SourceEndpointArn) 4343 } 4344 4345 if v.TableMappings != nil { 4346 ok := object.Key("TableMappings") 4347 ok.String(*v.TableMappings) 4348 } 4349 4350 if v.Tags != nil { 4351 ok := object.Key("Tags") 4352 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 4353 return err 4354 } 4355 } 4356 4357 if v.TargetEndpointArn != nil { 4358 ok := object.Key("TargetEndpointArn") 4359 ok.String(*v.TargetEndpointArn) 4360 } 4361 4362 if v.TaskData != nil { 4363 ok := object.Key("TaskData") 4364 ok.String(*v.TaskData) 4365 } 4366 4367 return nil 4368} 4369 4370func awsAwsjson11_serializeOpDocumentDeleteCertificateInput(v *DeleteCertificateInput, value smithyjson.Value) error { 4371 object := value.Object() 4372 defer object.Close() 4373 4374 if v.CertificateArn != nil { 4375 ok := object.Key("CertificateArn") 4376 ok.String(*v.CertificateArn) 4377 } 4378 4379 return nil 4380} 4381 4382func awsAwsjson11_serializeOpDocumentDeleteConnectionInput(v *DeleteConnectionInput, value smithyjson.Value) error { 4383 object := value.Object() 4384 defer object.Close() 4385 4386 if v.EndpointArn != nil { 4387 ok := object.Key("EndpointArn") 4388 ok.String(*v.EndpointArn) 4389 } 4390 4391 if v.ReplicationInstanceArn != nil { 4392 ok := object.Key("ReplicationInstanceArn") 4393 ok.String(*v.ReplicationInstanceArn) 4394 } 4395 4396 return nil 4397} 4398 4399func awsAwsjson11_serializeOpDocumentDeleteEndpointInput(v *DeleteEndpointInput, value smithyjson.Value) error { 4400 object := value.Object() 4401 defer object.Close() 4402 4403 if v.EndpointArn != nil { 4404 ok := object.Key("EndpointArn") 4405 ok.String(*v.EndpointArn) 4406 } 4407 4408 return nil 4409} 4410 4411func awsAwsjson11_serializeOpDocumentDeleteEventSubscriptionInput(v *DeleteEventSubscriptionInput, value smithyjson.Value) error { 4412 object := value.Object() 4413 defer object.Close() 4414 4415 if v.SubscriptionName != nil { 4416 ok := object.Key("SubscriptionName") 4417 ok.String(*v.SubscriptionName) 4418 } 4419 4420 return nil 4421} 4422 4423func awsAwsjson11_serializeOpDocumentDeleteReplicationInstanceInput(v *DeleteReplicationInstanceInput, value smithyjson.Value) error { 4424 object := value.Object() 4425 defer object.Close() 4426 4427 if v.ReplicationInstanceArn != nil { 4428 ok := object.Key("ReplicationInstanceArn") 4429 ok.String(*v.ReplicationInstanceArn) 4430 } 4431 4432 return nil 4433} 4434 4435func awsAwsjson11_serializeOpDocumentDeleteReplicationSubnetGroupInput(v *DeleteReplicationSubnetGroupInput, value smithyjson.Value) error { 4436 object := value.Object() 4437 defer object.Close() 4438 4439 if v.ReplicationSubnetGroupIdentifier != nil { 4440 ok := object.Key("ReplicationSubnetGroupIdentifier") 4441 ok.String(*v.ReplicationSubnetGroupIdentifier) 4442 } 4443 4444 return nil 4445} 4446 4447func awsAwsjson11_serializeOpDocumentDeleteReplicationTaskAssessmentRunInput(v *DeleteReplicationTaskAssessmentRunInput, value smithyjson.Value) error { 4448 object := value.Object() 4449 defer object.Close() 4450 4451 if v.ReplicationTaskAssessmentRunArn != nil { 4452 ok := object.Key("ReplicationTaskAssessmentRunArn") 4453 ok.String(*v.ReplicationTaskAssessmentRunArn) 4454 } 4455 4456 return nil 4457} 4458 4459func awsAwsjson11_serializeOpDocumentDeleteReplicationTaskInput(v *DeleteReplicationTaskInput, value smithyjson.Value) error { 4460 object := value.Object() 4461 defer object.Close() 4462 4463 if v.ReplicationTaskArn != nil { 4464 ok := object.Key("ReplicationTaskArn") 4465 ok.String(*v.ReplicationTaskArn) 4466 } 4467 4468 return nil 4469} 4470 4471func awsAwsjson11_serializeOpDocumentDescribeAccountAttributesInput(v *DescribeAccountAttributesInput, value smithyjson.Value) error { 4472 object := value.Object() 4473 defer object.Close() 4474 4475 return nil 4476} 4477 4478func awsAwsjson11_serializeOpDocumentDescribeApplicableIndividualAssessmentsInput(v *DescribeApplicableIndividualAssessmentsInput, value smithyjson.Value) error { 4479 object := value.Object() 4480 defer object.Close() 4481 4482 if v.Marker != nil { 4483 ok := object.Key("Marker") 4484 ok.String(*v.Marker) 4485 } 4486 4487 if v.MaxRecords != nil { 4488 ok := object.Key("MaxRecords") 4489 ok.Integer(*v.MaxRecords) 4490 } 4491 4492 if len(v.MigrationType) > 0 { 4493 ok := object.Key("MigrationType") 4494 ok.String(string(v.MigrationType)) 4495 } 4496 4497 if v.ReplicationInstanceArn != nil { 4498 ok := object.Key("ReplicationInstanceArn") 4499 ok.String(*v.ReplicationInstanceArn) 4500 } 4501 4502 if v.ReplicationTaskArn != nil { 4503 ok := object.Key("ReplicationTaskArn") 4504 ok.String(*v.ReplicationTaskArn) 4505 } 4506 4507 if v.SourceEngineName != nil { 4508 ok := object.Key("SourceEngineName") 4509 ok.String(*v.SourceEngineName) 4510 } 4511 4512 if v.TargetEngineName != nil { 4513 ok := object.Key("TargetEngineName") 4514 ok.String(*v.TargetEngineName) 4515 } 4516 4517 return nil 4518} 4519 4520func awsAwsjson11_serializeOpDocumentDescribeCertificatesInput(v *DescribeCertificatesInput, value smithyjson.Value) error { 4521 object := value.Object() 4522 defer object.Close() 4523 4524 if v.Filters != nil { 4525 ok := object.Key("Filters") 4526 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4527 return err 4528 } 4529 } 4530 4531 if v.Marker != nil { 4532 ok := object.Key("Marker") 4533 ok.String(*v.Marker) 4534 } 4535 4536 if v.MaxRecords != nil { 4537 ok := object.Key("MaxRecords") 4538 ok.Integer(*v.MaxRecords) 4539 } 4540 4541 return nil 4542} 4543 4544func awsAwsjson11_serializeOpDocumentDescribeConnectionsInput(v *DescribeConnectionsInput, value smithyjson.Value) error { 4545 object := value.Object() 4546 defer object.Close() 4547 4548 if v.Filters != nil { 4549 ok := object.Key("Filters") 4550 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4551 return err 4552 } 4553 } 4554 4555 if v.Marker != nil { 4556 ok := object.Key("Marker") 4557 ok.String(*v.Marker) 4558 } 4559 4560 if v.MaxRecords != nil { 4561 ok := object.Key("MaxRecords") 4562 ok.Integer(*v.MaxRecords) 4563 } 4564 4565 return nil 4566} 4567 4568func awsAwsjson11_serializeOpDocumentDescribeEndpointsInput(v *DescribeEndpointsInput, value smithyjson.Value) error { 4569 object := value.Object() 4570 defer object.Close() 4571 4572 if v.Filters != nil { 4573 ok := object.Key("Filters") 4574 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4575 return err 4576 } 4577 } 4578 4579 if v.Marker != nil { 4580 ok := object.Key("Marker") 4581 ok.String(*v.Marker) 4582 } 4583 4584 if v.MaxRecords != nil { 4585 ok := object.Key("MaxRecords") 4586 ok.Integer(*v.MaxRecords) 4587 } 4588 4589 return nil 4590} 4591 4592func awsAwsjson11_serializeOpDocumentDescribeEndpointTypesInput(v *DescribeEndpointTypesInput, value smithyjson.Value) error { 4593 object := value.Object() 4594 defer object.Close() 4595 4596 if v.Filters != nil { 4597 ok := object.Key("Filters") 4598 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4599 return err 4600 } 4601 } 4602 4603 if v.Marker != nil { 4604 ok := object.Key("Marker") 4605 ok.String(*v.Marker) 4606 } 4607 4608 if v.MaxRecords != nil { 4609 ok := object.Key("MaxRecords") 4610 ok.Integer(*v.MaxRecords) 4611 } 4612 4613 return nil 4614} 4615 4616func awsAwsjson11_serializeOpDocumentDescribeEventCategoriesInput(v *DescribeEventCategoriesInput, value smithyjson.Value) error { 4617 object := value.Object() 4618 defer object.Close() 4619 4620 if v.Filters != nil { 4621 ok := object.Key("Filters") 4622 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4623 return err 4624 } 4625 } 4626 4627 if v.SourceType != nil { 4628 ok := object.Key("SourceType") 4629 ok.String(*v.SourceType) 4630 } 4631 4632 return nil 4633} 4634 4635func awsAwsjson11_serializeOpDocumentDescribeEventsInput(v *DescribeEventsInput, value smithyjson.Value) error { 4636 object := value.Object() 4637 defer object.Close() 4638 4639 if v.Duration != nil { 4640 ok := object.Key("Duration") 4641 ok.Integer(*v.Duration) 4642 } 4643 4644 if v.EndTime != nil { 4645 ok := object.Key("EndTime") 4646 ok.Double(smithytime.FormatEpochSeconds(*v.EndTime)) 4647 } 4648 4649 if v.EventCategories != nil { 4650 ok := object.Key("EventCategories") 4651 if err := awsAwsjson11_serializeDocumentEventCategoriesList(v.EventCategories, ok); err != nil { 4652 return err 4653 } 4654 } 4655 4656 if v.Filters != nil { 4657 ok := object.Key("Filters") 4658 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4659 return err 4660 } 4661 } 4662 4663 if v.Marker != nil { 4664 ok := object.Key("Marker") 4665 ok.String(*v.Marker) 4666 } 4667 4668 if v.MaxRecords != nil { 4669 ok := object.Key("MaxRecords") 4670 ok.Integer(*v.MaxRecords) 4671 } 4672 4673 if v.SourceIdentifier != nil { 4674 ok := object.Key("SourceIdentifier") 4675 ok.String(*v.SourceIdentifier) 4676 } 4677 4678 if len(v.SourceType) > 0 { 4679 ok := object.Key("SourceType") 4680 ok.String(string(v.SourceType)) 4681 } 4682 4683 if v.StartTime != nil { 4684 ok := object.Key("StartTime") 4685 ok.Double(smithytime.FormatEpochSeconds(*v.StartTime)) 4686 } 4687 4688 return nil 4689} 4690 4691func awsAwsjson11_serializeOpDocumentDescribeEventSubscriptionsInput(v *DescribeEventSubscriptionsInput, value smithyjson.Value) error { 4692 object := value.Object() 4693 defer object.Close() 4694 4695 if v.Filters != nil { 4696 ok := object.Key("Filters") 4697 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4698 return err 4699 } 4700 } 4701 4702 if v.Marker != nil { 4703 ok := object.Key("Marker") 4704 ok.String(*v.Marker) 4705 } 4706 4707 if v.MaxRecords != nil { 4708 ok := object.Key("MaxRecords") 4709 ok.Integer(*v.MaxRecords) 4710 } 4711 4712 if v.SubscriptionName != nil { 4713 ok := object.Key("SubscriptionName") 4714 ok.String(*v.SubscriptionName) 4715 } 4716 4717 return nil 4718} 4719 4720func awsAwsjson11_serializeOpDocumentDescribeOrderableReplicationInstancesInput(v *DescribeOrderableReplicationInstancesInput, value smithyjson.Value) error { 4721 object := value.Object() 4722 defer object.Close() 4723 4724 if v.Marker != nil { 4725 ok := object.Key("Marker") 4726 ok.String(*v.Marker) 4727 } 4728 4729 if v.MaxRecords != nil { 4730 ok := object.Key("MaxRecords") 4731 ok.Integer(*v.MaxRecords) 4732 } 4733 4734 return nil 4735} 4736 4737func awsAwsjson11_serializeOpDocumentDescribePendingMaintenanceActionsInput(v *DescribePendingMaintenanceActionsInput, value smithyjson.Value) error { 4738 object := value.Object() 4739 defer object.Close() 4740 4741 if v.Filters != nil { 4742 ok := object.Key("Filters") 4743 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4744 return err 4745 } 4746 } 4747 4748 if v.Marker != nil { 4749 ok := object.Key("Marker") 4750 ok.String(*v.Marker) 4751 } 4752 4753 if v.MaxRecords != nil { 4754 ok := object.Key("MaxRecords") 4755 ok.Integer(*v.MaxRecords) 4756 } 4757 4758 if v.ReplicationInstanceArn != nil { 4759 ok := object.Key("ReplicationInstanceArn") 4760 ok.String(*v.ReplicationInstanceArn) 4761 } 4762 4763 return nil 4764} 4765 4766func awsAwsjson11_serializeOpDocumentDescribeRefreshSchemasStatusInput(v *DescribeRefreshSchemasStatusInput, value smithyjson.Value) error { 4767 object := value.Object() 4768 defer object.Close() 4769 4770 if v.EndpointArn != nil { 4771 ok := object.Key("EndpointArn") 4772 ok.String(*v.EndpointArn) 4773 } 4774 4775 return nil 4776} 4777 4778func awsAwsjson11_serializeOpDocumentDescribeReplicationInstancesInput(v *DescribeReplicationInstancesInput, value smithyjson.Value) error { 4779 object := value.Object() 4780 defer object.Close() 4781 4782 if v.Filters != nil { 4783 ok := object.Key("Filters") 4784 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4785 return err 4786 } 4787 } 4788 4789 if v.Marker != nil { 4790 ok := object.Key("Marker") 4791 ok.String(*v.Marker) 4792 } 4793 4794 if v.MaxRecords != nil { 4795 ok := object.Key("MaxRecords") 4796 ok.Integer(*v.MaxRecords) 4797 } 4798 4799 return nil 4800} 4801 4802func awsAwsjson11_serializeOpDocumentDescribeReplicationInstanceTaskLogsInput(v *DescribeReplicationInstanceTaskLogsInput, value smithyjson.Value) error { 4803 object := value.Object() 4804 defer object.Close() 4805 4806 if v.Marker != nil { 4807 ok := object.Key("Marker") 4808 ok.String(*v.Marker) 4809 } 4810 4811 if v.MaxRecords != nil { 4812 ok := object.Key("MaxRecords") 4813 ok.Integer(*v.MaxRecords) 4814 } 4815 4816 if v.ReplicationInstanceArn != nil { 4817 ok := object.Key("ReplicationInstanceArn") 4818 ok.String(*v.ReplicationInstanceArn) 4819 } 4820 4821 return nil 4822} 4823 4824func awsAwsjson11_serializeOpDocumentDescribeReplicationSubnetGroupsInput(v *DescribeReplicationSubnetGroupsInput, value smithyjson.Value) error { 4825 object := value.Object() 4826 defer object.Close() 4827 4828 if v.Filters != nil { 4829 ok := object.Key("Filters") 4830 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4831 return err 4832 } 4833 } 4834 4835 if v.Marker != nil { 4836 ok := object.Key("Marker") 4837 ok.String(*v.Marker) 4838 } 4839 4840 if v.MaxRecords != nil { 4841 ok := object.Key("MaxRecords") 4842 ok.Integer(*v.MaxRecords) 4843 } 4844 4845 return nil 4846} 4847 4848func awsAwsjson11_serializeOpDocumentDescribeReplicationTaskAssessmentResultsInput(v *DescribeReplicationTaskAssessmentResultsInput, value smithyjson.Value) error { 4849 object := value.Object() 4850 defer object.Close() 4851 4852 if v.Marker != nil { 4853 ok := object.Key("Marker") 4854 ok.String(*v.Marker) 4855 } 4856 4857 if v.MaxRecords != nil { 4858 ok := object.Key("MaxRecords") 4859 ok.Integer(*v.MaxRecords) 4860 } 4861 4862 if v.ReplicationTaskArn != nil { 4863 ok := object.Key("ReplicationTaskArn") 4864 ok.String(*v.ReplicationTaskArn) 4865 } 4866 4867 return nil 4868} 4869 4870func awsAwsjson11_serializeOpDocumentDescribeReplicationTaskAssessmentRunsInput(v *DescribeReplicationTaskAssessmentRunsInput, value smithyjson.Value) error { 4871 object := value.Object() 4872 defer object.Close() 4873 4874 if v.Filters != nil { 4875 ok := object.Key("Filters") 4876 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4877 return err 4878 } 4879 } 4880 4881 if v.Marker != nil { 4882 ok := object.Key("Marker") 4883 ok.String(*v.Marker) 4884 } 4885 4886 if v.MaxRecords != nil { 4887 ok := object.Key("MaxRecords") 4888 ok.Integer(*v.MaxRecords) 4889 } 4890 4891 return nil 4892} 4893 4894func awsAwsjson11_serializeOpDocumentDescribeReplicationTaskIndividualAssessmentsInput(v *DescribeReplicationTaskIndividualAssessmentsInput, value smithyjson.Value) error { 4895 object := value.Object() 4896 defer object.Close() 4897 4898 if v.Filters != nil { 4899 ok := object.Key("Filters") 4900 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4901 return err 4902 } 4903 } 4904 4905 if v.Marker != nil { 4906 ok := object.Key("Marker") 4907 ok.String(*v.Marker) 4908 } 4909 4910 if v.MaxRecords != nil { 4911 ok := object.Key("MaxRecords") 4912 ok.Integer(*v.MaxRecords) 4913 } 4914 4915 return nil 4916} 4917 4918func awsAwsjson11_serializeOpDocumentDescribeReplicationTasksInput(v *DescribeReplicationTasksInput, value smithyjson.Value) error { 4919 object := value.Object() 4920 defer object.Close() 4921 4922 if v.Filters != nil { 4923 ok := object.Key("Filters") 4924 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4925 return err 4926 } 4927 } 4928 4929 if v.Marker != nil { 4930 ok := object.Key("Marker") 4931 ok.String(*v.Marker) 4932 } 4933 4934 if v.MaxRecords != nil { 4935 ok := object.Key("MaxRecords") 4936 ok.Integer(*v.MaxRecords) 4937 } 4938 4939 if v.WithoutSettings != nil { 4940 ok := object.Key("WithoutSettings") 4941 ok.Boolean(*v.WithoutSettings) 4942 } 4943 4944 return nil 4945} 4946 4947func awsAwsjson11_serializeOpDocumentDescribeSchemasInput(v *DescribeSchemasInput, value smithyjson.Value) error { 4948 object := value.Object() 4949 defer object.Close() 4950 4951 if v.EndpointArn != nil { 4952 ok := object.Key("EndpointArn") 4953 ok.String(*v.EndpointArn) 4954 } 4955 4956 if v.Marker != nil { 4957 ok := object.Key("Marker") 4958 ok.String(*v.Marker) 4959 } 4960 4961 if v.MaxRecords != nil { 4962 ok := object.Key("MaxRecords") 4963 ok.Integer(*v.MaxRecords) 4964 } 4965 4966 return nil 4967} 4968 4969func awsAwsjson11_serializeOpDocumentDescribeTableStatisticsInput(v *DescribeTableStatisticsInput, value smithyjson.Value) error { 4970 object := value.Object() 4971 defer object.Close() 4972 4973 if v.Filters != nil { 4974 ok := object.Key("Filters") 4975 if err := awsAwsjson11_serializeDocumentFilterList(v.Filters, ok); err != nil { 4976 return err 4977 } 4978 } 4979 4980 if v.Marker != nil { 4981 ok := object.Key("Marker") 4982 ok.String(*v.Marker) 4983 } 4984 4985 if v.MaxRecords != nil { 4986 ok := object.Key("MaxRecords") 4987 ok.Integer(*v.MaxRecords) 4988 } 4989 4990 if v.ReplicationTaskArn != nil { 4991 ok := object.Key("ReplicationTaskArn") 4992 ok.String(*v.ReplicationTaskArn) 4993 } 4994 4995 return nil 4996} 4997 4998func awsAwsjson11_serializeOpDocumentImportCertificateInput(v *ImportCertificateInput, value smithyjson.Value) error { 4999 object := value.Object() 5000 defer object.Close() 5001 5002 if v.CertificateIdentifier != nil { 5003 ok := object.Key("CertificateIdentifier") 5004 ok.String(*v.CertificateIdentifier) 5005 } 5006 5007 if v.CertificatePem != nil { 5008 ok := object.Key("CertificatePem") 5009 ok.String(*v.CertificatePem) 5010 } 5011 5012 if v.CertificateWallet != nil { 5013 ok := object.Key("CertificateWallet") 5014 ok.Base64EncodeBytes(v.CertificateWallet) 5015 } 5016 5017 if v.Tags != nil { 5018 ok := object.Key("Tags") 5019 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 5020 return err 5021 } 5022 } 5023 5024 return nil 5025} 5026 5027func awsAwsjson11_serializeOpDocumentListTagsForResourceInput(v *ListTagsForResourceInput, value smithyjson.Value) error { 5028 object := value.Object() 5029 defer object.Close() 5030 5031 if v.ResourceArn != nil { 5032 ok := object.Key("ResourceArn") 5033 ok.String(*v.ResourceArn) 5034 } 5035 5036 return nil 5037} 5038 5039func awsAwsjson11_serializeOpDocumentModifyEndpointInput(v *ModifyEndpointInput, value smithyjson.Value) error { 5040 object := value.Object() 5041 defer object.Close() 5042 5043 if v.CertificateArn != nil { 5044 ok := object.Key("CertificateArn") 5045 ok.String(*v.CertificateArn) 5046 } 5047 5048 if v.DatabaseName != nil { 5049 ok := object.Key("DatabaseName") 5050 ok.String(*v.DatabaseName) 5051 } 5052 5053 if v.DmsTransferSettings != nil { 5054 ok := object.Key("DmsTransferSettings") 5055 if err := awsAwsjson11_serializeDocumentDmsTransferSettings(v.DmsTransferSettings, ok); err != nil { 5056 return err 5057 } 5058 } 5059 5060 if v.DocDbSettings != nil { 5061 ok := object.Key("DocDbSettings") 5062 if err := awsAwsjson11_serializeDocumentDocDbSettings(v.DocDbSettings, ok); err != nil { 5063 return err 5064 } 5065 } 5066 5067 if v.DynamoDbSettings != nil { 5068 ok := object.Key("DynamoDbSettings") 5069 if err := awsAwsjson11_serializeDocumentDynamoDbSettings(v.DynamoDbSettings, ok); err != nil { 5070 return err 5071 } 5072 } 5073 5074 if v.ElasticsearchSettings != nil { 5075 ok := object.Key("ElasticsearchSettings") 5076 if err := awsAwsjson11_serializeDocumentElasticsearchSettings(v.ElasticsearchSettings, ok); err != nil { 5077 return err 5078 } 5079 } 5080 5081 if v.EndpointArn != nil { 5082 ok := object.Key("EndpointArn") 5083 ok.String(*v.EndpointArn) 5084 } 5085 5086 if v.EndpointIdentifier != nil { 5087 ok := object.Key("EndpointIdentifier") 5088 ok.String(*v.EndpointIdentifier) 5089 } 5090 5091 if len(v.EndpointType) > 0 { 5092 ok := object.Key("EndpointType") 5093 ok.String(string(v.EndpointType)) 5094 } 5095 5096 if v.EngineName != nil { 5097 ok := object.Key("EngineName") 5098 ok.String(*v.EngineName) 5099 } 5100 5101 if v.ExternalTableDefinition != nil { 5102 ok := object.Key("ExternalTableDefinition") 5103 ok.String(*v.ExternalTableDefinition) 5104 } 5105 5106 if v.ExtraConnectionAttributes != nil { 5107 ok := object.Key("ExtraConnectionAttributes") 5108 ok.String(*v.ExtraConnectionAttributes) 5109 } 5110 5111 if v.IBMDb2Settings != nil { 5112 ok := object.Key("IBMDb2Settings") 5113 if err := awsAwsjson11_serializeDocumentIBMDb2Settings(v.IBMDb2Settings, ok); err != nil { 5114 return err 5115 } 5116 } 5117 5118 if v.KafkaSettings != nil { 5119 ok := object.Key("KafkaSettings") 5120 if err := awsAwsjson11_serializeDocumentKafkaSettings(v.KafkaSettings, ok); err != nil { 5121 return err 5122 } 5123 } 5124 5125 if v.KinesisSettings != nil { 5126 ok := object.Key("KinesisSettings") 5127 if err := awsAwsjson11_serializeDocumentKinesisSettings(v.KinesisSettings, ok); err != nil { 5128 return err 5129 } 5130 } 5131 5132 if v.MicrosoftSQLServerSettings != nil { 5133 ok := object.Key("MicrosoftSQLServerSettings") 5134 if err := awsAwsjson11_serializeDocumentMicrosoftSQLServerSettings(v.MicrosoftSQLServerSettings, ok); err != nil { 5135 return err 5136 } 5137 } 5138 5139 if v.MongoDbSettings != nil { 5140 ok := object.Key("MongoDbSettings") 5141 if err := awsAwsjson11_serializeDocumentMongoDbSettings(v.MongoDbSettings, ok); err != nil { 5142 return err 5143 } 5144 } 5145 5146 if v.MySQLSettings != nil { 5147 ok := object.Key("MySQLSettings") 5148 if err := awsAwsjson11_serializeDocumentMySQLSettings(v.MySQLSettings, ok); err != nil { 5149 return err 5150 } 5151 } 5152 5153 if v.NeptuneSettings != nil { 5154 ok := object.Key("NeptuneSettings") 5155 if err := awsAwsjson11_serializeDocumentNeptuneSettings(v.NeptuneSettings, ok); err != nil { 5156 return err 5157 } 5158 } 5159 5160 if v.OracleSettings != nil { 5161 ok := object.Key("OracleSettings") 5162 if err := awsAwsjson11_serializeDocumentOracleSettings(v.OracleSettings, ok); err != nil { 5163 return err 5164 } 5165 } 5166 5167 if v.Password != nil { 5168 ok := object.Key("Password") 5169 ok.String(*v.Password) 5170 } 5171 5172 if v.Port != nil { 5173 ok := object.Key("Port") 5174 ok.Integer(*v.Port) 5175 } 5176 5177 if v.PostgreSQLSettings != nil { 5178 ok := object.Key("PostgreSQLSettings") 5179 if err := awsAwsjson11_serializeDocumentPostgreSQLSettings(v.PostgreSQLSettings, ok); err != nil { 5180 return err 5181 } 5182 } 5183 5184 if v.RedshiftSettings != nil { 5185 ok := object.Key("RedshiftSettings") 5186 if err := awsAwsjson11_serializeDocumentRedshiftSettings(v.RedshiftSettings, ok); err != nil { 5187 return err 5188 } 5189 } 5190 5191 if v.S3Settings != nil { 5192 ok := object.Key("S3Settings") 5193 if err := awsAwsjson11_serializeDocumentS3Settings(v.S3Settings, ok); err != nil { 5194 return err 5195 } 5196 } 5197 5198 if v.ServerName != nil { 5199 ok := object.Key("ServerName") 5200 ok.String(*v.ServerName) 5201 } 5202 5203 if v.ServiceAccessRoleArn != nil { 5204 ok := object.Key("ServiceAccessRoleArn") 5205 ok.String(*v.ServiceAccessRoleArn) 5206 } 5207 5208 if len(v.SslMode) > 0 { 5209 ok := object.Key("SslMode") 5210 ok.String(string(v.SslMode)) 5211 } 5212 5213 if v.SybaseSettings != nil { 5214 ok := object.Key("SybaseSettings") 5215 if err := awsAwsjson11_serializeDocumentSybaseSettings(v.SybaseSettings, ok); err != nil { 5216 return err 5217 } 5218 } 5219 5220 if v.Username != nil { 5221 ok := object.Key("Username") 5222 ok.String(*v.Username) 5223 } 5224 5225 return nil 5226} 5227 5228func awsAwsjson11_serializeOpDocumentModifyEventSubscriptionInput(v *ModifyEventSubscriptionInput, value smithyjson.Value) error { 5229 object := value.Object() 5230 defer object.Close() 5231 5232 if v.Enabled != nil { 5233 ok := object.Key("Enabled") 5234 ok.Boolean(*v.Enabled) 5235 } 5236 5237 if v.EventCategories != nil { 5238 ok := object.Key("EventCategories") 5239 if err := awsAwsjson11_serializeDocumentEventCategoriesList(v.EventCategories, ok); err != nil { 5240 return err 5241 } 5242 } 5243 5244 if v.SnsTopicArn != nil { 5245 ok := object.Key("SnsTopicArn") 5246 ok.String(*v.SnsTopicArn) 5247 } 5248 5249 if v.SourceType != nil { 5250 ok := object.Key("SourceType") 5251 ok.String(*v.SourceType) 5252 } 5253 5254 if v.SubscriptionName != nil { 5255 ok := object.Key("SubscriptionName") 5256 ok.String(*v.SubscriptionName) 5257 } 5258 5259 return nil 5260} 5261 5262func awsAwsjson11_serializeOpDocumentModifyReplicationInstanceInput(v *ModifyReplicationInstanceInput, value smithyjson.Value) error { 5263 object := value.Object() 5264 defer object.Close() 5265 5266 if v.AllocatedStorage != nil { 5267 ok := object.Key("AllocatedStorage") 5268 ok.Integer(*v.AllocatedStorage) 5269 } 5270 5271 if v.AllowMajorVersionUpgrade { 5272 ok := object.Key("AllowMajorVersionUpgrade") 5273 ok.Boolean(v.AllowMajorVersionUpgrade) 5274 } 5275 5276 if v.ApplyImmediately { 5277 ok := object.Key("ApplyImmediately") 5278 ok.Boolean(v.ApplyImmediately) 5279 } 5280 5281 if v.AutoMinorVersionUpgrade != nil { 5282 ok := object.Key("AutoMinorVersionUpgrade") 5283 ok.Boolean(*v.AutoMinorVersionUpgrade) 5284 } 5285 5286 if v.EngineVersion != nil { 5287 ok := object.Key("EngineVersion") 5288 ok.String(*v.EngineVersion) 5289 } 5290 5291 if v.MultiAZ != nil { 5292 ok := object.Key("MultiAZ") 5293 ok.Boolean(*v.MultiAZ) 5294 } 5295 5296 if v.PreferredMaintenanceWindow != nil { 5297 ok := object.Key("PreferredMaintenanceWindow") 5298 ok.String(*v.PreferredMaintenanceWindow) 5299 } 5300 5301 if v.ReplicationInstanceArn != nil { 5302 ok := object.Key("ReplicationInstanceArn") 5303 ok.String(*v.ReplicationInstanceArn) 5304 } 5305 5306 if v.ReplicationInstanceClass != nil { 5307 ok := object.Key("ReplicationInstanceClass") 5308 ok.String(*v.ReplicationInstanceClass) 5309 } 5310 5311 if v.ReplicationInstanceIdentifier != nil { 5312 ok := object.Key("ReplicationInstanceIdentifier") 5313 ok.String(*v.ReplicationInstanceIdentifier) 5314 } 5315 5316 if v.VpcSecurityGroupIds != nil { 5317 ok := object.Key("VpcSecurityGroupIds") 5318 if err := awsAwsjson11_serializeDocumentVpcSecurityGroupIdList(v.VpcSecurityGroupIds, ok); err != nil { 5319 return err 5320 } 5321 } 5322 5323 return nil 5324} 5325 5326func awsAwsjson11_serializeOpDocumentModifyReplicationSubnetGroupInput(v *ModifyReplicationSubnetGroupInput, value smithyjson.Value) error { 5327 object := value.Object() 5328 defer object.Close() 5329 5330 if v.ReplicationSubnetGroupDescription != nil { 5331 ok := object.Key("ReplicationSubnetGroupDescription") 5332 ok.String(*v.ReplicationSubnetGroupDescription) 5333 } 5334 5335 if v.ReplicationSubnetGroupIdentifier != nil { 5336 ok := object.Key("ReplicationSubnetGroupIdentifier") 5337 ok.String(*v.ReplicationSubnetGroupIdentifier) 5338 } 5339 5340 if v.SubnetIds != nil { 5341 ok := object.Key("SubnetIds") 5342 if err := awsAwsjson11_serializeDocumentSubnetIdentifierList(v.SubnetIds, ok); err != nil { 5343 return err 5344 } 5345 } 5346 5347 return nil 5348} 5349 5350func awsAwsjson11_serializeOpDocumentModifyReplicationTaskInput(v *ModifyReplicationTaskInput, value smithyjson.Value) error { 5351 object := value.Object() 5352 defer object.Close() 5353 5354 if v.CdcStartPosition != nil { 5355 ok := object.Key("CdcStartPosition") 5356 ok.String(*v.CdcStartPosition) 5357 } 5358 5359 if v.CdcStartTime != nil { 5360 ok := object.Key("CdcStartTime") 5361 ok.Double(smithytime.FormatEpochSeconds(*v.CdcStartTime)) 5362 } 5363 5364 if v.CdcStopPosition != nil { 5365 ok := object.Key("CdcStopPosition") 5366 ok.String(*v.CdcStopPosition) 5367 } 5368 5369 if len(v.MigrationType) > 0 { 5370 ok := object.Key("MigrationType") 5371 ok.String(string(v.MigrationType)) 5372 } 5373 5374 if v.ReplicationTaskArn != nil { 5375 ok := object.Key("ReplicationTaskArn") 5376 ok.String(*v.ReplicationTaskArn) 5377 } 5378 5379 if v.ReplicationTaskIdentifier != nil { 5380 ok := object.Key("ReplicationTaskIdentifier") 5381 ok.String(*v.ReplicationTaskIdentifier) 5382 } 5383 5384 if v.ReplicationTaskSettings != nil { 5385 ok := object.Key("ReplicationTaskSettings") 5386 ok.String(*v.ReplicationTaskSettings) 5387 } 5388 5389 if v.TableMappings != nil { 5390 ok := object.Key("TableMappings") 5391 ok.String(*v.TableMappings) 5392 } 5393 5394 if v.TaskData != nil { 5395 ok := object.Key("TaskData") 5396 ok.String(*v.TaskData) 5397 } 5398 5399 return nil 5400} 5401 5402func awsAwsjson11_serializeOpDocumentMoveReplicationTaskInput(v *MoveReplicationTaskInput, value smithyjson.Value) error { 5403 object := value.Object() 5404 defer object.Close() 5405 5406 if v.ReplicationTaskArn != nil { 5407 ok := object.Key("ReplicationTaskArn") 5408 ok.String(*v.ReplicationTaskArn) 5409 } 5410 5411 if v.TargetReplicationInstanceArn != nil { 5412 ok := object.Key("TargetReplicationInstanceArn") 5413 ok.String(*v.TargetReplicationInstanceArn) 5414 } 5415 5416 return nil 5417} 5418 5419func awsAwsjson11_serializeOpDocumentRebootReplicationInstanceInput(v *RebootReplicationInstanceInput, value smithyjson.Value) error { 5420 object := value.Object() 5421 defer object.Close() 5422 5423 if v.ForceFailover != nil { 5424 ok := object.Key("ForceFailover") 5425 ok.Boolean(*v.ForceFailover) 5426 } 5427 5428 if v.ReplicationInstanceArn != nil { 5429 ok := object.Key("ReplicationInstanceArn") 5430 ok.String(*v.ReplicationInstanceArn) 5431 } 5432 5433 return nil 5434} 5435 5436func awsAwsjson11_serializeOpDocumentRefreshSchemasInput(v *RefreshSchemasInput, value smithyjson.Value) error { 5437 object := value.Object() 5438 defer object.Close() 5439 5440 if v.EndpointArn != nil { 5441 ok := object.Key("EndpointArn") 5442 ok.String(*v.EndpointArn) 5443 } 5444 5445 if v.ReplicationInstanceArn != nil { 5446 ok := object.Key("ReplicationInstanceArn") 5447 ok.String(*v.ReplicationInstanceArn) 5448 } 5449 5450 return nil 5451} 5452 5453func awsAwsjson11_serializeOpDocumentReloadTablesInput(v *ReloadTablesInput, value smithyjson.Value) error { 5454 object := value.Object() 5455 defer object.Close() 5456 5457 if len(v.ReloadOption) > 0 { 5458 ok := object.Key("ReloadOption") 5459 ok.String(string(v.ReloadOption)) 5460 } 5461 5462 if v.ReplicationTaskArn != nil { 5463 ok := object.Key("ReplicationTaskArn") 5464 ok.String(*v.ReplicationTaskArn) 5465 } 5466 5467 if v.TablesToReload != nil { 5468 ok := object.Key("TablesToReload") 5469 if err := awsAwsjson11_serializeDocumentTableListToReload(v.TablesToReload, ok); err != nil { 5470 return err 5471 } 5472 } 5473 5474 return nil 5475} 5476 5477func awsAwsjson11_serializeOpDocumentRemoveTagsFromResourceInput(v *RemoveTagsFromResourceInput, value smithyjson.Value) error { 5478 object := value.Object() 5479 defer object.Close() 5480 5481 if v.ResourceArn != nil { 5482 ok := object.Key("ResourceArn") 5483 ok.String(*v.ResourceArn) 5484 } 5485 5486 if v.TagKeys != nil { 5487 ok := object.Key("TagKeys") 5488 if err := awsAwsjson11_serializeDocumentKeyList(v.TagKeys, ok); err != nil { 5489 return err 5490 } 5491 } 5492 5493 return nil 5494} 5495 5496func awsAwsjson11_serializeOpDocumentStartReplicationTaskAssessmentInput(v *StartReplicationTaskAssessmentInput, value smithyjson.Value) error { 5497 object := value.Object() 5498 defer object.Close() 5499 5500 if v.ReplicationTaskArn != nil { 5501 ok := object.Key("ReplicationTaskArn") 5502 ok.String(*v.ReplicationTaskArn) 5503 } 5504 5505 return nil 5506} 5507 5508func awsAwsjson11_serializeOpDocumentStartReplicationTaskAssessmentRunInput(v *StartReplicationTaskAssessmentRunInput, value smithyjson.Value) error { 5509 object := value.Object() 5510 defer object.Close() 5511 5512 if v.AssessmentRunName != nil { 5513 ok := object.Key("AssessmentRunName") 5514 ok.String(*v.AssessmentRunName) 5515 } 5516 5517 if v.Exclude != nil { 5518 ok := object.Key("Exclude") 5519 if err := awsAwsjson11_serializeDocumentExcludeTestList(v.Exclude, ok); err != nil { 5520 return err 5521 } 5522 } 5523 5524 if v.IncludeOnly != nil { 5525 ok := object.Key("IncludeOnly") 5526 if err := awsAwsjson11_serializeDocumentIncludeTestList(v.IncludeOnly, ok); err != nil { 5527 return err 5528 } 5529 } 5530 5531 if v.ReplicationTaskArn != nil { 5532 ok := object.Key("ReplicationTaskArn") 5533 ok.String(*v.ReplicationTaskArn) 5534 } 5535 5536 if v.ResultEncryptionMode != nil { 5537 ok := object.Key("ResultEncryptionMode") 5538 ok.String(*v.ResultEncryptionMode) 5539 } 5540 5541 if v.ResultKmsKeyArn != nil { 5542 ok := object.Key("ResultKmsKeyArn") 5543 ok.String(*v.ResultKmsKeyArn) 5544 } 5545 5546 if v.ResultLocationBucket != nil { 5547 ok := object.Key("ResultLocationBucket") 5548 ok.String(*v.ResultLocationBucket) 5549 } 5550 5551 if v.ResultLocationFolder != nil { 5552 ok := object.Key("ResultLocationFolder") 5553 ok.String(*v.ResultLocationFolder) 5554 } 5555 5556 if v.ServiceAccessRoleArn != nil { 5557 ok := object.Key("ServiceAccessRoleArn") 5558 ok.String(*v.ServiceAccessRoleArn) 5559 } 5560 5561 return nil 5562} 5563 5564func awsAwsjson11_serializeOpDocumentStartReplicationTaskInput(v *StartReplicationTaskInput, value smithyjson.Value) error { 5565 object := value.Object() 5566 defer object.Close() 5567 5568 if v.CdcStartPosition != nil { 5569 ok := object.Key("CdcStartPosition") 5570 ok.String(*v.CdcStartPosition) 5571 } 5572 5573 if v.CdcStartTime != nil { 5574 ok := object.Key("CdcStartTime") 5575 ok.Double(smithytime.FormatEpochSeconds(*v.CdcStartTime)) 5576 } 5577 5578 if v.CdcStopPosition != nil { 5579 ok := object.Key("CdcStopPosition") 5580 ok.String(*v.CdcStopPosition) 5581 } 5582 5583 if v.ReplicationTaskArn != nil { 5584 ok := object.Key("ReplicationTaskArn") 5585 ok.String(*v.ReplicationTaskArn) 5586 } 5587 5588 if len(v.StartReplicationTaskType) > 0 { 5589 ok := object.Key("StartReplicationTaskType") 5590 ok.String(string(v.StartReplicationTaskType)) 5591 } 5592 5593 return nil 5594} 5595 5596func awsAwsjson11_serializeOpDocumentStopReplicationTaskInput(v *StopReplicationTaskInput, value smithyjson.Value) error { 5597 object := value.Object() 5598 defer object.Close() 5599 5600 if v.ReplicationTaskArn != nil { 5601 ok := object.Key("ReplicationTaskArn") 5602 ok.String(*v.ReplicationTaskArn) 5603 } 5604 5605 return nil 5606} 5607 5608func awsAwsjson11_serializeOpDocumentTestConnectionInput(v *TestConnectionInput, value smithyjson.Value) error { 5609 object := value.Object() 5610 defer object.Close() 5611 5612 if v.EndpointArn != nil { 5613 ok := object.Key("EndpointArn") 5614 ok.String(*v.EndpointArn) 5615 } 5616 5617 if v.ReplicationInstanceArn != nil { 5618 ok := object.Key("ReplicationInstanceArn") 5619 ok.String(*v.ReplicationInstanceArn) 5620 } 5621 5622 return nil 5623} 5624