prow/config/secret/agent.go
func (a *Agent) reloadSecret(secretPath string) {
	var lastModTime time.Time
	logger := logrus.NewEntry(logrus.StandardLogger())

	skips := 0
	for range time.Tick(1 * time.Second) {
		if skips < 600 {
			// Check if the file changed to see if it needs to be re-read.
			secretStat, err := os.Stat(secretPath)
			if err != nil {
				logger.WithField("secret-path", secretPath).
					WithError(err).Error("Error loading secret file.")
				continue
			}

			recentModTime := secretStat.ModTime()
			if !recentModTime.After(lastModTime) {
				skips++
				continue // file hasn't been modified
			}
			lastModTime = recentModTime
		}

		if secretValue, err := LoadSingleSecret(secretPath); err != nil {
			logger.WithField("secret-path: ", secretPath).
				WithError(err).Error("Error loading secret.")
		} else {
			a.setSecret(secretPath, secretValue)
			skips = 0
		}
	}
}
func (a *Agent) reloadSecret(secretPath string) {
	var lastModTime time.Time
	logger := logrus.NewEntry(logrus.StandardLogger())

	skips := 0
	for range time.Tick(1 * time.Second) {
		if skips < 600 {
			// Check if the file changed to see if it needs to be re-read.
			secretStat, err := os.Stat(secretPath)
			if err != nil {
				logger.WithField("secret-path", secretPath).
					WithError(err).Error("Error loading secret file.")
				continue
			}

			recentModTime := secretStat.ModTime()
			if !recentModTime.After(lastModTime) {
				skips++
				continue // file hasn't been modified
			}
			lastModTime = recentModTime
		}

		if secretValue, err := LoadSingleSecret(secretPath); err != nil {
			logger.WithField("secret-path: ", secretPath).
				WithError(err).Error("Error loading secret.")
		} else {
			a.setSecret(secretPath, secretValue)
			skips = 0
		}
	}
}
func ( a * Agent ) reloadSecret ( secretPath string ) { var lastModTime time . Time logger := logrus . NewEntry ( logrus . StandardLogger ( ) ) skips := 0 for range time . Tick ( 1 * time . Second ) { if skips < 600 { // Check if the file changed to see if it needs to be re-read. secretStat , err := os . Stat ( secretPath ) if err != nil { logger . WithField ( " " , secretPath ) . WithError ( err ) . Error ( " " ) continue } recentModTime := secretStat . ModTime ( ) if ! recentModTime . After ( lastModTime ) { skips ++ continue // file hasn't been modified } lastModTime = recentModTime } if secretValue , err := LoadSingleSecret ( secretPath ) ; err != nil { logger . WithField ( " " , secretPath ) . WithError ( err ) . Error ( " " ) } else { a . setSecret ( secretPath , secretValue ) skips = 0 } } }
// reloadSecret will begin polling the secret file at the path. If the first load
// fails, Start with return the error and abort. Future load failures will log
// the failure message but continue attempting to load.
reloadSecret will begin polling the secret file at the path . If the first load fails Start with return the error and abort . Future load failures will log the failure message but continue attempting to load .