expose internal worker identifier for unicast task delivery

engine/worker.go

@@ -0,0 +1,5 @@
+package engine
+
+func (e *Engine) Worker() string {
+	return e.wrk
+}

engine/worker_test.go

@@ -0,0 +1,47 @@
+package engine
+
+import (
+	"fmt"
+	"reflect"
+	"testing"
+
+	"github.com/google/go-cmp/cmp"
+	"github.com/xh3b4sd/redigo"
+)
+
+func Test_Engine_Worker(t *testing.T) {
+	testCases := []struct {
+		wrk string
+	}{
+		// Case 000
+		{
+			wrk: "foo",
+		},
+		// Case 001
+		{
+			wrk: "bar",
+		},
+		// Case 002
+		{
+			wrk: "123",
+		},
+	}
+
+	for i, tc := range testCases {
+		t.Run(fmt.Sprintf("%03d", i), func(t *testing.T) {
+			var e *Engine
+			{
+				e = New(Config{
+					Redigo: redigo.Fake(),
+					Worker: tc.wrk,
+				})
+			}
+
+			wrk := e.Worker()
+
+			if !reflect.DeepEqual(wrk, tc.wrk) {
+				t.Fatalf("\n\n%s\n", cmp.Diff(tc.wrk, wrk))
+			}
+		})
+	}
+}

interface.go

@@ -80,4 +80,8 @@ type Interface interface {
 	// multiple workers, it takes only a single functioning worker to call ticker
 	// in order to keep scheduling recurring tasks for anyone to work on.
 	Ticker() error
+
+	// Worker returns the this worker's identifier, which may be used for unicast
+	// style task delivery.
+	Worker() string
 }