- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 65 for phases (0.14 sec)
-
internal/arn/arn.go
arnPrefixArn, arn.Partition, arn.Service, arn.Region, "", // account-id is always empty in this implementation arn.ResourceType + "/" + arn.ResourceID, }, ":", ) } // Parse - parses an ARN string into a type. func Parse(arnStr string) (arn ARN, err error) { ps := strings.Split(arnStr, ":") if len(ps) != 6 || ps[0] != string(arnPrefixArn) { err = errors.New("invalid ARN string format") return }
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) -
docs/sts/client-grants.go
"crypto/tls" "encoding/json" "flag" "fmt" "log" "net/http" "net/url" "strings" minio "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" ) // JWTToken - parses the output from IDP id_token. type JWTToken struct { AccessToken string `json:"access_token"` Expiry int `json:"expires_in"` } var ( stsEndpoint string idpEndpoint string clientID string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 3.3K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
return true } if !rule.Transition.IsNull() { // this allows for Transition.Days to be zero. return true } } return false } // ParseLifecycleConfigWithID - parses for a Lifecycle config and assigns // unique id to rules with empty ID. func ParseLifecycleConfigWithID(r io.Reader) (*Lifecycle, error) { var lc Lifecycle if err := xml.NewDecoder(r).Decode(&lc); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/store/queuestore_test.go
t.Fatal("Failed to put to queue store ", err) } } // Should not allow 6th Put. if err := store.Put(testItem); err == nil { t.Fatalf("Expected to fail with %s, but passes", errLimitExceeded) } } // TestQueueStoreLimit - tests for store.LimitN. func TestQueueStoreListN(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/generic-handlers.go
} // Supported Amz date headers. var amzDateHeaders = []string{ // Do not change this order, x-amz-date value should be // validated first. "x-amz-date", "date", } // parseAmzDateHeader - parses supported amz date headers, in // supported amz date formats. func parseAmzDateHeader(req *http.Request) (time.Time, APIErrorCode) { for _, amzDateHeader := range amzDateHeaders {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/bucket-encryption.go
func (sys *BucketSSEConfigSys) Get(bucket string) (*sse.BucketSSEConfig, error) { sseCfg, _, err := globalBucketMetadataSys.GetSSEConfig(bucket) return sseCfg, err } // validateBucketSSEConfig parses bucket encryption configuration and validates if it is supported by MinIO. func validateBucketSSEConfig(r io.Reader) (*sse.BucketSSEConfig, error) { encConfig, err := sse.ParseBucketSSEConfig(r) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 1.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
type DeadlineWriter struct { io.WriteCloser timeout time.Duration err error } // WithDeadline will execute a function with a deadline and return a value of a given type. // If the deadline/context passes before the function finishes executing, // the zero value and the context error is returned.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/data-usage-cache.go
hash := hashPath(path) if d.Cache == nil { d.Cache = make(map[string]dataUsageEntry, 100) } d.Cache[hash.Key()] = e if parent != "" { phash := hashPath(parent) p := d.Cache[phash.Key()] p.addChild(hash) d.Cache[phash.Key()] = p } } // replaceHashed add or replaces an entry to the cache based on its hash. // If a parent is specified it will be added to that if not already there.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
internal/bucket/replication/replication.go
// RoleArn is being reused for MinIO replication ARN RoleArn string `xml:"Role" json:"Role"` } // Maximum 2MiB size per replication config. const maxReplicationConfigSize = 2 << 20 // ParseConfig parses ReplicationConfiguration from xml func ParseConfig(reader io.Reader) (*Config, error) { config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxReplicationConfigSize)).Decode(&config); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/crypto/sse-s3.go
// Return only true if the SSE header is specified and does not contain the SSE-KMS value return ok && !strings.EqualFold(h.Get(xhttp.AmzServerSideEncryption), xhttp.AmzEncryptionKMS) } // ParseHTTP parses the SSE-S3 related HTTP headers and checks // whether they contain valid values. func (sses3) ParseHTTP(h http.Header) error { if h.Get(xhttp.AmzServerSideEncryption) != xhttp.AmzEncryptionAES {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.5K bytes - Viewed (0)