interceptor

README

Interceptor Sample

This sample shows how to make a worker interceptor that intercepts workflow and activity GetLogger calls to customize the logger.

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 ./interceptor/worker

1. Run the following command to start the example

go run ./interceptor/starter

Notice the log output has the WorkflowStartTime/ActivityStartTime tags on the logs.

Documentation

Index

• func Activity(ctx context.Context, name string) (string, error)
• func NewWorkerInterceptor(options InterceptorOptions) interceptor.WorkerInterceptor
• func Workflow(ctx workflow.Context, name string) (string, error)
• type InterceptorOptions

Functions

func Activity

func Activity(ctx context.Context, name string) (string, error)

func NewWorkerInterceptor

func NewWorkerInterceptor(options InterceptorOptions) interceptor.WorkerInterceptor

func Workflow

func Workflow(ctx workflow.Context, name string) (string, error)

Types

type InterceptorOptions

type InterceptorOptions struct {
	GetExtraLogTagsForWorkflow func(workflow.Context) []interface{}
	GetExtraLogTagsForActivity func(context.Context) []interface{}
}