func cdCreateRollout()

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
}