- Sort Score
- Num 10 results
- Language All
Results 471 - 480 of 1,180 for func_ (0.01 seconds)
-
internal/config/lambda/event/targetid.go
ID string Name string } // String - returns string representation. func (tid TargetID) String() string { return tid.ID + ":" + tid.Name } // ToARN - converts to ARN. func (tid TargetID) ToARN(region string) ARN { return ARN{TargetID: tid, region: region} } // MarshalJSON - encodes to JSON data. func (tid TargetID) MarshalJSON() ([]byte, error) { return json.Marshal(tid.String()) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.8K bytes - Click Count (0) -
cmd/config-current.go
MultipleTargets: subSysHelp.MultipleTargets, KeysHelp: help, }, nil } func newServerConfig() config.Config { return config.New() } // newSrvConfig - initialize a new server config, saves env parameters if // found, otherwise use default parameters func newSrvConfig(objAPI ObjectLayer) error { // Initialize server config. srvCfg := newServerConfig()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 28.5K bytes - Click Count (0) -
cmd/jwt.go
} groups = ucred.Groups } return claims, groups, owner, nil } // newCachedAuthToken returns the cached token. func newCachedAuthToken() func() string { return func() string { return globalNodeAuthToken }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
lru *lru.LRU[string, *Stmt] } func (s *lruStore) Keys() []string { return s.lru.Keys() } func (s *lruStore) Get(key string) (*Stmt, bool) { stmt, ok := s.lru.Get(key) if ok && stmt != nil { <-stmt.prepared } return stmt, ok } func (s *lruStore) Set(key string, value *Stmt) { s.lru.Add(key, value) } func (s *lruStore) Delete(key string) { s.lru.Remove(key) }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Apr 27 06:05:16 GMT 2025 - 6K bytes - Click Count (0) -
cmd/metacache-bucket.go
} } func (b *bucketMetacache) debugf(format string, data ...any) { if serverDebugLog { console.Debugf(format+"\n", data...) } } // findCache will attempt to find a matching cache for the provided options. // If a cache with the same ID exists already it will be returned. // If none can be found a new is created with the provided ID.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.6K bytes - Click Count (0) -
cmd/decommetric_string.go
// Code generated by "stringer -type=decomMetric -trimprefix=decomMetric erasure-server-pool-decom.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[decomMetricDecommissionBucket-0] _ = x[decomMetricDecommissionObject-1] _ = x[decomMetricDecommissionRemoveObject-2]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Aug 10 19:46:45 GMT 2022 - 830 bytes - Click Count (0) -
clause/locking.go
LockingOptionsNoWait = "NOWAIT" ) type Locking struct { Strength string Table Table Options string } // Name where clause name func (locking Locking) Name() string { return "FOR" } // Build build where clause func (locking Locking) Build(builder Builder) { builder.WriteString(locking.Strength) if locking.Table.Name != "" { builder.WriteString(" OF ")
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Dec 15 08:32:56 GMT 2023 - 773 bytes - Click Count (0) -
cmd/erasure-metadata-utils_test.go
if err != nil { removeRoots(disks) t.Fatal(err) } defer removeRoots(disks) z := objLayer.(*erasureServerPools) testShuffleDisks(t, z) } func Test_hashOrder(t *testing.T) { for x := 1; x < 17; x++ { t.Run(fmt.Sprintf("%d", x), func(t *testing.T) { var first [17]int rng := rand.New(rand.NewSource(0)) var tmp [16]byte rng.Read(tmp[:]) prefix := hex.EncodeToString(tmp[:])Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.3K bytes - Click Count (0) -
cmd/api-utils.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "net/http" "reflect" "runtime" "strings" ) func shouldEscape(c byte) bool { if 'A' <= c && c <= 'Z' || 'a' <= c && c <= 'z' || '0' <= c && c <= '9' { return false } switch c { case '-', '_', '.', '/', '*': return false } return true }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 2.8K bytes - Click Count (0) -
internal/lock/lock_solaris.go
// This implementation doesn't support all the open // flags and shouldn't be considered as replacement // for os.OpenFile(). func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) { return lockedOpenFile(path, flag, perm, syscall.F_SETLKW) } // Open - Call os.OpenFile func Open(path string, flag int, perm os.FileMode) (*os.File, error) { return os.OpenFile(path, flag, perm)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.8K bytes - Click Count (0)