Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 1,214 for Func (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/archive/tar/tar_test.go

    type fileInfoNames struct{}
    
    func (f *fileInfoNames) Name() string {
    	return "tmp"
    }
    
    func (f *fileInfoNames) Size() int64 {
    	return 0
    }
    
    func (f *fileInfoNames) Mode() fs.FileMode {
    	return 0777
    }
    
    func (f *fileInfoNames) ModTime() time.Time {
    	return time.Time{}
    }
    
    func (f *fileInfoNames) IsDir() bool {
    	return false
    }
    
    func (f *fileInfoNames) Sys() any {
    	return nil
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. internal/lock/lock_windows.go

    	// paths or paths containing .. elements. For now,
    	// \\server\share paths are not converted to
    	// \\?\UNC\server\share paths because the rules for doing so
    	// are less well-specified.
    	if len(path) >= 2 && path[:2] == `\\` {
    		// Don't canonicalize UNC paths.
    		return path
    	}
    	if !filepath.IsAbs(path) {
    		// Relative path
    		return path
    	}
    
    	const prefix = `\\?`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  8. tests/hooks_test.go

    	return
    }
    
    func (s *Product) BeforeSave(tx *gorm.DB) (err error) {
    	if s.Code == "dont_save" {
    		err = errors.New("can't save")
    	}
    	s.BeforeSaveCallTimes = s.BeforeSaveCallTimes + 1
    	return
    }
    
    func (s *Product) AfterFind(tx *gorm.DB) (err error) {
    	s.AfterFindCallTimes = s.AfterFindCallTimes + 1
    	return
    }
    
    func (s *Product) AfterCreate(tx *gorm.DB) (err error) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 17 03:59:06 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  9. docs/debugging/reorder-disks/main.go

    		}
    		result[s[2]] = s[9]
    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. internal/crypto/sse.go

    // and no Type.
    func IsRequested(h http.Header) (Type, bool) {
    	switch {
    	case S3.IsRequested(h):
    		return S3, true
    	case S3KMS.IsRequested(h):
    		return S3KMS, true
    	case SSEC.IsRequested(h):
    		return SSEC, true
    	default:
    		return nil, false
    	}
    }
    
    // Requested returns whether any type of encryption is requested.
    func Requested(h http.Header) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
Back to top