-
Notifications
You must be signed in to change notification settings - Fork 626
/
api_op_DescribeDatasetImportJob.go
224 lines (194 loc) · 6.37 KB
/
api_op_DescribeDatasetImportJob.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
// Code generated by smithy-go-codegen DO NOT EDIT.
package forecast
import (
"context"
awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware"
"github.com/aws/aws-sdk-go-v2/aws/signer/v4"
"github.com/aws/aws-sdk-go-v2/service/forecast/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"time"
)
// Describes a dataset import job created using the CreateDatasetImportJob
// (https://docs.aws.amazon.com/forecast/latest/dg/API_CreateDatasetImportJob.html)
// operation. In addition to listing the parameters provided in the
// CreateDatasetImportJob request, this operation includes the following
// properties:
//
// * CreationTime
//
// * LastModificationTime
//
// * DataSize
//
// *
// FieldStatistics
//
// * Status
//
// * Message - If an error occurred, information about
// the error.
func (c *Client) DescribeDatasetImportJob(ctx context.Context, params *DescribeDatasetImportJobInput, optFns ...func(*Options)) (*DescribeDatasetImportJobOutput, error) {
if params == nil {
params = &DescribeDatasetImportJobInput{}
}
result, metadata, err := c.invokeOperation(ctx, "DescribeDatasetImportJob", params, optFns, c.addOperationDescribeDatasetImportJobMiddlewares)
if err != nil {
return nil, err
}
out := result.(*DescribeDatasetImportJobOutput)
out.ResultMetadata = metadata
return out, nil
}
type DescribeDatasetImportJobInput struct {
// The Amazon Resource Name (ARN) of the dataset import job.
//
// This member is required.
DatasetImportJobArn *string
noSmithyDocumentSerde
}
type DescribeDatasetImportJobOutput struct {
// When the dataset import job was created.
CreationTime *time.Time
// The size of the dataset in gigabytes (GB) after the import job has finished.
DataSize *float64
// The location of the training data to import and an Identity and Access
// Management (IAM) role that Amazon Forecast can assume to access the data. If
// encryption is used, DataSource includes an Key Management Service (KMS) key.
DataSource *types.DataSource
// The Amazon Resource Name (ARN) of the dataset that the training data was
// imported to.
DatasetArn *string
// The ARN of the dataset import job.
DatasetImportJobArn *string
// The name of the dataset import job.
DatasetImportJobName *string
// The estimated time remaining in minutes for the dataset import job to complete.
EstimatedTimeRemainingInMinutes *int64
// Statistical information about each field in the input data.
FieldStatistics map[string]types.Statistics
// The format of the imported data, CSV or PARQUET.
Format *string
// The format of the geolocation attribute. Valid Values:"LAT_LONG" and
// "CC_POSTALCODE".
GeolocationFormat *string
// The import mode of the dataset import job, FULL or INCREMENTAL.
ImportMode types.ImportMode
// The last time the resource was modified. The timestamp depends on the status of
// the job:
//
// * CREATE_PENDING - The CreationTime.
//
// * CREATE_IN_PROGRESS - The
// current timestamp.
//
// * CREATE_STOPPING - The current timestamp.
//
// * CREATE_STOPPED
// - When the job stopped.
//
// * ACTIVE or CREATE_FAILED - When the job finished or
// failed.
LastModificationTime *time.Time
// If an error occurred, an informational message about the error.
Message *string
// The status of the dataset import job. States include:
//
// * ACTIVE
//
// *
// CREATE_PENDING, CREATE_IN_PROGRESS, CREATE_FAILED
//
// * DELETE_PENDING,
// DELETE_IN_PROGRESS, DELETE_FAILED
//
// * CREATE_STOPPING, CREATE_STOPPED
Status *string
// The single time zone applied to every item in the dataset
TimeZone *string
// The format of timestamps in the dataset. The format that you specify depends on
// the DataFrequency specified when the dataset was created. The following formats
// are supported
//
// * "yyyy-MM-dd" For the following data frequencies: Y, M, W, and
// D
//
// * "yyyy-MM-dd HH:mm:ss" For the following data frequencies: H, 30min, 15min,
// and 1min; and optionally, for: Y, M, W, and D
TimestampFormat *string
// Whether TimeZone is automatically derived from the geolocation attribute.
UseGeolocationForTimeZone bool
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationDescribeDatasetImportJobMiddlewares(stack *middleware.Stack, options Options) (err error) {
err = stack.Serialize.Add(&awsAwsjson11_serializeOpDescribeDatasetImportJob{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpDescribeDatasetImportJob{}, middleware.After)
if err != nil {
return err
}
if err = addSetLoggerMiddleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil {
return err
}
if err = addResolveEndpointMiddleware(stack, options); err != nil {
return err
}
if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil {
return err
}
if err = addRetryMiddlewares(stack, options); err != nil {
return err
}
if err = addHTTPSignerV4Middleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil {
return err
}
if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil {
return err
}
if err = addClientUserAgent(stack); err != nil {
return err
}
if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = addOpDescribeDatasetImportJobValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opDescribeDatasetImportJob(options.Region), middleware.Before); err != nil {
return err
}
if err = addRequestIDRetrieverMiddleware(stack); err != nil {
return err
}
if err = addResponseErrorMiddleware(stack); err != nil {
return err
}
if err = addRequestResponseLogging(stack, options); err != nil {
return err
}
return nil
}
func newServiceMetadataMiddleware_opDescribeDatasetImportJob(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
SigningName: "forecast",
OperationName: "DescribeDatasetImportJob",
}
}