- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 1,214 for Func (0.02 sec)
-
cmd/background-newdisks-heal-ops_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsghealingTracker(b *testing.B) { v := healingTracker{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsghealingTracker(b *testing.B) { v := healingTracker{} bts := make([]byte, 0, v.Msgsize())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 2.3K bytes - Viewed (0) -
internal/cachevalue/cache_test.go
"errors" "testing" "time" ) func slowCaller(ctx context.Context) error { sl := time.NewTimer(time.Second) defer sl.Stop() select { case <-sl.C: case <-ctx.Done(): return ctx.Err() } return nil } func TestCacheCtx(t *testing.T) { cache := New[time.Time]() t.Parallel() cache.InitOnce(2*time.Second, Opts{}, func(ctx context.Context) (time.Time, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 2.7K bytes - Viewed (0) -
internal/store/batch.go
func (b *Batch[I]) Close() error { defer func() { close(b.quitCh) }() b.Lock() defer b.Unlock() return b.commit() } // NewBatch creates a new batch func NewBatch[I any](config BatchConfig[I]) *Batch[I] { if config.CommitTimeout == 0 { config.CommitTimeout = defaultCommitTimeout } quitCh := make(chan struct{}) batch := &Batch[I]{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
misc/ios/detect.go
matches++ } } } if matches == len(udids) { files = append(files, string(line)) } } return files } func parseMobileProvision(fname string) *exec.Cmd { return exec.Command("security", "cms", "-D", "-i", string(fname)) } func plistExtract(fname string, path string) ([]byte, error) { out, err := exec.Command("/usr/libexec/PlistBuddy", "-c", "Print "+path, fname).CombinedOutput()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 19 23:33:30 UTC 2023 - 3.2K bytes - Viewed (0) -
internal/logger/logonce.go
) // LogOnce provides the function type for logger.LogOnceIf() function type LogOnce func(ctx context.Context, err error, id string, errKind ...interface{}) type onceErr struct { Err error Count int } // Holds a map of recently logged errors. type logOnceType struct { IDMap map[string]onceErr sync.Mutex }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 3.8K bytes - Viewed (0) -
internal/logger/reqinfo.go
ObjectName: object, } } // AppendTags - appends key/val to ReqInfo.tags func (r *ReqInfo) AppendTags(key, val string) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() r.tags = append(r.tags, KeyVal{key, val}) return r } // SetTags - sets key/val to ReqInfo.tags func (r *ReqInfo) SetTags(key, val string) *ReqInfo { if r == nil { return nil } r.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/untar.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 6K bytes - Viewed (0) -
internal/bucket/replication/destination.go
} func (d Destination) isValidStorageClass() bool { if d.StorageClass == "" { return true } return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY" } // IsValid - checks whether Destination is valid or not. func (d Destination) IsValid() bool { return d.Bucket != "" || !d.isValidStorageClass() } func (d Destination) String() string { return d.ARN }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
callbacks/preload.go
// }, // "k1": {}, // "k2": { // "k3": {"arg3"}, // }, // "k4": { // "k5.k6": {"arg4"}, // }, // } func parsePreloadMap(s *schema.Schema, preloads map[string][]interface{}) map[string]map[string][]interface{} { preloadMap := map[string]map[string][]interface{}{} setPreloadMap := func(name, value string, args []interface{}) { if _, ok := preloadMap[name]; !ok { preloadMap[name] = map[string][]interface{}{} }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
} writeSuccessResponseJSON(w, body) } func getSRAddOptions(r *http.Request) (opts madmin.SRAddOptions) { opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true" return } // SRPeerJoin - PUT /minio/admin/v3/site-replication/join // // used internally to tell current cluster to enable SR with // the provided peer clusters and service account.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0)