Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for prepare (0.16 sec)

  1. internal/event/target/postgresql.go

    		if target.updateStmt, err = target.db.Prepare(fmt.Sprintf(psqlUpdateRow, target.args.Table)); err != nil {
    			return err
    		}
    		// delete statement
    		if target.deleteStmt, err = target.db.Prepare(fmt.Sprintf(psqlDeleteRow, target.args.Table)); err != nil {
    			return err
    		}
    	case event.AccessFormat:
    		// insert statement
    		if target.insertStmt, err = target.db.Prepare(fmt.Sprintf(psqlInsertRow, target.args.Table)); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  2. scan.go

    package gorm
    
    import (
    	"database/sql"
    	"database/sql/driver"
    	"reflect"
    	"time"
    
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils"
    )
    
    // prepareValues prepare values slice
    func prepareValues(values []interface{}, db *DB, columnTypes []*sql.ColumnType, columns []string) {
    	if db.Statement.Schema != nil {
    		for idx, name := range columns {
    			if field := db.Statement.Schema.LookUpField(name); field != nil {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Apr 26 09:53:11 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	f := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		r.RequestURI = r.URL.RequestURI()
    		apiRouter.ServeHTTP(w, r)
    	})
    	return bucketName, f, nil
    }
    
    // prepare test backend.
    // create FS/Erasure/ErasureSet backend.
    // return object layer, backend disks.
    func prepareTestBackend(ctx context.Context, instanceType string) (ObjectLayer, []string, error) {
    	switch instanceType {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/metrics-v3.go

    			)
    		}
    		mg.SetCache(metricsCache)
    		if mg.IsBucketMetricsGroup() {
    			bucketMGMap[mg.CollectorPath] = mg
    		} else {
    			mgMap[mg.CollectorPath] = mg
    		}
    	}
    
    	// Prepare to register the collectors. Other than `MetricGroup` collectors,
    	// we also have standard collectors like `GoCollector`.
    
    	// Create all Non-`MetricGroup` collectors here.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  5. cmd/jwt_test.go

    }
    
    // Tests web request authenticator.
    func TestWebRequestAuthenticate(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	creds := globalActiveCred
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:14 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  6. internal/logger/logger.go

    // unique set. data is expected to be pre-sorted, and the resulting set in
    // the range [0:size] will remain in sorted order. Uniq, following a
    // sort.Sort call, can be used to prepare arbitrary inputs for use as sets.
    func uniq(data sort.Interface) (size int) {
    	p, l := 0, data.Len()
    	if l <= 1 {
    		return l
    	}
    	for i := 1; i < l; i++ {
    		if !data.Less(p, i) {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    					defer wg.Done()
    					_ = disk.Delete(ctx, bucket, object, DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    				}(index, disk)
    			}
    			wg.Wait()
    		}
    	}
    
    	// Prepare object creation in all disks
    	for i, err := range errs {
    		drive := storageEndpoints[i].String()
    		switch err {
    		case nil:
    			hr.Before.Drives[i] = madmin.HealDriveInfo{Endpoint: drive, State: madmin.DriveStateOk}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/server-main.go

    	loadEnvVarsFromFiles()
    
    	// Handle all server command args and build the disks layout
    	bootstrapTrace("serverHandleCmdArgs", func() {
    		err := buildServerCtxt(ctx, &globalServerCtxt)
    		logger.FatalIf(err, "Unable to prepare the list of endpoints")
    
    		serverHandleCmdArgs(globalServerCtxt)
    	})
    
    	// DNS cache subsystem to reduce outgoing DNS requests
    	runDNSCache(ctx)
    
    	// Handle all server environment vars.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  9. cmd/erasure-sets.go

    		return madmin.HealResultItem{}, err
    	}
    
    	refFormat, err := getFormatErasureInQuorum(formats)
    	if err != nil {
    		return res, err
    	}
    
    	// Prepare heal-result
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemMetadata,
    		Detail:    "disk-format",
    		DiskCount: s.setCount * s.setDriveCount,
    		SetCount:  s.setCount,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top