awss3v1

Documentation

Overview

Package awss3v1 provides s3iot.Uploader with aws-sdk-go (v1).

Index

• Variables
• func NewAPI(api s3iface.S3API) s3iot.S3API
• func NewDownloader(c client.ConfigProvider, opts ...s3iot.DownloaderOption) *s3iot.Downloader
• func NewUploader(c client.ConfigProvider, opts ...s3iot.UploaderOption) *s3iot.Uploader
• type ErrorClassifier
  • func (ErrorClassifier) IsRetryable(err error) bool
  • func (c ErrorClassifier) IsThrottle(err error) (time.Duration, bool)

Variables

var DefaultThrottleWait = 5 * time.Second

DefaultThrottleWait is a default wait duration on throttle.

Functions

func NewAPI

func NewAPI(api s3iface.S3API) s3iot.S3API

NewAPI wraps s3iface.S3API to s3iot.S3API.

func NewDownloader

func NewDownloader(c client.ConfigProvider, opts ...s3iot.DownloaderOption) *s3iot.Downloader

NewDownloader creates s3iot.Downloader from aws-sdk-go ConfigProvider (like Session).

func NewUploader

func NewUploader(c client.ConfigProvider, opts ...s3iot.UploaderOption) *s3iot.Uploader

NewUploader creates s3iot.Uploader from aws-sdk-go ConfigProvider (like Session).

Types

type ErrorClassifier

type ErrorClassifier struct {
	ThrottleWait time.Duration
}

ErrorClassifier classifies aws-sdk-go (v1) errors.

func (ErrorClassifier) IsRetryable

func (ErrorClassifier) IsRetryable(err error) bool

IsRetryable implements ErrorClassifier.

func (ErrorClassifier) IsThrottle

func (c ErrorClassifier) IsThrottle(err error) (time.Duration, bool)

IsThrottle implements ErrorClassifier.