manager/runner.go
func newWatcher(c *config.Config, clients *dep.ClientSet, once bool) (*watch.Watcher, error) {
	log.Printf("[INFO] (runner) creating watcher")

	w, err := watch.NewWatcher(&watch.NewWatcherInput{
		Clients:             clients,
		MaxStale:            config.TimeDurationVal(c.MaxStale),
		Once:                once,
		RenewVault:          clients.Vault().Token() != "" && config.BoolVal(c.Vault.RenewToken),
		VaultAgentTokenFile: config.StringVal(c.Vault.VaultAgentTokenFile),
		RetryFuncConsul:     watch.RetryFunc(c.Consul.Retry.RetryFunc()),
		// TODO: Add a sane default retry - right now this only affects "local"
		// dependencies like reading a file from disk.
		RetryFuncDefault: nil,
		RetryFuncVault:   watch.RetryFunc(c.Vault.Retry.RetryFunc()),
		VaultGrace:       config.TimeDurationVal(c.Vault.Grace),
		VaultToken:       clients.Vault().Token(),
	})
	if err != nil {
		return nil, errors.Wrap(err, "runner")
	}
	return w, nil
}
func newWatcher(c *config.Config, clients *dep.ClientSet, once bool) (*watch.Watcher, error) {
	log.Printf("[INFO] (runner) creating watcher")

	w, err := watch.NewWatcher(&watch.NewWatcherInput{
		Clients:             clients,
		MaxStale:            config.TimeDurationVal(c.MaxStale),
		Once:                once,
		RenewVault:          clients.Vault().Token() != "" && config.BoolVal(c.Vault.RenewToken),
		VaultAgentTokenFile: config.StringVal(c.Vault.VaultAgentTokenFile),
		RetryFuncConsul:     watch.RetryFunc(c.Consul.Retry.RetryFunc()),
		// TODO: Add a sane default retry - right now this only affects "local"
		// dependencies like reading a file from disk.
		RetryFuncDefault: nil,
		RetryFuncVault:   watch.RetryFunc(c.Vault.Retry.RetryFunc()),
		VaultGrace:       config.TimeDurationVal(c.Vault.Grace),
		VaultToken:       clients.Vault().Token(),
	})
	if err != nil {
		return nil, errors.Wrap(err, "runner")
	}
	return w, nil
}
func newWatcher ( c * config . Config , clients * dep . ClientSet , once bool ) ( * watch . Watcher , error ) { log . Printf ( " " ) w , err := watch . NewWatcher ( & watch . NewWatcherInput { Clients : clients , MaxStale : config . TimeDurationVal ( c . MaxStale ) , Once : once , RenewVault : clients . Vault ( ) . Token ( ) != " " && config . BoolVal ( c . Vault . RenewToken ) , VaultAgentTokenFile : config . StringVal ( c . Vault . VaultAgentTokenFile ) , RetryFuncConsul : watch . RetryFunc ( c . Consul . Retry . RetryFunc ( ) ) , // TODO: Add a sane default retry - right now this only affects "local" // dependencies like reading a file from disk. RetryFuncDefault : nil , RetryFuncVault : watch . RetryFunc ( c . Vault . Retry . RetryFunc ( ) ) , VaultGrace : config . TimeDurationVal ( c . Vault . Grace ) , VaultToken : clients . Vault ( ) . Token ( ) , } ) if err != nil { return nil , errors . Wrap ( err , " " ) } return w , nil }
// newWatcher creates a new watcher.
newWatcher creates a new watcher .