Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for errorea (0.13 sec)

  1. internal/store/batch.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"errors"
    	"fmt"
    	"sync"
    )
    
    // ErrBatchFull indicates that the batch is full
    var ErrBatchFull = errors.New("batch is full")
    
    type key interface {
    	string | int | int64
    }
    
    // Batch represents an ordered batch
    type Batch[K key, T any] struct {
    	keys  []K
    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

    		Value: "0ms", // No wait by default between each expiration attempts.
    	},
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.BatchSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	cfg.ReplicationWorkersWait = 0
    	cfg.KeyRotationWorkersWait = 0
    	cfg.ExpirationWorkersWait = 0
    
    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