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
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package sagemaker
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/sagemaker/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
)
// Deploys the new EndpointConfig specified in the request, switches to using newly
// created endpoint, and then deletes resources provisioned for the endpoint using
// the previous EndpointConfig (there is no availability loss). When SageMaker
// receives the request, it sets the endpoint status to Updating. After updating
// the endpoint, it sets the status to InService. To check the status of an
// endpoint, use the DescribeEndpoint API. You must not delete an EndpointConfig in
// use by an endpoint that is live or while the UpdateEndpoint or CreateEndpoint
// operations are being performed on the endpoint. To update an endpoint, you must
// create a new EndpointConfig. If you delete the EndpointConfig of an endpoint
// that is active or being created or updated you may lose visibility into the
// instance type the endpoint is using. The endpoint must be deleted in order to
// stop incurring charges.
func (c *Client) UpdateEndpoint(ctx context.Context, params *UpdateEndpointInput, optFns ...func(*Options)) (*UpdateEndpointOutput, error) {
if params == nil {
params = &UpdateEndpointInput{}
}
result, metadata, err := c.invokeOperation(ctx, "UpdateEndpoint", params, optFns, c.addOperationUpdateEndpointMiddlewares)
if err != nil {
return nil, err
}
out := result.(*UpdateEndpointOutput)
out.ResultMetadata = metadata
return out, nil
}
type UpdateEndpointInput struct {
// The name of the new endpoint configuration.
//
// This member is required.
EndpointConfigName *string
// The name of the endpoint whose configuration you want to update.
//
// This member is required.
EndpointName *string
// The deployment configuration for an endpoint, which contains the desired
// deployment strategy and rollback configurations.
DeploymentConfig *types.DeploymentConfig
// When you are updating endpoint resources with
// UpdateEndpointInput$RetainAllVariantProperties, whose value is set to true,
// ExcludeRetainedVariantProperties specifies the list of type VariantProperty to
// override with the values provided by EndpointConfig. If you don't specify a
// value for ExcludeAllVariantProperties, no variant properties are overridden.
ExcludeRetainedVariantProperties []types.VariantProperty
// When updating endpoint resources, enables or disables the retention of variant
// properties
// (https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_VariantProperty.html),
// such as the instance count or the variant weight. To retain the variant
// properties of an endpoint when updating it, set RetainAllVariantProperties to
// true. To use the variant properties specified in a new EndpointConfig call when
// updating an endpoint, set RetainAllVariantProperties to false. The default is
// false.
RetainAllVariantProperties bool
// Specifies whether to reuse the last deployment configuration. The default value
// is false (the configuration is not reused).
RetainDeploymentConfig bool
noSmithyDocumentSerde
}
type UpdateEndpointOutput struct {
// The Amazon Resource Name (ARN) of the endpoint.
//
// This member is required.
EndpointArn *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationUpdateEndpointMiddlewares(stack *middleware.Stack, options Options) (err error) {
err = stack.Serialize.Add(&awsAwsjson11_serializeOpUpdateEndpoint{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpUpdateEndpoint{}, 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 = addOpUpdateEndpointValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opUpdateEndpoint(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_opUpdateEndpoint(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
SigningName: "sagemaker",
OperationName: "UpdateEndpoint",
}
}
|
