- Sort Score
- Result 10 results
- Languages All
Results 31 - 37 of 37 for newobject (0.26 sec)
-
src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java
final XContentBuilder builder = XContentFactory.jsonBuilder(); builder.startObject(); response.toXContent(builder, ToXContent.EMPTY_PARAMS); builder.endObject(); builder.flush(); try (OutputStream out = builder.getOutputStream()) { stats = ((ByteArrayOutputStream) out).toString(Constants.UTF_8); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/warm-backend-s3.go
return nil, s3.ToObjectError(err, object) } } c := &minio.Core{Client: s3.client} // Important to use core primitives here to pass range get options as is. r, _, _, err := c.GetObject(ctx, s3.Bucket, s3.getDest(object), gopts) if err != nil { return nil, s3.ToObjectError(err, object) } return r, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.5K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
var partsMD5Sum [][]byte var failedMD5 bool for p := 1; p <= parts; p++ { opts := minio.GetObjectOptions{ VersionID: object.VersionID, PartNumber: p, } obj, err := s3Client.GetObject(context.Background(), bucket, object.Key, opts) if err != nil { log.Println("FAILED: GET", objFullPath(object), "=>", err) failedMD5 = true break } h := md5.New()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Feb 17 01:15:57 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
// GCS storage decompresses a gzipped object by default and returns the data. // Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding // Need to set `Accept-Encoding` header to `gzip` when issuing a GetObject call, to be able // to download the object in compressed state. // Calling ReadCompressed with true accomplishes that. object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/policy_test.go
Effect: string(policy.Allow), Principal: miniogopolicy.User{AWS: set.CreateStringSet("*")}, Resources: set.CreateStringSet(policy.NewResource(bucketName + "/" + prefix).String()), Actions: set.CreateStringSet("s3:GetObject"), }, } } func TestPolicyToBucketAccessPolicy(t *testing.T) { case1Policy := &policy.BucketPolicy{ Version: policy.DefaultVersion, Statements: []policy.BPStatement{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/sftp-server_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 8K bytes - Viewed (0) -
plugin/pkg/admission/runtimeclass/admission.go
func (r *RuntimeClass) prepareObjects(ctx context.Context, attributes admission.Attributes) (pod *api.Pod, runtimeClass *nodev1.RuntimeClass, err error) { pod, ok := attributes.GetObject().(*api.Pod) if !ok { return nil, nil, apierrors.NewBadRequest("Resource was marked with kind Pod but was unable to be converted") } if pod.Spec.RuntimeClassName == nil { return pod, nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 05:53:38 UTC 2024 - 8.9K bytes - Viewed (0)