- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Bell (0.14 sec)
-
cmd/admin-handlers-site-replication.go
opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true" return } // SRPeerJoin - PUT /minio/admin/v3/site-replication/join // // used internally to tell current cluster to enable SR with // the provided peer clusters and service account. func (a adminAPIHandlers) SRPeerJoin(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0) -
internal/rest/client.go
// to explicitly say that the ContentLength is zero is // to set the Body to nil. But turns out too much code // depends on NewRequest returning a non-nil Body, // so we use a well-known ReadCloser variable instead // and have the http package also treat that sentinel // variable to mean explicitly zero. if req.GetBody != nil && req.ContentLength == 0 { req.Body = http.NoBody
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
cmd/common-main.go
logger.Fatal(errors.New("ambiguous KMS configuration"), fmt.Sprintf("The environment contains %q as well as %q", kms.EnvKESAPIKey, kms.EnvKESClientKey)) } if env.IsSet(kms.EnvKESClientCert) { logger.Fatal(errors.New("ambiguous KMS configuration"), fmt.Sprintf("The environment contains %q as well as %q", kms.EnvKESAPIKey, kms.EnvKESClientCert)) } } if !env.IsSet(kms.EnvKESKeyName) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 00:34:45 GMT 2024 - 35.5K bytes - Viewed (2) -
cmd/admin-handlers-config-kv.go
if err := applyDynamicConfigForSubSys(GlobalContext, objectAPI, cfg, subSys); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } globalNotificationSys.SignalConfigReload(subSys) // Tell the client that dynamic config was applied. w.Header().Set(madmin.ConfigAppliedHeader, madmin.ConfigAppliedTrue) } type badConfigErr struct { Err error } // Error - return the error message
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cmd/config-current.go
AccessKey: accessKey, SecretKey: secretKey, } } } // applyDynamicConfig will apply dynamic config values. // Dynamic systems should be in config.SubSystemsDynamic as well. func applyDynamicConfig(ctx context.Context, objAPI ObjectLayer, s config.Config) error { for subSys := range config.SubSystemsDynamic { err := applyDynamicConfigForSubSys(ctx, objAPI, s, subSys) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 30.9K bytes - Viewed (0) -
cmd/storage-rest-server.go
} mw.Flush() } }() err = s.getStorage().ReadMultiple(r.Context(), req, responses) wg.Wait() rw.CloseWithError(err) } // globalLocalSetDrives is used for local drive as well as remote REST // API caller for other nodes to talk to this node. // // Any updates to this must be serialized via globalLocalDrivesMu (locker) var globalLocalSetDrives [][][]StorageAPI
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 44.3K bytes - Viewed (0) -
src/archive/tar/reader_test.go
testRead{1, "", io.ErrUnexpectedEOF}, testRemaining{38, 38}, }, }, { maker: makeReg{"hello, world", 5}, tests: []testFnc{ testRemaining{5, 5}, testRead{0, "", nil}, testRead{4, "hell", nil}, testRemaining{1, 1}, testWriteTo{fileOps{"o"}, 1, nil}, testRemaining{0, 0}, testWriteTo{nil, 0, nil}, testRead{0, "", io.EOF}, }, }, {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Nov 21 21:14:38 GMT 2022 - 47.1K bytes - Viewed (0) -
internal/config/config.go
// letter. At least 2 characters long. var validSiteNameRegex = regexp.MustCompile("^[a-z][a-z0-9-]+$") // LookupSite - get site related configuration. Loads configuration from legacy // region sub-system as well. func LookupSite(siteKV KVS, regionKV KVS) (s Site, err error) { if err = CheckValidKeys(SiteSubSys, siteKV, DefaultSiteKVS); err != nil { return } region := env.Get(EnvRegion, "") if region == "" {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/erasure.go
continue } onlineDisks[ep]++ } rootDiskCount := 0 for _, di := range disksInfo { if di.RootDisk { rootDiskCount++ } } // Count offline disks as well to ensure consistent // reportability of offline drives on local setups. if len(disksInfo) == (rootDiskCount + offlineDisks.Sum()) { // Success. return onlineDisks, offlineDisks }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 10:02:39 GMT 2024 - 16K bytes - Viewed (1) -
cmd/object-handlers-common.go
if objInfo.VersionID != "" && objInfo.VersionID != nullVersionID { w.Header()[xhttp.AmzVersionID] = []string{objInfo.VersionID} // If version is a deleted marker, set this header as well if objInfo.DeleteMarker && delete { // only returned during delete object w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(objInfo.DeleteMarker)} } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0)