Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 529 for fetches (0.61 sec)

  1. cmd/bucket-policy-handlers_test.go

    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testGetBucketPolicyHandler, endpoints: []string{"PutBucketPolicy", "GetBucketPolicy"}})
    }
    
    // testGetBucketPolicyHandler - Test for end point which fetches the access policy json of the given bucket.
    func testGetBucketPolicyHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

            if (StringUtil.isNotBlank(name) && value != null) {
                httpClientPropertyMap.put(name, value);
            }
        }
    
        /**
         * Processes robots.txt for the given URL.
         * This method fetches and parses the robots.txt file to extract disallow/allow rules
         * and sitemap information.
         *
         * @param url The URL to process robots.txt for
         */
        protected void processRobotsTxt(final String url) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 53.7K bytes
    - Viewed (0)
  3. cmd/notification.go

    		go func(index int) {
    			defer wg.Done()
    			errs[index] = sys.peerClients[index].ReloadSiteReplicationConfig(ctx)
    		}(index)
    	}
    
    	wg.Wait()
    	return errs
    }
    
    // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers
    func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats {
    	errs := make([]error, len(sys.allPeerClients))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    			if endpoint.IsLocal && endpoint.Type() == URLEndpointType {
    				return endpoint.Host
    			}
    		}
    	}
    
    	return net.JoinHostPort(globalMinioHost, globalMinioPort)
    }
    
    // fetches a random number between range min-max.
    func getRandomRange(minN, maxN int, seed int64) int {
    	// special value -1 means no explicit seeding.
    	if seed == -1 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    		counter++
    	}
    	return notify
    }
    
    // fetchKMSStatus fetches KMS-related status information for all instances
    func fetchKMSStatus(ctx context.Context) []madmin.KMS {
    	if GlobalKMS == nil {
    		return []madmin.KMS{}
    	}
    
    	stat, err := GlobalKMS.Status(ctx)
    	if err != nil {
    		kmsLogIf(ctx, err, "failed to fetch KMS status information")
    		return []madmin.KMS{}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    			Description: getMinIOGORoutineCountMD(),
    			Value:       float64(runtime.NumGoroutine()),
    		})
    		return metrics
    	})
    	return mg
    }
    
    // getHistogramMetrics fetches histogram metrics and returns it in a []Metric
    // Note: Typically used in MetricGroup.RegisterRead
    //
    // The toLowerAPILabels parameter is added for compatibility,
    // if set, it lowercases the `api` label values.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

      @Test
      fun interceptorMakesAnUnrelatedRequest() {
        server.enqueue(MockResponse.Builder().body("a").build()) // Fetched by interceptor.
        server.enqueue(MockResponse.Builder().body("b").build()) // Fetched directly.
        client =
          client
            .newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain ->
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 16:11:23 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.6.md

    * `kubefed init` correctly checks for RBAC API enablement. ([#48077](https://github.com/kubernetes/kubernetes/pull/48077), [@liggitt](https://github.com/liggitt))
    * `kubectl api-versions` now always fetches information about enabled API groups and versions instead of using the local cache. ([#48016](https://github.com/kubernetes/kubernetes/pull/48016), [@liggitt](https://github.com/liggitt))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 304K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.8.md

    * Advanced audit policy now supports matching subresources and resource names, but the top level resource no longer matches the subresouce. For example "pods" no longer matches requests to the logs subresource of pods. Use "pods/logs" to match subresources. ([#48836](https://github.com/kubernetes/kubernetes/pull/48836), [@ericchiang](https://github.com/ericchiang))
    
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 312.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java

         * @return the servlet context
         */
        protected ServletContext getServletContext() {
            return LaServletContextUtil.getServletContext();
        }
    
        /**
         * Verifies that the CRUD mode matches the expected mode.
         *
         * @param crudMode the actual CRUD mode
         * @param expectedMode the expected CRUD mode
         * @param errorHook the error hook to call if verification fails
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 27 07:01:25 UTC 2025
    - 9.7K bytes
    - Viewed (0)
Back to top