- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 67 for matches (0.28 sec)
-
internal/grid/handlers.go
func NewRemoteErrString(msg string) *RemoteErr { r := RemoteErr(msg) return &r } func (r RemoteErr) Error() string { return string(r) } // Is returns if the string representation matches. func (r *RemoteErr) Is(other error) bool { if r == nil || other == nil { return r == other } var o RemoteErr if errors.As(other, &o) { return r == &o } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/site-replication.go
return true } // isIAMPolicyReplicated returns true if count of replicated IAM policies matches total // number of sites and IAM policies are identical. func isIAMPolicyReplicated(cntReplicated, total int, policies []*policy.Policy) bool { if cntReplicated > 0 && cntReplicated != total { return false } // check if policies match between sites var prev *policy.Policy for i, p := range policies { if i == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/bucket-replication.go
const ( replicateMetadata replicationAction = "metadata" replicateNone replicationAction = "none" replicateAll replicationAction = "all" ) // matches k1 with all keys, returns 'true' if one of them matches func equals(k1 string, keys ...string) bool { for _, k2 := range keys { if strings.EqualFold(k1, k2) { return true } } return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/signature-v4.go
} // doesPolicySignatureMatch - Verify query headers with post policy // - http://docs.aws.amazon.com/AmazonS3/latest/API/sigv4-HTTPPOSTConstructPolicy.html // // returns ErrNone if the signature matches. func doesPolicySignatureV4Match(formValues http.Header) (auth.Credentials, APIErrorCode) { // Server region. region := globalSite.Region // Parse credential tag.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/object-handlers-common.go
return true } } // If-None-Match : Return the object only if its entity tag (ETag) is different from the // one specified otherwise, return a 304 (not modified). ifNoneMatchETagHeader := r.Header.Get(xhttp.AmzCopySourceIfNoneMatch) if ifNoneMatchETagHeader != "" { if isETagEqual(objInfo.ETag, ifNoneMatchETagHeader) { // If the object ETag matches with the specified ETag. writeHeaders()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
ch3 := make(chan Maskable, 1) doneCh := make(chan struct{}) defer close(doneCh) // Mask matches maskString, should get result if err := ps.Subscribe(Mask(1), ch1, doneCh, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err) } // Mask matches maskString, should get result
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-cluster.json
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:15:39 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/store/batch.go
b.Lock() defer b.Unlock() if b.isFull() { return ErrBatchFull } if _, ok := b.items[key]; !ok { b.keys = append(b.keys, key) } b.items[key] = item return nil } // GetAll fetches the items and resets the batch // Returned items are not referenced by the batch func (b *Batch[K, T]) GetAll() (orderedKeys []K, orderedItems []T, err error) { b.Lock() defer b.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
cmd/iam-store.go
// layer. type IAMStoreSys struct { IAMStorageAPI } // HasWatcher - returns if the storage system has a watcher. func (store *IAMStoreSys) HasWatcher() bool { _, ok := store.IAMStorageAPI.(iamStorageWatcher) return ok } // GetUser - fetches credential from memory. func (store *IAMStoreSys) GetUser(user string) (UserIdentity, bool) { cache := store.rlock() defer store.runlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/bucket-versioning.go
vc, err := sys.Get(bucket) if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.Suspended() } // PrefixSuspended returns true if the given prefix matches an excluded prefix // pattern. This is part of a MinIO versioning configuration extension. func (sys *BucketVersioningSys) PrefixSuspended(bucket, prefix string) bool { vc, err := sys.Get(bucket) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 2.6K bytes - Viewed (0)