s3

Mar 9, 2017

Changes in this version

+ func NewFakeS3Context(ctx context.Context) context.Context

+ func UsingFakeS3(ctx context.Context) bool

+ type AWS struct

+ func (a *AWS) New(signer Signer, region Region) Connection

+ type BucketInt interface

+ Del func(ctx context.Context, path string) error

+ GetReader func(ctx context.Context, path string) (rc io.ReadCloser, err error)

+ Multi func(ctx context.Context, key, contType string, perm ACL) (MultiInt, error)

+ PutReader func(ctx context.Context, path string, r io.Reader, length int64, contType string, ...) error

+ type Connection interface

+ Bucket func(name string) BucketInt

+ SetAccessKey func(key string)

+ type Mem struct

+ func (m *Mem) New(signer Signer, region Region) Connection

+ func (m *Mem) NewMemConn() *MemConn

+ type MemBucket struct

+ func NewMemBucket(conn *MemConn, name string) *MemBucket

+ func (b *MemBucket) Del(ctx context.Context, path string) error

+ func (b *MemBucket) GetReader(ctx context.Context, path string) (io.ReadCloser, error)

+ func (b *MemBucket) Multi(ctx context.Context, key, contType string, perm ACL) (MultiInt, error)

+ func (b *MemBucket) PutReader(ctx context.Context, path string, r io.Reader, length int64, contType string, ...) error

+ type MemConn struct

+ func (s *MemConn) AllMultis() []*MemMulti

+ func (s *MemConn) Bucket(name string) BucketInt

+ func (s *MemConn) SetAccessKey(key string)

+ type MemMulti struct

+ func NewMemMulti(b *MemBucket, path string) *MemMulti

+ func (m *MemMulti) Complete(ctx context.Context, parts []Part) error

+ func (m *MemMulti) ListParts(ctx context.Context) ([]Part, error)

+ func (m *MemMulti) NumPutParts() int

+ func (m *MemMulti) PutPart(ctx context.Context, index int, r io.ReadSeeker) (Part, error)

+ type MultiInt interface

+ Complete func(ctx context.Context, parts []Part) error

+ ListParts func(ctx context.Context) ([]Part, error)

+ PutPart func(ctx context.Context, n int, r io.ReadSeeker) (Part, error)

+ type Root interface

+ New func(signer Signer, region Region) Connection

type S3

+ func (s3 *S3) SetAccessKey(key string)

Oct 26, 2016

Changes in this version

+ const AuthenticatedRead

+ const BucketOwnerFull

+ const BucketOwnerRead

+ const Private

+ const PublicRead

+ const PublicReadWrite

+ var DefaultAttemptStrategy = AttemptStrategy

+ var USEastAccelerated = Region

+ type ACL string

+ type Attempt struct

+ func (a *Attempt) HasNext() bool

+ func (a *Attempt) Next() bool

+ type AttemptStrategy struct

+ Delay time.Duration

+ Min int

+ Total time.Duration

+ func (s AttemptStrategy) Start() *Attempt

+ type Bucket struct

+ Name string

+ func (b *Bucket) Del(path string) error

+ func (b *Bucket) DelBucket() (err error)

+ func (b *Bucket) DelMulti(objects Delete) error

+ func (b *Bucket) Exists(path string) (exists bool, err error)

+ func (b *Bucket) Get(path string) (data []byte, err error)

+ func (b *Bucket) GetBucketContents() (*map[string]Key, error)

+ func (b *Bucket) GetReader(path string) (rc io.ReadCloser, err error)

+ func (b *Bucket) GetResponse(path string) (resp *http.Response, err error)

+ func (b *Bucket) GetResponseWithHeaders(path string, headers map[string][]string) (resp *http.Response, err error)

+ func (b *Bucket) Head(path string, headers map[string][]string) (*http.Response, error)

+ func (b *Bucket) InitMulti(key string, contType string, perm ACL) (*Multi, error)

+ func (b *Bucket) List(prefix, delim, marker string, max int) (result *ListResp, err error)

+ func (b *Bucket) ListMulti(prefix, delim string) (multis []*Multi, prefixes []string, err error)

