aws

Documentation

Index

• Constants
• func AttemptLoggerInitMiddleware(logger log.Logger, backoff *exec.BackoffSettings) smithyMiddleware.InitializeMiddleware
• func AttemptLoggerRetryMiddleware(logger log.Logger) smithyMiddleware.FinalizeMiddleware
• func DefaultClientConfig(ctx context.Context, config cfg.Config, logger log.Logger, ...) (aws.Config, error)
• func DefaultClientOptions(ctx context.Context, _ cfg.Config, logger log.Logger, ...) ([]func(options *awsCfg.LoadOptions) error, error)
• func DefaultClientRetryOptions(clientConfig ClientConfigAware) []func(*retry.StandardOptions)
• func GetAssumeRoleCredentialsProvider(ctx context.Context, roleArn string) (aws.CredentialsProvider, error)
• func GetClientConfigKey(service string, name string) string
• func GetCredentialsOption(ctx context.Context, settings ClientSettings) (func(options *awsCfg.LoadOptions) error, error)
• func GetCredentialsProvider(ctx context.Context, settings ClientSettings) (aws.CredentialsProvider, error)
• func GetDefaultProvider() aws.CredentialsProvider
• func IsAwsErrorCodeRequestCanceled(err error) bool
• func LogNewClientCreated(ctx context.Context, logger log.Logger, service string, clientName string, ...)
• func NilIfEmpty[T comparable](val T) *T
• func RetryWithBackoff(backoff retry.BackoffDelayer) func(*retry.StandardOptions)
• func RetryWithMaxAttempts(maxAttempts int) func(*retry.StandardOptions)
• func RetryWithMaxBackoff(maxBackoff time.Duration) func(*retry.StandardOptions)
• func RetryWithRateLimiter(rateLimiter retry.RateLimiter) func(options *retry.StandardOptions)
• func RetryWithRetryables(retryables []retry.IsErrorRetryable) func(options *retry.StandardOptions)
• func UnmarshalClientSettings(config cfg.Config, settings ClientSettingsAware, service string, name string)
• func WithResourceTarget(ctx context.Context, target string) context.Context
• type BackoffDelayer
  • func NewBackoffDelayer(initialInterval time.Duration, maxInterval time.Duration) *BackoffDelayer
  • func (d *BackoffDelayer) BackoffDelay(attempt int, _ error) (time.Duration, error)
• type ClientConfigAware
• type ClientHttpSettings
• type ClientSettings
  • func (s *ClientSettings) LogFields() log.Fields
  • func (s *ClientSettings) SetBackoff(backoff exec.BackoffSettings)
• type ClientSettingsAware
• type Credentials
• type Logger
  • func NewLogger(base log.Logger) *Logger
  • func (l Logger) Logf(classification logging.Classification, format string, v ...any)
  • func (l Logger) WithContext(ctx context.Context) logging.Logger
• type NopRateLimiter
  • func NewNopRateLimiter() NopRateLimiter
  • func (n NopRateLimiter) AddTokens(_ uint) error
  • func (n NopRateLimiter) GetToken(_ context.Context, _ uint) (releaseToken func() error, err error)
• type RetryOnClosedNetworkConnection
  • func (r RetryOnClosedNetworkConnection) IsErrorRetryable(err error) aws.Ternary

Constants

const (
	DefaultAccessKeyID     = ""
	DefaultSecretAccessKey = ""
	DefaultToken           = ""
)

Functions

func AttemptLoggerInitMiddleware

func AttemptLoggerInitMiddleware(logger log.Logger, backoff *exec.BackoffSettings) smithyMiddleware.InitializeMiddleware

func AttemptLoggerRetryMiddleware

func AttemptLoggerRetryMiddleware(logger log.Logger) smithyMiddleware.FinalizeMiddleware

func DefaultClientConfig

func DefaultClientConfig(ctx context.Context, config cfg.Config, logger log.Logger, clientConfig ClientConfigAware) (aws.Config, error)

func DefaultClientOptions

func DefaultClientOptions(ctx context.Context, _ cfg.Config, logger log.Logger, clientConfig ClientConfigAware) ([]func(options *awsCfg.LoadOptions) error, error)

func DefaultClientRetryOptions

func DefaultClientRetryOptions(clientConfig ClientConfigAware) []func(*retry.StandardOptions)

func GetAssumeRoleCredentialsProvider

func GetAssumeRoleCredentialsProvider(ctx context.Context, roleArn string) (aws.CredentialsProvider, error)

