temporal

type BackupExecutionResult struct {
	Status        db.RunStatus  `json:"status"`
	BytesScanned  int64         `json:"bytes_scanned"`
	BytesUploaded int64         `json:"bytes_uploaded"`
	DedupRatio    float64       `json:"dedup_ratio"`
	ChunkCount    int           `json:"chunk_count"`
	SnapshotID    string        `json:"snapshot_id"`
	ErrorMessage  string        `json:"error_message,omitempty"`
	Duration      time.Duration `json:"duration"`
}

type BackupHeartbeatProgress struct {
	CurrentFile   string  `json:"current_file"`
	BytesScanned  int64   `json:"bytes_scanned"`
	BytesUploaded int64   `json:"bytes_uploaded"`
	Percent       float64 `json:"percent"`
}

type BackupSessionInfo struct {
	JobID          uuid.UUID `json:"job_id"`
	AgentID        uuid.UUID `json:"agent_id"`
	TargetID       uuid.UUID `json:"target_id"`
	AgentTaskQueue string    `json:"agent_task_queue"`
	ProxyURL       string    `json:"proxy_url"`
	Ticket         string    `json:"ticket"`
	Datastore      string    `json:"datastore"`
	Namespace      string    `json:"namespace"`
	// Snapshot identity the server opens on PBS (also bound into the ticket)
	BackupType string `json:"backup_type"`
	BackupID   string `json:"backup_id"`
	BackupTime int64  `json:"backup_time"`
	// PxarFormat is "v1" or "v2" (target setting)
	PxarFormat string `json:"pxar_format"`
	// DirectPBS: the agent fetches PBS credentials with its ticket and connects to PBS
	// itself instead of through the server tunnel (job setting)
	DirectPBS bool `json:"direct_pbs"`
	// JobType is filesystem or database; database jobs carry DBConfig (password
	// redacted — the agent fetches it with its ticket when DBPasswordOnServer is set)
	JobType            string         `json:"job_type,omitempty"`
	DBConfig           *dbbackup.Spec `json:"db_config,omitempty"`
	DBPasswordOnServer bool           `json:"db_password_on_server,omitempty"`
	// JobName is informational (manifest)
	JobName         string             `json:"job_name,omitempty"`
	BackupPaths     []string           `json:"backup_paths"`
	ExcludePaths    []string           `json:"exclude_paths"`
	RetentionPolicy db.RetentionPolicy `json:"retention_policy"`
	WorkflowID      string             `json:"workflow_id"`
	RunID           string             `json:"run_id"`
	BackupRunID     uuid.UUID          `json:"backup_run_id"`
}

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