- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for isObject (0.21 sec)
-
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 May 05 19:28:20 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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return true default: return false } } var versionsFound int if err = set.listObjectsToDecommission(ctx, bi, func(entry metaCacheEntry) { if !entry.isObject() { return } fivs, err := entry.fileInfoVersions(bi.Name) if err != nil { return } // We need a reversed order for decommissioning,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
internal/event/target/nats_tls_contrib_test.go
defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", Secure: true, CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"), } con, err := clientConfig.connectNats() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.1K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package bandwidth import ( "context" "io" "math" ) // MonitoredReader represents a throttled reader subject to bandwidth monitoring type MonitoredReader struct { r io.Reader throttle *bucketThrottle ctx context.Context // request context
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/test-utils_test.go
if err != nil { return nil, nil, fmt.Errorf("failed to generate serial number: %w", err) } template := x509.Certificate{ SerialNumber: serialNumber, Subject: pkix.Name{ Organization: []string{"Acme Co"}, }, NotBefore: notBefore, NotAfter: notAfter, KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
docs/sts/web-identity.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 May 05 19:28:20 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
schema/relationship_test.go
ID uint `gorm:"primary_key"` Locale string `gorm:"primary_key"` Value string } type Blog struct { ID uint `gorm:"primary_key"` Locale string `gorm:"primary_key"` Subject string Body string Tags []Tag `gorm:"many2many:blog_tags;"` SharedTags []Tag `gorm:"many2many:shared_blog_tags;ForeignKey:id;References:id"`
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 15 03:20:20 GMT 2024 - 25.5K bytes - Viewed (0) -
internal/event/target/nats.go
if target.args.Streaming.Async { _, err = target.stanConn.PublishAsync(target.args.Subject, data, nil) } else { err = target.stanConn.Publish(target.args.Subject, data) } } else { if target.jstream != nil { _, err = target.jstream.Publish(target.args.Subject, data) } else { err = target.natsConn.Publish(target.args.Subject, data) } } return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0)