Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 858 for err (0.02 sec)

  1. cmd/background-newdisks-heal-ops_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "ID")
    				return
    			}
    		case "PoolIndex":
    			z.PoolIndex, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "PoolIndex")
    				return
    			}
    		case "SetIndex":
    			z.SetIndex, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "SetIndex")
    				return
    			}
    		case "DiskIndex":
    			z.DiskIndex, err = dc.ReadInt()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 20 15:42:49 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  2. internal/s3select/sql/aggregation.go

    		err = rt.Right.aggregateRow(r, tableAlias)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func (e *MultOp) aggregateRow(r Record, tableAlias string) error {
    	err := e.Left.aggregateRow(r, tableAlias)
    	if err != nil {
    		return err
    	}
    	for _, rt := range e.Right {
    		err = rt.Right.aggregateRow(r, tableAlias)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. cmd/untar.go

    	switch f := detect(bf); f {
    	case formatGzip:
    		gz, err := gzip.NewReader(bf)
    		if err != nil {
    			return err
    		}
    		defer gz.Close()
    		r = gz
    	case formatS2:
    		r = s2.NewReader(bf)
    	case formatZstd:
    		// Limit to 16 MiB per stream.
    		dec, err := zstd.NewReader(bf, zstd.WithDecoderMaxWindow(16<<20))
    		if err != nil {
    			return err
    		}
    		defer dec.Close()
    		r = dec
    	case formatBZ2:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    	if !h.kconfig.Enabled {
    		return nil
    	}
    	if err := h.validate(); err != nil {
    		return err
    	}
    	if h.kconfig.QueueDir != "" {
    		if err := h.initQueueStoreOnce.DoWithContext(ctx, h.initQueueStore); err != nil {
    			return err
    		}
    		return h.initKafkaOnce.Do(h.init)
    	}
    	if err := h.init(); err != nil {
    		return err
    	}
    	go h.startKafkaLogger()
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. tests/embedded_struct_test.go

    	}
    
    	DB.Migrator().DropTable(&HNPost{})
    	if err := DB.Migrator().AutoMigrate(&HNPost{}); err != nil {
    		t.Fatalf("failed to auto migrate, got error: %v", err)
    	}
    
    	DB.Create(&HNPost{BasePost: &BasePost{Title: "embedded_pointer_type"}})
    
    	var hnPost HNPost
    	if err := DB.First(&hnPost, "title = ?", "embedded_pointer_type").Error; err != nil {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. internal/dsync/lock-args_gen.go

    				var zb0002 uint8
    				zb0002, err = dc.ReadUint8()
    				if err != nil {
    					err = msgp.WrapError(err, "Code")
    					return
    				}
    				z.Code = ResponseCode(zb0002)
    			}
    		case "Err":
    			z.Err, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Err")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. cmd/httprange_test.go

    		rs, err := parseRequestRangeSpec(testCase.spec)
    		if err != nil {
    			if !testCase.errExpected || err == nil && testCase.errExpected {
    				t.Errorf("unexpected err: %v", err)
    			}
    			continue
    		}
    		h, err := rs.ToHeader()
    		if err != nil && !testCase.errExpected || err == nil && testCase.errExpected {
    			t.Errorf("expected error with invalid range: %v", err)
    		}
    		if h != testCase.spec {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun May 05 16:56:21 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  8. cmd/config-common.go

    	r, err := store.GetObjectNInfo(ctx, minioMetaBucket, configFile, nil, http.Header{}, opts)
    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  9. cmd/site-replication-utils_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "Version")
    				return
    			}
    		case "ss":
    			err = z.Status.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Status")
    				return
    			}
    		case "did":
    			z.DeplID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DeplID")
    				return
    			}
    		case "bkts":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  10. cmd/sts-handlers.go

    	}
    
    	if err := claims.populateSessionPolicy(r.Form); err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err)
    		return
    	}
    
    	secret, err := getTokenSigningKey()
    	if err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInternalError, err)
    		return
    	}
    	cred, err := auth.GetNewCredentialsWithMetadata(claims, secret)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
Back to top