Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 1,142 for Append (0.05 sec)

  1. cmd/batch-expire.go

    				if exp.ExpireAll {
    					toExpireAll = append(toExpireAll, exp.ObjectInfo)
    					continue
    				}
    				// Cache ObjectInfo value via pointers for
    				// subsequent use to track objects which
    				// couldn't be deleted.
    				od := ObjectToDelete{
    					ObjectV: ObjectV{
    						ObjectName: exp.Name,
    						VersionID:  exp.VersionID,
    					},
    				}
    				toDel = append(toDel, od)
    				oiCache.Add(od, &exp.ObjectInfo)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/lex/stack.go

    // it resumes reading the next one down.
    type Stack struct {
    	tr []TokenReader
    }
    
    // Push adds tr to the top (end) of the input stack. (Popping happens automatically.)
    func (s *Stack) Push(tr TokenReader) {
    	s.tr = append(s.tr, tr)
    }
    
    func (s *Stack) Next() ScanToken {
    	tos := s.tr[len(s.tr)-1]
    	tok := tos.Next()
    	for tok == scanner.EOF && len(s.tr) > 1 {
    		tos.Close()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jan 09 22:33:23 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  3. cmd/listen-notification-handlers.go

    		eventName, err := event.ParseName(s)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. docs/debugging/reorder-disks/main.go

    	if node == "" {
    		for index, e := range exp {
    			result = append(result, localDisk{index: index, path: strings.Join(e, "")})
    		}
    	} else {
    		for index, e := range exp {
    			u, err := url.Parse(strings.Join(e, ""))
    			if err != nil {
    				return nil, err
    			}
    			if strings.Contains(u.Host, node) {
    				result = append(result, localDisk{index: index, path: u.Path})
    			}
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    		return metaCacheEntriesSorted{}, io.EOF
    	}
    
    	if r.current.name != "" {
    		if (inclDeleted || !r.current.isLatestDeletemarker()) && r.current.hasPrefix(prefix) && (inclDirs || r.current.isObject()) {
    			res = append(res, r.current)
    		}
    		r.current.name = ""
    		r.current.metadata = nil
    	}
    
    	for n < 0 || len(res) < n {
    		if more, err := r.mr.ReadBool(); !more {
    			switch err {
    			case nil:
    				r.err = io.EOF
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  6. src/archive/zip/fuzz_test.go

    		}
    		files := []file{}
    
    		for _, f := range r.File {
    			fr, err := f.Open()
    			if err != nil {
    				continue
    			}
    			content, err := io.ReadAll(fr)
    			if err != nil {
    				continue
    			}
    			files = append(files, file{header: &f.FileHeader, content: content})
    			if _, err := r.Open(f.Name); err != nil {
    				continue
    			}
    		}
    
    		// If we were unable to read anything out of the archive don't
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 13 18:06:33 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/ecds_test.go

    	var rm json.RawMessage = gotOut.Bytes()
    	jsonOutput, err := json.MarshalIndent(rm, "", "    ")
    	if err != nil {
    		assert.NoError(t, err)
    	}
    	jsonOutput = append(jsonOutput, '\n')
    
    	util.CompareContent(t, jsonOutput, "testdata/ecds/output.json")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 13 01:08:07 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  8. clause/clause_test.go

    		stmt          = gorm.Statement{DB: db, Table: user.Table, Schema: user, Clauses: map[string]clause.Clause{}}
    	)
    
    	for _, c := range clauses {
    		if _, ok := buildNamesMap[c.Name()]; !ok {
    			buildNames = append(buildNames, c.Name())
    			buildNamesMap[c.Name()] = true
    		}
    
    		stmt.AddClause(c)
    	}
    
    	stmt.Build(buildNames...)
    
    	if strings.TrimSpace(stmt.SQL.String()) != result {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 02:50:38 UTC 2020
    - 1012 bytes
    - Viewed (0)
  9. cmd/metrics-resource.go

    	name := rm.Name
    	metrics := make([]MetricV2, 0, 3)
    	metrics = append(metrics, MetricV2{
    		Description:    getResourceMetricDescription(subSys, name, help),
    		Value:          rm.Current,
    		VariableLabels: cloneMSS(rm.Labels),
    	})
    
    	if requireAvgMax {
    		avgName := MetricName(fmt.Sprintf("%s_avg", name))
    		avgHelp := fmt.Sprintf("%s (avg)", help)
    		metrics = append(metrics, MetricV2{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. internal/s3select/sql/value_test.go

    			b := valueBuilders[j]()
    			tests = append(tests, test{
    				name: fmt.Sprint(a.GetTypeString(), "==", b.GetTypeString()),
    				fields: fields{
    					a: *a, b: *b,
    				},
    				wantOk: i == j,
    			})
    		}
    	}
    	for i := range valueBuilders {
    		a := valueBuilders[i]()
    		for j := range altValueBuilders {
    			b := altValueBuilders[j]()
    			tests = append(tests, test{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 12.5K bytes
    - Viewed (0)
Back to top