diff options
-rw-r--r-- | vault/logger.go | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/vault/logger.go b/vault/logger.go index 7e16895..a83eb33 100644 --- a/vault/logger.go +++ b/vault/logger.go | |||
@@ -2,13 +2,16 @@ package vault | |||
2 | 2 | ||
3 | import ( | 3 | import ( |
4 | "context" | 4 | "context" |
5 | "log" | ||
6 | "sync" | 5 | "sync" |
7 | 6 | ||
8 | "code.crute.us/mcrute/golib/service" | 7 | "code.crute.us/mcrute/golib/service" |
9 | ) | 8 | ) |
10 | 9 | ||
11 | func MakeRenewalLogger(rc chan *Renewal) service.RunnerFunc { | 10 | type VaultInfofLogger interface { |
11 | Infof(string, ...interface{}) | ||
12 | } | ||
13 | |||
14 | func MakeRenewalLogger(rc chan *Renewal, log VaultInfofLogger) service.RunnerFunc { | ||
12 | return func(ctx context.Context, wg *sync.WaitGroup) error { | 15 | return func(ctx context.Context, wg *sync.WaitGroup) error { |
13 | wg.Add(1) | 16 | wg.Add(1) |
14 | defer wg.Done() | 17 | defer wg.Done() |
@@ -16,8 +19,9 @@ func MakeRenewalLogger(rc chan *Renewal) service.RunnerFunc { | |||
16 | for { | 19 | for { |
17 | select { | 20 | select { |
18 | case r := <-rc: | 21 | case r := <-rc: |
19 | log.Printf("Renewing credential %s at %s", r.Name, r.RenewedAt) | 22 | log.Infof("Renewing credential %s at %s", r.Name, r.RenewedAt) |
20 | case <-ctx.Done(): | 23 | case <-ctx.Done(): |
24 | log.Infof("Shutting down vault renewal logger") | ||
21 | return nil | 25 | return nil |
22 | } | 26 | } |
23 | } | 27 | } |