awss3v1

Documentation

Overview

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

Index

• Variables
• func NewAPI(api s3iface.S3API) s3api.S3API
• func NewAWSSDKDownloader(u s3manageriface.DownloaderAPI) s3iotiface.Downloader
• func NewAWSSDKUploader(u s3manageriface.UploaderAPI) s3iotiface.Uploader
• 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) s3api.S3API

NewAPI wraps s3iface.S3API to s3api.S3API.

func NewAWSSDKDownloader

func NewAWSSDKDownloader(u s3manageriface.DownloaderAPI) s3iotiface.Downloader

NewAWSSDKDownloader wraps aws-sdk-go s3manager as s3iotiface.Downloader. Some fields of download status and result is not provided. Pause/resume feature is unavailable.

func NewAWSSDKUploader

func NewAWSSDKUploader(u s3manageriface.UploaderAPI) s3iotiface.Uploader

NewAWSSDKUploader wraps aws-sdk-go s3manager as s3iotiface.Uploader. Some fields of download status and result is not provided. Pause/resume feature is unavailable.

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.