Method syncAll

cmd/pk/sync.go:250–298

()

}

func (c *syncCmd) syncAll() error {
	if c.loop {
		return cmdmain.UsageError("--all can't be used with --loop")
	}
	if c.third != "" {
		return cmdmain.UsageError("--all can't be used with --thirdleg")
	}
	if c.dest != "" {
		return cmdmain.UsageError("--all can't be used with --dest")
	}

	dc := c.discoClient()
	syncHandlers, err := dc.SyncHandlers()
	if err != nil {
		return fmt.Errorf("sync handlers discovery failed: %v", err)
	}
	cmdmain.Logf("To be synced:\n")
	for _, sh := range syncHandlers {
		cmdmain.Logf("%v -> %v", sh.From, sh.To)
	}
	for _, sh := range syncHandlers {
		from, err := client.New(client.OptionServer(sh.From), client.OptionInsecure(c.insecureTLS))
		if err != nil {
			return fmt.Errorf("creating source client from %q: %v", sh.From, err)
		}
		from.Verbose = *cmdmain.FlagVerbose
		from.Logger = log.New(cmdmain.Stderr, "", log.LstdFlags)
		if err := from.SetupAuth(); err != nil {
			return fmt.Errorf("could not setup auth for connecting to %v: %v", sh.From, err)
		}

		to, err := client.New(client.OptionServer(sh.To), client.OptionInsecure(c.insecureTLS))
		if err != nil {
			return fmt.Errorf("creating destination client to %q: %v", sh.To, err)
		}
		to.Verbose = *cmdmain.FlagVerbose
		to.Logger = log.New(cmdmain.Stderr, "", log.LstdFlags)
		if err := to.SetupAuth(); err != nil {
			return fmt.Errorf("could not setup auth for connecting to %v: %v", sh.To, err)
		}
		cmdmain.Logf("Now syncing: %v -> %v", sh.From, sh.To)
		stats, err := c.doPass(from, to, nil)
		cmdmain.Logf("sync stats, blobs: %d, bytes %d\n", stats.BlobsCopied, stats.BytesCopied)
		if err != nil {
			return err
		}
	}
	return nil
}

// discoClient returns a client initialized with a server
// based from --src or from the configuration file if --src