Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ToErrorResponse (0.2 sec)

  1. cmd/site-replication-metrics.go

    	// failures seen since uptime
    	atomic.AddInt64(&rt.SinceUptime.Bytes, size)
    	atomic.AddInt64(&rt.SinceUptime.Count, 1)
    	rt.LastMinute.addsize(size)
    	rt.LastHour.addsize(size)
    	if err != nil && minio.ToErrorResponse(err).Code == "AccessDenied" {
    		if rt.ErrCounts == nil {
    			rt.ErrCounts = make(map[string]int)
    		}
    		rt.ErrCounts["AccessDenied"]++
    	}
    }
    
    func (rt *RTimedMetrics) merge(o RTimedMetrics) (n RTimedMetrics) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  2. cmd/ftp-server-driver.go

    			info:  minio.ObjectInfo{Key: bucket},
    			isDir: true,
    		}, nil
    	}
    
    	objInfo, err := clnt.StatObject(context.Background(), bucket, object, minio.StatObjectOptions{})
    	if err != nil {
    		if minio.ToErrorResponse(err).Code == "NoSuchKey" {
    			// dummy return to satisfy LIST (stat -> list) behavior.
    			return &minioFileInfo{
    				p:     pathClean(object),
    				info:  minio.ObjectInfo{Key: object},
    				isDir: true,
    			}, nil
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/sftp-server-driver.go

    				info:  minio.ObjectInfo{Key: bucket},
    				isDir: true,
    			}}, nil
    		}
    
    		objInfo, err := clnt.StatObject(context.Background(), bucket, object, minio.StatObjectOptions{})
    		if err != nil {
    			if minio.ToErrorResponse(err).Code == "NoSuchKey" {
    				// dummy return to satisfy LIST (stat -> list) behavior.
    				return listerAt{&minioFileInfo{
    					p:     pathClean(object),
    					info:  minio.ObjectInfo{Key: object},
    					isDir: true,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 12:23:42 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	} else {
    		_, rinfo.Err = c.PutObject(ctx, tgt.Bucket, object, r, size, "", "", putOpts)
    	}
    	if rinfo.Err != nil {
    		if minio.ToErrorResponse(rinfo.Err).Code != "PreconditionFailed" {
    			rinfo.ReplicationStatus = replication.Failed
    			replLogIf(ctx, fmt.Errorf("unable to replicate for object %s/%s(%s): to (target: %s): %w",
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
  5. cmd/batch-handlers.go

    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts)
    				success := true
    				if err := r.ReplicateToTarget(ctx, api, c, result, retry); err != nil {
    					if miniogo.ToErrorResponse(err).Code == "PreconditionFailed" {
    						// pre-condition failed means we already have the object copied over.
    						return
    					}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  6. cmd/bucket-targets.go

    		return BucketRemoteTargetNotFound{Bucket: tgt.TargetBucket, Err: err}
    	}
    	// validate if target credentials are ok
    	exists, err := clnt.BucketExists(ctx, tgt.TargetBucket)
    	if err != nil {
    		switch minio.ToErrorResponse(err).Code {
    		case "NoSuchBucket":
    			return BucketRemoteTargetNotFound{Bucket: tgt.TargetBucket, Err: err}
    		case "AccessDenied":
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
Back to top