- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for loom (0.23 sec)
-
internal/s3select/sql/jsonpath.go
package sql import ( "errors" "github.com/bcicen/jstream" "github.com/minio/simdjson-go" ) var ( errKeyLookup = errors.New("Cannot look up key in non-object value") errIndexLookup = errors.New("Cannot look up array index in non-array value") errWildcardObjectLookup = errors.New("Object wildcard used on non-object value")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
internal/disk/stat_linux.go
if firstTime { bfs, err := blockdevice.NewDefaultFS() if err == nil { devName := "" diskstats, _ := bfs.ProcDiskstats() for _, dstat := range diskstats { // ignore all loop devices if strings.HasPrefix(dstat.DeviceName, "loop") { continue } if dstat.MajorNumber == info.Major && dstat.MinorNumber == info.Minor { devName = dstat.DeviceName break } } if devName != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/license-update.go
// will keep performing the license update. If the leader goes down for some // reason, the lock will be released and another node will acquire it and // take over because of this loop. for { licenceUpdaterLoop(ctx, objAPI) // license update stopped for some reason. // sleep for some time and try again. duration := time.Duration(r.Float64() * float64(time.Hour))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
helm/minio/templates/_helper_create_svcacct.txt
# Special characters for example : ',",<,>,{,} MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_svcacct_tmp" # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 23:20:50 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/erasure-object.go
} written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer) // Note: we should not be defer'ing the following closeBitrotReaders() call as // we are inside a for loop i.e if we use defer, we would accumulate a lot of open files by the time // we return from this function. closeBitrotReaders(readers) if err != nil { // If we have successfully written all the content that was asked
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) -
internal/config/identity/openid/jwt.go
if !ok { return errors.New("STS JWT Token has `aud` claim invalid, `aud` must match configured OpenID Client ID") } if !audValues.Contains(pCfg.ClientID) { // if audience claims is missing, look for "azp" claims. // OPTIONAL. Authorized party - the party to which the ID // Token was issued. If present, it MUST contain the OAuth // 2.0 Client ID of this party. This Claim is only needed
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5) -
cmd/signature-v4-utils.go
return hex.EncodeToString(sum256[:]) } var ( defaultSha256Cksum string v []string ok bool ) // For a presigned request we look at the query param for sha256. if isRequestPresignedSignatureV4(r) { // X-Amz-Content-Sha256, if not set in presigned requests, checksum // will default to 'UNSIGNED-PAYLOAD'. defaultSha256Cksum = unsignedPayload
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
docs/sts/web-identity.md
2018/12/26 17:49:36 listening on http://localhost:8080/ ``` > NOTE: for a reasonable test outcome, make sure the assumed user has at least permission/policy to list all buckets. That policy would look like below: ``` { "version": "2012-10-17", "statement": [ { "effect": "Allow", "action": [ "s3:ListAllMyBuckets" ], "resource": [
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/erasure-server-pool.go
return z.serverPools[poolIdx].CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts) } // Destination is versioned, source is not destination version, // as a special case look for if the source object is not legacy // from older format, for older format we will rewrite them as // newer using PutObject() - this is an optimization to save space
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/handlers/proxy.go
// match should contain at least two elements if the protocol was // specified in the Forwarded header. The first element will always be // the 'for=', which we ignore, subsequently we proceed to look for // 'proto=' which should precede right after `for=` if not // we simply ignore the values and return empty. This is in line // with the approach we took for returning first ip from multiple // params.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0)