archive

Documentation

Index

• func NewBackupRedisMetaConstructor(ctx context.Context, folder storage.Folder, permanent bool) internal.MetaConstructor
• func RedisModelToTimedBackup(backups []Backup) []internal.TimedBackup
• type Backup
  • func SplitRedisBackups(backups []Backup, purgeBackups, retainBackups map[string]bool) (purge, retain []Backup)
  • func (b Backup) IsPermanent() bool
  • func (b Backup) Name() string
  • func (b Backup) StartTime() time.Time
• type BackupMeta
• type RedisMetaConstructor
  • func (m *RedisMetaConstructor) Finalize(backupName string) error
  • func (m *RedisMetaConstructor) Init() error
  • func (m *RedisMetaConstructor) MetaInfo() interface{}
• type StorageUploader
  • func NewRedisStorageUploader(upl *internal.Uploader) *StorageUploader
  • func (su *StorageUploader) UploadBackup(stream io.Reader, cmd internal.ErrWaiter, ...) error

Functions

func NewBackupRedisMetaConstructor

func NewBackupRedisMetaConstructor(ctx context.Context, folder storage.Folder, permanent bool) internal.MetaConstructor

func RedisModelToTimedBackup

func RedisModelToTimedBackup(backups []Backup) []internal.TimedBackup

Types

type Backup

type Backup struct {
	BackupName      string      `json:"BackupName,omitempty"`
	StartLocalTime  time.Time   `json:"StartLocalTime,omitempty"`
	FinishLocalTime time.Time   `json:"FinishLocalTime,omitempty"`
	UserData        interface{} `json:"UserData,omitempty"`
	Permanent       bool        `json:"Permanent"`
	DataSize        int64       `json:"DataSize,omitempty"`
	BackupSize      int64       `json:"BackupSize,omitempty"`
}

Backup represents backup sentinel data

func SplitRedisBackups

func SplitRedisBackups(backups []Backup, purgeBackups, retainBackups map[string]bool) (purge, retain []Backup)

func (Backup) IsPermanent

func (b Backup) IsPermanent() bool

func (Backup) Name

func (b Backup) Name() string

func (Backup) StartTime

func (b Backup) StartTime() time.Time

type BackupMeta

type BackupMeta struct {
	DataSize       int64
	CompressedSize int64
	Permanent      bool
	User           interface{}
	StartTime      time.Time
	FinishTime     time.Time
}

BackupMeta stores the data needed to create a Backup json object

type RedisMetaConstructor

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

func (*RedisMetaConstructor) Finalize

func (m *RedisMetaConstructor) Finalize(backupName string) error

func (*RedisMetaConstructor) Init

func (m *RedisMetaConstructor) Init() error

Init - required for internal.MetaConstructor

func (*RedisMetaConstructor) MetaInfo

func (m *RedisMetaConstructor) MetaInfo() interface{}

type StorageUploader

type StorageUploader struct {
	internal.UploaderProvider
}

func NewRedisStorageUploader

func NewRedisStorageUploader(upl *internal.Uploader) *StorageUploader

NewRedisStorageUploader builds redis uploader, that also push metadata

func (*StorageUploader) UploadBackup

func (su *StorageUploader) UploadBackup(stream io.Reader, cmd internal.ErrWaiter, metaConstructor internal.MetaConstructor) error

UploadBackup compresses a stream and uploads it, and uploads meta info