- Jobs plugin initial commit

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 52 insertions, 0 deletions

diff --git a/plugins/jobs/event_test.go b/plugins/jobs/event_test.go
new file mode 100644
index 00000000..94d53531
--- /dev/null
+++ b/plugins/jobs/event_test.go
@@ -0,0 +1,52 @@
+package jobs
+
+import (
+	"errors"
+	"github.com/stretchr/testify/assert"
+	"testing"
+	"time"
+)
+
+func TestJobEvent_Elapsed(t *testing.T) {
+	e := &JobEvent{
+		ID:      "id",
+		Job:     &Job{},
+		start:   time.Now(),
+		elapsed: time.Millisecond,
+	}
+
+	assert.Equal(t, time.Millisecond, e.Elapsed())
+}
+
+func TestJobError_Elapsed(t *testing.T) {
+	e := &JobError{
+		ID:      "id",
+		Job:     &Job{},
+		start:   time.Now(),
+		elapsed: time.Millisecond,
+	}
+
+	assert.Equal(t, time.Millisecond, e.Elapsed())
+}
+
+func TestJobError_Error(t *testing.T) {
+	e := &JobError{
+		ID:      "id",
+		Job:     &Job{},
+		start:   time.Now(),
+		elapsed: time.Millisecond,
+		Caused:  errors.New("error"),
+	}
+
+	assert.Equal(t, time.Millisecond, e.Elapsed())
+	assert.Equal(t, "error", e.Error())
+}
+
+func TestPipelineError_Error(t *testing.T) {
+	e := &PipelineError{
+		Pipeline: &Pipeline{},
+		Caused:   errors.New("error"),
+	}
+
+	assert.Equal(t, "error", e.Error())
+}