Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for forwardly (0.15 sec)

  1. cmd/tier-last-day-stats.go

    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. internal/handlers/proxy.go

    )
    
    var (
    	// De-facto standard header keys.
    	xForwardedFor    = http.CanonicalHeaderKey("X-Forwarded-For")
    	xForwardedHost   = http.CanonicalHeaderKey("X-Forwarded-Host")
    	xForwardedPort   = http.CanonicalHeaderKey("X-Forwarded-Port")
    	xForwardedProto  = http.CanonicalHeaderKey("X-Forwarded-Proto")
    	xForwardedScheme = http.CanonicalHeaderKey("X-Forwarded-Scheme")
    	xRealIP          = http.CanonicalHeaderKey("X-Real-IP")
    )
    
    var (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  3. internal/handlers/proxy_test.go

    		{xForwardedScheme, "http", "http"},
    		{xForwardedScheme, "HTTP", "http"},
    		{forwarded, `For="[2001:db8:cafe::17]:4711`, ""},                    // No proto
    		{forwarded, `for=192.0.2.43, for=198.51.100.17;proto=https`, ""},    // Multiple params, will be empty.
    		{forwarded, `for=172.32.10.15; proto=https;by=127.0.0.1;`, "https"}, // Space before proto
    		{forwarded, `for=192.0.2.60;proto=http;by=203.0.113.43`, "http"},    // Multiple params
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  4. cmd/data-usage.go

    		}
    	}
    
    	var dataUsageInfo DataUsageInfo
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err = json.Unmarshal(buf, &dataUsageInfo); err != nil {
    		return DataUsageInfo{}, err
    	}
    	// For forward compatibility reasons, we need to add this code.
    	if len(dataUsageInfo.BucketsUsage) == 0 {
    		dataUsageInfo.BucketsUsage = make(map[string]BucketUsageInfo, len(dataUsageInfo.BucketSizes))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  5. internal/cachevalue/cache.go

    	t.Once.Do(func() {
    		t.ttl = ttl
    		t.updateFn = update
    		t.opts = opts
    	})
    }
    
    // Get will return a cached value or fetch a new one.
    // Tf the Update function returns an error the value is forwarded as is and not cached.
    func (t *Cache[T]) Get() (T, error) {
    	v := t.valErr.Load()
    	ttl := t.ttl
    	vTime := t.lastUpdateMs.Load()
    	tNow := time.Now().UnixMilli()
    	if v != nil && tNow-vTime < ttl.Milliseconds() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top