Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewTicker (0.33 sec)

  1. internal/store/store.go

    func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key {
    	keyCh := make(chan Key)
    
    	go func() {
    		defer xioutil.SafeClose(keyCh)
    
    		retryTicker := time.NewTicker(retryInterval)
    		defer retryTicker.Stop()
    
    		for {
    			names, err := store.List()
    			if err != nil {
    				log(context.Background(), fmt.Errorf("store.List() failed with: %w", err), id)
    			} else {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 3.5K 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/metrics-v2_test.go

    			label: labels[1],
    		},
    		{
    			val:   0.31,
    			label: labels[1],
    		},
    		{
    			val:   0.61,
    			label: labels[3],
    		},
    		{
    			val:   0.79,
    			label: labels[2],
    		},
    	}
    	ticker := time.NewTicker(1 * time.Millisecond)
    	defer ticker.Stop()
    	for _, obs := range observations {
    		// Send observations once every 1ms, to simulate delay between
    		// observations. This is to test the channel based
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  4. cmd/metacache-manager.go

    	// Start saver when object layer is ready.
    	go func() {
    		objAPI := newObjectLayerFn()
    		for objAPI == nil {
    			time.Sleep(time.Second)
    			objAPI = newObjectLayerFn()
    		}
    
    		t := time.NewTicker(time.Minute)
    		defer t.Stop()
    
    		var exit bool
    		for !exit {
    			select {
    			case <-t.C:
    			case <-GlobalContext.Done():
    				exit = true
    			}
    			m.mu.RLock()
    			for _, v := range m.buckets {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  5. internal/bucket/bandwidth/monitor.go

    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    	return m
    }
    
    func (m *Monitor) updateMeasurement(opts BucketOptions, bytes uint64) {
    	m.mlock.Lock()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/site-replication-metrics.go

    	} else {
    		srs.XferRateSml.addSize(sz, duration)
    	}
    }
    
    func newSRStats() *SRStats {
    	s := SRStats{
    		M:               make(map[string]*SRStatus),
    		movingAvgTicker: time.NewTicker(time.Second * 2),
    	}
    	go s.trackEWMA()
    	return &s
    }
    
    func (sr *SRStats) trackEWMA() {
    	for {
    		select {
    		case <-sr.movingAvgTicker.C:
    			sr.updateMovingAvg()
    		case <-GlobalContext.Done():
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  7. cmd/tier-journal.go

    	}
    	err = w.Remove(ctx, objName, remoteVersionID(rvID))
    	if err != nil {
    		return err
    	}
    	return nil
    }
    
    func (jd *tierDiskJournal) deletePending(ctx context.Context) {
    	ticker := time.NewTicker(30 * time.Minute)
    	defer ticker.Stop()
    	for {
    		select {
    		case <-ticker.C:
    			jd.WalkEntries(ctx, deleteObjectFromRemoteTier)
    
    		case <-ctx.Done():
    			jd.Close()
    			return
    		}
    	}
    }
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  8. internal/grid/muxserver.go

    	handlerErr = handler.Handle(ctx, msg.Payload, handlerIn, send)
    	return handlerErr
    }
    
    // checkRemoteAlive will check if the remote is alive.
    func (m *muxServer) checkRemoteAlive() {
    	t := time.NewTicker(lastPingThreshold / 4)
    	defer t.Stop()
    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > lastPingThreshold {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
Back to top