feat: workflow authoring and management support

.github/workflows/validate_examples.yaml

@@ -14,15 +14,15 @@ on:
   workflow_dispatch:
     inputs:
       daprdapr_commit:
-        description: 'Dapr/Dapr commit to build custom daprd from'
+        description: "Dapr/Dapr commit to build custom daprd from"
         required: false
-        default: ''
+        default: ""
       daprcli_commit:
-        description: 'Dapr/CLI commit to build custom dapr CLI from'
+        description: "Dapr/CLI commit to build custom dapr CLI from"
         required: false
-        default: ''
+        default: ""
   repository_dispatch:
-    types: [ validate-examples ]
+    types: [validate-examples]
   merge_group:
 jobs:
   setup:
@@ -154,7 +154,17 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        examples: [ "actor", "configuration", "grpc-service", "hello-world", "pubsub", "service", "socket" ]
+        examples:
+          [
+            "actor",
+            "configuration",
+            "grpc-service",
+            "hello-world",
+            "pubsub",
+            "service",
+            "socket",
+            "workflow",
+          ]
     steps:
       - name: Check out code onto GOPATH
         uses: actions/checkout@v4

Makefile

@@ -27,6 +27,7 @@ cover: ## Displays test coverage in the client and service packages
 	go test -coverprofile=cover-client.out ./client && go tool cover -html=cover-client.out
 	go test -coverprofile=cover-grpc.out ./service/grpc && go tool cover -html=cover-grpc.out
 	go test -coverprofile=cover-http.out ./service/http && go tool cover -html=cover-http.out
+	go test -coverprofile=cover-workflow.out ./workflow && go tool cover -html=cover-workflow.out
 
 .PHONY: lint
 lint: check-lint ## Lints the entire project

client/client.go

@@ -209,8 +209,31 @@ type Client interface {
 	// ImplActorClientStub is to impl user defined actor client stub
 	ImplActorClientStub(actorClientStub actor.Client, opt ...config.Option)
 
+	// StartWorkflowBeta1 starts a workflow.
+	StartWorkflowBeta1(ctx context.Context, req *StartWorkflowRequest) (*StartWorkflowResponse, error)
+
+	// GetWorkflowBeta1 gets a workflow.
+	GetWorkflowBeta1(ctx context.Context, req *GetWorkflowRequest) (*GetWorkflowResponse, error)
+
+	// PurgeWorkflowBeta1 purges a workflow.
+	PurgeWorkflowBeta1(ctx context.Context, req *PurgeWorkflowRequest) error
+
+	// TerminateWorkflowBeta1 terminates a workflow.
+	TerminateWorkflowBeta1(ctx context.Context, req *TerminateWorkflowRequest) error
+
+	// PauseWorkflowBeta1 pauses a workflow.
+	PauseWorkflowBeta1(ctx context.Context, req *PauseWorkflowRequest) error
+
+	// ResumeWorkflowBeta1 resumes a workflow.
+	ResumeWorkflowBeta1(ctx context.Context, req *ResumeWorkflowRequest) error
+
+	// RaiseEventWorkflowBeta1 raises an event for a workflow.
+	RaiseEventWorkflowBeta1(ctx context.Context, req *RaiseEventWorkflowRequest) error
+
 	// GrpcClient returns the base grpc client if grpc is used and nil otherwise
 	GrpcClient() pb.DaprClient
+
+	GrpcClientConn() *grpc.ClientConn
 }
 
 // NewClient instantiates Dapr client using DAPR_GRPC_PORT environment variable as port.

client/client_test.go

@@ -39,8 +39,9 @@ import (
 )
 
 const (
-	testBufSize = 1024 * 1024
-	testSocket  = "/tmp/dapr.socket"
+	testBufSize           = 1024 * 1024
+	testSocket            = "/tmp/dapr.socket"
+	testWorkflowFailureID = "test_failure_id"
 )
 
 var testClient Client
@@ -500,6 +501,62 @@ func (s *testDaprServer) UnsubscribeConfiguration(ctx context.Context, in *pb.Un
 	return &pb.UnsubscribeConfigurationResponse{Ok: true}, nil
 }
 
+func (s *testDaprServer) StartWorkflowBeta1(ctx context.Context, in *pb.StartWorkflowRequest) (*pb.StartWorkflowResponse, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &pb.StartWorkflowResponse{
+		InstanceId: in.GetInstanceId(),
+	}, nil
+}
+
+func (s *testDaprServer) GetWorkflowBeta1(ctx context.Context, in *pb.GetWorkflowRequest) (*pb.GetWorkflowResponse, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &pb.GetWorkflowResponse{
+		InstanceId:    in.GetInstanceId(),
+		WorkflowName:  "TestWorkflowName",
+		RuntimeStatus: "Running",
+		Properties:    make(map[string]string),
+	}, nil
+}
+
+func (s *testDaprServer) PurgeWorkflowBeta1(ctx context.Context, in *pb.PurgeWorkflowRequest) (*emptypb.Empty, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &emptypb.Empty{}, nil
+}
+
+func (s *testDaprServer) TerminateWorkflowBeta1(ctx context.Context, in *pb.TerminateWorkflowRequest) (*emptypb.Empty, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &emptypb.Empty{}, nil
+}
+
+func (s *testDaprServer) PauseWorkflowBeta1(ctx context.Context, in *pb.PauseWorkflowRequest) (*emptypb.Empty, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &emptypb.Empty{}, nil
+}
+
+func (s *testDaprServer) ResumeWorkflowBeta1(ctx context.Context, in *pb.ResumeWorkflowRequest) (*emptypb.Empty, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &emptypb.Empty{}, nil
+}
+
+func (s *testDaprServer) RaiseEventWorkflowBeta1(ctx context.Context, in *pb.RaiseEventWorkflowRequest) (*emptypb.Empty, error) {
+	if in.GetInstanceId() == testWorkflowFailureID {
+		return nil, errors.New("test failure")
+	}
+	return &emptypb.Empty{}, nil
+}
+
 func TestGrpcClient(t *testing.T) {
 	protoClient := pb.NewDaprClient(nil)
 	client := &GRPCClient{protoClient: protoClient}