- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 1,168 for rfunc (0.01 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)