- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 76 for Stat (0.37 sec)
-
cmd/peer-s3-client.go
result = append(result, bi) } sort.Slice(result, func(i, j int) bool { return result[i].Name < result[j].Name }) return result, nil } // GetBucketInfo returns bucket stat info about bucket on disk across all peers func (sys *S3PeerSys) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (binfo BucketInfo, err error) { g := errgroup.WithNErrs(len(sys.peerClients))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
internal/kms/kes.go
_ KeyManager = (*kesClient)(nil) _ IdentityManager = (*kesClient)(nil) _ PolicyManager = (*kesClient)(nil) ) // Stat returns the current KES status containing a // list of KES endpoints and the default key ID. func (c *kesClient) Stat(ctx context.Context) (Status, error) { c.lock.RLock() defer c.lock.RUnlock() st, err := c.client.Status(ctx) if err != nil { return Status{}, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
}) return err } processedFiles := map[string]bool{} for _, filename := range filenames { var isDir bool if filename != "-" { fi, err := os.Stat(filename) if err != nil { errs = multierror.Append(errs, fmt.Errorf("cannot stat file %q: %v", filename, err)) continue } isDir = fi.IsDir() } if !isDir { processFile(filename) processedFiles[filename] = true
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
cmd/erasure-healing_test.go
t.Fatal(err) } // This would create the bucket. _, err = obj.HealBucket(ctx, bucket, madmin.HealOpts{ DryRun: false, Remove: false, }) if err != nil { t.Fatal(err) } // Stat the bucket to make sure that it was created. _, err = er.getDisks()[0].StatVol(context.Background(), bucket) if err != nil { t.Fatal(err) } } // Tests both object and bucket healing.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 47.6K bytes - Viewed (0) -
android/guava/src/com/google/common/math/PairedStatsAccumulator.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class PairedStatsAccumulator { // These fields must satisfy the requirements of PairedStats' constructor as well as those of the // stat methods of this class. private final StatsAccumulator xStats = new StatsAccumulator(); private final StatsAccumulator yStats = new StatsAccumulator(); private double sumOfProductsOfDeltas = 0.0;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 17:02:53 GMT 2023 - 10.3K bytes - Viewed (0) -
src/archive/tar/tar_test.go
t.Errorf("test %d, inverseSparseEntries():\ngot %v\nwant %v", i, gotInverted, v.wantInverted) } } } func TestFileInfoHeader(t *testing.T) { fi, err := os.Stat("testdata/small.txt") if err != nil { t.Fatal(err) } h, err := FileInfoHeader(fi, "") if err != nil { t.Fatalf("FileInfoHeader: %v", err) } if g, e := h.Name, "small.txt"; g != e {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
cmd/metacache-walk.go
legacy := s.formatLegacy s.RUnlock() // Verify if volume is valid and it exists. volumeDir, err := s.getVolDir(opts.Bucket) if err != nil { return err } if !skipAccessChecks(opts.Bucket) { // Stat a volume entry. if err = Access(volumeDir); err != nil { return convertAccessError(err, errVolumeAccessDenied) } } // Use a small block size to start sending quickly w := newMetacacheWriter(wr, 16<<10)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cni/test/install_cni.go
} // checkBinDir verifies the presence/absence of test files. func checkBinDir(t *testing.T, tempCNIBinDir, op string, files ...string) error { t.Helper() for _, f := range files { if _, err := os.Stat(tempCNIBinDir + "/" + f); !os.IsNotExist(err) { if op == "add" { t.Logf("PASS: File %v was added to %v", f, tempCNIBinDir) return nil } else if op == "del" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
func (m *rateMeasurement) getExpMovingAvgBytesPerSecond() float64 { m.lock.Lock() defer m.lock.Unlock() return m.expMovingAvg } // ActiveWorkerStat is stat for active replication workers type ActiveWorkerStat struct { Curr int `json:"curr"` Avg float32 `json:"avg"` Max int `json:"max"` hist metrics.Histogram }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0)