Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 108 for index (0.04 sec)

  1. internal/event/target/elasticsearch.go

    func (c *esClientV7) updateEntry(ctx context.Context, index string, key string, eventData event.Event) error {
    	doc := map[string]interface{}{
    		"Records": []event.Event{eventData},
    	}
    	var buf bytes.Buffer
    	enc := json.NewEncoder(&buf)
    	err := enc.Encode(doc)
    	if err != nil {
    		return err
    	}
    	res, err := c.Index(
    		index,
    		&buf,
    		c.Index.WithDocumentID(key),
    		c.Index.WithContext(ctx),
    	)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils_test.go

    	shuffledDisks := shuffleDisks(disks, distribution)
    	// From the "distribution" above you can notice that:
    	// 1st data block is in the 9th disk (i.e distribution index 8)
    	// 2nd data block is in the 8th disk (i.e distribution index 7) and so on.
    	if shuffledDisks[0] != disks[8] ||
    		shuffledDisks[1] != disks[7] ||
    		shuffledDisks[2] != disks[9] ||
    		shuffledDisks[3] != disks[6] ||
    		shuffledDisks[4] != disks[10] ||
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. cmd/api-response.go

    	for index, commonPrefix := range multipartsInfo.CommonPrefixes {
    		listMultipartUploadsResponse.CommonPrefixes[index] = CommonPrefix{
    			Prefix: s3EncodeName(commonPrefix, encodingType),
    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    	for index, upload := range multipartsInfo.Uploads {
    		newUpload := Upload{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    			// No ellipses pattern. Anonymize host name from every pool arg
    			pools := strings.Fields(poolsArgs)
    			anonPools = make([]string, len(pools))
    			for index, arg := range pools {
    				anonPools[index] = anonAddr(arg)
    			}
    			return cmdLineWithoutPools + strings.Join(anonPools, " ")
    		}
    
    		// Ellipses pattern in pool args. Regex groups:
    		// 1 - server prefix
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    	g := errgroup.WithNErrs(len(storageDisks))
    
    	// Write `format.json` to all disks.
    	for index := range storageDisks {
    		index := index
    		g.Go(func() error {
    			if formats[index] == nil {
    				return errDiskNotFound
    			}
    			return saveFormatErasure(storageDisks[index], formats[index], "")
    		}, index)
    	}
    
    	// Wait for the routines to finish.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  6. cmd/lceventsrc_string.go

    // Code generated by "stringer -type lcEventSrc -trimprefix lcEventSrc_ bucket-lifecycle-audit.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[lcEventSrc_None-0]
    	_ = x[lcEventSrc_Heal-1]
    	_ = x[lcEventSrc_Scanner-2]
    	_ = x[lcEventSrc_Decom-3]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 01 15:56:24 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/action_string.go

    // Code generated by "stringer -type Action lifecycle.go"; DO NOT EDIT.
    
    package lifecycle
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[NoneAction-0]
    	_ = x[DeleteAction-1]
    	_ = x[DeleteVersionAction-2]
    	_ = x[TransitionAction-3]
    	_ = x[TransitionVersionAction-4]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	// Iterate through all the modTimes and count the FileInfo(s) with latest time.
    	for index, t := range modTimes {
    		if partsMetadata[index].IsValid() && t.Equal(modTime) {
    			latestFileInfo = partsMetadata[index]
    			count++
    		}
    	}
    
    	if !latestFileInfo.IsValid() {
    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	if count < latestFileInfo.Erasure.DataBlocks {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. cmd/erasure-decode.go

    	tmp := make([]io.ReaderAt, len(p.orgReaders))
    	copy(tmp, p.orgReaders)
    	p.readers = tmp
    	// next is the next non-preferred index.
    	next := 0
    	for i, ok := range prefer {
    		if !ok || p.readers[i] == nil {
    			continue
    		}
    		if i == next {
    			next++
    			continue
    		}
    		// Move reader with index i to index next.
    		// Do this by swapping next and i
    		p.readers[next], p.readers[i] = p.readers[i], p.readers[next]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    	nSets := make([]int, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		index := index
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    		pool := z.serverPools[index]
    		nSets[index] = pool.setCount
    		g.Go(func() error {
    			// Get the set where it would be placed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top