- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 100 for Alimin (0.23 sec)
-
internal/store/queuestore_test.go
// Ext for test item testItemExt = ".test" ) // Initialize the queue store. func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) { queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt) if oErr := queueStore.Open(); oErr != nil { return nil, oErr } return queueStore, nil } // Tear down queue store. func tearDownQueueStore() error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/ioutil/ioutil.go
w.skipBytes -= int64(len(p)) return n, nil } p = p[w.skipBytes:] w.skipBytes = 0 } if w.wLimit == 0 { return n, nil } if w.wLimit < int64(len(p)) { n1, err = w.Writer.Write(p[:w.wLimit]) w.wLimit -= int64(n1) return n, err } n1, err = w.Writer.Write(p) w.wLimit -= int64(n1) return n, err } // Close closes the LimitWriter. It behaves like io.Closer.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
internal/store/batch_test.go
batchLen := batch.Len() if batchLen != int(limit) { t.Fatalf("expected batch length to be %v but got %v", limit, batchLen) } keys, items, err := batch.GetAll() if err != nil { t.Fatalf("unable to get the items from the batch; %v", err) } if len(items) != int(limit) { t.Fatalf("Expected length of the batch items to be %v but got %v", limit, len(items)) } if len(keys) != int(limit) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/metacache-set.go
// used when o.Versioned is false if !o.Versioned { resolver.requestedVersions = 1 } var limit int if o.Limit > 0 && o.StopDiskAtLimit { // Over-read by 4 + 1 for every 16 in limit to give some space for resolver, // allow for truncating the list and know if we have more results. limit = o.Limit + 4 + (o.Limit / 16) } ctxDone := ctx.Done() return listPathRaw(ctx, listPathRawOptions{ disks: disks,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/metacache-walk.go
// Should never contain a slash. FilterPrefix string // ForwardTo will forward to the given object path. ForwardTo string // Limit the number of returned objects if > 0. Limit int // DiskID contains the disk ID of the disk. // Leave empty to not check disk ID. DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
tests/query_test.go
*GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}), *GetUser("find_in_batches_with_offset_limit", Config{}),
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Thu Apr 25 12:22:53 GMT 2024 - 49.8K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue18146.go
} if runtime.GOARCH == "mips" || runtime.GOARCH == "mips64" { t.Skipf("skipping on %s", runtime.GOARCH) } attempts := 1000 threads := 4 // Restrict the number of attempts based on RLIMIT_NPROC. // Tediously, RLIMIT_NPROC was left out of the syscall package, // probably because it is not in POSIX.1, so we define it here. // It is not defined on Solaris. var nproc int setNproc := true switch runtime.GOOS {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Sep 05 23:35:32 GMT 2023 - 2.8K bytes - Viewed (0) -
tests/sql_builder_test.go
// find sql := DB.ToSQL(func(tx *gorm.DB) *gorm.DB { return tx.Model(&User{}).Where("id = ?", 100).Limit(10).Order("age desc").Find(&[]User{}) }) assertEqualSQL(t, `SELECT * FROM "users" WHERE id = 100 AND "users"."deleted_at" IS NULL ORDER BY age desc LIMIT 10`, sql) // after model changed if DB.Statement.DryRun || DB.DryRun {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 16.7K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
processIOWriteBytes = "io_write_bytes" processStartTimeSeconds = "start_time_seconds" processUptimeSeconds = "uptime_seconds" processFileDescriptorLimitTotal = "file_descriptor_limit_total" processFileDescriptorOpenTotal = "file_descriptor_open_total" processSyscallReadTotal = "syscall_read_total" processSyscallWriteTotal = "syscall_write_total"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/metacache-walk_gen.go
return } case "ForwardTo": z.ForwardTo, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ForwardTo") return } case "Limit": z.Limit, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Limit") return } case "DiskID": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } default:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7K bytes - Viewed (0)