Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 126 for save3_ (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. internal/event/target/kafka.go

    	brokers := target.client.Brokers()
    	if len(brokers) == 0 {
    		return false, store.ErrNotConnected
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the Kafka connection is active.
    func (target *KafkaTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		if target.batch != nil {
    			return target.batch.Add(eventData)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. internal/event/target/postgresql.go

    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active.
    func (target *PostgreSQLTarget) 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
    - 13.3K bytes
    - Viewed (0)
Back to top