helloworld

Documentation

Index

• func Greet(ctx workflow.Context, subject string) (string, error)
• func PickGreeting(ctx context.Context) (string, error)
• func RegisterWorkflowsAndActivities(r worker.Registry)
• func TestIntercept(ctx context.Context) (string, error)
• type Interceptor
  • func NewTestInterceptor() *Interceptor
  • func (i *Interceptor) InterceptClient(next interceptor.ClientOutboundInterceptor) interceptor.ClientOutboundInterceptor
  • func (i *Interceptor) InterceptWorkflow(ctx workflow.Context, next interceptor.WorkflowInboundInterceptor) interceptor.WorkflowInboundInterceptor
• type WorkflowInterceptor
  • func (i *WorkflowInterceptor) ExecuteWorkflow(ctx workflow.Context, in *interceptor.ExecuteWorkflowInput) (interface{}, error)
  • func (i *WorkflowInterceptor) Init(outbound interceptor.WorkflowOutboundInterceptor) error

Functions

func Greet

func Greet(ctx workflow.Context, subject string) (string, error)

Greet implements a Temporal workflow that returns a salutation for a given subject.

func PickGreeting

func PickGreeting(ctx context.Context) (string, error)

PickGreeting is a Temporal activity that returns some greeting text.

func RegisterWorkflowsAndActivities

func RegisterWorkflowsAndActivities(r worker.Registry)

func TestIntercept

func TestIntercept(ctx context.Context) (string, error)

Types

type Interceptor

type Interceptor struct {
	interceptor.InterceptorBase
}

func NewTestInterceptor

func NewTestInterceptor() *Interceptor

func (*Interceptor) InterceptClient

func (i *Interceptor) InterceptClient(next interceptor.ClientOutboundInterceptor) interceptor.ClientOutboundInterceptor

func (*Interceptor) InterceptWorkflow

func (i *Interceptor) InterceptWorkflow(ctx workflow.Context, next interceptor.WorkflowInboundInterceptor) interceptor.WorkflowInboundInterceptor

type WorkflowInterceptor

type WorkflowInterceptor struct {
	interceptor.WorkflowInboundInterceptorBase
}

func (*WorkflowInterceptor) ExecuteWorkflow

func (i *WorkflowInterceptor) ExecuteWorkflow(ctx workflow.Context, in *interceptor.ExecuteWorkflowInput) (interface{}, error)

func (*WorkflowInterceptor) Init

func (i *WorkflowInterceptor) Init(outbound interceptor.WorkflowOutboundInterceptor) error