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 225 226 227 228 229 230 231 232 233 234 235 236 237 238
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package datasync
import (
"context"
"fmt"
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/datasync/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"time"
)
// Provides information about an execution of your DataSync task. You can use this
// operation to help monitor the progress of an ongoing transfer or check the
// results of the transfer.
func (c *Client) DescribeTaskExecution(ctx context.Context, params *DescribeTaskExecutionInput, optFns ...func(*Options)) (*DescribeTaskExecutionOutput, error) {
if params == nil {
params = &DescribeTaskExecutionInput{}
}
result, metadata, err := c.invokeOperation(ctx, "DescribeTaskExecution", params, optFns, c.addOperationDescribeTaskExecutionMiddlewares)
if err != nil {
return nil, err
}
out := result.(*DescribeTaskExecutionOutput)
out.ResultMetadata = metadata
return out, nil
}
// DescribeTaskExecutionRequest
type DescribeTaskExecutionInput struct {
// Specifies the Amazon Resource Name (ARN) of the task execution that you want
// information about.
//
// This member is required.
TaskExecutionArn *string
noSmithyDocumentSerde
}
// DescribeTaskExecutionResponse
type DescribeTaskExecutionOutput struct {
// The physical number of bytes transferred over the network after compression was
// applied. In most cases, this number is less than BytesTransferred unless the
// data isn't compressible.
BytesCompressed int64
// The total number of bytes that are involved in the transfer. For the number of
// bytes sent over the network, see BytesCompressed .
BytesTransferred int64
// The number of logical bytes written to the destination location.
BytesWritten int64
// The estimated physical number of bytes that will transfer over the network.
EstimatedBytesToTransfer int64
// The expected number of files, objects, and directories that DataSync will
// delete in your destination location. If you don't configure your task (https://docs.aws.amazon.com/datasync/latest/userguide/configure-metadata.html)
// to delete data in the destination that isn't in the source, the value is always
// 0 .
EstimatedFilesToDelete int64
// The expected number of files, objects, and directories that DataSync will
// transfer over the network. This value is calculated during the task execution's
// PREPARING phase before the TRANSFERRING phase. The calculation is based on
// comparing the content of the source and destination locations and finding the
// difference that needs to be transferred.
EstimatedFilesToTransfer int64
// A list of filter rules that exclude specific data during your transfer. For
// more information and examples, see Filtering data transferred by DataSync (https://docs.aws.amazon.com/datasync/latest/userguide/filtering.html)
// .
Excludes []types.FilterRule
// The number of files, objects, and directories that DataSync deleted in your
// destination location. If you don't configure your task (https://docs.aws.amazon.com/datasync/latest/userguide/configure-metadata.html)
// to delete data in the destination that isn't in the source, the value is always
// 0 .
FilesDeleted int64
// The number of files, objects, and directories that DataSync skipped during your
// transfer.
FilesSkipped int64
// The actual number of files, objects, and directories that DataSync transferred
// over the network. This value is updated periodically during the task execution's
// TRANSFERRING phase when something is read from the source and sent over the
// network. If DataSync fails to transfer something, this value can be less than
// EstimatedFilesToTransfer . In some cases, this value can also be greater than
// EstimatedFilesToTransfer . This element is implementation-specific for some
// location types, so don't use it as an exact indication of what transferred or to
// monitor your task execution.
FilesTransferred int64
// The number of files, objects, and directories that DataSync verified during
// your transfer. When you configure your task to verify only the data that's
// transferred (https://docs.aws.amazon.com/datasync/latest/userguide/configure-data-verification-options.html)
// , DataSync doesn't verify directories in some situations or files that fail to
// transfer.
FilesVerified int64
// A list of filter rules that include specific data during your transfer. For
// more information and examples, see Filtering data transferred by DataSync (https://docs.aws.amazon.com/datasync/latest/userguide/filtering.html)
// .
Includes []types.FilterRule
// Indicates how your transfer task is configured. These options include how
// DataSync handles files, objects, and their associated metadata during your
// transfer. You also can specify how to verify data integrity, set bandwidth
// limits for your task, among other options. Each option has a default value.
// Unless you need to, you don't have to configure any of these options before
// starting your task.
Options *types.Options
// Indicates whether DataSync generated a complete task report (https://docs.aws.amazon.com/datasync/latest/userguide/task-reports.html)
// for your transfer.
ReportResult *types.ReportResult
// The result of the task execution.
Result *types.TaskExecutionResultDetail
// The time when the task execution started.
StartTime *time.Time
// The status of the task execution.
Status types.TaskExecutionStatus
// The ARN of the task execution that you wanted information about.
// TaskExecutionArn is hierarchical and includes TaskArn for the task that was
// executed. For example, a TaskExecution value with the ARN
// arn:aws:datasync:us-east-1:111222333444:task/task-0208075f79cedf4a2/execution/exec-08ef1e88ec491019b
// executed the task with the ARN
// arn:aws:datasync:us-east-1:111222333444:task/task-0208075f79cedf4a2 .
TaskExecutionArn *string
// The configuration of your task report, which provides detailed information
// about for your DataSync transfer.
TaskReportConfig *types.TaskReportConfig
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationDescribeTaskExecutionMiddlewares(stack *middleware.Stack, options Options) (err error) {
if err := stack.Serialize.Add(&setOperationInputMiddleware{}, middleware.After); err != nil {
return err
}
err = stack.Serialize.Add(&awsAwsjson11_serializeOpDescribeTaskExecution{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpDescribeTaskExecution{}, middleware.After)
if err != nil {
return err
}
if err := addProtocolFinalizerMiddlewares(stack, options, "DescribeTaskExecution"); err != nil {
return fmt.Errorf("add protocol finalizers: %v", err)
}
if err = addlegacyEndpointContextSetter(stack, options); 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 = awsmiddleware.AddRawResponseToMetadata(stack); err != nil {
return err
}
if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil {
return err
}
if err = addClientUserAgent(stack, options); err != nil {
return err
}
if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = addSetLegacyContextSigningOptionsMiddleware(stack); err != nil {
return err
}
if err = addOpDescribeTaskExecutionValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opDescribeTaskExecution(options.Region), middleware.Before); err != nil {
return err
}
if err = awsmiddleware.AddRecursionDetection(stack); 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
}
if err = addDisableHTTPSMiddleware(stack, options); err != nil {
return err
}
return nil
}
func newServiceMetadataMiddleware_opDescribeTaskExecution(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
OperationName: "DescribeTaskExecution",
}
}
|