1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package datapipeline 4 5import ( 6 "bytes" 7 "context" 8 "fmt" 9 "github.com/aws/aws-sdk-go-v2/service/datapipeline/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_serializeOpActivatePipeline struct { 19} 20 21func (*awsAwsjson11_serializeOpActivatePipeline) ID() string { 22 return "OperationSerializer" 23} 24 25func (m *awsAwsjson11_serializeOpActivatePipeline) 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.(*ActivatePipelineInput) 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("DataPipeline.ActivatePipeline") 47 48 jsonEncoder := smithyjson.NewEncoder() 49 if err := awsAwsjson11_serializeOpDocumentActivatePipelineInput(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_serializeOpAddTags struct { 66} 67 68func (*awsAwsjson11_serializeOpAddTags) ID() string { 69 return "OperationSerializer" 70} 71 72func (m *awsAwsjson11_serializeOpAddTags) 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.(*AddTagsInput) 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("DataPipeline.AddTags") 94 95 jsonEncoder := smithyjson.NewEncoder() 96 if err := awsAwsjson11_serializeOpDocumentAddTagsInput(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_serializeOpCreatePipeline struct { 113} 114 115func (*awsAwsjson11_serializeOpCreatePipeline) ID() string { 116 return "OperationSerializer" 117} 118 119func (m *awsAwsjson11_serializeOpCreatePipeline) 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.(*CreatePipelineInput) 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("DataPipeline.CreatePipeline") 141 142 jsonEncoder := smithyjson.NewEncoder() 143 if err := awsAwsjson11_serializeOpDocumentCreatePipelineInput(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_serializeOpDeactivatePipeline struct { 160} 161 162func (*awsAwsjson11_serializeOpDeactivatePipeline) ID() string { 163 return "OperationSerializer" 164} 165 166func (m *awsAwsjson11_serializeOpDeactivatePipeline) 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.(*DeactivatePipelineInput) 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("DataPipeline.DeactivatePipeline") 188 189 jsonEncoder := smithyjson.NewEncoder() 190 if err := awsAwsjson11_serializeOpDocumentDeactivatePipelineInput(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_serializeOpDeletePipeline struct { 207} 208 209func (*awsAwsjson11_serializeOpDeletePipeline) ID() string { 210 return "OperationSerializer" 211} 212 213func (m *awsAwsjson11_serializeOpDeletePipeline) 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.(*DeletePipelineInput) 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("DataPipeline.DeletePipeline") 235 236 jsonEncoder := smithyjson.NewEncoder() 237 if err := awsAwsjson11_serializeOpDocumentDeletePipelineInput(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_serializeOpDescribeObjects struct { 254} 255 256func (*awsAwsjson11_serializeOpDescribeObjects) ID() string { 257 return "OperationSerializer" 258} 259 260func (m *awsAwsjson11_serializeOpDescribeObjects) 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.(*DescribeObjectsInput) 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("DataPipeline.DescribeObjects") 282 283 jsonEncoder := smithyjson.NewEncoder() 284 if err := awsAwsjson11_serializeOpDocumentDescribeObjectsInput(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_serializeOpDescribePipelines struct { 301} 302 303func (*awsAwsjson11_serializeOpDescribePipelines) ID() string { 304 return "OperationSerializer" 305} 306 307func (m *awsAwsjson11_serializeOpDescribePipelines) 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.(*DescribePipelinesInput) 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("DataPipeline.DescribePipelines") 329 330 jsonEncoder := smithyjson.NewEncoder() 331 if err := awsAwsjson11_serializeOpDocumentDescribePipelinesInput(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_serializeOpEvaluateExpression struct { 348} 349 350func (*awsAwsjson11_serializeOpEvaluateExpression) ID() string { 351 return "OperationSerializer" 352} 353 354func (m *awsAwsjson11_serializeOpEvaluateExpression) 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.(*EvaluateExpressionInput) 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("DataPipeline.EvaluateExpression") 376 377 jsonEncoder := smithyjson.NewEncoder() 378 if err := awsAwsjson11_serializeOpDocumentEvaluateExpressionInput(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_serializeOpGetPipelineDefinition struct { 395} 396 397func (*awsAwsjson11_serializeOpGetPipelineDefinition) ID() string { 398 return "OperationSerializer" 399} 400 401func (m *awsAwsjson11_serializeOpGetPipelineDefinition) 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.(*GetPipelineDefinitionInput) 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("DataPipeline.GetPipelineDefinition") 423 424 jsonEncoder := smithyjson.NewEncoder() 425 if err := awsAwsjson11_serializeOpDocumentGetPipelineDefinitionInput(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_serializeOpListPipelines struct { 442} 443 444func (*awsAwsjson11_serializeOpListPipelines) ID() string { 445 return "OperationSerializer" 446} 447 448func (m *awsAwsjson11_serializeOpListPipelines) 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.(*ListPipelinesInput) 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("DataPipeline.ListPipelines") 470 471 jsonEncoder := smithyjson.NewEncoder() 472 if err := awsAwsjson11_serializeOpDocumentListPipelinesInput(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_serializeOpPollForTask struct { 489} 490 491func (*awsAwsjson11_serializeOpPollForTask) ID() string { 492 return "OperationSerializer" 493} 494 495func (m *awsAwsjson11_serializeOpPollForTask) 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.(*PollForTaskInput) 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("DataPipeline.PollForTask") 517 518 jsonEncoder := smithyjson.NewEncoder() 519 if err := awsAwsjson11_serializeOpDocumentPollForTaskInput(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_serializeOpPutPipelineDefinition struct { 536} 537 538func (*awsAwsjson11_serializeOpPutPipelineDefinition) ID() string { 539 return "OperationSerializer" 540} 541 542func (m *awsAwsjson11_serializeOpPutPipelineDefinition) 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.(*PutPipelineDefinitionInput) 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("DataPipeline.PutPipelineDefinition") 564 565 jsonEncoder := smithyjson.NewEncoder() 566 if err := awsAwsjson11_serializeOpDocumentPutPipelineDefinitionInput(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_serializeOpQueryObjects struct { 583} 584 585func (*awsAwsjson11_serializeOpQueryObjects) ID() string { 586 return "OperationSerializer" 587} 588 589func (m *awsAwsjson11_serializeOpQueryObjects) 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.(*QueryObjectsInput) 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("DataPipeline.QueryObjects") 611 612 jsonEncoder := smithyjson.NewEncoder() 613 if err := awsAwsjson11_serializeOpDocumentQueryObjectsInput(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_serializeOpRemoveTags struct { 630} 631 632func (*awsAwsjson11_serializeOpRemoveTags) ID() string { 633 return "OperationSerializer" 634} 635 636func (m *awsAwsjson11_serializeOpRemoveTags) 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.(*RemoveTagsInput) 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("DataPipeline.RemoveTags") 658 659 jsonEncoder := smithyjson.NewEncoder() 660 if err := awsAwsjson11_serializeOpDocumentRemoveTagsInput(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_serializeOpReportTaskProgress struct { 677} 678 679func (*awsAwsjson11_serializeOpReportTaskProgress) ID() string { 680 return "OperationSerializer" 681} 682 683func (m *awsAwsjson11_serializeOpReportTaskProgress) 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.(*ReportTaskProgressInput) 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("DataPipeline.ReportTaskProgress") 705 706 jsonEncoder := smithyjson.NewEncoder() 707 if err := awsAwsjson11_serializeOpDocumentReportTaskProgressInput(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_serializeOpReportTaskRunnerHeartbeat struct { 724} 725 726func (*awsAwsjson11_serializeOpReportTaskRunnerHeartbeat) ID() string { 727 return "OperationSerializer" 728} 729 730func (m *awsAwsjson11_serializeOpReportTaskRunnerHeartbeat) 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.(*ReportTaskRunnerHeartbeatInput) 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("DataPipeline.ReportTaskRunnerHeartbeat") 752 753 jsonEncoder := smithyjson.NewEncoder() 754 if err := awsAwsjson11_serializeOpDocumentReportTaskRunnerHeartbeatInput(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_serializeOpSetStatus struct { 771} 772 773func (*awsAwsjson11_serializeOpSetStatus) ID() string { 774 return "OperationSerializer" 775} 776 777func (m *awsAwsjson11_serializeOpSetStatus) 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.(*SetStatusInput) 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("DataPipeline.SetStatus") 799 800 jsonEncoder := smithyjson.NewEncoder() 801 if err := awsAwsjson11_serializeOpDocumentSetStatusInput(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_serializeOpSetTaskStatus struct { 818} 819 820func (*awsAwsjson11_serializeOpSetTaskStatus) ID() string { 821 return "OperationSerializer" 822} 823 824func (m *awsAwsjson11_serializeOpSetTaskStatus) 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.(*SetTaskStatusInput) 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("DataPipeline.SetTaskStatus") 846 847 jsonEncoder := smithyjson.NewEncoder() 848 if err := awsAwsjson11_serializeOpDocumentSetTaskStatusInput(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_serializeOpValidatePipelineDefinition struct { 865} 866 867func (*awsAwsjson11_serializeOpValidatePipelineDefinition) ID() string { 868 return "OperationSerializer" 869} 870 871func (m *awsAwsjson11_serializeOpValidatePipelineDefinition) 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.(*ValidatePipelineDefinitionInput) 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("DataPipeline.ValidatePipelineDefinition") 893 894 jsonEncoder := smithyjson.NewEncoder() 895 if err := awsAwsjson11_serializeOpDocumentValidatePipelineDefinitionInput(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} 910func awsAwsjson11_serializeDocumentField(v *types.Field, value smithyjson.Value) error { 911 object := value.Object() 912 defer object.Close() 913 914 if v.Key != nil { 915 ok := object.Key("key") 916 ok.String(*v.Key) 917 } 918 919 if v.RefValue != nil { 920 ok := object.Key("refValue") 921 ok.String(*v.RefValue) 922 } 923 924 if v.StringValue != nil { 925 ok := object.Key("stringValue") 926 ok.String(*v.StringValue) 927 } 928 929 return nil 930} 931 932func awsAwsjson11_serializeDocumentFieldList(v []types.Field, value smithyjson.Value) error { 933 array := value.Array() 934 defer array.Close() 935 936 for i := range v { 937 av := array.Value() 938 if err := awsAwsjson11_serializeDocumentField(&v[i], av); err != nil { 939 return err 940 } 941 } 942 return nil 943} 944 945func awsAwsjson11_serializeDocumentIdList(v []string, value smithyjson.Value) error { 946 array := value.Array() 947 defer array.Close() 948 949 for i := range v { 950 av := array.Value() 951 av.String(v[i]) 952 } 953 return nil 954} 955 956func awsAwsjson11_serializeDocumentInstanceIdentity(v *types.InstanceIdentity, value smithyjson.Value) error { 957 object := value.Object() 958 defer object.Close() 959 960 if v.Document != nil { 961 ok := object.Key("document") 962 ok.String(*v.Document) 963 } 964 965 if v.Signature != nil { 966 ok := object.Key("signature") 967 ok.String(*v.Signature) 968 } 969 970 return nil 971} 972 973func awsAwsjson11_serializeDocumentOperator(v *types.Operator, value smithyjson.Value) error { 974 object := value.Object() 975 defer object.Close() 976 977 if len(v.Type) > 0 { 978 ok := object.Key("type") 979 ok.String(string(v.Type)) 980 } 981 982 if v.Values != nil { 983 ok := object.Key("values") 984 if err := awsAwsjson11_serializeDocumentStringList(v.Values, ok); err != nil { 985 return err 986 } 987 } 988 989 return nil 990} 991 992func awsAwsjson11_serializeDocumentParameterAttribute(v *types.ParameterAttribute, value smithyjson.Value) error { 993 object := value.Object() 994 defer object.Close() 995 996 if v.Key != nil { 997 ok := object.Key("key") 998 ok.String(*v.Key) 999 } 1000 1001 if v.StringValue != nil { 1002 ok := object.Key("stringValue") 1003 ok.String(*v.StringValue) 1004 } 1005 1006 return nil 1007} 1008 1009func awsAwsjson11_serializeDocumentParameterAttributeList(v []types.ParameterAttribute, value smithyjson.Value) error { 1010 array := value.Array() 1011 defer array.Close() 1012 1013 for i := range v { 1014 av := array.Value() 1015 if err := awsAwsjson11_serializeDocumentParameterAttribute(&v[i], av); err != nil { 1016 return err 1017 } 1018 } 1019 return nil 1020} 1021 1022func awsAwsjson11_serializeDocumentParameterObject(v *types.ParameterObject, value smithyjson.Value) error { 1023 object := value.Object() 1024 defer object.Close() 1025 1026 if v.Attributes != nil { 1027 ok := object.Key("attributes") 1028 if err := awsAwsjson11_serializeDocumentParameterAttributeList(v.Attributes, ok); err != nil { 1029 return err 1030 } 1031 } 1032 1033 if v.Id != nil { 1034 ok := object.Key("id") 1035 ok.String(*v.Id) 1036 } 1037 1038 return nil 1039} 1040 1041func awsAwsjson11_serializeDocumentParameterObjectList(v []types.ParameterObject, value smithyjson.Value) error { 1042 array := value.Array() 1043 defer array.Close() 1044 1045 for i := range v { 1046 av := array.Value() 1047 if err := awsAwsjson11_serializeDocumentParameterObject(&v[i], av); err != nil { 1048 return err 1049 } 1050 } 1051 return nil 1052} 1053 1054func awsAwsjson11_serializeDocumentParameterValue(v *types.ParameterValue, value smithyjson.Value) error { 1055 object := value.Object() 1056 defer object.Close() 1057 1058 if v.Id != nil { 1059 ok := object.Key("id") 1060 ok.String(*v.Id) 1061 } 1062 1063 if v.StringValue != nil { 1064 ok := object.Key("stringValue") 1065 ok.String(*v.StringValue) 1066 } 1067 1068 return nil 1069} 1070 1071func awsAwsjson11_serializeDocumentParameterValueList(v []types.ParameterValue, value smithyjson.Value) error { 1072 array := value.Array() 1073 defer array.Close() 1074 1075 for i := range v { 1076 av := array.Value() 1077 if err := awsAwsjson11_serializeDocumentParameterValue(&v[i], av); err != nil { 1078 return err 1079 } 1080 } 1081 return nil 1082} 1083 1084func awsAwsjson11_serializeDocumentPipelineObject(v *types.PipelineObject, value smithyjson.Value) error { 1085 object := value.Object() 1086 defer object.Close() 1087 1088 if v.Fields != nil { 1089 ok := object.Key("fields") 1090 if err := awsAwsjson11_serializeDocumentFieldList(v.Fields, ok); err != nil { 1091 return err 1092 } 1093 } 1094 1095 if v.Id != nil { 1096 ok := object.Key("id") 1097 ok.String(*v.Id) 1098 } 1099 1100 if v.Name != nil { 1101 ok := object.Key("name") 1102 ok.String(*v.Name) 1103 } 1104 1105 return nil 1106} 1107 1108func awsAwsjson11_serializeDocumentPipelineObjectList(v []types.PipelineObject, value smithyjson.Value) error { 1109 array := value.Array() 1110 defer array.Close() 1111 1112 for i := range v { 1113 av := array.Value() 1114 if err := awsAwsjson11_serializeDocumentPipelineObject(&v[i], av); err != nil { 1115 return err 1116 } 1117 } 1118 return nil 1119} 1120 1121func awsAwsjson11_serializeDocumentQuery(v *types.Query, value smithyjson.Value) error { 1122 object := value.Object() 1123 defer object.Close() 1124 1125 if v.Selectors != nil { 1126 ok := object.Key("selectors") 1127 if err := awsAwsjson11_serializeDocumentSelectorList(v.Selectors, ok); err != nil { 1128 return err 1129 } 1130 } 1131 1132 return nil 1133} 1134 1135func awsAwsjson11_serializeDocumentSelector(v *types.Selector, value smithyjson.Value) error { 1136 object := value.Object() 1137 defer object.Close() 1138 1139 if v.FieldName != nil { 1140 ok := object.Key("fieldName") 1141 ok.String(*v.FieldName) 1142 } 1143 1144 if v.Operator != nil { 1145 ok := object.Key("operator") 1146 if err := awsAwsjson11_serializeDocumentOperator(v.Operator, ok); err != nil { 1147 return err 1148 } 1149 } 1150 1151 return nil 1152} 1153 1154func awsAwsjson11_serializeDocumentSelectorList(v []types.Selector, value smithyjson.Value) error { 1155 array := value.Array() 1156 defer array.Close() 1157 1158 for i := range v { 1159 av := array.Value() 1160 if err := awsAwsjson11_serializeDocumentSelector(&v[i], av); err != nil { 1161 return err 1162 } 1163 } 1164 return nil 1165} 1166 1167func awsAwsjson11_serializeDocumentStringList(v []string, value smithyjson.Value) error { 1168 array := value.Array() 1169 defer array.Close() 1170 1171 for i := range v { 1172 av := array.Value() 1173 av.String(v[i]) 1174 } 1175 return nil 1176} 1177 1178func awsAwsjson11_serializeDocumentTag(v *types.Tag, value smithyjson.Value) error { 1179 object := value.Object() 1180 defer object.Close() 1181 1182 if v.Key != nil { 1183 ok := object.Key("key") 1184 ok.String(*v.Key) 1185 } 1186 1187 if v.Value != nil { 1188 ok := object.Key("value") 1189 ok.String(*v.Value) 1190 } 1191 1192 return nil 1193} 1194 1195func awsAwsjson11_serializeDocumentTagList(v []types.Tag, value smithyjson.Value) error { 1196 array := value.Array() 1197 defer array.Close() 1198 1199 for i := range v { 1200 av := array.Value() 1201 if err := awsAwsjson11_serializeDocumentTag(&v[i], av); err != nil { 1202 return err 1203 } 1204 } 1205 return nil 1206} 1207 1208func awsAwsjson11_serializeOpDocumentActivatePipelineInput(v *ActivatePipelineInput, value smithyjson.Value) error { 1209 object := value.Object() 1210 defer object.Close() 1211 1212 if v.ParameterValues != nil { 1213 ok := object.Key("parameterValues") 1214 if err := awsAwsjson11_serializeDocumentParameterValueList(v.ParameterValues, ok); err != nil { 1215 return err 1216 } 1217 } 1218 1219 if v.PipelineId != nil { 1220 ok := object.Key("pipelineId") 1221 ok.String(*v.PipelineId) 1222 } 1223 1224 if v.StartTimestamp != nil { 1225 ok := object.Key("startTimestamp") 1226 ok.Double(smithytime.FormatEpochSeconds(*v.StartTimestamp)) 1227 } 1228 1229 return nil 1230} 1231 1232func awsAwsjson11_serializeOpDocumentAddTagsInput(v *AddTagsInput, value smithyjson.Value) error { 1233 object := value.Object() 1234 defer object.Close() 1235 1236 if v.PipelineId != nil { 1237 ok := object.Key("pipelineId") 1238 ok.String(*v.PipelineId) 1239 } 1240 1241 if v.Tags != nil { 1242 ok := object.Key("tags") 1243 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 1244 return err 1245 } 1246 } 1247 1248 return nil 1249} 1250 1251func awsAwsjson11_serializeOpDocumentCreatePipelineInput(v *CreatePipelineInput, value smithyjson.Value) error { 1252 object := value.Object() 1253 defer object.Close() 1254 1255 if v.Description != nil { 1256 ok := object.Key("description") 1257 ok.String(*v.Description) 1258 } 1259 1260 if v.Name != nil { 1261 ok := object.Key("name") 1262 ok.String(*v.Name) 1263 } 1264 1265 if v.Tags != nil { 1266 ok := object.Key("tags") 1267 if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil { 1268 return err 1269 } 1270 } 1271 1272 if v.UniqueId != nil { 1273 ok := object.Key("uniqueId") 1274 ok.String(*v.UniqueId) 1275 } 1276 1277 return nil 1278} 1279 1280func awsAwsjson11_serializeOpDocumentDeactivatePipelineInput(v *DeactivatePipelineInput, value smithyjson.Value) error { 1281 object := value.Object() 1282 defer object.Close() 1283 1284 if v.CancelActive != nil { 1285 ok := object.Key("cancelActive") 1286 ok.Boolean(*v.CancelActive) 1287 } 1288 1289 if v.PipelineId != nil { 1290 ok := object.Key("pipelineId") 1291 ok.String(*v.PipelineId) 1292 } 1293 1294 return nil 1295} 1296 1297func awsAwsjson11_serializeOpDocumentDeletePipelineInput(v *DeletePipelineInput, value smithyjson.Value) error { 1298 object := value.Object() 1299 defer object.Close() 1300 1301 if v.PipelineId != nil { 1302 ok := object.Key("pipelineId") 1303 ok.String(*v.PipelineId) 1304 } 1305 1306 return nil 1307} 1308 1309func awsAwsjson11_serializeOpDocumentDescribeObjectsInput(v *DescribeObjectsInput, value smithyjson.Value) error { 1310 object := value.Object() 1311 defer object.Close() 1312 1313 if v.EvaluateExpressions { 1314 ok := object.Key("evaluateExpressions") 1315 ok.Boolean(v.EvaluateExpressions) 1316 } 1317 1318 if v.Marker != nil { 1319 ok := object.Key("marker") 1320 ok.String(*v.Marker) 1321 } 1322 1323 if v.ObjectIds != nil { 1324 ok := object.Key("objectIds") 1325 if err := awsAwsjson11_serializeDocumentIdList(v.ObjectIds, ok); err != nil { 1326 return err 1327 } 1328 } 1329 1330 if v.PipelineId != nil { 1331 ok := object.Key("pipelineId") 1332 ok.String(*v.PipelineId) 1333 } 1334 1335 return nil 1336} 1337 1338func awsAwsjson11_serializeOpDocumentDescribePipelinesInput(v *DescribePipelinesInput, value smithyjson.Value) error { 1339 object := value.Object() 1340 defer object.Close() 1341 1342 if v.PipelineIds != nil { 1343 ok := object.Key("pipelineIds") 1344 if err := awsAwsjson11_serializeDocumentIdList(v.PipelineIds, ok); err != nil { 1345 return err 1346 } 1347 } 1348 1349 return nil 1350} 1351 1352func awsAwsjson11_serializeOpDocumentEvaluateExpressionInput(v *EvaluateExpressionInput, value smithyjson.Value) error { 1353 object := value.Object() 1354 defer object.Close() 1355 1356 if v.Expression != nil { 1357 ok := object.Key("expression") 1358 ok.String(*v.Expression) 1359 } 1360 1361 if v.ObjectId != nil { 1362 ok := object.Key("objectId") 1363 ok.String(*v.ObjectId) 1364 } 1365 1366 if v.PipelineId != nil { 1367 ok := object.Key("pipelineId") 1368 ok.String(*v.PipelineId) 1369 } 1370 1371 return nil 1372} 1373 1374func awsAwsjson11_serializeOpDocumentGetPipelineDefinitionInput(v *GetPipelineDefinitionInput, value smithyjson.Value) error { 1375 object := value.Object() 1376 defer object.Close() 1377 1378 if v.PipelineId != nil { 1379 ok := object.Key("pipelineId") 1380 ok.String(*v.PipelineId) 1381 } 1382 1383 if v.Version != nil { 1384 ok := object.Key("version") 1385 ok.String(*v.Version) 1386 } 1387 1388 return nil 1389} 1390 1391func awsAwsjson11_serializeOpDocumentListPipelinesInput(v *ListPipelinesInput, value smithyjson.Value) error { 1392 object := value.Object() 1393 defer object.Close() 1394 1395 if v.Marker != nil { 1396 ok := object.Key("marker") 1397 ok.String(*v.Marker) 1398 } 1399 1400 return nil 1401} 1402 1403func awsAwsjson11_serializeOpDocumentPollForTaskInput(v *PollForTaskInput, value smithyjson.Value) error { 1404 object := value.Object() 1405 defer object.Close() 1406 1407 if v.Hostname != nil { 1408 ok := object.Key("hostname") 1409 ok.String(*v.Hostname) 1410 } 1411 1412 if v.InstanceIdentity != nil { 1413 ok := object.Key("instanceIdentity") 1414 if err := awsAwsjson11_serializeDocumentInstanceIdentity(v.InstanceIdentity, ok); err != nil { 1415 return err 1416 } 1417 } 1418 1419 if v.WorkerGroup != nil { 1420 ok := object.Key("workerGroup") 1421 ok.String(*v.WorkerGroup) 1422 } 1423 1424 return nil 1425} 1426 1427func awsAwsjson11_serializeOpDocumentPutPipelineDefinitionInput(v *PutPipelineDefinitionInput, value smithyjson.Value) error { 1428 object := value.Object() 1429 defer object.Close() 1430 1431 if v.ParameterObjects != nil { 1432 ok := object.Key("parameterObjects") 1433 if err := awsAwsjson11_serializeDocumentParameterObjectList(v.ParameterObjects, ok); err != nil { 1434 return err 1435 } 1436 } 1437 1438 if v.ParameterValues != nil { 1439 ok := object.Key("parameterValues") 1440 if err := awsAwsjson11_serializeDocumentParameterValueList(v.ParameterValues, ok); err != nil { 1441 return err 1442 } 1443 } 1444 1445 if v.PipelineId != nil { 1446 ok := object.Key("pipelineId") 1447 ok.String(*v.PipelineId) 1448 } 1449 1450 if v.PipelineObjects != nil { 1451 ok := object.Key("pipelineObjects") 1452 if err := awsAwsjson11_serializeDocumentPipelineObjectList(v.PipelineObjects, ok); err != nil { 1453 return err 1454 } 1455 } 1456 1457 return nil 1458} 1459 1460func awsAwsjson11_serializeOpDocumentQueryObjectsInput(v *QueryObjectsInput, value smithyjson.Value) error { 1461 object := value.Object() 1462 defer object.Close() 1463 1464 if v.Limit != nil { 1465 ok := object.Key("limit") 1466 ok.Integer(*v.Limit) 1467 } 1468 1469 if v.Marker != nil { 1470 ok := object.Key("marker") 1471 ok.String(*v.Marker) 1472 } 1473 1474 if v.PipelineId != nil { 1475 ok := object.Key("pipelineId") 1476 ok.String(*v.PipelineId) 1477 } 1478 1479 if v.Query != nil { 1480 ok := object.Key("query") 1481 if err := awsAwsjson11_serializeDocumentQuery(v.Query, ok); err != nil { 1482 return err 1483 } 1484 } 1485 1486 if v.Sphere != nil { 1487 ok := object.Key("sphere") 1488 ok.String(*v.Sphere) 1489 } 1490 1491 return nil 1492} 1493 1494func awsAwsjson11_serializeOpDocumentRemoveTagsInput(v *RemoveTagsInput, value smithyjson.Value) error { 1495 object := value.Object() 1496 defer object.Close() 1497 1498 if v.PipelineId != nil { 1499 ok := object.Key("pipelineId") 1500 ok.String(*v.PipelineId) 1501 } 1502 1503 if v.TagKeys != nil { 1504 ok := object.Key("tagKeys") 1505 if err := awsAwsjson11_serializeDocumentStringList(v.TagKeys, ok); err != nil { 1506 return err 1507 } 1508 } 1509 1510 return nil 1511} 1512 1513func awsAwsjson11_serializeOpDocumentReportTaskProgressInput(v *ReportTaskProgressInput, value smithyjson.Value) error { 1514 object := value.Object() 1515 defer object.Close() 1516 1517 if v.Fields != nil { 1518 ok := object.Key("fields") 1519 if err := awsAwsjson11_serializeDocumentFieldList(v.Fields, ok); err != nil { 1520 return err 1521 } 1522 } 1523 1524 if v.TaskId != nil { 1525 ok := object.Key("taskId") 1526 ok.String(*v.TaskId) 1527 } 1528 1529 return nil 1530} 1531 1532func awsAwsjson11_serializeOpDocumentReportTaskRunnerHeartbeatInput(v *ReportTaskRunnerHeartbeatInput, value smithyjson.Value) error { 1533 object := value.Object() 1534 defer object.Close() 1535 1536 if v.Hostname != nil { 1537 ok := object.Key("hostname") 1538 ok.String(*v.Hostname) 1539 } 1540 1541 if v.TaskrunnerId != nil { 1542 ok := object.Key("taskrunnerId") 1543 ok.String(*v.TaskrunnerId) 1544 } 1545 1546 if v.WorkerGroup != nil { 1547 ok := object.Key("workerGroup") 1548 ok.String(*v.WorkerGroup) 1549 } 1550 1551 return nil 1552} 1553 1554func awsAwsjson11_serializeOpDocumentSetStatusInput(v *SetStatusInput, value smithyjson.Value) error { 1555 object := value.Object() 1556 defer object.Close() 1557 1558 if v.ObjectIds != nil { 1559 ok := object.Key("objectIds") 1560 if err := awsAwsjson11_serializeDocumentIdList(v.ObjectIds, ok); err != nil { 1561 return err 1562 } 1563 } 1564 1565 if v.PipelineId != nil { 1566 ok := object.Key("pipelineId") 1567 ok.String(*v.PipelineId) 1568 } 1569 1570 if v.Status != nil { 1571 ok := object.Key("status") 1572 ok.String(*v.Status) 1573 } 1574 1575 return nil 1576} 1577 1578func awsAwsjson11_serializeOpDocumentSetTaskStatusInput(v *SetTaskStatusInput, value smithyjson.Value) error { 1579 object := value.Object() 1580 defer object.Close() 1581 1582 if v.ErrorId != nil { 1583 ok := object.Key("errorId") 1584 ok.String(*v.ErrorId) 1585 } 1586 1587 if v.ErrorMessage != nil { 1588 ok := object.Key("errorMessage") 1589 ok.String(*v.ErrorMessage) 1590 } 1591 1592 if v.ErrorStackTrace != nil { 1593 ok := object.Key("errorStackTrace") 1594 ok.String(*v.ErrorStackTrace) 1595 } 1596 1597 if v.TaskId != nil { 1598 ok := object.Key("taskId") 1599 ok.String(*v.TaskId) 1600 } 1601 1602 if len(v.TaskStatus) > 0 { 1603 ok := object.Key("taskStatus") 1604 ok.String(string(v.TaskStatus)) 1605 } 1606 1607 return nil 1608} 1609 1610func awsAwsjson11_serializeOpDocumentValidatePipelineDefinitionInput(v *ValidatePipelineDefinitionInput, value smithyjson.Value) error { 1611 object := value.Object() 1612 defer object.Close() 1613 1614 if v.ParameterObjects != nil { 1615 ok := object.Key("parameterObjects") 1616 if err := awsAwsjson11_serializeDocumentParameterObjectList(v.ParameterObjects, ok); err != nil { 1617 return err 1618 } 1619 } 1620 1621 if v.ParameterValues != nil { 1622 ok := object.Key("parameterValues") 1623 if err := awsAwsjson11_serializeDocumentParameterValueList(v.ParameterValues, ok); err != nil { 1624 return err 1625 } 1626 } 1627 1628 if v.PipelineId != nil { 1629 ok := object.Key("pipelineId") 1630 ok.String(*v.PipelineId) 1631 } 1632 1633 if v.PipelineObjects != nil { 1634 ok := object.Key("pipelineObjects") 1635 if err := awsAwsjson11_serializeDocumentPipelineObjectList(v.PipelineObjects, ok); err != nil { 1636 return err 1637 } 1638 } 1639 1640 return nil 1641} 1642