Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 938 for Nil (0.04 sec)

  1. clause/insert_test.go

    	}{
    		{
    			[]clause.Interface{clause.Insert{}},
    			"INSERT INTO `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Insert{Modifier: "LOW_PRIORITY"}},
    			"INSERT LOW_PRIORITY INTO `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Insert{Table: clause.Table{Name: "products"}, Modifier: "LOW_PRIORITY"}},
    			"INSERT LOW_PRIORITY INTO `products`", nil,
    		},
    	}
    
    	for idx, result := range results {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 737 bytes
    - Viewed (0)
  2. cmd/xl-storage-free-version_test.go

    	fivs, err := x.ListVersions(volume, path, true)
    	if err != nil {
    		return nil, err
    	}
    	n := 0
    	for _, fiv := range fivs {
    		if fiv.TierFreeVersion() {
    			fivs[n] = fiv
    			n++
    		}
    	}
    	fivs = fivs[:n]
    	return fivs, nil
    }
    
    func TestFreeVersion(t *testing.T) {
    	fatalErr := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. src/archive/zip/zip_test.go

    		if err != nil {
    			t.Fatal("write chunk:", err)
    		}
    	}
    	end := []byte("END\n")
    	_, err = f.Write(end)
    	if err != nil {
    		t.Fatal("write end:", err)
    	}
    	if err := w.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// read back zip file and check that we get to the end of it
    	r, err := NewReader(buf, buf.Size())
    	if err != nil {
    		t.Fatal("reader:", err)
    	}
    	f0 := r.File[0]
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "Path")
    				return
    			}
    		case "Endpoint":
    			z.Endpoint, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Endpoint")
    				return
    			}
    		case "Started":
    			z.Started, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "Started")
    				return
    			}
    		case "LastUpdate":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 15:42:49 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  5. cmd/metacache_gen.go

    		return
    	}
    	err = en.WriteString(z.bucket)
    	if err != nil {
    		err = msgp.WrapError(err, "bucket")
    		return
    	}
    	// write "flt"
    	err = en.Append(0xa3, 0x66, 0x6c, 0x74)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.filter)
    	if err != nil {
    		err = msgp.WrapError(err, "filter")
    		return
    	}
    	// write "id"
    	err = en.Append(0xa2, 0x69, 0x64)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 08 18:26:08 UTC 2021
    - 10K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users-race_test.go

    	if err != nil {
    		c.Fatalf("policy add error: %v", err)
    	}
    
    	userCount := 50
    	accessKeys := make([]string, userCount)
    	secretKeys := make([]string, userCount)
    	for i := 0; i < userCount; i++ {
    		accessKey, secretKey := mustGenerateCredentials(c)
    		err = s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    		if err != nil {
    			c.Fatalf("Unable to set user: %v", err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. internal/logger/targets.go

    // list of enabled loggers
    func AddSystemTarget(ctx context.Context, t Target) error {
    	if err := t.Init(ctx); err != nil {
    		return err
    	}
    
    	if consoleTgt == nil {
    		if t.Type() == types.TargetConsole {
    			consoleTgt = t
    		}
    	}
    
    	systemTargets.add(t)
    	return nil
    }
    
    func initKafkaTargets(ctx context.Context, cfgMap map[string]kafka.Config) ([]Target, []error) {
    	tgts := []Target{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. clause/locking_test.go

    			"SELECT * FROM `users` FOR UPDATE", nil,
    		},
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthShare, Table: clause.Table{Name: clause.CurrentTable}}},
    			"SELECT * FROM `users` FOR SHARE OF `users`", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:32:56 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  9. cmd/server_test.go

    	c.Assert(err, nil)
    
    	// execute the HTTP request.
    	response, err = s.client.Do(request)
    
    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	request, err = newTestSignedRequest(http.MethodGet, getGetObjectURL(s.endPoint, bucketName, "my-object-directory/"),
    		0, nil, s.accessKey, s.secretKey, s.signer)
    	c.Assert(err, nil)
    
    	// execute the HTTP request.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  10. internal/event/target/amqp.go

    		}
    
    		// close when we know this is a network error.
    		target.conn.Close()
    	}
    
    	conn, err = amqp091.Dial(target.args.URL.String())
    	if err != nil {
    		if xnet.IsConnRefusedErr(err) {
    			return nil, nil, store.ErrNotConnected
    		}
    		return nil, nil, err
    	}
    
    	ch, err = conn.Channel()
    	if err != nil {
    		return nil, nil, err
    	}
    
    	target.conn = conn
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top