- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for get_bucket (0.31 sec)
-
internal/bucket/bandwidth/monitor_test.go
test2Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{ LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: exponentialMovingAverage(betaBucket, float64(oneMiB), 2*float64(oneMiB)), } test1ActiveBuckets := make(map[BucketOptions]*bucketMeasurement) test1ActiveBuckets[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = m0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 4.3K bytes - Viewed (0) -
src/test/resources/plugin/repo2/index.html
HTML - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Tue Aug 13 07:34:14 GMT 2019 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
searchResponse.ifPresent(response -> { final Terms terms = response.getAggregations().get(fessConfig.getIndexFieldSegment()); for (final Bucket bucket : terms.getBuckets()) { final Map<String, String> map = new HashMap<>(2); map.put(fessConfig.getIndexFieldSegment(), bucket.getKey().toString());
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 10.6K bytes - Viewed (1) -
cmd/metacache-server-pool.go
if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o) c = &resp } else { rctx, cancel := context.WithTimeout(ctx, 5*time.Second) c, err = rpc.GetMetacacheListing(rctx, *o) cancel() } if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/postpolicyform_test.go
t.Errorf("Expected failed but succeeded") } }) } } // Test Post Policy parsing and checking conditions func TestPostPolicyForm(t *testing.T) { pp := minio.NewPostPolicy() pp.SetBucket("testbucket") pp.SetContentType("image/jpeg") pp.SetUserMetadata("uuid", "14365123651274") pp.SetKeyStartsWith("user/user1/filename") pp.SetContentLengthRange(1048579, 10485760) pp.SetSuccessStatusAction("201")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 8.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
// this code is present to avoid any missing meta buckets on other // pools. for _, metaBucket := range []string{ pathJoin(minioMetaBucket, minioConfigPrefix), pathJoin(minioMetaBucket, bucketMetaPrefix), } { var bucketExists BucketExists if err = z.MakeBucket(ctx, metaBucket, MakeBucketOptions{}); err != nil { if !errors.As(err, &bucketExists) { return err } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/peer-rest-client.go
} // GetMetacacheListing - get a new or existing metacache. func (client *peerRESTClient) GetMetacacheListing(ctx context.Context, o listPathOptions) (*metacache, error) { if client == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(o) return &resp, nil } return getMetacacheListingRPC.Call(ctx, client.gridConn(), &o) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/peer-rest-server.go
} return } func (s *peerRESTServer) GetMetacacheListingHandler(opts *listPathOptions) (*metacache, *grid.RemoteErr) { resp := localMetacacheMgr.getBucket(context.Background(), opts.Bucket).findCache(*opts) return &resp, nil } func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)