Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PutMultiple (0.21 sec)

  1. internal/store/queuestore.go

    	}
    
    	return nil
    }
    
    // Delete - Remove the store directory from disk
    func (store *QueueStore[_]) Delete() error {
    	return os.Remove(store.directory)
    }
    
    // PutMultiple - puts an item to the store.
    func (store *QueueStore[I]) PutMultiple(item []I) error {
    	store.Lock()
    	defer store.Unlock()
    	if uint64(len(store.entries)) >= store.entryLimit {
    		return errLimitExceeded
    	}
    	// Generate a new UUID for the key.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  2. internal/store/store.go

    // Target - store target interface
    type Target interface {
    	Name() string
    	SendFromStore(key Key) error
    }
    
    // Store - Used to persist items.
    type Store[I any] interface {
    	Put(item I) error
    	PutMultiple(item []I) error
    	Get(key string) (I, error)
    	GetRaw(key string) ([]byte, error)
    	Len() int
    	List() ([]string, error)
    	Del(key string) error
    	DelList(key []string) error
    	Open() error
    	Delete() error
    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)
  3. internal/logger/target/http/http.go

    					go h.startQueueProcessor(ctx, false)
    				}
    			}
    		}
    
    		if !isDirQueue {
    			err = h.send(ctx, buf.Bytes(), h.payloadType, webhookCallTimeout)
    		} else {
    			err = h.store.PutMultiple(entries)
    		}
    
    		if err != nil {
    
    			h.config.LogOnceIf(
    				context.Background(),
    				fmt.Errorf("unable to send webhook log entry to '%s' err '%w'", name, err),
    				name,
    			)
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
Back to top