Function RetryWithRefreshedResource

pkg/resources/retry.go:33–46

RetryWithRefreshedResource updates the resource before invoking the cb

(
	ctx context.Context,
	cli client.Client,
	resource client.Object,
	cb func() error,
)

// RetryWithRefreshedResource updates the resource before invoking the cb
func RetryWithRefreshedResource(
	ctx context.Context,
	cli client.Client,
	resource client.Object,
	cb func() error,
) error {
	return retry.OnError(retry.DefaultBackoff, RetryAlways, func() error {
		if err := cli.Get(ctx, client.ObjectKeyFromObject(resource), resource); err != nil {
			return err
		}

		return cb()
	})
}