- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 212 for copts (0.03 sec)
-
cmd/erasure-healing.go
if b > 0 && b == a { opts.Error = fmt.Sprintf("unable to heal %d missing blocks on drives", b) } opts.Tags = map[string]string{ "healObject": auditObjectOp{ Name: opts.Object, Pool: er.poolIndex + 1, Set: er.setIndex + 1, }.String(), } auditLogInternal(ctx, opts) } // Heals an object by re-writing corrupt/missing erasure blocks.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/object-api-utils.go
// not all run!). func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions, h http.Header) ( fn ObjReaderFn, off, length int64, err error, ) { if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) { return nil, 0, 0, PreConditionFailed{} } if rs == nil && opts.PartNumber > 0 { rs = partNumberToRangeSpec(oi, opts.PartNumber) } _, isEncrypted := crypto.IsEncrypted(oi.UserDefined)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
idxCb = compressionIndexEncrypter(objectEncryptionKey, idxCb) } opts.EncryptFn = metadataEncrypter(objectEncryptionKey) } } opts.IndexCB = idxCb opts.ReplicationRequest = sourceReplReq putObjectPart := objectAPI.PutObjectPart partInfo, err := putObjectPart(ctx, bucket, object, uploadID, partID, pReader, opts) if err != nil { // Verify if the underlying error is signature mismatch.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
cmd/erasure-healing_test.go
data := bytes.Repeat([]byte("a"), 5*1024*1024) var opts ObjectOptions err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{}) if err != nil { t.Fatalf("Failed to make a bucket - %v", err) } // Create an object with multiple parts uploaded in decreasing // part number. res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
.bazelrc
build:windows --copt=/W0 build:windows --host_copt=/W0 # Suppress most C++ compiler warnings to reduce log size but allow # for specific warnings to still be present. build:linux --copt="-Wno-all" build:linux --copt="-Wno-extra" build:linux --copt="-Wno-deprecated" build:linux --copt="-Wno-deprecated-declarations" build:linux --copt="-Wno-ignored-attributes" build:linux --copt="-Wno-array-bounds" # Add unused-result as an error on Linux.
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Mon Oct 28 22:02:31 UTC 2024 - 51.3K bytes - Viewed (0) -
cmd/notification.go
if report == nil || report.BucketStats == nil { continue } for opts := range report.BucketStats { d, ok := consolidatedReport.BucketStats[opts] if !ok { d = bandwidth.Details{ LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond, } } dt, ok := report.BucketStats[opts] if ok { d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/object-api-options.go
opts, err = getDefaultOpts(hdr, false, metadata) if err != nil { return opts, err } opts.MTime = mtime opts.ReplicationSourceLegalholdTimestamp = lholdtimestmp opts.ReplicationSourceRetentionTimestamp = retaintimestmp opts.ReplicationSourceTaggingTimestamp = taggingtimestmp opts.PreserveETag = etag opts.WantChecksum = wantCRC return opts, nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 21 21:13:59 UTC 2024 - 14.4K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
defer con.Close() } func TestNatsConnUserPass(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14223 opts.Username = "testminio" opts.Password = "miniotest" s := natsserver.RunServer(&opts) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test",
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/metacache-walk.go
} return nil } // Stream output. return scanDir(opts.BaseDir) } func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { if err := p.checkID(opts.DiskID); err != nil { return err } ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir) if err != nil { return err } defer done(0, &err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
ServiceAccount: serviceAccount, Namespace: ns, CloudrunAddr: opts.IstiodAddr, }.ToStruct(), CertDir: opts.CertDir, InsecureSkipVerify: opts.InsecureSkipVerify, XDSSAN: opts.XDSSAN, GrpcOpts: grpcOpts, }, }, nil) if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0)