Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for if (0.14 sec)

  1. internal/store/batch.go

    	keys  []K
    	items map[K]T
    	limit uint32
    
    	sync.Mutex
    }
    
    // Add adds the item to the batch
    func (b *Batch[K, T]) Add(key K, item T) error {
    	b.Lock()
    	defer b.Unlock()
    
    	if b.isFull() {
    		return ErrBatchFull
    	}
    
    	if _, ok := b.items[key]; !ok {
    		b.keys = append(b.keys, key)
    	}
    	b.items[key] = item
    
    	return nil
    }
    
    // GetAll fetches the items and resets the batch
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 2.5K bytes
    - Viewed (0)
  2. internal/config/batch/batch.go

    	if err != nil {
    		return cfg, err
    	}
    	if eduration < 0 {
    		return cfg, config.ErrInvalidBatchExpirationWorkersWait(nil)
    	}
    
    	if rduration > 0 {
    		cfg.ReplicationWorkersWait = rduration
    	}
    
    	if kduration > 0 {
    		cfg.KeyRotationWorkersWait = kduration
    	}
    
    	if eduration > 0 {
    		cfg.ExpirationWorkersWait = eduration
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K bytes
    - Viewed (0)
Back to top