为了账号安全,请及时绑定邮箱和手机立即绑定

Cadence 分别注册工作流程和活动

Cadence 分别注册工作流程和活动

Go
慕斯王 2022-05-18 14:39:02
我有一个由多台机器组成的网络,并且我正在使用 cadence go 客户端。机器 1 需要注册活动。// Machine 1 registering activitiesfunc sampleActivity(ctx context.Context) (string, error) {    logger := activity.GetLogger(ctx)    logger.Info("separate machines are handling this")    return "Activity machine succeeded"}func main() {     activity.RegisterWithOptions(sampleActivity, RegisterOptions{Name: "Machine1Activity"})}机器 2 需要注册工作流。// Machine 2 registering workflowsfunc sample_workflow(ctx workflow.Context, name string) (string, error) {     ...     err := workflow.ExecuteActivity(ctx, "Machine1Activity")     ...}func main() {    workflow.RegisterWithOptions(sampleWorkflow, "Machine2Workflow")}机器 3 需要启动才能启动工作流程。// Machine 3 starting the workflow// Prepare options and ctxclient.StartWorkflow(ctx, options, "Machine2Workflow", "Machine1Activity")cadence-fronted 服务在另一台机器上。如何使用 go 客户端执行此操作?寄存器是否也仅将工作流/活动保存在内存中?如何将它们推送到 cadence 服务,以便其他机器也可以找到它们。
查看完整描述

1 回答

?
Cats萌萌

TA贡献1805条经验 获得超9个赞

目前,注册对于特定的工作进程来说纯粹是本地的。我们计划在未来添加某种带有活动目录和工作流类型的元数据服务。

要在机器 1 上禁用工作流工作者,请指定WorkerOptions.DisableWorkflowWorker.

要在机器 2 上禁用活动工作者,请指定WorkerOptions.DisableActivityWorker.

3.机器上不需要注册任何东西。


查看完整回答
反对 回复 2022-05-18
  • 1 回答
  • 0 关注
  • 87 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号