testworker

Documentation

Index

• Constants
• func GreetingSample(ctx workflow.Context) (string, error)
• type Activities
  • func (a *Activities) GetGreeting() (string, error)
  • func (a *Activities) GetName() (string, error)
  • func (a *Activities) SayGreeting(greeting string, name string) (string, error)
• type Worker
  • func NewWorker(client client.Client) (*Worker, error)
  • func (w *Worker) Start() error
  • func (w *Worker) Stop()

Constants

const Taskqueue = "greetings"

Functions

func GreetingSample

func GreetingSample(ctx workflow.Context) (string, error)

GreetingSample workflow definition. This greetings sample workflow executes 3 activities in sequential. It gets greeting and name from 2 different activities, and then pass greeting and name as input to a 3rd activity to generate final greetings.

Types

type Activities

type Activities struct {
	Name     string
	Greeting string
}

func (*Activities) GetGreeting

func (a *Activities) GetGreeting() (string, error)

GetGreeting Activity.

func (*Activities) GetName

func (a *Activities) GetName() (string, error)

GetName Activity.

func (*Activities) SayGreeting

func (a *Activities) SayGreeting(greeting string, name string) (string, error)

SayGreeting Activity.

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(client client.Client) (*Worker, error)

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop()