Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 163 for save3_ (0.1 sec)

  1. cmd/metacache-server-pool.go

    	mc := o.newMetacache()
    	meta := metaCacheRPC{meta: &mc, cancel: cancel, rpc: globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)), o: *o}
    
    	// Save listing...
    	go func() {
    		if err := saver.saveMetaCacheStream(listCtx, &meta, saveCh); err != nil {
    			meta.setErr(err.Error())
    		}
    		cancel()
    	}()
    
    	// Do listing...
    	go func(o listPathOptions) {
    		err := z.listMerged(listCtx, o, inCh)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. tests/transaction_test.go

    	tx := DB.Begin()
    
    	user := *GetUser("transaction-save-point", Config{})
    	tx.Create(&user)
    
    	if err := tx.First(&User{}, "name = ?", user.Name).Error; err != nil {
    		t.Fatalf("Should find saved record")
    	}
    
    	if err := tx.SavePoint("save_point1").Error; err != nil {
    		t.Fatalf("Failed to save point, got error %v", err)
    	}
    
    	user1 := *GetUser("transaction-save-point-1", Config{})
    	tx.Create(&user1)
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. tests/hooks_test.go

    	DB.AutoMigrate(&Product{})
    
    	p := Product{Code: "Invalid", Price: 100}
    	if DB.Save(&p).Error == nil {
    		t.Fatalf("An error from before create callbacks happened when create with invalid value")
    	}
    
    	if DB.Where("code = ?", "Invalid").First(&Product{}).Error == nil {
    		t.Fatalf("Should not save record that have errors")
    	}
    
    	if DB.Save(&Product{Code: "dont_save", Price: 100}).Error == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. docs/en/docs/tutorial/dependencies/sub-dependencies.md

    * It also declares an optional `last_query` cookie, as a `str`.
        * If the user didn't provide any query `q`, we use the last query used, which we saved to a cookie before.
    
    ## Use the dependency
    
    Then we can use the dependency with:
    
    //// tab | Python 3.10+
    
    ```Python hl_lines="23"
    {!> ../../docs_src/dependencies/tutorial005_an_py310.py!}
    ```
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    			return index
    		}
    	}
    	return -1
    }
    
    // initRebalanceMeta initializes rebalance metadata for a new rebalance
    // operation and saves it in the object store.
    func (z *erasureServerPools) initRebalanceMeta(ctx context.Context, buckets []string) (arn string, err error) {
    	r := &rebalanceMeta{
    		ID:        shortuuid.New(),
    		PoolStats: make([]*rebalanceStats, len(z.serverPools)),
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/RepositoryCache.java

         */
        void put(RepositoryRequest request, Object key, Object data);
    
        /**
         * Gets the specified data from the cache. <strong>Warning:</strong> The cache will directly return the saved
         * reference. If the cached data is to be modified after its retrieval, the caller is responsible to create a copy
         * of the returned data and use this instead of the cache record.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. cmd/erasure.go

    					continue
    				}
    				scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update")
    				updates <- cache.clone()
    
    				lastSave = cache.Info.LastUpdate
    			case v, ok := <-bucketResults:
    				if !ok {
    					// Save final state...
    					cache.Info.NextCycle = wantCycle
    					cache.Info.LastUpdate = time.Now()
    					scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    // Save - saves the events to the store if queuestore is configured,
    // which will be replayed when the webhook connection is active.
    func (target *WebhookTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    		}
    		p.Pools[idx].LastUpdate = now
    		if err := p.save(ctx, pools); err != nil {
    			return false, err
    		}
    		return true, nil
    	}
    	return false, nil
    }
    
    func (p poolMeta) save(ctx context.Context, pools []*erasureSets) error {
    	if p.dontSave {
    		return nil
    	}
    	data := make([]byte, 4, p.Msgsize()+4)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. internal/event/target/nsq.go

    		if xnet.IsConnRefusedErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the nsq connection is active.
    func (target *NSQTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top