s3

Documentation

Index

• func NewS3Client(ctx context.Context, cfg *config.S3Config) (*s3.Client, error)
• type FolderRepositoryRepository
  • func NewFolderRepositoryRepository(client *s3.Client, bucket string) *FolderRepositoryRepository
  • func (f FolderRepositoryRepository) CreateConfig(ctx context.Context, repositoryPath string, c *repository.Config) error
  • func (f FolderRepositoryRepository) CreateFolder(ctx context.Context, _ string) error
  • func (f FolderRepositoryRepository) Exists(ctx context.Context, repositoryPath string) (bool, error)
  • func (f FolderRepositoryRepository) GetConfig(ctx context.Context, repositoryPath string) (*repository.Config, error)
• type ManifestRepository
  • func NewManifestRepository(client *s3.Client, bucket, repositoryPath string) *ManifestRepository
  • func (r ManifestRepository) Get(ctx context.Context, snapshotID string) (*snapshot.Manifest, error)
  • func (r ManifestRepository) List(ctx context.Context) ([]snapshot.Manifest, error)
  • func (r ManifestRepository) Save(ctx context.Context, m *snapshot.Manifest) error
• type ObjectRepository
  • func NewObjectRepository(client *s3.Client, bucket, repositoryPath string) *ObjectRepository
  • func (o ObjectRepository) AbortRekey(ctx context.Context, generation uint64) error
  • func (o ObjectRepository) AlreadyExists(ctx context.Context, hash string, symmetricKey []byte, generation uint64) (bool, error)
  • func (o ObjectRepository) DeleteEncryptedGeneration(ctx context.Context, generation uint64) error
  • func (o ObjectRepository) ListEncryptedObjects(ctx context.Context, generation uint64) ([]string, error)
  • func (o ObjectRepository) ReadEncryptedObject(ctx context.Context, hash string, generation uint64, key []byte) (io.ReadCloser, error)
  • func (o ObjectRepository) ReadObject(ctx context.Context, hash string, symmetricKey []byte, generation uint64) (io.ReadCloser, error)
  • func (o ObjectRepository) RestoreObject(ctx context.Context, comp *repository.Compression, obj *snapshot.File, ...) error
  • func (o ObjectRepository) Save(ctx context.Context, filePath, hash string, comp *repository.Compression, ...) error
  • func (o ObjectRepository) SaveChunk(ctx context.Context, filePath, hash string, offset, size int64, ...) error
  • func (o ObjectRepository) SaveRekeyedObject(ctx context.Context, hash string, source io.Reader, generation uint64, ...) error
• type Storage
  • func ParseS3URL(rawURL string) (storage *Storage, err error)

Functions

func NewS3Client

func NewS3Client(
	ctx context.Context,
	cfg *config.S3Config,
) (*s3.Client, error)

Types

type FolderRepositoryRepository

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

func NewFolderRepositoryRepository

func NewFolderRepositoryRepository(client *s3.Client, bucket string) *FolderRepositoryRepository

func (FolderRepositoryRepository) CreateConfig

func (f FolderRepositoryRepository) CreateConfig(ctx context.Context, repositoryPath string, c *repository.Config) error

func (FolderRepositoryRepository) CreateFolder

func (f FolderRepositoryRepository) CreateFolder(ctx context.Context, _ string) error

func (FolderRepositoryRepository) Exists

func (f FolderRepositoryRepository) Exists(ctx context.Context, repositoryPath string) (bool, error)

func (FolderRepositoryRepository) GetConfig

func (f FolderRepositoryRepository) GetConfig(ctx context.Context, repositoryPath string) (*repository.Config, error)

type ManifestRepository

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

func NewManifestRepository

func NewManifestRepository(client *s3.Client, bucket, repositoryPath string) *ManifestRepository

func (ManifestRepository) Get

func (r ManifestRepository) Get(ctx context.Context, snapshotID string) (*snapshot.Manifest, error)

func (ManifestRepository) List

func (r ManifestRepository) List(ctx context.Context) ([]snapshot.Manifest, error)

func (ManifestRepository) Save

func (r ManifestRepository) Save(ctx context.Context, m *snapshot.Manifest) error

type ObjectRepository

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

func NewObjectRepository

func NewObjectRepository(client *s3.Client, bucket, repositoryPath string) *ObjectRepository

func (ObjectRepository) AbortRekey

func (o ObjectRepository) AbortRekey(ctx context.Context, generation uint64) error

func (ObjectRepository) AlreadyExists

func (o ObjectRepository) AlreadyExists(ctx context.Context, hash string, symmetricKey []byte, generation uint64) (bool, error)

func (ObjectRepository) DeleteEncryptedGeneration

func (o ObjectRepository) DeleteEncryptedGeneration(ctx context.Context, generation uint64) error

func (ObjectRepository) ListEncryptedObjects

func (o ObjectRepository) ListEncryptedObjects(ctx context.Context, generation uint64) ([]string, error)

func (ObjectRepository) ReadEncryptedObject

func (o ObjectRepository) ReadEncryptedObject(ctx context.Context, hash string, generation uint64, key []byte) (io.ReadCloser, error)

func (ObjectRepository) ReadObject

func (o ObjectRepository) ReadObject(ctx context.Context, hash string, symmetricKey []byte, generation uint64) (io.ReadCloser, error)

func (ObjectRepository) RestoreObject

func (o ObjectRepository) RestoreObject(ctx context.Context, comp *repository.Compression, obj *snapshot.File, symmetricKey []byte, generation uint64) error

func (ObjectRepository) Save

func (o ObjectRepository) Save(ctx context.Context, filePath, hash string, comp *repository.Compression, symmetricKey []byte, generation uint64) error

func (ObjectRepository) SaveChunk

func (o ObjectRepository) SaveChunk(ctx context.Context, filePath, hash string, offset, size int64, comp *repository.Compression, key []byte, generation uint64) error

func (ObjectRepository) SaveRekeyedObject

func (o ObjectRepository) SaveRekeyedObject(ctx context.Context, hash string, source io.Reader, generation uint64, key []byte) error

type Storage

type Storage struct {
	Bucket, Prefix string
}

func ParseS3URL

func ParseS3URL(rawURL string) (storage *Storage, err error)