- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for fn (0.2 sec)
-
internal/s3select/progress.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
cmd/os_other.go
return err } func osMkdirAll(dirPath string, perm os.FileMode, _ string) error { // baseDir is not honored in plan9 and solaris platforms. return os.MkdirAll(dirPath, perm) } // readDirFn applies the fn() function on each entries at dirPath, doesn't recurse into // the directory itself, if the dirPath doesn't exist this function doesn't return // an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 4K bytes - Viewed (0) -
cmd/utils.go
switch madmin.ProfilerType(profilerType) { case madmin.ProfilerCPU: dirPath, err := os.MkdirTemp("", "profile") if err != nil { return nil, err } fn := filepath.Join(dirPath, "cpu.out") f, err := Create(fn) if err != nil { return nil, err } err = pprof.StartCPUProfile(f) if err != nil { return nil, err } prof.stopFn = func() ([]byte, error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 31.3K bytes - Viewed (0) -
cmd/jwt.go
} // newCachedAuthToken returns a token that is cached up to 15 seconds. // If globalActiveCred is updated it is reflected at once. func newCachedAuthToken() func(audience string) string { fn := func(accessKey, secretKey, audience string) (s string, err error) { k := cacheKey{accessKey: accessKey, secretKey: secretKey, audience: audience} var ok bool s, ok = cacheLRU.Get(k) if !ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/s3select/sql/aggregation.go
type aggVal struct { runningSum *Value runningCount int64 runningMax, runningMin *Value // Stores if at least one record has been seen seen bool } func newAggVal(fn FuncName) *aggVal { switch fn { case aggFnAvg, aggFnSum: return &aggVal{runningSum: FromFloat(0)} case aggFnMin: return &aggVal{runningMin: FromInt(0)} case aggFnMax: return &aggVal{runningMax: FromInt(0)} default:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/metacache-stream.go
// and provide a callback for each entry read in order // as long as true is returned on the callback. func (r *metacacheReader) readFn(fn func(entry metaCacheEntry) bool) error { r.checkInit() if r.err != nil { return r.err } if r.current.name != "" { fn(r.current) r.current.name = "" r.current.metadata = nil } for { if more, err := r.mr.ReadBool(); !more { switch err {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/object-api-interface.go
HealObject(ctx context.Context, bucket, object, versionID string, opts madmin.HealOpts) (madmin.HealResultItem, error) HealObjects(ctx context.Context, bucket, prefix string, opts madmin.HealOpts, fn HealObjectFn) error CheckAbandonedParts(ctx context.Context, bucket, object string, opts madmin.HealOpts) error // Returns health of the backend Health(ctx context.Context, opts HealthOptions) HealthResult
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/os_windows.go
return err } func osMkdirAll(dirPath string, perm os.FileMode, _ string) error { // baseDir is not honored in windows platform return os.MkdirAll(dirPath, perm) } // readDirFn applies the fn() function on each entries at dirPath, doesn't recurse into // the directory itself, if the dirPath doesn't exist this function doesn't return // an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 5.1K bytes - Viewed (0) -
cmd/jwt_test.go
creds := globalActiveCred b.Run("uncached", func(b *testing.B) { fn := authenticateNode b.ResetTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { fn(creds.AccessKey, creds.SecretKey, "aud") } }) b.Run("cached", func(b *testing.B) { fn := newCachedAuthToken() b.ResetTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { fn("aud") } })
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1)