Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 1,425 for Func (0.03 sec)

  1. internal/bucket/lifecycle/noncurrentversion.go

    func (n NoncurrentVersionExpiration) IsNull() bool {
    	return n.IsDaysNull() && n.NewerNoncurrentVersions == 0
    }
    
    // IsDaysNull returns true if days field is null
    func (n NoncurrentVersionExpiration) IsDaysNull() bool {
    	return n.NoncurrentDays == ExpirationDays(0)
    }
    
    // Validate returns an error with wrong value
    func (n NoncurrentVersionExpiration) Validate() error {
    	if !n.set {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 14 17:41:44 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  2. internal/s3select/progress.go

    var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2)
    
    func (r *countUpReader) Read(p []byte) (n int, err error) {
    	n, err = r.reader.Read(p)
    	atomic.AddInt64(&r.bytesRead, int64(n))
    	return n, err
    }
    
    func (r *countUpReader) BytesRead() int64 {
    	if r == nil {
    		return 0
    	}
    	return atomic.LoadInt64(&r.bytesRead)
    }
    
    func newCountUpReader(reader io.Reader) *countUpReader {
    	return &countUpReader{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. internal/dsync/utils.go

    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(r *rand.Rand, attempt uint) time.Duration {
    		sleep := min
    		sleep += unit * time.Duration(attempt)
    		if sleep > cap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 13 15:42:21 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := z.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    		unlockOnDefer = true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. internal/s3select/json/preader_test.go

    import (
    	"bytes"
    	"io"
    	"os"
    	"path/filepath"
    	"testing"
    
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    func TestNewPReader(t *testing.T) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, file := range files {
    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  6. internal/s3select/json/reader_test.go

    import (
    	"bytes"
    	"io"
    	"os"
    	"path/filepath"
    	"testing"
    
    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    func TestNewReader(t *testing.T) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		t.Fatal(err)
    	}
    	for _, file := range files {
    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = rebalSaveOpts(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z rebalSaveOpts) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.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/storage-rest_test.go

    	}
    
    	return restClient
    }
    
    func TestStorageRESTClientDiskInfo(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIDiskInfo(t, restClient)
    }
    
    func TestStorageRESTClientStatInfoFile(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIStatInfoFile(t, restClient)
    }
    
    func TestStorageRESTClientListDir(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    // Endpoint - return kafka target
    func (h *Target) Endpoint() string {
    	return "kafka"
    }
    
    // String - kafka string
    func (h *Target) String() string {
    	return "kafka"
    }
    
    // Stats returns the target statistics.
    func (h *Target) Stats() types.TargetStats {
    	h.logChMu.RLock()
    	queueLength := len(h.logCh)
    	h.logChMu.RUnlock()
    
    	return types.TargetStats{
    		TotalMessages:  atomic.LoadInt64(&h.totalMessages),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top