- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 33 for Func (0.03 seconds)
-
cmd/peer-rest-server.go
getMemInfoRPC = grid.NewSingleHandler[*grid.MSS, *grid.JSON[madmin.MemInfo]](grid.HandlerGetMemInfo, grid.NewMSS, madminMemInfo.NewJSON) getMetacacheListingRPC = grid.NewSingleHandler[*listPathOptions, *metacache](grid.HandlerGetMetacacheListing, func() *listPathOptions { return &listPathOptions{} }, func() *metacache { return &metacache{} })
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/iam-store.go
r = append(r, v) } } sort.Slice(r, func(i, j int) bool { return r[i].User < r[j].User }) return r } // Assumes store is locked by caller. If groups is empty, returns all group mappings. func (store *IAMStoreSys) listGroupPolicyMappings(cache *iamCache, groupsSet set.StringSet, groupPredicate func(string) bool, decodeFunc func(string) string, ) []madmin.GroupPolicyEntities {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 87.1K bytes - Click Count (0) -
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 }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
cmd/iam.go
// SetUsersSysType - sets the users system type, regular or LDAP. func (sys *IAMSys) SetUsersSysType(t UsersSysType) { sys.usersSysType = t } // GetUsersSysType - returns the users system type for this IAM func (sys *IAMSys) GetUsersSysType() UsersSysType { return sys.usersSysType } // NewIAMSys - creates new config system object. func NewIAMSys() *IAMSys { return &IAMSys{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
cmd/test-utils_test.go
func resetGlobalEndpoints() { globalEndpoints = EndpointServerPools{} } func resetGlobalIsErasure() { globalIsErasure = false } // reset global heal state func resetGlobalHealState() { // Init global heal state if globalAllHealState == nil { globalAllHealState = newHealState(GlobalContext, false) } else { globalAllHealState.Lock() for _, v := range globalAllHealState.healSeqMap {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0) -
cmd/xl-storage.go
} // Implements stringer compatible interface. func (s *xlStorage) String() string { return s.drivePath } func (s *xlStorage) Hostname() string { return s.endpoint.Host } func (s *xlStorage) Endpoint() Endpoint { return s.endpoint } func (s *xlStorage) Close() error { s.immediatePurgeCancel() return nil } func (s *xlStorage) IsOnline() bool { return true }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
tests/migrate_test.go
checkMyIndex = func(t *testing.T) { checkColumnType(t, "name", true) checkIndex(t, []gorm.Index{uniqueConstraintIndex, myIndex}) } checkMulIndex = func(t *testing.T) { checkColumnType(t, "name", false) checkColumnType(t, "nick_name", false) checkIndex(t, []gorm.Index{mulIndex}) } } else { checkNotUnique = func(t *testing.T) { checkColumnType(t, "name", false) }Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed Aug 20 04:51:17 GMT 2025 - 65.2K bytes - Click Count (0) -
cmd/xl-storage-format-v2.go
var metaDataPool = bpool.Pool[[]byte]{New: func() []byte { return make([]byte, 0, metaDataReadDefault) }} // metaDataPoolGet will return a byte slice with capacity at least metaDataReadDefault. // It will be length 0. func metaDataPoolGet() []byte { return metaDataPool.Get()[:0] } // metaDataPoolPut will put an unused small buffer back into the pool. func metaDataPoolPut(buf []byte) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 65.6K bytes - Click Count (1) -
cmd/xl-storage-format-v2_gen.go
func (z ErasureAlgo) Msgsize() (s int) { s = msgp.Uint8Size return } // DecodeMsg implements msgp.Decodable func (z *VersionType) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = VersionType(zb0001) } return } // EncodeMsg implements msgp.Encodable
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 55.8K bytes - Click Count (0) -
src/bytes/bytes_test.go
} func bmIndexByte(index func([]byte, byte) int) func(b *testing.B, n int) { return func(b *testing.B, n int) { buf := bmbuf[0:n] buf[n-1] = 'x' for i := 0; i < b.N; i++ { j := index(buf, 'x') if j != n-1 { b.Fatal("bad index", j) } } buf[n-1] = '\x00' } } func BenchmarkIndexRune(b *testing.B) {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Dec 23 23:54:14 GMT 2025 - 62.9K bytes - Click Count (0)