Versions in this module Expand all Collapse all v3 v3.0.0 Jan 10, 2023 Changes in this version + const RrMetricName + const RrWorkflowsMetricName + func NewWorkerInterceptor() interceptor.WorkerInterceptor + func TemporalWorkers(wDef *Workflow, actDef *Activity, wi []*internal.WorkerInfo, log *zap.Logger, ...) ([]worker.Worker, error) + type Activity struct + func NewActivityDefinition(ac common.Codec, p common.Pool, log *zap.Logger) *Activity + func (a *Activity) GetActivityContext(taskToken []byte) (context.Context, error) + type Callback func() error + type LocalActivityFn struct + func NewLocalActivityFn(header *commonpb.Header, codec common.Codec, pool common.Pool, log *zap.Logger) *LocalActivityFn + type Workflow struct + func NewWorkflowDefinition(codec common.Codec, pool common.Pool, log *zap.Logger) *Workflow + func (wp *Workflow) Close() + func (wp *Workflow) Execute(env bindings.WorkflowEnvironment, header *commonpb.Header, ...) + func (wp *Workflow) NewWorkflowDefinition() bindings.WorkflowDefinition + func (wp *Workflow) OnWorkflowTaskStarted(t time.Duration) + func (wp *Workflow) StackTrace() string Other modules containing this package github.com/temporalio/roadrunner-temporal github.com/temporalio/roadrunner-temporal/v2 github.com/temporalio/roadrunner-temporal/v4 github.com/temporalio/roadrunner-temporal/v5
Go to main page