Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/store/batch.go

    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
    	items map[K]T
    	limit uint32
    
    	sync.Mutex
    }
    
    // Add adds the item to the batch
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 2.5K bytes
    - Viewed (0)
  2. internal/config/batch/batch.go

    	EnvKeyRotationWorkersWait   = "MINIO_BATCH_KEYROTATION_WORKERS_WAIT"
    	EnvKeyExpirationWorkersWait = "MINIO_BATCH_EXPIRATION_WORKERS_WAIT"
    )
    
    var configMu sync.RWMutex
    
    // Config represents the batch job settings.
    type Config struct {
    	ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"`
    	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
    	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
    }
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K bytes
    - Viewed (0)
Back to top