工作流与活动

func OrderWorkflow(ctx workflow.Context, orderID string) error {
    ao := workflow.ActivityOptions{
        StartToCloseTimeout: 30 * time.Second,
        RetryPolicy: &temporal.RetryPolicy{
            InitialInterval: time.Second,
            MaximumAttempts: 5,
        },
    }
    ctx = workflow.WithActivityOptions(ctx, ao)

    if err := workflow.ExecuteActivity(ctx, ValidateOrderActivity, orderID).Get(ctx, nil); err != nil {
        return err
    }

    var paymentID string
    if err := workflow.ExecuteActivity(ctx, ChargePaymentActivity, orderID).Get(ctx, &paymentID); err != nil {
        return err
    }

    return workflow.ExecuteActivity(ctx, CreateShipmentActivity, orderID, paymentID).Get(ctx, nil)
}