executor

Oct 25, 2026

Changes in this version

+ func IsBackupProduct(name string) bool

Oct 24, 2026

Changes in this version

type ForcePushApprover

+ ConsumeForcePushApproval func(taskKey, branch string)

Oct 1, 2026

Changes in this version

+ func BuildRepoAuth(repo *model.Repo, p *model.Platform) gitbackend.AuthConfig

Oct 1, 2026

Changes in this version

type Executor

+ Approver ForcePushApprover

+ type ForcePushApprover interface

+ IsForcePushApproved func(taskKey, branch string) bool

+ RequestApproval func(taskKey, branch, reason string)

Oct 1, 2026

Changes in this version

+ type Pipeline struct

+ func NewPipeline(stages ...Stage) *Pipeline

+ func (p *Pipeline) Run(ctx context.Context, rc *RunContext) error

+ type RunContext struct

+ BundlesPath string

+ Details *strings.Builder

+ Exec *Executor

+ Platforms map[uint]*model.Platform

+ RepoDir string

+ Run *model.SyncRun

+ SourceRepo *model.Repo

+ TargetRepo *model.Repo

+ Task *model.SyncTask

+ WorkDir string

+ type Stage interface

+ IsOptional func() bool

+ Name func() string

+ Run func(ctx context.Context, rc *RunContext) error

+ type Uploader interface

+ Type func() DestinationType

+ Upload func(ctx context.Context, d Destination, objectKey string, data []byte) (string, error)

Sep 29, 2026

Changes in this version

+ func DecryptFile(encPath, keyParam, destPath string) error

+ func DecryptToTemp(encPath, keyParam string) (string, error)

+ func EncryptFile(srcPath, keyParam string) (string, error)

+ func EncryptFileWithSuffix(srcPath, keyParam, suffix string) (string, error)

+ func IsEncryptedFile(name string) bool

+ func SaveManifest(m *BackupManifest) (string, error)

+ func VerifyDrillChain(historyFile string) (ok bool, checked int, brokenAt string)

+ type BackupManifest struct

+ BackupDir string

+ Entries []ManifestEntry

+ EntryCount int

+ Generated time.Time

+ MerkleRoot string

+ TotalSize int64

+ Version int

+ func BuildManifest(backupDir string) (*BackupManifest, error)

+ func LoadManifest(backupDir string) (*BackupManifest, error)

+ type Destination struct

+ AccessKey string

+ AccountKey string

+ AccountName string

+ Bucket string

+ Container string

+ Enabled *bool

+ Endpoint string

+ Name string

+ Password string

+ PathStyle bool

+ Prefix string

+ Region string

+ SecretKey string

+ Type DestinationType

+ URL string

+ Username string

+ type DestinationType string

+ const DestAzure

+ const DestLocal

+ const DestS3

+ const DestWebDAV

+ type DrillHistoryEntry struct

+ Hash string

+ PrevHash string

+ Report *DrillReport

+ func LoadDrillHistory(historyFile string, limit int) ([]DrillHistoryEntry, error)

+ func SaveDrillReport(historyFile string, rep *DrillReport) (*DrillHistoryEntry, error)

+ type DrillReport struct

+ BundleName string

+ BundleSize int64

+ CheckedAt time.Time

+ CommitCount int

+ Details map[string]string

+ DurationMS int64

+ Errors []string

+ EstRTO string

+ ExtraRefs []string

+ FinishedAt time.Time

+ FsckOK bool

+ FsckOutput string

+ MissingRefs []string

+ RefSpecs []string

+ RestoredRefs []string

+ StartedAt time.Time

+ Success bool

+ func BatchDRDrill(ctx context.Context, bundlePaths []string) (reports []*DrillReport, summary map[string]any)

+ func RunDRDrill(ctx context.Context, bundlePath string) (*DrillReport, error)

+ type ManifestEntry struct

+ LeafHash string

+ ModTime time.Time

+ Name string

+ SHA256 string

+ Size int64

+ TaskKey string

+ type ManifestVerifyResult struct

+ CheckedCount int

+ ExtraFiles []string

+ HashMismatch []string

+ MerkleRoot string

+ Message string

+ MissingFiles []string

+ OK bool

+ StoredRoot string

+ func VerifyManifest(backupDir string) (*ManifestVerifyResult, error)

+ type UploadResult struct

+ Bytes int64

+ Destination string

+ Error string

+ OK bool

+ ObjectKey string

+ Type string

+ func FanoutUpload(ctx context.Context, localPath string, dests []Destination) []UploadResult

Sep 27, 2026

Changes in this version

+ func RestoreBundle(ctx context.Context, bundlePath, destDir string) error

+ type BundleInfo struct

+ ModTime time.Time

+ Name string

+ Path string

+ RefSpecs []string

+ Size int64

+ TaskKey string

+ Valid bool

+ func ListBundles(backupDir, taskKey string) ([]BundleInfo, error)

+ func VerifyBundle(ctx context.Context, bundlePath string) (*BundleInfo, error)

Sep 27, 2026

Changes in this version

+ func UploadBundle(ctx context.Context, cfg *S3Config, localPath, objectKey string) error

+ type S3Config struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ PathStyle bool

+ Prefix string

+ Region string

+ SecretKey string

Sep 20, 2026

Changes in this version

+ const RemoteOrigin

+ const RemoteTarget

+ const RepoDir

+ func ClassifyError(err error) string

+ type Executor struct

+ func NewExecutor(svc Service) (*Executor, error)

+ func (e *Executor) Execute(ctx context.Context, task *model.SyncTask, trigger string, ...) (*model.SyncRun, error)

+ type PlatformProvider interface

+ GetPlatformByID func(ctx context.Context, id uint) (*model.Platform, error)

+ type RepoProvider interface

+ GetRepoByKey func(key string) (*model.Repo, error)

+ type RunManager interface

+ CompleteRun func(run *model.SyncRun) error

+ CompleteRunWithTaskUpdate func(run *model.SyncRun, task *model.SyncTask) error

+ CreateRun func(task *model.SyncTask, trigger string, webhookEventID *uint) (*model.SyncRun, error)

+ CreateRunStep func(step *model.SyncRunStep) error

+ UpdateRunStep func(step *model.SyncRunStep) error

+ UpdateTaskLastRun func(task *model.SyncTask, run *model.SyncRun) error

+ type Service interface

+ GetConfig func() *model.Config

+ GetTempDir func(taskKey string) string