1// Code generated by smithy-go-codegen DO NOT EDIT.
2
3package datapipeline
4
5import (
6	"context"
7	awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware"
8	"github.com/aws/aws-sdk-go-v2/aws/signer/v4"
9	"github.com/aws/aws-sdk-go-v2/service/datapipeline/types"
10	"github.com/aws/smithy-go/middleware"
11	smithyhttp "github.com/aws/smithy-go/transport/http"
12)
13
14// Gets the definition of the specified pipeline. You can call
15// GetPipelineDefinition to retrieve the pipeline definition that you provided
16// using PutPipelineDefinition. POST / HTTP/1.1 Content-Type:
17// application/x-amz-json-1.1 X-Amz-Target: DataPipeline.GetPipelineDefinition
18// Content-Length: 40 Host: datapipeline.us-east-1.amazonaws.com X-Amz-Date: Mon,
19// 12 Nov 2012 17:49:52 GMT Authorization: AuthParams {"pipelineId":
20// "df-06372391ZG65EXAMPLE"} x-amzn-RequestId: e28309e5-0776-11e2-8a14-21bb8a1f50ef
21// Content-Type: application/x-amz-json-1.1 Content-Length: 890 Date: Mon, 12 Nov
22// 2012 17:50:53 GMT {"pipelineObjects": [ {"fields": [ {"key": "workerGroup",
23// "stringValue": "workerGroup"} ], "id": "Default", "name": "Default"}, {"fields":
24// [ {"key": "startDateTime", "stringValue": "2012-09-25T17:00:00"}, {"key":
25// "type", "stringValue": "Schedule"}, {"key": "period", "stringValue": "1 hour"},
26// {"key": "endDateTime", "stringValue": "2012-09-25T18:00:00"} ], "id":
27// "Schedule", "name": "Schedule"}, {"fields": [ {"key": "schedule", "refValue":
28// "Schedule"}, {"key": "command", "stringValue": "echo hello"}, {"key": "parent",
29// "refValue": "Default"}, {"key": "type", "stringValue": "ShellCommandActivity"}
30// ], "id": "SayHello", "name": "SayHello"} ] }
31func (c *Client) GetPipelineDefinition(ctx context.Context, params *GetPipelineDefinitionInput, optFns ...func(*Options)) (*GetPipelineDefinitionOutput, error) {
32	if params == nil {
33		params = &GetPipelineDefinitionInput{}
34	}
35
36	result, metadata, err := c.invokeOperation(ctx, "GetPipelineDefinition", params, optFns, addOperationGetPipelineDefinitionMiddlewares)
37	if err != nil {
38		return nil, err
39	}
40
41	out := result.(*GetPipelineDefinitionOutput)
42	out.ResultMetadata = metadata
43	return out, nil
44}
45
46// Contains the parameters for GetPipelineDefinition.
47type GetPipelineDefinitionInput struct {
48
49	// The ID of the pipeline.
50	//
51	// This member is required.
52	PipelineId *string
53
54	// The version of the pipeline definition to retrieve. Set this parameter to latest
55	// (default) to use the last definition saved to the pipeline or active to use the
56	// last definition that was activated.
57	Version *string
58}
59
60// Contains the output of GetPipelineDefinition.
61type GetPipelineDefinitionOutput struct {
62
63	// The parameter objects used in the pipeline definition.
64	ParameterObjects []types.ParameterObject
65
66	// The parameter values used in the pipeline definition.
67	ParameterValues []types.ParameterValue
68
69	// The objects defined in the pipeline.
70	PipelineObjects []types.PipelineObject
71
72	// Metadata pertaining to the operation's result.
73	ResultMetadata middleware.Metadata
74}
75
76func addOperationGetPipelineDefinitionMiddlewares(stack *middleware.Stack, options Options) (err error) {
77	err = stack.Serialize.Add(&awsAwsjson11_serializeOpGetPipelineDefinition{}, middleware.After)
78	if err != nil {
79		return err
80	}
81	err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpGetPipelineDefinition{}, middleware.After)
82	if err != nil {
83		return err
84	}
85	if err = addSetLoggerMiddleware(stack, options); err != nil {
86		return err
87	}
88	if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil {
89		return err
90	}
91	if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil {
92		return err
93	}
94	if err = addResolveEndpointMiddleware(stack, options); err != nil {
95		return err
96	}
97	if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil {
98		return err
99	}
100	if err = addRetryMiddlewares(stack, options); err != nil {
101		return err
102	}
103	if err = addHTTPSignerV4Middleware(stack, options); err != nil {
104		return err
105	}
106	if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil {
107		return err
108	}
109	if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil {
110		return err
111	}
112	if err = addClientUserAgent(stack); err != nil {
113		return err
114	}
115	if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil {
116		return err
117	}
118	if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil {
119		return err
120	}
121	if err = addOpGetPipelineDefinitionValidationMiddleware(stack); err != nil {
122		return err
123	}
124	if err = stack.Initialize.Add(newServiceMetadataMiddleware_opGetPipelineDefinition(options.Region), middleware.Before); err != nil {
125		return err
126	}
127	if err = addRequestIDRetrieverMiddleware(stack); err != nil {
128		return err
129	}
130	if err = addResponseErrorMiddleware(stack); err != nil {
131		return err
132	}
133	if err = addRequestResponseLogging(stack, options); err != nil {
134		return err
135	}
136	return nil
137}
138
139func newServiceMetadataMiddleware_opGetPipelineDefinition(region string) *awsmiddleware.RegisterServiceMetadata {
140	return &awsmiddleware.RegisterServiceMetadata{
141		Region:        region,
142		ServiceID:     ServiceID,
143		SigningName:   "datapipeline",
144		OperationName: "GetPipelineDefinition",
145	}
146}
147