Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 809 for timme (0.03 sec)

  1. cmd/data-scanner.go

    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Run the data scanner in a loop
    		for {
    			runDataScanner(ctx, objAPI)
    			duration := time.Duration(r.Float64() * float64(scannerCycle.Load()))
    			if duration < time.Second {
    				// Make sure to sleep at least a second to avoid high CPU ticks.
    				duration = time.Second
    			}
    			time.Sleep(duration)
    		}
    	}()
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    		if pingInterval < 1 {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL)
    			return
    		}
    		t := time.NewTicker(time.Duration(pingInterval) * time.Second)
    		defer t.Stop()
    		emptyEventTicker = t.C
    	} else {
    		// Deprecated Apr 2023
    		t := time.NewTicker(500 * time.Millisecond)
    		defer t.Stop()
    		keepAliveTicker = t.C
    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/expiration.go

    	if eDays == 0 {
    		return nil
    	}
    	return e.EncodeElement(int(eDays), startElement)
    }
    
    // ExpirationDate is a embedded type containing time.Time to unmarshal
    // Date in Expiration
    type ExpirationDate struct {
    	time.Time
    }
    
    // UnmarshalXML parses date from Expiration and validates date format
    func (eDate *ExpirationDate) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. cmd/site-replication-metrics.go

    		s.XferRateSml.measure.updateExponentialMovingAverage(time.Now())
    	}
    }
    
    // SRMetric captures replication metrics for a deployment
    type SRMetric struct {
    	DeploymentID  string             `json:"deploymentID"`
    	Endpoint      string             `json:"endpoint"`
    	TotalDowntime time.Duration      `json:"totalDowntime"`
    	LastOnline    time.Time          `json:"lastOnline"`
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. cmd/metrics-v3-cache.go

    		// values for IOStat related disk metrics e.g. reads/sec.
    		prevDriveIOStats            map[string]madmin.DiskIOStats
    		prevDriveIOStatsMu          sync.RWMutex
    		prevDriveIOStatsRefreshedAt time.Time
    	)
    
    	loadDriveMetrics := func(ctx context.Context) (v storageMetrics, err error) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    		jobCancelers: make(map[string]context.CancelFunc),
    	}
    	jpool.ResizeWorkers(workers)
    
    	randomWait := func() time.Duration {
    		// randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time.
    		return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour))
    	}
    
    	go func() {
    		jpool.resume(randomWait)
    		jpool.cleanupReports(randomWait)
    	}()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  7. schema/model_test.go

    	Active    *bool
    }
    
    type (
    	mytime time.Time
    	myint  int
    	mybool = bool
    )
    
    type AdvancedDataTypeUser struct {
    	ID           sql.NullInt64
    	Name         *sql.NullString
    	Birthday     sql.NullTime
    	RegisteredAt mytime
    	DeletedAt    *mytime
    	Active       mybool
    	Admin        *mybool
    }
    
    type BaseModel struct {
    	ID        uint
    	CreatedAt time.Time
    	CreatedBy *int
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    			if h.batchSize > 1 && time.Since(lastBatchProcess) < time.Second {
    				continue
    			}
    		}
    
    		// if we have reached the count send at once
    		// or we have crossed last second before batch was sent, send at once
    		lastBatchProcess = time.Now()
    
    		var retries int
    		retryIntvl := h.config.RetryIntvl
    		if retryIntvl <= 0 {
    			retryIntvl = 3 * time.Second
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. tests/serializer_test.go

    	CreatedTime            int64                  `gorm:"serializer:unixtime;type:datetime"` // store time in db, use int as field type
    	UpdatedTime            *int64                 `gorm:"serializer:unixtime;type:datetime"` // store time in db, use int as field type
    	CustomSerializerString string                 `gorm:"serializer:custom"`
    	EncryptedString        EncryptedString
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  10. internal/config/identity/openid/jwt_test.go

    		t.Fatal(err)
    	}
    }
    
    func TestDefaultExpiryDuration(t *testing.T) {
    	testCases := []struct {
    		reqURL    string
    		duration  time.Duration
    		expectErr bool
    	}{
    		{
    			reqURL:   "http://127.0.0.1:8443/?Token=xxxxx",
    			duration: time.Duration(60) * time.Minute,
    		},
    		{
    			reqURL:    "http://127.0.0.1:8443/?DurationSeconds=9s",
    			expectErr: true,
    		},
    		{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top