possible_retry_logic.go

type selectionFunc func(config.CPI) (string, error)
type reservationFunc func(config.CPI, string) (string, error)

func tryReservation(c config.CPI, choose selectionFunc, reserve reservationFunc) (string, error) {
	var cid string

Loop:
	for i := 0; i < maxRetries; i++ {
		nodeID, loopErr := choose(c)
		if loopErr != nil {
			//log loopErr
			continue
		}

		cid, loopErr = reserve(nodeID)
		if loopErr != nil {
			//log loopErr
			continue
		}

		if cid != "" {
			break Loop
		}

	}

	if cid == "" {
		return "", errors.New("unable to reserve node")
	}

	return cid, nil
}