Skip to content

Commit d3e8fa1

Browse files
fudiweifudiwei
committed
refactor: re-implement aws services with custom sdk, to lightweight package size
1 parent e8139f0 commit d3e8fa1

71 files changed

Lines changed: 3195 additions & 132 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎pkg/core/certifier/challengers/dns01/aws-lightsail/internal/lego.go‎

Lines changed: 12 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,13 @@ import (
66
"strconv"
77
"time"
88

9-
aws "github.com/aws/aws-sdk-go-v2/aws"
10-
awscfg "github.com/aws/aws-sdk-go-v2/config"
11-
awscred "github.com/aws/aws-sdk-go-v2/credentials"
12-
"github.com/aws/aws-sdk-go-v2/service/lightsail"
9+
"github.com/aws/aws-sdk-go-v2/aws"
1310
"github.com/aws/aws-sdk-go-v2/service/lightsail/types"
1411
"github.com/go-acme/lego/v5/challenge"
1512
"github.com/go-acme/lego/v5/challenge/dns01"
1613
"github.com/go-acme/lego/v5/platform/env"
14+
15+
awslightsailsdk "github.com/certimate-go/certimate/pkg/sdk3rd/aws/lightsail"
1716
)
1817

1918
const (
@@ -25,8 +24,6 @@ const (
2524
EnvPollingInterval = envNamespace + "POLLING_INTERVAL"
2625
)
2726

28-
const maxRetries = 5
29-
3027
var _ challenge.ProviderTimeout = (*DNSProvider)(nil)
3128

3229
type Config struct {
@@ -49,7 +46,7 @@ func NewDefaultConfig() *Config {
4946
// 这里有意不使用 lego 提供的 lightsail 实现，
5047
// 因为它只支持单个域，无法签发多域名证书。
5148
type DNSProvider struct {
52-
client *lightsail.Client
49+
client *awslightsailsdk.Client
5350
config *Config
5451
}
5552

@@ -65,18 +62,17 @@ func NewDNSProviderConfig(config *Config) (*DNSProvider, error) {
6562
return nil, fmt.Errorf("lightsail: the configuration of the DNS provider is nil")
6663
}
6764

68-
ctx := context.Background()
69-
cfg, err := awscfg.LoadDefaultConfig(ctx,
70-
awscfg.WithCredentialsProvider(awscred.NewStaticCredentialsProvider(config.AccessKeyID, config.SecretAccessKey, config.SessionToken)),
71-
awscfg.WithRegion(config.Region),
65+
client, err := awslightsailsdk.NewClient(
66+
awslightsailsdk.WithAkSk(config.AccessKeyID, config.SecretAccessKey),
67+
awslightsailsdk.WithRegion(config.Region),
7268
)
7369
if err != nil {
7470
return nil, err
7571
}
7672

7773
return &DNSProvider{
7874
config: config,
79-
client: lightsail.NewFromConfig(cfg),
75+
client: client,
8076
}, nil
8177
}
8278

@@ -88,7 +84,8 @@ func (d *DNSProvider) Present(ctx context.Context, domain, _, keyAuth string) er
8884
return fmt.Errorf("lightsail: could not find zone for domain %q: %w", domain, err)
8985
}
9086

91-
if _, err := d.client.CreateDomainEntry(ctx, &lightsail.CreateDomainEntryInput{
87+
// REF: https://docs.aws.amazon.com/lightsail/2016-11-28/api-reference/API_CreateDomainEntry.html
88+
if _, err := d.client.CreateDomainEntryWithContext(ctx, &awslightsailsdk.CreateDomainEntryRequest{
9289
DomainName: aws.String(dns01.UnFqdn(authZone)),
9390
DomainEntry: &types.DomainEntry{
9491
Type: aws.String("TXT"),
@@ -110,7 +107,8 @@ func (d *DNSProvider) CleanUp(ctx context.Context, domain, _, keyAuth string) er
110107
return fmt.Errorf("lightsail: could not find zone for domain %q: %w", domain, err)
111108
}
112109

113-
if _, err := d.client.DeleteDomainEntry(ctx, &lightsail.DeleteDomainEntryInput{
110+
// REF: https://docs.aws.amazon.com/lightsail/2016-11-28/api-reference/API_DeleteDomainEntry.html
111+
if _, err := d.client.DeleteDomainEntryWithContext(ctx, &awslightsailsdk.DeleteDomainEntryRequest{
114112
DomainName: aws.String(dns01.UnFqdn(authZone)),
115113
DomainEntry: &types.DomainEntry{
116114
Type: aws.String("TXT"),

‎pkg/core/certmgr/providers/aws-acm/aws_acm.go‎

Lines changed: 22 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -8,12 +8,11 @@ import (
88
"strings"
99

1010
aws "github.com/aws/aws-sdk-go-v2/aws"
11-
awscfg "github.com/aws/aws-sdk-go-v2/config"
12-
awscred "github.com/aws/aws-sdk-go-v2/credentials"
13-
"github.com/aws/aws-sdk-go-v2/service/acm"
11+
"github.com/aws/aws-sdk-go-v2/service/acm/types"
1412
"github.com/aws/smithy-go"
1513

1614
"github.com/certimate-go/certimate/pkg/core"
15+
awsacmsdk "github.com/certimate-go/certimate/pkg/sdk3rd/aws/acm"
1716
xcert "github.com/certimate-go/certimate/pkg/utils/cert"
1817
)
1918

@@ -35,7 +34,7 @@ type CertmgrConfig struct {
3534
type Certmgr struct {
3635
config *CertmgrConfig
3736
logger *slog.Logger
38-
sdkClient *acm.Client
37+
sdkClient *awsacmsdk.Client
3938
}
4039

4140
var _ Provider = (*Certmgr)(nil)
@@ -89,34 +88,37 @@ func (c *Certmgr) Upload(ctx context.Context, certPEM, privkeyPEM string) (*Uplo
8988
default:
9089
}
9190

92-
listCertificatesReq := &acm.ListCertificatesInput{
91+
listCertificatesReq := &awsacmsdk.ListCertificatesRequest{
9392
NextToken: listCertificatesNextToken,
9493
MaxItems: aws.Int32(1000),
94+
SortBy: types.SortByCreatedAt,
95+
SortOrder: types.SortOrderDescending,
9596
}
96-
listCertificatesResp, err := c.sdkClient.ListCertificates(ctx, listCertificatesReq)
97+
listCertificatesResp, err := c.sdkClient.ListCertificatesWithContext(ctx, listCertificatesReq)
9798
c.logger.Debug("sdk request 'acm.ListCertificates'", slog.Any("request", listCertificatesReq), slog.Any("response", listCertificatesResp))
9899
if err != nil {
99100
return nil, fmt.Errorf("failed to execute sdk request 'acm.ListCertificates': %w", err)
100101
}
101102

102103
for _, certItem := range listCertificatesResp.CertificateSummaryList {
103-
// 对比证书备用名称
104-
if !strings.EqualFold(strings.Join(certX509.DNSNames, ","), strings.Join(certItem.SubjectAlternativeNameSummaries, ",")) {
104+
// 对比证书通用名称
105+
// 注意，虽然文档中描述为包含了备用名称字段，但实际值不完整，因此不能用于判断证书是否相同
106+
if certItem.DomainName == nil || !strings.EqualFold(certX509.Subject.CommonName, *certItem.DomainName) {
105107
continue
106108
}
107109

108110
// 对比证书有效期
109-
if certItem.NotBefore == nil || !certX509.NotBefore.Equal(*certItem.NotBefore) {
111+
if certItem.NotBefore == nil || certX509.NotBefore.Unix() != certItem.NotBefore.Unix() {
110112
continue
111-
} else if certItem.NotAfter == nil || !certX509.NotAfter.Equal(*certItem.NotAfter) {
113+
} else if certItem.NotAfter == nil || certX509.NotAfter.Unix() != certItem.NotAfter.Unix() {
112114
continue
113115
}
114116

115117
// 对比证书内容
116-
getCertificateReq := &acm.GetCertificateInput{
118+
getCertificateReq := &awsacmsdk.GetCertificateRequest{
117119
CertificateArn: certItem.CertificateArn,
118120
}
119-
getCertificateResp, err := c.sdkClient.GetCertificate(ctx, getCertificateReq)
121+
getCertificateResp, err := c.sdkClient.GetCertificateWithContext(ctx, getCertificateReq)
120122
if err != nil {
121123
var sdkErr smithy.APIError
122124
if errors.As(err, &sdkErr) {
@@ -151,12 +153,12 @@ func (c *Certmgr) Upload(ctx context.Context, certPEM, privkeyPEM string) (*Uplo
151153

152154
// 导入证书
153155
// REF: https://docs.aws.amazon.com/acm/latest/APIReference/API_ImportCertificate.html
154-
importCertificateReq := &acm.ImportCertificateInput{
156+
importCertificateReq := &awsacmsdk.ImportCertificateRequest{
155157
Certificate: ([]byte)(serverCertPEM),
156158
CertificateChain: ([]byte)(issuerCertPEM),
157159
PrivateKey: ([]byte)(privkeyPEM),
158160
}
159-
importCertificateResp, err := c.sdkClient.ImportCertificate(ctx, importCertificateReq)
161+
importCertificateResp, err := c.sdkClient.ImportCertificateWithContext(ctx, importCertificateReq)
160162
c.logger.Debug("sdk request 'acm.ImportCertificate'", slog.Any("request", importCertificateReq), slog.Any("response", importCertificateResp))
161163
if err != nil {
162164
return nil, fmt.Errorf("failed to execute sdk request 'acm.ImportCertificate': %w", err)
@@ -179,13 +181,13 @@ func (c *Certmgr) Replace(ctx context.Context, certIdOrName string, certPEM, pri
179181

180182
// 导入证书
181183
// REF: https://docs.aws.amazon.com/acm/latest/APIReference/API_ImportCertificate.html
182-
importCertificateReq := &acm.ImportCertificateInput{
184+
importCertificateReq := &awsacmsdk.ImportCertificateRequest{
183185
CertificateArn: aws.String(certIdOrName),
184186
Certificate: ([]byte)(serverCertPEM),
185187
CertificateChain: ([]byte)(issuerCertPEM),
186188
PrivateKey: ([]byte)(privkeyPEM),
187189
}
188-
importCertificateResp, err := c.sdkClient.ImportCertificate(ctx, importCertificateReq)
190+
importCertificateResp, err := c.sdkClient.ImportCertificateWithContext(ctx, importCertificateReq)
189191
c.logger.Debug("sdk request 'acm.ImportCertificate'", slog.Any("request", importCertificateReq), slog.Any("response", importCertificateResp))
190192
if err != nil {
191193
return nil, fmt.Errorf("failed to execute sdk request 'acm.ImportCertificate': %w", err)
@@ -194,15 +196,14 @@ func (c *Certmgr) Replace(ctx context.Context, certIdOrName string, certPEM, pri
194196
return &ReplaceResult{}, nil
195197
}
196198

197-
func createSDKClient(accessKeyId, secretAccessKey, region string) (*acm.Client, error) {
198-
cfg, err := awscfg.LoadDefaultConfig(context.Background(),
199-
awscfg.WithCredentialsProvider(awscred.NewStaticCredentialsProvider(accessKeyId, secretAccessKey, "")),
200-
awscfg.WithRegion(region),
199+
func createSDKClient(accessKeyId, secretAccessKey, region string) (*awsacmsdk.Client, error) {
200+
client, err := awsacmsdk.NewClient(
201+
awsacmsdk.WithAkSk(accessKeyId, secretAccessKey),
202+
awsacmsdk.WithRegion(region),
201203
)
202204
if err != nil {
203205
return nil, err
204206
}
205207

206-
client := acm.NewFromConfig(cfg)
207208
return client, nil
208209
}

‎pkg/core/certmgr/providers/aws-iam/aws_iam.go‎

Lines changed: 12 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -9,13 +9,12 @@ import (
99
"time"
1010

1111
aws "github.com/aws/aws-sdk-go-v2/aws"
12-
awscfg "github.com/aws/aws-sdk-go-v2/config"
13-
awscred "github.com/aws/aws-sdk-go-v2/credentials"
1412
"github.com/aws/aws-sdk-go-v2/service/iam"
1513
"github.com/aws/smithy-go"
1614
"github.com/samber/lo"
1715

1816
"github.com/certimate-go/certimate/pkg/core"
17+
awsiamsdk "github.com/certimate-go/certimate/pkg/sdk3rd/aws/iam"
1918
xcert "github.com/certimate-go/certimate/pkg/utils/cert"
2019
)
2120

@@ -40,7 +39,7 @@ type CertmgrConfig struct {
4039
type Certmgr struct {
4140
config *CertmgrConfig
4241
logger *slog.Logger
43-
sdkClient *iam.Client
42+
sdkClient *awsiamsdk.Client
4443
}
4544

4645
var _ Provider = (*Certmgr)(nil)
@@ -99,7 +98,7 @@ func (c *Certmgr) Upload(ctx context.Context, certPEM, privkeyPEM string) (*Uplo
9998
Marker: listServerCertificatesMarker,
10099
MaxItems: aws.Int32(1000),
101100
}
102-
listServerCertificatesResp, err := c.sdkClient.ListServerCertificates(ctx, listServerCertificatesReq)
101+
listServerCertificatesResp, err := c.sdkClient.ListServerCertificatesWithContext(ctx, listServerCertificatesReq)
103102
c.logger.Debug("sdk request 'iam.ListServerCertificates'", slog.Any("request", listServerCertificatesReq), slog.Any("response", listServerCertificatesResp))
104103
if err != nil {
105104
return nil, fmt.Errorf("failed to execute sdk request 'iam.ListServerCertificates': %w", err)
@@ -112,15 +111,15 @@ func (c *Certmgr) Upload(ctx context.Context, certPEM, privkeyPEM string) (*Uplo
112111
}
113112

114113
// 对比证书有效期
115-
if certItem.Expiration == nil || !certX509.NotAfter.Equal(*certItem.Expiration) {
114+
if certItem.Expiration == nil || certX509.NotAfter.Unix() != certItem.Expiration.Unix() {
116115
continue
117116
}
118117

119118
// 对比证书内容
120-
getServerCertificateReq := &iam.GetServerCertificateInput{
119+
getServerCertificateReq := &awsiamsdk.GetServerCertificateRequest{
121120
ServerCertificateName: certItem.ServerCertificateName,
122121
}
123-
getServerCertificateResp, err := c.sdkClient.GetServerCertificate(ctx, getServerCertificateReq)
122+
getServerCertificateResp, err := c.sdkClient.GetServerCertificateWithContext(ctx, getServerCertificateReq)
124123
if err != nil {
125124
var sdkErr smithy.APIError
126125
if errors.As(err, &sdkErr) {
@@ -160,14 +159,14 @@ func (c *Certmgr) Upload(ctx context.Context, certPEM, privkeyPEM string) (*Uplo
160159

161160
// 导入证书
162161
// REF: https://docs.aws.amazon.com/IAM/latest/APIReference/API_UploadServerCertificate.html
163-
uploadServerCertificateReq := &iam.UploadServerCertificateInput{
162+
uploadServerCertificateReq := &awsiamsdk.UploadServerCertificateRequest{
164163
ServerCertificateName: aws.String(certName),
165164
Path: aws.String(cmp.Or(c.config.CertificatePath, "/")),
166165
CertificateBody: aws.String(serverCertPEM),
167166
CertificateChain: aws.String(issuerCertPEM),
168167
PrivateKey: aws.String(privkeyPEM),
169168
}
170-
uploadServerCertificateResp, err := c.sdkClient.UploadServerCertificate(ctx, uploadServerCertificateReq)
169+
uploadServerCertificateResp, err := c.sdkClient.UploadServerCertificateWithContext(ctx, uploadServerCertificateReq)
171170
c.logger.Debug("sdk request 'iam.UploadServerCertificate'", slog.Any("request", uploadServerCertificateReq), slog.Any("response", uploadServerCertificateResp))
172171
if err != nil {
173172
return nil, fmt.Errorf("failed to execute sdk request 'iam.UploadServerCertificate': %w", err)
@@ -187,15 +186,14 @@ func (c *Certmgr) Replace(ctx context.Context, certIdOrName string, certPEM, pri
187186
return nil, core.ErrUnsupported
188187
}
189188

190-
func createSDKClient(accessKeyId, secretAccessKey, region string) (*iam.Client, error) {
191-
cfg, err := awscfg.LoadDefaultConfig(context.Background(),
192-
awscfg.WithCredentialsProvider(awscred.NewStaticCredentialsProvider(accessKeyId, secretAccessKey, "")),
193-
awscfg.WithRegion(region),
189+
func createSDKClient(accessKeyId, secretAccessKey, region string) (*awsiamsdk.Client, error) {
190+
client, err := awsiamsdk.NewClient(
191+
awsiamsdk.WithAkSk(accessKeyId, secretAccessKey),
192+
awsiamsdk.WithRegion(region),
194193
)
195194
if err != nil {
196195
return nil, err
197196
}
198197

199-
client := iam.NewFromConfig(cfg)
200198
return client, nil
201199
}

‎pkg/core/deployer/providers/aws-alb/aws_alb.go‎

Lines changed: 14 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,12 @@ import (
66
"log/slog"
77

88
aws "github.com/aws/aws-sdk-go-v2/aws"
9-
awscfg "github.com/aws/aws-sdk-go-v2/config"
10-
awscred "github.com/aws/aws-sdk-go-v2/credentials"
11-
"github.com/aws/aws-sdk-go-v2/service/elasticloadbalancingv2"
129
"github.com/aws/aws-sdk-go-v2/service/elasticloadbalancingv2/types"
1310

1411
"github.com/certimate-go/certimate/pkg/core"
1512
cmgrimplacm "github.com/certimate-go/certimate/pkg/core/certmgr/providers/aws-acm"
1613
cmgrimpliam "github.com/certimate-go/certimate/pkg/core/certmgr/providers/aws-iam"
14+
awselbsdk "github.com/certimate-go/certimate/pkg/sdk3rd/aws/elasticloadbalancingv2"
1715
)
1816

1917
type (
@@ -42,7 +40,7 @@ type DeployerConfig struct {
4240
type Deployer struct {
4341
config *DeployerConfig
4442
logger *slog.Logger
45-
sdkClient *elasticloadbalancingv2.Client
43+
sdkClient *awselbsdk.Client
4644
sdkCertmgr core.Certmgr
4745
}
4846

@@ -121,10 +119,10 @@ func (d *Deployer) Deploy(ctx context.Context, certPEM, privkeyPEM string) (*Dep
121119

122120
// 查询负载均衡器
123121
// REF: https://docs.aws.amazon.com/elasticloadbalancing/latest/APIReference/API_DescribeLoadBalancers.html
124-
describeLoadBalancersReq := &elasticloadbalancingv2.DescribeLoadBalancersInput{
122+
describeLoadBalancersReq := &awselbsdk.DescribeLoadBalancersRequest{
125123
LoadBalancerArns: []string{d.config.LoadbalancerArn},
126124
}
127-
describeLoadBalancersResp, err := d.sdkClient.DescribeLoadBalancers(ctx, describeLoadBalancersReq)
125+
describeLoadBalancersResp, err := d.sdkClient.DescribeLoadBalancersWithContext(ctx, describeLoadBalancersReq)
128126
d.logger.Debug("sdk request 'elasticloadbalancingv2.DescribeLoadBalancers'", slog.Any("request", describeLoadBalancersReq), slog.Any("response", describeLoadBalancersResp))
129127
if err != nil {
130128
return nil, fmt.Errorf("failed to execute sdk request 'elasticloadbalancingv2.DescribeLoadBalancers': %w", err)
@@ -134,11 +132,11 @@ func (d *Deployer) Deploy(ctx context.Context, certPEM, privkeyPEM string) (*Dep
134132

135133
// 查询侦听器
136134
// REF: https://docs.aws.amazon.com/elasticloadbalancing/latest/APIReference/API_DescribeListeners.html
137-
describeListenersReq := &elasticloadbalancingv2.DescribeListenersInput{
135+
describeListenersReq := &awselbsdk.DescribeListenersRequest{
138136
LoadBalancerArn: aws.String(d.config.LoadbalancerArn),
139137
ListenerArns: []string{d.config.ListenerArn},
140138
}
141-
describeListenersResp, err := d.sdkClient.DescribeListeners(ctx, describeListenersReq)
139+
describeListenersResp, err := d.sdkClient.DescribeListenersWithContext(ctx, describeListenersReq)
142140
d.logger.Debug("sdk request 'elasticloadbalancingv2.DescribeListeners'", slog.Any("request", describeListenersReq), slog.Any("response", describeListenersResp))
143141
if err != nil {
144142
return nil, fmt.Errorf("failed to execute sdk request 'elasticloadbalancingv2.DescribeListeners': %w", err)
@@ -183,15 +181,15 @@ func (d *Deployer) Deploy(ctx context.Context, certPEM, privkeyPEM string) (*Dep
183181
func (d *Deployer) updateListenerDefaultCertificate(ctx context.Context, cloudListenerArn string, cloudCertArn string) error {
184182
// 更新 HTTPS 侦听器
185183
// REF: https://docs.aws.amazon.com/elasticloadbalancing/latest/APIReference/API_ModifyListener.html
186-
modifyListenerReq := &elasticloadbalancingv2.ModifyListenerInput{
184+
modifyListenerReq := &awselbsdk.ModifyListenerRequest{
187185
ListenerArn: aws.String(cloudListenerArn),
188186
Certificates: []types.Certificate{
189187
{
190188
CertificateArn: aws.String(cloudCertArn),
191189
},
192190
},
193191
}
194-
modifyListenerResp, err := d.sdkClient.ModifyListener(ctx, modifyListenerReq)
192+
modifyListenerResp, err := d.sdkClient.ModifyListenerWithContext(ctx, modifyListenerReq)
195193
d.logger.Debug("sdk request 'elasticloadbalancingv2.ModifyListener'", slog.Any("request", modifyListenerReq), slog.Any("response", modifyListenerResp))
196194
if err != nil {
197195
return fmt.Errorf("failed to execute sdk request 'elasticloadbalancingv2.ModifyListener': %w", err)
@@ -203,15 +201,15 @@ func (d *Deployer) updateListenerDefaultCertificate(ctx context.Context, cloudLi
203201
func (d *Deployer) updateListenerSniCertificate(ctx context.Context, cloudListenerArn string, cloudCertArn string) error {
204202
// 将证书添加到证书列表
205203
// REF: https://docs.aws.amazon.com/elasticloadbalancing/latest/APIReference/API_AddListenerCertificates.html
206-
addListenerCertificatesReq := &elasticloadbalancingv2.AddListenerCertificatesInput{
204+
addListenerCertificatesReq := &awselbsdk.AddListenerCertificatesRequest{
207205
ListenerArn: aws.String(cloudListenerArn),
208206
Certificates: []types.Certificate{
209207
{
210208
CertificateArn: aws.String(cloudCertArn),
211209
},
212210
},
213211
}
214-
addListenerCertificatesResp, err := d.sdkClient.AddListenerCertificates(ctx, addListenerCertificatesReq)
212+
addListenerCertificatesResp, err := d.sdkClient.AddListenerCertificatesWithContext(ctx, addListenerCertificatesReq)
215213
d.logger.Debug("sdk request 'elasticloadbalancingv2.AddListenerCertificates'", slog.Any("request", addListenerCertificatesReq), slog.Any("response", addListenerCertificatesResp))
216214
if err != nil {
217215
return fmt.Errorf("failed to execute sdk request 'elasticloadbalancingv2.AddListenerCertificates': %w", err)
@@ -220,15 +218,14 @@ func (d *Deployer) updateListenerSniCertificate(ctx context.Context, cloudListen
220218
return nil
221219
}
222220

223-
func createSDKClient(accessKeyId, secretAccessKey, region string) (*elasticloadbalancingv2.Client, error) {
224-
cfg, err := awscfg.LoadDefaultConfig(context.Background(),
225-
awscfg.WithCredentialsProvider(awscred.NewStaticCredentialsProvider(accessKeyId, secretAccessKey, "")),
226-
awscfg.WithRegion(region),
221+
func createSDKClient(accessKeyId, secretAccessKey, region string) (*awselbsdk.Client, error) {
222+
client, err := awselbsdk.NewClient(
223+
awselbsdk.WithAkSk(accessKeyId, secretAccessKey),
224+
awselbsdk.WithRegion(region),
227225
)
228226
if err != nil {
229227
return nil, err
230228
}
231229

232-
client := elasticloadbalancingv2.NewFromConfig(cfg)
233230
return client, nil
234231
}

0 commit comments

Comments
 (0)