status

package

v0.4.7 Latest Latest Go to latest Published: Nov 30, 2017 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func GetBackupsInfo(cli *clientv3.Client) map[string]*statuspb.BackupInfo

func GetNodesInfo(cli *clientv3.Client) *statuspb.NodeInfoMap

func RemoveBackupInfo(cli *clientv3.Client, key string) error

func StoreFullBackupInfo(cli *clientv3.Client, key string, info *statuspb.FullBackupInfo) error

func StoreIncBackupInfo(cli *clientv3.Client, key string, info *statuspb.IncBackupInfo) error

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

func NewStatusRecorder(
	client *clientv3.Client, storeDir string, name string, cfg *base.ServerConfig,
) *StatusRecorder

func (sr *StatusRecorder) WriteStatus(ctx context.Context) error

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

func NewWeeklyBackupAggregator() *WeeklyBackupAggregator

NewWeeklyBackupAggregator returns new instance.

func (a *WeeklyBackupAggregator) AddFullBackupInfo(i *statuspb.FullBackupInfo) error

AddFullBackupInfo adds full backup information to aggregator.

func (a *WeeklyBackupAggregator) BestStartTime(w time.Weekday) (int, int)

func (a *WeeklyBackupAggregator) Switch()

Switch replace next with new weekly information store.

Path	Synopsis
statuspb Package statuspb is a generated protocol buffer package.	Package statuspb is a generated protocol buffer package.