s3

Documentation

Index

• func LoadS3StorageInfoFromDatabase(storageID []byte, identifier string, rootPath string) storage_base.Storage
• type ETagCalculator
  • func CreateETagCalculator() *ETagCalculator
• type ETagResult
• type GbCustomRetryer
  • func (r GbCustomRetryer) ShouldRetry(req *request.Request) bool
• type S3
  • func (remote *S3) BeginBlobUpload(blobID []byte) storage_base.StorageUpload
  • func (remote *S3) BeginDatabaseUpload(filename string) storage_base.StorageUpload
  • func (remote *S3) DownloadSection(path string, offset int64, length int64) io.ReadCloser
  • func (remote *S3) GetID() []byte
  • func (remote *S3) ListBlobs() []storage_base.UploadedBlob
  • func (remote *S3) Metadata(path string) (string, int64)
  • func (remote *S3) String() string
• type S3DatabaseIdentifier

Functions

func LoadS3StorageInfoFromDatabase

func LoadS3StorageInfoFromDatabase(storageID []byte, identifier string, rootPath string) storage_base.Storage

Types

type ETagCalculator

type ETagCalculator struct {
	Writer *io.PipeWriter
	Result chan ETagResult
}

func CreateETagCalculator

func CreateETagCalculator() *ETagCalculator

type ETagResult

type ETagResult struct {
	ETag string
	Size int64
}

type GbCustomRetryer

type GbCustomRetryer struct {
	client.DefaultRetryer
}

func (GbCustomRetryer) ShouldRetry

func (r GbCustomRetryer) ShouldRetry(req *request.Request) bool

type S3

type S3 struct {
	StorageID []byte
	RootPath  string
	Data      S3DatabaseIdentifier
	// contains filtered or unexported fields
}

func (*S3) BeginBlobUpload

func (remote *S3) BeginBlobUpload(blobID []byte) storage_base.StorageUpload

func (*S3) BeginDatabaseUpload

func (remote *S3) BeginDatabaseUpload(filename string) storage_base.StorageUpload

func (*S3) DownloadSection

func (remote *S3) DownloadSection(path string, offset int64, length int64) io.ReadCloser

func (*S3) GetID

func (remote *S3) GetID() []byte

func (*S3) ListBlobs

func (remote *S3) ListBlobs() []storage_base.UploadedBlob

func (*S3) Metadata

func (remote *S3) Metadata(path string) (string, int64)

func (*S3) String

func (remote *S3) String() string

type S3DatabaseIdentifier

type S3DatabaseIdentifier struct {
	Bucket    string `json:"bucket"`
	KeyID     string `json:"aws_access_key_id"`
	SecretKey string `json:"aws_secret_access_key"`
	Region    string `json:"aws_region"`
	Endpoint  string `json:"endpoint"`
}