Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for Yano (0.27 sec)

  1. internal/store/queuestore.go

    // QueueStore - Filestore for persisting items.
    type QueueStore[_ any] struct {
    	sync.RWMutex
    	entryLimit uint64
    	directory  string
    	fileExt    string
    
    	entries map[string]int64 // key -> modtime as unix nano
    }
    
    // NewQueueStore - Creates an instance for QueueStore.
    func NewQueueStore[I any](directory string, limit uint64, ext string) *QueueStore[I] {
    	if limit == 0 {
    		limit = defaultLimit
    	}
    
    	if ext == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
Back to top