- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PutMultiple (0.21 sec)
-
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) -
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) -
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)