Documentation
¶
Index ¶
- type AgentActivities
- type ServerActivities
- func (s *ServerActivities) FinalizeBackupRun(ctx context.Context, session *temporal.BackupSessionInfo, ...) error
- func (s *ServerActivities) PrepareBackupSession(ctx context.Context, jobID uuid.UUID) (*temporal.BackupSessionInfo, error)
- func (s *ServerActivities) PruneJob(ctx context.Context, session *temporal.BackupSessionInfo) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentActivities ¶
type AgentActivities struct {
// ServerURL is the FallBCK server URL this agent is configured to talk to.
// When set, the PBS proxy is reached through it instead of the server-advertised
// public URL, which may not be routable from the agent's network (e.g. containers).
ServerURL string
}
AgentActivities provides activities executed on the client backup agent host
func NewAgentActivities ¶
func NewAgentActivities() *AgentActivities
NewAgentActivities creates a new AgentActivities instance
func (*AgentActivities) ExecuteFilesystemBackup ¶
func (a *AgentActivities) ExecuteFilesystemBackup(ctx context.Context, session *temporal.BackupSessionInfo) (*temporal.BackupExecutionResult, error)
ExecuteFilesystemBackup performs the filesystem backup on the agent host and streams chunks through the proxy
type ServerActivities ¶
type ServerActivities struct {
DB *db.DB
Config *config.ServerConfig
TokenManager *auth.TokenManager
}
ServerActivities provides activities executed on the central FallBCK server
func NewServerActivities ¶
func NewServerActivities(database *db.DB, cfg *config.ServerConfig, tm *auth.TokenManager) *ServerActivities
NewServerActivities creates a new ServerActivities instance
func (*ServerActivities) FinalizeBackupRun ¶
func (s *ServerActivities) FinalizeBackupRun(ctx context.Context, session *temporal.BackupSessionInfo, result *temporal.BackupExecutionResult) error
FinalizeBackupRun updates the backup run record in the database with results and deduplication metrics
func (*ServerActivities) PrepareBackupSession ¶
func (s *ServerActivities) PrepareBackupSession(ctx context.Context, jobID uuid.UUID) (*temporal.BackupSessionInfo, error)
PrepareBackupSession validates job parameters and generates a short-lived backup ticket
func (*ServerActivities) PruneJob ¶
func (s *ServerActivities) PruneJob(ctx context.Context, session *temporal.BackupSessionInfo) error
PruneJob executes the retention policy prune on the target Proxmox Backup Server