Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for Newport (0.15 sec)

  1. cmd/admin-router.go

    		// Export IAM info to zipped file
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/export-iam").HandlerFunc(adminMiddleware(adminAPI.ExportIAM, noGZFlag))
    
    		// Import IAM info
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    }
    
    // healSequence - state for each heal sequence initiated on the
    // server.
    type healSequence struct {
    	// bucket, and object on which heal seq. was initiated
    	bucket, object string
    
    	// Report healing progress
    	reportProgress bool
    
    	// time at which heal sequence was started
    	startTime time.Time
    
    	// time at which heal sequence has ended
    	endTime time.Time
    
    	// Heal client info
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  3. internal/dsync/dsync_test.go

    		t.Fatal("Lock context canceled which is not expected")
    	case <-timer.C:
    	}
    
    	// Should be safe operation in all cases
    	dm.Unlock(context.Background())
    }
    
    // Test canceling context while quorum servers report lock not found
    func TestFailedRefreshLock(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping test in short mode.")
    	}
    
    	// Simulate Refresh response to return no locking found
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 24 03:49:07 GMT 2022
    - 11K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/listener.go

    		}
    	}
    	return fmt.Sprintf("Inline Route: %s", strings.Join(vhosts, "; "))
    }
    
    // If this is a route that matches everything and forwards to a cluster, just report the cluster.
    func getMatchAllCluster(er *route.RouteConfiguration) string {
    	if len(er.GetVirtualHosts()) != 1 {
    		return ""
    	}
    	vh := er.GetVirtualHosts()[0]
    	if !reflect.DeepEqual(vh.Domains, []string{"*"}) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  5. cmd/object-api-datatypes.go

    	// Add your own backend.
    )
    
    // StorageInfo - represents total capacity of underlying storage.
    type StorageInfo = madmin.StorageInfo
    
    // objectHistogramInterval is an interval that will be
    // used to report the histogram of objects data sizes
    type objectHistogramInterval struct {
    	name       string
    	start, end int64
    }
    
    const (
    	// dataUsageBucketLenV1 must be length of ObjectsHistogramIntervalsV1
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  6. src/archive/zip/reader.go

    		return err
    	}
    	buf := bufio.NewReader(rs)
    
    	// The count of files inside a zip is truncated to fit in a uint16.
    	// Gloss over this by reading headers until we encounter
    	// a bad one, and then only report an ErrFormat or UnexpectedEOF if
    	// the file count modulo 65536 is incorrect.
    	for {
    		f := &File{zip: r, zipr: rdr}
    		err = readDirectoryHeader(f, buf)
    		if err == ErrFormat || err == io.ErrUnexpectedEOF {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  7. cmd/api-response.go

    	for index, part := range partsInfo.Parts {
    		newPart := Part{}
    		newPart.PartNumber = part.PartNumber
    		newPart.ETag = "\"" + part.ETag + "\""
    		newPart.Size = part.Size
    		newPart.LastModified = amztime.ISO8601Format(part.LastModified.UTC())
    		newPart.ChecksumCRC32 = part.ChecksumCRC32
    		newPart.ChecksumCRC32C = part.ChecksumCRC32C
    		newPart.ChecksumSHA1 = part.ChecksumSHA1
    		newPart.ChecksumSHA256 = part.ChecksumSHA256
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  8. cmd/format-erasure.go

    		if err != nil {
    			return nil, nil, fmt.Errorf("Drive %s: %w", export, err)
    		}
    		// Migrate successful v1 => v2, proceed to v2 => v3
    		version = formatErasureVersionV2
    		fallthrough
    	case formatErasureVersionV2:
    		formatData, err = formatErasureMigrateV2ToV3(formatData, export, version)
    		if err != nil {
    			return nil, nil, fmt.Errorf("Drive %s: %w", export, err)
    		}
    		// Migrate successful v2 => v3, v3 is latest
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  9. cmd/metacache-server-pool.go

    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    			}
    			if !errors.Is(err, context.DeadlineExceeded) {
    				// Report error once per bucket, but continue listing.
    				storageLogOnceIf(ctx, err, "GetMetacacheListing:"+o.Bucket)
    			}
    			o.Transient = true
    			o.Create = false
    			o.ID = mustGetUUID()
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  10. cmd/tier.go

    		Subsystem: tierSubsystem,
    		Name:      tierRequestsFailure,
    		Help:      "Number of requests to download object from warm tier that failed",
    		Type:      counterMetric,
    	}
    )
    
    func (t *tierMetrics) Report() []MetricV2 {
    	metrics := getHistogramMetrics(t.histogram, tierTTLBMD, true)
    	t.RLock()
    	defer t.RUnlock()
    	for tier, stat := range t.requestsCount {
    		metrics = append(metrics, MetricV2{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top