kubernetes
/
git-sync
mirror of https://github.com/kubernetes/git-sync.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updated main to add the env var and send a post request

This commit is contained in:
Zac 2018-08-28 10:46:48 -07:00 committed by Thomas Jackson
parent 08282abe9d
commit 7f64d79bbe
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/git-sync/main.go
View File

@ -33,6 +33,7 @@ import (
"strconv" "strconv"
"strings" "strings"
"time" "time"
"http"
"github.com/thockin/glogr" "github.com/thockin/glogr"
"github.com/thockin/logr" "github.com/thockin/logr"
@ -61,6 +62,8 @@ var flMaxSyncFailures = flag.Int("max-sync-failures", envInt("GIT_SYNC_MAX_SYNC_
"the number of consecutive failures allowed before aborting (the first pull must succeed, -1 disables aborting for any number of failures after the initial sync)") "the number of consecutive failures allowed before aborting (the first pull must succeed, -1 disables aborting for any number of failures after the initial sync)")
var flChmod = flag.Int("change-permissions", envInt("GIT_SYNC_PERMISSIONS", 0), var flChmod = flag.Int("change-permissions", envInt("GIT_SYNC_PERMISSIONS", 0),
"the file permissions to apply to the checked-out files") "the file permissions to apply to the checked-out files")
var flSymlinkUpdatePostUrl = flag.String("symlink-update-post-url", envString("GIT_SYNC_SYMLINK_UPDATE_POST_URL", ""),
"a command to run when the symlink is updated")
var flUsername = flag.String("username", envString("GIT_SYNC_USERNAME", ""), var flUsername = flag.String("username", envString("GIT_SYNC_USERNAME", ""),
"the username to use") "the username to use")
@ -290,6 +293,15 @@ func updateSymlink(ctx context.Context, gitRoot, link, newDir string) error {
log.V(1).Infof("pruned old worktrees") log.V(1).Infof("pruned old worktrees")
} }
// If there is a symlink update callback, call it
if len(*flSymlinkUpdateCallback) > 0 {
// Send the post request
resp, err := http.NewRequest("POST", url, nil)
if err != nil {
return fmt.Errorf("error sending symlink update callback post request: %v", err)
}
}
return nil return nil
} }