func GetClientConfigKey

func GetClientConfigKey(service string, name string) string

func GetCredentialsOption

func GetCredentialsOption(ctx context.Context, settings ClientSettings) (func(options *awsCfg.LoadOptions) error, error)

func GetCredentialsProvider

func GetCredentialsProvider(ctx context.Context, settings ClientSettings) (aws.CredentialsProvider, error)

func GetDefaultProvider

func GetDefaultProvider() aws.CredentialsProvider

func IsAwsErrorCodeRequestCanceled

func IsAwsErrorCodeRequestCanceled(err error) bool

func LogNewClientCreated

func LogNewClientCreated(ctx context.Context, logger log.Logger, service string, clientName string, settings ClientSettings)

func NilIfEmpty

func NilIfEmpty[T comparable](val T) *T

func RetryWithBackoff

func RetryWithBackoff(backoff retry.BackoffDelayer) func(*retry.StandardOptions)

func RetryWithMaxAttempts

func RetryWithMaxAttempts(maxAttempts int) func(*retry.StandardOptions)

func RetryWithMaxBackoff

func RetryWithMaxBackoff(maxBackoff time.Duration) func(*retry.StandardOptions)

func RetryWithRateLimiter

func RetryWithRateLimiter(rateLimiter retry.RateLimiter) func(options *retry.StandardOptions)

func RetryWithRetryables

func RetryWithRetryables(retryables []retry.IsErrorRetryable) func(options *retry.StandardOptions)

func UnmarshalClientSettings

func UnmarshalClientSettings(config cfg.Config, settings ClientSettingsAware, service string, name string)

func WithResourceTarget

func WithResourceTarget(ctx context.Context, target string) context.Context

Types

type BackoffDelayer

type BackoffDelayer struct {
	// contains filtered or unexported fields
}

func NewBackoffDelayer

func NewBackoffDelayer(initialInterval time.Duration, maxInterval time.Duration) *BackoffDelayer

func (*BackoffDelayer) BackoffDelay

func (d *BackoffDelayer) BackoffDelay(attempt int, _ error) (time.Duration, error)

type ClientConfigAware

type ClientConfigAware interface {
	GetSettings() ClientSettings
	GetLoadOptions() []func(options *awsCfg.LoadOptions) error
	GetRetryOptions() []func(*retry.StandardOptions)
}

type ClientHttpSettings

type ClientHttpSettings struct {
	Timeout time.Duration `cfg:"timeout" default:"0"`
}

type ClientSettings

type ClientSettings struct {
	Region      string             `cfg:"region" default:"eu-central-1"`
	Endpoint    string             `cfg:"endpoint" default:"http://localhost:4566"`
	AssumeRole  string             `cfg:"assume_role"`
	Profile     string             `cfg:"profile"`
	Credentials Credentials        `cfg:"credentials"`
	HttpClient  ClientHttpSettings `cfg:"http_client"`
	Backoff     exec.BackoffSettings
}

func (*ClientSettings) LogFields

func (s *ClientSettings) LogFields() log.Fields

func (*ClientSettings) SetBackoff

func (s *ClientSettings) SetBackoff(backoff exec.BackoffSettings)

type ClientSettingsAware

type ClientSettingsAware interface {
	SetBackoff(backoff exec.BackoffSettings)
}

type Credentials

type Credentials struct {
	AccessKeyID     string `cfg:"access_key_id"`
	SecretAccessKey string `cfg:"secret_access_key"`
	SessionToken    string `cfg:"session_token"`
}

type Logger

type Logger struct {
	// contains filtered or unexported fields
}

func NewLogger

func NewLogger(base log.Logger) *Logger

func (Logger) Logf

func (l Logger) Logf(classification logging.Classification, format string, v ...any)

func (Logger) WithContext

func (l Logger) WithContext(ctx context.Context) logging.Logger

type NopRateLimiter

type NopRateLimiter struct{}

func NewNopRateLimiter

func NewNopRateLimiter() NopRateLimiter

func (NopRateLimiter) AddTokens

func (n NopRateLimiter) AddTokens(_ uint) error

func (NopRateLimiter) GetToken

func (n NopRateLimiter) GetToken(_ context.Context, _ uint) (releaseToken func() error, err error)

type RetryOnClosedNetworkConnection

type RetryOnClosedNetworkConnection struct{}

func (RetryOnClosedNetworkConnection) IsErrorRetryable

func (r RetryOnClosedNetworkConnection) IsErrorRetryable(err error) aws.Ternary