aggregatedpool

May 28, 2022

Changes in this version

+ func GetWorkerInfo(c Codec, p pool.Pool, rrVersion string, wi *[]*internal.WorkerInfo) error

+ func GrabActivities(wi []*internal.WorkerInfo) map[string]*internal.ActivityInfo

+ func GrabWorkflows(wi []*internal.WorkerInfo) map[string]*internal.WorkflowInfo

+ func InitWorkers(wDef *Workflow, actDef *Activity, wi []*internal.WorkerInfo, log *zap.Logger, ...) ([]worker.Worker, error)

May 14, 2022

Changes in this version

+ const RrMetricName

+ const RrWorkflowsMetricName

+ func Init(wDef *Workflow, actDef *Activity, p pool.Pool, c Codec, log *zap.Logger, ...) ([]worker.Worker, map[string]internal.WorkflowInfo, []string, error)

+ type Activity struct

+ func NewActivityDefinition(ac Codec, p pool.Pool, log *zap.Logger, dc converter.DataConverter, ...) *Activity

+ func (a *Activity) GetActivityContext(taskToken []byte) (context.Context, error)

+ type Callback func() error

+ type Codec interface

+ Decode func(pld *payload.Payload, msg *[]*internal.Message) error

+ DecodeWorkerInfo func(p *payload.Payload, wi *[]*internal.WorkerInfo) error

+ Encode func(ctx *internal.Context, p *payload.Payload, msg ...*internal.Message) error

+ type Workflow struct

+ func NewWorkflowDefinition(codec Codec, dc converter.DataConverter, pool pool.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