Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 906 for errh (0.03 sec)

  1. internal/logger/logger.go

    func CriticalIf(ctx context.Context, err error, errKind ...interface{}) {
    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    		panic(ErrCritical)
    	}
    }
    
    // FatalIf is similar to Fatal() but it ignores passed nil error
    func FatalIf(err error, msg string, data ...interface{}) {
    	if err == nil {
    		return
    	}
    	fatal(err, msg, data...)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. cmd/postpolicyform.go

    	}
    
    	d.DisallowUnknownFields()
    	if err := d.Decode(&rawPolicy); err != nil {
    		return PostPolicyForm{}, err
    	}
    
    	parsedPolicy := PostPolicyForm{}
    
    	// Parse expiry time.
    	parsedPolicy.Expiration, err = time.Parse(time.RFC3339Nano, rawPolicy.Expiration)
    	if err != nil {
    		return PostPolicyForm{}, err
    	}
    
    	// Parse conditions.
    	for _, val := range rawPolicy.Conditions {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. docs/iam/access-manager-plugin.go

    }
    
    func writeErrorResponse(w http.ResponseWriter, err error) {
    	w.WriteHeader(http.StatusBadRequest)
    	json.NewEncoder(w).Encode(map[string]string{
    		"error": fmt.Sprintf("%v", err),
    	})
    }
    
    type Result struct {
    	Result bool `json:"result"`
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponse(w, err)
    		return
    	}
    
    	var out bytes.Buffer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 08 17:15:20 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. tests/callbacks_test.go

    			}
    
    			if e, ok := v.(error); !ok || e != nil {
    				err = e
    			}
    		}
    
    		if len(data.err) > 0 && err == nil {
    			t.Errorf("callbacks tests #%v should got error %v, but not", idx+1, data.err)
    		} else if len(data.err) == 0 && err != nil {
    			t.Errorf("callbacks tests #%v should not got error, but got %v", idx+1, err)
    		}
    
    		if ok, msg := assertCallbacks(callbacks.Create(), data.results); !ok {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 26 03:33:36 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  5. cmd/object-api-deleteobject_test.go

    			if err != nil {
    				t.Log(oi)
    				t.Fatalf("%s : %s", instanceType, err.Error())
    			}
    		}
    
    		oi, err := obj.DeleteObject(context.Background(), testCase.bucketName, testCase.pathToDelete, ObjectOptions{})
    		if err != nil && !isErrObjectNotFound(err) {
    			t.Log(oi)
    			t.Errorf("Test %d: %s:  Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err)
    			continue
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. internal/config/batch/batch.go

    	if err != nil {
    		return cfg, err
    	}
    	if rduration < 0 {
    		return cfg, config.ErrInvalidBatchReplicationWorkersWait(nil)
    	}
    
    	kduration, err := time.ParseDuration(env.Get(EnvKeyRotationWorkersWait, kvs.GetWithDefault(KeyRotationWorkersWait, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    	if kduration < 0 {
    		return cfg, config.ErrInvalidBatchKeyRotationWorkersWait(nil)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. cmd/mrf.go

    			mw := msgp.NewWriter(w)
    			n, err := mw.Write(data[:])
    			if err != nil {
    				w.CloseWithError(err)
    				return
    			}
    			if n != len(data) {
    				w.CloseWithError(io.ErrShortWrite)
    				return
    			}
    			for item := range m.opCh {
    				err = item.EncodeMsg(mw)
    				if err != nil {
    					break
    				}
    			}
    			mw.Flush()
    			w.CloseWithError(err)
    		}()
    		return r
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. internal/config/etcd/etcd.go

    	cfg := Config{}
    	if err := config.CheckValidKeys(config.EtcdSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	endpoints := env.Get(EnvEtcdEndpoints, kvs.Get(Endpoints))
    	if endpoints == "" {
    		return cfg, nil
    	}
    
    	etcdEndpoints, etcdSecure, err := parseEndpoints(endpoints)
    	if err != nil {
    		return cfg, err
    	}
    
    	cfg.Enabled = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. internal/hash/reader.go

    				err := ChecksumMismatch{
    					Want: r.contentHash.Encoded,
    					Got:  base64.StdEncoding.EncodeToString(sum),
    				}
    				return n, err
    			}
    		}
    	}
    	if err != nil && err != io.EOF {
    		if v, ok := err.(etag.VerifyError); ok {
    			return n, BadDigest{
    				ExpectedMD5:   v.Expected.String(),
    				CalculatedMD5: v.Computed.String(),
    			}
    		}
    	}
    	return n, err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  10. cmd/fmt-gen.go

    	deploymentID := ctxt.String("deployment-id")
    	err := buildServerCtxt(ctxt, &globalServerCtxt)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	handleCommonArgs(globalServerCtxt)
    	pools, _, err := createServerEndpoints(globalMinioAddr, globalServerCtxt.Layout.pools, globalServerCtxt.Layout.legacy)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
Back to top