- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for isObject (0.2 sec)
-
cmd/metacache-set.go
continue } if !strings.HasPrefix(entry.name, o.Prefix) { continue } if !o.Recursive && !entry.isInDir(o.Prefix, o.Separator) { continue } if !o.InclDeleted && entry.isObject() && entry.isLatestDeletemarker() && !entry.isObjectDir() { continue } if o.Lifecycle != nil || o.Replication.Config != nil { if skipped := triggerExpiryAndRepl(ctx, *o, entry); skipped == true {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/metacache-entries.go
// isDir returns if the entry is representing a prefix directory. func (e metaCacheEntry) isDir() bool { return len(e.metadata) == 0 && strings.HasSuffix(e.name, slashSeparator) } // isObject returns if the entry is representing an object. func (e metaCacheEntry) isObject() bool { return len(e.metadata) > 0 } // isObjectDir returns if the entry is representing an object/ func (e metaCacheEntry) isObjectDir() bool {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/metacache-stream.go
if !next.hasPrefix(prefix) { return metaCacheEntriesSorted{}, io.EOF } if r.current.name != "" { if (inclDeleted || !r.current.isLatestDeletemarker()) && r.current.hasPrefix(prefix) && (inclDirs || r.current.isObject()) { res = append(res, r.current) } r.current.name = "" r.current.metadata = nil } for n < 0 || len(res) < n { if more, err := r.mr.ReadBool(); !more { switch err { case nil:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
docs/LICENSE
Using Creative Commons Public Licenses Creative Commons public licenses provide a standard set of terms and conditions that creators and other rights holders may use to share original works of authorship and other material subject to copyright and certain other rights specified in the public license below. The following considerations are for informational purposes only, are not exhaustive, and do not form part of our licenses.
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon May 10 16:50:06 GMT 2021 - 18.2K bytes - Viewed (0) -
cmd/sts-handlers.go
expiry = validUntil } // Associate any service accounts to the certificate CN parentUser := "tls:" + certificate.Subject.CommonName claims[expClaim] = UTCNow().Add(expiry).Unix() claims[subClaim] = certificate.Subject.CommonName claims[audClaim] = certificate.Subject.Organization claims[issClaim] = certificate.Issuer.CommonName claims[parentClaim] = parentUser secretKey, err := getTokenSigningKey()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 18:36:18 GMT 2024 - 34.7K bytes - Viewed (2) -
internal/config/identity/openid/provider/provider.go
JwksURI string `json:"jwks_uri,omitempty"` ResponseTypesSupported []string `json:"response_types_supported,omitempty"` SubjectTypesSupported []string `json:"subject_types_supported,omitempty"` IDTokenSigningAlgValuesSupported []string `json:"id_token_signing_alg_values_supported,omitempty"` ScopesSupported []string `json:"scopes_supported,omitempty"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/config/notify/legacy.go
Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.NATSAddress, Value: cfg.Address.String(), }, config.KV{ Key: target.NATSSubject, Value: cfg.Subject, }, config.KV{ Key: target.NATSUsername, Value: cfg.Username, }, config.KV{ Key: target.NATSUserCredentials, Value: cfg.UserCredentials, }, config.KV{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnUserPass(t *testing.T) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.3K bytes - Viewed (0) -
docs/bucket/notifications/README.md
``` KEY: notify_nats[:name] publish bucket notifications to NATS endpoints ARGS: address* (address) NATS server address e.g. '0.0.0.0:4222' subject* (string) NATS subscription subject username (string) NATS username password (string) NATS password token (string) NATS token
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
internal/config/notify/help.go
Description: "NATS server address e.g. '0.0.0.0:4222'", Type: "address", Sensitive: true, }, config.HelpKV{ Key: target.NATSSubject, Description: "NATS subscription subject", Type: "string", }, config.HelpKV{ Key: target.NATSUsername, Description: "NATS username", Optional: true, Type: "string", Sensitive: true, },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0)