Search Options

Results per page
Sort
Preferred Languages
Advance

Results 931 - 940 of 1,020 for err (0.07 sec)

  1. cmd/bucket-lifecycle-handlers_test.go

    		// construct HTTP request
    		req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
    			int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil)
    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed to create HTTP request for GetBucketLocationHandler: <ERROR> %v", i+1, instanceType, err)
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. cmd/metrics-v3-bucket-replication.go

    	if globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    	bucketReplStats := globalReplicationStats.Load().getAllLatest(dataUsageInfo.BucketsUsage)
    	for _, bucket := range buckets {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. cmd/generic-handlers_test.go

    )
    
    // Tests request guess function for net/rpc requests.
    func TestGuessIsRPC(t *testing.T) {
    	if guessIsRPCReq(nil) {
    		t.Fatal("Unexpected return for nil request")
    	}
    
    	u, err := url.Parse("http://localhost:9000/minio/lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	r := &http.Request{
    		Proto:  "HTTP/1.0",
    		Method: http.MethodPost,
    		URL:    u,
    	}
    	if !guessIsRPCReq(r) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. internal/http/transports.go

    	transport := s.NewHTTPTransportWithTimeout(1 * time.Minute)
    	if clientCert != "" && clientKey != "" {
    		c, err := certs.NewManager(ctx, clientCert, clientKey, tls.LoadX509KeyPair)
    		if err != nil {
    			return nil, err
    		}
    		if c != nil {
    			c.UpdateReloadDuration(10 * time.Second)
    			c.ReloadOnSignal(syscall.SIGHUP) // allow reloads upon SIGHUP
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. internal/kms/conn.go

    		KeyID      string `json:"keyid"`
    		Version    uint32 `json:"version"`
    		Ciphertext []byte `json:"ciphertext"`
    	}
    	var v JSON
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(text, &v); err != nil {
    		return err
    	}
    	d.KeyID, d.Version, d.Plaintext, d.Ciphertext = v.KeyID, int(v.Version), nil, v.Ciphertext
    	return nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. cmd/erasure-common.go

    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			if disks[i] == nil {
    				return
    			}
    			di, err := disks[i].DiskInfo(context.Background(), DiskInfoOptions{})
    			if err != nil || di.Healing {
    				// - Do not consume disks which are not reachable
    				//   unformatted or simply not accessible for some reason.
    				//
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. internal/rest/rpc-stats.go

    		},
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    		},
    		ConnectDone: func(network, addr string, err error) {
    			if err == nil {
    				atomic.StoreInt64(&dialEnd, time.Now().UnixNano())
    			}
    		},
    	}
    
    	return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. cmd/policy_test.go

    	}{
    		{case1Policy, case1Result, false},
    		{case2Policy, case2Result, false},
    		{case3Policy, nil, true},
    	}
    
    	for i, testCase := range testCases {
    		result, err := PolicyToBucketAccessPolicy(testCase.bucketPolicy)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v\n", i+1, testCase.expectErr, expectErr)
    		}
    
    		if !testCase.expectErr {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. cmd/update-notifier.go

    	maxContentWidth := max(line1Length, line2Length)
    
    	// termWidth is set to a default one to use when we are
    	// not able to calculate terminal width via OS syscalls
    	termWidth := 25
    	if width, err := pb.GetTerminalWidth(); err == nil {
    		termWidth = width
    	}
    
    	// Box cannot be printed if terminal width is small than maxContentWidth
    	if maxContentWidth > termWidth {
    		return "\n" + line1InColor + "\n" + line2InColor + "\n\n"
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. internal/logger/target/console/console.go

    func (c *Target) Send(e interface{}) error {
    	entry, ok := e.(log.Entry)
    	if !ok {
    		return fmt.Errorf("Uexpected log entry structure %#v", e)
    	}
    	if logger.IsJSON() {
    		logJSON, err := json.Marshal(&entry)
    		if err != nil {
    			return err
    		}
    		fmt.Fprintln(c.output, string(logJSON))
    		return nil
    	}
    
    	if entry.Level == logger.EventKind {
    		fmt.Fprintln(c.output, entry.Message)
    		return nil
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.9K bytes
    - Viewed (0)
Back to top