我有一個由多臺機器組成的網絡,并且我正在使用 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.機器上不需要注冊任何東西。
- 1 回答
- 0 關注
- 100 瀏覽
添加回答
舉報
0/150
提交
取消