summaryrefslogtreecommitdiffstats
path: root/deploy
diff options
context:
space:
mode:
authordavidejones <david@davidejones.com>2023-03-04 09:18:43 +0000
committerBjørn Erik Pedersen <bjorn.erik.pedersen@gmail.com>2023-03-07 15:38:26 +0100
commitbebb2b8d0a0a15350c492b13ce878ac5b01d488c (patch)
treea33061e3f311ad9aff765cc9a08aedfc1d77be1b /deploy
parente6f029bdeef4e1a719c5e77d51006b9007d96646 (diff)
switch transfers to workers
Diffstat (limited to 'deploy')
-rw-r--r--deploy/deploy.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/deploy/deploy.go b/deploy/deploy.go
index e2a12ca7f..edc94c404 100644
--- a/deploy/deploy.go
+++ b/deploy/deploy.go
@@ -65,7 +65,7 @@ type Deployer struct {
force bool // true forces upload of all files
invalidateCDN bool // true enables invalidate CDN cache (if possible)
maxDeletes int // caps the # of files to delete; -1 to disable
- transfers int // The number of file transfers to run in parallel
+ workers int // The number of workers to transfer files
// For tests...
summary deploySummary // summary of latest Deploy results
@@ -119,7 +119,7 @@ func New(cfg config.Provider, localFs afero.Fs) (*Deployer, error) {
force: cfg.GetBool("force"),
invalidateCDN: cfg.GetBool("invalidateCDN"),
maxDeletes: cfg.GetInt("maxDeletes"),
- transfers: cfg.GetInt("transfers"),
+ workers: cfg.GetInt("workers"),
}, nil
}
@@ -191,7 +191,7 @@ func (d *Deployer) Deploy(ctx context.Context) error {
// Apply the changes in parallel, using an inverted worker
// pool (https://www.youtube.com/watch?v=5zXAHh5tJqQ&t=26m58s).
// sem prevents more than nParallel concurrent goroutines.
- nParallel := d.transfers
+ nParallel := d.workers
var errs []error
var errMu sync.Mutex // protects errs