s3utils

Documentation

Index

• func NewS3Session(serviceKey string) (*s3.S3, error)
• func SplitS3Url(url string) (string, string, error)
• type S3Object
  • func NewS3Object(bucket string, objectKey string, serviceKey string) (S3Object, error)
  • func NewS3ObjectFromS3Url(url string, serviceKey string) (S3Object, error)
  • func (s *S3Object) Bytes() []byte
  • func (s *S3Object) Copy(target S3Object) error
  • func (s *S3Object) Delete() error
  • func (s *S3Object) DownloadBytes() ([]byte, error)
  • func (s *S3Object) DownloadReader() (io.ReadCloser, error)
  • func (s *S3Object) Filename() string
  • func (s *S3Object) MultipartCopy(target S3Object) error
  • func (s *S3Object) Rename(targetObjectKey string) error
  • func (s *S3Object) S3Url() (string, error)
  • func (s *S3Object) String() string
  • func (s *S3Object) UploadBytes(uploadBytes []byte) error
  • func (s *S3Object) UploadReader(reader io.ReadCloser) error
  • func (s *S3Object) WriteToHttpResponse(w http.ResponseWriter) error
• type S3ObjectPrefix
  • func NewS3ObjectPrefix(bucket string, prefix string, serviceKey string) (S3ObjectPrefix, error)
  • func NewS3ObjectPrefixFromS3Url(url string, serviceKey string) (S3ObjectPrefix, error)
  • func (s *S3ObjectPrefix) Bytes() []byte
  • func (s *S3ObjectPrefix) DeleteObjects() error
  • func (s *S3ObjectPrefix) GetTotalSize() (int64, int64, error)
  • func (s *S3ObjectPrefix) ListObjects() ([]S3Object, error)
  • func (s *S3ObjectPrefix) ListObjectsAfterTime(afterTime time.Time) ([]S3Object, error)
  • func (s *S3ObjectPrefix) ListObjectsBeforeTime(beforeTime time.Time) ([]S3Object, error)
  • func (s *S3ObjectPrefix) ListObjectsBetweenTimes(afterTime time.Time, beforeTime time.Time) ([]S3Object, error)
  • func (s *S3ObjectPrefix) S3Url() (string, error)
  • func (s *S3ObjectPrefix) String() string

Functions

func NewS3Session

func NewS3Session(serviceKey string) (*s3.S3, error)

TODO make a version that can be passed as an encrypted hash

func SplitS3Url

func SplitS3Url(url string) (string, string, error)

TODO this is a convenience function TBD if still needed

Types

type S3Object

type S3Object struct {
	ServiceKey   string    `json:"-"` // Should be private for output
	Region       string    `json:"region"`
	Bucket       string    `json:"bucket"`
	ObjectKey    string    `json:"objectKey"`
	Exists       bool      `json:"exists"`
	ETag         string    `json:"etag"`
	Size         int64     `json:"size"`
	StorageClass string    `json:"storageClass"`
	LastModified time.Time `json:"lastModified"`
}

func NewS3Object

func NewS3Object(bucket string, objectKey string, serviceKey string) (S3Object, error)

func NewS3ObjectFromS3Url

func NewS3ObjectFromS3Url(url string, serviceKey string) (S3Object, error)

func (*S3Object) Bytes

func (s *S3Object) Bytes() []byte

func (*S3Object) Copy

func (s *S3Object) Copy(target S3Object) error

func (*S3Object) Delete

func (s *S3Object) Delete() error

func (*S3Object) DownloadBytes

func (s *S3Object) DownloadBytes() ([]byte, error)

func (*S3Object) DownloadReader

func (s *S3Object) DownloadReader() (io.ReadCloser, error)

func (*S3Object) Filename

func (s *S3Object) Filename() string

func (*S3Object) MultipartCopy

func (s *S3Object) MultipartCopy(target S3Object) error

func (*S3Object) Rename

func (s *S3Object) Rename(targetObjectKey string) error

func (*S3Object) S3Url

func (s *S3Object) S3Url() (string, error)

func (*S3Object) String

func (s *S3Object) String() string

func (*S3Object) UploadBytes

func (s *S3Object) UploadBytes(uploadBytes []byte) error

func (*S3Object) UploadReader

func (s *S3Object) UploadReader(reader io.ReadCloser) error

func (*S3Object) WriteToHttpResponse

func (s *S3Object) WriteToHttpResponse(w http.ResponseWriter) error

type S3ObjectPrefix

type S3ObjectPrefix struct {
	ServiceKey string `json:"-"` // Should be private for output
	Bucket     string `json:"bucket"`
	Prefix     string `json:"prefix"`
}

func NewS3ObjectPrefix

func NewS3ObjectPrefix(bucket string, prefix string, serviceKey string) (S3ObjectPrefix, error)

func NewS3ObjectPrefixFromS3Url

func NewS3ObjectPrefixFromS3Url(url string, serviceKey string) (S3ObjectPrefix, error)

func (*S3ObjectPrefix) Bytes

func (s *S3ObjectPrefix) Bytes() []byte

func (*S3ObjectPrefix) DeleteObjects

func (s *S3ObjectPrefix) DeleteObjects() error

func (*S3ObjectPrefix) GetTotalSize

func (s *S3ObjectPrefix) GetTotalSize() (int64, int64, error)

func (*S3ObjectPrefix) ListObjects

func (s *S3ObjectPrefix) ListObjects() ([]S3Object, error)

func (*S3ObjectPrefix) ListObjectsAfterTime

func (s *S3ObjectPrefix) ListObjectsAfterTime(afterTime time.Time) ([]S3Object, error)

func (*S3ObjectPrefix) ListObjectsBeforeTime

func (s *S3ObjectPrefix) ListObjectsBeforeTime(beforeTime time.Time) ([]S3Object, error)

func (*S3ObjectPrefix) ListObjectsBetweenTimes

func (s *S3ObjectPrefix) ListObjectsBetweenTimes(afterTime time.Time, beforeTime time.Time) ([]S3Object, error)

func (*S3ObjectPrefix) S3Url

func (s *S3ObjectPrefix) S3Url() (string, error)

func (*S3ObjectPrefix) String

func (s *S3ObjectPrefix) String() string