summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/event_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/event_test.go')
-rw-r--r--plugins/jobs/oooold/event_test.go52
1 files changed, 52 insertions, 0 deletions
diff --git a/plugins/jobs/oooold/event_test.go b/plugins/jobs/oooold/event_test.go
new file mode 100644
index 00000000..82241124
--- /dev/null
+++ b/plugins/jobs/oooold/event_test.go
@@ -0,0 +1,52 @@
+package oooold
+
+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())
+}