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
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package sagemaker
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/sagemaker/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"time"
)
// Retrieves the list of instances (also called nodes interchangeably) in a
// SageMaker HyperPod cluster.
func (c *Client) ListClusterNodes(ctx context.Context, params *ListClusterNodesInput, optFns ...func(*Options)) (*ListClusterNodesOutput, error) {
if params == nil {
params = &ListClusterNodesInput{}
}
result, metadata, err := c.invokeOperation(ctx, "ListClusterNodes", params, optFns, c.addOperationListClusterNodesMiddlewares)
if err != nil {
return nil, err
}
out := result.(*ListClusterNodesOutput)
out.ResultMetadata = metadata
return out, nil
}
type ListClusterNodesInput struct {
// The string name or the Amazon Resource Name (ARN) of the SageMaker HyperPod
// cluster in which you want to retrieve the list of nodes.
//
// This member is required.
ClusterName *string
// A filter that returns nodes in a SageMaker HyperPod cluster created after the
// specified time. Timestamps are formatted according to the ISO 8601 standard.
// Acceptable formats include:
// - YYYY-MM-DDThh:mm:ss.sssTZD (UTC), for example, 2014-10-01T20:30:00.000Z
// - YYYY-MM-DDThh:mm:ss.sssTZD (with offset), for example,
// 2014-10-01T12:30:00.000-08:00
// - YYYY-MM-DD , for example, 2014-10-01
// - Unix time in seconds, for example, 1412195400 . This is also referred to as
// Unix Epoch time and represents the number of seconds since midnight, January 1,
// 1970 UTC.
// For more information about the timestamp format, see Timestamp (https://docs.aws.amazon.com/cli/latest/userguide/cli-usage-parameters-types.html#parameter-type-timestamp)
// in the Amazon Web Services Command Line Interface User Guide.
CreationTimeAfter *time.Time
// A filter that returns nodes in a SageMaker HyperPod cluster created before the
// specified time. The acceptable formats are the same as the timestamp formats for
// CreationTimeAfter . For more information about the timestamp format, see
// Timestamp (https://docs.aws.amazon.com/cli/latest/userguide/cli-usage-parameters-types.html#parameter-type-timestamp)
// in the Amazon Web Services Command Line Interface User Guide.
CreationTimeBefore *time.Time
// A filter that returns the instance groups whose name contain a specified string.
InstanceGroupNameContains *string
// The maximum number of nodes to return in the response.
MaxResults *int32
// If the result of the previous ListClusterNodes request was truncated, the
// response includes a NextToken . To retrieve the next set of cluster nodes, use
// the token in the next request.
NextToken *string
// The field by which to sort results. The default value is CREATION_TIME .
SortBy types.ClusterSortBy
// The sort order for results. The default value is Ascending .
SortOrder types.SortOrder
noSmithyDocumentSerde
}
type ListClusterNodesOutput struct {
// The summaries of listed instances in a SageMaker HyperPod cluster
//
// This member is required.
ClusterNodeSummaries []types.ClusterNodeSummary
// The next token specified for listing instances in a SageMaker HyperPod cluster.
//
// This member is required.
NextToken *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationListClusterNodesMiddlewares(stack *middleware.Stack, options Options) (err error) {
if err := stack.Serialize.Add(&setOperationInputMiddleware{}, middleware.After); err != nil {
return err
}
err = stack.Serialize.Add(&awsAwsjson11_serializeOpListClusterNodes{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpListClusterNodes{}, middleware.After)
if err != nil {
return err
}
if err := addProtocolFinalizerMiddlewares(stack, options, "ListClusterNodes"); 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 = addOpListClusterNodesValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opListClusterNodes(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_opListClusterNodes(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
OperationName: "ListClusterNodes",
}
}
|
