1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package dax 4 5import ( 6 "bytes" 7 "context" 8 "fmt" 9 "github.com/aws/aws-sdk-go-v2/service/dax/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_serializeOpCreateCluster struct { 19} 20 21func (*awsAwsjson11_serializeOpCreateCluster) ID() string { 22 return "OperationSerializer" 23} 24 25func (m *awsAwsjson11_serializeOpCreateCluster) 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.(*CreateClusterInput) 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("AmazonDAXV3.CreateCluster") 47 48 jsonEncoder := smithyjson.NewEncoder() 49 if err := awsAwsjson11_serializeOpDocumentCreateClusterInput(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_serializeOpCreateParameterGroup struct { 66} 67 68func (*awsAwsjson11_serializeOpCreateParameterGroup) ID() string { 69 return "OperationSerializer" 70} 71 72func (m *awsAwsjson11_serializeOpCreateParameterGroup) 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.(*CreateParameterGroupInput) 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("AmazonDAXV3.CreateParameterGroup") 94 95 jsonEncoder := smithyjson.NewEncoder() 96 if err := awsAwsjson11_serializeOpDocumentCreateParameterGroupInput(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_serializeOpCreateSubnetGroup struct { 113} 114 115func (*awsAwsjson11_serializeOpCreateSubnetGroup) ID() string { 116 return "OperationSerializer" 117} 118 119func (m *awsAwsjson11_serializeOpCreateSubnetGroup) 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.(*CreateSubnetGroupInput) 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("AmazonDAXV3.CreateSubnetGroup") 141 142 jsonEncoder := smithyjson.NewEncoder() 143 if err := awsAwsjson11_serializeOpDocumentCreateSubnetGroupInput(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_serializeOpDecreaseReplicationFactor struct { 160} 161 162func (*awsAwsjson11_serializeOpDecreaseReplicationFactor) ID() string { 163 return "OperationSerializer" 164} 165 166func (m *awsAwsjson11_serializeOpDecreaseReplicationFactor) 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.(*DecreaseReplicationFactorInput) 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("AmazonDAXV3.DecreaseReplicationFactor") 188 189 jsonEncoder := smithyjson.NewEncoder() 190 if err := awsAwsjson11_serializeOpDocumentDecreaseReplicationFactorInput(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_serializeOpDeleteCluster struct { 207} 208 209func (*awsAwsjson11_serializeOpDeleteCluster) ID() string { 210 return "OperationSerializer" 211} 212 213func (m *awsAwsjson11_serializeOpDeleteCluster) 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.(*DeleteClusterInput) 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("AmazonDAXV3.DeleteCluster") 235 236 jsonEncoder := smithyjson.NewEncoder() 237 if err := awsAwsjson11_serializeOpDocumentDeleteClusterInput(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_serializeOpDeleteParameterGroup struct { 254} 255 256func (*awsAwsjson11_serializeOpDeleteParameterGroup) ID() string { 257 return "OperationSerializer" 258} 259 260func (m *awsAwsjson11_serializeOpDeleteParameterGroup) 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.(*DeleteParameterGroupInput) 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("AmazonDAXV3.DeleteParameterGroup") 282 283 jsonEncoder := smithyjson.NewEncoder() 284 if err := awsAwsjson11_serializeOpDocumentDeleteParameterGroupInput(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_serializeOpDeleteSubnetGroup struct { 301} 302 303func (*awsAwsjson11_serializeOpDeleteSubnetGroup) ID() string { 304 return "OperationSerializer" 305} 306 307func (m *awsAwsjson11_serializeOpDeleteSubnetGroup) 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.(*DeleteSubnetGroupInput) 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("AmazonDAXV3.DeleteSubnetGroup") 329 330 jsonEncoder := smithyjson.NewEncoder() 331 if err := awsAwsjson11_serializeOpDocumentDeleteSubnetGroupInput(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_serializeOpDescribeClusters struct { 348} 349 350func (*awsAwsjson11_serializeOpDescribeClusters) ID() string { 351 return "OperationSerializer" 352} 353 354func (m *awsAwsjson11_serializeOpDescribeClusters) 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.(*DescribeClustersInput) 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("AmazonDAXV3.DescribeClusters") 376 377 jsonEncoder := smithyjson.NewEncoder() 378 if err := awsAwsjson11_serializeOpDocumentDescribeClustersInput(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_serializeOpDescribeDefaultParameters struct { 395} 396 397func (*awsAwsjson11_serializeOpDescribeDefaultParameters) ID() string { 398 return "OperationSerializer" 399} 400 401func (m *awsAwsjson11_serializeOpDescribeDefaultParameters) 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.(*DescribeDefaultParametersInput) 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("AmazonDAXV3.DescribeDefaultParameters") 423 424 jsonEncoder := smithyjson.NewEncoder() 425 if err := awsAwsjson11_serializeOpDocumentDescribeDefaultParametersInput(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_serializeOpDescribeEvents struct { 442} 443 444func (*awsAwsjson11_serializeOpDescribeEvents) ID() string { 445 return "OperationSerializer" 446} 447 448func (m *awsAwsjson11_serializeOpDescribeEvents) 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.(*DescribeEventsInput) 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("AmazonDAXV3.DescribeEvents") 470 471 jsonEncoder := smithyjson.NewEncoder() 472 if err := awsAwsjson11_serializeOpDocumentDescribeEventsInput(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_serializeOpDescribeParameterGroups struct { 489} 490 491func (*awsAwsjson11_serializeOpDescribeParameterGroups) ID() string { 492 return "OperationSerializer" 493} 494 495func (m *awsAwsjson11_serializeOpDescribeParameterGroups) 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.(*DescribeParameterGroupsInput) 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("AmazonDAXV3.DescribeParameterGroups") 517 518 jsonEncoder := smithyjson.NewEncoder() 519 if err := awsAwsjson11_serializeOpDocumentDescribeParameterGroupsInput(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_serializeOpDescribeParameters struct { 536} 537 538func (*awsAwsjson11_serializeOpDescribeParameters) ID() string { 539 return "OperationSerializer" 540} 541 542func (m *awsAwsjson11_serializeOpDescribeParameters) 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.(*DescribeParametersInput) 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("AmazonDAXV3.DescribeParameters") 564 565 jsonEncoder := smithyjson.NewEncoder() 566 if err := awsAwsjson11_serializeOpDocumentDescribeParametersInput(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_serializeOpDescribeSubnetGroups struct { 583} 584 585func (*awsAwsjson11_serializeOpDescribeSubnetGroups) ID() string { 586 return "OperationSerializer" 587} 588 589func (m *awsAwsjson11_serializeOpDescribeSubnetGroups) 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.(*DescribeSubnetGroupsInput) 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("AmazonDAXV3.DescribeSubnetGroups") 611 612 jsonEncoder := smithyjson.NewEncoder() 613 if err := awsAwsjson11_serializeOpDocumentDescribeSubnetGroupsInput(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_serializeOpIncreaseReplicationFactor struct { 630} 631 632func (*awsAwsjson11_serializeOpIncreaseReplicationFactor) ID() string { 633 return "OperationSerializer" 634} 635 636func (m *awsAwsjson11_serializeOpIncreaseReplicationFactor) 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.(*IncreaseReplicationFactorInput) 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("AmazonDAXV3.IncreaseReplicationFactor") 658 659 jsonEncoder := smithyjson.NewEncoder() 660 if err := awsAwsjson11_serializeOpDocumentIncreaseReplicationFactorInput(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_serializeOpListTags struct { 677} 678 679func (*awsAwsjson11_serializeOpListTags) ID() string { 680 return "OperationSerializer" 681} 682 683func (m *awsAwsjson11_serializeOpListTags) 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.(*ListTagsInput) 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("AmazonDAXV3.ListTags") 705 706 jsonEncoder := smithyjson.NewEncoder() 707 if err := awsAwsjson11_serializeOpDocumentListTagsInput(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_serializeOpRebootNode struct { 724} 725 726func (*awsAwsjson11_serializeOpRebootNode) ID() string { 727 return "OperationSerializer" 728} 729 730func (m *awsAwsjson11_serializeOpRebootNode) 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.(*RebootNodeInput) 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("AmazonDAXV3.RebootNode") 752 753 jsonEncoder := smithyjson.NewEncoder() 754 if err := awsAwsjson11_serializeOpDocumentRebootNodeInput(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_serializeOpTagResource struct { 771} 772 773func (*awsAwsjson11_serializeOpTagResource) ID() string { 774 return "OperationSerializer" 775} 776 777func (m *awsAwsjson11_serializeOpTagResource) 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.(*TagResourceInput) 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("AmazonDAXV3.TagResource") 799 800 jsonEncoder := smithyjson.NewEncoder() 801 if err := awsAwsjson11_serializeOpDocumentTagResourceInput(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_serializeOpUntagResource struct { 818} 819 820func (*awsAwsjson11_serializeOpUntagResource) ID() string { 821 return "OperationSerializer" 822} 823 824func (m *awsAwsjson11_serializeOpUntagResource) 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.(*UntagResourceInput) 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("AmazonDAXV3.UntagResource") 846 847 jsonEncoder := smithyjson.NewEncoder() 848 if err := awsAwsjson11_serializeOpDocumentUntagResourceInput(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_serializeOpUpdateCluster struct { 865} 866 867func (*awsAwsjson11_serializeOpUpdateCluster) ID() string { 868 return "OperationSerializer" 869} 870 871func (m *awsAwsjson11_serializeOpUpdateCluster) 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.(*UpdateClusterInput) 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("AmazonDAXV3.UpdateCluster") 893 894 jsonEncoder := smithyjson.NewEncoder() 895 if err := awsAwsjson11_serializeOpDocumentUpdateClusterInput(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_serializeOpUpdateParameterGroup struct { 912} 913 914func (*awsAwsjson11_serializeOpUpdateParameterGroup) ID() string { 915 return "OperationSerializer" 916} 917 918func (m *awsAwsjson11_serializeOpUpdateParameterGroup) 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.(*UpdateParameterGroupInput) 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("AmazonDAXV3.UpdateParameterGroup") 940 941 jsonEncoder := smithyjson.NewEncoder() 942 if err := awsAwsjson11_serializeOpDocumentUpdateParameterGroupInput(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_serializeOpUpdateSubnetGroup struct { 959} 960 961func (*awsAwsjson11_serializeOpUpdateSubnetGroup) ID() string { 962 return "OperationSerializer" 963} 964 965func (m *awsAwsjson11_serializeOpUpdateSubnetGroup) 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.(*UpdateSubnetGroupInput) 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("AmazonDAXV3.UpdateSubnetGroup") 987 988 jsonEncoder := smithyjson.NewEncoder() 989 if err := awsAwsjson11_serializeOpDocumentUpdateSubnetGroupInput(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} 1004func awsAwsjson11_serializeDocumentAvailabilityZoneList(v []string, value smithyjson.Value) error { 1005 array := value.Array() 1006 defer array.Close() 1007 1008 for i := range v { 1009 av := array.Value() 1010 av.String(v[i]) 1011 } 1012 return nil 1013} 1014 1015func awsAwsjson11_serializeDocumentClusterNameList(v []string, value smithyjson.Value) error { 1016 array := value.Array() 1017 defer array.Close() 1018 1019 for i := range v { 1020 av := array.Value() 1021 av.String(v[i]) 1022 } 1023 return nil 1024} 1025 1026func awsAwsjson11_serializeDocumentKeyList(v []string, value smithyjson.Value) error { 1027 array := value.Array() 1028 defer array.Close() 1029 1030 for i := range v { 1031 av := array.Value() 1032 av.String(v[i]) 1033 } 1034 return nil 1035} 1036 1037func awsAwsjson11_serializeDocumentNodeIdentifierList(v []string, value smithyjson.Value) error { 1038 array := value.Array() 1039 defer array.Close() 1040 1041 for i := range v { 1042 av := array.Value() 1043 av.String(v[i]) 1044 } 1045 return nil 1046} 1047 1048func awsAwsjson11_serializeDocumentParameterGroupNameList(v []string, value smithyjson.Value) error { 1049 array := value.Array() 1050 defer array.Close() 1051 1052 for i := range v { 1053 av := array.Value() 1054 av.String(v[i]) 1055 } 1056 return nil 1057} 1058 1059func awsAwsjson11_serializeDocumentParameterNameValue(v *types.ParameterNameValue, value smithyjson.Value) error { 1060 object := value.Object() 1061 defer object.Close() 1062 1063 if v.ParameterName != nil { 1064 ok := object.Key("ParameterName") 1065 ok.String(*v.ParameterName) 1066 } 1067 1068 if v.ParameterValue != nil { 1069 ok := object.Key("ParameterValue") 1070 ok.String(*v.ParameterValue) 1071 } 1072 1073 return nil 1074} 1075 1076func awsAwsjson11_serializeDocumentParameterNameValueList(v []types.ParameterNameValue, value smithyjson.Value) error { 1077 array := value.Array() 1078 defer array.Close() 1079 1080 for i := range v { 1081 av := array.Value() 1082 if err := awsAwsjson11_serializeDocumentParameterNameValue(&v[i], av); err != nil { 1083 return err 1084 } 1085 } 1086 return nil 1087} 1088 1089func awsAwsjson11_serializeDocumentSecurityGroupIdentifierList(v []string, value smithyjson.Value) error { 1090 array := value.Array() 1091 defer array.Close() 1092 1093 for i := range v { 1094 av := array.Value() 1095 av.String(v[i]) 1096 } 1097 return nil 1098} 1099 1100func awsAwsjson11_serializeDocumentSSESpecification(v *types.SSESpecification, value smithyjson.Value) error { 1101 object := value.Object() 1102 defer object.Close() 1103 1104 if v.Enabled != nil { 1105 ok := object.Key("Enabled") 1106 ok.Boolean(*v.Enabled) 1107 } 1108 1109 return nil 1110} 1111 1112func awsAwsjson11_serializeDocumentSubnetGroupNameList(v []string, value smithyjson.Value) error { 1113 array := value.Array() 1114 defer array.Close() 1115 1116 for i := range v { 1117 av := array.Value() 1118 av.String(v[i]) 1119 } 1120 return nil 1121} 1122 1123func awsAwsjson11_serializeDocumentSubnetIdentifierList(v []string, value smithyjson.Value) error { 1124 array := value.Array() 1125 defer array.Close() 1126 1127 for i := range v { 1128 av := array.Value() 1129 av.String(v[i]) 1130 } 1131 return nil 1132} 1133 1134func awsAwsjson11_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { 1135 object := value.Object() 1136 defer object.Close() 1137 1138 if v.Key != nil { 1139 ok := object.Key("Key") 1140 ok.String(*v.Key) 1141 } 1142 1143 if v.Value != nil { 1144 ok := object.Key("Value") 1145 ok.String(*v.Value) 1146 } 1147 1148 return nil 1149} 1150 1151func awsAwsjson11_serializeDocumentTagList(v []types.Tag, value smithyjson.Value) error { 1152 array := value.Array() 1153 defer array.Close() 1154 1155 for i := range v { 1156 av := array.Value() 1157 if err := awsAwsjson11_serializeDocumentTag(&v[i], av); err != nil { 1158 return err 1159 } 1160 } 1161 return nil 1162} 1163 1164func awsAwsjson11_serializeOpDocumentCreateClusterInput(v *CreateClusterInput, value smithyjson.Value) error { 1165 object := value.Object() 1166 defer object.Close() 1167 1168 if v.AvailabilityZones != nil { 1169 ok := object.Key("AvailabilityZones") 1170 if err := awsAwsjson11_serializeDocumentAvailabilityZoneList(v.AvailabilityZones, ok); err != nil { 1171 return err 1172 } 1173 } 1174 1175 if v.ClusterName != nil { 1176 ok := object.Key("ClusterName") 1177 ok.String(*v.ClusterName) 1178 } 1179 1180 if v.Description != nil { 1181 ok := object.Key("Description") 1182 ok.String(*v.Description) 1183 } 1184 1185 if v.IamRoleArn != nil { 1186 ok := object.Key("IamRoleArn") 1187 ok.String(*v.IamRoleArn) 1188 } 1189 1190 if v.NodeType != nil { 1191 ok := object.Key("NodeType") 1192 ok.String(*v.NodeType) 1193 } 1194 1195 if v.NotificationTopicArn != nil { 1196 ok := object.Key("NotificationTopicArn") 1197 ok.String(*v.NotificationTopicArn) 1198 } 1199 1200 if v.ParameterGroupName != nil { 1201 ok := object.Key("ParameterGroupName") 1202 ok.String(*v.ParameterGroupName) 1203 } 1204 1205 if v.PreferredMaintenanceWindow != nil { 1206 ok := object.Key("PreferredMaintenanceWindow") 1207 ok.String(*v.PreferredMaintenanceWindow) 1208 } 1209 1210 if v.ReplicationFactor != 0 { 1211 ok := object.Key("ReplicationFactor") 1212 ok.Integer(v.ReplicationFactor) 1213 } 1214 1215 if v.SecurityGroupIds != nil { 1216 ok := object.Key("SecurityGroupIds") 1217 if err := awsAwsjson11_serializeDocumentSecurityGroupIdentifierList(v.SecurityGroupIds, ok); err != nil { 1218 return err 1219 } 1220 } 1221 1222 if v.SSESpecification != nil { 1223 ok := object.Key("SSESpecification") 1224 if err := awsAwsjson11_serializeDocumentSSESpecification(v.SSESpecification, ok); err != nil { 1225 return err 1226 } 1227 } 1228 1229 if v.SubnetGroupName != nil { 1230 ok := object.Key("SubnetGroupName") 1231 ok.String(*v.SubnetGroupName) 1232 } 1233 1234 if v.Tags != nil { 1235 ok := object.Key("Tags") 1236 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 1237 return err 1238 } 1239 } 1240 1241 return nil 1242} 1243 1244func awsAwsjson11_serializeOpDocumentCreateParameterGroupInput(v *CreateParameterGroupInput, value smithyjson.Value) error { 1245 object := value.Object() 1246 defer object.Close() 1247 1248 if v.Description != nil { 1249 ok := object.Key("Description") 1250 ok.String(*v.Description) 1251 } 1252 1253 if v.ParameterGroupName != nil { 1254 ok := object.Key("ParameterGroupName") 1255 ok.String(*v.ParameterGroupName) 1256 } 1257 1258 return nil 1259} 1260 1261func awsAwsjson11_serializeOpDocumentCreateSubnetGroupInput(v *CreateSubnetGroupInput, value smithyjson.Value) error { 1262 object := value.Object() 1263 defer object.Close() 1264 1265 if v.Description != nil { 1266 ok := object.Key("Description") 1267 ok.String(*v.Description) 1268 } 1269 1270 if v.SubnetGroupName != nil { 1271 ok := object.Key("SubnetGroupName") 1272 ok.String(*v.SubnetGroupName) 1273 } 1274 1275 if v.SubnetIds != nil { 1276 ok := object.Key("SubnetIds") 1277 if err := awsAwsjson11_serializeDocumentSubnetIdentifierList(v.SubnetIds, ok); err != nil { 1278 return err 1279 } 1280 } 1281 1282 return nil 1283} 1284 1285func awsAwsjson11_serializeOpDocumentDecreaseReplicationFactorInput(v *DecreaseReplicationFactorInput, value smithyjson.Value) error { 1286 object := value.Object() 1287 defer object.Close() 1288 1289 if v.AvailabilityZones != nil { 1290 ok := object.Key("AvailabilityZones") 1291 if err := awsAwsjson11_serializeDocumentAvailabilityZoneList(v.AvailabilityZones, ok); err != nil { 1292 return err 1293 } 1294 } 1295 1296 if v.ClusterName != nil { 1297 ok := object.Key("ClusterName") 1298 ok.String(*v.ClusterName) 1299 } 1300 1301 if v.NewReplicationFactor != 0 { 1302 ok := object.Key("NewReplicationFactor") 1303 ok.Integer(v.NewReplicationFactor) 1304 } 1305 1306 if v.NodeIdsToRemove != nil { 1307 ok := object.Key("NodeIdsToRemove") 1308 if err := awsAwsjson11_serializeDocumentNodeIdentifierList(v.NodeIdsToRemove, ok); err != nil { 1309 return err 1310 } 1311 } 1312 1313 return nil 1314} 1315 1316func awsAwsjson11_serializeOpDocumentDeleteClusterInput(v *DeleteClusterInput, value smithyjson.Value) error { 1317 object := value.Object() 1318 defer object.Close() 1319 1320 if v.ClusterName != nil { 1321 ok := object.Key("ClusterName") 1322 ok.String(*v.ClusterName) 1323 } 1324 1325 return nil 1326} 1327 1328func awsAwsjson11_serializeOpDocumentDeleteParameterGroupInput(v *DeleteParameterGroupInput, value smithyjson.Value) error { 1329 object := value.Object() 1330 defer object.Close() 1331 1332 if v.ParameterGroupName != nil { 1333 ok := object.Key("ParameterGroupName") 1334 ok.String(*v.ParameterGroupName) 1335 } 1336 1337 return nil 1338} 1339 1340func awsAwsjson11_serializeOpDocumentDeleteSubnetGroupInput(v *DeleteSubnetGroupInput, value smithyjson.Value) error { 1341 object := value.Object() 1342 defer object.Close() 1343 1344 if v.SubnetGroupName != nil { 1345 ok := object.Key("SubnetGroupName") 1346 ok.String(*v.SubnetGroupName) 1347 } 1348 1349 return nil 1350} 1351 1352func awsAwsjson11_serializeOpDocumentDescribeClustersInput(v *DescribeClustersInput, value smithyjson.Value) error { 1353 object := value.Object() 1354 defer object.Close() 1355 1356 if v.ClusterNames != nil { 1357 ok := object.Key("ClusterNames") 1358 if err := awsAwsjson11_serializeDocumentClusterNameList(v.ClusterNames, ok); err != nil { 1359 return err 1360 } 1361 } 1362 1363 if v.MaxResults != nil { 1364 ok := object.Key("MaxResults") 1365 ok.Integer(*v.MaxResults) 1366 } 1367 1368 if v.NextToken != nil { 1369 ok := object.Key("NextToken") 1370 ok.String(*v.NextToken) 1371 } 1372 1373 return nil 1374} 1375 1376func awsAwsjson11_serializeOpDocumentDescribeDefaultParametersInput(v *DescribeDefaultParametersInput, value smithyjson.Value) error { 1377 object := value.Object() 1378 defer object.Close() 1379 1380 if v.MaxResults != nil { 1381 ok := object.Key("MaxResults") 1382 ok.Integer(*v.MaxResults) 1383 } 1384 1385 if v.NextToken != nil { 1386 ok := object.Key("NextToken") 1387 ok.String(*v.NextToken) 1388 } 1389 1390 return nil 1391} 1392 1393func awsAwsjson11_serializeOpDocumentDescribeEventsInput(v *DescribeEventsInput, value smithyjson.Value) error { 1394 object := value.Object() 1395 defer object.Close() 1396 1397 if v.Duration != nil { 1398 ok := object.Key("Duration") 1399 ok.Integer(*v.Duration) 1400 } 1401 1402 if v.EndTime != nil { 1403 ok := object.Key("EndTime") 1404 ok.Double(smithytime.FormatEpochSeconds(*v.EndTime)) 1405 } 1406 1407 if v.MaxResults != nil { 1408 ok := object.Key("MaxResults") 1409 ok.Integer(*v.MaxResults) 1410 } 1411 1412 if v.NextToken != nil { 1413 ok := object.Key("NextToken") 1414 ok.String(*v.NextToken) 1415 } 1416 1417 if v.SourceName != nil { 1418 ok := object.Key("SourceName") 1419 ok.String(*v.SourceName) 1420 } 1421 1422 if len(v.SourceType) > 0 { 1423 ok := object.Key("SourceType") 1424 ok.String(string(v.SourceType)) 1425 } 1426 1427 if v.StartTime != nil { 1428 ok := object.Key("StartTime") 1429 ok.Double(smithytime.FormatEpochSeconds(*v.StartTime)) 1430 } 1431 1432 return nil 1433} 1434 1435func awsAwsjson11_serializeOpDocumentDescribeParameterGroupsInput(v *DescribeParameterGroupsInput, value smithyjson.Value) error { 1436 object := value.Object() 1437 defer object.Close() 1438 1439 if v.MaxResults != nil { 1440 ok := object.Key("MaxResults") 1441 ok.Integer(*v.MaxResults) 1442 } 1443 1444 if v.NextToken != nil { 1445 ok := object.Key("NextToken") 1446 ok.String(*v.NextToken) 1447 } 1448 1449 if v.ParameterGroupNames != nil { 1450 ok := object.Key("ParameterGroupNames") 1451 if err := awsAwsjson11_serializeDocumentParameterGroupNameList(v.ParameterGroupNames, ok); err != nil { 1452 return err 1453 } 1454 } 1455 1456 return nil 1457} 1458 1459func awsAwsjson11_serializeOpDocumentDescribeParametersInput(v *DescribeParametersInput, value smithyjson.Value) error { 1460 object := value.Object() 1461 defer object.Close() 1462 1463 if v.MaxResults != nil { 1464 ok := object.Key("MaxResults") 1465 ok.Integer(*v.MaxResults) 1466 } 1467 1468 if v.NextToken != nil { 1469 ok := object.Key("NextToken") 1470 ok.String(*v.NextToken) 1471 } 1472 1473 if v.ParameterGroupName != nil { 1474 ok := object.Key("ParameterGroupName") 1475 ok.String(*v.ParameterGroupName) 1476 } 1477 1478 if v.Source != nil { 1479 ok := object.Key("Source") 1480 ok.String(*v.Source) 1481 } 1482 1483 return nil 1484} 1485 1486func awsAwsjson11_serializeOpDocumentDescribeSubnetGroupsInput(v *DescribeSubnetGroupsInput, value smithyjson.Value) error { 1487 object := value.Object() 1488 defer object.Close() 1489 1490 if v.MaxResults != nil { 1491 ok := object.Key("MaxResults") 1492 ok.Integer(*v.MaxResults) 1493 } 1494 1495 if v.NextToken != nil { 1496 ok := object.Key("NextToken") 1497 ok.String(*v.NextToken) 1498 } 1499 1500 if v.SubnetGroupNames != nil { 1501 ok := object.Key("SubnetGroupNames") 1502 if err := awsAwsjson11_serializeDocumentSubnetGroupNameList(v.SubnetGroupNames, ok); err != nil { 1503 return err 1504 } 1505 } 1506 1507 return nil 1508} 1509 1510func awsAwsjson11_serializeOpDocumentIncreaseReplicationFactorInput(v *IncreaseReplicationFactorInput, value smithyjson.Value) error { 1511 object := value.Object() 1512 defer object.Close() 1513 1514 if v.AvailabilityZones != nil { 1515 ok := object.Key("AvailabilityZones") 1516 if err := awsAwsjson11_serializeDocumentAvailabilityZoneList(v.AvailabilityZones, ok); err != nil { 1517 return err 1518 } 1519 } 1520 1521 if v.ClusterName != nil { 1522 ok := object.Key("ClusterName") 1523 ok.String(*v.ClusterName) 1524 } 1525 1526 if v.NewReplicationFactor != 0 { 1527 ok := object.Key("NewReplicationFactor") 1528 ok.Integer(v.NewReplicationFactor) 1529 } 1530 1531 return nil 1532} 1533 1534func awsAwsjson11_serializeOpDocumentListTagsInput(v *ListTagsInput, value smithyjson.Value) error { 1535 object := value.Object() 1536 defer object.Close() 1537 1538 if v.NextToken != nil { 1539 ok := object.Key("NextToken") 1540 ok.String(*v.NextToken) 1541 } 1542 1543 if v.ResourceName != nil { 1544 ok := object.Key("ResourceName") 1545 ok.String(*v.ResourceName) 1546 } 1547 1548 return nil 1549} 1550 1551func awsAwsjson11_serializeOpDocumentRebootNodeInput(v *RebootNodeInput, value smithyjson.Value) error { 1552 object := value.Object() 1553 defer object.Close() 1554 1555 if v.ClusterName != nil { 1556 ok := object.Key("ClusterName") 1557 ok.String(*v.ClusterName) 1558 } 1559 1560 if v.NodeId != nil { 1561 ok := object.Key("NodeId") 1562 ok.String(*v.NodeId) 1563 } 1564 1565 return nil 1566} 1567 1568func awsAwsjson11_serializeOpDocumentTagResourceInput(v *TagResourceInput, value smithyjson.Value) error { 1569 object := value.Object() 1570 defer object.Close() 1571 1572 if v.ResourceName != nil { 1573 ok := object.Key("ResourceName") 1574 ok.String(*v.ResourceName) 1575 } 1576 1577 if v.Tags != nil { 1578 ok := object.Key("Tags") 1579 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 1580 return err 1581 } 1582 } 1583 1584 return nil 1585} 1586 1587func awsAwsjson11_serializeOpDocumentUntagResourceInput(v *UntagResourceInput, value smithyjson.Value) error { 1588 object := value.Object() 1589 defer object.Close() 1590 1591 if v.ResourceName != nil { 1592 ok := object.Key("ResourceName") 1593 ok.String(*v.ResourceName) 1594 } 1595 1596 if v.TagKeys != nil { 1597 ok := object.Key("TagKeys") 1598 if err := awsAwsjson11_serializeDocumentKeyList(v.TagKeys, ok); err != nil { 1599 return err 1600 } 1601 } 1602 1603 return nil 1604} 1605 1606func awsAwsjson11_serializeOpDocumentUpdateClusterInput(v *UpdateClusterInput, value smithyjson.Value) error { 1607 object := value.Object() 1608 defer object.Close() 1609 1610 if v.ClusterName != nil { 1611 ok := object.Key("ClusterName") 1612 ok.String(*v.ClusterName) 1613 } 1614 1615 if v.Description != nil { 1616 ok := object.Key("Description") 1617 ok.String(*v.Description) 1618 } 1619 1620 if v.NotificationTopicArn != nil { 1621 ok := object.Key("NotificationTopicArn") 1622 ok.String(*v.NotificationTopicArn) 1623 } 1624 1625 if v.NotificationTopicStatus != nil { 1626 ok := object.Key("NotificationTopicStatus") 1627 ok.String(*v.NotificationTopicStatus) 1628 } 1629 1630 if v.ParameterGroupName != nil { 1631 ok := object.Key("ParameterGroupName") 1632 ok.String(*v.ParameterGroupName) 1633 } 1634 1635 if v.PreferredMaintenanceWindow != nil { 1636 ok := object.Key("PreferredMaintenanceWindow") 1637 ok.String(*v.PreferredMaintenanceWindow) 1638 } 1639 1640 if v.SecurityGroupIds != nil { 1641 ok := object.Key("SecurityGroupIds") 1642 if err := awsAwsjson11_serializeDocumentSecurityGroupIdentifierList(v.SecurityGroupIds, ok); err != nil { 1643 return err 1644 } 1645 } 1646 1647 return nil 1648} 1649 1650func awsAwsjson11_serializeOpDocumentUpdateParameterGroupInput(v *UpdateParameterGroupInput, value smithyjson.Value) error { 1651 object := value.Object() 1652 defer object.Close() 1653 1654 if v.ParameterGroupName != nil { 1655 ok := object.Key("ParameterGroupName") 1656 ok.String(*v.ParameterGroupName) 1657 } 1658 1659 if v.ParameterNameValues != nil { 1660 ok := object.Key("ParameterNameValues") 1661 if err := awsAwsjson11_serializeDocumentParameterNameValueList(v.ParameterNameValues, ok); err != nil { 1662 return err 1663 } 1664 } 1665 1666 return nil 1667} 1668 1669func awsAwsjson11_serializeOpDocumentUpdateSubnetGroupInput(v *UpdateSubnetGroupInput, value smithyjson.Value) error { 1670 object := value.Object() 1671 defer object.Close() 1672 1673 if v.Description != nil { 1674 ok := object.Key("Description") 1675 ok.String(*v.Description) 1676 } 1677 1678 if v.SubnetGroupName != nil { 1679 ok := object.Key("SubnetGroupName") 1680 ok.String(*v.SubnetGroupName) 1681 } 1682 1683 if v.SubnetIds != nil { 1684 ok := object.Key("SubnetIds") 1685 if err := awsAwsjson11_serializeDocumentSubnetIdentifierList(v.SubnetIds, ok); err != nil { 1686 return err 1687 } 1688 } 1689 1690 return nil 1691} 1692