Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 309 for martin (0.11 sec)

  1. cmd/os-instrumented.go

    	atomic.AddUint64(&o.operations[s], 1)
    	o.latency[s].add(d)
    }
    
    func osTrace(s osMetric, startTime time.Time, duration time.Duration, path string, err error) madmin.TraceInfo {
    	var errStr string
    	if err != nil {
    		errStr = err.Error()
    	}
    	return madmin.TraceInfo{
    		TraceType: madmin.TraceOS,
    		Time:      startTime,
    		NodeName:  globalLocalNodeName,
    		FuncName:  "os." + s.String(),
    		Duration:  duration,
    		Path:      path,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. CHANGELOG/CHANGELOG-1.31.md

    filename | sha512 hash
    -------- | -----------
    [kubernetes-client-darwin-amd64.tar.gz](https://dl.k8s.io/v1.31.12/kubernetes-client-darwin-amd64.tar.gz) | ce201aad62761c2f5efce91a0f827e4eca0b8aae4ab43b95e8375b1aa2126397fd373e46385fa2f074bc213112764564c29ade3bf9d0d5b1d2fe8afaff88618a
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 19:49:57 UTC 2025
    - 429.6K bytes
    - Viewed (0)
  3. cmd/sts-handlers_test.go

    	}
    
    	// Validate that the client from sts creds can access the bucket.
    	c.mustListObjects(ctx, minioClient, bucket)
    
    	// Create an madmin client with user creds
    	userAdmClient, err := madmin.NewWithOptions(s.endpoint, &madmin.Options{
    		Creds:  cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken),
    		Secure: s.secure,
    	})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  4. cmd/background-heal-ops.go

    // failure error occurred.
    func healDiskFormat(ctx context.Context, objAPI ObjectLayer, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	res, err := objAPI.HealFormat(ctx, opts.DryRun)
    
    	// return any error, ignore error returned when disks have
    	// already healed.
    	if err != nil && err != errNoHealRequired {
    		return madmin.HealResultItem{}, err
    	}
    
    	return res, nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  5. cmd/site-replication-metrics.go

    }
    
    func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats {
    	if rt == nil {
    		return madmin.TimedErrStats{}
    	}
    	errCounts := make(map[string]int)
    	maps.Copy(errCounts, rt.ErrCounts)
    	minuteTotals := rt.LastMinute.getTotal()
    	hourTotals := rt.LastHour.getTotal()
    	return madmin.TimedErrStats{
    		LastMinute: madmin.RStat{
    			Count: float64(minuteTotals.N),
    			Bytes: minuteTotals.Size,
    		},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil {
    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  7. buildscripts/heal-manual.go

    	// New returns an MinIO Admin client object.
    	madmClnt, err := madmin.New(os.Args[1], os.Args[2], os.Args[3], false)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	opts := madmin.HealOpts{
    		Recursive: true,                  // recursively heal all objects at 'prefix'
    		Remove:    true,                  // remove content that has lost quorum and not recoverable
    		ScanMode:  madmin.HealNormalScan, // by default do not do 'deep' scanning
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 27 09:47:58 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. cmd/admin-bucket-handlers.go

    	case bucketLifecycleConfig:
    		st.Lifecycle = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketSSEConfig:
    		st.SSEConfig = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketTaggingConfig:
    		st.Tagging = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case bucketQuotaConfigFile:
    		st.Quota = madmin.MetaStatus{IsSet: true, Err: errMsg}
    	case objectLockConfig:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    		matchedPolicies, _ := filterPolicies(cache, strings.Join(policies, ","), bucket)
    		if len(matchedPolicies) > 0 {
    			result[k] = madmin.UserInfo{
    				PolicyName: matchedPolicies,
    				Status: func() madmin.AccountStatus {
    					if c.IsValid() {
    						return madmin.AccountEnabled
    					}
    					return madmin.AccountDisabled
    				}(),
    				MemberOf: cache.iamUserGroupMemberships[k].ToSlice(),
    			}
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 86.7K bytes
    - Viewed (0)
  10. cmd/warm-backend.go

    // checkWarmBackend on it.
    func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) {
    	switch tier.Type {
    	case madmin.S3:
    		d, err = newWarmBackendS3(*tier.S3, tier.Name)
    	case madmin.Azure:
    		d, err = newWarmBackendAzure(*tier.Azure, tier.Name)
    	case madmin.GCS:
    		d, err = newWarmBackendGCS(*tier.GCS, tier.Name)
    	case madmin.MinIO:
    		d, err = newWarmBackendMinIO(*tier.MinIO, tier.Name)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top