meiliang86/samples-go

Temporal Go SDK samples

Temporal Go SDK samples

This repository contains several sample Workflow applications that demonstrate the various capabilities of the Temporal Server via the Temporal Go SDK.

• Temporal Server repo: https://github.com/temporalio/temporal
• Temporal Go SDK repo: https://github.com/temporalio/sdk-go
• Go SDK docs: https://docs.temporal.io/docs/go/introduction

How to use

Make sure the Temporal Server is running locally. Follow the Quick install guide to do that.

Then, clone this repository and follow the instructions in the README that is included with each sample. The helloworld sample is a good place to start.

You can learn more about running the Server locally in the temporalio/docker-compose README. And you can learn more about the Temporal Server technology in general via our documentation.

Samples directory

Each sample demonstrates one feature of the SDK, together with tests.

• Basic hello world: Simple example of a Workflow Definition and an Activity Definition.

API demonstrations

• Async activity completion: Example of an Expense reporting Workflow that communicates with a server API. Additional documentation: How to complete an Activity Execution asynchronously in Go

• Retry Activity Execution: This samples executes an unreliable Activity. The Activity is executed with a custom Retry Policy. If the Activity Execution fails, the Server will schedule a retry based on the Retry Policy. This Activity also includes a Heartbeat, which enables it to resume from the Activity Execution's last reported progress when it retries.

• Child Workflow: Demonstrates how to use execute a Child Workflow from a Parent Workflow Execution. A Child Workflow Execution only returns to the Parent Workflow Execution after completing its last Run.

• Child Workflow with ContinueAsNew: Demonstrates that the call to Continue-As-New, by a Child Workflow Execution, is not visible to the a parent. The Parent Workflow Execution receives a notification only when a Child Workflow Execution completes, fails or times out. This is a useful feature when there is a need to process a large set of data. The child can iterate over the data set calling Continue-As-New periodically without polluting the parents' history.

• Cancellation: Demonstrates how to cancel a Workflow Execution by calling CancelWorkflow, an how to defer an Activity Execution that "cleans up" after the Workflow Execution has been cancelled.

• Coroutines: Do not use native go routines in Workflows. Instead use Temporal coroutines (workflow.Go()) to maintain a deterministic Workflow. Can be seen in the Split/Merge, DSL, Recovery, PSO, and Parallel Workflow examples.

• Cron Workflow: Demonstrates a recurring Workflow Execution that occurs according to a cron schedule. This samples showcases the HasLastCompletionResult and GetLastCompletionResult APIs which are used to pass information between executions. Additional documentation: What is a Temporal Cron Job?.

• Encryption: How to use encryption for Workflow/Activity data with the DataConverter API. Also includes an example of stacking encoders (in this case encryption and compression). Docs.

• Query Example: Demonstrates how to Query the state of a single Workflow Execution using the QueryWorkflow and SetQueryHandler APIs. Additional documentation: How to Query a Workflow Execution in Go.

• Selectors: Do not use the native Go select statement. Instead use Go SDK Selectors (selector.Select(ctx)) to maintain a deterministic Workflow. Can be seen in the Pick First, Mutex, DSL, and Timer examples.

• Sessions: Demonstrates how to bind a set of Activity Executions to a specific Worker after the first Activity executes. This feature is showcased in the File Processing example. Addition documentation: How to use Sessions in Go.

• Signals: Can be seen in the Recovery and Mutex examples. Additional documentation: eCommerce application tutorial, How to send a Signal to a Workflow Execution in Go, How to handle a Signal in a Workflow Execution in Go.

• Search Attributes: Demonstrates how to use custom Search Attributes that can be used to find Workflow Executions using predicates (must use with Elasticsearch).

• Timer Futures: The sample starts a long running order processing operation and starts a Timer (workflow.NewTimer()). If the processing time is too long, a notification email is "sent" to the user regarding the delay (the execution does not cancel). If the operation finishes before the Timer fires, then the Timer is cancelled.

