s3client

Nov 18, 2021

Changes in this version

type Uploader

+ func (u *Uploader) UploadWithPSKAndContext(ctx context.Context, input *s3manager.UploadInput, psk []byte, ...) (*s3manager.UploadOutput, error)

+ func (u *Uploader) ValidateInput(input *s3manager.UploadInput) (log.Data, error)

Nov 11, 2021

Changes in this version

type S3

+ func (cli *S3) Head(key string) (*s3.HeadObjectOutput, error)

type S3SDKClient

+ HeadObject func(in *s3.HeadObjectInput) (out *s3.HeadObjectOutput, err error)

Oct 28, 2021

Changes in this version

type S3SDKUploader

+ UploadWithContext func(context.Context, *s3manager.UploadInput, ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)

type Uploader

+ func (u *Uploader) UploadWithContext(ctx context.Context, input *s3manager.UploadInput, ...) (*s3manager.UploadOutput, error)

Aug 3, 2021

Changes in this version

+ type Error struct

+ func NewError(err error, logData map[string]interface{}) *Error

+ func (e *Error) Error() string

+ func (e *Error) LogData() map[string]interface{}

+ func (e *Error) Unwrap() error

Mar 23, 2020

Changes in this version

+ const AliasVirtualHostedStyle

+ const GlobalPathStyle

+ const GlobalVirtualHostedStyle

+ const PathStyle

+ const VirtualHostedStyle

+ type ErrUnexpectedRegion struct

+ ExpectedRegion string

+ Region string

+ func (e *ErrUnexpectedRegion) Error() string

type S3

+ func (cli *S3) GetFromS3URLWithPSK(rawURL string, style URLStyle, psk []byte) (io.ReadCloser, error)

+ type S3Url struct

+ BucketName string

+ Key string

+ Region string

+ Scheme string

+ func NewURLWithScheme(scheme, region, bucketName, key string) (*S3Url, error)

+ func ParseAliasVirtualHostedURL(avhURL string) (*S3Url, error)

+ func ParseGlobalPathStyleURL(gpURL string) (*S3Url, error)

+ func ParseGlobalVirtualHostedURL(gvhURL string) (*S3Url, error)

+ func ParsePathStyleURL(pathStyleURL string) (*S3Url, error)

+ func ParseURL(rawURL string, style URLStyle) (*S3Url, error)

+ func ParseVirtualHostedURL(vhURL string) (*S3Url, error)

+ func (s3Url *S3Url) String(style URLStyle) (string, error)

+ type URLStyle int

+ func (style URLStyle) String() string

Feb 25, 2020

Changes in this version

+ type ErrBucketNotFound struct

+ BucketName string

+ func (e *ErrBucketNotFound) Error() string

type S3

+ func (cli *S3) GetWithPSK(key string, psk []byte) (io.ReadCloser, error)

+ func (cli *S3) PutWithPSK(key *string, reader *bytes.Reader, psk []byte) error

type S3CryptoClient

+ GetObjectWithPSK func(*s3.GetObjectInput, []byte) (*s3.GetObjectOutput, error)

+ PutObjectWithPSK func(*s3.PutObjectInput, []byte) (*s3.PutObjectOutput, error)

type S3SDKClient

+ HeadBucket func(*s3.HeadBucketInput) (*s3.HeadBucketOutput, error)

Feb 20, 2020

Changes in this version

+ type ErrInvalidUploader struct

+ ExpectCrypto bool

+ func (e *ErrInvalidUploader) Error() string

type S3

+ func InstantiateClient(sdkClient S3SDKClient, cryptoClient S3CryptoClient, bucketName, region string, ...) *S3

+ func NewClient(region string, bucketName string, hasUserDefinedPSK bool) (*S3, error)

+ func NewClientWithSession(bucketName string, hasUserDefinedPSK bool, s *session.Session) *S3

+ func (cli *S3) CheckPartUploaded(ctx context.Context, req *UploadPartRequest) (bool, error)

+ func (cli *S3) Session() *session.Session

+ func (cli *S3) UploadPart(ctx context.Context, req *UploadPartRequest, payload []byte) error

+ func (cli *S3) UploadPartWithPsk(ctx context.Context, req *UploadPartRequest, payload []byte, psk []byte) error

+ type S3CryptoUploader interface

