Documentation
¶
Index ¶
- type TempBackupManager
- type TempBackupManagerConfig
- type TempBackupState
- type TempBackupTransferService
- func (s *TempBackupTransferService) PostCheckpoints(ctx context.Context, req *tempbackuppb.PostCheckpointsRequest) (*tempbackuppb.PostCheckpointsResponse, error)
- func (s *TempBackupTransferService) TransferFullBackup(stream tempbackuppb.BackupTransferService_TransferFullBackupServer) error
- func (s *TempBackupTransferService) TransferIncBackup(stream tempbackuppb.BackupTransferService_TransferIncBackupServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TempBackupManager ¶
type TempBackupManager struct {
// Injected after etcd launched
EtcdCli *clientv3.Client
// contains filtered or unexported fields
}
func NewTempBackupManager ¶
func NewTempBackupManager(storage storage.BackupStorage, cfg *TempBackupManagerConfig) (*TempBackupManager, error)
func (*TempBackupManager) OpenFullBackup ¶
func (m *TempBackupManager) OpenFullBackup(db string) (*TempBackupState, error)
func (*TempBackupManager) OpenIncBackup ¶
func (m *TempBackupManager) OpenIncBackup(db string, lsn string) (*TempBackupState, error)
type TempBackupManagerConfig ¶
type TempBackupState ¶
type TempBackupState struct {
// contains filtered or unexported fields
}
func (*TempBackupState) Append ¶
func (s *TempBackupState) Append(content []byte) error
func (*TempBackupState) Close ¶
func (s *TempBackupState) Close() error
type TempBackupTransferService ¶
type TempBackupTransferService struct {
// contains filtered or unexported fields
}
func NewBackupTransferService ¶
func NewBackupTransferService(m *TempBackupManager) *TempBackupTransferService
func (*TempBackupTransferService) PostCheckpoints ¶
func (s *TempBackupTransferService) PostCheckpoints( ctx context.Context, req *tempbackuppb.PostCheckpointsRequest, ) (*tempbackuppb.PostCheckpointsResponse, error)
func (*TempBackupTransferService) TransferFullBackup ¶
func (s *TempBackupTransferService) TransferFullBackup( stream tempbackuppb.BackupTransferService_TransferFullBackupServer, ) error
func (*TempBackupTransferService) TransferIncBackup ¶
func (s *TempBackupTransferService) TransferIncBackup( stream tempbackuppb.BackupTransferService_TransferIncBackupServer, ) error
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package tempbackuppb is a generated protocol buffer package.
|
Package tempbackuppb is a generated protocol buffer package. |
Click to show internal directories.
Click to hide internal directories.