Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for Switkin (0.17 sec)

  1. cmd/tier-last-day-stats.go

    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    	// within the hour since l.UpdatedAt
    	if since < 1 {
    		return
    	}
    
    	idx, lastIdx := t.Hour(), l.UpdatedAt.Hour()
    
    	l.UpdatedAt = t // update to the latest time index
    
    	if since >= 24 {
    		l.Bins = [24]tierStats{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    	if poolStats.Info.Status == rebalCompleted {
    		return true
    	}
    
    	pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity)
    	// Mark pool rebalance as done if within 5% from PercentFreeGoal.
    	if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 {
    		r.PoolStats[poolIdx].Info.Status = rebalCompleted
    		r.PoolStats[poolIdx].Info.EndTime = time.Now()
    		return true
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	var (
    		// We check every 15 seconds if the disk is writable and we can read back.
    		checkEvery = 15 * time.Second
    
    		// If the disk has completed an operation successfully within last 5 seconds, don't check it.
    		skipIfSuccessBefore = 5 * time.Second
    	)
    
    	// if disk max timeout is smaller than checkEvery window
    	// reduce checks by a second.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/metrics-v2.go

    }
    
    // MetricNamespace is top level grouping of metrics to create the metric name.
    type MetricNamespace string
    
    // MetricSubsystem is the sub grouping for metrics within a namespace.
    type MetricSubsystem string
    
    const (
    	bucketMetricNamespace    MetricNamespace = "minio_bucket"
    	clusterMetricNamespace   MetricNamespace = "minio_cluster"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  5. cmd/metacache-entries.go

    	"bytes"
    	"context"
    	"errors"
    	"os"
    	"path"
    	"sort"
    	"strings"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v2/console"
    )
    
    // metaCacheEntry is an object or a directory within an unknown bucket.
    type metaCacheEntry struct {
    	// name is the full name of the object including prefixes
    	name string
    	// Metadata. If none is present it is not an object but only a prefix.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    // need a sample HTTP request to be sent as argument so that the relevant handler is called, the handler registration is expected
    // to be done since its called from within the API handler tests, the reference to the registered HTTP handler has to be sent
    // as an argument.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    				}
    			}
    
    			info.Buckets[bucket] = bms
    		}
    	}
    
    	if opts.Users && opts.Groups && opts.Policies && !opts.Buckets {
    		// serialize SiteReplicationMetaInfo calls - if data in cache is within
    		// healing interval, avoid fetching IAM data again from disk.
    		if metaInfo, ok := c.getSRCachedIAMInfo(); ok {
    			return metaInfo, nil
    		}
    	}
    	if opts.Policies || opts.Entity == madmin.SRPolicyEntity {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  8. cmd/warm-backend.go

    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"strings"
    
    	"github.com/minio/madmin-go/v3"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // WarmBackendGetOpts is used to express byte ranges within an object. The zero
    // value represents the entire byte range of an object.
    type WarmBackendGetOpts struct {
    	startOffset int64
    	length      int64
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    // compute skipLen, the number of bytes to skip in the beginning of
    // the encrypted range.
    //
    // In addition we also compute the object part number for where the
    // requested range starts, along with the DARE sequence number within
    // that part. For single part objects, the partStart will be 0.
    func (o *ObjectInfo) GetDecryptedRange(rs *HTTPRangeSpec) (encOff, encLength, skipLen int64, seqNumber uint32, partStart int, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  10. cmd/utils_test.go

    		}
    	}
    }
    
    // Tests minimum allowed part size.
    func TestMinAllowedPartSize(t *testing.T) {
    	sizes := []struct {
    		isMin bool
    		size  int64
    	}{
    		// Test - 1 - within minimum part size.
    		{
    			true,
    			globalMinPartSize + 1,
    		},
    		// Test - 2 - smaller than minimum part size.
    		{
    			false,
    			globalMinPartSize - 1,
    		},
    	}
    
    	for i, s := range sizes {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 23 21:28:14 GMT 2024
    - 10.2K bytes
    - Viewed (0)
Back to top