Skip to content
This repository was archived by the owner on Apr 29, 2020. It is now read-only.

Commit 22d0501

Browse files
committed
Merge pull request #142 from tummychow/setpod-errors
2 parents cefce12 + ceb1522 commit 22d0501

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

pkg/kp/kv.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,10 +51,14 @@ func (s *Store) SetPod(key string, manifest pods.Manifest) (time.Duration, error
5151
}
5252

5353
writeMeta, err := s.client.KV().Put(keyPair, nil)
54-
if writeMeta == nil {
55-
return 0, KVError{Op: "set", Key: key}
54+
var retDur time.Duration
55+
if writeMeta != nil {
56+
retDur = writeMeta.RequestTime
5657
}
57-
return writeMeta.RequestTime, err
58+
if err != nil {
59+
err = KVError{Op: "set", Key: key}
60+
}
61+
return retDur, err
5862
}
5963

6064
// Pod reads a pod manifest from the key-value store. If the given key does not

0 commit comments

Comments
 (0)