Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 781 - 790 of 1,099 for Fsync (0.04 seconds)

  1. docs_src/extra_models/tutorial002_py310.py

        user_in_db = UserInDB(**user_in.model_dump(), hashed_password=hashed_password)
        print("User saved! ..not really")
        return user_in_db
    
    
    @app.post("/user/", response_model=UserOut)
    async def create_user(user_in: UserIn):
        user_saved = fake_save_user(user_in)
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 20 15:55:38 GMT 2025
    - 798 bytes
    - Click Count (0)
  2. docs/fr/docs/tutorial/first-steps.md

    Ici, c'est une fonction asynchrone (définie avec `async def`).
    
    ---
    
    Vous pourriez aussi la définir comme une fonction classique plutôt qu'avec `async def` :
    
    {* ../../docs_src/first_steps/tutorial003.py hl[7] *}
    
    /// note
    
    Si vous ne connaissez pas la différence, allez voir la section [Concurrence : *"Vous êtes pressés ?"*](../async.md#vous-etes-presses){.internal-link target=_blank}.
    
    ///
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  3. cmd/bootstrap-peer-server.go

    	clnts := newBootstrapRESTClients(endpointServerPools, gm)
    	var onlineServers int
    	var offlineEndpoints []error
    	var incorrectConfigs []error
    	var retries int
    	var mu sync.Mutex
    	for onlineServers < len(clnts)/2 {
    		var wg sync.WaitGroup
    		wg.Add(len(clnts))
    		onlineServers = 0
    		for _, clnt := range clnts {
    			go func(clnt *bootstrapRESTClient) {
    				defer wg.Done()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 01 22:13:18 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  4. cmd/bucket-replication-stats.go

    	Cache             map[string]*BucketReplicationStats
    	mostRecentStats   BucketStatsMap
    	registry          metrics.Registry
    	sync.RWMutex                 // mutex for Cache
    	mostRecentStatsMu sync.Mutex // mutex for mostRecentStats
    
    	wlock sync.RWMutex // mutex for active workers
    
    	movingAvgTicker *time.Ticker // Ticker for calculating moving averages
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  5. docs_src/path_operation_configuration/tutorial004_py310.py

    class Item(BaseModel):
        name: str
        description: str | None = None
        price: float
        tax: float | None = None
        tags: set[str] = set()
    
    
    @app.post("/items/", response_model=Item, summary="Create an item")
    async def create_item(item: Item):
        """
        Create an item with all the information:
    
        - **name**: each item must have a name
        - **description**: a long description
        - **price**: required
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Jan 07 14:11:31 GMT 2022
    - 638 bytes
    - Click Count (0)
  6. internal/dsync/utils.go

    // GNU Affero General Public License for more details.
    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(minSleep, unit, maxSleep time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  7. cmd/site-replication-metrics.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"maps"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    )
    
    //go:generate msgp -file $GOFILE
    
    // RStat has replication error stats
    type RStat struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  8. schema/serializer.go

    package schema
    
    import (
    	"bytes"
    	"context"
    	"database/sql"
    	"database/sql/driver"
    	"encoding/gob"
    	"encoding/json"
    	"fmt"
    	"math"
    	"reflect"
    	"strings"
    	"sync"
    	"time"
    )
    
    var serializerMap = sync.Map{}
    
    // RegisterSerializer register serializer
    func RegisterSerializer(name string, serializer SerializerInterface) {
    	serializerMap.Store(strings.ToLower(name), serializer)
    }
    
    // GetSerializer get serializer
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:29:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. internal/config/lambda/event/targetlist.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"fmt"
    	"maps"
    	"net/http"
    	"strings"
    	"sync"
    )
    
    // Target - lambda target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Send(Event) (*http.Response, error)
    	Stat() TargetStat
    	Close() error
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  10. tests/prepared_stmt_test.go

    package tests_test
    
    import (
    	"context"
    	"errors"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestPreparedStmt(t *testing.T) {
    	tx := DB.Session(&gorm.Session{PrepareStmt: true})
    
    	if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok {
    		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
    	}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
Back to Top