- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 107 for intro (0.13 sec)
-
cmd/erasure-object.go
} // DeleteObjects deletes objects/versions in bulk, this function will still automatically split objects list // into smaller bulks if some object names are found to be duplicated in the delete list, splitting // into smaller bulks will avoid holding twice the write lock of the duplicated object names.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/server_test.go
c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // data to be written into buffer. data := "1234567890" // seed the random number generator once. rand.Seed(3) // generate a random number between 13 and 200. randInt := getRandomRange(13, 200, -1) // write into buffer till length of the buffer is greater than the generated random number. for i := 0; i <= randInt; i += 10 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/data-usage_test.go
objs: 3, oSizes: sizeHistogram{0: 1, 1: 2}, }, { path: "bucket/newfolder", size: 5, objs: 3, oSizes: sizeHistogram{0: 3}, }, { // Compacted into bucket/dir1 path: "bucket/dir1/dira", isNil: true, }, { path: "bucket/nonexistying", isNil: true, }, } for _, w := range want { t.Run(w.path, func(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/globals.go
GlobalKMS kms.KMS // Common lock for various subsystems performing the leader tasks globalLeaderLock *sharedLock // Auto-Encryption, if enabled, turns any non-SSE-C request // into an SSE-S3 request. If enabled a valid, non-empty KMS // configuration must be present. globalAutoEncryption bool // Is compression enabled? globalCompressConfigMu sync.Mutex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/iam.go
return errServerNotInitialized } return sys.store.PolicyNotificationHandler(ctx, policyName) } // LoadPolicyMapping - loads the mapped policy for a user or group // from storage into server memory. func (sys *IAMSys) LoadPolicyMapping(ctx context.Context, objAPI ObjectLayer, userOrGroup string, userType IAMUserType, isGroup bool) error { if !sys.Initialized() { return errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/metrics-v2.go
ch := make(chan prometheus.Metric) go func() { defer xioutil.SafeClose(ch) // Collects prometheus metrics from hist and sends it over ch hist.Collect(ch) }() // Converts metrics received into internal []Metric type var metrics []MetricV2 for promMetric := range ch { dtoMetric := &dto.Metric{} err := promMetric.Write(dtoMetric) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/config/bool-flag.go
func (bf BoolFlag) String() string { if bf { return "on" } return "off" } // MarshalJSON - converts BoolFlag into JSON data. func (bf BoolFlag) MarshalJSON() ([]byte, error) { return json.Marshal(bf.String()) } // UnmarshalJSON - parses given data into BoolFlag. func (bf *BoolFlag) UnmarshalJSON(data []byte) (err error) { var s string if err = json.Unmarshal(data, &s); err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 07 15:10:40 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/bucket/lifecycle/delmarker-expiration.go
// Used to detect if lifecycle.Rule contained a DelMarkerExpiration element. func (de DelMarkerExpiration) Empty() bool { return de.Days == 0 } // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error { type delMarkerExpiration DelMarkerExpiration var dexp delMarkerExpiration
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/bpool/bpool.go
return } // Put returns the given Buffer to the BytePool. func (bp *BytePoolCap) Put(b []byte) { if bp == nil { return } select { case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
// IsValid - returns true if input string is a valid // storage class kind supported. func IsValid(sc string) bool { return sc == RRS || sc == STANDARD } // UnmarshalText unmarshals storage class from its textual form into // storageClass structure. func (sc *StorageClass) UnmarshalText(b []byte) error { scStr := string(b) if scStr == "" { return nil } s, err := parseStorageClass(scStr) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (1)