- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 153 for if (0.12 sec)
-
cmd/object-multipart-handlers.go
return } // Check if bucket encryption is enabled sseConfig, _ := globalBucketSSEConfigSys.Get(bucket) sseConfig.Apply(r.Header, sse.ApplyOptions{ AutoEncrypt: globalAutoEncryption, }) // Validate storage class metadata if present if sc := r.Header.Get(xhttp.AmzStorageClass); sc != "" { if !storageclass.IsValid(sc) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
if err != nil { return nil, err } if _, nbuf, err := msgp.ReadUint32Bytes(b); err == nil { // Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, err = msgp.CopyToJSON(buf, bytes.NewReader(v)) if err != nil { return nil, err } data = b case 3: v, b, err := msgp.ReadBytesZC(b) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/auth-handler.go
} else if isRequestSignStreamingTrailerV4(r) { return authTypeStreamingSignedTrailer } else if isRequestUnsignedTrailerV4(r) { return authTypeStreamingUnsignedTrailer } else if isRequestSignatureV4(r) { return authTypeSigned } else if isRequestPresignedSignatureV4(r) { return authTypePresigned } else if isRequestJWT(r) { return authTypeJWT } else if isRequestPostPolicySignatureV4(r) { return authTypePostPolicy
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
cmd/metacache-set_gen.go
if err != nil { err = msgp.WrapError(err, "FilterPrefix") return } case "Marker": z.Marker, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Marker") return } case "Limit": z.Limit, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Limit") return } case "AskDisks": z.AskDisks, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/kms-handlers.go
if objectAPI == nil { return } if GlobalKMS == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrKMSNotConfigured), r.URL) return } if _, ok := GlobalKMS.(kms.KeyManager); !ok { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } metrics, err := GlobalKMS.Metrics(ctx) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 20.7K bytes - Viewed (0) -
internal/hash/checksum.go
b = b[n:] if part > 0 { cs = "" } if typ.Is(ChecksumIncludesMultipart) { wantLen := int(t) * length if len(b) < wantLen { break } // Read part checksum if part > 0 && uint64(part) <= t { offset := (part - 1) * length partCs := b[offset:] cs = base64.StdEncoding.EncodeToString(partCs[:length]) } b = b[wantLen:] } } else if part > 1 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
internal/event/target/nats.go
} if n.Username != "" && n.Password == "" || n.Username == "" && n.Password != "" { return errors.New("username and password must be specified as a pair") } if n.Streaming.Enable { if n.Streaming.ClusterID == "" { return errors.New("empty cluster id") } } if n.JetStream.Enable { if n.Subject == "" { return errors.New("empty subject") } } if n.QueueDir != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/bucket-targets.go
found := false for idx, t := range tgts { if t.Type == tgt.Type { if t.Arn == tgt.Arn { if !update { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket} } newtgts[idx] = *tgt found = true continue } // fail if endpoint is already present in list of targets and not a matching ARN if t.Endpoint == tgt.Endpoint { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// checkID will check if the disk ID matches the provided ID. func (p *xlStorageDiskIDCheck) checkID(wantID string) (err error) { if wantID == "" { return nil } id, err := p.storage.GetDiskID() if err != nil { return err } if id != wantID { return fmt.Errorf("disk ID %s does not match. disk reports %s", wantID, id) } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/event/target/kafka.go
if target.batch.IsFull() { if err := target.commitBatch(); err != nil { return err } } if _, ok := target.batch.GetByKey(key.Name); !ok { eventData, err := target.store.Get(key.Name) if err != nil { if os.IsNotExist(err) { return nil } return err } msg, err := target.toProducerMessage(eventData) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0)