- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for Peters (0.29 sec)
-
cmd/global-heal.go
retErr = err healingLogIf(ctx, err) continue } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue } rcfg, err = getReplicationConfig(ctx, bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
internal/arn/arn.go
) // ARN - representation of resources based on AWS ARNs. type ARN struct { Partition string Service string Region string ResourceType string ResourceID string } // Allows english letters, numbers, '.', '-', '_' and '/'. Starts with a // letter or digit. At least 1 character long. var validResourceIDRegex = regexp.MustCompile(`[A-Za-z0-9_/\.-]+$`) // NewIAMRoleARN - returns an ARN for a role in MinIO.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 08:31:34 GMT 2024 - 3.5K bytes - Viewed (0) -
cmd/metacache-set.go
//msgp:ignore metaCacheRPC type metaCacheRPC struct { o listPathOptions mu sync.Mutex meta *metacache rpc *peerRESTClient cancel context.CancelFunc } func (m *metaCacheRPC) setErr(err string) { m.mu.Lock() defer m.mu.Unlock() meta := *m.meta if meta.status != scanStateError { meta.error = err meta.status = scanStateError } else { // An error is already set. return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
docs/LICENSE
the Licensor (including by pseudonym if designated); ii. a copyright notice; iii. a notice that refers to this Public License; iv. a notice that refers to the disclaimer of warranties; v. a URI or hyperlink to the Licensed Material to the extent reasonably practicable;
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon May 10 16:50:06 GMT 2021 - 18.2K bytes - Viewed (0) -
cmd/admin-handlers.go
// expected in case of read timeout w.Header().Set("Connection", "close") setEventStreamHeaders(w) logCh := make(chan log.Info, 1000) peers, _ := newPeerRestClients(globalEndpoints) encodedCh := make(chan []byte, 1000+len(peers)*1000) err = globalConsoleSys.Subscribe(logCh, ctx.Done(), node, limitLines, logKind, nil) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/admin-handlers_test.go
if err != nil { t.Fatal("Failed to initialize a single node Erasure backend for admin handler tests.", err) } defer adminTestBed.TearDown() // Initialize admin peers to make admin RPC calls. Note: In a // single node setup, this degenerates to a simple function // call under the hood. globalMinioAddr = "127.0.0.1:9000" var wg sync.WaitGroup
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/config/config.go
type Site struct { Name string Region string } var validRegionRegex = regexp.MustCompile("^[a-zA-Z][a-zA-Z0-9-_-]+$") // validSiteNameRegex - allows lowercase letters, digits and '-', starts with // letter. At least 2 characters long. var validSiteNameRegex = regexp.MustCompile("^[a-z][a-z0-9-]+$") // LookupSite - get site related configuration. Loads configuration from legacy
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/utils.go
strl := len(str) // short-circuit empty strings if xfixl == 0 || strl == 0 { return "" } // maximum possible length maxl := xfixl if strl < maxl { maxl = strl } // compare letters if pre { // prefix, iterate left to right for i := 0; i < maxl; i++ { if xfix[i] != str[i] { xfix = xfix[:i] break } } } else { // suffix, iterate right to left
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
internal/config/errors-utils.go
if errors.Is(err, syscall.EADDRINUSE) { return ErrPortAlreadyInUse(err).Msg("Specified port is already in use") } else if errors.Is(err, syscall.EACCES) || errors.Is(err, syscall.EPERM) { if netErr, ok := err.(*net.OpError); ok { return ErrPortAccess(netErr).Msg("Insufficient permissions to use specified port") } } // Failed to identify what type of error this, return a simple UI error return Err{msg: err.Error()} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/bucket-metadata.go
// BucketMetadata contains bucket metadata. // When adding/removing fields, regenerate the marshal code using the go generate above. // Only changing meaning of fields requires a version bump. // bucketMetadataFormat refers to the format. // bucketMetadataVersion can be used to track a rolling upgrade of a field. type BucketMetadata struct { Name string Created time.Time
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 16.5K bytes - Viewed (0)