s3_backend

Documentation

Index

• type S3BackendFactory
  • func (factory *S3BackendFactory) BuildStorage(configuration backend.StringProperties, configPrefix string, id string) (backend.BackendStorage, error)
  • func (factory *S3BackendFactory) StorageType() backend.StorageType
• type S3BackendStorage
  • func (s *S3BackendStorage) CopyFile(f *os.File, attributes map[string]string, ...) (key string, size int64, err error)
  • func (s *S3BackendStorage) DeleteFile(key string) (err error)
  • func (s *S3BackendStorage) DownloadFile(fileName string, key string, ...) (size int64, err error)
  • func (s *S3BackendStorage) NewStorageFile(key string, tierInfo *volume_server_pb.VolumeInfo) backend.BackendStorageFile
  • func (s *S3BackendStorage) ToProperties() map[string]string
• type S3BackendStorageFile
  • func (s3backendStorageFile S3BackendStorageFile) Close() error
  • func (s3backendStorageFile S3BackendStorageFile) GetStat() (datSize int64, modTime time.Time, err error)
  • func (s3backendStorageFile S3BackendStorageFile) Name() string
  • func (s3backendStorageFile S3BackendStorageFile) ReadAt(p []byte, off int64) (n int, err error)
  • func (s3backendStorageFile S3BackendStorageFile) Sync() error
  • func (s3backendStorageFile S3BackendStorageFile) Truncate(off int64) error
  • func (s3backendStorageFile S3BackendStorageFile) WriteAt(p []byte, off int64) (n int, err error)

Types

type S3BackendFactory

type S3BackendFactory struct {
}

func (*S3BackendFactory) BuildStorage

func (factory *S3BackendFactory) BuildStorage(configuration backend.StringProperties, configPrefix string, id string) (backend.BackendStorage, error)

func (*S3BackendFactory) StorageType

func (factory *S3BackendFactory) StorageType() backend.StorageType

type S3BackendStorage

type S3BackendStorage struct {
	// contains filtered or unexported fields
}

func (*S3BackendStorage) CopyFile

func (s *S3BackendStorage) CopyFile(f *os.File, attributes map[string]string, fn func(progressed int64, percentage float32) error) (key string, size int64, err error)

func (*S3BackendStorage) DeleteFile

func (s *S3BackendStorage) DeleteFile(key string) (err error)

func (*S3BackendStorage) DownloadFile

func (s *S3BackendStorage) DownloadFile(fileName string, key string, fn func(progressed int64, percentage float32) error) (size int64, err error)

func (*S3BackendStorage) NewStorageFile

func (s *S3BackendStorage) NewStorageFile(key string, tierInfo *volume_server_pb.VolumeInfo) backend.BackendStorageFile

func (*S3BackendStorage) ToProperties

func (s *S3BackendStorage) ToProperties() map[string]string

type S3BackendStorageFile

type S3BackendStorageFile struct {
	// contains filtered or unexported fields
}

func (S3BackendStorageFile) Close

func (s3backendStorageFile S3BackendStorageFile) Close() error

func (S3BackendStorageFile) GetStat

func (s3backendStorageFile S3BackendStorageFile) GetStat() (datSize int64, modTime time.Time, err error)

func (S3BackendStorageFile) Name

func (s3backendStorageFile S3BackendStorageFile) Name() string

func (S3BackendStorageFile) ReadAt

func (s3backendStorageFile S3BackendStorageFile) ReadAt(p []byte, off int64) (n int, err error)

func (S3BackendStorageFile) Sync

func (s3backendStorageFile S3BackendStorageFile) Sync() error

func (S3BackendStorageFile) Truncate

func (s3backendStorageFile S3BackendStorageFile) Truncate(off int64) error

func (S3BackendStorageFile) WriteAt

func (s3backendStorageFile S3BackendStorageFile) WriteAt(p []byte, off int64) (n int, err error)