- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for from (0.12 sec)
-
cmd/erasure-common.go
for _, i := range r.Perm(len(disks)) { if disks[i] != nil && disks[i].IsLocal() { newDisks = append(newDisks, disks[i]) } } return newDisks } // readMultipleFiles Reads raw data from all specified files from all disks. func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) { resps := make([]chan ReadMultipleResp, len(disks)) for i := range resps {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/bucket/lifecycle/rule.go
return r.NoncurrentVersionTransition.Validate() } // GetPrefix - a rule can either have prefix under <rule></rule>, <filter></filter> // or under <filter><and></and></filter>. This method returns the prefix from the // location where it is available. func (r Rule) GetPrefix() string { if p := r.Prefix.String(); p != "" { return p } if p := r.Filter.Prefix.String(); p != "" { return p }
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) -
buildscripts/minio-iam-ldap-upgrade-import-test.sh
#!/bin/bash # This script is used to test the migration of IAM content from old minio # instance to new minio instance. # # To run it locally, start the LDAP server in github.com/minio/minio-iam-testing # repo (e.g. make podman-run), and then run this script. # # This script assumes that LDAP server is at: # # `localhost:1389` # # if this is not the case, set the environment variable # `_MINIO_LDAP_TEST_SERVER`.
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 3.4K bytes - Viewed (0) -
internal/logger/console.go
quiet(msg string, args ...interface{}) pretty(msg string, args ...interface{}) } func consoleLog(console Logger, msg string, args ...interface{}) { switch { case jsonFlag: // Strip escape control characters from json message msg = ansiRE.ReplaceAllLiteralString(msg, "") console.json(msg, args...) case quietFlag: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/http/transports.go
Proxy: http.ProxyFromEnvironment, DialContext: dialContext, MaxIdleConnsPerHost: maxIdleConnsPerHost, WriteBufferSize: 64 << 10, // 64KiB moving up from 4KiB default ReadBufferSize: 64 << 10, // 64KiB moving up from 4KiB default IdleConnTimeout: 15 * time.Second, ResponseHeaderTimeout: 15 * time.Minute, // Conservative timeout is the default (for MinIO internode)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
func (h *metricsV3Server) ServeHTTP(w http.ResponseWriter, r *http.Request) { pathComponents := mux.Vars(r)["pathComps"] isListingRequest := r.Form.Has("list") buckets := []string{} if strings.HasPrefix(pathComponents, "/bucket/") { // bucket specific metrics, extract the bucket name from the path. // it's the last part of the path. e.g. /bucket/api/<bucket-name> bucketIdx := strings.LastIndex(pathComponents, "/")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
docs/ftp/README.md
``` --ftp="tls-private-key=path/to/private.key" --ftp="tls-public-cert=path/to/public.crt" ``` > NOTE: if MinIO distributed setup is already configured to run under TLS, FTP will automatically use the relevant > certs from the server certificate chain, this is mainly to add simplicity of setup. However if you wish to terminate > TLS certificates via a different domain for your FTP servers you may choose the above command line options.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/http/listener.go
} } // Start separate goroutine for each TCP listener to handle connection. for idx, tcpListener := range listener.listeners { go handleListener(idx, tcpListener) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result, ok := <-listener.acceptCh: if ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
docs/distributed/CONFIG.md
- "https://server3-pool1:9000/mnt/disk{1...4}/" - "https://server4-pool1:9000/mnt/disk{1...4}/" set-drive-count: 4 # Advanced option, must be used under guidance from MinIO team. ``` ### Things to know - Fields such as `version` and `pools` are mandatory, however all other fields are optional.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/os-reliable.go
case osIsNotExist(err): return errFileNotFound case osIsExist(err): // This is returned only when destination is a directory and we // are attempting a rename from file to directory. return errIsNotRegular default: return err } } return nil } // Reliably retries os.RenameAll if for some reason os.RenameAll returns
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0)