in reference-architectures/cloud_deploy_flow/CloudFunctions/cloudDeployInteractions/main.go [109:124]
func cdCreateRollout(ctx context.Context, d deploy.CloudDeployClient, c *deploypb.CreateRolloutRequest) error {
// Initiate the rollout creation operation
rollout, err := d.CreateRollout(ctx, c)
if err != nil {
return fmt.Errorf("error creating rollout request: %v", err)
}
log.Printf("Created Rollout Request: %v", rollout.Name())
// Wait for the rollout operation to complete and check for errors
_, err = rollout.Wait(ctx)
if err != nil {
return fmt.Errorf("error on rollout operation: %v", err)
}
log.Printf("Create Rollout Operation Completed")
return nil
}