[Workflow] Updates for Go SDK

daprdocs/content/en/developing-applications/building-blocks/workflow/howto-author-workflow.md

@@ -34,7 +34,7 @@ The Dapr sidecar doesn’t load any workflow definitions. Rather, the sidecar si
 
 [Workflow activities]({{< ref "workflow-features-concepts.md#workflow-activites" >}}) are the basic unit of work in a workflow and are the tasks that get orchestrated in the business process.
 
-{{< tabs Python ".NET" Java >}}
+{{< tabs Python ".NET" Java Go >}}
 
 {{% codetab %}}
 
@@ -165,14 +165,63 @@ public class DemoWorkflowActivity implements WorkflowActivity {
 
 {{% /codetab %}}
 
+{{% codetab %}}
+
+<!--go-->
+
+Define the workflow activities you'd like your workflow to perform. Activities are wrapped in the public `callActivityOptions` method, which implements the workflow activities. 
+
+```go
+type ActivityContext struct {
+	ctx task.ActivityContext
+}
+
+func (wfac *ActivityContext) GetInput(v interface{}) error {
+	return wfac.ctx.GetInput(&v)
+}
+
+func (wfac *ActivityContext) Context() context.Context {
+	return wfac.ctx.Context()
+}
+
+type callActivityOption func(*callActivityOptions) error
+
+type callActivityOptions struct {
+	rawInput *wrapperspb.StringValue
+}
+
+// ActivityInput is an option to pass a JSON-serializable input
+func ActivityInput(input any) callActivityOption {
+	return func(opts *callActivityOptions) error {
+		data, err := marshalData(input)
+		if err != nil {
+			return err
+		}
+		opts.rawInput = wrapperspb.String(string(data))
+		return nil
+	}
+}
+
+// ActivityRawInput is an option to pass a byte slice as an input
+func ActivityRawInput(input string) callActivityOption {
+	return func(opts *callActivityOptions) error {
+		opts.rawInput = wrapperspb.String(input)
+		return nil
+	}
+}
+```
+
+[See the Go SDK workflow activity example in context.](todo)
+
+{{% /codetab %}}
 
 {{< /tabs >}}
 
 ## Write the workflow
 
 Next, register and call the activites in a workflow. 
 
-{{< tabs Python ".NET" Java >}}
+{{< tabs Python ".NET" Java Go >}}
 
 {{% codetab %}}
 
@@ -267,6 +316,69 @@ public class DemoWorkflowWorker {
 [See the Java SDK workflow in context.](https://github.com/dapr/java-sdk/blob/master/examples/src/main/java/io/dapr/examples/workflows/DemoWorkflowWorker.java)
 
 
+{{% /codetab %}}
+
+{{% codetab %}}
+
+<!--go-->
+
+Next, register the workflow and workflow activities and start the workflow runtime.
+
+```go
+package workflow
+
+// RegisterWorkflow adds a workflow function to the registry
+func (ww *WorkflowWorker) RegisterWorkflow(w Workflow) error {
+	wrappedOrchestration := wrapWorkflow(w)
+
+	// get the function name for the passed workflow
+	name, err := getFunctionName(w)
+	if err != nil {
+		return fmt.Errorf("failed to get workflow decorator: %v", err)
+	}
+
+	err = ww.tasks.AddOrchestratorN(name, wrappedOrchestration)
+	return err
+}
+
+// Activity wrapper
+func wrapActivity(a Activity) task.Activity {
+	return func(ctx task.ActivityContext) (any, error) {
+		aCtx := ActivityContext{ctx: ctx}
+
+		return a(aCtx)
+	}
+}
+
+// RegisterActivity adds an activity function to the registry
+func (ww *WorkflowWorker) RegisterActivity(a Activity) error {
+	wrappedActivity := wrapActivity(a)
+
+	// get the function name for the passed activity
+	name, err := getFunctionName(a)
+	if err != nil {
+		return fmt.Errorf("failed to get activity decorator: %v", err)
+	}
+
+	err = ww.tasks.AddActivityN(name, wrappedActivity)
+	return err
+}
+
+// Start initialises a non-blocking worker to handle workflows and activities registered
+// prior to this being called.
+func (ww *WorkflowWorker) Start() error {
+	ctx, cancel := context.WithCancel(context.Background())
+	ww.cancel = cancel
+	if err := ww.client.StartWorkItemListener(ctx, ww.tasks); err != nil {
+		return fmt.Errorf("failed to start work stream: %v", err)
+	}
+	log.Println("work item listener started")
+	return nil
+}
+```
+
+[See the Go SDK workflow in context.](todo)
+
 {{% /codetab %}}
 
 {{< /tabs >}}
@@ -275,7 +387,7 @@ public class DemoWorkflowWorker {
 
 Finally, compose the application using the workflow.
 
-{{< tabs Python ".NET" Java >}}
+{{< tabs Python ".NET" Java Go >}}
 
 {{% codetab %}}
 
@@ -484,6 +596,25 @@ public class DemoWorkflow extends Workflow {
 
 {{% /codetab %}}
 
+{{% codetab %}}
+
+<!--go-->
+
+[As in the following example](todo), a hello-world application using the Go SDK and Dapr Workflow would include:
+
+- A Go package called `todo` to receive the Go SDK client capabilities.
+- An import of `todo`
+- The `DemoWorkflow` class which extends `Workflow`
+- Creating the workflow with input and output.
+- API calls. In the example below, these calls start and call the workflow activities.
+
+```go
+
+```
+
+[See the full Go SDK workflow example in context.](todo)
+
+{{% /codetab %}}
 
 {{< /tabs >}}
 
@@ -506,3 +637,4 @@ Now that you've authored a workflow, learn how to manage it.
   - [Python example](https://github.com/dapr/python-sdk/tree/master/examples/demo_workflow)
   - [.NET example](https://github.com/dapr/dotnet-sdk/tree/master/examples/Workflow)
   - [Java example](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/workflows)
+  - [Go example](todo)

daprdocs/content/en/developing-applications/building-blocks/workflow/howto-manage-workflow.md

@@ -12,7 +12,7 @@ Dapr Workflow is currently in beta. [See known limitations for {{% dapr-latest-v
 
 Now that you've [authored the workflow and its activities in your application]({{< ref howto-author-workflow.md >}}), you can start, terminate, and get information about the workflow using HTTP API calls. For more information, read the [workflow API reference]({{< ref workflow_api.md >}}).
 
-{{< tabs Python ".NET" Java HTTP >}}
+{{< tabs Python ".NET" Java Go HTTP >}}
 
 <!--Python-->
 {{% codetab %}}
@@ -99,7 +99,7 @@ await daprClient.PurgeWorkflowAsync(orderId, workflowComponent);
 
 {{% /codetab %}}
 
-<!--Python-->
+<!--Java-->
 {{% codetab %}}
 
 Manage your workflow within your code. [In the workflow example from the Java SDK](https://github.com/dapr/java-sdk/blob/master/examples/src/main/java/io/dapr/examples/workflows/DemoWorkflowClient.java), the workflow is registered in the code using the following APIs:
@@ -164,6 +164,84 @@ public class DemoWorkflowClient {
 
 {{% /codetab %}}
 
+<!--Go-->
+{{% codetab %}}
+
+Manage your workflow within your code. [In the workflow example from the Go SDK](todo), the workflow is registered in the code using the following APIs:
+
+- **StartWorkflow**: Starts a new workflow instance
+- **GetWorkflow**: Get information on the status of the workflow
+- **PauseWorkflow**: Pauses or suspends a workflow instance that can later be resumed
+- **RaiseEventWorkflow**: Raises events/tasks for the running workflow instance
+- **ResumeWorkflow**: Waits for the workflow to complete its tasks
+- **PurgeWorkflow**: Removes all metadata related to a specific workflow instance
+- **TerminateWorkflow**: Terminates the workflow
+
+```go
+// Start workflow
+type StartWorkflowRequest struct {
+	InstanceID        string // Optional instance identifier
+	WorkflowComponent string
+	WorkflowName      string
+	Options           map[string]string // Optional metadata
+	Input             any               // Optional input
+	SendRawInput      bool              // Set to True in order to disable serialization on the input
+}
+
+type StartWorkflowResponse struct {
+	InstanceID string
+}
+
+// Get the workflow status
+type GetWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+}
+
+type GetWorkflowResponse struct {
+	InstanceID    string
+	WorkflowName  string
+	CreatedAt     time.Time
+	LastUpdatedAt time.Time
+	RuntimeStatus string
+	Properties    map[string]string
+}
+
+// Purge workflow
+type PurgeWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+}
+
+// Terminate workflow
+type TerminateWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+}
+
+// Pause workflow
+type PauseWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+}
+
+// Resume workflow
+type ResumeWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+}
+
+// Raise an event for the running workflow
+type RaiseEventWorkflowRequest struct {
+	InstanceID        string
+	WorkflowComponent string
+	EventName         string
+	EventData         any
+	SendRawData       bool // Set to True in order to disable serialization on the data
+}
+```
+
+{{% /codetab %}}
 
 <!--HTTP-->
 {{% codetab %}}
@@ -244,5 +322,6 @@ Learn more about these HTTP calls in the [workflow API reference guide]({{< ref
   - [Python example](https://github.com/dapr/python-sdk/blob/master/examples/demo_workflow/app.py)
   - [.NET example](https://github.com/dapr/dotnet-sdk/tree/master/examples/Workflow)
   - [Java example](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/workflows)
+  - [Go example](todo)
 
 - [Workflow API reference]({{< ref workflow_api.md >}})

daprdocs/content/en/developing-applications/building-blocks/workflow/workflow-architecture.md

@@ -196,4 +196,5 @@ See the [Reminder usage and execution guarantees section]({{< ref "workflow-arch
 - Try out the following examples: 
    - [Python](https://github.com/dapr/python-sdk/tree/master/examples/demo_workflow)
    - [.NET](https://github.com/dapr/dotnet-sdk/tree/master/examples/Workflow)
-   - [Java](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/workflows)
+   - [Java](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/workflows)
+   - [Go example](todo)