- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 251 for One (0.12 sec)
-
internal/event/rules.go
// Add - adds pattern and target ID. func (rules Rules) Add(pattern string, targetID TargetID) { rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern]) } // MatchSimple - returns true one of the matching object name in rules. func (rules Rules) MatchSimple(objectName string) bool { for pattern := range rules { if wildcard.MatchSimple(pattern, objectName) { return true } } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.7K bytes - Viewed (0) -
cmd/mrf.go
} // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan partialOperation } // Add a partial S3 operation (put/delete) when one or more disks are offline. func (m *mrfState) addPartialOp(op partialOperation) { if m == nil { return } select { case m.opCh <- op: default: } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
if string(found) == key { vals = append(vals, value) plSize += len(value) replaced = true } else { vals = append(vals, foundVal) plSize += len(foundVal) } } // Add one more. if !replaced { keys = append(keys, []byte(key)) vals = append(vals, value) plSize += len(key) + len(value) + msgp.StringPrefixSize + msgp.ArrayHeaderSize } // Reserialize...
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/erasure-object_test.go
if tt.expectedWriteQuorum != actualWriteQuorum { t.Errorf("Expected Write Quorum %d, got %d", tt.expectedWriteQuorum, actualWriteQuorum) } }) } } // In some deployments, one object has data inlined in one disk and not inlined in other disks. func TestGetObjectInlineNotInline(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
docs/bucket/retention/README.md
### 2. Set bucket WORM configuration WORM on a bucket is enabled by setting object lock configuration. This configuration is applied to all the objects in the bucket. Below is an example to set `Governance` mode and one day retention time on `mybucket`. ```sh awscli s3api put-object-lock-configuration --bucket mybucket --object-lock-configuration 'ObjectLockEnabled=\"Enabled\",Rule={DefaultRetention={Mode=\"GOVERNANCE\",Days=1}}' ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/bucket/lifecycle/rule.go
} // validateStatus - checks if status is valid or not. func (r Rule) validateStatus() error { // Status can't be empty if len(r.Status) == 0 { return errEmptyRuleStatus } // Status must be one of Enabled or Disabled if r.Status != Enabled && r.Status != Disabled { return errInvalidRuleStatus } return nil } func (r Rule) validateExpiration() error { return r.Expiration.Validate() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/config/etcd/etcd.go
if err != nil { return nil, false, err } if etcdSecure && u.Scheme == "http" { return nil, false, config.Errorf("all endpoints should be https or http: %s", endpoint) } // If one of the endpoint is https, we will use https directly. etcdSecure = etcdSecure || u.Scheme == "https" } return etcdEndpoints, etcdSecure, nil } // Enabled returns if etcd is enabled.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/storage-errors.go
return string(h) } // Collection of basic errors. var baseErrs = []error{ errDiskNotFound, errFaultyDisk, errFaultyRemoteDisk, } var baseIgnoredErrs = baseErrs // Is a one place function which converts all os.PathError // into a more FS object layer friendly form, converts // known errors into their typed form for top level // interpretation. func osErrToFileErr(err error) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/object-api-errors.go
type InvalidUploadID struct { Bucket string Object string UploadID string } func (e InvalidUploadID) Error() string { return "Invalid upload id " + e.UploadID } // InvalidPart One or more of the specified parts could not be found type InvalidPart struct { PartNumber int ExpETag string GotETag string } func (e InvalidPart) Error() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/s3select/select.go
// The queue should always have at least one entry left for this to work. outputQueue = outputQueue[:len(outputQueue)+1] if t := outputQueue[len(outputQueue)-1]; t != nil { // If the output record is already set, we reuse it. outputRecord = t outputRecord.Reset() } else { // Create new one outputRecord = s3Select.outputRecord()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0)