• Tracing and Context Propagation: Demonstrates the client initialization with a context propagator, which propagates specific information in the context.Context object across the Workflow Execution. The context.Context object is populated with information prior to calling StartWorkflow. This example demonstrates that the information is available in the Workflow Execution and Activity Executions. Additional documentation: How to use tracing in Go.

• Updatable Timer: Demonstrates timer cancellation and use of a Selector to wait on a Future and a Channel simultaneously.

• Greetings: Demonstrates how to pass dependencies to activities defined as struct methods.

• Greetings Local: Demonstrates how to pass dependencies to local activities defined as struct methods.

• Interceptors: Demonstrates how to use interceptors to intercept calls, in this case for adding context to the logger.

Dynamic Workflow logic examples

These samples demonstrate some common control flow patterns using Temporal's Go SDK API.

• Dynamic Execution: Demonstrates how to execute Workflows and Activities using a name rather than a strongly typed function.

• Branching Acitivites: Executes multiple Activities in parallel. The number of branches is controlled by a parameter that is passed in at the start of the Workflow Execution.

• Exclusive Choice: Demonstrates how to execute Activities based on a dynamic input.

• Multi-Choice: Demonstrates how to execute multiple Activities in parallel based on a dynamic input.

• Mutex Workflow: Demonstrates the ability to lock/unlock a particular resource within a particular Temporal Namespace. In this examples the other Workflow Executions within the same Namespace wait until a locked resource is unlocked. This shows how to avoid race conditions or parallel mutually exclusive operations on the same resource.

• Parallel Workflow: This sample executes multiple branches in parallel using the workflow.Go() API.

• Pick First: This sample executes Activities in parallel branches, picks the result of the branch that completes first, and then cancels other Activities that have not finished.

• Split/Merge: Demonstrates how to use multiple Temporal coroutines, instead of native goroutines. This samples to processes chunks of a large work item in parallel, and then merges the intermediate results to generate the final result. Do not use native goroutines in Temporal Workflows. Instead, the coroutine provided by the workflow.Go API.

• Synchronous Proxy Workflow pattern: This sample demonstrates a synchronous interaction with a "main" Workflow Execution from a "proxy" Workflow Execution. The proxy Workflow Execution sends a Signal to the "main" Workflow Execution, then blocks, waiting for a Signal in response.

Scenario based examples

• DSL Workflow: Demonstrates how to implement a DSL-based Workflow. This sample contains 2 yaml files that each define a custom "workflow" which instructs the Temporal Workflow. This is useful if you want to build in a "low code" layer.

• Expense Request: This demonstrates how to process an expense request. This sample showcases how to complete an Activity Execution asynchronously.

• File Processing: Demonstrates how to download and process a file using set of Activities that run on the same host. Activities are executed to download a file from the web, store it locally on the host, and then "process it". This samples showcases how to handle a scenario where all subsequent Activities need to execute on the same host as the first Activity in the sequence. In Go, this is achieved by using the Session APIs.

• Particle Swarm Optimization: Demonstrates how to perform a long iterative math optimization process using particle swarm optimization (PSO). This sample showcases the use of parallel executions, ContinueAsNew for long histories, a Query API, and the use of a custom DataConverter for serialization.

• Prometheus Metrics: Demonstrates how to instrument Temporal with Prometheus and Uber's Tally library.

• Request/Response with Response Activities: Demonstrates how to accept requests via signals and use callback activities to push responses.

• Request/Response with Response Queries: Demonstrates how to accept requests via signals and use queries to poll for responses.

Pending examples

Mostly examples we haven't yet ported from https://github.com/temporalio/samples-java/

• Async activity calling: Example to be completed
• Async lambda: Example to be completed
• Periodic Workflow: Workflow that executes some logic periodically. Example to be completed
• Exception propagation and wrapping: Example to be completed
• Polymorphic activity: Example to be completed
• SAGA pattern: Example to be completed
• Side Effect: Example to be completed - Docs

Fixtures

These are edge case examples useful for Temporal internal development and bug reporting. See their readme for more details.