- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for Mock (0.17 sec)
-
internal/store/batch.go
func (b *Batch[K, T]) GetByKey(key K) (T, bool) { b.Lock() defer b.Unlock() item, ok := b.items[key] return item, ok } // Len returns the no of items in the batch func (b *Batch[K, T]) Len() int { b.Lock() defer b.Unlock() return len(b.keys) } // IsFull checks if the batch is full or not func (b *Batch[K, T]) IsFull() bool { b.Lock() defer b.Unlock() return b.isFull() }
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) -
internal/config/batch/batch.go
KeyRotationWorkersWait: opts.KeyRotationWorkersWait, ExpirationWorkersWait: opts.ExpirationWorkersWait, } } // Update updates opts with nopts func (opts *Config) Update(nopts Config) { configMu.Lock() defer configMu.Unlock() opts.ReplicationWorkersWait = nopts.ReplicationWorkersWait opts.KeyRotationWorkersWait = nopts.KeyRotationWorkersWait opts.ExpirationWorkersWait = nopts.ExpirationWorkersWait }
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)