splitmerge

README

Steps to run this sample:

1. You need a Temporal service running. See details in README.md
2. Run the following command to start the worker

go run splitmerge/worker/main.go

1. Run the following command to start the example

go run splitmerge/starter/main.go

Documentation

Index

• type ChunkResult
  • func ChunkProcessingActivity(ctx context.Context, chunkID int) (result ChunkResult, err error)
  • func SampleSplitMergeWorkflow(ctx workflow.Context, workerCount int) (ChunkResult, error)

Types

type ChunkResult

type ChunkResult struct {
	NumberOfItemsInChunk int
	SumInChunk           int
}

ChunkResult contains the result for this sample

func ChunkProcessingActivity

func ChunkProcessingActivity(ctx context.Context, chunkID int) (result ChunkResult, err error)

func SampleSplitMergeWorkflow

func SampleSplitMergeWorkflow(ctx workflow.Context, workerCount int) (ChunkResult, error)

SampleSplitMergeWorkflow workflow definition