wfping

Documentation

Overview

Package wfping implements a simple temporal workflow with a trivial action and some signal processing. It is usefull to test if a temporal.io infrastructure service is up and running.

Index

• func PingActivity(ctx context.Context, value string) (string, error)
• func PingWorkflow(ctx workflow.Context, param string) (string, error)
• func Run(lg *log.Logger, temporaladress string) error

Functions

func PingActivity

func PingActivity(ctx context.Context, value string) (string, error)

PingActivity implements a dummy temporal activity

func PingWorkflow

func PingWorkflow(ctx workflow.Context, param string) (string, error)

PingWorkflow implements the Ping temporal Workflow

func Run

func Run(lg *log.Logger, temporaladress string) error

Run implements a testing workflow and runs it against the temporal.io server at temporaladress. It logs progress to lg.