aggregatedpool

Jul 4, 2024

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 LaFn func(ctx context.Context, hdr *commonpb.Header, args *commonpb.Payloads) (*commonpb.Payloads, error)

+ type LocalActivityFn struct

+ func NewLocalActivityFn(codec common.Codec, pool common.Pool, log *zap.Logger) *LocalActivityFn

+ func (la *LocalActivityFn) ExecuteLA(ctx context.Context, hdr *commonpb.Header, args *commonpb.Payloads) (*commonpb.Payloads, error)

+ type Workflow struct

+ func NewWorkflowDefinition(codec common.Codec, la LaFn, 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