Merge pull request #126 from alexgridx/dependabot/go_modules/github.com/aws/aws-sdk-go-v2/config-1.27.24
Bump github.com/aws/aws-sdk-go-v2/config from 1.27.16 to 1.27.24
This commit is contained in:
commit
e5f5c42a16
11 changed files with 173 additions and 6 deletions
2
go.mod
2
go.mod
|
|
@ -7,7 +7,7 @@ require (
|
||||||
github.com/alicebob/miniredis v2.5.0+incompatible
|
github.com/alicebob/miniredis v2.5.0+incompatible
|
||||||
github.com/apex/log v1.9.0
|
github.com/apex/log v1.9.0
|
||||||
github.com/aws/aws-sdk-go-v2 v1.30.1
|
github.com/aws/aws-sdk-go-v2 v1.30.1
|
||||||
github.com/aws/aws-sdk-go-v2/config v1.27.16
|
github.com/aws/aws-sdk-go-v2/config v1.27.24
|
||||||
github.com/aws/aws-sdk-go-v2/credentials v1.17.24
|
github.com/aws/aws-sdk-go-v2/credentials v1.17.24
|
||||||
github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.14.1
|
github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.14.1
|
||||||
github.com/aws/aws-sdk-go-v2/service/dynamodb v1.32.8
|
github.com/aws/aws-sdk-go-v2/service/dynamodb v1.32.8
|
||||||
|
|
|
||||||
4
go.sum
4
go.sum
|
|
@ -17,8 +17,8 @@ github.com/aws/aws-sdk-go-v2 v1.30.1 h1:4y/5Dvfrhd1MxRDD77SrfsDaj8kUkkljU7XE83NP
|
||||||
github.com/aws/aws-sdk-go-v2 v1.30.1/go.mod h1:nIQjQVp5sfpQcTc9mPSr1B0PaWK5ByX9MOoDadSN4lc=
|
github.com/aws/aws-sdk-go-v2 v1.30.1/go.mod h1:nIQjQVp5sfpQcTc9mPSr1B0PaWK5ByX9MOoDadSN4lc=
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.2 h1:x6xsQXGSmW6frevwDA+vi/wqhp1ct18mVXYN08/93to=
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.2 h1:x6xsQXGSmW6frevwDA+vi/wqhp1ct18mVXYN08/93to=
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.2/go.mod h1:lPprDr1e6cJdyYeGXnRaJoP4Md+cDBvi2eOj00BlGmg=
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.2/go.mod h1:lPprDr1e6cJdyYeGXnRaJoP4Md+cDBvi2eOj00BlGmg=
|
||||||
github.com/aws/aws-sdk-go-v2/config v1.27.16 h1:knpCuH7laFVGYTNd99Ns5t+8PuRjDn4HnnZK48csipM=
|
github.com/aws/aws-sdk-go-v2/config v1.27.24 h1:NM9XicZ5o1CBU/MZaHwFtimRpWx9ohAUAqkG6AqSqPo=
|
||||||
github.com/aws/aws-sdk-go-v2/config v1.27.16/go.mod h1:vutqgRhDUktwSge3hrC3nkuirzkJ4E/mLj5GvI0BQas=
|
github.com/aws/aws-sdk-go-v2/config v1.27.24/go.mod h1:aXzi6QJTuQRVVusAO8/NxpdTeTyr/wRcybdDtfUwJSs=
|
||||||
github.com/aws/aws-sdk-go-v2/credentials v1.17.24 h1:YclAsrnb1/GTQNt2nzv+756Iw4mF8AOzcDfweWwwm/M=
|
github.com/aws/aws-sdk-go-v2/credentials v1.17.24 h1:YclAsrnb1/GTQNt2nzv+756Iw4mF8AOzcDfweWwwm/M=
|
||||||
github.com/aws/aws-sdk-go-v2/credentials v1.17.24/go.mod h1:Hld7tmnAkoBQdTMNYZGzztzKRdA4fCdn9L83LOoigac=
|
github.com/aws/aws-sdk-go-v2/credentials v1.17.24/go.mod h1:Hld7tmnAkoBQdTMNYZGzztzKRdA4fCdn9L83LOoigac=
|
||||||
github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.14.1 h1:Uhn/kOwwHAL4vI6LdgvV0cfaQbaLyvJbCCyrSZLNBm8=
|
github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.14.1 h1:Uhn/kOwwHAL4vI6LdgvV0cfaQbaLyvJbCCyrSZLNBm8=
|
||||||
|
|
|
||||||
33
vendor/github.com/aws/aws-sdk-go-v2/config/CHANGELOG.md
generated
vendored
33
vendor/github.com/aws/aws-sdk-go-v2/config/CHANGELOG.md
generated
vendored
|
|
@ -1,3 +1,36 @@
|
||||||
|
# v1.27.24 (2024-07-03)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.23 (2024-06-28)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.22 (2024-06-26)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.21 (2024-06-19)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.20 (2024-06-18)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.19 (2024-06-17)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.18 (2024-06-07)
|
||||||
|
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
|
# v1.27.17 (2024-06-03)
|
||||||
|
|
||||||
|
* **Documentation**: Add deprecation docs to global endpoint resolution interfaces. These APIs were previously deprecated with the introduction of service-specific endpoint resolution (EndpointResolverV2 and BaseEndpoint on service client options).
|
||||||
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
||||||
# v1.27.16 (2024-05-23)
|
# v1.27.16 (2024-05-23)
|
||||||
|
|
||||||
* **Dependency Update**: Updated to the latest SDK module versions
|
* **Dependency Update**: Updated to the latest SDK module versions
|
||||||
|
|
|
||||||
3
vendor/github.com/aws/aws-sdk-go-v2/config/config.go
generated
vendored
3
vendor/github.com/aws/aws-sdk-go-v2/config/config.go
generated
vendored
|
|
@ -80,6 +80,9 @@ var defaultAWSConfigResolvers = []awsConfigResolver{
|
||||||
|
|
||||||
// Sets the RequestMinCompressSizeBytes if present in env var or shared config profile
|
// Sets the RequestMinCompressSizeBytes if present in env var or shared config profile
|
||||||
resolveRequestMinCompressSizeBytes,
|
resolveRequestMinCompressSizeBytes,
|
||||||
|
|
||||||
|
// Sets the AccountIDEndpointMode if present in env var or shared config profile
|
||||||
|
resolveAccountIDEndpointMode,
|
||||||
}
|
}
|
||||||
|
|
||||||
// A Config represents a generic configuration value or set of values. This type
|
// A Config represents a generic configuration value or set of values. This type
|
||||||
|
|
|
||||||
37
vendor/github.com/aws/aws-sdk-go-v2/config/env_config.go
generated
vendored
37
vendor/github.com/aws/aws-sdk-go-v2/config/env_config.go
generated
vendored
|
|
@ -80,6 +80,9 @@ const (
|
||||||
awsRequestMinCompressionSizeBytes = "AWS_REQUEST_MIN_COMPRESSION_SIZE_BYTES"
|
awsRequestMinCompressionSizeBytes = "AWS_REQUEST_MIN_COMPRESSION_SIZE_BYTES"
|
||||||
|
|
||||||
awsS3DisableExpressSessionAuthEnv = "AWS_S3_DISABLE_EXPRESS_SESSION_AUTH"
|
awsS3DisableExpressSessionAuthEnv = "AWS_S3_DISABLE_EXPRESS_SESSION_AUTH"
|
||||||
|
|
||||||
|
awsAccountIDEnv = "AWS_ACCOUNT_ID"
|
||||||
|
awsAccountIDEndpointModeEnv = "AWS_ACCOUNT_ID_ENDPOINT_MODE"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
@ -290,6 +293,9 @@ type EnvConfig struct {
|
||||||
// will only bypass the modified endpoint routing and signing behaviors
|
// will only bypass the modified endpoint routing and signing behaviors
|
||||||
// associated with the feature.
|
// associated with the feature.
|
||||||
S3DisableExpressAuth *bool
|
S3DisableExpressAuth *bool
|
||||||
|
|
||||||
|
// Indicates whether account ID will be required/ignored in endpoint2.0 routing
|
||||||
|
AccountIDEndpointMode aws.AccountIDEndpointMode
|
||||||
}
|
}
|
||||||
|
|
||||||
// loadEnvConfig reads configuration values from the OS's environment variables.
|
// loadEnvConfig reads configuration values from the OS's environment variables.
|
||||||
|
|
@ -309,6 +315,7 @@ func NewEnvConfig() (EnvConfig, error) {
|
||||||
setStringFromEnvVal(&creds.AccessKeyID, credAccessEnvKeys)
|
setStringFromEnvVal(&creds.AccessKeyID, credAccessEnvKeys)
|
||||||
setStringFromEnvVal(&creds.SecretAccessKey, credSecretEnvKeys)
|
setStringFromEnvVal(&creds.SecretAccessKey, credSecretEnvKeys)
|
||||||
if creds.HasKeys() {
|
if creds.HasKeys() {
|
||||||
|
creds.AccountID = os.Getenv(awsAccountIDEnv)
|
||||||
creds.SessionToken = os.Getenv(awsSessionTokenEnvVar)
|
creds.SessionToken = os.Getenv(awsSessionTokenEnvVar)
|
||||||
cfg.Credentials = creds
|
cfg.Credentials = creds
|
||||||
}
|
}
|
||||||
|
|
@ -389,6 +396,10 @@ func NewEnvConfig() (EnvConfig, error) {
|
||||||
return cfg, err
|
return cfg, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := setAIDEndPointModeFromEnvVal(&cfg.AccountIDEndpointMode, []string{awsAccountIDEndpointModeEnv}); err != nil {
|
||||||
|
return cfg, err
|
||||||
|
}
|
||||||
|
|
||||||
return cfg, nil
|
return cfg, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -417,6 +428,10 @@ func (c EnvConfig) getRequestMinCompressSizeBytes(context.Context) (int64, bool,
|
||||||
return *c.RequestMinCompressSizeBytes, true, nil
|
return *c.RequestMinCompressSizeBytes, true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c EnvConfig) getAccountIDEndpointMode(context.Context) (aws.AccountIDEndpointMode, bool, error) {
|
||||||
|
return c.AccountIDEndpointMode, len(c.AccountIDEndpointMode) > 0, nil
|
||||||
|
}
|
||||||
|
|
||||||
// GetRetryMaxAttempts returns the value of AWS_MAX_ATTEMPTS if was specified,
|
// GetRetryMaxAttempts returns the value of AWS_MAX_ATTEMPTS if was specified,
|
||||||
// and not 0.
|
// and not 0.
|
||||||
func (c EnvConfig) GetRetryMaxAttempts(ctx context.Context) (int, bool, error) {
|
func (c EnvConfig) GetRetryMaxAttempts(ctx context.Context) (int, bool, error) {
|
||||||
|
|
@ -491,6 +506,28 @@ func setEC2IMDSEndpointMode(mode *imds.EndpointModeState, keys []string) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func setAIDEndPointModeFromEnvVal(m *aws.AccountIDEndpointMode, keys []string) error {
|
||||||
|
for _, k := range keys {
|
||||||
|
value := os.Getenv(k)
|
||||||
|
if len(value) == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
switch value {
|
||||||
|
case "preferred":
|
||||||
|
*m = aws.AccountIDEndpointModePreferred
|
||||||
|
case "required":
|
||||||
|
*m = aws.AccountIDEndpointModeRequired
|
||||||
|
case "disabled":
|
||||||
|
*m = aws.AccountIDEndpointModeDisabled
|
||||||
|
default:
|
||||||
|
return fmt.Errorf("invalid value for environment variable, %s=%s, must be preferred/required/disabled", k, value)
|
||||||
|
}
|
||||||
|
break
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
// GetRegion returns the AWS Region if set in the environment. Returns an empty
|
// GetRegion returns the AWS Region if set in the environment. Returns an empty
|
||||||
// string if not set.
|
// string if not set.
|
||||||
func (c EnvConfig) getRegion(ctx context.Context) (string, bool, error) {
|
func (c EnvConfig) getRegion(ctx context.Context) (string, bool, error) {
|
||||||
|
|
|
||||||
2
vendor/github.com/aws/aws-sdk-go-v2/config/go_module_metadata.go
generated
vendored
2
vendor/github.com/aws/aws-sdk-go-v2/config/go_module_metadata.go
generated
vendored
|
|
@ -3,4 +3,4 @@
|
||||||
package config
|
package config
|
||||||
|
|
||||||
// goModuleVersion is the tagged release for this module
|
// goModuleVersion is the tagged release for this module
|
||||||
const goModuleVersion = "1.27.16"
|
const goModuleVersion = "1.27.24"
|
||||||
|
|
|
||||||
29
vendor/github.com/aws/aws-sdk-go-v2/config/load_options.go
generated
vendored
29
vendor/github.com/aws/aws-sdk-go-v2/config/load_options.go
generated
vendored
|
|
@ -215,6 +215,8 @@ type LoadOptions struct {
|
||||||
|
|
||||||
// Whether S3 Express auth is disabled.
|
// Whether S3 Express auth is disabled.
|
||||||
S3DisableExpressAuth *bool
|
S3DisableExpressAuth *bool
|
||||||
|
|
||||||
|
AccountIDEndpointMode aws.AccountIDEndpointMode
|
||||||
}
|
}
|
||||||
|
|
||||||
func (o LoadOptions) getDefaultsMode(ctx context.Context) (aws.DefaultsMode, bool, error) {
|
func (o LoadOptions) getDefaultsMode(ctx context.Context) (aws.DefaultsMode, bool, error) {
|
||||||
|
|
@ -278,6 +280,10 @@ func (o LoadOptions) getRequestMinCompressSizeBytes(ctx context.Context) (int64,
|
||||||
return *o.RequestMinCompressSizeBytes, true, nil
|
return *o.RequestMinCompressSizeBytes, true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (o LoadOptions) getAccountIDEndpointMode(ctx context.Context) (aws.AccountIDEndpointMode, bool, error) {
|
||||||
|
return o.AccountIDEndpointMode, len(o.AccountIDEndpointMode) > 0, nil
|
||||||
|
}
|
||||||
|
|
||||||
// WithRegion is a helper function to construct functional options
|
// WithRegion is a helper function to construct functional options
|
||||||
// that sets Region on config's LoadOptions. Setting the region to
|
// that sets Region on config's LoadOptions. Setting the region to
|
||||||
// an empty string, will result in the region value being ignored.
|
// an empty string, will result in the region value being ignored.
|
||||||
|
|
@ -323,6 +329,17 @@ func WithRequestMinCompressSizeBytes(RequestMinCompressSizeBytes *int64) LoadOpt
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// WithAccountIDEndpointMode is a helper function to construct functional options
|
||||||
|
// that sets AccountIDEndpointMode on config's LoadOptions
|
||||||
|
func WithAccountIDEndpointMode(m aws.AccountIDEndpointMode) LoadOptionsFunc {
|
||||||
|
return func(o *LoadOptions) error {
|
||||||
|
if m != "" {
|
||||||
|
o.AccountIDEndpointMode = m
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// getDefaultRegion returns DefaultRegion from config's LoadOptions
|
// getDefaultRegion returns DefaultRegion from config's LoadOptions
|
||||||
func (o LoadOptions) getDefaultRegion(ctx context.Context) (string, bool, error) {
|
func (o LoadOptions) getDefaultRegion(ctx context.Context) (string, bool, error) {
|
||||||
if len(o.DefaultRegion) == 0 {
|
if len(o.DefaultRegion) == 0 {
|
||||||
|
|
@ -824,7 +841,14 @@ func (o LoadOptions) getEndpointResolver(ctx context.Context) (aws.EndpointResol
|
||||||
// the EndpointResolver value is ignored. If multiple WithEndpointResolver calls
|
// the EndpointResolver value is ignored. If multiple WithEndpointResolver calls
|
||||||
// are made, the last call overrides the previous call values.
|
// are made, the last call overrides the previous call values.
|
||||||
//
|
//
|
||||||
// Deprecated: See WithEndpointResolverWithOptions
|
// Deprecated: The global endpoint resolution interface is deprecated. The API
|
||||||
|
// for endpoint resolution is now unique to each service and is set via the
|
||||||
|
// EndpointResolverV2 field on service client options. Use of
|
||||||
|
// WithEndpointResolver or WithEndpointResolverWithOptions will prevent you
|
||||||
|
// from using any endpoint-related service features released after the
|
||||||
|
// introduction of EndpointResolverV2. You may also encounter broken or
|
||||||
|
// unexpected behavior when using the old global interface with services that
|
||||||
|
// use many endpoint-related customizations such as S3.
|
||||||
func WithEndpointResolver(v aws.EndpointResolver) LoadOptionsFunc {
|
func WithEndpointResolver(v aws.EndpointResolver) LoadOptionsFunc {
|
||||||
return func(o *LoadOptions) error {
|
return func(o *LoadOptions) error {
|
||||||
o.EndpointResolver = v
|
o.EndpointResolver = v
|
||||||
|
|
@ -844,6 +868,9 @@ func (o LoadOptions) getEndpointResolverWithOptions(ctx context.Context) (aws.En
|
||||||
// that sets the EndpointResolverWithOptions on LoadOptions. If the EndpointResolverWithOptions is set to nil,
|
// that sets the EndpointResolverWithOptions on LoadOptions. If the EndpointResolverWithOptions is set to nil,
|
||||||
// the EndpointResolver value is ignored. If multiple WithEndpointResolver calls
|
// the EndpointResolver value is ignored. If multiple WithEndpointResolver calls
|
||||||
// are made, the last call overrides the previous call values.
|
// are made, the last call overrides the previous call values.
|
||||||
|
//
|
||||||
|
// Deprecated: The global endpoint resolution interface is deprecated. See
|
||||||
|
// deprecation docs on [WithEndpointResolver].
|
||||||
func WithEndpointResolverWithOptions(v aws.EndpointResolverWithOptions) LoadOptionsFunc {
|
func WithEndpointResolverWithOptions(v aws.EndpointResolverWithOptions) LoadOptionsFunc {
|
||||||
return func(o *LoadOptions) error {
|
return func(o *LoadOptions) error {
|
||||||
o.EndpointResolverWithOptions = v
|
o.EndpointResolverWithOptions = v
|
||||||
|
|
|
||||||
17
vendor/github.com/aws/aws-sdk-go-v2/config/provider.go
generated
vendored
17
vendor/github.com/aws/aws-sdk-go-v2/config/provider.go
generated
vendored
|
|
@ -225,6 +225,23 @@ func getRequestMinCompressSizeBytes(ctx context.Context, configs configs) (value
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// accountIDEndpointModeProvider provides access to the AccountIDEndpointMode
|
||||||
|
type accountIDEndpointModeProvider interface {
|
||||||
|
getAccountIDEndpointMode(context.Context) (aws.AccountIDEndpointMode, bool, error)
|
||||||
|
}
|
||||||
|
|
||||||
|
func getAccountIDEndpointMode(ctx context.Context, configs configs) (value aws.AccountIDEndpointMode, found bool, err error) {
|
||||||
|
for _, cfg := range configs {
|
||||||
|
if p, ok := cfg.(accountIDEndpointModeProvider); ok {
|
||||||
|
value, found, err = p.getAccountIDEndpointMode(ctx)
|
||||||
|
if err != nil || found {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
// ec2IMDSRegionProvider provides access to the ec2 imds region
|
// ec2IMDSRegionProvider provides access to the ec2 imds region
|
||||||
// configuration value
|
// configuration value
|
||||||
type ec2IMDSRegionProvider interface {
|
type ec2IMDSRegionProvider interface {
|
||||||
|
|
|
||||||
16
vendor/github.com/aws/aws-sdk-go-v2/config/resolve.go
generated
vendored
16
vendor/github.com/aws/aws-sdk-go-v2/config/resolve.go
generated
vendored
|
|
@ -166,6 +166,22 @@ func resolveRequestMinCompressSizeBytes(ctx context.Context, cfg *aws.Config, co
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// resolveAccountIDEndpointMode extracts the AccountIDEndpointMode from the configs slice's
|
||||||
|
// SharedConfig or EnvConfig
|
||||||
|
func resolveAccountIDEndpointMode(ctx context.Context, cfg *aws.Config, configs configs) error {
|
||||||
|
m, found, err := getAccountIDEndpointMode(ctx, configs)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
if !found {
|
||||||
|
m = aws.AccountIDEndpointModePreferred
|
||||||
|
}
|
||||||
|
|
||||||
|
cfg.AccountIDEndpointMode = m
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
// resolveDefaultRegion extracts the first instance of a default region and sets `aws.Config.Region` to the default
|
// resolveDefaultRegion extracts the first instance of a default region and sets `aws.Config.Region` to the default
|
||||||
// region if region had not been resolved from other sources.
|
// region if region had not been resolved from other sources.
|
||||||
func resolveDefaultRegion(ctx context.Context, cfg *aws.Config, configs configs) error {
|
func resolveDefaultRegion(ctx context.Context, cfg *aws.Config, configs configs) error {
|
||||||
|
|
|
||||||
34
vendor/github.com/aws/aws-sdk-go-v2/config/shared_config.go
generated
vendored
34
vendor/github.com/aws/aws-sdk-go-v2/config/shared_config.go
generated
vendored
|
|
@ -115,6 +115,9 @@ const (
|
||||||
requestMinCompressionSizeBytes = "request_min_compression_size_bytes"
|
requestMinCompressionSizeBytes = "request_min_compression_size_bytes"
|
||||||
|
|
||||||
s3DisableExpressSessionAuthKey = "s3_disable_express_session_auth"
|
s3DisableExpressSessionAuthKey = "s3_disable_express_session_auth"
|
||||||
|
|
||||||
|
accountIDKey = "aws_account_id"
|
||||||
|
accountIDEndpointMode = "account_id_endpoint_mode"
|
||||||
)
|
)
|
||||||
|
|
||||||
// defaultSharedConfigProfile allows for swapping the default profile for testing
|
// defaultSharedConfigProfile allows for swapping the default profile for testing
|
||||||
|
|
@ -341,6 +344,8 @@ type SharedConfig struct {
|
||||||
// will only bypass the modified endpoint routing and signing behaviors
|
// will only bypass the modified endpoint routing and signing behaviors
|
||||||
// associated with the feature.
|
// associated with the feature.
|
||||||
S3DisableExpressAuth *bool
|
S3DisableExpressAuth *bool
|
||||||
|
|
||||||
|
AccountIDEndpointMode aws.AccountIDEndpointMode
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c SharedConfig) getDefaultsMode(ctx context.Context) (value aws.DefaultsMode, ok bool, err error) {
|
func (c SharedConfig) getDefaultsMode(ctx context.Context) (value aws.DefaultsMode, ok bool, err error) {
|
||||||
|
|
@ -1124,12 +1129,17 @@ func (c *SharedConfig) setFromIniSection(profile string, section ini.Section) er
|
||||||
return fmt.Errorf("failed to load %s from shared config, %w", requestMinCompressionSizeBytes, err)
|
return fmt.Errorf("failed to load %s from shared config, %w", requestMinCompressionSizeBytes, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := updateAIDEndpointMode(&c.AccountIDEndpointMode, section, accountIDEndpointMode); err != nil {
|
||||||
|
return fmt.Errorf("failed to load %s from shared config, %w", accountIDEndpointMode, err)
|
||||||
|
}
|
||||||
|
|
||||||
// Shared Credentials
|
// Shared Credentials
|
||||||
creds := aws.Credentials{
|
creds := aws.Credentials{
|
||||||
AccessKeyID: section.String(accessKeyIDKey),
|
AccessKeyID: section.String(accessKeyIDKey),
|
||||||
SecretAccessKey: section.String(secretAccessKey),
|
SecretAccessKey: section.String(secretAccessKey),
|
||||||
SessionToken: section.String(sessionTokenKey),
|
SessionToken: section.String(sessionTokenKey),
|
||||||
Source: fmt.Sprintf("SharedConfigCredentials: %s", section.SourceFile[accessKeyIDKey]),
|
Source: fmt.Sprintf("SharedConfigCredentials: %s", section.SourceFile[accessKeyIDKey]),
|
||||||
|
AccountID: section.String(accountIDKey),
|
||||||
}
|
}
|
||||||
|
|
||||||
if creds.HasKeys() {
|
if creds.HasKeys() {
|
||||||
|
|
@ -1177,6 +1187,26 @@ func updateDisableRequestCompression(disable **bool, sec ini.Section, key string
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func updateAIDEndpointMode(m *aws.AccountIDEndpointMode, sec ini.Section, key string) error {
|
||||||
|
if !sec.Has(key) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
v := sec.String(key)
|
||||||
|
switch v {
|
||||||
|
case "preferred":
|
||||||
|
*m = aws.AccountIDEndpointModePreferred
|
||||||
|
case "required":
|
||||||
|
*m = aws.AccountIDEndpointModeRequired
|
||||||
|
case "disabled":
|
||||||
|
*m = aws.AccountIDEndpointModeDisabled
|
||||||
|
default:
|
||||||
|
return fmt.Errorf("invalid value for shared config profile field, %s=%s, must be preferred/required/disabled", key, v)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
func (c SharedConfig) getRequestMinCompressSizeBytes(ctx context.Context) (int64, bool, error) {
|
func (c SharedConfig) getRequestMinCompressSizeBytes(ctx context.Context) (int64, bool, error) {
|
||||||
if c.RequestMinCompressSizeBytes == nil {
|
if c.RequestMinCompressSizeBytes == nil {
|
||||||
return 0, false, nil
|
return 0, false, nil
|
||||||
|
|
@ -1191,6 +1221,10 @@ func (c SharedConfig) getDisableRequestCompression(ctx context.Context) (bool, b
|
||||||
return *c.DisableRequestCompression, true, nil
|
return *c.DisableRequestCompression, true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c SharedConfig) getAccountIDEndpointMode(ctx context.Context) (aws.AccountIDEndpointMode, bool, error) {
|
||||||
|
return c.AccountIDEndpointMode, len(c.AccountIDEndpointMode) > 0, nil
|
||||||
|
}
|
||||||
|
|
||||||
func updateDefaultsMode(mode *aws.DefaultsMode, section ini.Section, key string) error {
|
func updateDefaultsMode(mode *aws.DefaultsMode, section ini.Section, key string) error {
|
||||||
if !section.Has(key) {
|
if !section.Has(key) {
|
||||||
return nil
|
return nil
|
||||||
|
|
|
||||||
2
vendor/modules.txt
vendored
2
vendor/modules.txt
vendored
|
|
@ -48,7 +48,7 @@ github.com/aws/aws-sdk-go-v2/internal/timeconv
|
||||||
## explicit; go 1.20
|
## explicit; go 1.20
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream
|
||||||
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream/eventstreamapi
|
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream/eventstreamapi
|
||||||
# github.com/aws/aws-sdk-go-v2/config v1.27.16
|
# github.com/aws/aws-sdk-go-v2/config v1.27.24
|
||||||
## explicit; go 1.20
|
## explicit; go 1.20
|
||||||
github.com/aws/aws-sdk-go-v2/config
|
github.com/aws/aws-sdk-go-v2/config
|
||||||
# github.com/aws/aws-sdk-go-v2/credentials v1.17.24
|
# github.com/aws/aws-sdk-go-v2/credentials v1.17.24
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue