- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for get_bucket (0.28 sec)
-
docs_src/nosql_databases/tutorial001.py
from couchbase.bucket import Bucket from couchbase.cluster import Cluster, PasswordAuthenticator from fastapi import FastAPI from pydantic import BaseModel USERPROFILE_DOC_TYPE = "userprofile" def get_bucket(): cluster = Cluster( "couchbase://couchbasehost:8091?fetch_mutation_tokens=1&operation_timeout=30&n1ql_timeout=300" ) authenticator = PasswordAuthenticator("username", "password")
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat May 14 11:59:59 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/global-heal.go
var forwardTo string // If we resume to the same bucket, forward to last known item. if b := tracker.getBucket(); b != "" { if b == bucket { forwardTo = tracker.getObject() } else { // Reset to where last bucket ended if resuming. tracker.resume() } } tracker.setObject("") tracker.setBucket(bucket) // Heal current bucket again in case if it is failed // in the beginning of erasure set healing
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/metacache-manager.go
if ok { return b.updateCacheEntry(update) } // We should have either a trashed bucket or this return metacache{}, errVolumeNotFound } // getBucket will get a bucket metacache or load it from disk if needed. func (m *metacacheManager) getBucket(ctx context.Context, bucket string) *bucketMetacache { m.init.Do(m.initManager) // Return a transient bucket for invalid or system buckets. m.mu.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/SearchLogService.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 28.4K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
func (h healingTracker) getLastUpdate() time.Time { h.mu.RLock() defer h.mu.RUnlock() return h.LastUpdate } func (h healingTracker) getBucket() string { h.mu.RLock() defer h.mu.RUnlock() return h.Bucket } func (h *healingTracker) setBucket(bucket string) { h.mu.Lock() defer h.mu.Unlock() h.Bucket = bucket } func (h healingTracker) getObject() string { h.mu.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package bandwidth import ( "sync" "sync/atomic" "time" ) const ( // betaBucket is the weight used to calculate exponential moving average betaBucket = 0.1 // Number of averages considered = 1/(1-betaObject) ) // bucketMeasurement captures the bandwidth details for one bucket type bucketMeasurement struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
README.md
[![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](https://github.com/gitbucket/gitbucket/blob/master/LICENSE) ## Overview
Plain Text - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sun Feb 25 00:40:07 GMT 2024 - 7.6K bytes - Viewed (0) -
src/test/resources/plugin/repo1/index.html
<a href="fess-ds-elasticsearch/" title="fess-ds-elasticsearch/">fess-ds-elasticsearch/</a> - - <a href="fess-ds-gitbucket/" title="fess-ds-gitbucket/">fess-ds-gitbucket/</a> - - <a href="fess-ds-gsuite/" title="fess-ds-gsuite/">fess-ds-gsuite/</a> - -
HTML - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Tue Aug 13 07:34:14 GMT 2019 - 3.3K bytes - Viewed (0) -
README.fr.md
[![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](https://github.com/gitbucket/gitbucket/blob/master/LICENSE) ## Overview Fess est un serveur de moteur de recherche très puissant et facile à déployer en entreprise.
Plain Text - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Mon Feb 06 22:59:17 GMT 2023 - 8.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/FacetResponse.java
name = new String(BaseEncoding.base64().decode(encodedField), StandardCharsets.UTF_8); for (final Terms.Bucket tfEntry : termFacet.getBuckets()) { valueCountMap.put(tfEntry.getKeyAsString(), tfEntry.getDocCount()); } } /** * @return the valueCountMap */
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.3K bytes - Viewed (0)