- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 663 for Sprintf (0.27 sec)
-
tests/lru_test.go
func TestLRUWithPurgeEnforcedBySize(t *testing.T) { lc := lru.NewLRU[string, string](10, nil, time.Hour) for i := 0; i < 100; i++ { i := i lc.Add(fmt.Sprintf("key%d", i), fmt.Sprintf("val%d", i)) v, ok := lc.Get(fmt.Sprintf("key%d", i)) if v != fmt.Sprintf("val%d", i) { t.Fatalf("value differs from expected") } if !ok { t.Fatalf("should be true") } if lc.Len() > 20 {
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Mon Sep 08 09:19:22 UTC 2025 - 10.4K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.go
body, err := io.ReadAll(r.Body) defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err) w.WriteHeader(http.StatusBadRequest) return } log.Printf(">>> %s %s\n", r.Method, r.URL.Path) var out bytes.Buffer json.Indent(&out, body, "", " ") log.Printf("%s\n", out.String()) w.WriteHeader(http.StatusOK) } func main() { flag.Parse()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 1.5K bytes - Viewed (0) -
docs/debugging/inspect/main.go
if err != nil { fmt.Printf("error generating key: %s n", err) os.Exit(1) } // dump private key to file privateKeyBytes := x509.MarshalPKCS1PrivateKey(privatekey) privateKeyBlock := &pem.Block{ Type: "RSA PRIVATE KEY", Bytes: privateKeyBytes, } privatePem, err := os.Create("support_private.pem") if err != nil { fmt.Printf("error when create private.pem: %s n", err)Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 17 17:09:42 UTC 2025 - 5.7K bytes - Viewed (0) -
internal/store/store.go
Name string Compress bool Extension string ItemCount int } // String returns the filepath name func (k Key) String() string { keyStr := k.Name if k.ItemCount > 1 { keyStr = fmt.Sprintf("%d:%s", k.ItemCount, k.Name) } return keyStr + k.Extension + func() string { if k.Compress { return compressExt } return "" }() } func getItemCount(k string) (count int, err error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
func testCreateBucket(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) { bucketName1 := fmt.Sprintf("%s-1", bucketName) const n = 100 start := make(chan struct{}) var ok, errs int var wg sync.WaitGroup var mu sync.Mutex wg.Add(n) for range n { go func() { defer wg.Done()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.9K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
case errorMessage: logf = func(format string, args ...any) { fmt.Fprintf(os.Stderr, format+"\n", args...) } case fatalMessage: logf = func(format string, args ...any) { fmt.Fprintf(os.Stderr, format+"\n", args...) } defer os.Exit(1) default: logf = func(format string, args ...any) { fmt.Fprintf(os.Stdout, format+"\n", args...) } } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4K bytes - Viewed (0) -
internal/event/target/mysql.go
if target.updateStmt, err = target.db.Prepare(fmt.Sprintf(mysqlUpdateRow, target.args.Table)); err != nil { return err } // delete statement if target.deleteStmt, err = target.db.Prepare(fmt.Sprintf(mysqlDeleteRow, target.args.Table)); err != nil { return err } case event.AccessFormat: // insert statement if target.insertStmt, err = target.db.Prepare(fmt.Sprintf(mysqlInsertRow, target.args.Table)); err != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 11.6K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
} corrupted := false if !multipart { md5sum := fmt.Sprintf("%x", partsMD5Sum[0]) if md5sum != object.ETag { corrupted = true } } else { var totalMD5SumBytes []byte for _, sum := range partsMD5Sum { totalMD5SumBytes = append(totalMD5SumBytes, sum...) } s3MD5 := fmt.Sprintf("%x-%d", getMD5Sum(totalMD5SumBytes), parts) if s3MD5 != object.ETag {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.3K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
if n != 10000 { panic(fmt.Sprintf("wlock(%d)\n", n)) } for range 100 { } atomic.AddInt32(activity, -10000) rwm.Unlock(context.Background()) } } cdone <- true } // Borrowed from rwmutex_test.go func hammerRWMutex(t *testing.T, gomaxprocs, numReaders, numIterations int) { t.Run(fmt.Sprintf("%d-%d-%d", gomaxprocs, numReaders, numIterations), func(t *testing.T) {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 9.4K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
json.NewEncoder(w).Encode(map[string]string{ "error": fmt.Sprintf("%v", err), }) } type Result struct { Result bool `json:"result"` } func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) if err != nil { writeErrorResponse(w, err) return } var out bytes.Buffer json.Indent(&out, body, "", " ") fmt.Printf("Received JSON payload:\n%s\n", out.String())
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Feb 08 17:15:20 UTC 2024 - 2.7K bytes - Viewed (0)