Merge pull request #33 from cschleiden/redis-backend

Add initial version of Redis backend

Author: cschleiden

.github/workflows/go.yml

@@ -21,6 +21,14 @@ jobs:
     - name: Build
       run: go build -v ./...
 
+    - name: Start Redis
+      uses: shogo82148/actions-setup-redis@v1
+      with:
+        auto-start: true
+        redis-port: 6379
+        redis-version: latest
+        redis-conf: 'requirepass RedisPassw0rd'
+
     - name: Tests
       run: |
         sudo /etc/init.d/mysql start

.vscode/launch.json

@@ -4,6 +4,7 @@
   // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
   "version": "0.2.0",
   "configurations": [
+
     {
       "name": "Current sample",
       "type": "go",
@@ -53,5 +54,12 @@
       "mode": "debug",
       "program": "${workspaceFolder}/samples/subworkflow/subworkflow.go"
     },
+    {
+      "name": "Launch scale/worker sample",
+      "type": "go",
+      "request": "launch",
+      "mode": "debug",
+      "program": "${workspaceFolder}/samples/scale/worker/main.go"
+    },
   ]
 }

backend/backend.go

@@ -3,6 +3,7 @@ package backend
 import (
 	"context"
 
+	core "github.com/cschleiden/go-workflows/internal/core"
 	"github.com/cschleiden/go-workflows/internal/history"
 	"github.com/cschleiden/go-workflows/internal/task"
 	"github.com/cschleiden/go-workflows/workflow"
@@ -21,13 +22,13 @@ type Backend interface {
 	CreateWorkflowInstance(ctx context.Context, event history.WorkflowEvent) error
 
 	// CancelWorkflowInstance cancels a running workflow instance
-	CancelWorkflowInstance(ctx context.Context, instance workflow.Instance) error
+	CancelWorkflowInstance(ctx context.Context, instance *workflow.Instance, event *history.Event) error
 
 	// GetWorkflowInstanceState returns the state of the given workflow instance
-	GetWorkflowInstanceState(ctx context.Context, instance workflow.Instance) (WorkflowState, error)
+	GetWorkflowInstanceState(ctx context.Context, instance *workflow.Instance) (WorkflowState, error)
 
 	// GetWorkflowInstanceHistory returns the full workflow history for the given instance
-	GetWorkflowInstanceHistory(ctx context.Context, instance workflow.Instance) ([]history.Event, error)
+	GetWorkflowInstanceHistory(ctx context.Context, instance *workflow.Instance) ([]history.Event, error)
 
 	// SignalWorkflow signals a running workflow instance
 	SignalWorkflow(ctx context.Context, instanceID string, event history.Event) error
@@ -36,22 +37,22 @@ type Backend interface {
 	GetWorkflowTask(ctx context.Context) (*task.Workflow, error)
 
 	// ExtendWorkflowTask extends the lock of a workflow task
-	ExtendWorkflowTask(ctx context.Context, instance workflow.Instance) error
+	ExtendWorkflowTask(ctx context.Context, taskID string, instance *core.WorkflowInstance) error
 
 	// CompleteWorkflowTask checkpoints a workflow task retrieved using GetWorkflowTask
 	//
 	// This checkpoints the execution. events are new events from the last workflow execution
 	// which will be added to the workflow instance history. workflowEvents are new events for the
 	// completed or other workflow instances.
 	CompleteWorkflowTask(
-		ctx context.Context, instance workflow.Instance, state WorkflowState,
+		ctx context.Context, taskID string, instance *workflow.Instance, state WorkflowState,
 		executedEvents []history.Event, activityEvents []history.Event, workflowEvents []history.WorkflowEvent) error
 
 	// GetActivityTask returns a pending activity task or nil if there are no pending activities
 	GetActivityTask(ctx context.Context) (*task.Activity, error)
 
 	// CompleteActivityTask completes a activity task retrieved using GetActivityTask
-	CompleteActivityTask(ctx context.Context, instance workflow.Instance, activityID string, event history.Event) error
+	CompleteActivityTask(ctx context.Context, instance *workflow.Instance, activityID string, event history.Event) error
 
 	// ExtendActivityTask extends the lock of an activity task
 	ExtendActivityTask(ctx context.Context, activityID string) error