gcs

Documentation

Index

• func BuildBackupsToComplete(gcpServiceAccountKey string, config map[string]Config) (map[string]BackupToComplete, error)
• func CreateBucketsForBackupArtifact(gcpSerivceAccountKey string, bucketBackups map[string]BucketBackup) (map[string]BucketBackup, error)
• func MarkSameBackupsToComplete(backupsToComplete map[string]BackupToComplete) map[string]BackupToComplete
• func ParseConfig(configFilePath string) (map[string]Config, error)
• func ReadGCPServiceAccountKey(gcpConfigFilePath string) (string, error)
• type Artifact
  • func NewArtifact(path string) Artifact
  • func (a Artifact) Read() (map[string]BucketBackup, error)
  • func (a Artifact) Write(backups map[string]BucketBackup) error
• type BackupArtifact
• type BackupToComplete
• type Backuper
  • func NewBackuper(backupsToComplete map[string]BackupToComplete) Backuper
  • func (b *Backuper) Backup() (map[string]BucketBackup, error)
• type Blob
  • func NewBlob(name string) Blob
  • func (b Blob) Name() string
  • func (b Blob) Resource() string
• type Bucket
• type BucketBackup
• type BucketPair
• type Config
• type ExecutableBackup
  • func (e ExecutableBackup) Execute() error
• type Restorer
  • func NewRestorer(backupsToComplete map[string]BackupToComplete) Restorer
  • func (r Restorer) Restore(bucketBackups map[string]BucketBackup) error
• type SDKBucket
  • func NewSDKBucket(serviceAccountKeyJson string, name string) (SDKBucket, error)
  • func (b SDKBucket) CopyBlobToBucket(dstBucket Bucket, srcBlob, dstBlob string) error
  • func (b SDKBucket) CopyBlobsToBucket(dstBucket Bucket, srcPrefix string) error
  • func (b SDKBucket) DeleteBlob(blob string) error
  • func (b SDKBucket) ListBlobs(prefix string) ([]Blob, error)
  • func (b SDKBucket) Name() string

Functions

func BuildBackupsToComplete

func BuildBackupsToComplete(gcpServiceAccountKey string, config map[string]Config) (map[string]BackupToComplete, error)

func CreateBucketsForBackupArtifact

func CreateBucketsForBackupArtifact(gcpSerivceAccountKey string, bucketBackups map[string]BucketBackup) (map[string]BucketBackup, error)

func MarkSameBackupsToComplete

func MarkSameBackupsToComplete(backupsToComplete map[string]BackupToComplete) map[string]BackupToComplete

func ParseConfig

func ParseConfig(configFilePath string) (map[string]Config, error)

func ReadGCPServiceAccountKey

func ReadGCPServiceAccountKey(gcpConfigFilePath string) (string, error)

Types

type Artifact

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

func NewArtifact

func NewArtifact(path string) Artifact

func (Artifact) Read

func (a Artifact) Read() (map[string]BucketBackup, error)

func (Artifact) Write

func (a Artifact) Write(backups map[string]BucketBackup) error

type BackupArtifact

type BackupArtifact interface {
	Write(backups map[string]BucketBackup) error
	Read() (map[string]BucketBackup, error)
}

type BackupToComplete

type BackupToComplete struct {
	BucketPair     BucketPair
	SameAsBucketID string
}

type Backuper

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

func NewBackuper

func NewBackuper(backupsToComplete map[string]BackupToComplete) Backuper

func (*Backuper) Backup

func (b *Backuper) Backup() (map[string]BucketBackup, error)

type Blob

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

func NewBlob

func NewBlob(name string) Blob

func (Blob) Name

func (b Blob) Name() string

func (Blob) Resource

func (b Blob) Resource() string

type Bucket

type Bucket interface {
	Name() string
	ListBlobs(prefix string) ([]Blob, error)
	CopyBlobToBucket(bucket Bucket, src string, dst string) error
	CopyBlobsToBucket(bucket Bucket, src string) error
	DeleteBlob(name string) error
}

type BucketBackup

type BucketBackup struct {
	BucketName   string `json:"bucket_name"`
	Bucket       Bucket `json:"-"`
	Path         string `json:"path"`
	SameBucketAs string `json:"same_bucket_as,omitempty"`
}

type BucketPair

type BucketPair struct {
	LiveBucket        Bucket
	BackupBucket      Bucket
	ExecutionStrategy executor.Executor
}

type Config

type Config struct {
	BucketName       string `json:"bucket_name"`
	BackupBucketName string `json:"backup_bucket_name"`
}

type ExecutableBackup

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

func (ExecutableBackup) Execute

func (e ExecutableBackup) Execute() error

type Restorer

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

func NewRestorer

func NewRestorer(backupsToComplete map[string]BackupToComplete) Restorer

func (Restorer) Restore

func (r Restorer) Restore(bucketBackups map[string]BucketBackup) error

type SDKBucket

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

func NewSDKBucket

func NewSDKBucket(serviceAccountKeyJson string, name string) (SDKBucket, error)

func (SDKBucket) CopyBlobToBucket

func (b SDKBucket) CopyBlobToBucket(dstBucket Bucket, srcBlob, dstBlob string) error

func (SDKBucket) CopyBlobsToBucket

func (b SDKBucket) CopyBlobsToBucket(dstBucket Bucket, srcPrefix string) error

func (SDKBucket) DeleteBlob

func (b SDKBucket) DeleteBlob(blob string) error

func (SDKBucket) ListBlobs

func (b SDKBucket) ListBlobs(prefix string) ([]Blob, error)

func (SDKBucket) Name

func (b SDKBucket) Name() string