+ func (b *Bucket) Multi(key, contType string, perm ACL) (*Multi, error)

+ func (b *Bucket) Put(path string, data []byte, contType string, perm ACL, options Options) error

+ func (b *Bucket) PutBucket(perm ACL) error

+ func (b *Bucket) PutBucketSubresource(subresource string, r io.Reader, length int64) error

+ func (b *Bucket) PutBucketWebsite(configuration WebsiteConfiguration) error

+ func (b *Bucket) PutCopy(path string, perm ACL, options CopyOptions, source string) (result *CopyObjectResult, err error)

+ func (b *Bucket) PutHeader(path string, data []byte, customHeaders map[string][]string, perm ACL) error

+ func (b *Bucket) PutReader(path string, r io.Reader, length int64, contType string, perm ACL, ...) error

+ func (b *Bucket) PutReaderHeader(path string, r io.Reader, length int64, customHeaders map[string][]string, ...) error

+ func (b *Bucket) SignedURL(path string, expires time.Time) string

+ func (b *Bucket) URL(path string) string

+ func (b *Bucket) Versions(prefix, delim, keyMarker string, versionIDMarker string, max int) (result *VersionsResp, err error)

+ type CopyObjectResult struct

+ ETag string

+ LastModified string

+ type CopyOptions struct

+ ContentType string

+ MetadataDirective string

+ type Delete struct

+ Objects []Object

+ Quiet bool

+ type Error struct

+ BucketName string

+ Code string

+ HostID string

+ Message string

+ RequestID string

+ StatusCode int

+ func (e *Error) Error() string

+ type Key struct

+ ETag string

+ Key string

+ LastModified string

+ Owner Owner

+ Size int64

+ StorageClass string

+ type ListResp struct

+ CommonPrefixes []string

+ Contents []Key

+ Delimiter string

+ IsTruncated bool

+ Marker string

+ MaxKeys int

+ Name string

+ NextMarker string

+ Prefix string

+ type Multi struct

+ Bucket *Bucket

+ Key string

+ UploadID string

+ func (m *Multi) Abort() error

+ func (m *Multi) Complete(parts []Part) error

+ func (m *Multi) ListParts() ([]Part, error)

+ func (m *Multi) PutAll(r ReaderAtSeeker, partSize int64) ([]Part, error)

+ func (m *Multi) PutPart(n int, r io.ReadSeeker) (Part, error)

+ type Object struct

+ Key string

+ VersionID string

+ type Options struct

+ CacheControl string

+ ContentEncoding string

+ ContentMD5 string

+ Meta map[string][]string

+ RedirectLocation string

+ SSE bool

+ type Owner struct

+ DisplayName string

+ ID string

+ type Part struct

+ ETag string

+ N int

+ Size int64

+ type ReaderAtSeeker interface

+ type Region struct

+ Name string

+ S3BucketEndpoint string

+ S3Endpoint string

+ S3LocationConstraint bool

+ S3LowercaseBucket bool

+ type RoutingRule struct

+ ConditionKeyPrefixEquals string

+ RedirectReplaceKeyPrefixWith string

+ RedirectReplaceKeyWith string

+ type S3 struct

+ AccessKey string

+ ConnectTimeout time.Duration

+ ReadTimeout time.Duration

+ RequestTimeout time.Duration

+ Signer Signer

+ WriteTimeout time.Duration

+ func New(signer Signer, region Region, client ...*http.Client) *S3

+ func (s3 *S3) Bucket(name string) *Bucket

+ type Signer interface

+ Sign func(payload []byte) ([]byte, error)

+ type Version struct

+ ETag string

+ IsLatest bool

+ Key string

+ LastModified string

+ Owner Owner

+ Size int64

+ StorageClass string

+ VersionID string

+ type VersionsResp struct

+ CommonPrefixes []string

+ Delimiter string

+ IsTruncated bool

+ KeyMarker string

+ MaxKeys int

+ Name string

+ Prefix string

+ VersionIDMarker string

+ Versions []Version

+ type WebsiteConfiguration struct

+ ErrorDocumentKey string

+ IndexDocumentSuffix string

+ RoutingRules *[]RoutingRule

+ XMLName xml.Name