Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 850 for objecten (0.1 sec)

  1. cmd/metrics.go

    				prometheus.BuildFQName(healMetricsNamespace, "objects", "scanned"),
    				"Objects scanned since uptime",
    				[]string{"type"}, nil),
    			prometheus.CounterValue,
    			float64(v), string(k),
    		)
    	}
    	for k, v := range bgSeq.getHealedItemsMap() {
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(healMetricsNamespace, "objects", "healed"),
    				"Objects healed since uptime",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"errors"
    
    	"github.com/zeebo/xxh3"
    )
    
    // getFileInfoVersions partitions this object's versions such that,
    //   - fivs.Versions has all the non-free versions
    //   - fivs.FreeVersions has all the free versions
    //
    // if inclFreeVersions is true all the versions are in fivs.Versions, free and non-free versions alike.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/untar.go

    						asyncErr = err
    					}
    					asyncErrMu.Unlock()
    				}
    			}(name, header.FileInfo(), b)
    			continue
    		}
    
    		// If zero or earlier modtime, set to current.
    		// Otherwise the resulting objects will be invalid.
    		if header.ModTime.UnixNano() <= 0 {
    			header.ModTime = time.Now()
    		}
    
    		// Sync upload.
    		rc := disconnectReader{r: tarReader}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. cmd/prepare-storage.go

    			m[err.Error()]--
    			m[err.Error()]--
    		}
    		m[err.Error()]++
    	}
    }()
    
    // Cleans up tmp directory of the local disk.
    func bgFormatErasureCleanupTmp(diskPath string) {
    	// Need to move temporary objects left behind from previous run of minio
    	// server to a unique directory under `minioMetaTmpBucket-old` to clean
    	// up `minioMetaTmpBucket` for the current run.
    	//
    	// /disk1/.minio.sys/tmp-old/
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. internal/s3select/jstream/decoder_test.go

    { "bio": "bada bing bada boom", "id": 5, "name": "Charles" }
    `
    	)
    
    	decoder := NewDecoder(mkReader(body), 0)
    
    	for mv = range decoder.Stream() {
    		if mv.ValueType != Object {
    			t.Fatalf("got %v value type, expected: Object value type", mv.ValueType)
    		}
    		counter++
    		t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value)
    	}
    	if err := decoder.Err(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. cmd/bucket-stats.go

    	} else {
    		bs.XferRateSml.addSize(sz, duration)
    	}
    }
    
    // RMetricName - name of replication metric
    type RMetricName string
    
    const (
    	// Large - objects larger than 128MiB
    	Large RMetricName = "Large"
    	// Small - objects smaller than 128MiB
    	Small RMetricName = "Small"
    	// Total - metric pertaining to totals
    	Total RMetricName = "Total"
    )
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers_test.go

    		owners = append(owners, fmt.Sprintf("node-%d", i))
    	}
    
    	// Simulate DeleteObjects of 10 objects in a single request. i.e same lock
    	// request UID, but 10 different resource names associated with it.
    	var lris []lockRequesterInfo
    	uuid := mustGetUUID()
    	for i := 0; i < 10; i++ {
    		resource := fmt.Sprintf("bucket/delete-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			Writer: true,
    			UID:    uuid,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. docs/en/docs/advanced/custom-response.md

    ```Python hl_lines="2  14"
    {!../../docs_src/custom_response/tutorial007.py!}
    ```
    
    #### Using `StreamingResponse` with file-like objects
    
    If you have a file-like object (e.g. the object returned by `open()`), you can create a generator function to iterate over that file-like object.
    
    That way, you don't have to read it all first in memory, and you can pass that generator function to the `StreamingResponse`, and return it.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users_test.go

    	c.Helper()
    
    	r, err := client.GetObject(ctx, bucket, object, minio.GetObjectOptions{})
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    	defer r.Close()
    
    	_, err = io.Copy(io.Discard, r)
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/expiration.go

    	// Indicates whether MinIO will remove all versions. If set to true, all versions will be deleted;
    	// if set to false the policy takes no action. This action uses the Days/Date to expire objects.
    	// This check is verified for latest version of the object.
    	DeleteAll Boolean `xml:"ExpiredObjectAllVersions"`
    
    	set bool
    }
    
    // MarshalXML encodes delete marker boolean into an XML form.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top