- Sort Score
- Num 10 results
- Language All
Results 641 - 650 of 1,168 for func_ (0.01 seconds)
-
cmd/os-readdir_test.go
dir string entries []string } // Test to read empty directory. func setupTestReadDirEmpty(t *testing.T) (testResults []result) { // Add empty entry slice for this test directory. testResults = append(testResults, result{t.TempDir(), []string{}}) return testResults } // Test to read non-empty directory with only files. func setupTestReadDirFiles(t *testing.T) (testResults []result) { dir := t.TempDir()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 7.5K bytes - Click Count (0) -
internal/bpool/pool.go
// If New is not set Get may return the zero value of T. type Pool[T any] struct { New func() T p sync.Pool } // Get will retuen a new T func (p *Pool[T]) Get() T { v, ok := p.p.Get().(T) if ok { return v } if p.New == nil { var t T return t } return p.New() } // Put a used T. func (p *Pool[T]) Put(t T) { p.p.Put(t)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 1.2K bytes - Click Count (0) -
internal/bucket/lifecycle/error.go
// the string as a value that satisfies error of type tagging.Error func Errorf(format string, a ...any) error { return Error{err: fmt.Errorf(format, a...)} } // Unwrap the internal error. func (e Error) Unwrap() error { return e.err } // Error 'error' compatible method. func (e Error) Error() string { if e.err == nil { return "lifecycle: cause <nil>" } return e.err.Error()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.3K bytes - Click Count (0) -
internal/bucket/versioning/error.go
// the string as a value that satisfies error of type tagging.Error func Errorf(format string, a ...any) error { return Error{err: fmt.Errorf(format, a...)} } // Unwrap the internal error. func (e Error) Unwrap() error { return e.err } // Error 'error' compatible method. func (e Error) Error() string { if e.err == nil { return "versioning: cause <nil>" } return e.err.Error()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.3K bytes - Click Count (0) -
cmd/metacache-stream_test.go
func loadMetacacheSample(t testing.TB) *metacacheReader { b, err := os.ReadFile("testdata/metacache.s2") if err != nil { t.Fatal(err) } return newMetacacheReader(bytes.NewReader(b)) } func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted { r := loadMetacacheSample(t) defer r.Close()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 15K bytes - Click Count (0) -
cmd/hasher.go
// getSHA256Hash returns SHA-256 hash in hex encoding of given data. func getSHA256Hash(data []byte) string { return hex.EncodeToString(getSHA256Sum(data)) } // getSHA256Hash returns SHA-256 sum of given data. func getSHA256Sum(data []byte) []byte { hash := sha256.New() hash.Write(data) return hash.Sum(nil) } // getMD5Sum returns MD5 sum of given data. func getMD5Sum(data []byte) []byte { hash := md5.New() hash.Write(data)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 27 13:00:19 GMT 2022 - 1.4K bytes - Click Count (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{}{} }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun May 25 07:40:40 GMT 2025 - 11.7K bytes - Click Count (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 opts } // 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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
src/archive/tar/writer_test.go
} // failOnceWriter fails exactly once and then always reports success. type failOnceWriter bool func (w *failOnceWriter) Write(b []byte) (int, error) { if !*w { return 0, io.ErrShortWrite } *w = true return len(b), nil } func TestWriterErrors(t *testing.T) { t.Run("HeaderOnly", func(t *testing.T) { tw := NewWriter(new(bytes.Buffer)) hdr := &Header{Name: "dir/", Typeflag: TypeDir}
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 40.2K bytes - Click Count (0) -
cmd/scannermetric_string.go
// Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.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[scannerMetricReadMetadata-0] _ = x[scannerMetricCheckMissing-1] _ = x[scannerMetricSaveUsage-2]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 1.7K bytes - Click Count (0)