s3

package

v0.2.0 Latest Latest Go to latest Published: Dec 11, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func Backup(source io.Reader, s3Conf config.S3ClientConfig, cypherKey []byte) error

func Prune(s3Conf config.S3ClientConfig, expiry time.Duration, minCount int64) error

func PruneBackupEntry(cli *minio.Client, bucket string, namingConv NamingConvention, entry BackupEntry) error

func Restore(s3Conf config.S3ClientConfig, timestamp string) (io.Reader, []byte, error)

func RotateKey(s3Conf config.S3ClientConfig, conv ConvertKeyFn) error

type BackupEntries struct {
	Entries   map[time.Time]BackupEntry
	LastEntry *BackupEntry
}

func ListBackups(cli *minio.Client, bucket string, nameConv NamingConvention) (BackupEntries, error)

func (entries *BackupEntries) GetDeletable(cutoff time.Time, minCount int64) []BackupEntry

type BackupEntry struct {
	Timestamp time.Time
	Encrypted bool
	DumpFound bool
}

type ConvertKeyFn func([]byte) ([]byte, error)

type NamingConvention struct {
	Prefix string
	// contains filtered or unexported fields
}

func NewNamingConvention(prefix string) NamingConvention

func (conv *NamingConvention) GetObjectInfo(objName string) (ObjectInfo, error)

func (conv *NamingConvention) GetObjectNames(timestamp time.Time) (string, string)

type ObjectInfo struct {
	Timestamp time.Time
	Type      ObjectType
}

type ObjectType int

const (
	OBJ_TYPE_DUMP ObjectType = iota
	OBJ_TYPE_KEY
)