Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 1,214 for Func (0.06 sec)

  1. docs/debugging/inspect/export.go

    // afterVersion returns the payload after the version, if any.
    func (x xlMetaInlineData) afterVersion() []byte {
    	if len(x) == 0 {
    		return x
    	}
    	return x[1:]
    }
    
    // versionOK returns whether the version is ok.
    func (x xlMetaInlineData) versionOK() bool {
    	if len(x) == 0 {
    		return true
    	}
    	return x[0] > 0 && x[0] <= xlMetaInlineDataVer
    }
    
    func (x xlMetaInlineData) json() ([]byte, error) {
    	if len(x) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 08 15:58:02 UTC 2022
    - 9.1K bytes
    - Viewed (0)
  2. cmd/erasure-metadata_test.go

    	}
    }
    
    func TestSkipTierFreeVersion(t *testing.T) {
    	fi := newFileInfo("object", 8, 8)
    	fi.SetSkipTierFreeVersion()
    	if ok := fi.SkipTierFreeVersion(); !ok {
    		t.Fatal("Expected SkipTierFreeVersion to be set on FileInfo but wasn't")
    	}
    }
    
    func TestListObjectParities(t *testing.T) {
    	mkMetaArr := func(N, parity, agree int) []FileInfo {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. cmd/metrics-resource.go

    }
    
    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  4. cmd/dynamic-timeouts_test.go

    		t.Errorf("Failure to decrease timeout appropriately")
    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    				for j := 0; j < 100; j++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  5. cmd/jwt.go

    		}
    
    		groups = ucred.Groups
    	}
    
    	return claims, groups, owner, nil
    }
    
    // newCachedAuthToken returns the cached token.
    func newCachedAuthToken() func() string {
    	return func() string {
    		return globalNodeAuthToken
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  6. cmd/signature-v2_test.go

    package cmd
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"net/url"
    	"os"
    	"sort"
    	"testing"
    )
    
    // Tests for 'func TestResourceListSorting(t *testing.T)'.
    func TestResourceListSorting(t *testing.T) {
    	sortedResourceList := make([]string, len(resourceList))
    	copy(sortedResourceList, resourceList)
    	sort.Strings(sortedResourceList)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 8K bytes
    - Viewed (0)
  7. internal/event/rules_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestNewPattern(t *testing.T) {
    	testCases := []struct {
    		prefix         string
    		suffix         string
    		expectedResult string
    	}{
    		{"", "", ""},
    		{"*", "", "*"},
    		{"", "*", "*"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
  8. tests/tests_test.go

    		db.Logger = db.Logger.LogMode(logger.Silent)
    	}
    
    	return
    }
    
    func RunMigrations() {
    	var err error
    	allModels := []interface{}{&User{}, &Account{}, &Pet{}, &Company{}, &Toy{}, &Language{}, &Coupon{}, &CouponProduct{}, &Order{}, &Parent{}, &Child{}, &Tools{}}
    	rand.Seed(time.Now().UnixNano())
    	rand.Shuffle(len(allModels), func(i, j int) { allModels[i], allModels[j] = allModels[j], allModels[i] })
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Sep 30 03:21:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. cmd/erasure-metadata-utils_test.go

    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    func Test_hashOrder(t *testing.T) {
    	for x := 1; x < 17; x++ {
    		t.Run(fmt.Sprintf("%d", x), func(t *testing.T) {
    			var first [17]int
    			rng := rand.New(rand.NewSource(0))
    			var tmp [16]byte
    			rng.Read(tmp[:])
    			prefix := hex.EncodeToString(tmp[:])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  10. cmd/api-headers.go

    	xxml "github.com/minio/xxml"
    )
    
    // Returns a hexadecimal representation of time at the
    // time response is sent to the client.
    func mustGetRequestID(t time.Time) string {
    	return fmt.Sprintf("%X", t.UnixNano())
    }
    
    // setEventStreamHeaders to allow proxies to avoid buffering proxy responses
    func setEventStreamHeaders(w http.ResponseWriter) {
    	w.Header().Set(xhttp.ContentType, "text/event-stream")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
Back to top