- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 236 for background (0.06 sec)
-
tests/scopes_test.go
if result.RowsAffected != 2 { t.Errorf("Should found two users's name in 1, 2, but got %v", result.RowsAffected) } var maxId int64 userTable := func(db *gorm.DB) *gorm.DB { return db.WithContext(context.Background()).Table("users") } if err := DB.Scopes(userTable).Select("max(id)").Scan(&maxId).Error; err != nil { t.Errorf("select max(id)") } } func TestComplexScopes(t *testing.T) { tests := []struct {
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Jan 12 08:42:21 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/batch-expire.go
xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil { batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err)) } return nil } //msgp:ignore batchExpireJobError type batchExpireJobError struct { Code string
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
README.md
Crawler crawler = container.getComponent("crawler"); crawler.addUrl("https://example.com"); crawler.crawlerContext.setMaxAccessCount(500); String sessionId = crawler.execute(); ``` ### Background Crawling ```java // Configure for background execution crawler.setBackground(true); String sessionId = crawler.execute(); // Check crawling status while (crawler.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 15.3K bytes - Viewed (0) -
cmd/callhome.go
"math/rand" "net/url" "time" "github.com/minio/madmin-go/v3" ) var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second) // initCallhome will start the callhome task in the background. func initCallhome(ctx context.Context, objAPI ObjectLayer) { if !globalCallhomeConfig.Enabled() { return } go func() { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
func(t *testing.T) { runAllIAMConcurrencyTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestDeleteUserRace(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second) defer cancel() bucket := getRandomBucketName() err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket creat error: %v", err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4K bytes - Viewed (0) -
docs/sts/ldap.go
if bucketToList == "" { bucketToList = ldapUsername } fmt.Printf("Calling list objects on bucket named `%s` with temp creds:\n===\n", bucketToList) objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{}) for obj := range objCh { if obj.Err != nil { log.Fatalf("Listing error: %v", obj.Err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Aug 07 12:59:47 UTC 2024 - 4K bytes - Viewed (0) -
cmd/post-policy_test.go
curTimePlus5Min := curTime.Add(time.Minute * 5) // bucketnames[0]. // objectNames[0]. // uploadIds [0]. // Create bucket before initiating NewMultipartUpload. err := obj.MakeBucket(context.Background(), bucketName, MakeBucketOptions{}) if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } // Test cases for signature-V2. testCasesV2 := []struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
if err != nil { return nil, nil, err } pools := mustGetPoolEndpoints(0, fsDirs[:16]...) pools = append(pools, mustGetPoolEndpoints(1, fsDirs[16:]...)...) objLayer, _, err := initObjectLayer(context.Background(), pools) if err != nil { removeRoots(fsDirs) return nil, nil, err } return objLayer, fsDirs, nil } func TestPoolMetaValidate(t *testing.T) { objLayer1, fsDirs, err := prepareErasurePools()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.8K bytes - Viewed (0) -
cmd/erasure-decode_test.go
setup, err := newErasureTestSetup(b, data, parity, blockSizeV2) if err != nil { b.Fatalf("failed to create test setup: %v", err) } disks := setup.disks erasure, err := NewErasure(context.Background(), data, parity, blockSizeV2) if err != nil { b.Fatalf("failed to create ErasureStorage: %v", err) } writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21K bytes - Viewed (0) -
src/test/resources/plugin/repo3/index.html
<!DOCTYPE html> <html> <head> <title>Central Repository: org/codelibs/fess</title> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <style> body { background: #fff; } </style> </head> <body> <header> <h1>org/codelibs/fess</h1> </header> <hr/> <main> <pre id="contents"> <a href="../">../</a>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Mon Jun 17 13:30:41 UTC 2024 - 6.2K bytes - Viewed (0)