diff options
author | Mike Crute <mike@crute.us> | 2022-05-21 19:22:07 -0700 |
---|---|---|
committer | Mike Crute <mike@crute.us> | 2022-05-21 19:22:07 -0700 |
commit | 2d1a293315de90b31269b92ec854a6c3b32a0302 (patch) | |
tree | d0e0682e0ef52ddcd49d37759727de06061a4a16 | |
parent | 3e0ef101576c96ebdf429cc45b3980082afe0328 (diff) | |
download | golib-vault/v0.2.4.tar.bz2 golib-vault/v0.2.4.tar.xz golib-vault/v0.2.4.zip |
vault: make logger configurationvault/v0.2.4
-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 | } |