add onerror strategy

internal/resource/onerror.go

@@ -0,0 +1,66 @@
+// Copyright 2024 Matthew Rich <matthewrich.conf@gmail.com>. All rights reserved.
+
+package resource
+
+import (
+	"errors"
+	"encoding/json"
+	"gopkg.in/yaml.v3"
+)
+
+var (
+	ErrInvalidOnErrorStrategy = errors.New("Invalid OnError strategy")
+)
+
+type OnError string
+
+const (
+	OnErrorStop = "stop"
+	OnErrorFail = "fail"
+	OnErrorSkip = "skip"
+)
+
+func NewOnError() OnError {
+	return OnErrorFail
+}
+
+func (o OnError) Strategy() string {
+	switch o {
+	case OnErrorStop, OnErrorFail, OnErrorSkip:
+		return string(o)
+	}
+	return ""
+}
+
+
+func (o OnError) Validate() error {
+        switch o {
+        case OnErrorStop, OnErrorFail, OnErrorSkip:
+                return nil
+        default:
+                return ErrInvalidOnErrorStrategy
+        }
+}
+
+func (o *OnError) UnmarshalValue(value string) (err error) {
+        if err = OnError(value).Validate(); err == nil {
+                *o = OnError(value)
+        }
+        return
+}
+
+func (o *OnError) UnmarshalJSON(jsonData []byte) error {
+        var s string
+        if unmarshalErr := json.Unmarshal(jsonData, &s); unmarshalErr != nil {
+                return unmarshalErr
+        }
+        return o.UnmarshalValue(s)
+}
+
+func (o *OnError) UnmarshalYAML(value *yaml.Node) error {
+        var s string
+        if err := value.Decode(&s); err != nil {
+                return err
+        }
+        return o.UnmarshalValue(s)
+}

internal/resource/onerror_test.go

@@ -0,0 +1,21 @@
+// Copyright 2024 Matthew Rich <matthewrich.conf@gmail.com>. All rights reserved.
+
+package resource
+
+import (
+	"github.com/stretchr/testify/assert"
+	"testing"
+)
+
+func TestOnErrorStrategies(t *testing.T) {
+	for _, v := range []struct{ strategy OnError; expected OnError; validate error }{
+		{ strategy: OnErrorFail, expected: "fail", validate: nil },
+		{ strategy: OnErrorSkip, expected: "skip", validate: nil },
+		{ strategy: OnError("unknown"), expected: "", validate: ErrInvalidOnErrorStrategy },
+	}{
+		o := v.strategy
+		assert.Equal(t, v.expected, o.Strategy())
+		assert.ErrorIs(t, o.Validate(), v.validate)
+	}
+
+}