+ UploadWithPSK func(*s3manager.UploadInput, []byte) (*s3manager.UploadOutput, error)

+ type S3SDKUploader interface

+ Upload func(*s3manager.UploadInput, ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)

+ type UploadPartRequest struct

+ ChunkNumber int64

+ FileName string

+ TotalChunks int

+ Type string

+ UploadKey string

+ type Uploader struct

+ func InstantiateUploader(s3Client *S3, sdkUploader S3SDKUploader, cryptoUploader S3CryptoUploader) *Uploader

+ func NewUploader(region string, bucketName string, hasUserDefinedPSK bool) (*Uploader, error)

+ func NewUploaderWithSession(bucketName string, hasUserDefinedPSK bool, s *session.Session) *Uploader

+ func (u *Uploader) Session() *session.Session

+ func (u *Uploader) Upload(input *s3manager.UploadInput, options ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)

+ func (u *Uploader) UploadWithPSK(input *s3manager.UploadInput, psk []byte) (*s3manager.UploadOutput, error)

Feb 11, 2020

Changes in this version

+ type ErrChunkNumberNotFound struct

+ ChunkNumber int64

+ func (e *ErrChunkNumberNotFound) Error() string

+ type ErrListParts struct

+ Msg string

+ func (e *ErrListParts) Error() string

+ type ErrNotUploaded struct

+ UploadKey string

+ func (e *ErrNotUploaded) Error() string

+ type ErrUnexpectedBucket struct

+ BucketName string

+ ExpectedBucketName string

+ func (e *ErrUnexpectedBucket) Error() string

type S3

+ func Instantiate(sdkClient S3SDKClient, cryptoClient S3CryptoClient, bucketName, region string) *S3

+ func (cli *S3) CheckUploaded(ctx context.Context, req *UploadRequest) (bool, error)

+ func (cli *S3) GetFromS3URL(rawURL string) (io.ReadCloser, error)

+ func (cli *S3) GetPathStyleURL(path string) string

+ func (cli *S3) Upload(ctx context.Context, req *UploadRequest, payload []byte) error

+ func (cli *S3) UploadWithPsk(ctx context.Context, req *UploadRequest, payload []byte, psk []byte) error

+ func (cli *S3) ValidateBucket() error

+ type S3CryptoClient interface

+ UploadPartWithPSK func(*s3.UploadPartInput, []byte) (*s3.UploadPartOutput, error)

+ type S3SDKClient interface

+ CompleteMultipartUpload func(input *s3.CompleteMultipartUploadInput) (*s3.CompleteMultipartUploadOutput, error)

+ CreateMultipartUpload func(*s3.CreateMultipartUploadInput) (*s3.CreateMultipartUploadOutput, error)

+ GetObject func(input *s3.GetObjectInput) (*s3.GetObjectOutput, error)

+ ListMultipartUploads func(*s3.ListMultipartUploadsInput) (*s3.ListMultipartUploadsOutput, error)

+ ListObjectsV2 func(input *s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

+ ListParts func(*s3.ListPartsInput) (*s3.ListPartsOutput, error)

+ UploadPart func(*s3.UploadPartInput) (*s3.UploadPartOutput, error)

+ type UploadRequest struct

+ ChunkNumber int64

+ FileName string

+ TotalChunks int

+ Type string

+ UploadKey string

Feb 4, 2020

Changes in this version

+ const MsgHealthy

+ const ServiceName

+ type AmzClient interface

+ GetBucketReader func(bucketName string, path string) (io.ReadCloser, error)

+ type AmzClientImpl struct

+ func (amzCli *AmzClientImpl) GetBucketReader(bucketName string, path string) (io.ReadCloser, error)

+ type ErrBucketDoesNotExist struct

+ BucketName string

+ func (e *ErrBucketDoesNotExist) Error() string

+ type S3 struct

+ BucketName string

+ func New(region string, bucketName string) (*S3, error)

+ func NewWithClient(client AmzClient, bucketName string) *S3

+ func (s3 *S3) Checker(ctx context.Context, state *health.CheckState) error

+ func (s3 *S3) Get(rawURL string) (io.ReadCloser, error)

+ type URL struct

+ func NewURL(rawURL string) (*URL, error)

+ func (url *URL) BucketName() string

+ func (url *URL) Path() string