Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 1,168 for rfunc (0.01 seconds)

  1. internal/pubsub/mask.go

    func (t Mask) SingleType() bool {
    	return bits.OnesCount64(uint64(t)) == 1
    }
    
    // FromUint64 will set a mask to the uint64 value.
    func (t *Mask) FromUint64(m uint64) {
    	*t = Mask(m)
    }
    
    // Merge will merge other into t.
    func (t *Mask) Merge(other Mask) {
    	*t |= other
    }
    
    // MergeMaskable will merge other into t.
    func (t *Mask) MergeMaskable(other Maskable) {
    	*t |= Mask(other.Mask())
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jul 05 21:45:49 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  2. generics.go

    		return db.Table(name, args...)
    	})}
    }
    
    func (c createG[T]) Select(query string, args ...interface{}) CreateInterface[T] {
    	return createG[T]{c.with(func(db *DB) *DB {
    		return db.Select(query, args...)
    	})}
    }
    
    func (c createG[T]) Omit(columns ...string) CreateInterface[T] {
    	return createG[T]{c.with(func(db *DB) *DB {
    		return db.Omit(columns...)
    	})}
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Nov 02 14:09:18 GMT 2025
    - 25.9K bytes
    - Click Count (0)
  3. cmd/erasure-multipart-conditional_test.go

    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:8] {
    			erasureDisks[i] = nil
    		}
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	t.Run("if-none-match with read quorum failure", func(t *testing.T) {
    		// Test Case 1: if-none-match (create only if doesn't exist)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  4. fastapi/dependencies/models.py

        if call is None:
            return call  # pragma: no cover
        unwrapped = inspect.unwrap(_impartial(call))
        return unwrapped
    
    
    def _impartial(func: Callable[..., Any]) -> Callable[..., Any]:
        while isinstance(func, partial):
            func = func.func
        return func
    
    
    @dataclass
    class Dependant:
        path_params: list[ModelField] = field(default_factory=list)
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  5. internal/mountinfo/mountinfo_linux.go

    			ss1.Ino == ss2.Ino)
    }
    
    // CheckCrossDevice - check if any list of paths has any sub-mounts at /proc/mounts.
    func CheckCrossDevice(absPaths []string) error {
    	return checkCrossDevice(absPaths, procMountsPath)
    }
    
    // Check cross device is an internal function.
    func checkCrossDevice(absPaths []string, mountsPath string) error {
    	mounts, err := readProcMounts(mountsPath)
    	if err != nil {
    		return err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  6. internal/bucket/lifecycle/tag.go

    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    
    	return nil
    }
    
    func (tag Tag) String() string {
    	return tag.Key + "=" + tag.Value
    }
    
    // IsEmpty returns whether this tag is empty or not.
    func (tag Tag) IsEmpty() bool {
    	return tag.Key == ""
    }
    
    // Validate checks this tag.
    func (tag Tag) Validate() error {
    	if len(tag.Key) == 0 || utf8.RuneCountInString(tag.Key) > 128 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 2.4K bytes
    - Click Count (0)
  7. cmd/bucket-stats.go

    	return nl
    }
    
    func (rl *ReplicationLastMinute) addsize(n int64) {
    	t := time.Now().Unix()
    	rl.LastMinute.addAll(t-1, AccElem{Total: t - 1, Size: n, N: 1})
    }
    
    func (rl *ReplicationLastMinute) String() string {
    	t := rl.LastMinute.getTotal()
    	return fmt.Sprintf("ReplicationLastMinute sz= %d, n=%d , dur=%d", t.Size, t.N, t.Total)
    }
    
    func (rl *ReplicationLastMinute) getTotal() AccElem {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  8. cmd/admin-handlers.go

    	isDir   bool
    	sys     any
    }
    
    func (f dummyFileInfo) Name() string       { return f.name }
    func (f dummyFileInfo) Size() int64        { return f.size }
    func (f dummyFileInfo) Mode() os.FileMode  { return f.mode }
    func (f dummyFileInfo) ModTime() time.Time { return f.modTime }
    func (f dummyFileInfo) IsDir() bool        { return f.isDir }
    func (f dummyFileInfo) Sys() any           { return f.sys }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  9. cmd/batch-job-common-types_gen.go

    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BatchJobKV) Msgsize() (s int) {
    	s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobNotification) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.9K bytes
    - Click Count (0)
  10. api/go1.24.txt

    pkg crypto/cipher, func NewOFB //deprecated #69445
    pkg crypto/fips140, func Enabled() bool #70123
    pkg crypto/hkdf, func Expand[$0 hash.Hash](func() $0, []uint8, string, int) ([]uint8, error) #61477
    pkg crypto/hkdf, func Extract[$0 hash.Hash](func() $0, []uint8, []uint8) ([]uint8, error) #61477
    pkg crypto/hkdf, func Key[$0 hash.Hash](func() $0, []uint8, []uint8, string, int) ([]uint8, error) #61477
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 17 21:28:29 GMT 2024
    - 14.2K bytes
    - Click Count (0)
Back to Top