Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 156 for Ustat (0.06 sec)

  1. cmd/xl-storage-format-v1_gen.go

    			}
    		case "Format":
    			z.Format, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Format")
    				return
    			}
    		case "Stat":
    			err = z.Stat.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Stat")
    				return
    			}
    		case "Erasure":
    			err = z.Erasure.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Erasure")
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.VerifyFile(ctx, volume, path, fi)
    }
    
    func (d *naughtyDisk) StatInfoFile(ctx context.Context, volume, path string, glob bool) (stat []StatInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return stat, err
    	}
    	return d.disk.StatInfoFile(ctx, volume, path, glob)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/fakes_test.go

    	fs.ReadDirFS
    }
    type fakeFileFakeFds struct {
    	fs.File
    	fd uintptr
    }
    
    func (f *fakeFileFakeFds) Fd() uintptr {
    	return f.fd
    }
    
    func (f *fakeFileFakeFds) Stat() (fs.FileInfo, error) {
    	fi, err := f.File.Stat()
    	if err != nil {
    		return nil, err
    	}
    	return &fakeFileFakeFI{FileInfo: fi}, nil
    }
    
    type fakeFileFakeFI struct {
    	fs.FileInfo
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. helm/minio/templates/_helper_create_bucket.txt

    		STATUS=$?
    	done
    	set -e # reset `e` as active
    	return 0
    }
    
    # checkBucketExists ($bucket)
    # Check if the bucket exists, by using the exit code of `mc ls`
    checkBucketExists() {
    	BUCKET=$1
    	CMD=$(${MC} stat myminio/$BUCKET >/dev/null 2>&1)
    	return $?
    }
    
    # createBucket ($bucket, $policy, $purge)
    # Ensure bucket exists, purging if asked to
    createBucket() {
    	BUCKET=$1
    	POLICY=$2
    	PURGE=$3
    	VERSIONING=$4
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 12 18:18:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. cmd/metrics.go

    			prometheus.GaugeValue,
    			float64(stat.ReplicationStats.ReplicatedSize),
    			bucket,
    		)
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName("bucket", "replication", "received_size"),
    				"Total capacity replicated to this instance",
    				[]string{"bucket"}, nil),
    			prometheus.GaugeValue,
    			float64(stat.ReplicationStats.ReplicaSize),
    			bucket,
    		)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. src/archive/tar/tar_test.go

    	testenv.MustHaveSymlink(t)
    
    	tmpdir := t.TempDir()
    
    	link := filepath.Join(tmpdir, "link")
    	target := tmpdir
    	if err := os.Symlink(target, link); err != nil {
    		t.Fatal(err)
    	}
    	fi, err := os.Lstat(link)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	h, err := FileInfoHeader(fi, target)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if g, e := h.Name, fi.Name(); g != e {
    		t.Errorf("Name = %q; want %q", g, e)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  7. src/archive/zip/reader.go

    }
    
    type openDir struct {
    	e      *fileListEntry
    	files  []fileListEntry
    	offset int
    }
    
    func (d *openDir) Close() error               { return nil }
    func (d *openDir) Stat() (fs.FileInfo, error) { return d.e.stat() }
    
    func (d *openDir) Read([]byte) (int, error) {
    	return 0, &fs.PathError{Op: "read", Path: d.e.name, Err: errors.New("is a directory")}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. cmd/sftp-server-driver.go

    	if err != nil {
    		return nil, err
    	}
    
    	obj, err := clnt.GetObject(context.Background(), bucket, object, minio.GetObjectOptions{})
    	if err != nil {
    		return nil, err
    	}
    
    	_, err = obj.Stat()
    	if err != nil {
    		return nil, err
    	}
    
    	return obj, nil
    }
    
    // TransferError will catch network errors during transfer.
    // When TransferError() is called Close() will also
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics_gen.go

    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *QStat) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  10. internal/config/lambda/target/webhook.go

    	}
    	xhttp.DrainBody(resp.Body)
    	// No network failure i.e response from the target means its up
    	return true, nil
    }
    
    // Stat - returns lambda webhook target statistics such as
    // current calls in progress, successfully completed functions
    // failed functions.
    func (target *WebhookTarget) Stat() event.TargetStat {
    	return event.TargetStat{
    		ID:             target.id,
    		ActiveRequests: atomic.LoadInt64(&target.activeRequests),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top