restore

Documentation

Index

• Constants
• func FlattenBackupMeta(backup *meta.BackupMeta) map[string]*PartInfo
• func FlattenRestoreMeta(resp *meta.RestoreMetaResp) map[string][]*nebula.HostAddr
• func GenDataPathKey(host *nebula.HostAddr, partKey string) string
• func GenPartKey(spaceId, partId string) string
• func NewPathSelectorMap(storages []*meta.ServiceInfo) map[string]*PathSelector
• func ParseAddr(addrStr string) (*nebula.HostAddr, error)
• func ParseMetaFromFile(filename string) (*meta.BackupMeta, error)
• func StringifyAddr(addr *nebula.HostAddr) string
• func UriJoin(elem ...string) (string, error)
• type Config
• type HostDir
• type NebulaHosts
  • func (h *NebulaHosts) GetMetas() []*meta.ServiceInfo
  • func (h *NebulaHosts) GetStorages() []*meta.ServiceInfo
  • func (h *NebulaHosts) LoadFrom(resp *meta.ListClusterInfoResp) error
• type PartInfo
• type PathSelector
  • func NewPathSelector(paths [][]byte) *PathSelector
  • func (p *PathSelector) EvenlyGet() string

Constants

const LocalTmpDir = "/tmp/nebula-br"

Functions

func FlattenBackupMeta

func FlattenBackupMeta(backup *meta.BackupMeta) map[string]*PartInfo

FlattenBackupMeta flatten backup meta to a map for convenience because of (spaceId + partId) can specify a unique part

func FlattenRestoreMeta

func FlattenRestoreMeta(resp *meta.RestoreMetaResp) map[string][]*nebula.HostAddr

FlattenRestoreMeta flatten meta.RestoreMetaResp to a map for convenience because of (spaceId + partId) can specify a unique part

func GenDataPathKey

func GenDataPathKey(host *nebula.HostAddr, partKey string) string

GenDataPathKey generate a unique key for data path

func GenPartKey

func GenPartKey(spaceId, partId string) string

GenPartKey generate a unique key for part

func NewPathSelectorMap

func NewPathSelectorMap(storages []*meta.ServiceInfo) map[string]*PathSelector

func ParseAddr

func ParseAddr(addrStr string) (*nebula.HostAddr, error)

func ParseMetaFromFile

func ParseMetaFromFile(filename string) (*meta.BackupMeta, error)

func StringifyAddr

func StringifyAddr(addr *nebula.HostAddr) string

func UriJoin

func UriJoin(elem ...string) (string, error)

Types

type Config

type Config struct {
	BackupName  string
	Concurrency int32
	Backend     *pb.Backend
}

type HostDir

type HostDir struct {
	Host string // ip
	Dir  string // nebula root dir
}

type NebulaHosts

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

func (*NebulaHosts) GetMetas

func (h *NebulaHosts) GetMetas() []*meta.ServiceInfo

func (*NebulaHosts) GetStorages

func (h *NebulaHosts) GetStorages() []*meta.ServiceInfo

func (*NebulaHosts) LoadFrom

func (h *NebulaHosts) LoadFrom(resp *meta.ListClusterInfoResp) error

type PartInfo

type PartInfo struct {
	SpaceID        string
	PartID         string
	HostAddr       *nebula.HostAddr
	DataPath       string
	CheckpointPath string
	CommitLogId    int64
	LastLogId      int64
}

PartInfo save a unique part's information for FlattenBackupMeta

type PathSelector

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

func NewPathSelector

func NewPathSelector(paths [][]byte) *PathSelector

func (*PathSelector) EvenlyGet

func (p *PathSelector) EvenlyGet() string