- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 804 for store (0.16 sec)
-
internal/config/dns/store.go
// ErrBucketConflict for buckets that already exist type ErrBucketConflict Error func (e ErrBucketConflict) Error() string { return e.Bucket + " bucket conflict error: " + e.Err.Error() } // Store dns record store type Store interface { Put(bucket string) error Get(bucket string) ([]SrvRecord, error) Delete(bucket string) error List() (map[string][]SrvRecord, error) DeleteRecord(record SrvRecord) error Close() error
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.6K bytes - Viewed (0) -
internal/store/store.go
return } } } // StreamItems reads the keys from the store and replays the corresponding item to the target. func StreamItems[I any](store Store[I], target Target, doneCh <-chan struct{}, logger logger) { go func() { // Replays the items from the store. keyCh := replayItems(store, doneCh, logger, target.Name()) // Send items from the store. sendItems(target, keyCh, doneCh, logger) }()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 3.6K bytes - Viewed (0) -
cmd/iam-store.go
} // HasWatcher - returns if the storage system has a watcher. func (store *IAMStoreSys) HasWatcher() bool { _, ok := store.IAMStorageAPI.(iamStorageWatcher) return ok } // GetUser - fetches credential from memory. func (store *IAMStoreSys) GetUser(user string) (UserIdentity, bool) { cache := store.rlock() defer store.runlock() u, ok := cache.iamUsersMap[user] if !ok { // Check the sts map
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:19:50 GMT 2024 - 73.2K bytes - Viewed (2) -
cmd/iam-object-store.go
} // PurgeExpiredSTS - purge expired STS credentials from object store. func (iamOS *IAMObjectStore) PurgeExpiredSTS(ctx context.Context) error { if iamOS.objAPI == nil { return errServerNotInitialized } bootstrapTraceMsg("purging expired STS credentials") // Scan STS users on disk and purge expired ones. We do not need to hold a // lock with store.lock() here.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Mar 02 00:21:34 GMT 2024 - 19.2K bytes - Viewed (0) -
cmd/iam-etcd-store.go
Harshavardhana <******@****.***> 1709338894 -0800
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Mar 02 00:21:34 GMT 2024 - 13.7K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/object_store_immutable_days.png
object_store_immutable_days.png...
PNG Image - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Jul 17 00:16:53 GMT 2020 - 12.6K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/1_add_object_store.png
1_add_object_store.png...
PNG Image - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Apr 17 00:36:14 GMT 2020 - 42.6K bytes - Viewed (0) -
cmd/iam-etcd-store_test.go
Harshavardhana <******@****.***> 1618774873 -0700
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 1.5K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/6_add_sobr_with_object_store.png
6_add_sobr_with_object_store.png...
PNG Image - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Apr 17 00:36:14 GMT 2020 - 31.5K bytes - Viewed (0) -
internal/store/queuestore.go
if err := os.WriteFile(path, eventData, os.FileMode(0o770)); err != nil { return err } // Increment the item count. store.entries[key] = time.Now().UnixNano() return nil } // Put - puts an item to the store. func (store *QueueStore[I]) Put(item I) error { store.Lock() defer store.Unlock() if uint64(len(store.entries)) >= store.entryLimit {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 5.5K bytes - Viewed (0)