mongo

package

v0.0.0-...-e89a0ad Latest Latest Go to latest Published: Mar 18, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apecloud/dataprotection-wal-g

Links

Open Source Insights

Documentation ¶

Index ¶

func HandleBackupDelete(backupName string, downloader archive.Downloader, purger archive.Purger, ...) error
func HandleBackupPush(uploader archive.Uploader, metaConstructor internal.MetaConstructor, ...) error
func HandleBackupShow(backupFolder storage.Folder, backupName string, output io.Writer, pretty bool) (err error)
func HandleBackupsPurge(backupTimes []internal.BackupTime, downloader archive.Downloader, ...) (purge, retain []*models.Backup, err error)
func HandleBinaryBackupPush(ctx context.Context, permanent bool, appName string) error
func HandleBinaryFetchPush(ctx context.Context, ...) error
func HandleDetailedBackupList(folder storage.Folder, output io.Writer, pretty, json bool) error
func HandleOplogPurge(downloader archive.Downloader, purger archive.Purger, retainAfter *time.Time, ...) error
func HandleOplogPush(ctx context.Context, fetcher stages.Fetcher, applier stages.Applier) error
func HandleOplogReplay(ctx context.Context, since, until models.Timestamp, ...) error
func HandlePurge(downloader archive.Downloader, purger archive.Purger, setters ...PurgeOption) error
func LoadBackups(downloader archive.Downloader) ([]*models.Backup, error)
type BackupDetail
- func NewBackupDetail(backupTime internal.BackupTime, sentinel *models.Backup) *BackupDetail
type PurgeOption
type PurgeSettings

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func HandleBackupDelete ¶

func HandleBackupDelete(backupName string, downloader archive.Downloader, purger archive.Purger, dryRun bool) error

HandleBackupDelete deletes backup.

func HandleBackupPush ¶

func HandleBackupPush(uploader archive.Uploader,
	metaConstructor internal.MetaConstructor,
	backupCmd *exec.Cmd) error

HandleBackupPush starts backup procedure.

func HandleBackupShow ¶

func HandleBackupShow(backupFolder storage.Folder, backupName string, output io.Writer, pretty bool) (err error)

HandleBackupShow prints sentinel contents.

func HandleBackupsPurge ¶

func HandleBackupsPurge(backupTimes []internal.BackupTime,
	downloader archive.Downloader,
	purger archive.Purger,
	opts PurgeSettings) (purge, retain []*models.Backup, err error)

HandleBackupsPurge delete backups according to settings

func HandleBinaryBackupPush ¶

func HandleBinaryBackupPush(ctx context.Context, permanent bool, appName string) error

func HandleBinaryFetchPush ¶

func HandleBinaryFetchPush(ctx context.Context, mongodConfigPath, minimalConfigPath, backupName, restoreMongodVersion,
	rsName, rsMembers string,
) error

func HandleDetailedBackupList ¶

func HandleDetailedBackupList(folder storage.Folder, output io.Writer, pretty, json bool) error

func HandleOplogPurge ¶

func HandleOplogPurge(downloader archive.Downloader, purger archive.Purger, retainAfter *time.Time, dryRun bool) error

HandleOplogPurge delete oplog archives according to settings

func HandleOplogPush ¶

func HandleOplogPush(ctx context.Context, fetcher stages.Fetcher, applier stages.Applier) error

HandleOplogPush starts oplog archiving process: fetch, validate, upload to storage.

func HandleOplogReplay ¶

func HandleOplogReplay(ctx context.Context,
	since,
	until models.Timestamp,
	fetcher stages.BetweenFetcher,
	applier stages.Applier) error

HandleOplogReplay starts oplog replay process: download from storage and apply to mongodb

func HandlePurge ¶

func HandlePurge(downloader archive.Downloader, purger archive.Purger, setters ...PurgeOption) error

HandlePurge delete backups and oplog archives according to settings

func LoadBackups ¶

func LoadBackups(downloader archive.Downloader) ([]*models.Backup, error)

Types ¶

type BackupDetail ¶

type BackupDetail struct {
	models.Backup
	ModifyTime time.Time `json:"modify_time"`
}

func NewBackupDetail ¶

func NewBackupDetail(backupTime internal.BackupTime, sentinel *models.Backup) *BackupDetail

type PurgeOption ¶

type PurgeOption func(*PurgeSettings)

func PurgeDryRun ¶

func PurgeDryRun(dryRun bool) PurgeOption

PurgeDryRun ...

func PurgeGarbage ¶

func PurgeGarbage(purgeGarbage bool) PurgeOption

PurgeGarbage ...

func PurgeOplog ¶

func PurgeOplog(purgeOplog bool) PurgeOption

PurgeOplog ...

func PurgeRetainAfter ¶

func PurgeRetainAfter(retainAfter time.Time) PurgeOption

PurgeRetainAfter ...

func PurgeRetainCount ¶

func PurgeRetainCount(retainCount int) PurgeOption

PurgeRetainCount ...

type PurgeSettings ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
archive
mocks
binary
client
mocks
common
discovery
models
oplog
stages
buffer
mocks
stats

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL