lourenco/mgmt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

engine: resources: Update kv error messages

Browse Source
This commit is contained in:
James Shubin
2024-01-16 15:46:56 -05:00
parent 6b4fb434da
commit b4bb4ca397
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
engine/resources/kv.go
View File

@@ -138,7 +138,7 @@ func (obj *KVRes) Watch(ctx context.Context) error {
ch, err := obj.init.World.StrMapWatch(ctx, obj.getKey()) // get possible events!
if err != nil {
return err
return errwrap.Wrapf(err, "error during watch")
}
obj.init.Running() // when started, notify engine that we're running
@@ -236,7 +236,7 @@ func (obj *KVRes) CheckApply(ctx context.Context, apply bool) (bool, error) {
hostname := obj.init.Hostname // me
keyMap, err := obj.init.World.StrMapGet(ctx, obj.getKey())
if err != nil {
return false, errwrap.Wrapf(err, "check error during StrGet")
return false, errwrap.Wrapf(err, "error during get")
}
if value, exists := keyMap[hostname]; exists && obj.Value != nil {
@@ -258,7 +258,7 @@ func (obj *KVRes) CheckApply(ctx context.Context, apply bool) (bool, error) {
return false, nil
}
err := obj.kvDel(ctx, obj.getKey())
return false, errwrap.Wrapf(err, "apply error during StrDel")
return false, errwrap.Wrapf(err, "error during del")
}
if !apply {
@@ -266,7 +266,7 @@ func (obj *KVRes) CheckApply(ctx context.Context, apply bool) (bool, error) {
}
if err := obj.init.World.StrMapSet(ctx, obj.getKey(), *obj.Value); err != nil {
return false, errwrap.Wrapf(err, "apply error during StrSet")
return false, errwrap.Wrapf(err, "error during set")
}
return false, nil