Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewHTTPFetcher (0.5 sec)

  1. pkg/wasm/httpfetcher_test.go

    			wantWasmModule := "wasm\n"
    			ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    				c.handler(w, r, gotNumRequest)
    				gotNumRequest++
    			}))
    			defer ts.Close()
    			fetcher := NewHTTPFetcher(DefaultHTTPRequestTimeout, DefaultHTTPRequestMaxRetries)
    			fetcher.initialBackoff = time.Microsecond
    			ctx, cancel := context.WithTimeout(context.Background(), c.timeout)
    			defer cancel()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 24 15:56:41 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  2. pkg/wasm/httpfetcher.go

    	insecureClient  *http.Client
    	initialBackoff  time.Duration
    	requestMaxRetry int
    }
    
    // NewHTTPFetcher create a new HTTP remote wasm module fetcher.
    // requestTimeout is a timeout for each HTTP/HTTPS request.
    // requestMaxRetry is # of maximum retries of HTTP/HTTPS requests.
    func NewHTTPFetcher(requestTimeout time.Duration, requestMaxRetry int) *HTTPFetcher {
    	if requestTimeout == 0 {
    		requestTimeout = 5 * time.Second
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 14 20:23:34 UTC 2022
    - 5.5K bytes
    - Viewed (0)
  3. pkg/wasm/cache.go

    	wasmLog.Debugf("LocalFileCache is created with the option\n%#v", options)
    
    	cacheOptions := cacheOptions{Options: options}
    	cache := &LocalFileCache{
    		httpFetcher:  NewHTTPFetcher(options.HTTPRequestTimeout, options.HTTPRequestMaxRetries),
    		modules:      make(map[moduleKey]*cacheEntry),
    		checksums:    make(map[string]*checksumEntry),
    		dir:          dir,
    		cacheOptions: cacheOptions.sanitize(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top