backup

Documentation

Index

• Constants
• func Backup(ctx context.Context, bs *tree.BackupStart, cfg *Config) error
• func BackupData(ctx context.Context, srcFs, dstFs fileservice.FileService, dir string, ...) error
• func CopyDir(ctx context.Context, srcFs, dstFs fileservice.FileService, dir string, ...) ([]*taeFile, error)
• func CopyFile(ctx context.Context, srcFs, dstFs fileservice.FileService, name, dstDir string) ([]byte, error)
• func CopyFileWithRetry(ctx context.Context, srcFs, dstFs fileservice.FileService, name, dstDir string) ([]byte, error)
• func SaveLaunchConfigPath(typ string, paths []string)
• func ToCsvLine2(s [][]string) (string, error)
• type Config
• type Meta
  • func (m *Meta) CsvString() []string
  • func (m *Meta) String() string
• type MetaType
  • func (t MetaType) String() string
• type Metas
  • func NewMetas() *Metas
  • func (m *Metas) Append(meta *Meta)
  • func (m *Metas) AppendBuildinfo(info string)
  • func (m *Metas) AppendLaunchconfig(subTyp, file string)
  • func (m *Metas) AppendVersion(version string)
  • func (m *Metas) CsvString() [][]string
  • func (m *Metas) String() string

Constants

const (
	TypePos              = 0
	SubTypePos           = 1
	FileNameOrDirNamePos = 2
)

Format :type,subtype,filename or dirname

const (
	CnConfig     = "cn"
	DnConfig     = "dn"
	LogConfig    = "log"
	ProxyConfig  = "proxy"
	LaunchConfig = "launch"
)

const (
	HakeeperFile = "hk_data"
)

const (
	Version = "0823"
)

Functions

func Backup

func Backup(ctx context.Context, bs *tree.BackupStart, cfg *Config) error

Backup Note: ctx needs to support cancel. The user can cancel the backup task by canceling the ctx.

func BackupData

func BackupData(ctx context.Context, srcFs, dstFs fileservice.FileService, dir string, config *Config) error

func CopyDir

func CopyDir(ctx context.Context, srcFs, dstFs fileservice.FileService, dir string, backup types.TS) ([]*taeFile, error)

func CopyFile

func CopyFile(ctx context.Context, srcFs, dstFs fileservice.FileService, name, dstDir string) ([]byte, error)

CopyFile copy file from srcFs to dstFs and return checksum of the written file.

func CopyFileWithRetry

func CopyFileWithRetry(ctx context.Context, srcFs, dstFs fileservice.FileService, name, dstDir string) ([]byte, error)

func SaveLaunchConfigPath

func SaveLaunchConfigPath(typ string, paths []string)

SaveLaunchConfigPath saves all config file paths for the standalone config

func ToCsvLine2

func ToCsvLine2(s [][]string) (string, error)

Types

type Config

type Config struct {
	// Timestamp
	Timestamp types.TS

	// For General usage
	GeneralDir fileservice.FileService

	// For locating tae's storage fs
	SharedFs fileservice.FileService

	// For tae and hakeeper
	TaeDir fileservice.FileService

	// hakeeper client
	HAkeeper logservice.CNHAKeeperClient

	Metas *Metas

	// For parallel backup
	Parallelism uint16

	BackupType string
	BackupTs   types.TS
}

type Meta

type Meta struct {
	Typ               MetaType
	SubTyp            string
	FileNameOrDirName string

	//version
	Version string

	//build info
	Buildinfo string

	//launch config
	LaunchConfigFile string
}

Meta of mo_meta same as the mo_br

func (*Meta) CsvString

func (m *Meta) CsvString() []string

func (*Meta) String

func (m *Meta) String() string

type MetaType

type MetaType int

const (
	/**
	  backup_meta | mo_meta
	    ID        |
	    Version   | Version
	    Buildinfo | Buildinfo
	              | Launchconfig
	              | Tae
	              | Hakeeper
	*/
	TypeVersion MetaType = iota
	TypeBuildinfo
	TypeLaunchconfig
)

func (MetaType) String

func (t MetaType) String() string

type Metas

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

func NewMetas

func NewMetas() *Metas

func (*Metas) Append

func (m *Metas) Append(meta *Meta)

func (*Metas) AppendBuildinfo

func (m *Metas) AppendBuildinfo(info string)

func (*Metas) AppendLaunchconfig

func (m *Metas) AppendLaunchconfig(subTyp, file string)

func (*Metas) AppendVersion

func (m *Metas) AppendVersion(version string)

func (*Metas) CsvString

func (m *Metas) CsvString() [][]string

func (*Metas) String

func (m *Metas) String() string